#!/usr/bin/python
# -*- coding: utf-8 -*-

# --------------------------------------------------------------------------- #
#                                                                             #
#    Plugin for iSida Jabber Bot                                              #
#    Copyright (C) diSabler <dsy@dsy.name>                                    #
#                                                                             #
#    This program is free software: you can redistribute it and/or modify     #
#    it under the terms of the GNU General Public License as published by     #
#    the Free Software Foundation, either version 3 of the License, or        #
#    (at your option) any later version.                                      #
#                                                                             #
#    This program is distributed in the hope that it will be useful,          #
#    but WITHOUT ANY WARRANTY; without even the implied warranty of           #
#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the            #
#    GNU General Public License for more details.                             #
#                                                                             #
#    You should have received a copy of the GNU General Public License        #
#    along with this program.  If not, see <http://www.gnu.org/licenses/>.    #
#                                                                             #
# --------------------------------------------------------------------------- #

spy_stat_time = int(time.time())    # время последнего сканирования

#conf hrs usrs msgs action
def spy_add(text,rn):
    if text == '': return L('what do you want to add?',rn)
    text = text.lower()
    sconf = text.split(' ')[0]
    try: saction = text.split(' ',1)[1]
    except: return L('not given tracking',rn)
    for tmp in saction.split(' '):
        if tmp[0] != 'u' and tmp[0] != 'm':
            return L('is not specified criterion tracking',rn)
        try: int(tmp[1:])
        except: return L('incorrect digital parameter',rn)
    if sconf not in [t[0] for t in cur_execute_fetchone('select room from conference;')]: return L('I am not in the %s ',rn) % sconf
    if cur_execute_fetchone('select room from spy where room=%s;',(sconf,)):
        msg = L('Updated: %s',rn) % text
        cur_execute('delete from spy where room=%s;',(sconf,))
    else: msg = L('Append: %s',rn) % text
    cnt = len(['' for t in megabase if t[0]==tmp[0]])
    cur_execute('insert into spy values (%s,%s,%s,%s,%s)',(sconf,int(time.time()),cnt,0,saction))
    return msg

def spy_del(text,rn):
    if text == '': return L('what do you want remove?',rn)
    text = text.lower().split(' ')[0]
    if cur_execute_fetchone('select room from spy where room=%s;',(text,)):
        cur_execute('delete from spy where room=%s;',(text,))
        return L('Removed: %s',rn) % text
    else: return L('Not found: %s',rn) % text

def spy_show(rn):
    sb = cur_execute_fetchall('select * from spy;')
    if not sb: return L('List is empty.')
    msg = L('Monitoring conferences:',rn)
    msg += '\n%s' % '\n'.join(['%s %s (%s|u%s|m%s)' % (tmp[0],tmp[4],un_unix(int(time.time()-tmp[1]),rn),tmp[2],tmp[3]) for tmp in sb])
    msg += L('\nNext scanning across %s',rn) % un_unix(int(GT('scan_time')-(time.time()-spy_stat_time)),rn)
    return msg

def conf_spy(type, jid, nick,text):
    text = text.strip().lower()
    rn = '%s/%s'%(jid,nick)
    msg = None
    if text.startswith('add '): msg = spy_add(text[4:],rn)
    elif text.startswith('del '): msg = spy_del(text[4:],rn)
    elif text == 'show': msg = spy_show(rn)
    if not msg: msg = L('Smoke help about command!',rn)
    send_msg(type, jid, nick, msg)

def spy_message(room,jid,nick,type,text):
    sb = cur_execute_fetchone('select message from spy where room=%s;',(room,))
    if sb: cur_execute('update spy set message=message+1 where room=%s',(room,))

def get_spy_stat():
    global spy_stat_time
    if time.time()-spy_stat_time < GT('scan_time'): return None
    spy_stat_time = time.time()
    sb = cur_execute_fetchone('select room from spy;')
    if sb:
        for tmp in sb:
            cnt = len(['' for t in megabase if t[0]==tmp[0]])
            cur_execute('update spy set participant=(participant+%s)/2 where room=%s',(cnt,tmp[0]))

def spy_action():
    try:
        if cur_execute_fetchone('select count(*) from conference;')[0] == 1: raise
    except: return None # Last conference
    sb = cur_execute_fetchall('select * from spy where %s-time>%s;',(int(time.time()),GT('spy_action_time')))
    for tmp in sb:
        act = tmp[4].split(' ')
        mist = None
        for tmp2 in act:
            if tmp2[0] == 'u' and int(tmp2[1:]) > tmp[2]: mist = tmp2
            elif tmp2[0] == 'm' and int(tmp2[1:]) > tmp[3]: mist = tmp2
            cur_execute('delete from spy where room=%s',(tmp[0],))
            if mist:
                if cur_execute_fetchall('select * from conference where room ilike %s;', ('%s/%%'%getRoom(tmp[0]),)):
                    cur_execute('delete from conference where room ilike %s;', ('%s/%%'%getRoom(tmp[0]),))
                    leave(tmp[0], L('I leave your conference because low activity'))
                    pprint('*** Leave room: %s by spy activity!' % tmp[0],'red')
                    own = cur_execute_fetchall('select * from bot_owner;')
                    if own:
                        for tmpo in own: send_msg('chat', tmpo[0], '', L('I leave conference %s by condition spy plugin: %s') % (tmp[0], mist))
            else: cur_execute('insert into spy values (%s,%s,%s,%s,%s)',(tmp[0],int(time.time()),tmp[2], 0,tmp[4]))

global execute, timer, message_control

timer = [get_spy_stat, spy_action]

message_control = [spy_message]

execute = [(9, 'spy', conf_spy, 2, 'Check conference activity\nspy add <conference>[ u<number>][ m<number>] - add conference to list. u - count users, m - count message per night. At default At least one condition - the bot will leave the conference\nspy del <conference> - remove conference from list\nspy show - show active monitoring.')]