Anonymous

import sys
import socket
import string
import os
import irclib
from constants import *

# twisted imports
from twisted.protocols import irc
from twisted.internet import reactor, protocol
from twisted.python import log

#######log test
#class FakeLog(object):
    #def flush(self):
        #return
    #def close(self):
        #return
    #def write(self, s):
        #return

##class ChannelLogger(callbacks.Plugin):
    #noIgnore = True
    #def __init__(self, irc):
        #self.__parent = super(ChannelLogger, self)
        #self.__parent.__init__(irc)
        #self.lastMsgs = {}
        #self.lastStates = {}
        #self.logs = {}
        #world.flushers.append(self.flush)

    #def die(self):
        #for log in self._logs():
            #log.close()
        #world.flushers = [x for x in world.flushers
                          #if hasattr(x, 'im_class') and
                          #x.im_class is not self.__class__]

    #def __call__(self, irc, msg):
        #try:
            ## I don't know why I put this in, but it doesn't work, because it
            ## doesn't call doNick or doQuit.
            ## if msg.args and irc.isChannel(msg.args[0]):
            #self.__parent.__call__(irc, msg)
            #if irc in self.lastMsgs:
                #if irc not in self.lastStates:
                    #self.lastStates[irc] = irc.state.copy()
                #self.lastStates[irc].addMsg(irc, self.lastMsgs[irc])
        #finally:
            ## We must make sure this always gets updated.
            #self.lastMsgs[irc] = msg

    #def reset(self):
        #for log in self._logs():
            #log.close()
        #self.logs.clear()
        #self.lastMsgs.clear()
        #self.lastStates.clear()

    #def _logs(self):
        #for logs in self.logs.itervalues():
            #for log in logs.itervalues():
                #yield log

    #def flush(self):
        #self.checkLogNames()
        #for log in self._logs():
            #try:
                #log.flush()
            #except ValueError, e:
                #if e.args[0] != 'I/O operation on a closed file':
                    #self.log.exception('Odd exception:')

    #def logNameTimestamp(self, channel):
        #format = self.registryValue('filenameTimestamp', channel)
        #return time.strftime(format)

    #def getLogName(self, channel):
        #if self.registryValue('rotateLogs', channel):
            #return '%s.%s.log' % (channel, self.logNameTimestamp(channel))
        #else:
            #return '%s.log' % channel

    #def getLogDir(self, irc, channel):
        #logDir = conf.supybot.directories.log.dirize(self.name())
        #if self.registryValue('directories'):
            #if self.registryValue('directories.network'):
                #logDir = os.path.join(logDir,  irc.network)
            #if self.registryValue('directories.channel'):
                #logDir = os.path.join(logDir, channel)
            #if self.registryValue('directories.timestamp'):
                #format = self.registryValue('directories.timestamp.format')
                #timeDir =time.strftime(format)
                #logDir = os.path.join(logDir, timeDir)
        #if not os.path.exists(logDir):
            #os.makedirs(logDir)
        #return logDir

    #def checkLogNames(self):
        #for (irc, logs) in self.logs.items():
            #for (channel, log) in logs.items():
                #if self.registryValue('rotateLogs', channel):
                    #name = self.getLogName(channel)
                    #if name != log.name:
                        #log.close()
                        #del logs[channel]

    #def getLog(self, irc, channel):
        #self.checkLogNames()
        #try:
            #logs = self.logs[irc]
        #except KeyError:
            #logs = ircutils.IrcDict()
            #self.logs[irc] = logs
        #if channel in logs:
            #return logs[channel]
        #else:
            #try:
                #name = self.getLogName(channel)
                #logDir = self.getLogDir(irc, channel)
                #log = file(os.path.join(logDir, name), 'a')
                #logs[channel] = log
                #return log
            #except IOError:
                #self.log.exception('Error opening log:')
                #return FakeLog()

    #def timestamp(self, log):
        #format = conf.supybot.log.timestampFormat()
        #if format:
            #log.write(time.strftime(format))
            #log.write('  ')

    #def normalizeChannel(self, irc, channel):
        #return ircutils.toLower(channel)

    #def doLog(self, irc, channel, s, *args):
        #s = format(s, *args)
        #channel = self.normalizeChannel(irc, channel)
        #log = self.getLog(irc, channel)
        #if self.registryValue('timestamp', channel):
            #self.timestamp(log)
        #if self.registryValue('stripFormatting', channel):
            #s = ircutils.stripFormatting(s)
        #log.write(s)
        #if self.registryValue('flushImmediately'):
            #log.flush()

    #def doPrivmsg(self, irc, msg):
        #(recipients, text) = msg.args
        #for channel in recipients.split(','):
            #if irc.isChannel(channel):
                #noLogPrefix = self.registryValue('noLogPrefix', channel)
                #if noLogPrefix and text.startswith(noLogPrefix):
                    #text = '-= THIS MESSAGE NOT LOGGED =-'
                #nick = msg.nick or irc.nick
                #if ircmsgs.isAction(msg):
                    #self.doLog(irc, channel,
                               #'* %s %s\n', nick, ircmsgs.unAction(msg))
                #else:
                    #self.doLog(irc, channel, '<%s> %s\n', nick, text)

    #def doNotice(self, irc, msg):
        #(recipients, text) = msg.args
        #for channel in recipients.split(','):
            #if irc.isChannel(channel):
                #self.doLog(irc, channel, '-%s- %s\n', msg.nick, text)

    #def doNick(self, irc, msg):
        #oldNick = msg.nick
        #newNick = msg.args[0]
        #for (channel, c) in irc.state.channels.iteritems():
            #if newNick in c.users:
                #self.doLog(irc, channel,
                           #'*** %s is now known as %s\n', oldNick, newNick)
    #def doJoin(self, irc, msg):
        #for channel in msg.args[0].split(','):
            #self.doLog(irc, channel,
                       #'*** %s has joined %s\n',
                       #msg.nick or msg.prefix, channel)

    #def doKick(self, irc, msg):
        #if len(msg.args) == 3:
            #(channel, target, kickmsg) = msg.args
        #else:
            #(channel, target) = msg.args
            #kickmsg = ''
        #if kickmsg:
            #self.doLog(irc, channel,
                       #'*** %s was kicked by %s (%s)\n',
                       #target, msg.nick, kickmsg)
        #else:
            #self.doLog(irc, channel,
                       #'*** %s was kicked by %s\n', target, msg.nick)

    #def doPart(self, irc, msg):
        #for channel in msg.args[0].split(','):
            #self.doLog(irc, channel,
                       #'*** %s has left %s\n', msg.nick, channel)

    #def doMode(self, irc, msg):
        #channel = msg.args[0]
        #if irc.isChannel(channel) and msg.args[1:]:
            #self.doLog(irc, channel,
                       #'*** %s sets mode: %s %s\n',
                       #msg.nick or msg.prefix, msg.args[1],
                        #' '.join(msg.args[2:]))

    #def doTopic(self, irc, msg):
        #if len(msg.args) == 1:
            #return # It's an empty TOPIC just to get the current topic.
        #channel = msg.args[0]
        #self.doLog(irc, channel,
                   #'*** %s changes topic to "%s"\n', msg.nick, msg.args[1])

    #def doQuit(self, irc, msg):
        #if not isinstance(irc, irclib.Irc):
            #irc = irc.getRealIrc()
        #for (channel, chan) in self.lastStates[irc].channels.iteritems():
            #if msg.nick in chan.users:
                #self.doLog(irc, channel, '*** %s has quit IRC\n', msg.nick)

    #def outFilter(self, irc, msg):
        ## Gotta catch my own messages *somehow* :)
        ## Let's try this little trick...
        #if msg.command in ('PRIVMSG', 'NOTICE'):
            ## Other messages should be sent back to us.
            #m = ircmsgs.IrcMsg(msg=msg, prefix=irc.prefix)
            #self(irc, m)
        #return msg


##Class = ChannelLogger
## vim:set shiftwidth=4 softtabstop=4 expandtab textwidth=79:


###########end log test

#######################2nd log test :P

def ctcp(s): return '\x01%s\x01' % s
def me(s): return ctcp('ACTION %s' % s)

global people
people = {}
global channels
channels = [] # channels that this bot's on

import os, os.path
global directories
directories = []	
for entry in os.listdir(os.getcwd()):
   if os.path.isdir(entry): directories.append(entry)

def log(channel, text): 
   fn = time.strftime('%Y-%m-%d.log', time.gmtime(time.time()))
   if channel not in directories: 
      os.mkdir(channel) # if it fails, the exception may as well be raised
      directories.append(channel)
   if TimeStamp: 
      t = time.strftime('[%H:%M]', time.gmtime(time.time()))
      text = t + ' ' + text
   text += '\n'
   open(os.path.join(channel, fn), 'a').write(text)

def main(hostName, port, chan):
   c = ircAsync.T()
   c.startChannels(chan)
   c.nick = NickName
   c.userid = 'logger'

   # Put any new functions here

   def hi(m, origin, args, text, c=c): 
      c.tell(args[1], 'hi, %s' % origin.split('!')[0])
   c.bind(hi, PRIVMSG, r"(?i)^(Hi|Hey|welcome)(,)? %s(\!)?$" % NickName)

   def logText(m, origin, args, text, c=c): 
      channel = args[1]
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]
      if not (text.startswith('\x01ACTION ') and text.endswith('\x01')): 
         text = _text % (nick, text)
      else: text = _action % (nick, text[8:-1])
      try: 
         if not text[text.index(' ')+1:].startswith('[off]'): 
            log(channel, text)
      except ValueError: log(channel, text)
   c.bind(logText, PRIVMSG, r"(.*)")

   def logTopic(m, origin, args, text, c=c): 
      channel = args[1]
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]
      topic = _topic % (nick, text)
      log(channel, topic)
   c.bind(logTopic, 'TOPIC', r"(.*)")

   def logMode(m, origin, args, text, c=c): 
      channel = args[1]
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]
      mode = _mode % (nick, ' '.join(args[2:]))
      log(channel, mode)
   c.bind(logMode, 'MODE', r"(.*)")

   def logJoin(m, origin, args, text, c=c): 
      channel = text
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]

      if nick == NickName: 
         if channel not in channels: channels.append(channel)
         t = time.strftime('%a %b %d %H:%M:%S %Y', time.gmtime(time.time()))
         log(channel, "Session Start: %s" % t)
         log(channel, "Session Ident: %s" % channel)

      join = _join % (nick, channel)
      log(channel, join)
      if people.has_key(nick): 
         if channel not in people[nick]: 
            people[nick].append(channel)
      else: people[nick] = [channel]
   c.bind(logJoin, 'JOIN', r"(.*)")

   def logNames(m, origin, args, text, c=c): 
      channel = args[3]
      raw_nicks = text.split(' ')
      for nick in raw_nicks: 
         if nick.startswith('@') or nick.startswith('+'): 
            nick = nick[1:]
         if people.has_key(nick): 
            if channel not in people[nick]: 
               people[nick].append(channel)
         else: people[nick] = [channel]
   c.bind(logNames, '353', r"(.*)")

   def logPart(m, origin, args, text, c=c): 
      if nick == NickName: 
         if channel in channels: channels.remove(channel)
      channel = args[1]
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]
      part = _part % (nick, text)
      log(channel, part)
      try: people[nick].remove(channel)
      except: 
         print >> sys.stderr, "Something messed up, but it doesn't matter"
   c.bind(logPart, 'PART', r"(.*)")

   def logQuit(m, origin, args, text, c=c): 
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]
      quit = _quit % (nick, text)
      if people.has_key(nick): 
         for channel in people[nick]: log(channel, quit)
         del people[nick]
   c.bind(logQuit, 'QUIT', r"(.*)")

   def logKick(m, origin, args, text, c=c): 
      if nick == NickName: 
         if channel in channels: channels.remove(channel)
      channel = args[1]
      nick = origin
      if '!' in origin: nick = origin.split('!')[0]
      kickee = args[2]
      kick = _kick % (kickee, nick, text)
      log(channel, kick)
      try: people[nick].remove(channel)
      except: 
         print >> sys.stderr, "Something messed up, but it doesn't matter"
   c.bind(logKick, 'KICK', r"(.*)")

   def logNick(m, origin, args, text, c=c): 
      old = origin
      if '!' in origin: old = origin.split('!')[0]
      new = text
      nick = _nick % (old, new)
      if people.has_key(old): 
         for channel in people[old]: log(channel, nick)
         people[new] = people[old]
         del people[old]
   c.bind(logNick, 'NICK', r"(.*)")

   c.makeConn(hostName, port)
   try: asyncore.loop()
   except: 
      t = time.strftime('%a %b %d %H:%M:%S %Y', time.gmtime(time.time()))
      for channel in channels: 
         log(channel, "Session Close: %s" % t)
      sys.exit(0)
    
if __name__=='__main__': 
   if len(sys.argv) > 2: 
      server, chans = sys.argv[1], sys.argv[2:]
      chans = [('#%s' % c, c)[c.startswith('#')] for c in chans]
      if ':' in server: server, port = server.split(':')
      else: port = '6667'
      main(server, int(port), chans)
   else: print __doc__

###################end 2nd log test

# Generic echo handler ( space added )
# This is used to output some initial information from the server
def handleEcho ( connection, event ):
		print
		print ' '.join ( event.arguments() )

irc = irclib.IRC()
irc.add_global_handler ( 'welcome', handleEcho ) 

#def send(self, to, msg):
#	"""Sends a message "msg" to "to" """
#   	 s.send('PRIVMSG %s :%s\r\n' % (to, msg))

def make_log(s):
    '''
    function to parse logs into HTML, post them, and modify the log index
    accordingly
    '''
    title=time.strftime('%A, %B %d %Y', time.gmtime(time.time()))

    # make sure we're making a new file and not overwriting an old one
    fn = 'file'
    if os.path.exists(fn+'.html'):
        num = 1
        while os.path.exists(fn+'.html'):
            num += 1
            prev = fn
            fn = 'file'+str(num)

    # see if we have a log entry for this already
    description = '<p><a href="./%s">%s</a></p>' % (fn, title)
    index = open('IRCIntoLog.html').read()
    if index.count(title):
        fn = prev

    else:
        # add entry to log index (IRCIntoLog on the site)
        index = '\n'.join([index[:index.rfind('</p>')+4], description,
                           index[index.rfind('</p>')+4:]])
        open('IRCIntoLog.html', 'w').write(index)

    # add HTML header
    html = '''<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" >

<html xmlns="http://www.w3.org/1999/xhtml">
<head profile="http://infomesh.net/pwyky/profile#">
<title>%s</title>
<link rel="stylesheet" type="text/css" href="http://blazeofglory.org/wiki/style.css" />
</head>
<body>
<center><iframe src="http://blazeofglory.org/main/nav.html" width="900" height="100" frameborder="0" scrolling="no"></iframe></center><div class="about">(<a href="./">home</a> | <a 
href="./@meta/about">about</a> | <a 
href="./@info/%s">stats</a>)</div>

<h1>%s</h1>
<div class="content">''' % (title, title, title)

    # add all lines of the log as HTML paragraphs (so that we have line breaks)
    html += '\n'.join(['<p>%s</p>' % string.replace(escape(line),'}', '}}') for line in s.split('\n')])

    # add HTML footer
    html += '''
</div>
logging.basicConfig(level=logging.DEBUG, format='%(asctime)s %(levelname)-6s %(message)s', filename=NICK+'.log')
log = logging.getLogger()
<address>BlazeOfGlory.org. This is a <a
href="http://infomesh.net/pwyky/">pwyky</a> site. <a
href="./@edit/%s" class="edit">Edit this document</a>.</address>
</body>
</html>''' % fn[:-5]
        
    # write finished HTML to file
    open(fn+'.html', 'w').write(html)

def command(cmd):
    '''
    commands function for control via IRC
    '''
    if cmd.startswith('BOT: '): cmd = cmd[len('BOT: '):].split()
    if cmd[0] == OWNER:
        if not cmd[1] in variables.admins:
            variables.admins.append(cmd[1])
    elif cmd[0] == 'start':
        variables.logging = True
    elif cmd[0] == 'stop':
        variables.logging = False
    elif cmd[0] == 'ban':
        if cmd[1] in variables.admins and cmd[1] <> 'mcferrill':
            variables.admins.remove(cmd[1])
    elif cmd[0] == 'post':
        make_log(variables.log)
    elif cmd[0] == 'reset':
        variables.log = ''

    
def sendresponse(self, to, msg, nick):
        """Personalized version of send."""
    	msg = msg.replace('[nick]', nick)
    	s.send('PRIVMSG %s :%s\r\n' % (to, msg))
		
def parsemsg(msg):
    complete=msg[1:].split(':',1)
    info=complete[0].split(' ')
    msgpart=complete[1]
    sender=info[0].split('!')
    if msgpart[0]=='`' and sender[0]==OWNER:
        cmd=msgpart[1:].split(' ')
        if cmd[0]=='op':
            s.send('MODE %s +o %s \n' % (info[2], cmd[1]))
        if cmd[0]=='deop':
            s.send('MODE %s -o %s \n' % (info[2], cmd[1]))
        if cmd[0]=='voice':
            s.send('MODE %s +v %s \n' % (info[2], cmd[1]))
        if cmd[0]=='devoice':
            s.send('MODE %s -o %s \n' % (info[2], cmd[1]))
        if cmd[0]=='sys':
            syscmd(msgpart[1:],info[2])

    if msgpart[0]=='-' and sender[0]==OWNER :
        cmd=msgpart[1:]
        s.send(cmd, '\n')
        print 'cmd= %s' % (cmd)

    if msgpart[0]=='@':
        print msgpart
        cmd=msgpart[1:].strip(
)
        channel=info[2]
        factoids(cmd,channel,sender)
 
def factoids(cmd,channel,sender):
    print cmd
    reply = "I have no idea what you're talking about"
    
    if cmd == 'ping':
       reply = 'pong'
    if cmd == 'info':
       reply = "I am the beginners-help channel bot. Beware the mighty power of the boot"
    if cmd == 'cbf':
       reply = 'TOO BAD! DO IT!!'
    if cmd == 'pacman':
       reply = 'OM NOM NOM NOM! I EAT YOU!'
    if cmd == 'help':
       reply = 'ajmorris, Joeb454, bodhi_zazen, attention please!'
    if cmd == 'help!':
       reply = 'ajmorris, Joeb454, bodhi_zazen, attention please!'
    if cmd == 'run':
       reply = '[nick], im coming to eat you!'
    if cmd == 'you suck':
       reply = 'no you do %s\r\n' % (sender[0])
    if cmd == 'ohmy':
       reply = 'Please watch your language and topic to help keep this channel family friendly.'
    if cmd == 'microsoft':
       reply = 'Microsoft is bad, VERY BAD. END OF DISCUSSION!'
    if cmd == 'pastebin':
       reply = 'pastebin is a service to post multiple-lined texts so you do not flood the channel. One of the many is located at http://www.pastebin.ca' 
    if cmd == 'insult':
       reply = '%s, You are nothing but a weedy ooze of penguin-molesting bladders.' % (sender[0])

    if cmd.find('join')!=-1 and sender[0] == OWNER:
       chan = cmd.split(' ')
       print cmd
       s.send('JOIN %s\r\n' % (chan[1]))
       reply = 'done'

    if cmd.find('kick')!=-1 and sender[0] == OWNER:
       target = cmd.split(' ')
       print cmd
       s.send('KICK %s\r\n' % (target[1]))
       reply = 'with pleasure'

    if cmd.find('cs')!=-1 and sender[0] == OWNER:
       #cmd = cmd.split(' ')
       print cmd
       s.send('PRIVMSG ChanServ :OP %s\r\n' % (CHAN))
       reply = 'I feel the power!'

    if cmd.find('op')!=-1 and cmd.find('op')!=2 and sender[0] == OWNER:
       target = cmd.split(' ')
       print cmd
       s.send('ChanServ OP %s\r\n' % (target[1]))
       reply = 'with pleasure'

    if cmd.find('deop')!=-1 and sender[0] == OWNER:
       target = cmd.split(' ')
       print cmd
       s.send('DEOP %s\r\n' % (target[1]))

    if cmd == 'leave' and sender[0] == OWNER: 
       print cmd
       s.send('QUIT \r\n')

    if cmd.find('identify')!=-1 and sender [0] == OWNER:
	cmd = cmd.split('_')
	print cmd
	s.send('PRIVMSG NickServ: IDENTIFY %s\r\n' % (PASS))

    s.send('PRIVMSG %s :%s\n' % (channel, reply))

def syscmd(commandline,channel):
	cmd=commandline.replace('sys ',' ')
	cmd=cmd.rstrip()
	os.system(cmd+' >temp.txt')
	a=open('temp.txt')
	ot=a.read()
	ot.replace('n','|')
	a.close()
	s.send('PRIVMSG %s :%s\n' % (channel, ot))
	return 0

#Connection
s=socket.socket( )
s.connect((HOST, PORT)) 
s.send('NICK %s \n' % (NICK)) #Tells nick server nickname
s.send('USER %s %s bla : %s \n' % (IDENT, HOST, REALNAME)) #Tells user Identity, current host, and actual name
s.send('PRIVMSG NickServ :IDENTIFY %s\r\n' % (PASS))
s.send('PRIVMSG ChanServ :OP %s\r\n' % (CHAN))


while 1:  #While True
    line=s.recv(500)
    print line # I believe this is for the bot owners information. It doesn't send anything to chatroom
    if line.find('Welcome to the freenode IRC Network')!=-1: #If any line says this it will join the channel(s) put in CHAN
        s.send('JOIN %s \n' % (CHAN))
    if line.find('PRIVMSG')!=-1: # For private messaging, I do not know how this works
        parsemsg(line)