use local1.info as it's ridiculously spammy
[uccdoor.git] / client-xmpp.py
1 #! /usr/bin/env python
2 # UCC Door Server - Jabber/XMPP door client
3 # David Adam <zanchey@ucc.gu.uwa.edu.au>
4 # Released under an MIT-style license; see COPYING for details.
5
6 import dbus
7 import gobject
8 import xmpp
9 import os
10
11 server = 'ucc.asn.au'
12 password = open(os.environ['HOME']+ '/.jabberpw', 'r').readline().strip()
13
14 class Door(object):
15     # XXX: if the server process is not running, this client will terminate
16     # XXX: if the server process stops, there is not notification, and old
17     #      statuses will be persisted until it is restarted
18     
19     def __init__(self, doorname):
20         self.presences = {-1: {'show': 'dnd', 'status': 'busted'},
21             0: {'show': 'away', 'status': 'closed'},
22             1: {'show': 'chat', 'status': 'open'},}
23         
24         if 'pir' in doorname:
25             self.presences = {-1: {'show': 'dnd', 'status': 'busted'},
26                 0: {'show': 'away', 'status': 'nothing moves'},
27                 1: {'show': 'chat', 'status': 'there is movement'},}
28         
29         self.state = -1
30         
31         # connect to hardware server over D-BUS
32         self.remoteobj = system_bus.get_object('au.asn.ucc.DoorServer',
33                                                '/au/asn/ucc/doors/' + doorname)
34         self.remoteobj.connect_to_signal('status_changed', self.state_changed,
35                                          dbus_interface='au.asn.ucc.DoorInterface')
36         
37         # connect to the Jabber server
38         self.jabberclient = xmpp.Client(server, debug=None)
39         self.jabberclient.connect()
40         self.jabberclient.auth(doorname, password)
41         # make self available via jabber, don't bother getting the contact list
42         self.jabberclient.sendInitPresence(requestRoster = 0)
43         
44         try:
45             new_state = self.remoteobj.get_status(dbus_interface='au.asn.ucc.DoorInterface')
46         except:
47             pass
48         
49         self.state_changed(new_state)
50     
51     def state_changed(self, new_state):
52         self.state = new_state
53         # look up the dictionary object for the current state, then construct
54         # a presence object using that as a keyword argument
55         new_presence = xmpp.dispatcher.Presence(**self.presences[new_state])
56         self.jabberclient.send(new_presence)
57
58 if __name__ == '__main__':
59     
60     from dbus.mainloop.glib import DBusGMainLoop
61     DBusGMainLoop(set_as_default=True)
62     # get on the bus
63     system_bus = dbus.SystemBus()
64     
65     # dictionary to hold door names and objects
66     doors = {'uccdoor': None, 'unisfadoor': None, 'chdoor': None, 'mrdoor': None, 'uccpir': None}
67     
68     # create and save door objects
69     for doorname in doors.keys():
70         doors[doorname] = Door(doorname)
71     
72     # engage!
73     loop = gobject.MainLoop()
74     try:
75         loop.run()
76     except KeyboardInterrupt:
77         loop.quit()

UCC git Repository :: git.ucc.asn.au