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
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
|
/**
* @file message.c SIP MESSAGE -- RFC 3428
*
* Copyright (C) 2010 Creytiv.com
*/
#include <re.h>
#include <baresip.h>
#include "core.h"
struct message {
struct list lsnrl;
struct sip_lsnr *sip_lsnr;
};
struct message_lsnr {
struct le le;
message_recv_h *recvh;
void *arg;
};
static void destructor(void *data)
{
struct message *message = data;
list_flush(&message->lsnrl);
mem_deref(message->sip_lsnr);
}
static void listener_destructor(void *data)
{
struct message_lsnr *lsnr = data;
list_unlink(&lsnr->le);
}
static void handle_message(struct message_lsnr *lsnr, struct ua *ua,
const struct sip_msg *msg)
{
static const char ctype_text[] = "text/plain";
struct pl ctype_pl = {ctype_text, sizeof(ctype_text)-1};
(void)ua;
if (msg_ctype_cmp(&msg->ctyp, "text", "plain") && lsnr->recvh) {
lsnr->recvh(&msg->from.auri, &ctype_pl,
msg->mb, lsnr->arg);
(void)sip_reply(uag_sip(), msg, 200, "OK");
}
else {
(void)sip_replyf(uag_sip(), msg, 415, "Unsupported Media Type",
"Accept: %s\r\n"
"Content-Length: 0\r\n"
"\r\n",
ctype_text);
}
}
static bool request_handler(const struct sip_msg *msg, void *arg)
{
struct message *message = arg;
struct ua *ua;
struct le *le = message->lsnrl.head;
bool hdld = false;
if (pl_strcmp(&msg->met, "MESSAGE"))
return false;
ua = uag_find(&msg->uri.user);
if (!ua) {
(void)sip_treply(NULL, uag_sip(), msg, 404, "Not Found");
return true;
}
while (le) {
struct message_lsnr *lsnr = le->data;
le = le->next;
handle_message(lsnr, ua, msg);
hdld = true;
}
return hdld;
}
int message_init(struct message **messagep)
{
struct message *message;
int err = 0;
if (!messagep)
return EINVAL;
message = mem_zalloc(sizeof(*message), destructor);
if (!message)
return ENOMEM;
/* note: cannot create sip listener here, there is not UAs yet */
if (err)
mem_deref(message);
else
*messagep = message;
return err;
}
int message_listen(struct message_lsnr **lsnrp, struct message *message,
message_recv_h *recvh, void *arg)
{
struct message_lsnr *lsnr;
int err = 0;
if (!message || !recvh)
return EINVAL;
/* create the SIP listener if it does not exist */
if (!message->sip_lsnr) {
err = sip_listen(&message->sip_lsnr, uag_sip(), true,
request_handler, message);
if (err)
goto out;
}
lsnr = mem_zalloc(sizeof(*lsnr), listener_destructor);
lsnr->recvh = recvh;
lsnr->arg = arg;
list_append(&message->lsnrl, &lsnr->le, lsnr);
if (lsnrp)
*lsnrp = lsnr;
out:
return err;
}
/**
* Send SIP instant MESSAGE to a peer
*
* @param ua User-Agent object
* @param peer Peer SIP Address
* @param msg Message to send
*
* @return 0 if success, otherwise errorcode
*/
int message_send(struct ua *ua, const char *peer, const char *msg,
sip_resp_h *resph, void *arg)
{
struct sip_addr addr;
struct pl pl;
char *uri = NULL;
int err = 0;
if (!ua || !peer || !msg)
return EINVAL;
pl_set_str(&pl, peer);
err = sip_addr_decode(&addr, &pl);
if (err)
return err;
err = pl_strdup(&uri, &addr.auri);
if (err)
return err;
err = sip_req_send(ua, "MESSAGE", uri, resph, arg,
"Accept: text/plain\r\n"
"Content-Type: text/plain\r\n"
"Content-Length: %zu\r\n"
"\r\n%s",
str_len(msg), msg);
mem_deref(uri);
return err;
}
|
