/work/toxcore/events/friend_status_message.c
Line | Count | Source (jump to first uncovered line) |
1 | | /* SPDX-License-Identifier: GPL-3.0-or-later |
2 | | * Copyright © 2023-2025 The TokTok team. |
3 | | */ |
4 | | |
5 | | #include "events_alloc.h" |
6 | | |
7 | | #include <assert.h> |
8 | | #include <stdlib.h> |
9 | | #include <string.h> |
10 | | |
11 | | #include "../attributes.h" |
12 | | #include "../bin_pack.h" |
13 | | #include "../bin_unpack.h" |
14 | | #include "../ccompat.h" |
15 | | #include "../mem.h" |
16 | | #include "../tox.h" |
17 | | #include "../tox_event.h" |
18 | | #include "../tox_events.h" |
19 | | |
20 | | /***************************************************** |
21 | | * |
22 | | * :: struct and accessors |
23 | | * |
24 | | *****************************************************/ |
25 | | |
26 | | struct Tox_Event_Friend_Status_Message { |
27 | | uint32_t friend_number; |
28 | | uint8_t *message; |
29 | | uint32_t message_length; |
30 | | }; |
31 | | |
32 | | static void tox_event_friend_status_message_set_friend_number(Tox_Event_Friend_Status_Message *_Nonnull friend_status_message, uint32_t friend_number) |
33 | 985 | { |
34 | 985 | assert(friend_status_message != nullptr); |
35 | 985 | friend_status_message->friend_number = friend_number; |
36 | 985 | } |
37 | | uint32_t tox_event_friend_status_message_get_friend_number(const Tox_Event_Friend_Status_Message *friend_status_message) |
38 | 0 | { |
39 | 0 | assert(friend_status_message != nullptr); |
40 | 0 | return friend_status_message->friend_number; |
41 | 0 | } |
42 | | |
43 | | static bool tox_event_friend_status_message_set_message(Tox_Event_Friend_Status_Message *_Nonnull friend_status_message, |
44 | | const uint8_t *_Nullable message, uint32_t message_length) |
45 | 985 | { |
46 | 985 | assert(friend_status_message != nullptr); |
47 | 985 | if (friend_status_message->message != nullptr) { |
48 | 0 | free(friend_status_message->message); |
49 | 0 | friend_status_message->message = nullptr; |
50 | 0 | friend_status_message->message_length = 0; |
51 | 0 | } |
52 | | |
53 | 985 | if (message == nullptr) { |
54 | 0 | assert(message_length == 0); |
55 | 0 | return true; |
56 | 0 | } |
57 | | |
58 | 985 | uint8_t *message_copy = (uint8_t *)malloc(message_length); |
59 | | |
60 | 985 | if (message_copy == nullptr) { |
61 | 7 | return false; |
62 | 7 | } |
63 | | |
64 | 978 | memcpy(message_copy, message, message_length); |
65 | 978 | friend_status_message->message = message_copy; |
66 | 978 | friend_status_message->message_length = message_length; |
67 | 978 | return true; |
68 | 985 | } |
69 | | uint32_t tox_event_friend_status_message_get_message_length(const Tox_Event_Friend_Status_Message *friend_status_message) |
70 | 2 | { |
71 | 2 | assert(friend_status_message != nullptr); |
72 | 2 | return friend_status_message->message_length; |
73 | 2 | } |
74 | | const uint8_t *tox_event_friend_status_message_get_message(const Tox_Event_Friend_Status_Message *friend_status_message) |
75 | 2 | { |
76 | 2 | assert(friend_status_message != nullptr); |
77 | 2 | return friend_status_message->message; |
78 | 2 | } |
79 | | |
80 | | static void tox_event_friend_status_message_construct(Tox_Event_Friend_Status_Message *_Nonnull friend_status_message) |
81 | 1.01k | { |
82 | 1.01k | *friend_status_message = (Tox_Event_Friend_Status_Message) { |
83 | 1.01k | 0 |
84 | 1.01k | }; |
85 | 1.01k | } |
86 | | static void tox_event_friend_status_message_destruct(Tox_Event_Friend_Status_Message *_Nonnull friend_status_message, const Memory *_Nonnull mem) |
87 | 1.01k | { |
88 | 1.01k | free(friend_status_message->message); |
89 | 1.01k | } |
90 | | |
91 | | bool tox_event_friend_status_message_pack( |
92 | | const Tox_Event_Friend_Status_Message *event, Bin_Pack *bp) |
93 | 34 | { |
94 | 34 | return bin_pack_array(bp, 2) |
95 | 34 | && bin_pack_u32(bp, event->friend_number) |
96 | 34 | && bin_pack_bin(bp, event->message, event->message_length); |
97 | 34 | } |
98 | | |
99 | | static bool tox_event_friend_status_message_unpack_into(Tox_Event_Friend_Status_Message *_Nonnull event, Bin_Unpack *_Nonnull bu) |
100 | 20 | { |
101 | 20 | assert(event != nullptr); |
102 | 20 | if (!bin_unpack_array_fixed(bu, 2, nullptr)) { |
103 | 1 | return false; |
104 | 1 | } |
105 | | |
106 | 19 | return bin_unpack_u32(bu, &event->friend_number) |
107 | 19 | && bin_unpack_bin(bu, &event->message, &event->message_length); |
108 | 20 | } |
109 | | |
110 | | /***************************************************** |
111 | | * |
112 | | * :: new/free/add/get/size/unpack |
113 | | * |
114 | | *****************************************************/ |
115 | | |
116 | | const Tox_Event_Friend_Status_Message *tox_event_get_friend_status_message(const Tox_Event *event) |
117 | 0 | { |
118 | 0 | return event->type == TOX_EVENT_FRIEND_STATUS_MESSAGE ? event->data.friend_status_message : nullptr; |
119 | 0 | } |
120 | | |
121 | | Tox_Event_Friend_Status_Message *tox_event_friend_status_message_new(const Memory *mem) |
122 | 1.02k | { |
123 | 1.02k | Tox_Event_Friend_Status_Message *const friend_status_message = |
124 | 1.02k | (Tox_Event_Friend_Status_Message *)mem_alloc(mem, sizeof(Tox_Event_Friend_Status_Message)); |
125 | | |
126 | 1.02k | if (friend_status_message == nullptr) { |
127 | 10 | return nullptr; |
128 | 10 | } |
129 | | |
130 | 1.01k | tox_event_friend_status_message_construct(friend_status_message); |
131 | 1.01k | return friend_status_message; |
132 | 1.02k | } |
133 | | |
134 | | void tox_event_friend_status_message_free(Tox_Event_Friend_Status_Message *friend_status_message, const Memory *mem) |
135 | 1.01k | { |
136 | 1.01k | if (friend_status_message != nullptr) { |
137 | 1.01k | tox_event_friend_status_message_destruct(friend_status_message, mem); |
138 | 1.01k | } |
139 | 1.01k | mem_delete(mem, friend_status_message); |
140 | 1.01k | } |
141 | | |
142 | | static Tox_Event_Friend_Status_Message *tox_events_add_friend_status_message(Tox_Events *_Nonnull events, const Memory *_Nonnull mem) |
143 | 1.00k | { |
144 | 1.00k | Tox_Event_Friend_Status_Message *const friend_status_message = tox_event_friend_status_message_new(mem); |
145 | | |
146 | 1.00k | if (friend_status_message == nullptr) { |
147 | 9 | return nullptr; |
148 | 9 | } |
149 | | |
150 | 993 | Tox_Event event; |
151 | 993 | event.type = TOX_EVENT_FRIEND_STATUS_MESSAGE; |
152 | 993 | event.data.friend_status_message = friend_status_message; |
153 | | |
154 | 993 | if (!tox_events_add(events, &event)) { |
155 | 8 | tox_event_friend_status_message_free(friend_status_message, mem); |
156 | 8 | return nullptr; |
157 | 8 | } |
158 | 985 | return friend_status_message; |
159 | 993 | } |
160 | | |
161 | | bool tox_event_friend_status_message_unpack( |
162 | | Tox_Event_Friend_Status_Message **event, Bin_Unpack *bu, const Memory *mem) |
163 | 21 | { |
164 | 21 | assert(event != nullptr); |
165 | 21 | assert(*event == nullptr); |
166 | 21 | *event = tox_event_friend_status_message_new(mem); |
167 | | |
168 | 21 | if (*event == nullptr) { |
169 | 1 | return false; |
170 | 1 | } |
171 | | |
172 | 20 | return tox_event_friend_status_message_unpack_into(*event, bu); |
173 | 21 | } |
174 | | |
175 | | static Tox_Event_Friend_Status_Message *tox_event_friend_status_message_alloc(void *_Nonnull user_data) |
176 | 1.00k | { |
177 | 1.00k | Tox_Events_State *state = tox_events_alloc(user_data); |
178 | 1.00k | assert(state != nullptr); |
179 | | |
180 | 1.00k | if (state->events == nullptr) { |
181 | 7 | return nullptr; |
182 | 7 | } |
183 | | |
184 | 1.00k | Tox_Event_Friend_Status_Message *friend_status_message = tox_events_add_friend_status_message(state->events, state->mem); |
185 | | |
186 | 1.00k | if (friend_status_message == nullptr) { |
187 | 17 | state->error = TOX_ERR_EVENTS_ITERATE_MALLOC; |
188 | 17 | return nullptr; |
189 | 17 | } |
190 | | |
191 | 985 | return friend_status_message; |
192 | 1.00k | } |
193 | | |
194 | | /***************************************************** |
195 | | * |
196 | | * :: event handler |
197 | | * |
198 | | *****************************************************/ |
199 | | |
200 | | void tox_events_handle_friend_status_message( |
201 | | Tox *tox, uint32_t friend_number, const uint8_t *message, size_t length, |
202 | | void *user_data) |
203 | 1.00k | { |
204 | 1.00k | Tox_Event_Friend_Status_Message *friend_status_message = tox_event_friend_status_message_alloc(user_data); |
205 | | |
206 | 1.00k | if (friend_status_message == nullptr) { |
207 | 24 | return; |
208 | 24 | } |
209 | | |
210 | 985 | tox_event_friend_status_message_set_friend_number(friend_status_message, friend_number); |
211 | 985 | tox_event_friend_status_message_set_message(friend_status_message, message, length); |
212 | 985 | } |