diff options
author | noname <[email protected]> | 2025-03-07 17:42:02 +1100 |
---|---|---|
committer | noname <[email protected]> | 2025-03-07 17:42:02 +1100 |
commit | f40a5c5aa8a5242190464c30521e9aca8e8dc2f0 (patch) | |
tree | c7128b5027ecbe14c9df0d4fd4b956cf4bdae7ba /lib/sway/ipc.vala | |
parent | f77586bd467ac9d15068f6edfd6a1b856273c878 (diff) |
change indent to 4 spaces
Diffstat (limited to 'lib/sway/ipc.vala')
-rw-r--r-- | lib/sway/ipc.vala | 157 |
1 files changed, 78 insertions, 79 deletions
diff --git a/lib/sway/ipc.vala b/lib/sway/ipc.vala index 772ab40..3fb4650 100644 --- a/lib/sway/ipc.vala +++ b/lib/sway/ipc.vala @@ -1,7 +1,7 @@ namespace AstalSway { - private const string IPC_MAGIC = "i3-ipc"; +private const string IPC_MAGIC = "i3-ipc"; - public enum PayloadType { +public enum PayloadType { MESSAGE_RUN_COMMAND = 0, MESSAGE_GET_WORKSPACES = 1, MESSAGE_SUBSCRIBE = 2, @@ -27,113 +27,112 @@ namespace AstalSway { EVENT_TICK = 0x80000007, EVENT_BAR_STATE_UPDATE = 0x80000014, EVENT_INPUT = 0x80000015, - } +} - private struct IpcReponse { +private struct IpcReponse { public PayloadType type; public string payload; - } +} + - - // Basic interface to send and receive data through Sway IPjC - private class Ipc : Object { +// Basic interface to send and receive data through Sway IPjC +private class Ipc : Object { private string SWAYSOCK = GLib.Environment.get_variable("SWAYSOCK"); internal void init() throws Error { - SWAYSOCK = GLib.Environment.get_variable("SWAYSOCK"); - - if (SWAYSOCK == null) { - critical("Unable to detect Sway"); - return; - } + SWAYSOCK = GLib.Environment.get_variable("SWAYSOCK"); + + if (SWAYSOCK == null) { + critical("Unable to detect Sway"); + return; + } } internal SocketConnection? connection() { - try { - SocketConnection socket = new SocketClient().connect(new UnixSocketAddress(SWAYSOCK), null); - return socket; - } catch (Error err) { - critical(err.message); - return null; - } + try { + SocketConnection socket = new SocketClient().connect(new UnixSocketAddress(SWAYSOCK), null); + return socket; + } catch (Error err) { + critical(err.message); + return null; + } } internal void send(OutputStream stream, PayloadType type, string payload) { - Array<uint8> message = new Array<uint8> (); + Array<uint8> message = new Array<uint8> (); - uint8[] magic_str = IPC_MAGIC.data; - uint32 pl_length = (uint32) payload.length; - uint32 pl_type = (uint32) type; - uint8[] pl_data = payload.data; + uint8[] magic_str = IPC_MAGIC.data; + uint32 pl_length = (uint32) payload.length; + uint32 pl_type = (uint32) type; + uint8[] pl_data = payload.data; - message.append_vals(magic_str, magic_str.length); - message.append_vals((uint8 *)&pl_length, 4); - message.append_vals((uint8 *)&pl_type, 4); - message.append_vals(pl_data, pl_data.length); - - stream.write(message.data); + message.append_vals(magic_str, magic_str.length); + message.append_vals((uint8 *)&pl_length, 4); + message.append_vals((uint8 *)&pl_type, 4); + message.append_vals(pl_data, pl_data.length); + + stream.write(message.data); } internal IpcReponse? receive(InputStream stream) { - var header = stream.read_bytes(14); - uint8 data[14] = header.get_data(); - if (data == null) { - return null; - } - uint32 pl_length = *(uint32 *)&data[IPC_MAGIC.length]; - PayloadType pl_type = *(uint32 *)&data[IPC_MAGIC.length+4]; - - var payload = stream.read_bytes(pl_length); - - var result = payload.get_data(); - result += '\0'; - - return {pl_type, (string)result}; + var header = stream.read_bytes(14); + uint8 data[14] = header.get_data(); + if (data == null) { + return null; + } + uint32 pl_length = *(uint32 *)&data[IPC_MAGIC.length]; + PayloadType pl_type = *(uint32 *)&data[IPC_MAGIC.length+4]; + + var payload = stream.read_bytes(pl_length); + + var result = payload.get_data(); + result += '\0'; + + return {pl_type, (string)result}; } internal async IpcReponse? receive_async(InputStream stream) { - var header = yield stream.read_bytes_async(14, Priority.DEFAULT, null); - uint8 data[14] = header.get_data(); - if (data == null) { - return null; - } - uint32 pl_length = *(uint32 *)&data[IPC_MAGIC.length]; - PayloadType pl_type = *(uint32 *)&data[IPC_MAGIC.length+4]; - - var payload = yield stream.read_bytes_async(pl_length, Priority.DEFAULT, null); - - var result = payload.get_data(); - result += '\0'; + var header = yield stream.read_bytes_async(14, Priority.DEFAULT, null); + uint8 data[14] = header.get_data(); + if (data == null) { + return null; + } + uint32 pl_length = *(uint32 *)&data[IPC_MAGIC.length]; + PayloadType pl_type = *(uint32 *)&data[IPC_MAGIC.length+4]; + + var payload = yield stream.read_bytes_async(pl_length, Priority.DEFAULT, null); + + var result = payload.get_data(); + result += '\0'; - return {pl_type, (string)result}; + return {pl_type, (string)result}; } public string message(PayloadType type, string payload) { - SocketConnection conn = connection(); - if (conn == null) { - return ""; - } - - send(conn.output_stream, type, payload); - var result = receive(conn.input_stream); - conn.close(null); + SocketConnection conn = connection(); + if (conn == null) { + return ""; + } + + send(conn.output_stream, type, payload); + var result = receive(conn.input_stream); + conn.close(null); - return result.payload; + return result.payload; } public async string message_async(PayloadType type, string payload) { - SocketConnection conn = connection(); - if (conn == null) { - return ""; - } - - send(conn.output_stream, type, payload); - var result = yield receive_async(conn.input_stream); - conn.close(null); + SocketConnection conn = connection(); + if (conn == null) { + return ""; + } + + send(conn.output_stream, type, payload); + var result = yield receive_async(conn.input_stream); + conn.close(null); - return result.payload; + return result.payload; } - - } +} } |