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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
# $Id$
#
# Presence and instant messaging
#
# Copyright (C) 2003-2008 Benny Prijono <benny@prijono.org>
#
import sys
import pjsua as pj
LOG_LEVEL = 3
def log_cb(level, str, len):
print str,
class MyBuddyCallback(pj.BuddyCallback):
def __init__(self, buddy):
pj.BuddyCallback.__init__(self, buddy)
def on_state(self):
print "Buddy", self.buddy.info().uri, "is",
print self.buddy.info().online_text
def on_pager(self, mime_type, body):
print "Instant message from", self.buddy.info().uri,
print "(", mime_type, "):"
print body
def on_pager_status(self, body, im_id, code, reason):
if code >= 300:
print "Message delivery failed for message",
print body, "to", self.buddy.info().uri, ":", reason
def on_typing(self, is_typing):
if is_typing:
print self.buddy.info().uri, "is typing"
else:
print self.buddy.info().uri, "stops typing"
lib = pj.Lib()
try:
# Init library with default config and some customized
# logging config.
lib.init(log_cfg = pj.LogConfig(level=LOG_LEVEL, callback=log_cb))
# Create UDP transport which listens to any available port
transport = lib.create_transport(pj.TransportType.UDP,
pj.TransportConfig(0))
print "\nListening on", transport.info().host,
print "port", transport.info().port, "\n"
# Start the library
lib.start()
# Create local account
acc = lib.create_account_for_transport(transport)
my_sip_uri = "sip:" + transport.info().host + \
":" + str(transport.info().port)
buddy = None
# Menu loop
while True:
print "My SIP URI is", my_sip_uri
print "Menu: a=add buddy, t=toggle online status, i=send IM, q=quit"
input = sys.stdin.readline().rstrip("\r\n")
if input == "a":
# Add buddy
print "Enter buddy URI: ",
input = sys.stdin.readline().rstrip("\r\n")
if input == "":
continue
buddy = acc.add_buddy(input)
cb = MyBuddyCallback(buddy)
buddy.set_callback(cb)
buddy.subscribe()
elif input == "t":
acc.set_basic_status(not acc.info().online_status)
elif input == "i":
if not buddy:
print "Add buddy first"
continue
buddy.send_typing_ind(True)
print "Type the message: ",
input = sys.stdin.readline().rstrip("\r\n")
if input == "":
buddy.send_typing_ind(False)
continue
buddy.send_pager(input)
elif input == "q":
break
# Shutdown the library
lib.destroy()
lib = None
except pj.Error, e:
print "Exception: " + str(e)
lib.destroy()
lib = None
|
