irc-books/bot.py

#!/usr/bin/env python3

import threading
import re
import socket
import sys
from unzipper import unar

class IRCClient():
    HOST="irc.irchighway.net"
    PORT=6667
    NICK="booksbot3321321"
    IDENT="booksbot"
    REALNAME="NotABot"
    IGNORE=["NOTICE","PART","QUIT", "332","333", "372", "353","366", "251", "252", "254", "255","265","266","396"]
    CHANNEL="#ebooks"
    STATUS=""
    OUT_DIR="/tmp"
    TYPE="SEARCH"
    buffer = []
    readbuffer=b''
    NOT_EXITED=True

    joined=False
    connected=False

    def __init__(self,book,extension,t,logging=False,q=None):

        self.TYPE=t
        self.EXTENSION=extension
        self.LOOKING_FOR=book
        self.LOGGING=logging
        self.OUTPUT=q

        self.socket=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.socket.connect( (self.HOST, self.PORT) )
        self.handle_connect()
        nickstr="NICK %s" % self.NICK
        userstr="USER %s %s bla :%s" % (self.IDENT, self.HOST, self.REALNAME)


        self.t=threading.Thread(target=self.handle_read)
        self.t.start()
        self.send_queue(nickstr)
        self.send_queue(userstr)
        self.t.join()

    def handle_connect(self):
        self.log("connected")
        self.STATUS="CONNECTED"
        self.connected=True
        pass

    def handle_close(self):
        self.NOT_EXITED=False
        self.log("closed")
        self.STATUS="DISCONNECTED"
        self.connected=False
        self.socket.close()

    def handle_read(self):
        while self.NOT_EXITED:
            try:
                data=self.socket.recv(1024)
            except e:
                break

            if not (data[-1]==10 and data[-2]==13):
                self.readbuffer+=data
                continue
    
            data=self.readbuffer+data
            data=data.replace(b'\x95', b'').replace(b'0xc2',b'').decode('utf-8','ignore') #purge mojibake
            self.readbuffer=b''
    
            lines=data.splitlines()
    
            for line in lines:
                words=line.split(' ')
                if len(words)<2:
                    continue
                msg_from=words[0]
                comm=words[1]
    
                if comm in self.IGNORE:
                    continue
                if comm=="JOIN":
                    if self.NICK not in msg_from:
                        continue
                    self.STATUS="JOINED"
                    self.log("Joined channel %s" % self.CHANNEL)
                    self.run_query()
                    self.joined=True
                    continue
    
                if comm=="PRIVMSG":
                    if words[2] != self.NICK:
                        continue
                    self.parse_msg(line);
    
                if comm=="PING" or msg_from=="PING":
                    self.pong(line)
                    continue
                if comm=="376": #END MOTD
                    self.join_channel(self.CHANNEL)
                    continue
    
                if not self.joined:
                    continue


    def run_query(self):
        if self.TYPE=="SEARCH":
            self.search(self.LOOKING_FOR)
            return

        self.book(self.LOOKING_FOR)

    def parse_msg(self,msg):
        msg=msg.split(':')[2]
        msg=msg.replace("\x01","")
        if not msg.startswith("DCC"):
            self.log(msg)
            return
        args=msg.replace("DCC SEND ","").split(" ")
        size=int(args.pop())
        port=int(args.pop())
        ip=self.ip_from_decimal(int(args.pop()))
        filename="_".join(args)
        self.STATUS="RECEIVING"

        n=self.netcat(ip,port,size,filename)
        files=unar(n,"/tmp/")

        out=[]
        for f in files:
            if "searchbot" in f.lower():
                out.append(self.list_books(f))

        if self.OUTPUT is not None:
            self.OUTPUT.put(out)
        self.handle_close()

    def list_books(self,f):
        f=open(f,"r")
        lines=f.readlines()
        lines=[l.strip() for l in lines if self.EXTENSION in l.lower() ]
        for l in lines:
            self.log(l)
        return lines

    def netcat(self,ip,port,size,filename):
        s=socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        s.connect((ip,port))
        #s.shutdown(socket.SHUT_WR)
        sizelen=len(str(size))
        fname='%s/%s' % (self.OUT_DIR,filename)
        f=open(fname, 'wb')
        count=0
        while True:
            data = s.recv(1024)
            if len(data)==0:
                self.log("empty")
                break
            count+=len(data)
            f.write(data)
            sys.stdout.write("\r%s/%d" % (str(count).zfill(sizelen),size)) #progress
            if count >= size:
                break

        s.close()
        f.close()
        return fname

    def search(self,book):
        self.log("searching for %s" % book)
        self.send_queue("PRIVMSG %s :@search %s " % (self.CHANNEL,book))

    def pong(self,data):
        msg=data.replace("PING ","")
        self.send_queue("PONG %s" % msg)

    def join_channel(self,channel):
        self.send_queue("JOIN %s" % channel)

    def send_queue(self,msg):
        add=bytes(str(msg),"utf-8")+bytes([13,10])
        self.socket.send(add)
#        self.buffer.append(add)

    def book(self,book):
        self.log("DOWNLOADING  %s" % book)
        self.send_queue("PRIVMSG %s :%s " % (self.CHANNEL,book))

    def who(self):
        self.send_queue("WHO %s" % self.CHANNEL)

    def ip_from_decimal(self,dec):
        return ".".join([ str(int(b,2)) for b in self.b_octets(bin(dec)[2:]) ])

    def b_octets(self,l):
        l=l.zfill(32)
        return [l[0:8],l[8:16],l[16:24],l[24:32]]

    def log(self,val):
        if self.LOGGING:
            print(val)

if __name__ == "__main__":
    if len(sys.argv)!=3:
        print("USAGE: %s <BOOK> <FORMAT>" % sys.argv[0])
        sys.exit(1)
    
    print("Looking for %s in format %s" % (sys.argv[1],sys.argv[2]))
    #client = IRCClient(sys.argv[1],sys.argv[2],"SEARCH",True)
    client = IRCClient(sys.argv[1],sys.argv[2],"BOOK",True)