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
|
/**
* @file message.c SIP MESSAGE -- RFC 3428
*
* Copyright (C) 2010 Creytiv.com
*/
#include <re.h>
#include <baresip.h>
#include "core.h"
static struct sip_lsnr *lsnr;
static message_recv_h *recvh;
static void *recvarg;
static void handle_message(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") && recvh) {
recvh(&msg->from.auri, &ctype_pl, msg->mb, recvarg);
(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 ua *ua;
(void)arg;
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;
}
handle_message(ua, msg);
return true;
}
static void resp_handler(int err, const struct sip_msg *msg, void *arg)
{
struct ua *ua = arg;
(void)ua;
if (err) {
(void)re_fprintf(stderr, " \x1b[31m%m\x1b[;m\n", err);
return;
}
if (msg->scode >= 300) {
(void)re_fprintf(stderr, " \x1b[31m%u %r\x1b[;m\n",
msg->scode, &msg->reason);
}
}
int message_init(message_recv_h *h, void *arg)
{
int err;
err = sip_listen(&lsnr, uag_sip(), true, request_handler, NULL);
if (err)
return err;
recvh = h;
recvarg = arg;
return 0;
}
void message_close(void)
{
lsnr = mem_deref(lsnr);
}
/**
* 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)
{
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, resp_handler, ua,
"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;
}
|
