'''
Palringo Python Bot Developed by Ariel Saldana (Palringo ID 2015666)
'''

#!/usr/bin/python3.4

__author__ = "Ariel Saldana"
__copyright__ = "Copyright 2015, An Ariel / Unreal Project"
__credits__ = ["Ariel Saldana"]
__license__ = "MIT"
__version__ = "0.1"
__maintainer__ = "Ariel Saldana"
__email__ = "[email protected]"
__status__ = "Production"



#from PIL import Image PIL IMAGE
import io
#import speex
import sys
import socket
import threading
from PacketTemplate import *
from Salsa20 import *
import Parser
import time
import datetime
import re ##regex
import urllib
import json

def clock():
    while True:
        parser = Parser.Parser()
        print("test working")
        try:
            parser.sendGroupMessage(47, '!typing')
        except:
            pass
        time.sleep(4)

def main():
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_address = ('80.69.129.4',12345);
    print('Attempting to connect to the server')
    try:
        sock.connect(server_address)
    except:
        raise Exception('Error Connecting to the server')

    print('Connected succesfully')
    #typingBotThread = threading.Thread(target=clock)
    #typingBotThread.start()
    try:
        parser = Parser.Parser()
        parser.bind(sock, False)
        parser.sendLogon('[email protected]')
        passwd = "password"

        amount_received = 0

        while True:
            data = sock.recv(65535)
            thr = threading.Thread(group=None, target=parser.ParsePacket, name=None, args=[(data)])
            ## pass our socket object to the parser class
            ## parse our data
            #parser.ParsePacket(data)
            thr.start()
            #e = speex.Encoder()
            #thr.is_alive() # will return whether foo is running currently
            #thr.join() # will wait till "foo" is donedef foo():

            if len(data) == 0:
                break

            else:
                if ( parser.getCommand() == 'GroupMESG'):

                    '''
                    s = ''.join(
                        ["MESG\r\n",
                         "Content-length: %s\r\n" % (str(len(parser.getPayload()))),
                         "Content-type: image/jpeghtml\r\n",
                         "mesg-id: 666\r\n",
                         "mesg-target: 1\r\n",
                         "target-id: %s\r\n\r\n%s"]) % (str(parser.getTargetID()), parser.getPayload())
                    rawPacket = s.encode('raw-unicode-escape')

                    sock.sendall(rawPacket)
                    '''





                    if (parser.getPayload().lower() == 'about'):
                        parser.sendGroupMessage(parser.getTargetID(), 'This bots source code was modified, to contact the owner add him on skype!')

                    if ("lol" in parser.getPayload().lower()):
                        parser.sendGroupMessage(parser.getTargetID(), 'U wot m8')

                    if ("masa" in parser.getPayload().lower()):
                        parser.sendGroupMessage(parser.getTargetID(), 'Masa is the best :D')

                    if ("papi" in parser.getPayload().lower()):
                        parser.sendGroupMessage(parser.getTargetID(), 'papi is awesome')

                    if ( "test12345" in parser.getPayload().lower() and parser.getSourceID() == 4604623 ):
                        parser.sendGroupMessage(parser.getTargetID(), 'hi') if parser.getSourceID() == 4604623 False else parser.sendGroupMessage(parser.getTargetID(), 'kys'


                    ## if jesse talks
                    #if ( parser.getSourceID() == 4604623 ):
                        #print("Jesse")

                    m = re.search('<p class="dictionary_word">(.*?)</p>', parser.getPayload())
                    l = re.search('    (.*?)    ', parser.getPayload())
                    if m:
                        parser.sendGroupMessage(parser.getTargetID(), m.group(1))
                    if l:
                        parser.sendGroupMessage(parser.getTargetID(), l.group(1))



                elif ( parser.getCommand() == 'PrivMESG'):
                    parser.sendPrivateMessage(parser.getSourceID(), "Do NOT message me here!")

                elif (parser.getCommand() == 'AUTH'):
                    parser.sendAuth(passwd)

                elif ( parser.getCommand() == 'P'):
                    parser.sendPing()

    finally:
        print('closing the socket')
        sock.close()



if __name__ == '__main__':
    main()