/work/toxcore/events/group_topic_lock.c
Line | Count | Source (jump to first uncovered line) |
1 | | /* SPDX-License-Identifier: GPL-3.0-or-later |
2 | | * Copyright © 2023-2026 The TokTok team. |
3 | | */ |
4 | | |
5 | | #include "events_alloc.h" |
6 | | |
7 | | #include <assert.h> |
8 | | |
9 | | #include "../attributes.h" |
10 | | #include "../bin_pack.h" |
11 | | #include "../bin_unpack.h" |
12 | | #include "../ccompat.h" |
13 | | #include "../mem.h" |
14 | | #include "../tox.h" |
15 | | #include "../tox_event.h" |
16 | | #include "../tox_events.h" |
17 | | #include "../tox_pack.h" |
18 | | #include "../tox_struct.h" |
19 | | #include "../tox_unpack.h" |
20 | | |
21 | | /***************************************************** |
22 | | * |
23 | | * :: struct and accessors |
24 | | * |
25 | | *****************************************************/ |
26 | | |
27 | | struct Tox_Event_Group_Topic_Lock { |
28 | | uint32_t group_number; |
29 | | Tox_Group_Topic_Lock topic_lock; |
30 | | }; |
31 | | |
32 | | static void tox_event_group_topic_lock_set_group_number(Tox_Event_Group_Topic_Lock *_Nonnull group_topic_lock, uint32_t group_number) |
33 | 13 | { |
34 | 13 | assert(group_topic_lock != nullptr); |
35 | 13 | group_topic_lock->group_number = group_number; |
36 | 13 | } |
37 | | uint32_t tox_event_group_topic_lock_get_group_number(const Tox_Event_Group_Topic_Lock *group_topic_lock) |
38 | 0 | { |
39 | 0 | assert(group_topic_lock != nullptr); |
40 | 0 | return group_topic_lock->group_number; |
41 | 0 | } |
42 | | |
43 | | static void tox_event_group_topic_lock_set_topic_lock(Tox_Event_Group_Topic_Lock *_Nonnull group_topic_lock, Tox_Group_Topic_Lock topic_lock) |
44 | 13 | { |
45 | 13 | assert(group_topic_lock != nullptr); |
46 | 13 | group_topic_lock->topic_lock = topic_lock; |
47 | 13 | } |
48 | | Tox_Group_Topic_Lock tox_event_group_topic_lock_get_topic_lock(const Tox_Event_Group_Topic_Lock *group_topic_lock) |
49 | 8 | { |
50 | 8 | assert(group_topic_lock != nullptr); |
51 | 8 | return group_topic_lock->topic_lock; |
52 | 8 | } |
53 | | |
54 | | static void tox_event_group_topic_lock_construct(Tox_Event_Group_Topic_Lock *_Nonnull group_topic_lock) |
55 | 38 | { |
56 | 38 | *group_topic_lock = (Tox_Event_Group_Topic_Lock) { |
57 | 38 | 0 |
58 | 38 | }; |
59 | 38 | } |
60 | | static void tox_event_group_topic_lock_destruct(Tox_Event_Group_Topic_Lock *_Nonnull group_topic_lock, const Memory *_Nonnull mem) |
61 | 38 | { |
62 | 38 | return; |
63 | 38 | } |
64 | | |
65 | | bool tox_event_group_topic_lock_pack( |
66 | | const Tox_Event_Group_Topic_Lock *event, Bin_Pack *bp) |
67 | 20 | { |
68 | 20 | return bin_pack_array(bp, 2) |
69 | 20 | && bin_pack_u32(bp, event->group_number) |
70 | 20 | && tox_group_topic_lock_pack(event->topic_lock, bp); |
71 | 20 | } |
72 | | |
73 | | static bool tox_event_group_topic_lock_unpack_into(Tox_Event_Group_Topic_Lock *_Nonnull event, Bin_Unpack *_Nonnull bu) |
74 | 25 | { |
75 | 25 | assert(event != nullptr); |
76 | 25 | if (!bin_unpack_array_fixed(bu, 2, nullptr)) { |
77 | 2 | return false; |
78 | 2 | } |
79 | | |
80 | 23 | return bin_unpack_u32(bu, &event->group_number) |
81 | 23 | && tox_group_topic_lock_unpack(&event->topic_lock, bu); |
82 | 25 | } |
83 | | |
84 | | /***************************************************** |
85 | | * |
86 | | * :: new/free/add/get/size/unpack |
87 | | * |
88 | | *****************************************************/ |
89 | | |
90 | | const Tox_Event_Group_Topic_Lock *tox_event_get_group_topic_lock(const Tox_Event *event) |
91 | 0 | { |
92 | 0 | return event->type == TOX_EVENT_GROUP_TOPIC_LOCK ? event->data.group_topic_lock : nullptr; |
93 | 0 | } |
94 | | |
95 | | Tox_Event_Group_Topic_Lock *tox_event_group_topic_lock_new(const Memory *mem) |
96 | 39 | { |
97 | 39 | Tox_Event_Group_Topic_Lock *const group_topic_lock = |
98 | 39 | (Tox_Event_Group_Topic_Lock *)mem_alloc(mem, sizeof(Tox_Event_Group_Topic_Lock)); |
99 | | |
100 | 39 | if (group_topic_lock == nullptr) { |
101 | 1 | return nullptr; |
102 | 1 | } |
103 | | |
104 | 38 | tox_event_group_topic_lock_construct(group_topic_lock); |
105 | 38 | return group_topic_lock; |
106 | 39 | } |
107 | | |
108 | | void tox_event_group_topic_lock_free(Tox_Event_Group_Topic_Lock *group_topic_lock, const Memory *mem) |
109 | 39 | { |
110 | 39 | if (group_topic_lock != nullptr) { |
111 | 38 | tox_event_group_topic_lock_destruct(group_topic_lock, mem); |
112 | 38 | } |
113 | 39 | mem_delete(mem, group_topic_lock); |
114 | 39 | } |
115 | | |
116 | | static Tox_Event_Group_Topic_Lock *_Nullable tox_events_add_group_topic_lock(Tox_Events *_Nonnull events, const Memory *_Nonnull mem) |
117 | 13 | { |
118 | 13 | Tox_Event_Group_Topic_Lock *const group_topic_lock = tox_event_group_topic_lock_new(mem); |
119 | | |
120 | 13 | if (group_topic_lock == nullptr) { |
121 | 0 | return nullptr; |
122 | 0 | } |
123 | | |
124 | 13 | Tox_Event event; |
125 | 13 | event.type = TOX_EVENT_GROUP_TOPIC_LOCK; |
126 | 13 | event.data.group_topic_lock = group_topic_lock; |
127 | | |
128 | 13 | if (!tox_events_add(events, &event)) { |
129 | 0 | tox_event_group_topic_lock_free(group_topic_lock, mem); |
130 | 0 | return nullptr; |
131 | 0 | } |
132 | 13 | return group_topic_lock; |
133 | 13 | } |
134 | | |
135 | | bool tox_event_group_topic_lock_unpack( |
136 | | Tox_Event_Group_Topic_Lock **event, Bin_Unpack *bu, const Memory *mem) |
137 | 26 | { |
138 | 26 | assert(event != nullptr); |
139 | 26 | assert(*event == nullptr); |
140 | 26 | *event = tox_event_group_topic_lock_new(mem); |
141 | | |
142 | 26 | if (*event == nullptr) { |
143 | 1 | return false; |
144 | 1 | } |
145 | | |
146 | 25 | return tox_event_group_topic_lock_unpack_into(*event, bu); |
147 | 26 | } |
148 | | |
149 | | static Tox_Event_Group_Topic_Lock *_Nullable tox_event_group_topic_lock_alloc(Tox_Events_State *_Nonnull state) |
150 | 13 | { |
151 | 13 | if (state->events == nullptr) { |
152 | 0 | return nullptr; |
153 | 0 | } |
154 | | |
155 | 13 | Tox_Event_Group_Topic_Lock *group_topic_lock = tox_events_add_group_topic_lock(state->events, state->mem); |
156 | | |
157 | 13 | if (group_topic_lock == nullptr) { |
158 | 0 | state->error = TOX_ERR_EVENTS_ITERATE_MALLOC; |
159 | 0 | return nullptr; |
160 | 0 | } |
161 | | |
162 | 13 | return group_topic_lock; |
163 | 13 | } |
164 | | |
165 | | /***************************************************** |
166 | | * |
167 | | * :: event handler |
168 | | * |
169 | | *****************************************************/ |
170 | | |
171 | | void tox_events_handle_group_topic_lock( |
172 | | Tox *_Nonnull tox, |
173 | | uint32_t group_number, |
174 | | Tox_Group_Topic_Lock topic_lock, |
175 | | void *_Nullable user_data) |
176 | 13 | { |
177 | 13 | Tox_Events_State *state = tox_events_alloc(user_data); |
178 | 13 | Tox_Event_Group_Topic_Lock *group_topic_lock = tox_event_group_topic_lock_alloc(state); |
179 | | |
180 | 13 | if (group_topic_lock == nullptr) { |
181 | 0 | return; |
182 | 0 | } |
183 | | |
184 | 13 | tox_event_group_topic_lock_set_group_number(group_topic_lock, group_number); |
185 | 13 | tox_event_group_topic_lock_set_topic_lock(group_topic_lock, topic_lock); |
186 | 13 | } |
187 | | |
188 | | void tox_events_handle_group_topic_lock_dispatch(Tox *tox, const Tox_Event_Group_Topic_Lock *event, void *user_data) |
189 | 0 | { |
190 | 0 | if (tox->group_topic_lock_callback == nullptr) { |
191 | 0 | return; |
192 | 0 | } |
193 | | |
194 | 0 | tox_unlock(tox); |
195 | 0 | tox->group_topic_lock_callback(tox, event->group_number, event->topic_lock, user_data); |
196 | 0 | tox_lock(tox); |
197 | 0 | } |