Telegram Integration

[listy]

Hi All!

Today i was played a little with telegram bots and notifications from tactic. Want to share some raw code, to anyone who's interesting.
This trigger on change|sthpw/task

Code:

import telegram
bot = telegram.Bot(token='TOKEN_HERE')


"""
#***LOGGING

from pprint import pformat

assigned_user_chat_id = CHAT_ID_HERE

mess = pformat(input)
message = bot.send_message(chat_id=assigned_user_chat_id, text=mess)

#***LOGGING
"""

def sending_guess(status=None):
    # some code to guess whos should be notified
    send_to_user = False
    send_to_supervisor = False
   
    return send_to_user, send_to_supervisor


def get_users_from_task_sobj(sobj):
    assigned_user = sobj.get('assigned')
    supervisor_user = sobj.get('supervisor')
   
    if assigned_user:
        assigned_user = server.eval("@SOBJECT(sthpw/login['login','{0}'])".format(assigned_user))[0]
    if supervisor_user:
        supervisor_user = server.eval("@SOBJECT(sthpw/login['login','{0}'])".format(supervisor_user))[0]
   
    return assigned_user, supervisor_user

assigned_user, supervisor_user = get_users_from_task_sboj(input['sobject'])

assigned_user_chat_id = None
if assigned_user:
    assigned_user_chat_id = assigned_user['phone_number']

supervisor_user_chat_id = SUPER_CHAT_ID
if supervisor_user:
    supervisor_user_chat_id = supervisor_user['phone_number']


def generate_task_info_message(input, assigned_user):
    message_text = None

    if input['mode'] == 'insert':
        status = input['update_data'].get('status')
       
        task_sobject = input['sobject']
       
        filters = [('code', task_sobject['search_code'])]
        related_sobject = server.query(task_sobject['search_type'], filters, single=True)
               

        message_text = u'{0}: {1}\nПроцесс: {2}\nОписание:{3}\nКатегория: {4}\nПроект: {5}'.format(status, related_sobject['name'], task_sobject['context'],related_sobject['description'],related_sobject['assets_category_code'], task_sobject['project_code'])

    if input['mode'] == 'update':
        status = input['update_data'].get('status')
       
        task_sobject = input['sobject']
       
        filters = [('code', task_sobject['search_code'])]
        related_sobject = server.query(task_sobject['search_type'], filters, single=True)
               
        gallery_link = 'http://SITE/episodes/{}'.format(related_sobject['code'])
       
        assigned_user_title = u'{0} {1}'.format(assigned_user['first_name'], assigned_user['last_name'])
       
        message_text = u'{0}: {1}\nИсполнитель: {2}\nПроцесс: {3}\nПроект: {4}\nГалерея: {5}'.format(status, related_sobject['name'], assigned_user_title, task_sobject['context'], task_sobject['project_code'], gallery_link)

       
    return message_text


message_text = generate_task_info_message(input, assigned_user)

send_to_user, send_to_supervisor = sending_guess()

if message_text:
    # sendging message to supervisor
    if supervisor_user_chat_id and send_to_supervisor:
        message = bot.send_message(chat_id=supervisor_user_chat_id, text=message_text)

    # sendging message to assigned user
    if assigned_user_chat_id and send_to_user:
        message = bot.send_message(chat_id=assigned_user_chat_id, text=message_text)

Also, wanted to ask devs. Does it possible to run telegram bot polling from inside tactic or it is not recommended? It would be great to have ability to access all TACTIC from itself, not through slow xmlrpc api.

---

And some code for mass notifications:

Code:

# **** making mass notification about free episode ****

# first we check if animation or layout isn't assigned, for that we get those tasks
PROCESSES = ['script', 'layout', 'animation']

have_assigned_tasks = False
have_approved_script = False

for process in PROCESSES:
    search_task = Search('sthpw/task')
    search_task.add_sobject_filter(sobject)
    search_task.add_filter('process', process)
   
    task_sobject = search_task.get_sobject()
   
    if task_sobject:
        if process == 'script':
            if task_sobject.get_value('status') in [u'Принят', u'Оплачен']:
                have_approved_script = True
        else:
            if task_sobject.get_value('assigned'):
                have_assigned_tasks = True

   

mess = '{}/{}'.format(have_assigned_tasks, have_approved_script)

# then if we have False/True we create mass notification

# for that, we getting assigned groups of logins
animators_list = []

if not have_assigned_tasks and have_approved_script:
    animators_logins = Search.eval("@SOBJECT(sthpw/login_in_group['login_group','animator'].sthpw/login)")
    for animator_login in animators_logins:
        if animator_login.get_value('phone_number'):
            animators_list.append(animator_login)


# when we have list with logins we can generate mass message
def generate_message(parent_sobject):
    episode_link = 'http://SITE/link/free_to_take_episodes'
    episode_script = parent_sobject.get_value('script')
    episode_name = parent_sobject.get_value('name')
    mess = '<i>Готов к работе:</i><b> {0}</b>\n<a href="{1}">Сценарий</a>\n<a href="{2}">Свободные эпизоды</a>'.format(episode_name, episode_script, episode_link)
   
    return mess

# begin mass sending
for animator in animators_list:
    if animator.get_value('phone_number'):
        try:
            bot.send_message(chat_id=animator.get_value('phone_number'), parse_mode=telegram.ParseMode.HTML, text=generate_message(sobject))
        except:
            mess = 'Message not sent to {0}'.format(animator.get_value('login'))
            bot.send_message(chat_id=CHECK_ID, text=mess)

[Diego]

Hi listy,
nice idea to use telegram! I do a similar thing with rocketchat

I think you don't have to use the xmlrpc API in your trigger, you should be able to do something like:

Code:

from pyasm.search import Search

login = Search.eval("@SOBJECT(sthpw/login['login','dcortassa'])",
                            single=True)
print(login.get_full_email())

[listy]

Hi, Diego.

When i run telegram bot polling script outside of tactic there is the only option - use xmlrpc api.
So thats why i asking about how to run bot, not just sender from inside of TACTIC itself

---

My goal is to make smart messages, where supervisor can push the button from his messenger and for example approve/disapprove task

[Diego]

I see, I misunderstood you question,

what about putting your main script in the tactic script editor or in the custom python_path specified in tactic-conf.xml and then call it from an outside script using the xmlrpc api only to fire up up you main script inside tactic.

The external script would just do:

Code:

server.execute_python_script("path_in_tactic_script_editor/mass_notification", kwargs={'test_arg': 'test'})

this should launch "path_in_tactic_script_editor/mass_notification" server side in tactic.

[remkonoteboom]

When you say "inside TACTIC", do you mean as a library that Python code can access or do you mean to run as a separate thread or do you mean as a separate process running beside TACTIC? How do you "run" this bot? If there is a library that allows for internal running of the bot, then you can access it in process. We do this with numerous interal services. CherryPy is a good example. We also use a sheduler which runs internally, which can fire off threads to do separate tasks.

[listy]

When you say "inside TACTIC", do you mean as a library that Python code can access or do you mean to run as a separate thread or do you mean as a separate process running beside TACTIC?  How do you "run" this bot?  If there is a library that allows for internal running of the bot, then you can access it in process.  We do this with numerous interal services.  CherryPy is a good example.  We also use a sheduler which runs internally, which can fire off threads to do separate tasks.

Hi! Thank you for answering me.
By running inside a TACTIC, I mean running a process that can be started, closed, or restarted by a TACTIC, and this process would have access to all the objects that the current TACTIC server-instance operates on.

At the moment, the bot is running as a separate python process that accesses the tactic through tactic_server_stub via localhost

[remkonoteboom]

If the process is running on a TACTIC server, for any process to have full access to TACTIC, you can simply initialize the process in Batch mode.

ie: test_script.py

import tacticenv
from pyasm.security import Batch
Batch(project_code=project_code)

import sys
project_code = sys.args[1]

from pyasm.search import Search
animators_logins = Search.eval("@SOBJECT(sthpw/login_in_group['login_group','animator'].sthpw/login)")
....


This will run natively and have the same speed as the TACTIC services. You can run this code with a separate thread (TACTIC is thread-safe) or you can run it in a separate process. From what I can tell, this process can be heavy so you would want to run it as a separate process. You can use a native subprocess to run this as a non-blocking daemon.

[listy]

Wow! This is really awesome! I will test it with my Bot

[listy]

Hi, again!

Don't know why, but i have some errors when try to use Search.eval
It puts me to this assert

Code:

def get_login():
    security = Environment.get_security()
    assert security

I have tried to pass login_code to batch, no luck.

In newer version of TACTIC there is also ticket keyword, but it is missing in 4.5
I am doing something wrong?

[remkonoteboom]

The ticket keyword just allows you to reuse login ticket on batch scripts.

The login_code keyword allows you to run as a particular user, however if none is specified, it will run as "admin".

Other than that, if this is run on the TACTIC server, it should just work.

Here is a full script example:

Code:

import tacticenv

from pyasm.security import Batch
from pyasm.search import Search

project_code = "workflow"
Batch(project_code=project_code)

logins = Search.eval("@SOBJECT(login)")
print("logins: ", logins)

This produces:

Code:

python ~/test.py
num jobs:  406