diff -r 000000000000 -r cc7c1f9d20f7 satorimessage.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/satorimessage.h	Fri Aug 08 09:46:55 2025 +0800
@@ -0,0 +1,113 @@
+/*
+ * Purple Satori Plugin - Satori Protocol Plugin for Purple3
+ * Copyright (C) 2025 Gong Zhile
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, see <https://www.gnu.org/licenses/>.
+ */
+
+#ifndef SATORI_MESSAGE_H
+#define SATORI_MESSAGE_H
+
+#include <glib.h>
+#include <glib-object.h>
+#include <libsoup/soup.h>
+#include <libsoup/soup-message.h>
+#include <json-glib/json-glib.h>
+
+#include "satoritypes.h"
+#include "purplesatoriconnection.h"
+
+#define SATORI_ENDPOINT(path) "http://" PURPLE_SATORI_HOST path
+
+#define JBO(b) json_builder_begin_object(b)
+#define JEO(b) json_builder_end_object(b)
+#define JBSN(b, name) json_builder_set_member_name(b, name)
+#define JBSI(b, val) json_builder_add_int_value(b, val)
+#define JBSS(b, val) json_builder_add_string_value(b, val)
+#define JBA(b, name, val) (JBSN(b, name), JBSS(b, val))
+#define JBAI(b, name, val) (JBSN(b, name), JBSI(b, val))
+
+static inline GBytes *
+JB2GBYTES(JsonBuilder *builder)
+{
+	JsonNode *root = json_builder_get_root(builder);
+	JsonGenerator *gen = json_generator_new();
+	json_generator_set_root(gen, root);
+
+	gchar *json_str = json_generator_to_data(gen, NULL);
+	GBytes *bytes = g_bytes_new_take(json_str, strlen(json_str));
+
+	json_node_free(root);
+	g_object_unref(gen);
+
+	return bytes;
+}
+
+#define JB_BEGIN_OBJ(name) \
+	JsonBuilder *name = json_builder_new(); \
+	JBO(name);
+
+#define JB_END_OBJ(lval, name) \
+	do { \
+		JEO(b); \
+		lval = JB2GBYTES(name); \
+		g_object_unref(b); \
+	} while (0)
+
+static inline SoupMessage *
+satori_message_new(const gchar *method, const gchar *url)
+{
+	SoupMessage *msg = soup_message_new(method, url);
+	SoupMessageHeaders *headers = soup_message_get_request_headers(msg);
+	soup_message_headers_append(headers, "Satori-Platform",
+				    PURPLE_SATORI_PLATFORM);
+	soup_message_headers_append(headers, "Satori-User-ID",
+				    PURPLE_SATORI_USER_ID);
+	return msg;
+}
+
+static inline GBytes *
+satori_message_gen_ident(const gchar *token, gint sn)
+{
+	GBytes *msg = NULL;
+
+	JB_BEGIN_OBJ(b);
+	JBAI(b, "op", SATORI_WEBSOCKET_OP_IDENTIFY);
+	JBSN(b, "body");
+
+	JBO(b);
+	if (token)
+		JBA(b, "token", token);
+	if (sn)
+		JBAI(b, "sn", sn);
+	JEO(b);
+
+	JB_END_OBJ(msg, b);
+	return msg;
+}
+
+static inline void
+satori_user_from_json(JsonObject *user_obj, SatoriUser *out_user) {
+	out_user->id = json_object_get_string_member(user_obj, "id");
+	out_user->name = json_object_get_string_member_with_default(
+		user_obj, "name", NULL);
+	out_user->nick = json_object_get_string_member_with_default(
+		user_obj, "nick", NULL);
+	out_user->avatar = json_object_get_string_member_with_default(
+		user_obj, "avatar", NULL);
+	out_user->is_bot = json_object_get_boolean_member_with_default(
+		user_obj, "is_bot", FALSE);
+}
+
+#endif	/* SATORI_MESSAGE_H */