Branch data Line data Source code
1 : : // SPDX-License-Identifier: GPL-3.0-or-later
2 : : // SPDX-FileCopyrightText: Andy Holmes <andrew.g.r.holmes@gmail.com>
3 : :
4 : : #define G_LOG_DOMAIN "valent-lock-plugin"
5 : :
6 : : #include "config.h"
7 : :
8 : : #include <glib/gi18n.h>
9 : : #include <gio/gio.h>
10 : : #include <json-glib/json-glib.h>
11 : : #include <valent.h>
12 : :
13 : : #include "valent-lock-plugin.h"
14 : :
15 : :
16 : : struct _ValentLockPlugin
17 : : {
18 : : ValentDevicePlugin parent_instance;
19 : :
20 : : ValentSession *session;
21 : : unsigned long session_changed_id;
22 : :
23 : : gboolean remote_locked;
24 : : };
25 : :
26 [ + + + - ]: 31 : G_DEFINE_FINAL_TYPE (ValentLockPlugin, valent_lock_plugin, VALENT_TYPE_DEVICE_PLUGIN)
27 : :
28 : : static void valent_lock_plugin_request_state (ValentLockPlugin *self);
29 : : static void valent_lock_plugin_send_state (ValentLockPlugin *self);
30 : :
31 : :
32 : : /*
33 : : * Local Lock
34 : : */
35 : : static void
36 : 3 : valent_lock_plugin_send_state (ValentLockPlugin *self)
37 : : {
38 : 6 : g_autoptr (JsonBuilder) builder = NULL;
39 [ - + ]: 3 : g_autoptr (JsonNode) packet = NULL;
40 : 3 : gboolean state;
41 : :
42 [ + - ]: 3 : g_assert (VALENT_IS_LOCK_PLUGIN (self));
43 : :
44 : 3 : state = valent_session_get_locked (self->session);
45 : :
46 : 3 : valent_packet_init (&builder, "kdeconnect.lock");
47 : 3 : json_builder_set_member_name (builder, "isLocked");
48 : 3 : json_builder_add_boolean_value (builder, state);
49 : 3 : packet = valent_packet_end (&builder);
50 : :
51 [ + - ]: 3 : valent_device_plugin_queue_packet (VALENT_DEVICE_PLUGIN (self), packet);
52 : 3 : }
53 : :
54 : : static void
55 : 3 : valent_lock_plugin_handle_lock_request (ValentLockPlugin *self,
56 : : JsonNode *packet)
57 : : {
58 : 3 : gboolean state;
59 : :
60 [ + - ]: 3 : g_assert (VALENT_IS_LOCK_PLUGIN (self));
61 [ - + ]: 3 : g_assert (VALENT_IS_PACKET (packet));
62 : :
63 [ + + ]: 3 : if (valent_packet_check_field (packet, "requestLocked"))
64 : 1 : valent_lock_plugin_send_state (self);
65 : :
66 [ + + ]: 3 : if (valent_packet_get_boolean (packet, "setLocked", &state))
67 : 2 : valent_session_set_locked (self->session, state);
68 : 3 : }
69 : :
70 : : /*
71 : : * Remote Lock
72 : : */
73 : : static void
74 : 6 : valent_lock_plugin_update_actions (ValentLockPlugin *self)
75 : : {
76 : 6 : GAction *action;
77 : :
78 : 6 : action = g_action_map_lookup_action (G_ACTION_MAP (self), "state");
79 : 6 : g_simple_action_set_state (G_SIMPLE_ACTION (action),
80 : : g_variant_new_boolean (self->remote_locked));
81 : 6 : }
82 : :
83 : : static void
84 : 3 : valent_lock_plugin_handle_lock (ValentLockPlugin *self,
85 : : JsonNode *packet)
86 : : {
87 [ + - ]: 3 : g_assert (VALENT_IS_LOCK_PLUGIN (self));
88 [ - + ]: 3 : g_assert (VALENT_IS_PACKET (packet));
89 : :
90 [ + - ]: 3 : if (valent_packet_get_boolean (packet, "isLocked", &self->remote_locked))
91 : 3 : valent_lock_plugin_update_actions (self);
92 : 3 : }
93 : :
94 : : static void
95 : 3 : valent_lock_plugin_request_state (ValentLockPlugin *self)
96 : : {
97 : 6 : g_autoptr (JsonBuilder) builder = NULL;
98 [ - + ]: 3 : g_autoptr (JsonNode) packet = NULL;
99 : :
100 : 3 : valent_packet_init (&builder, "kdeconnect.lock.request");
101 : 3 : json_builder_set_member_name (builder, "requestLocked");
102 : 3 : json_builder_add_boolean_value (builder, TRUE);
103 : 3 : packet = valent_packet_end (&builder);
104 : :
105 [ + - ]: 3 : valent_device_plugin_queue_packet (VALENT_DEVICE_PLUGIN (self), packet);
106 : 3 : }
107 : :
108 : : static void
109 : 2 : valent_lock_plugin_set_state (ValentLockPlugin *self,
110 : : gboolean state)
111 : : {
112 : 4 : g_autoptr (JsonBuilder) builder = NULL;
113 [ - + ]: 2 : g_autoptr (JsonNode) packet = NULL;
114 : :
115 : 2 : valent_packet_init (&builder, "kdeconnect.lock.request");
116 : 2 : json_builder_set_member_name (builder, "setLocked");
117 : 2 : json_builder_add_boolean_value (builder, state);
118 : 2 : packet = valent_packet_end (&builder);
119 : :
120 [ + - ]: 2 : valent_device_plugin_queue_packet (VALENT_DEVICE_PLUGIN (self), packet);
121 : 2 : }
122 : :
123 : : /*
124 : : * GActions
125 : : */
126 : : static void
127 : 2 : state_action (GSimpleAction *action,
128 : : GVariant *parameter,
129 : : gpointer user_data)
130 : : {
131 : 2 : ValentLockPlugin *self = VALENT_LOCK_PLUGIN (user_data);
132 : 2 : gboolean lock = FALSE;
133 : :
134 [ + - ]: 2 : g_assert (VALENT_IS_LOCK_PLUGIN (self));
135 : :
136 : 2 : lock = g_variant_get_boolean (parameter);
137 : :
138 [ + - ]: 2 : if (self->remote_locked != lock)
139 : 2 : valent_lock_plugin_set_state (self, lock);
140 : 2 : }
141 : :
142 : : static const GActionEntry actions[] = {
143 : : {"state", NULL, NULL, "false", state_action},
144 : : };
145 : :
146 : : /*
147 : : * ValentDevicePlugin
148 : : */
149 : : static void
150 : 11 : valent_lock_plugin_update_state (ValentDevicePlugin *plugin,
151 : : ValentDeviceState state)
152 : : {
153 : 11 : ValentLockPlugin *self = VALENT_LOCK_PLUGIN (plugin);
154 : 11 : gboolean available;
155 : :
156 [ + - ]: 11 : g_assert (VALENT_IS_LOCK_PLUGIN (self));
157 : :
158 : 11 : available = (state & VALENT_DEVICE_STATE_CONNECTED) != 0 &&
159 : : (state & VALENT_DEVICE_STATE_PAIRED) != 0;
160 : :
161 [ + + ]: 11 : if (available)
162 : : {
163 [ + - ]: 3 : if (self->session_changed_id == 0)
164 : : {
165 : 3 : self->session_changed_id =
166 : 3 : g_signal_connect_object (self->session,
167 : : "notify::locked",
168 : : G_CALLBACK (valent_lock_plugin_send_state),
169 : : self,
170 : : G_CONNECT_SWAPPED);
171 : : }
172 : :
173 : 3 : valent_extension_toggle_actions (VALENT_EXTENSION (plugin), available);
174 : 3 : valent_lock_plugin_update_actions (self);
175 : 3 : valent_lock_plugin_request_state (self);
176 : : }
177 : : else
178 : : {
179 [ + + ]: 8 : g_clear_signal_handler (&self->session_changed_id, self->session);
180 : 8 : valent_extension_toggle_actions (VALENT_EXTENSION (plugin), available);
181 : : }
182 : 11 : }
183 : :
184 : : static void
185 : 6 : valent_lock_plugin_handle_packet (ValentDevicePlugin *plugin,
186 : : const char *type,
187 : : JsonNode *packet)
188 : : {
189 : 6 : ValentLockPlugin *self = VALENT_LOCK_PLUGIN (plugin);
190 : :
191 [ + - ]: 6 : g_assert (VALENT_IS_LOCK_PLUGIN (self));
192 [ - + ]: 6 : g_assert (type != NULL);
193 [ - + ]: 6 : g_assert (VALENT_IS_PACKET (packet));
194 : :
195 [ + + ]: 6 : if (g_str_equal (type, "kdeconnect.lock"))
196 : 3 : valent_lock_plugin_handle_lock (self, packet);
197 [ + - ]: 3 : else if (g_str_equal (type, "kdeconnect.lock.request"))
198 : 3 : valent_lock_plugin_handle_lock_request (self, packet);
199 : : else
200 : 0 : g_assert_not_reached ();
201 : 6 : }
202 : :
203 : : /*
204 : : * ValentObject
205 : : */
206 : : static void
207 : 8 : valent_lock_plugin_destroy (ValentObject *object)
208 : : {
209 : 8 : ValentLockPlugin *self = VALENT_LOCK_PLUGIN (object);
210 : :
211 [ - + ]: 8 : g_clear_signal_handler (&self->session_changed_id, self->session);
212 : :
213 : 8 : VALENT_OBJECT_CLASS (valent_lock_plugin_parent_class)->destroy (object);
214 : 8 : }
215 : :
216 : : /*
217 : : * GObject
218 : : */
219 : : static void
220 : 4 : valent_lock_plugin_constructed (GObject *object)
221 : : {
222 : 4 : ValentLockPlugin *self = VALENT_LOCK_PLUGIN (object);
223 : 4 : ValentDevicePlugin *plugin = VALENT_DEVICE_PLUGIN (object);
224 : :
225 : 4 : self->session = valent_session_get_default ();
226 : :
227 : 4 : g_action_map_add_action_entries (G_ACTION_MAP (plugin),
228 : : actions,
229 : : G_N_ELEMENTS (actions),
230 : : plugin);
231 : :
232 : 4 : G_OBJECT_CLASS (valent_lock_plugin_parent_class)->constructed (object);
233 : 4 : }
234 : :
235 : : static void
236 : 1 : valent_lock_plugin_class_init (ValentLockPluginClass *klass)
237 : : {
238 : 1 : GObjectClass *object_class = G_OBJECT_CLASS (klass);
239 : 1 : ValentObjectClass *vobject_class = VALENT_OBJECT_CLASS (klass);
240 : 1 : ValentDevicePluginClass *plugin_class = VALENT_DEVICE_PLUGIN_CLASS (klass);
241 : :
242 : 1 : object_class->constructed = valent_lock_plugin_constructed;
243 : :
244 : 1 : vobject_class->destroy = valent_lock_plugin_destroy;
245 : :
246 : 1 : plugin_class->handle_packet = valent_lock_plugin_handle_packet;
247 : 1 : plugin_class->update_state = valent_lock_plugin_update_state;
248 : : }
249 : :
250 : : static void
251 : 4 : valent_lock_plugin_init (ValentLockPlugin *self)
252 : : {
253 : 4 : }
254 : :
|
