/work/toxcore/events/group_peer_limit.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 | | |
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 | | |
18 | | /***************************************************** |
19 | | * |
20 | | * :: struct and accessors |
21 | | * |
22 | | *****************************************************/ |
23 | | |
24 | | struct Tox_Event_Group_Peer_Limit { |
25 | | uint32_t group_number; |
26 | | uint32_t peer_limit; |
27 | | }; |
28 | | |
29 | | static void tox_event_group_peer_limit_set_group_number(Tox_Event_Group_Peer_Limit *_Nonnull group_peer_limit, uint32_t group_number) |
30 | 48 | { |
31 | 48 | assert(group_peer_limit != nullptr); |
32 | 48 | group_peer_limit->group_number = group_number; |
33 | 48 | } |
34 | | uint32_t tox_event_group_peer_limit_get_group_number(const Tox_Event_Group_Peer_Limit *group_peer_limit) |
35 | 8 | { |
36 | 8 | assert(group_peer_limit != nullptr); |
37 | 8 | return group_peer_limit->group_number; |
38 | 8 | } |
39 | | |
40 | | static void tox_event_group_peer_limit_set_peer_limit(Tox_Event_Group_Peer_Limit *_Nonnull group_peer_limit, uint32_t peer_limit) |
41 | 48 | { |
42 | 48 | assert(group_peer_limit != nullptr); |
43 | 48 | group_peer_limit->peer_limit = peer_limit; |
44 | 48 | } |
45 | | uint32_t tox_event_group_peer_limit_get_peer_limit(const Tox_Event_Group_Peer_Limit *group_peer_limit) |
46 | 8 | { |
47 | 8 | assert(group_peer_limit != nullptr); |
48 | 8 | return group_peer_limit->peer_limit; |
49 | 8 | } |
50 | | |
51 | | static void tox_event_group_peer_limit_construct(Tox_Event_Group_Peer_Limit *_Nonnull group_peer_limit) |
52 | 62 | { |
53 | 62 | *group_peer_limit = (Tox_Event_Group_Peer_Limit) { |
54 | 62 | 0 |
55 | 62 | }; |
56 | 62 | } |
57 | | static void tox_event_group_peer_limit_destruct(Tox_Event_Group_Peer_Limit *_Nonnull group_peer_limit, const Memory *_Nonnull mem) |
58 | 62 | { |
59 | 62 | return; |
60 | 62 | } |
61 | | |
62 | | bool tox_event_group_peer_limit_pack( |
63 | | const Tox_Event_Group_Peer_Limit *event, Bin_Pack *bp) |
64 | 22 | { |
65 | 22 | return bin_pack_array(bp, 2) |
66 | 22 | && bin_pack_u32(bp, event->group_number) |
67 | 22 | && bin_pack_u32(bp, event->peer_limit); |
68 | 22 | } |
69 | | |
70 | | static bool tox_event_group_peer_limit_unpack_into(Tox_Event_Group_Peer_Limit *_Nonnull event, Bin_Unpack *_Nonnull bu) |
71 | 13 | { |
72 | 13 | assert(event != nullptr); |
73 | 13 | if (!bin_unpack_array_fixed(bu, 2, nullptr)) { |
74 | 1 | return false; |
75 | 1 | } |
76 | | |
77 | 12 | return bin_unpack_u32(bu, &event->group_number) |
78 | 12 | && bin_unpack_u32(bu, &event->peer_limit); |
79 | 13 | } |
80 | | |
81 | | /***************************************************** |
82 | | * |
83 | | * :: new/free/add/get/size/unpack |
84 | | * |
85 | | *****************************************************/ |
86 | | |
87 | | const Tox_Event_Group_Peer_Limit *tox_event_get_group_peer_limit(const Tox_Event *event) |
88 | 0 | { |
89 | 0 | return event->type == TOX_EVENT_GROUP_PEER_LIMIT ? event->data.group_peer_limit : nullptr; |
90 | 0 | } |
91 | | |
92 | | Tox_Event_Group_Peer_Limit *tox_event_group_peer_limit_new(const Memory *mem) |
93 | 64 | { |
94 | 64 | Tox_Event_Group_Peer_Limit *const group_peer_limit = |
95 | 64 | (Tox_Event_Group_Peer_Limit *)mem_alloc(mem, sizeof(Tox_Event_Group_Peer_Limit)); |
96 | | |
97 | 64 | if (group_peer_limit == nullptr) { |
98 | 2 | return nullptr; |
99 | 2 | } |
100 | | |
101 | 62 | tox_event_group_peer_limit_construct(group_peer_limit); |
102 | 62 | return group_peer_limit; |
103 | 64 | } |
104 | | |
105 | | void tox_event_group_peer_limit_free(Tox_Event_Group_Peer_Limit *group_peer_limit, const Memory *mem) |
106 | 63 | { |
107 | 63 | if (group_peer_limit != nullptr) { |
108 | 62 | tox_event_group_peer_limit_destruct(group_peer_limit, mem); |
109 | 62 | } |
110 | 63 | mem_delete(mem, group_peer_limit); |
111 | 63 | } |
112 | | |
113 | | static Tox_Event_Group_Peer_Limit *tox_events_add_group_peer_limit(Tox_Events *_Nonnull events, const Memory *_Nonnull mem) |
114 | 50 | { |
115 | 50 | Tox_Event_Group_Peer_Limit *const group_peer_limit = tox_event_group_peer_limit_new(mem); |
116 | | |
117 | 50 | if (group_peer_limit == nullptr) { |
118 | 1 | return nullptr; |
119 | 1 | } |
120 | | |
121 | 49 | Tox_Event event; |
122 | 49 | event.type = TOX_EVENT_GROUP_PEER_LIMIT; |
123 | 49 | event.data.group_peer_limit = group_peer_limit; |
124 | | |
125 | 49 | if (!tox_events_add(events, &event)) { |
126 | 1 | tox_event_group_peer_limit_free(group_peer_limit, mem); |
127 | 1 | return nullptr; |
128 | 1 | } |
129 | 48 | return group_peer_limit; |
130 | 49 | } |
131 | | |
132 | | bool tox_event_group_peer_limit_unpack( |
133 | | Tox_Event_Group_Peer_Limit **event, Bin_Unpack *bu, const Memory *mem) |
134 | 14 | { |
135 | 14 | assert(event != nullptr); |
136 | 14 | assert(*event == nullptr); |
137 | 14 | *event = tox_event_group_peer_limit_new(mem); |
138 | | |
139 | 14 | if (*event == nullptr) { |
140 | 1 | return false; |
141 | 1 | } |
142 | | |
143 | 13 | return tox_event_group_peer_limit_unpack_into(*event, bu); |
144 | 14 | } |
145 | | |
146 | | static Tox_Event_Group_Peer_Limit *tox_event_group_peer_limit_alloc(void *_Nonnull user_data) |
147 | 51 | { |
148 | 51 | Tox_Events_State *state = tox_events_alloc(user_data); |
149 | 51 | assert(state != nullptr); |
150 | | |
151 | 51 | if (state->events == nullptr) { |
152 | 1 | return nullptr; |
153 | 1 | } |
154 | | |
155 | 50 | Tox_Event_Group_Peer_Limit *group_peer_limit = tox_events_add_group_peer_limit(state->events, state->mem); |
156 | | |
157 | 50 | if (group_peer_limit == nullptr) { |
158 | 2 | state->error = TOX_ERR_EVENTS_ITERATE_MALLOC; |
159 | 2 | return nullptr; |
160 | 2 | } |
161 | | |
162 | 48 | return group_peer_limit; |
163 | 50 | } |
164 | | |
165 | | /***************************************************** |
166 | | * |
167 | | * :: event handler |
168 | | * |
169 | | *****************************************************/ |
170 | | |
171 | | void tox_events_handle_group_peer_limit( |
172 | | Tox *tox, uint32_t group_number, uint32_t peer_limit, |
173 | | void *user_data) |
174 | 51 | { |
175 | 51 | Tox_Event_Group_Peer_Limit *group_peer_limit = tox_event_group_peer_limit_alloc(user_data); |
176 | | |
177 | 51 | if (group_peer_limit == nullptr) { |
178 | 3 | return; |
179 | 3 | } |
180 | | |
181 | 48 | tox_event_group_peer_limit_set_group_number(group_peer_limit, group_number); |
182 | 48 | tox_event_group_peer_limit_set_peer_limit(group_peer_limit, peer_limit); |
183 | 48 | } |