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
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
#include <stdio.h>
#include <unistd.h>
#include <glib.h>
#include <gibber/gibber-xmpp-connection.h>
#include <gibber/gibber-transport.h>
#include "test-transport.h"
#include "check-gibber.h"
#include <check.h>
struct _FileChunker {
gchar *contents;
gsize length;
gsize size;
gsize offset;
};
typedef struct _FileChunker FileChunker;
static void
file_chunker_destroy (FileChunker *fc) {
g_free (fc->contents);
g_free (fc);
}
static FileChunker *
file_chunker_new (const gchar *filename, gsize chunk_size) {
FileChunker *fc;
fc = g_new0 (FileChunker, 1);
fc->size = chunk_size;
if (!g_file_get_contents (filename, &fc->contents, &fc->length, NULL)) {
file_chunker_destroy (fc);
return NULL;
}
return fc;
}
static gboolean
file_chunker_get_chunk (FileChunker *fc,
gchar **chunk,
gsize *chunk_size) {
if (fc->offset < fc->length) {
*chunk_size = MIN (fc->length - fc->offset, fc->size);
*chunk = fc->contents + fc->offset;
fc->offset += *chunk_size;
return TRUE;
}
return FALSE;
}
START_TEST (test_instantiation)
{
GibberXmppConnection *connection;
TestTransport *transport;
transport = test_transport_new (NULL, NULL);
connection = gibber_xmpp_connection_new (GIBBER_TRANSPORT(transport));
fail_if (connection == NULL);
connection = gibber_xmpp_connection_new (NULL);
fail_if (connection == NULL);
}
END_TEST
static void
parse_error_cb (GibberXmppConnection *connection, gpointer user_data)
{
gboolean *parse_error_found = user_data;
*parse_error_found = TRUE;
}
START_TEST (test_simple_message)
{
GibberXmppConnection *connection;
TestTransport *transport;
gchar *chunk;
gsize chunk_length;
gboolean parse_error_found = FALSE;
const gchar *srcdir;
gchar *file;
FileChunker *fc;
srcdir = g_getenv ("srcdir");
if (srcdir == NULL)
{
file = g_strdup ("inputs/simple-message.input");
}
else
{
file = g_strdup_printf ("%s/inputs/simple-message.input", srcdir);
}
fc = file_chunker_new (file, 10);
fail_if (fc == NULL);
transport = test_transport_new (NULL, NULL);
connection = gibber_xmpp_connection_new (GIBBER_TRANSPORT(transport));
g_signal_connect (connection, "parse-error",
G_CALLBACK(parse_error_cb), &parse_error_found);
while (!parse_error_found &&
file_chunker_get_chunk (fc, &chunk, &chunk_length))
{
test_transport_write (transport, (guint8 *) chunk, chunk_length);
}
fail_if (parse_error_found);
g_free (file);
file_chunker_destroy (fc);
} END_TEST
TCase *
make_gibber_xmpp_connection_tcase (void)
{
TCase *tc = tcase_create ("XMPP Connection");
tcase_add_test (tc, test_instantiation);
tcase_add_test (tc, test_simple_message);
return tc;
}
|
