connectwith	myaccount@gmail.com
password	mypassword
pluginsdir	/data/src/gtalkbot/plugins
outboxdir	/data/src/gtalkbot/outbox
authfile	/data/src/.gtalkbot-passwd

$ longcommand; echo "long command done" | notify mikaljabber@gmail.com

#!/usr/bin/python

# A simple example of how to use pcapy. This needs to be run as root.

import datetime
import gflags
import pcapy
import sys

FLAGS = gflags.FLAGS
gflags.DEFINE_string('i', 'eth1',
                     'The name of the interface to monitor')


def main(argv):
  # Parse flags
  try:
    argv = FLAGS(argv)
  except gflags.FlagsError, e:
    print FLAGS

  print 'Opening %s' % FLAGS.i

  # Arguments here are:
  #   device
  #   snaplen (maximum number of bytes to capture _per_packet_)
  #   promiscious mode (1 for true)
  #   timeout (in milliseconds)
  cap = pcapy.open_live(FLAGS.i, 100, 1, 0)

  # Read packets -- header contains information about the data from pcap,
  # payload is the actual packet as a string
  (header, payload) = cap.next()
  while header:
    print ('%s: captured %d bytes, truncated to %d bytes'
           %(datetime.datetime.now(), header.getlen(), header.getcaplen()))

    (header, payload) = cap.next()


if __name__ == "__main__":
  main(sys.argv)

2008-11-25 10:09:53.308310: captured 98 bytes, truncated to 98 bytes
2008-11-25 10:09:53.308336: captured 66 bytes, truncated to 66 bytes
2008-11-25 10:09:53.315028: captured 66 bytes, truncated to 66 bytes
2008-11-25 10:09:53.316520: captured 130 bytes, truncated to 100 bytes
2008-11-25 10:09:53.317030: captured 450 bytes, truncated to 100 bytes
2008-11-25 10:09:53.324414: captured 124 bytes, truncated to 100 bytes
2008-11-25 10:09:53.327770: captured 114 bytes, truncated to 100 bytes
2008-11-25 10:09:53.328001: captured 210 bytes, truncated to 100 bytes

##########################################################################
# Mailman

:0:
* List-Id:.*<\/[^>]*
$MATCH

:0:
* List-Post: ]*
$MATCH

##########################################################################
# Majordomo lists (sometimes don't have <>'s around the address

:0:
* X-Mailing-List:.*<\/[^>]*
$MATCH

:0:
* X-Mailing-List:.*\/.*
$MATCH

##########################################################################
# Ezmlm

:0:
* Mailing-List: .* \/[^ ;]*
$MATCH

##########################################################################
# I'm not sure what creates this one...

:0:
* X-Loop: \/.*
$MATCH

import feedparser
import os
import re
import shelve
import sys
import unicodedata
import urllib


_SENTENCE_LENGTH = 5


def Normalize(value):
  normalized = unicodedata.normalize('NFKD', unicode(value))
  normalized = normalized.encode('ascii', 'ignore')
  return normalized


def ListDifference(l1, l2):
  delta = []
  
  for l in l2:
    if l not in l1:
      delta.append(l)

  return len(delta)


plugins_dir = '%s/plugins' % os.getcwd()
print 'Appending %s to module path' % plugins_dir
sys.path.append(plugins_dir)
import blather

data = shelve.open('memes.slf', writeback=True)
data.setdefault('sentences', {})
data.setdefault('titles', {})
data.setdefault('content', {})
data.setdefault('content_orig', {})
data.setdefault('memes', [])

ds = blather.DataStore()

changed = False

# Scan feeds, looking for new posts. This just populates the database.
for feed in data['feeds']:
  print
  print 'Fetching %s' % feed
  d = feedparser.parse(feed)

  # Newest entries are first
  entries = d.entries
  entries.reverse()
  
  for ent in entries:
    print '  Considering %s' % ent.title
    data['titles'][ent.link] = ent.title
    
    content = Normalize(ent.description)
    data['content_orig'][ent.link] = content
    content = ' '.join(content.split('\n'))
    content = re.sub('<[^>]*>', '', content)
    content = re.sub('[^\w]+', ' ', content)
    content = content.lower()
    data['content'][ent.link] = content

    words = content.split()
    for i in range(len(words) - _SENTENCE_LENGTH):
      key = ' '.join(words[i:i + _SENTENCE_LENGTH])
      data['sentences'].setdefault(key, [])

      if not ent.link in data['sentences'][key]:
        data['sentences'][key].append(ent.link)

# Now we have a database of sentences and the posts which share them. What we
# really want is a collection of shared sentences that form a meme, and the
# posts which contain those sentences.
for sentence in data['sentences']:
  found = False

  if len(data['sentences'][sentence]) > 4:
    domains = {}
    
    # Its possible that they're all from one domain...
    for url in data['sentences'][key]:
      domain = url.strip('http://').split('/')[0]
      domains[domain] = True

    # Its not a meme unless the sentence is shared by at least four posts.
    # Try to find an existing meme which contains these posts.
    for (sentences, urls, published) in data['memes']:
      if not found and ListDifference(urls, data['sentences'][sentence]) < 2:
        data['memes'].remove((sentences, urls, published))

        if sentence not in sentences:
          sentences.append(sentence)

        new_titles = []
        for u in data['sentences'][sentence]:
          if not u in urls:
            urls.append(u)
            new_titles.append('<a href="%s">%s</a>'
                              %(u, data['titles'][u]))

        data['memes'].append((sentences, urls, published))
        found = True

        if published and new_titles:
          print 'Added posts to an existing meme'
          ds.AddMessage('Memeomatic extended an existing meme: %s'
                        % ', '.join(new_titles))
          changed = True

    if not found and len(domains) > 1:
      print ('Created a new meme for "%s" with %s'
             %(sentence, data['sentences'][sentence]))
      data['memes'].append(([sentence], data['sentences'][sentence], False))

# Publish new memes
for meme in data['memes']:
  (sentences, urls, published) = meme
  if not published:
    titles = []
    for url in urls:
      titles.append('<a href="%s">%s</a>' %(url, data['titles'][url]))
    
    ds.AddMessage('Memeomatic found a new meme: %s' % ', '.join(titles))
    data['memes'].remove((sentences, urls, published))
    data['memes'].append((sentences, urls, True))
    print 'Published a new meme'
    changed = True

if changed:
  ds.Save()
data.close()

# ./irserver -codedump -debug_code -loglevel 4 /dev/ttyUSB0
Name   : 
Version: D5.03.08
FW SNo : 18780
Capab  : Power On; 
FW Cap : 3964953
USB SNo: 
Node   : /dev/ttyUSB0

IRServer Version 5.7.08
[ 0]:                      D5.03.08     SN: 18780
Remote zalman               compiled:     1 Timings -     45 Commands
Total:   1 Remotes  -   1 Timings -  45 Commands
         0 CCF Data -   0 CCF RAW -   0 CCF Error

import gflags
import thread
import threading
import traceback
import logging

...

FLAGS = gflags.FLAGS
gflags.DEFINE_boolean('dumplocks', False,
                      'If true, dumps information about lock activity')
...

class LockHelper(object):
  """A wrapper which makes it easier to see what locks are doing."""

  lock = thread.allocate_lock()

  def acquire(self):
    if FLAGS.dumplocks:
      logging.info('%s acquiring lock' % threading.currentThread().getName())
      for s in traceback.extract_stack():
        logging.info('  Trace %s:%s [%s] %s' % s)
    self.lock.acquire()

  def release(self):
    if FLAGS.dumplocks:
      logging.info('%s releasing lock' % threading.currentThread().getName())
      for s in traceback.extract_stack():
        logging.info('  Trace %s:%s [%s] %s' % s)
    self.lock.release()