summaryrefslogtreecommitdiff
path: root/examples/client/python/stream-tube-accepter.py
blob: b5ed6773d77ed72ff583831f2dc404c64328b0c7 (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
#!/usr/bin/env python

import os

import gi
from gi.repository import GObject, Gio
gi.require_version('TelepathyGLib', '0.12')
from gi.repository import TelepathyGLib as Tp

def tube_conn_closed(tube, error):
    print "Tube connection has been closed", error.message

def tube_accept_cb(tube, result, loop):
    try:
        tube_conn = tube.accept_finish(result)
    except GObject.GError, e:
        print "Failed to accept tube: %s" % e
        sys.exit(1)

    tube_conn.connect('closed', tube_conn_closed)

    contact = tube_conn.get_contact();

    print "Got IOStream to", contact.get_identifier()

    conn = tube_conn.get_socket_connection();

    # g_input_stream_read() can't be used from Python so we use the more
    # binding friendly GDataInputStream
    in_stream = Gio.DataInputStream (base_stream=conn.get_input_stream())
    out_stream = conn.get_output_stream()

    print "Sending: Ping"
    out_stream.write("Ping\n", None)

    buf, len = in_stream.read_line_utf8(None)
    print "Received:", buf

def tube_invalidated_cb(tube, domain, code, message, loop):
    print "tube has been invalidated:", message
    loop.quit()

def handle_channels_cb(handler, account, connection, channels, requests,
    user_action_time, context, loop):
    for channel in channels:
        if not isinstance(channel, Tp.StreamTubeChannel):
            continue

        print "Accepting tube"

        channel.connect('invalidated', tube_invalidated_cb, loop)

        channel.accept_async(tube_accept_cb, loop)

    context.accept()

if __name__ == '__main__':
    Tp.debug_set_flags(os.getenv('EXAMPLE_DEBUG', ''))

    loop = GObject.MainLoop()

    account_manager = Tp.AccountManager.dup()
    handler = Tp.SimpleHandler.new_with_am(account_manager, False, False,
        'ExampleServiceHandler', False, handle_channels_cb, loop)

    handler.add_handler_filter({
        Tp.PROP_CHANNEL_CHANNEL_TYPE: Tp.IFACE_CHANNEL_TYPE_STREAM_TUBE,
        Tp.PROP_CHANNEL_TARGET_HANDLE_TYPE: int(Tp.HandleType.CONTACT),
        Tp.PROP_CHANNEL_TYPE_STREAM_TUBE_SERVICE: "ExampleService",
    })

    handler.register()

    print "Waiting for tube offer"
    loop.run()