#!/usr/bin/env python

import gobject
gobject.threads_init()

from gi.repository import TelepathyGLib
from gi.repository import TelepathyLogger

def hmessage(channel, message):
    print 'message = %s' % message.to_text()

def observe_channels(observer, account, connection, channels,
                     dispatch_op, requests, context, user_data):
    print 'observe_channels'
    for channel in channels:
        print 'channel = %s' % channel.get_object_path()
        channel.connect('message-sent', hmessage)
        channel.connect('message-received', hmessage)

    context.accept()

tp = TelepathyGLib
dbus = tp.DBusDaemon.dup()
observer = tp.SimpleObserver.new(dbus, True, 'Test', True, observe_channels, None)

props = {tp.PROP_CHANNEL_CHANNEL_TYPE: tp.IFACE_CHANNEL_TYPE_TEXT,}
observer.add_observer_filter(props)

observer.register()

loop = gobject.MainLoop()
loop.run()