abouttreesummaryrefslogcommitdiff
path: root/examples/Sync.c
blob: eafed27ee8f2a111ef9a3fe804f156934d59cbf4 (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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
#include <mjson.h>
#include <matrix.h>
#include <stdio.h>

#define SERVER      "https://matrix.org"
#define USER_ID     "@pscho:matrix.org"
#define USERNAME    "pscho"
#define PASSWORD    "Wc23EbmB9G3faMq"
#define DISPLAYNAME "SyncClient"

#define ROOM_ID      "!XKFUjAsGrSSrpDFIxB:matrix.org"
#define EVENT_ID     "$_-y42DkC3OmJ_s40gYko7jMwrUQhoXfEut2pMV3E2J8"
#define SESSION_ID   "tzdnJbDrm82D/RpgkZKpILTifQ5Rads+tVzp3ax8+Ls"

int
main(void)
{
    MatrixClient client;
    MatrixClientInit(&client,
        SERVER);
    
    MatrixHttpInit(&client);

    MatrixClientSetUserId(&client, USER_ID);

    MatrixClientLoginPassword(&client,
        USERNAME,
        PASSWORD,
        DISPLAYNAME);
    
    MatrixClientGenerateOnetimeKeys(&client, 10);
    MatrixClientUploadOnetimeKeys(&client);
    MatrixClientUploadDeviceKey(&client);
    

    static char eventBuffer[1024];
    MatrixClientGetRoomEvent(&client,
        ROOM_ID,
        EVENT_ID,
        eventBuffer, 1024);
    
    printf("event: %s\n", eventBuffer);


    while (getchar() != 'q') {
        static char nextBatch[1024];

        static char syncBuffer[1024*50];
        MatrixClientSync(&client, syncBuffer, 1024*50, nextBatch);
        
        int res;

        const char * s = syncBuffer;
        int slen = strlen(syncBuffer);
        
        {
        int koff, klen, voff, vlen, vtype, off = 0;
        for (off = 0; (off = mjson_next(s, slen, off, &koff, &klen,
                                        &voff, &vlen, &vtype)) != 0; ) {
            const char * key = s + koff;
            const char * val = s + voff;

            printf("%.*s: %.100s\n", klen, key, val);
        }
        }

        mjson_get_string(s, slen, "$.next_batch", nextBatch, 1024);

        const char * events;
        int eventsLen;
        res =
            mjson_find(s, slen, "$.to_device.events", &events, &eventsLen);
        
        if (res != MJSON_TOK_INVALID) {
            {
            int koff, klen, voff, vlen, vtype, off = 0;
            for (off = 0; (off = mjson_next(events, eventsLen, off, &koff, &klen,
                                            &voff, &vlen, &vtype)) != 0; ) {
                const char * val = events + voff;

                printf("%.*s\n", vlen, val);
            }
            }
        }
    }


    MatrixClientDeleteDevice(&client);
        
    MatrixHttpDeinit(&client);

    return 0;
}