summaryrefslogtreecommitdiffstats
path: root/Reaktor/UDP/index
blob: b7a21508ff59b9d7ae9debb0059c5898b8f3ddfc (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
#!/usr/bin/python

import asyncore, socket
import logging
import re
import sys
log = logging.getLogger('ubot')

def enable_syslog(logger):
  import logging.handlers as handlers
  from logging import Formatter
  hdlr = handlers.SysLogHandler(
      facility=handlers.SysLogHandler.LOG_DAEMON)
  formatter = Formatter( 
      '%(filename)s: %(levelname)s: %(message)s')
  hdlr.setFormatter(formatter)
  logger.addHandler(hdlr)


class ubot(asyncore.dispatcher):
  """ UDP Bot """
  def __init__(self, port,pattern,action,bind_addr="",):
    asyncore.dispatcher.__init__(self)
    self.bind_addr = bind_addr
    self.port = port
    self.data = ''
    self.pattern = pattern
    self.action = action
    self.bind_socket()

  def bind_socket(self):
    """
    if the socket is already bound we want to reuse this socket anyway
    """
    self.create_socket(socket.AF_INET,socket.SOCK_DGRAM)
    self.set_reuse_addr()
    self.socket.setsockopt(
        socket.SOL_SOCKET,socket.SO_BROADCAST,1)
    log.info("Binding Socket at %s:%d" 
        %(self.bind_addr,self.port))
    self.bind( (self.bind_addr,self.port) )

  def handle_connect(self):
    log.info("Server Started")

  def handle_read(self):
    self.data,addr = self.recvfrom(2048)
    log.debug('<< %s' % self.data)

    if self.find_pattern():
      self.start_action()

  def find_pattern(self):
    """ returns true if own pattern is found"""
    log.debug("Pattern is %s" %self.pattern)
    ret = re.search(self.pattern,self.data)
    if ret:
      log.info("Match \"%s\" with pattern \"%s\"" % ((ret.string.strip()),self.pattern))
    else:
      log.info("No Match")
    return ret


  def start_action(self):
    """ runs all the defined actions"""
    log.debug("Actions: %s" % str(self.action))
    log.error("not yet implemented")
    sys.exit(23)

if __name__ == "__main__":
  import os
  #enable_syslog(log)
  lol = logging.DEBUG if os.environ.get('debug',False) else logging.INFO
  logging.basicConfig(level=lol)
  ubot(1337,r'abc',{})
  asyncore.loop()