From 7d5a10e2826eb0a45464d885543ed6ff43eda1a7 Mon Sep 17 00:00:00 2001 From: Gergely Polonkai Date: Tue, 16 Feb 2016 17:30:33 +0100 Subject: [PATCH] Rework MatrixHTTPAPI in Vala --- .gitignore | 1 + src/Makefile.am | 3 +- src/c-api.vapi | 23 +- src/matrix-http-api.c | 2860 -------------------------------------- src/matrix-http-api.h | 60 - src/matrix-http-api.vala | 1745 +++++++++++++++++++++++ src/matrix-http-client.h | 1 - src/test-api-client.c | 4 +- 8 files changed, 1768 insertions(+), 2929 deletions(-) delete mode 100644 src/matrix-http-api.c delete mode 100644 src/matrix-http-api.h create mode 100644 src/matrix-http-api.vala diff --git a/.gitignore b/.gitignore index e53c747..77549bf 100644 --- a/.gitignore +++ b/.gitignore @@ -64,3 +64,4 @@ Makefile.in /src/matrix-api.c /src/matrix-client.c /src/matrix-enums.c +/src/matrix-http-api.c diff --git a/src/Makefile.am b/src/Makefile.am index ebdd306..539e452 100644 --- a/src/Makefile.am +++ b/src/Makefile.am @@ -19,6 +19,7 @@ libmatrix_glib_0_0_la_VALA_SOURCES = \ matrix-api.vala \ matrix-client.vala \ matrix-enums.vala \ + matrix-http-api.vala \ $(NULL) AM_CPPFLAGS += \ @@ -73,7 +74,6 @@ bin_PROGRAMS = test-api-client INST_H_SRC_FILES = \ matrix-types.h \ - matrix-http-api.h \ matrix-http-client.h \ $(NULL) @@ -91,7 +91,6 @@ libmatrix_glib_0_0_la_SOURCES = \ $(libmatrix_glib_0_0_la_VALA_SOURCES:.vala=.c) \ matrix-version.c \ matrix-types.c \ - matrix-http-api.c \ matrix-enumtypes.c \ utils.c \ matrix-http-client.c \ diff --git a/src/c-api.vapi b/src/c-api.vapi index 59e0e14..2602436 100644 --- a/src/c-api.vapi +++ b/src/c-api.vapi @@ -108,14 +108,29 @@ namespace Matrix { } [CCode (cheader_filename = "matrix-types.h")] - public class Pusher {} + public class Pusher { + public Json.Node? get_json_node() + throws Matrix.Error; + } [CCode (cheader_filename = "matrix-types.h")] - public class StateEvent {} + public class StateEvent { + public Json.Node? get_json_node(); + } [CCode (cheader_filename = "matrix-types.h")] - public class @3PidCredential {} + public class @3PidCredential { + public Json.Node? get_json_node() + throws Matrix.Error; + } [CCode (cheader_filename = "matrix-types.h")] - public class Filter {} + public class Filter { + public Json.Node? get_json_node(); + public string? get_json_data(out size_t datalen); + } + + [CCode (cheader_filename = "utils.h", cname = "_json_node_deep_copy")] + public Json.Node? + _json_node_deep_copy(Json.Node? node); } diff --git a/src/matrix-http-api.c b/src/matrix-http-api.c deleted file mode 100644 index b8837a0..0000000 --- a/src/matrix-http-api.c +++ /dev/null @@ -1,2860 +0,0 @@ -/* - * This file is part of matrix-glib-sdk - * - * matrix-glib-sdk 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 3 of the License, or (at your option) any later version. - * - * matrix-glib-sdk 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 matrix-glib-sdk. If not, see - * . - */ - -#include "config.h" -#include "matrix-http-api.h" -#include "matrix-enumtypes.h" -#include "matrix-glib.h" -#include "utils.h" - -#include -#include - -/** - * SECTION:matrix-http-api - * @short_description: Low level API calls to communicate with a - * Matrix.org server via HTTP - * @title: MatrixHTTPAPI - * @stability: Unstable - * @include: matrix-glib/matrix.h - * - * This is a class for low level communication with a Matrix.org - * server via HTTP. - */ - -/** - * MatrixHTTPAPI: - * - * The MatrixHTTPAPI object’s instance definition. - */ - -/** - * MatrixHTTPAPIClass: - * @parent_class: the parent class structure (#GObjectClass) - * - * The MatrixHTTPAPI object’s class definition. - */ - -#define API_ENDPOINT "/_matrix/client/r0/" -#define MEDIA_ENDPOINT "/_matrix/media/r0/" - -typedef struct _MatrixHTTPAPIPrivate { - SoupSession *soup_session; - SoupURI *uri; - SoupURI *media_uri; - gchar *token; - gchar *refresh_token; - gchar *user_id; - gchar *homeserver; - gboolean validate_certificate; -} MatrixHTTPAPIPrivate; - -enum { - PROP_VALIDATE_CERTIFICATE = 1, - PROP_BASE_URL, - PROP_TOKEN, - PROP_REFRESH_TOKEN, - PROP_USER_ID, - PROP_HOMESERVER, - N_PROPERTIES -}; - -typedef enum { - CALL_API, - CALL_MEDIA -} CallType; - -typedef struct { - MatrixHTTPAPI *api; - JsonNode *request_content; - GByteArray *raw_content; - MatrixAPICallback callback; - gpointer callback_data; - gboolean accept_non_json; - CallType call_type; -} MatrixHTTPAPIRequest; - -static GParamSpec *obj_properties[N_PROPERTIES] = {NULL,}; - -static void matrix_http_api_matrix_api_init(MatrixAPIIface *iface); -static void i_set_token(MatrixAPI *api, const gchar *token); -static const gchar *i_get_token(MatrixAPI *api); -static void i_set_refresh_token(MatrixAPI *api, const gchar *refresh_token); -static const gchar *i_get_refresh_token(MatrixAPI *api); -static const gchar *i_get_user_id(MatrixAPI *api); -static const gchar *i_get_homeserver(MatrixAPI *api); - -G_DEFINE_TYPE_WITH_CODE(MatrixHTTPAPI, matrix_http_api, G_TYPE_OBJECT, - G_ADD_PRIVATE(MatrixHTTPAPI) - G_IMPLEMENT_INTERFACE(MATRIX_TYPE_API, - matrix_http_api_matrix_api_init)); - -static void -matrix_http_api_dispose(GObject *gobject) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(gobject)); - - g_object_unref(priv->soup_session); - - G_OBJECT_CLASS(matrix_http_api_parent_class)->dispose(gobject); -} - -static void -matrix_http_api_finalize(GObject *gobject) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(gobject)); - - g_free(priv->token); - g_free(priv->refresh_token); - g_free(priv->user_id); - g_free(priv->homeserver); - - g_signal_handlers_destroy(gobject); - G_OBJECT_CLASS(matrix_http_api_parent_class)->finalize(gobject); -} - -static void -_set_url(SoupURI **uri, const gchar *base, const gchar *endpoint) -{ - gchar *url; - SoupURI *new_uri; - - if (base[strlen(base) - 1] == '/') { - url = g_strdup_printf("%s%s", base, endpoint + 1); - } else { - url = g_strdup_printf("%s%s", base, endpoint); - } - - new_uri = soup_uri_new(url); - - if (new_uri && SOUP_URI_VALID_FOR_HTTP(new_uri)) { - *uri = new_uri; - } else { - if (new_uri) { - soup_uri_free(new_uri); - } - - *uri = NULL; - } -} - -static void -matrix_http_api_set_property(GObject *gobject, - guint prop_id, - const GValue *value, - GParamSpec *pspec) -{ - MatrixHTTPAPI *api = MATRIX_HTTP_API(gobject); - - switch (prop_id) { - case PROP_VALIDATE_CERTIFICATE: - matrix_http_api_set_validate_certificate(api, g_value_get_boolean(value)); - - break; - - case PROP_BASE_URL: - matrix_http_api_set_base_url(api, g_value_get_string(value)); - - break; - - case PROP_TOKEN: - i_set_token(MATRIX_API(api), g_value_get_string(value)); - - break; - - case PROP_REFRESH_TOKEN: - i_set_refresh_token(MATRIX_API(api), - g_value_get_string(value)); - - break; - - default: - G_OBJECT_WARN_INVALID_PROPERTY_ID(gobject, prop_id, pspec); - } -} - -static void -matrix_http_api_get_property(GObject *gobject, - guint prop_id, - GValue *value, - GParamSpec *pspec) -{ - MatrixHTTPAPI *api = MATRIX_HTTP_API(gobject); - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - - switch (prop_id) { - case PROP_VALIDATE_CERTIFICATE: - g_value_set_boolean(value, priv->validate_certificate); - - break; - - case PROP_BASE_URL: - g_value_take_string(value, matrix_http_api_get_base_url(api)); - - break; - - case PROP_TOKEN: - g_value_set_string(value, i_get_token(MATRIX_API(api))); - - break; - - case PROP_REFRESH_TOKEN: - g_value_set_string(value, i_get_refresh_token(MATRIX_API(api))); - - break; - - case PROP_USER_ID: - g_value_set_string(value, i_get_user_id(MATRIX_API(api))); - - break; - - case PROP_HOMESERVER: - g_value_set_string(value, i_get_homeserver(MATRIX_API(api))); - - break; - - default: - G_OBJECT_WARN_INVALID_PROPERTY_ID(gobject, prop_id, pspec); - } -} - -static void -matrix_http_api_class_init(MatrixHTTPAPIClass *klass) -{ - GObjectClass *gobject_class = G_OBJECT_CLASS(klass); - - gobject_class->set_property = matrix_http_api_set_property; - gobject_class->get_property = matrix_http_api_get_property; - gobject_class->finalize = matrix_http_api_finalize; - gobject_class->dispose = matrix_http_api_dispose; - - /** - * MatrixHTTPAPI:validate-certificate: - * - * Set to %FALSE if you don’t want the SSL/TLS certificates to be - * validated. - */ - obj_properties[PROP_VALIDATE_CERTIFICATE] = g_param_spec_boolean( - "validate-certificate", - "Validate certificate", - "TRUE if server certificates should be validated", - TRUE, - G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS); - g_object_class_install_property(gobject_class, - PROP_VALIDATE_CERTIFICATE, - obj_properties[PROP_VALIDATE_CERTIFICATE]); - - /** - * MatrixHTTPAPI:base-url: - * - * The base URL to use for communication with the Matrix.org - * server. If the URL doesn’t end with the correct API endpoint - * (/_matrix/client/api/v1), it gets appended automatically. - * - * Changing the base URL automatically clears all authorization - * tokens. - */ - obj_properties[PROP_BASE_URL] = g_param_spec_string( - "base-url", "Server's base URL", - "Matrix.org home server to connect to.", - NULL, - G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS); - g_object_class_install_property(gobject_class, - PROP_BASE_URL, - obj_properties[PROP_BASE_URL]); - - g_object_class_override_property(gobject_class, PROP_TOKEN, "token"); - g_object_class_override_property(gobject_class, - PROP_REFRESH_TOKEN, - "refresh-token"); - g_object_class_override_property(gobject_class, PROP_USER_ID, "user-id"); - g_object_class_override_property(gobject_class, - PROP_HOMESERVER, - "homeserver"); -} - -static void -matrix_http_api_init(MatrixHTTPAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - - priv->uri = NULL; - priv->token = NULL; - priv->refresh_token = NULL; - priv->user_id = NULL; - priv->homeserver = NULL; - priv->validate_certificate = TRUE; - priv->soup_session = soup_session_new(); -} - -/** - * matrix_http_api_new: - * @base_url: the URL to use as the API endpoint - * @token: (allow-none): an authorization token to use. If %NULL, - * requests that need authentication will fail - * - * Create a new #MatrixHTTPAPI object with the specified base URL, and - * an optional authorization token. - * - * Returns: (transfer full): a new #MatrixHTTPAPI object cast to - * #MatrixAPI - */ -MatrixAPI * -matrix_http_api_new(const gchar *base_url, const gchar *token) -{ - MatrixHTTPAPI *api = g_object_new(MATRIX_TYPE_HTTP_API, - "base-url", base_url, - "token", token, - NULL); - - return MATRIX_API(api); -} - -static void -i_set_token(MatrixAPI *api, const gchar *token) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - g_free(priv->token); - priv->token = g_strdup(token); -} - -static const gchar * -i_get_token(MatrixAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - return priv->token; -} - -static void -i_set_refresh_token(MatrixAPI *api, const gchar *refresh_token) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - g_free(priv->refresh_token); - priv->refresh_token = g_strdup(refresh_token); -} - -static const gchar * -i_get_refresh_token(MatrixAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - return priv->refresh_token; -} - -static const gchar * -i_get_user_id(MatrixAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - return priv->user_id; -} - -static const gchar * -i_get_homeserver(MatrixAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - return priv->homeserver; -} - -/** - * matrix_http_api_set_validate_certificate: - * @api: a #MatrixHTTPAPI implementation - * @validate_certificate: %TRUE if server certificates should be - * validated - * - * Sets if server certificates should be validated. - */ -void -matrix_http_api_set_validate_certificate(MatrixHTTPAPI *api, - gboolean validate_certificate) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - - priv->validate_certificate = validate_certificate; - g_object_set(priv->soup_session, "ssl-strict", validate_certificate, NULL); -} - -/** - * matrix_http_api_get_validate_certificate: - * @api: a #MatrixHTTPAPI implementation - * - * Gets the value set by matrix_http_api_set_validate_certificate() - * - * Returns: %TRUE if the server certificates should be validated - */ -gboolean -matrix_http_api_get_validate_certificate(MatrixHTTPAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - - return priv->validate_certificate; -} - -/** - * matrix_http_api_set_base_url: - * @api: a #MatrixHTTPAPI - * @base_url: the new base URL without the API endpoint - * - * Set the base URL for @api. Authorization tokens will be reset with - * this call, so a new login becomes necessary. - */ -void -matrix_http_api_set_base_url(MatrixHTTPAPI *api, const gchar *base_url) -{ - gchar *last_occurence; - SoupURI *api_uri, *media_uri; - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - - if (!g_str_is_ascii(base_url)) { - g_warning("URL specified (%s) is not ASCII", base_url); - - return; - } - - /* Check if the provided URL already ends with the API endpoint */ - if ((last_occurence = g_strrstr(base_url, API_ENDPOINT)) != NULL) { - g_warning("Provided URL (%s) already contains the API endpoint. Please use an URL without it!", base_url); - - return; - } - - _set_url(&api_uri, base_url, API_ENDPOINT); - _set_url(&media_uri, base_url, MEDIA_ENDPOINT); - - if (api_uri && media_uri) { - gchar *api_url, *media_url; - - if (priv->uri) { - soup_uri_free(priv->uri); - } - - if (priv->media_uri) { - soup_uri_free(priv->media_uri); - } - - priv->uri = api_uri; - priv->media_uri = media_uri; - - // Free all tokens and IDs, as they won’t be valid for - // the new server - g_free(priv->token); - priv->token = NULL; - g_free(priv->refresh_token); - priv->refresh_token = NULL; - g_free(priv->homeserver); - priv->homeserver = NULL; - g_free(priv->user_id); - priv->user_id = NULL; - - api_url = soup_uri_to_string(api_uri, FALSE); - media_url = soup_uri_to_string(media_uri, FALSE); - - g_debug("API URL: %s", api_url); - g_debug("Media URL: %s", media_url); - - g_free(api_url); - g_free(media_url); - } else { - if (api_uri) { - soup_uri_free(api_uri); - } - - if (media_uri) { - soup_uri_free(media_uri); - } - - g_warning("Invalid URL: %s", base_url); - } -} - -/** - * matrix_http_api_get_base_url: - * @api: a #MatrixHTTPAPI implementation - * - * Get the base URL set for @api. - * - * Returns: (transfer full): the base URL set for @api - */ -gchar * -matrix_http_api_get_base_url(MatrixHTTPAPI *api) -{ - gchar *url, *api_occurence; - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - - url = soup_uri_to_string(priv->uri, FALSE); - api_occurence = g_strrstr(url, API_ENDPOINT); - *api_occurence = 0; - - return url; -} - -static void -_response_callback(SoupSession *session, - SoupMessage *msg, - MatrixHTTPAPIRequest *request) -{ - MatrixHTTPAPI *api = request->api; - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - GError *err = NULL; - JsonNode *content = NULL; - GByteArray *raw_content = NULL; - - if (msg->status_code < SOUP_STATUS_CONTINUE) { - err = g_error_new(MATRIX_ERROR, MATRIX_ERROR_COMMUNICATION_ERROR, - "%s %d: %s", - (msg->status_code < 100) ? "Network error" : "HTTP", - msg->status_code, msg->reason_phrase); - } else { // No error - SoupBuffer *buffer; - const guint8 *data; - gsize datalen; - JsonParser *parser; - SoupURI *request_uri = soup_message_get_uri(msg); - const gchar *request_url = NULL; - - switch (request->call_type) { - case CALL_API: - request_url = soup_uri_get_path(request_uri) - + strlen(API_ENDPOINT); - - break; - - case CALL_MEDIA: - request_url = soup_uri_get_path(request_uri) - + strlen(MEDIA_ENDPOINT); - - break; - } - - buffer = soup_message_body_flatten(msg->response_body); - soup_buffer_get_data(buffer, &data, &datalen); - - parser = json_parser_new(); - if (json_parser_load_from_data(parser, - (const gchar *)data, datalen, - &err)) { - g_debug("Data (%s): %s", request_url, data); - content = json_parser_get_root(parser); - - if (JSON_NODE_HOLDS_OBJECT(content)) { - JsonObject *root_object; - JsonNode *node; - - root_object = json_node_get_object(content); - - /* Check if the response holds an access token; if it - * does, set it as our new token */ - if ((node = json_object_get_member( - root_object, "access_token")) != NULL) { - const gchar *access_token; - - if ((access_token = json_node_get_string(node)) != NULL) { - g_debug("Got new access token: %s", access_token); - - i_set_token(MATRIX_API(api), access_token); - } - } - - /* Check if the response holds a refresh token; if it - * does, set it as our new refresh token */ - if ((node = json_object_get_member( - root_object, "refresh_token")) != NULL) { - const gchar *refresh_token; - - if ((refresh_token = json_node_get_string(node)) != NULL) { - g_debug("Got new refresh token: %s", refresh_token); - - i_set_refresh_token(MATRIX_API(api), refresh_token); - } - } - - /* Check if the response holds a homeserver name */ - if ((node = json_object_get_member( - root_object, "home_server")) != NULL) { - const gchar *homeserver = json_node_get_string(node); - - g_free(priv->homeserver); - priv->user_id = g_strdup(homeserver); - - g_debug("Our home server calls itself %s", homeserver); - } - - /* Check if the response holds a user ID; if it does, - * set this as our user ID */ - if ((node = json_object_get_member( - root_object, "user_id")) != NULL) { - const gchar *user_id = json_node_get_string(node); - - g_free(priv->user_id); - priv->user_id = g_strdup(user_id); - - g_debug("We are reported to be logged in as %s", user_id); - } - - { // Check if the response holds an error - JsonNode *errcode_node = json_object_get_member(root_object, - "errcode"); - JsonNode *error_node = json_object_get_member(root_object, - "error"); - - if (errcode_node || error_node) { - gchar *message; - const gchar *errcode = NULL; - const gchar *error = NULL; - MatrixError error_code = MATRIX_ERROR_UNKNOWN_ERROR; - - if (errcode_node) { - GEnumClass *error_class; - GEnumValue *value; - - errcode = json_node_get_string(errcode_node); - - if (strncmp("M_", errcode, 2) == 0) { - gchar *matrix_error_code = g_strdup_printf( - "MATRIX_ERROR_%s", errcode); - - error_class = g_type_class_ref( - MATRIX_TYPE_ERROR); - value = g_enum_get_value_by_name( - error_class, matrix_error_code); - g_free(matrix_error_code); - g_type_class_unref(error_class); - - if (value) { - error_code = value->value; - } else { - g_info("An unknown error code '%s' was sent by the homeserver. You may want to report it to the %s developers", errcode, PACKAGE_NAME); - } - } - } else { - g_info("An error was sent by the homeserver, but no error code was specified. You may want to report this to the homeserver administrators."); - error_code = MATRIX_ERROR_UNSPECIFIED; - } - - if (error_node) { - error = json_node_get_string(error_node); - } - - if (errcode_node && error_node) { - message = g_strdup_printf("%s: %s", errcode, error); - } else if (errcode_node) { - message = g_strdup(errcode); - } else { - message = g_strdup_printf( - "(No errcode given) %s", error); - } - - err = g_error_new_literal(MATRIX_ERROR, error_code, - message); - } - } - } else if (!JSON_NODE_HOLDS_ARRAY(content)) { - // Not a JSON object, neither an array - err = g_error_new(MATRIX_ERROR, MATRIX_ERROR_BAD_RESPONSE, - "Bad response (not a JSON object)"); - g_debug("Bad response: %s", data); - } - } else { // Invalid JSON - if (request->accept_non_json) { - raw_content = g_byte_array_sized_new(datalen); - g_byte_array_append(raw_content, data, datalen); - g_debug("Binary data (%s): %" G_GSIZE_FORMAT " bytes", - request_url, - datalen); - } else { - err = g_error_new(MATRIX_ERROR, MATRIX_ERROR_BAD_RESPONSE, - "Malformed response (invalid JSON)"); - g_debug("Malformed response (%s): %s", request_url, data); - } - } - } - - /* Call the assigned function, if any */ - if (request->callback) { - request->callback( - MATRIX_API(api), - soup_message_headers_get_content_type( - msg->response_headers, - NULL), - content, - raw_content, - request->callback_data, - err); - } - - g_clear_error(&err); -} - -#define create_query_params() (g_hash_table_new_full(g_str_hash, \ - (GEqualFunc)g_strcmp0, \ - NULL, \ - g_free)) - - -static void -_send(MatrixHTTPAPI *api, - MatrixAPICallback callback, - gpointer user_data, - CallType call_type, - const gchar *method, - const gchar *path, - GHashTable *params, - const gchar *content_type, - JsonNode *json_content, - GByteArray *raw_content, - gboolean accept_non_json, - GError **error) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private(api); - SoupURI *request_path = NULL; - SoupMessage *message; - gchar *data, *url; - gsize datalen; - MatrixHTTPAPIRequest *request; - - if (!priv->uri) { - g_set_error(error, - MATRIX_ERROR, MATRIX_ERROR_COMMUNICATION_ERROR, - "No valid base URL"); - - return; - } - - if (json_content && raw_content) { - g_critical("Too many parameters for MatrixHTTPAPI._send. This is a bug"); - } - - if (raw_content && !content_type) { - g_critical("Raw content needs content_type to be set. This is a bug"); - } - - if (!g_str_is_ascii(method)) { - g_warning("Method must be ASCII encoded!"); - - return; - } - - if ((g_ascii_strcasecmp("GET", method) != 0) - && (g_ascii_strcasecmp("POST", method) != 0) - && (g_ascii_strcasecmp("PUT", method) != 0) - && (g_ascii_strcasecmp("DELETE", method) != 0)) { - g_warning("Invalid method name '%s'", method); - - return; - } - - switch (call_type) { - case CALL_API: - request_path = soup_uri_new_with_base(priv->uri, path); - - break; - - case CALL_MEDIA: - request_path = soup_uri_new_with_base(priv->media_uri, path); - - break; - } - - if (!params) { - params = create_query_params(); - } - - if (priv->token) { - g_debug("Adding access token '%s'", priv->token); - - g_hash_table_replace(params, "access_token", g_strdup(priv->token)); - } - - soup_uri_set_query_from_form(request_path, params); - - g_hash_table_unref(params); - - message = soup_message_new_from_uri(method, request_path); - url = soup_uri_to_string(request_path, FALSE); - soup_uri_free(request_path); - - if (json_content) { - JsonGenerator *generator; - - generator = json_generator_new(); - json_generator_set_root(generator, (JsonNode *)json_content); - data = json_generator_to_data(generator, &datalen); - } else if (raw_content) { - data = (gchar *)raw_content->data; - datalen = raw_content->len; - } else { - data = g_strdup("{}"); - datalen = 2; - } - - g_debug("Sending (%s %s): %s", method, url, data); - - soup_message_set_flags(message, SOUP_MESSAGE_NO_REDIRECT); - soup_message_set_request(message, - (content_type == NULL) - ? "application/json" - : content_type, - raw_content ? SOUP_MEMORY_COPY : SOUP_MEMORY_TAKE, - data, datalen); - g_object_ref(message); - - request = g_new0(MatrixHTTPAPIRequest, 1); - request->request_content = json_content; - request->raw_content = raw_content; - request->api = api; - request->callback = callback; - request->callback_data = user_data; - request->accept_non_json = accept_non_json; - request->call_type = call_type; - - soup_session_queue_message(priv->soup_session, - message, - (SoupSessionCallback)_response_callback, - request); -} - -static void -i_login(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *login_type, - JsonNode *content, - GError **error) -{ - JsonNode *body; - JsonObject *root_object; - - body = json_node_copy((JsonNode *)content); - root_object = json_node_get_object(body); - json_object_set_string_member(root_object, "type", login_type); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "login", NULL, NULL, body, NULL, - FALSE, error); -} - -static void -add_state_event(MatrixStateEvent *event, JsonBuilder *builder) -{ - JsonNode *node = matrix_state_event_get_json_node(event); - - json_builder_add_value(builder, node); - json_node_free(node); -} - -static void -add_string(gchar *str, JsonBuilder *builder) -{ - json_builder_add_string_value(builder, str); -} - -typedef struct { - JsonBuilder *builder; - GError *error; -} Add3PidCredData; - -static void -add_3pidcred(Matrix3PidCredential *credential, Add3PidCredData *data) -{ - JsonNode *node; - - // If there is already an error set, return immediately - if (data->error) { - return; - } - - // Get the credentials’ JSON representation - node = matrix_3pid_credential_get_json_node(credential, &(data->error)); - - // Add it to the builder - json_builder_add_value(data->builder, node); -} - -static void -i_create_room(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - MatrixRoomPreset preset, - const gchar *room_name, - const gchar *room_alias, - const gchar *topic, - MatrixRoomVisibility visibility, - JsonNode *creation_content, - GList *initial_state, - GList *invitees, - GList *invite_3pids, - GError **error) -{ - JsonNode *body; - JsonBuilder *builder; - - builder = json_builder_new(); - json_builder_begin_object(builder); - - if (creation_content) { - json_builder_set_member_name(builder, "creation_content"); - json_builder_add_value(builder, creation_content); - } - - if (initial_state) { - json_builder_set_member_name(builder, "initial_state"); - json_builder_begin_array(builder); - g_list_foreach(initial_state, (GFunc)add_state_event, builder); - json_builder_end_array(builder); - } - - if (invitees) { - json_builder_set_member_name(builder, "invite"); - json_builder_begin_array(builder); - g_list_foreach(invitees, (GFunc)add_string, builder); - json_builder_end_array(builder); - } - - if (invite_3pids) { - Add3PidCredData add_data; - - add_data.builder = builder; - add_data.error = NULL; - - json_builder_set_member_name(builder, "invite_3pid"); - json_builder_begin_array(builder); - g_list_foreach(invite_3pids, (GFunc)add_3pidcred, &add_data); - - if (add_data.error) { - g_propagate_error(error, add_data.error); - - g_object_unref(builder); - - return; - } - - json_builder_end_array(builder); - } - - if (room_name) { - json_builder_set_member_name(builder, "name"); - json_builder_add_string_value(builder, room_name); - } - - if (preset != MATRIX_ROOM_PRESET_NONE) { - gchar *preset_string = _matrix_g_enum_value_to_nick( - MATRIX_TYPE_ROOM_PRESET, preset, TRUE); - - if (preset_string) { - json_builder_set_member_name(builder, "preset"); - json_builder_add_string_value(builder, preset_string); - g_free(preset_string); - } else { - g_debug("Invalid room preset type"); - } - } - - if (room_alias) { - json_builder_set_member_name(builder, "room_alias_name"); - json_builder_add_string_value(builder, room_alias); - } - - if (topic) { - json_builder_set_member_name(builder, "topic"); - json_builder_add_string_value(builder, topic); - } - - if (visibility != MATRIX_ROOM_VISIBILITY_DEFAULT) { - gchar *visibility_string = _matrix_g_enum_value_to_nick( - MATRIX_TYPE_ROOM_VISIBILITY, visibility, TRUE); - - if (visibility_string) { - json_builder_set_member_name(builder, "visibility"); - json_builder_add_string_value(builder, visibility_string); - g_free(visibility_string); - } else { - g_debug("Invalid room visibility type"); - } - } - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "createRoom", NULL, NULL, body, NULL, - FALSE, error); -} - -static void -i_initial_sync(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - guint limit, - gboolean archived, - GError **err) -{ - GHashTable *params; - - params = create_query_params(); - - if (limit != 0) { - g_hash_table_replace(params, "limit", g_strdup_printf("%d", limit)); - } - - if (archived) { - g_hash_table_replace(params, "archived", g_strdup("true")); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "initialSync", params, NULL, NULL, NULL, - FALSE, err); -} - -static void -i_event_stream(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *from_token, - gulong timeout, - GError **err) -{ - GHashTable *params; - - params = create_query_params(); - - if (from_token) { - g_hash_table_replace(params, "from", g_strdup(from_token)); - } - - if (timeout != 0) { - g_hash_table_replace(params, - "timeout", g_strdup_printf("%lu", timeout)); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "events", params, NULL, NULL, NULL, - FALSE, err); -} - -static void -i_leave_room(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - GError **error) -{ - gchar *encoded_room_id, *path; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/leave", encoded_room_id); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_list_public_rooms(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - GError **error) -{ - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "publicRooms", NULL, NULL, NULL, NULL, - FALSE, error); -} - -static void -i_join_room(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - GError **error) -{ - gchar *encoded_room_id, *path; - - // TODO: a more thorough check should be used here - if (*room_id != '!') { - g_set_error(error, - MATRIX_ERROR, MATRIX_ERROR_INVALID_ROOM_ID, - "Invalid room ID"); - - return; - } - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/join", encoded_room_id); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_presence_list(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GError **error) -{ - gchar *encoded_user_id; - gchar *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("presence/list/%s", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_user_presence(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GError **error) -{ - gchar *encoded_user_id; - gchar *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("presence/%s/status", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_media_download(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *server_name, - const gchar *media_id, - GError **error) -{ - gchar *encoded_server_name, *encoded_media_id, *path; - - encoded_server_name = soup_uri_encode(server_name, NULL); - encoded_media_id = soup_uri_encode(media_id, NULL); - path = g_strdup_printf("download/%s/%s", - encoded_server_name, - encoded_media_id); - g_free(encoded_server_name); - g_free(encoded_media_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_MEDIA, - "GET", path, NULL, NULL, NULL, NULL, - TRUE, error); - g_free(path); -} - -static void -i_media_thumbnail(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *server_name, - const gchar *media_id, - guint width, - guint height, - MatrixResizeMethod method, - GError **error) -{ - gchar *encoded_server_name, - *encoded_media_id, - *path; - GHashTable *params; - - encoded_server_name = soup_uri_encode(server_name, NULL); - encoded_media_id = soup_uri_encode(media_id, NULL); - path = g_strdup_printf("download/%s/%s", - encoded_server_name, - encoded_media_id); - g_free(encoded_server_name); - g_free(encoded_media_id); - - params = create_query_params(); - - if (width > 0) { - g_hash_table_replace(params, "width", g_strdup_printf("%u", width)); - } - - if (height > 0) { - g_hash_table_replace(params, "height", g_strdup_printf("%u", height)); - } - - if (method != MATRIX_RESIZE_METHOD_DEFAULT) { - switch (method) { - case MATRIX_RESIZE_METHOD_CROP: - g_hash_table_replace(params, "method", g_strdup("crop")); - - break; - - case MATRIX_RESIZE_METHOD_SCALE: - g_hash_table_replace(params, "method", g_strdup("scale")); - - break; - - // This is here to prevent compiler warnings - case MATRIX_RESIZE_METHOD_DEFAULT: break; - } - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_MEDIA, - "GET", path, params, NULL, NULL, NULL, - TRUE, error); - g_free(path); -} - -static void -i_media_upload(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *content_type, - GByteArray *content, - GError **error) -{ - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_MEDIA, - "POST", "upload", NULL, content_type, NULL, content, - FALSE, error); -} - -static void -i_update_presence_list(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GList *drop_ids, - GList *invite_ids, - GError **error) -{ - gchar *encoded_user_id; - gchar *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("presence/%s/status", encoded_user_id); - g_free(encoded_user_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - if (drop_ids) { - json_builder_set_member_name(builder, "drop"); - json_builder_begin_array(builder); - g_list_foreach(drop_ids, (GFunc)add_string, builder); - json_builder_end_array(builder); - } - - if (invite_ids) { - json_builder_set_member_name(builder, "invide"); - json_builder_begin_array(builder); - g_list_foreach(invite_ids, (GFunc)add_string, builder); - json_builder_end_array(builder); - } - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_set_user_presence(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - MatrixPresence presence, - const gchar *status_message, - GError **error) -{ - gchar *encoded_user_id; - gchar *path, *presence_string; - JsonBuilder *builder; - JsonNode *body; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("presence/%s/status", encoded_user_id); - g_free(encoded_user_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "presence"); - presence_string = _matrix_g_enum_value_to_nick(MATRIX_TYPE_PRESENCE, - presence, TRUE); - json_builder_add_string_value(builder, presence_string); - g_free(presence_string); - - if (status_message) { - json_builder_set_member_name(builder, "status_msg"); - json_builder_add_string_value(builder, status_message); - } - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_update_pusher(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - MatrixPusher *pusher, - GError **error) -{ - JsonNode *pusher_node; - - if ((pusher_node = matrix_pusher_get_json_node( - pusher, error)) == NULL) { - return; - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "pushers/set", NULL, NULL, pusher_node, NULL, - FALSE, error); -} - -static void -i_get_pushers(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - GError **error) -{ - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "pushrules/", NULL, NULL, NULL, NULL, - FALSE, error); -} - -static void -i_delete_pusher(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *scope, - MatrixPusherKind kind, - const gchar *rule_id, - GError **error) -{ - gchar *encoded_scope, *encoded_rule_id, *kind_string, *path; - - encoded_scope = soup_uri_encode(scope, NULL); - encoded_rule_id = soup_uri_encode(rule_id, NULL); - kind_string = _matrix_g_enum_value_to_nick(MATRIX_TYPE_PUSHER_KIND, kind, TRUE); - - path = g_strdup_printf("pushrules/%s/%s/%s", - encoded_scope, - kind_string, - encoded_rule_id); - - g_free(encoded_scope); - g_free(encoded_rule_id); - g_free(kind_string); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "DELETE", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_pusher(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *scope, - MatrixPusherKind kind, - const gchar *rule_id, - GError **error) -{ - gchar *encoded_scope, *encoded_rule_id, *kind_string, *path; - - encoded_scope = soup_uri_encode(scope, NULL); - encoded_rule_id = soup_uri_encode(rule_id, NULL); - kind_string = _matrix_g_enum_value_to_nick(MATRIX_TYPE_PUSHER_KIND, - kind, TRUE); - - path = g_strdup_printf("pushrules/%s/%s/%s", - encoded_scope, - kind_string, - encoded_rule_id); - - g_free(encoded_scope); - g_free(encoded_rule_id); - g_free(kind_string); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -add_condition_kind_object(MatrixPusherConditionKind kind, - JsonBuilder *builder) -{ - gchar *kind_string = _matrix_g_enum_value_to_nick( - MATRIX_TYPE_PUSHER_CONDITION_KIND, kind, TRUE); - - if (!kind_string) { - g_warning("Invalid condition kind"); - - return; - } - - json_builder_begin_object(builder); - json_builder_set_member_name(builder, "kind"); - json_builder_add_string_value(builder, kind_string); - json_builder_end_object(builder); - - g_free(kind_string); -} - -static void i_add_pusher(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *scope, - MatrixPusherKind kind, - const gchar *rule_id, - const gchar *before, - const gchar *after, - GList *actions, - GList *conditions, - GError **error) -{ - gchar *encoded_scope, *encoded_rule_id, *kind_string, *path; - GHashTable *params; - JsonBuilder *builder; - JsonNode *body; - - encoded_scope = soup_uri_encode(scope, NULL); - encoded_rule_id = soup_uri_encode(rule_id, NULL); - kind_string = _matrix_g_enum_value_to_nick(MATRIX_TYPE_PUSHER_KIND, - kind, TRUE); - - path = g_strdup_printf("pushrules/%s/%s/%s", - encoded_scope, - kind_string, - encoded_rule_id); - - g_free(encoded_scope); - g_free(encoded_rule_id); - g_free(kind_string); - - params = create_query_params(); - - if (before) { - g_hash_table_replace(params, "before", g_strdup(before)); - } - - if (after) { - g_hash_table_replace(params, "after", g_strdup(after)); - } - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "actions"); - json_builder_begin_array(builder); - g_list_foreach(actions, (GFunc)add_string, builder); - json_builder_end_array(builder); - - if (conditions) { - json_builder_set_member_name(builder, "conditions"); - json_builder_begin_array(builder); - g_list_foreach(conditions, (GFunc)add_condition_kind_object, builder); - json_builder_end_array(builder); - } - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, params, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_toggle_pusher(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *scope, - MatrixPusherKind kind, - const gchar *rule_id, - gboolean enabled, - GError **error) -{ - gchar *encoded_scope, *encoded_rule_id, *kind_string, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_scope = soup_uri_encode(scope, NULL); - encoded_rule_id = soup_uri_encode(rule_id, NULL); - kind_string = _matrix_g_enum_value_to_nick(MATRIX_TYPE_PUSHER_KIND, - kind, TRUE); - - path = g_strdup_printf("pushrules/%s/%s/%s", - encoded_scope, - kind_string, - encoded_rule_id); - - g_free(encoded_scope); - g_free(encoded_rule_id); - g_free(kind_string); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "enabled"); - json_builder_add_boolean_value(builder, enabled); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_delete_room_alias(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_alias, - GError **error) -{ - gchar *encoded_room_alias, *path; - - encoded_room_alias = soup_uri_encode(room_alias, NULL); - path = g_strdup_printf("room/%s", encoded_room_alias); - g_free(encoded_room_alias); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "DELETE", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_room_id(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_alias, - GError **error) -{ - gchar *encoded_room_alias, *path; - - encoded_room_alias = soup_uri_encode(room_alias, NULL); - path = g_strdup_printf("room/%s", encoded_room_alias); - g_free(encoded_room_alias); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_create_room_alias(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *room_alias, - GError **error) -{ - gchar *encoded_room_alias, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_room_alias = soup_uri_encode(room_alias, NULL); - path = g_strdup_printf("room/%s", encoded_room_alias); - g_free(encoded_room_alias); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "room_id"); - json_builder_add_string_value(builder, room_id); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_ban_user(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *user_id, - const gchar *reason, - GError **error) -{ - gchar *encoded_room_id, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/ban", encoded_room_id); - g_free(encoded_room_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "user_id"); - json_builder_add_string_value(builder, user_id); - - if (reason) { - json_builder_set_member_name(builder, "reason"); - json_builder_add_string_value(builder, reason); - } - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_forget_room(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - GError **error) -{ - gchar *encoded_room_id, *path; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/forget", encoded_room_id); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_invite_user_3rdparty(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - Matrix3PidCredential *credential, - GError **error) -{ - gchar *encoded_room_id, *path; - JsonNode *body; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/invite", encoded_room_id); - g_free(encoded_room_id); - - if ((body = matrix_3pid_credential_get_json_node(credential, - error)) == NULL) { - return; - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_invite_user(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *user_id, - GError **error) -{ - gchar *encoded_room_id, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/invite", encoded_room_id); - g_free(encoded_room_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "user_id"); - json_builder_add_string_value(builder, user_id); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_event(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *event_id, - GError **error) -{ - gchar *encoded_event_id, *path; - - encoded_event_id = soup_uri_encode(event_id, NULL); - path = g_strdup_printf("events/%s", encoded_event_id); - g_free(encoded_event_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_event_context(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *event_id, - guint limit, - GError **error) -{ - gchar *encoded_room_id, *encoded_event_id, *path; - GHashTable *params = NULL; - - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_event_id = soup_uri_encode(event_id, NULL); - path = g_strdup_printf("rooms/%s/context/%s", - encoded_room_id, encoded_event_id); - g_free(encoded_room_id); - g_free(encoded_event_id); - - if (limit != 0) { - params = create_query_params(); - - g_hash_table_replace(params, "limit", g_strdup_printf("%u", limit)); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, params, NULL, NULL, NULL, - FALSE, error); - g_free(params); -} - -static void -i_initial_sync_room(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - GError **error) -{ - gchar *encoded_room_id, *path; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/initialSync", encoded_room_id); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_list_room_members(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - GError **error) -{ - gchar *encoded_room_id, *path; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/members", encoded_room_id); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_list_room_messages(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *from_token, - MatrixEventDirection direction, - guint limit, - GError **error) -{ - gchar *encoded_room_id, *path; - GHashTable *params; - - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("rooms/%s/messages", encoded_room_id); - g_free(encoded_room_id); - - params = create_query_params(); - - g_hash_table_replace(params, "from", g_strdup(from_token)); - - switch (direction) { - case MATRIX_EVENT_DIRECTION_BACKWARD: - g_hash_table_replace(params, "dir", g_strdup("b")); - - break; - - case MATRIX_EVENT_DIRECTION_FORWARD: - g_hash_table_replace(params, "dir", g_strdup("f")); - - break; - } - - if (limit != 0) { - g_hash_table_replace(params, "limit", g_strdup_printf("%u", limit)); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, params, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_send_event_receipt(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - MatrixReceiptType receipt_type, - const gchar *event_id, - JsonNode *receipt, - GError **error) -{ - gchar *encoded_room_id, *receipt_type_string, *encoded_event_id, *path; - - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_event_id = soup_uri_encode(event_id, NULL); - receipt_type_string = _matrix_g_enum_value_to_nick(MATRIX_TYPE_RECEIPT_TYPE, - receipt_type, - TRUE); - path = g_strdup_printf("rooms/%s/receipt/%s/%s", - encoded_room_id, - receipt_type_string, - encoded_event_id); - g_free(encoded_room_id); - g_free(encoded_event_id); - g_free(receipt_type_string); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, receipt, NULL, - FALSE, error); - g_free(path); -} - -static void -i_redact_event(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *event_id, - const gchar *txn_id, - const gchar *reason, - GError **error) -{ - gchar *encoded_room_id, *encoded_event_id, *encoded_txn_id, *path; - JsonBuilder *builder; - JsonNode *body = NULL; - - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_event_id = soup_uri_encode(event_id, NULL); - encoded_txn_id = soup_uri_encode(txn_id, NULL); - path = g_strdup_printf("rooms/%s/redact/%s/%s", - encoded_room_id, - encoded_event_id, - encoded_txn_id); - g_free(encoded_room_id); - g_free(encoded_event_id); - g_free(encoded_txn_id); - - if (reason) { - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "reason"); - json_builder_add_string_value(builder, reason); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_send_message_event(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *event_type, - const gchar *txn_id, - JsonNode *content, - GError **error) -{ - gchar *encoded_room_id, *encoded_event_type, *encoded_txn_id, *path; - - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_event_type = soup_uri_encode(event_type, NULL); - encoded_txn_id = soup_uri_encode(txn_id, NULL); - path = g_strdup_printf("rooms/%s/send/%s/%s", - encoded_room_id, - encoded_event_type, - encoded_txn_id); - g_free(encoded_room_id); - g_free(encoded_event_type); - g_free(encoded_txn_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, content, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_room_state(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *event_type, - const gchar *state_key, - GError **error) -{ - gchar *encoded_room_id, *path, *encoded_event_type, *encoded_state_key; - - encoded_room_id = soup_uri_encode(room_id, NULL); - - if (event_type) { - encoded_event_type = soup_uri_encode(event_type, NULL); - - if (state_key) { - encoded_state_key = soup_uri_encode(state_key, NULL); - path = g_strdup_printf("rooms/%s/state/%s/%s", - encoded_room_id, - encoded_event_type, - encoded_state_key); - g_free(encoded_state_key); - } else { - path = g_strdup_printf("rooms/%s/state/%s", - encoded_room_id, encoded_event_type); - } - - g_free(encoded_event_type); - } else { - path = g_strdup_printf("rooms/%s/state", encoded_room_id); - } - - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_send_room_event(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *room_id, - const gchar *event_type, - const gchar *state_key, - JsonNode *content, - GError **error) -{ - gchar *encoded_room_id, *path, *encoded_event_type, *encoded_state_key; - - encoded_room_id = soup_uri_encode(room_id, NULL); - - encoded_event_type = soup_uri_encode(event_type, NULL); - - if (state_key) { - encoded_state_key = soup_uri_encode(state_key, NULL); - path = g_strdup_printf("rooms/%s/state/%s/%s", - encoded_room_id, - encoded_event_type, - encoded_state_key); - g_free(encoded_state_key); - } else { - path = g_strdup_printf("rooms/%s/state/%s", - encoded_room_id, encoded_event_type); - } - - g_free(encoded_event_type); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, content, NULL, - FALSE, error); - g_free(path); -} - -static void -i_notify_room_typing(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *room_id, - guint timeout, - gboolean typing, - GError **error) -{ - gchar *encoded_room_id, *encoded_user_id, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("rooms/%s/typing/%s", - encoded_room_id, encoded_user_id); - g_free(encoded_room_id); - g_free(encoded_user_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - if (timeout != 0) { - json_builder_set_member_name(builder, "timeout"); - json_builder_add_int_value(builder, timeout); - } - - json_builder_set_member_name(builder, "typing"); - json_builder_add_boolean_value(builder, typing); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_sync(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *filter_id, - MatrixFilter *filter, - const gchar *since, - gboolean full_state, - gboolean set_presence, - gulong timeout, - GError **error) -{ - GHashTable *params; - - params = create_query_params(); - - if (filter_id && filter) { - g_set_error(error, - MATRIX_ERROR, MATRIX_ERROR_BAD_REQUEST, - "Cannot set both filter_id and filter"); - - return; - } - - if (filter_id) { - g_hash_table_replace(params, "filter", g_strdup(filter_id)); - } - - if (filter) { - g_hash_table_replace(params, - "filter", - matrix_filter_get_json_data( - (MatrixFilter *)filter, - NULL)); - } - - if (since) { - g_hash_table_replace(params, "since", g_strdup(since)); - } - - g_hash_table_replace(params, - "full_state", - g_strdup((full_state) ? "true" : "false")); - - if (!set_presence) { - g_hash_table_replace(params, "set_presence", g_strdup("offline")); - } - - if (timeout != 0) { - g_hash_table_replace(params, - "timeout", - g_strdup_printf("%lu", timeout)); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "sync", params, NULL, NULL, NULL, - FALSE, error); -} - -static void -i_create_filter(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - MatrixFilter *filter, - GError **error) -{ - gchar *encoded_user_id, *path; - JsonNode *filter_node = matrix_filter_get_json_node(filter); - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("user/%s/filter", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", path, NULL, NULL, filter_node, NULL, - FALSE, error); - g_free(path); -} - -static void -i_download_filter(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *filter_id, - GError **error) -{ - gchar *encoded_user_id, *encoded_filter_id, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - encoded_filter_id = soup_uri_encode(filter_id, NULL); - path = g_strdup_printf("user/%s/filter/%s", - encoded_user_id, encoded_filter_id); - g_free(encoded_user_id); - g_free(encoded_filter_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_whois(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GError **error) -{ - gchar *encoded_user_id, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("admin/whois/%s", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_token_refresh(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *refresh_token, - GError **error) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - JsonBuilder *builder; - JsonNode *body; - - if (!refresh_token && !priv->refresh_token) { - g_set_error(error, - MATRIX_ERROR, MATRIX_ERROR_M_MISSING_TOKEN, - "No token available"); - - return; - } - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "refresh_token"); - - if (!refresh_token) { - json_builder_add_string_value(builder, priv->refresh_token); - } else { - json_builder_add_string_value(builder, refresh_token); - } - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "tokenreresh", NULL, NULL, body, NULL, - FALSE, error); -} - -static void -i_get_3pids(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - GError **error) -{ - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "account/3pid", NULL, NULL, NULL, NULL, - FALSE, error); -} - -static void -i_versions(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - GError **error) -{ - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "versions", NULL, NULL, NULL, NULL, - FALSE, error); -} - -static void -i_add_3pid(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - gboolean bind_creds, - Matrix3PidCredential *threepid_creds, - GError **error) -{ - JsonBuilder *builder; - JsonNode *body, *id_node; - - if ((id_node = matrix_3pid_credential_get_json_node( - threepid_creds, error)) == NULL) { - g_set_error(error, - MATRIX_ERROR, MATRIX_ERROR_INCOMPLETE, - "Incomplete credential"); - - return; - } - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "bind"); - json_builder_add_boolean_value(builder, bind_creds); - - json_builder_set_member_name(builder, "threePidCreds"); - json_builder_add_value(builder, id_node); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "account/3pid", NULL, NULL, body, NULL, - FALSE, error); -} - -static void -i_change_password(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *new_password, - GError **error) -{ - JsonBuilder *builder; - JsonNode *body; - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "new_password"); - json_builder_add_string_value(builder, new_password); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "account/password", NULL, NULL, body, NULL, - FALSE, error); -} - -static void -i_get_profile(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GError **error) -{ - gchar *encoded_user_id, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("profile/%s", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_avatar_url(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GError **error) -{ - gchar *encoded_user_id, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("profile/%s/avatar_url", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_set_avatar_url(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *avatar_url, - GError **error) -{ - gchar *encoded_user_id, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("profile/%s/avatar_url", encoded_user_id); - g_free(encoded_user_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "avatar_url"); - json_builder_add_string_value(builder, avatar_url); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_display_name(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - GError **error) -{ - gchar *encoded_user_id, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("profile/%s/displayname", encoded_user_id); - g_free(encoded_user_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_set_display_name(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *display_name, - GError **error) -{ - gchar *encoded_user_id, *path; - JsonBuilder *builder; - JsonNode *body; - - encoded_user_id = soup_uri_encode(user_id, NULL); - path = g_strdup_printf("profile/%s/displayname", encoded_user_id); - g_free(encoded_user_id); - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "displayname"); - json_builder_add_string_value(builder, display_name); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, body, NULL, - FALSE, error); - g_free(path); -} - -static void -i_register_account(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - MatrixAccountKind account_kind, - gboolean bind_email, - const gchar *username, - const gchar *password, - GError **error) -{ - JsonBuilder *builder; - JsonNode *body; - GHashTable *params = NULL; - - builder = json_builder_new(); - json_builder_begin_object(builder); - - json_builder_set_member_name(builder, "bind_email"); - json_builder_add_boolean_value(builder, bind_email); - - if (username) { - json_builder_set_member_name(builder, "username"); - json_builder_add_string_value(builder, username); - } - - json_builder_set_member_name(builder, "password"); - json_builder_add_string_value(builder, password); - - json_builder_end_object(builder); - body = json_builder_get_root(builder); - g_object_unref(builder); - - if (account_kind != MATRIX_ACCOUNT_KIND_DEFAULT) { - gchar *kind_string = _matrix_g_enum_value_to_nick( - MATRIX_TYPE_ACCOUNT_KIND, - account_kind, TRUE); - - params = create_query_params(); - - g_hash_table_replace(params, "kind", kind_string); - } - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "POST", "register", params, NULL, body, NULL, - FALSE, error); -} - -static void -i_set_account_data(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *room_id, - const gchar *event_type, - JsonNode *content, - GError **error) -{ - gchar *encoded_user_id, *encoded_type, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - encoded_type = soup_uri_encode(event_type, NULL); - - if (room_id) { - gchar *encoded_room_id = soup_uri_encode(room_id, NULL); - - path = g_strdup_printf("user/%s/rooms/%s/account_data/%s", - encoded_user_id, encoded_room_id, encoded_type); - g_free(encoded_room_id); - } else { - path = g_strdup_printf("user/%s/account_data/%s", - encoded_user_id, encoded_type); - } - - g_free(encoded_user_id); - g_free(encoded_type); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, content, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_room_tags(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *room_id, - GError **error) -{ - gchar *encoded_user_id, *encoded_room_id, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - encoded_room_id = soup_uri_encode(room_id, NULL); - path = g_strdup_printf("user/%s/rooms/%s/tags", - encoded_user_id, encoded_room_id); - g_free(encoded_user_id); - g_free(encoded_room_id); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_delete_room_tag(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *room_id, - const gchar *tag, - GError **error) -{ - gchar *encoded_user_id, *encoded_room_id, *encoded_tag, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_tag = soup_uri_encode(tag, NULL); - path = g_strdup_printf("user/%s/rooms/%s/tags/%s", - encoded_user_id, encoded_room_id, encoded_tag); - g_free(encoded_user_id); - g_free(encoded_room_id); - g_free(encoded_tag); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "DELETE", path, NULL, NULL, NULL, NULL, - FALSE, error); - g_free(path); -} - -static void -i_add_room_tag(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - const gchar *user_id, - const gchar *room_id, - const gchar *tag, - JsonNode *content, - GError **error) -{ - gchar *encoded_user_id, *encoded_room_id, *encoded_tag, *path; - - encoded_user_id = soup_uri_encode(user_id, NULL); - encoded_room_id = soup_uri_encode(room_id, NULL); - encoded_tag = soup_uri_encode(tag, NULL); - path = g_strdup_printf("user/%s/rooms/%s/tags/%s", - encoded_user_id, encoded_room_id, encoded_tag); - g_free(encoded_user_id); - g_free(encoded_room_id); - g_free(encoded_tag); - - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "PUT", path, NULL, NULL, content, NULL, - FALSE, error); - g_free(path); -} - -static void -i_get_turn_server(MatrixAPI *api, - MatrixAPICallback callback, - gpointer user_data, - GError **error) -{ - _send(MATRIX_HTTP_API(api), - callback, user_data, - CALL_API, - "GET", "void/turnServer", NULL, NULL, NULL, NULL, - FALSE, error); -} - -static void -i_abort_pending(MatrixAPI *api) -{ - MatrixHTTPAPIPrivate *priv = matrix_http_api_get_instance_private( - MATRIX_HTTP_API(api)); - - soup_session_abort(priv->soup_session); -} - -static void -matrix_http_api_matrix_api_init(MatrixAPIIface *iface) -{ - iface->set_token = i_set_token; - iface->get_token = i_get_token; - iface->set_refresh_token = i_set_refresh_token; - iface->get_refresh_token = i_get_refresh_token; - iface->get_user_id = i_get_user_id; - iface->get_homeserver = i_get_homeserver; - - /* Media */ - iface->media_download = i_media_download; - iface->media_thumbnail = i_media_thumbnail; - iface->media_upload = i_media_upload; - - /* Presence */ - iface->get_presence_list = i_get_presence_list; - iface->update_presence_list = i_update_presence_list; - iface->get_user_presence = i_get_user_presence; - iface->set_user_presence = i_set_user_presence; - - /* Push notifications */ - iface->update_pusher = i_update_pusher; - iface->get_pushers = i_get_pushers; - iface->delete_pusher = i_delete_pusher; - iface->get_pusher = i_get_pusher; - iface->add_pusher = i_add_pusher; - iface->toggle_pusher = i_toggle_pusher; - - /* Room creation */ - iface->create_room = i_create_room; - - /* Room directory */ - iface->delete_room_alias = i_delete_room_alias; - iface->get_room_id = i_get_room_id; - iface->create_room_alias = i_create_room_alias; - - /* Room discovery */ - iface->list_public_rooms = i_list_public_rooms; - - /* Room membership */ - iface->ban_user = i_ban_user; - iface->forget_room = i_forget_room; - iface->invite_user_3rdparty = i_invite_user_3rdparty; - iface->invite_user = i_invite_user; - iface->join_room = i_join_room; - iface->leave_room = i_leave_room; - - /* Room participation */ - iface->event_stream = i_event_stream; - iface->get_event = i_get_event; - iface->initial_sync = i_initial_sync; - iface->get_event_context = i_get_event_context; - iface->initial_sync_room = i_initial_sync_room; - iface->list_room_members = i_list_room_members; - iface->list_room_messages = i_list_room_messages; - iface->send_event_receipt = i_send_event_receipt; - iface->redact_event = i_redact_event; - iface->send_message_event = i_send_message_event; - iface->get_room_state = i_get_room_state; - iface->send_room_event = i_send_room_event; - iface->notify_room_typing = i_notify_room_typing; - iface->sync = i_sync; - iface->create_filter = i_create_filter; - iface->download_filter = i_download_filter; - - /* Search */ - - /* Server administration */ - iface->whois = i_whois; - iface->versions = i_versions; - - /* Session management */ - iface->login = i_login; - iface->token_refresh = i_token_refresh; - - /* User data */ - iface->get_3pids = i_get_3pids; - iface->add_3pid = i_add_3pid; - iface->change_password = i_change_password; - iface->get_profile = i_get_profile; - iface->get_avatar_url = i_get_avatar_url; - iface->set_avatar_url = i_set_avatar_url; - iface->get_display_name = i_get_display_name; - iface->set_display_name = i_set_display_name; - iface->register_account = i_register_account; - iface->set_account_data = i_set_account_data; - iface->get_room_tags = i_get_room_tags; - iface->delete_room_tag = i_delete_room_tag; - iface->add_room_tag = i_add_room_tag; - - /* VoIP */ - iface->get_turn_server = i_get_turn_server; - - /* Non-spec methods */ - iface->abort_pending = i_abort_pending; -} diff --git a/src/matrix-http-api.h b/src/matrix-http-api.h deleted file mode 100644 index f8641fb..0000000 --- a/src/matrix-http-api.h +++ /dev/null @@ -1,60 +0,0 @@ -/* - * This file is part of matrix-glib-sdk - * - * matrix-glib-sdk 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 3 of the License, or (at your option) any later version. - * - * matrix-glib-sdk 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 matrix-glib-sdk. If not, see - * . - */ - -#ifndef __MATRIX_HTTP_API_H__ -#define __MATRIX_HTTP_API_H__ - -#include - -#include "matrix-glib.h" - -G_BEGIN_DECLS - -#define MATRIX_TYPE_HTTP_API (matrix_http_api_get_type()) -#define MATRIX_HTTP_API(o) (G_TYPE_CHECK_INSTANCE_CAST((o), MATRIX_TYPE_HTTP_API, MatrixHTTPAPI)) -#define MATRIX_HTTP_API_CLASS(k) (G_TYPE_CHECK_CLASS_CAST((k), MATRIX_TYPE_HTTP_API, MatrixHTTPAPIClass)) -#define MATRIX_IS_HTTP_API(o) (G_TYPE_CHECK_INSTANCE_TYPE((o), MATRIX_TYPE_HTTP_API)) -#define MATRIX_IS_HTTP_API_CLASS(k) (G_TYPE_CHECK_CLASS_TYPE((k), MATRIX_TYPE_HTTP_API)) -#define MATRIX_HTTP_API_GET_CLASS(o) (G_TYPE_INSTANCE_GET_CLASS((o), MATRIX_TYPE_HTTP_API, MatrixHTTPAPIClass)) - -typedef struct _MatrixHTTPAPI MatrixHTTPAPI; -typedef struct _MatrixHTTPAPIClass MatrixHTTPAPIClass; - -struct _MatrixHTTPAPI { - /* Parent instance structure */ - GObject parent_instance; - - /* Instance members */ -}; - -struct _MatrixHTTPAPIClass { - GObjectClass parent_class; -}; - -GType matrix_http_api_get_type(void) G_GNUC_CONST; -void matrix_http_api_set_validate_certificate(MatrixHTTPAPI *api, - gboolean validate_certificate); -gboolean matrix_http_api_get_validate_certificate(MatrixHTTPAPI *api); -void matrix_http_api_set_base_url(MatrixHTTPAPI *api, const gchar *base_url); -gchar *matrix_http_api_get_base_url(MatrixHTTPAPI *api); - -MatrixAPI *matrix_http_api_new(const gchar *base_url, const gchar *token); - -G_END_DECLS - -#endif /* __MATRIX_HTTP_API_H__ */ diff --git a/src/matrix-http-api.vala b/src/matrix-http-api.vala new file mode 100644 index 0000000..bfb62ac --- /dev/null +++ b/src/matrix-http-api.vala @@ -0,0 +1,1745 @@ +/* + * This file is part of matrix-glib-sdk + * + * matrix-glib-sdk 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 3 of the License, or (at your option) any later version. + * + * matrix-glib-sdk 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 matrix-glib-sdk. If not, see + * . + */ + +/** + * This is a class for low level communication with a Matrix.org + * server via HTTP. + */ +[CCode (lower_case_csuffix = "http_api")] +public class Matrix.HTTPAPI : GLib.Object, Matrix.API { + private enum CallType { + API, + MEDIA; + } + + private const string API_ENDPOINT = "/_matrix/client/r0/"; + private const string MEDIA_ENDPOINT = "/_matrix/media/r0/"; + + private Soup.Session _soup_session = new Soup.Session(); + private string? _base_url = null; + private Soup.URI? _api_uri = null; + private Soup.URI? _media_uri = null; + + public string base_url { + get { + return _base_url; + } + + set { + Soup.URI? api_uri; + Soup.URI? media_uri; + + if (!value.is_ascii()) { + warning("URL specified(%s) is not ASCII", value); + + return; + } + + if (value.last_index_of(API_ENDPOINT) != -1) { + warning("Provided URL (%s) already contains the API endpoint. Please use an URL without it!", + base_url); + + return; + } + + _set_url(out api_uri, value, API_ENDPOINT); + _set_url(out media_uri, value, MEDIA_ENDPOINT); + + if ((api_uri != null) && (media_uri != null)) { + _api_uri = api_uri; + _media_uri = media_uri; + + _token = null; + _refresh_token = null; + _homeserver = null; + _user_id = null; + + debug("API URL: %s", api_uri.to_string(false)); + debug("Media URL: %s", media_uri.to_string(false)); + } else { + warning("Invalid base URL: %s", value); + } + } + } + public bool validate_certificate { + get { + return _soup_session.ssl_strict; + } + + set { + _soup_session.ssl_strict = value; + } + } + private string? _user_id; + public string? user_id { + get { + return _user_id; + } + + default = null; + } + public string? token { get; set; default = null; } + public string? refresh_token { get; set; default = null; } + private string? _homeserver; + public string? homeserver { + get { + return _homeserver; + } + + default = null; + } + + private void + _set_url(out Soup.URI? uri, string base_url, string endpoint) + { + string url; + + if (base_url[base_url.length - 1] == '/') { + url = "%s%s".printf(base_url, endpoint.offset(1)); + } else { + url = "%s%s".printf(base_url, endpoint); + } + + var new_uri = new Soup.URI(url); + + if (SOUP_URI_VALID_FOR_HTTP(new_uri)) { + uri = new_uri; + } else { + uri = null; + } + } + + protected + HTTPAPI(string base_url, string? token = null) + { + Object(base_url : base_url, token : token); + _soup_session.ssl_strict = true; + } + + // This macro is not available in Vala + private static bool + SOUP_URI_VALID_FOR_HTTP(Soup.URI? uri) + { + return ((uri != null) + && ((uri.scheme == "http") + || (uri.scheme == "https")) + && (uri.host != null) + && (uri.path != null)); + } + + private void + _send(API.Callback? cb, + CallType call_type, + string method, + string path, + owned GLib.HashTable? parms, + string? content_type, + Json.Node? json_content, + ByteArray? raw_content, + bool accept_non_json) + throws Matrix.Error + { + if ((_api_uri == null) || (_media_uri == null)) { + throw new Matrix.Error.COMMUNICATION_ERROR("No valid base URL"); + } + + if ((json_content != null) && (raw_content != null)) { + critical("json_content and raw_content cannot be used together. This is a bug."); + } + + if (!method.is_ascii()) { + critical("Method must be ASCII. This is a bug."); + } + + if ((method.ascii_casecmp("GET") != 0) + && (method.ascii_casecmp("POST") != 0) + && (method.ascii_casecmp("PUT") != 0) + && (method.ascii_casecmp("DELETE") != 0)) { + critical("Method %s is invalid. This is a bug.", method); + } + + Soup.URI? request_path = null; + + if (call_type == CallType.MEDIA) { + request_path = new Soup.URI.with_base(_media_uri, path); + } else { + request_path = new Soup.URI.with_base(_api_uri, path); + } + + if (parms == null) { + parms = _create_query_params(); + } + + if (token != null) { + debug("Adding access token '%s'", token); + + parms.replace("access_token", token); + } + + request_path.set_query_from_form(parms); + + var message = new Soup.Message.from_uri(method, request_path); + + uint8[] request_data; + + if (json_content != null) { + var generator = new Json.Generator(); + generator.set_root(json_content); + var json_str = generator.to_data(null); + request_data = json_str.data; + } else if (raw_content != null) { + request_data = raw_content.data; + } else { + request_data = "{}".data; + } + + debug("Sending %d bytes (%s %s): %s", + request_data.length, + method, + request_path.to_string(false), + (raw_content != null) + ? "" + : (string)request_data); + + message.set_flags(Soup.MessageFlags.NO_REDIRECT); + message.set_request( + (content_type == null) + ? "application/json" + : content_type, + Soup.MemoryUse.COPY, + request_data); + + _soup_session.queue_message( + message, + (session, msg) => _response_callback(msg, + call_type, + accept_non_json, + cb)); + } + + private void + _response_callback(Soup.Message msg, + CallType call_type, + bool accept_non_json, + API.Callback? cb) + { + string request_url = msg.get_uri().get_path(); + Matrix.Error? err = null; + ByteArray? raw_content = null; + Json.Node? content = null; + + switch (call_type) { + case CallType.API: + request_url = request_url .substring(API_ENDPOINT.length); + + break; + + case CallType.MEDIA: + request_url = request_url.substring(MEDIA_ENDPOINT.length); + + break; + } + + if ((msg.status_code < 100) + || (msg.status_code >= 400)) { + err = new Matrix.Error.COMMUNICATION_ERROR( + "%s %u: %s", + (msg.status_code < 100) ? "Network error" : "HTTP", + msg.status_code, + msg.reason_phrase); + } else { + var buffer = msg.response_body.flatten(); + string data = (string)buffer.data; + var datalen = buffer.length; + var parser = new Json.Parser(); + bool is_json; + + try { + is_json = parser.load_from_data(data, (ssize_t)datalen); + } catch (GLib.Error e) { + is_json = false; + } + + if (is_json) { + debug("Response (%s): %s", request_url, data); + + content = parser.get_root(); + + if (content.get_node_type() == Json.NodeType.OBJECT) { + var root = content.get_object(); + Json.Node node; + + /* Check if the response holds an access token; if it + * does, set it as our new token */ + if ((node = root.get_member("access_token")) != null) { + string? access_token; + + if ((access_token = node.get_string()) != null) { + debug("Got new access token: %s", access_token); + token = access_token; + } + } + + /* Check if the response holds a refresh token; if it + * does, set it as our new refresh token */ + if ((node = root.get_member("refresh_token")) != null) { + string? refresh_token; + + if ((refresh_token = node.get_string()) != null) { + debug("Got new refresh token: %s", + refresh_token); + this.refresh_token = refresh_token; + } + } + + /* Check if the response holds a homeserver name */ + if ((node = root.get_member("home_server")) != null) { + string homeserver = node.get_string(); + + debug("Our home server calls itself %s", homeserver); + this._homeserver = homeserver; + } + + /* Check if the response holds a user ID; if it does, + * set this as our user ID */ + if ((node = root.get_member("user_id")) != null) { + string user_id = node.get_string(); + + debug("We are reported to be logged in as %s", user_id); + this._user_id = user_id; + } + + /* Check if the response holds an error */ + var errcode_node = root.get_member("errcode"); + var error_node = root.get_member("error"); + string? error = null; + string? errcode = null; + + if ((errcode_node != null) || (error_node != null)) { + err = new Matrix.Error.UNKNOWN_ERROR( + "The error is not known to this library"); + + if (error_node != null) { + error = error_node.get_string(); + } + + if (errcode_node != null) { + errcode = errcode_node.get_string(); + + if (errcode.ascii_ncasecmp("M_", 2) == 0) { + // This is an ugly hack until Vala + // registers errordomains as an + // EnumClass + switch (errcode) { + case "M_MISSING_TOKEN": + err = new Matrix.Error.M_MISSING_TOKEN(""); + + break; + + case "M_FORBIDDEN": + err = new Matrix.Error.M_FORBIDDEN(""); + + break; + + case "M_UNKNOWN": + err = new Matrix.Error.M_UNKNOWN(""); + + break; + + case "M_UNKNOWN_TOKEN": + err = new Matrix.Error.M_UNKNOWN_TOKEN(""); + + break; + + case "M_NOT_JSON": + err = new Matrix.Error.M_NOT_JSON(""); + + break; + + case "M_UNRECOGNIZED": + err = new Matrix.Error.M_UNRECOGNIZED(""); + + break; + + default: + warning("An unknown error code '%s' was sent by the homeserver. You may want to report it to the Matrix GLib developers", errcode); + + break; + } + } + } else { + warning("An error was sent by the homeserver, but no error code was specified. You may want to report this to the homeserver admins."); + err = new Matrix.Error.UNSPECIFIED("No error code was sent by the server"); + } + + if ((errcode_node != null) && (error_node != null)) { + err.message = "%s: %s".printf(errcode, error); + } else if (errcode_node != null) { + err.message = errcode; + } else { + err.message = "(No errcode given) %s".printf(error); + } + } + } else if (content.get_node_type() != Json.NodeType.ARRAY) { + err = new Matrix.Error.BAD_RESPONSE( + "Bad response: not a JSON object, nor an array."); + } + } else { + if (accept_non_json) { + raw_content = new ByteArray.sized((uint)datalen); + raw_content.append(buffer.data); + debug("Binary data (%s): %u bytes", request_url, (uint)datalen); + } else { + err = new Matrix.Error.BAD_RESPONSE( + "Malformed response (invalid JSON)"); + debug("Malformed response (%s): %s", request_url, data); + } + } + } + + /* Call the assigned function, if any */ + if (cb != null) { + cb(this, + msg.response_headers.get_content_type(null), + content, + raw_content, + err); + } + } + + private static HashTable + _create_query_params() + { + return new HashTable(str_hash, str_equal); + } + + /* Media */ + + public void + media_download(API.Callback? cb, + string server_name, + string media_id) + throws Matrix.Error + { + string path = "download/" + + Soup.URI.encode(server_name, null) + + "/" + + Soup.URI.encode(media_id, null); + + _send(cb, + CallType.MEDIA, "GET", path, + null, null, null, null, true); + } + + public void + media_thumbnail(API.Callback? cb, + string server_name, + string media_id, + uint width, + uint height, + ResizeMethod method) + throws Matrix.Error + { + string path = "download/" + + Soup.URI.encode(server_name, null) + + "/" + + Soup.URI.encode(media_id, null); + HashTable parms; + + parms = _create_query_params(); + + if (width > 0) { + parms.replace("width", "%u".printf(width)); + } + + if (height > 0) { + parms.replace("height", "%u".printf(height)); + } + + if (method != ResizeMethod.DEFAULT) { + switch (method) { + case ResizeMethod.CROP: + parms.replace("method", "crop"); + + break; + + case ResizeMethod.SCALE: + parms.replace("method", "scale"); + + break; + + // This is here to prevent compiler warnings + case ResizeMethod.DEFAULT: break; + } + } + + _send(cb, + CallType.MEDIA, "GET", path, + parms, null, null, null, true); + } + + public void + media_upload(API.Callback? cb, + string? content_type, + owned ByteArray content) + throws Matrix.Error + { + _send(cb, + CallType.MEDIA, "POST", "upload", + null, content_type, null, content, false); + } + + /* Presence */ + + public void + get_presence_list(API.Callback? cb, string user_id) + throws Matrix.Error + { + string path = "presence/list/" + Soup.URI.encode(user_id, null); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + update_presence_list(API.Callback? cb, + string user_id, + List drop_ids, + List invite_ids) + throws Matrix.Error + { + Json.Builder builder; + string path = "presence/" + + Soup.URI.encode(user_id, null) + + "/status"; + + builder = new Json.Builder(); + builder.begin_object(); + + if (drop_ids != null) { + builder.set_member_name("drop"); + builder.begin_array(); + drop_ids.foreach( + (entry) => { + builder.add_string_value(entry); + }); + builder.end_array(); + } + + if (invite_ids != null) { + builder.set_member_name("invite"); + builder.begin_array(); + invite_ids.foreach( + (entry) => { + builder.add_string_value(entry); + }); + builder.end_array(); + } + + builder.end_object(); + + _send(cb, + CallType.API, "POST", path, + null, null, builder.get_root(), null, false); + } + + public void + get_user_presence(API.Callback? cb, + string user_id) + throws Matrix.Error + { + string path = "presence/" + + Soup.URI.encode(user_id, null) + + "/status"; + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + set_user_presence(API.Callback? cb, + string user_id, + Presence presence, + string? status_message) + throws Matrix.Error + { + Json.Builder builder; + string path = "presence/" + + Soup.URI.encode(user_id, null) + + "/status"; + + builder = new Json.Builder(); + builder.begin_object(); + + builder.set_member_name("presence"); + builder.add_string_value( + _g_enum_value_to_nick(typeof(Matrix.Presence), + presence)); + + if (status_message != null) { + builder.set_member_name("status_msg"); + builder.add_string_value(status_message); + } + + _send(cb, + CallType.API, "POST", path, + null, null, builder.get_root(), null, false); + } + + /* Push notifications */ + + public void + update_pusher(API.Callback? cb, + Matrix.Pusher pusher) + throws Matrix.Error + { + Json.Node? pusher_node; + + if ((pusher_node = pusher.get_json_node()) != null) { + return; + } + + _send(cb, + CallType.API, "POST", "pushers/set", + null, null, pusher_node, null, false); + } + + public void + get_pushers(API.Callback? cb) + throws Matrix.Error + { + _send(cb, + CallType.API, "GET", "pushrules", + null, null, null, null, false); + } + + private static string + _pusher_url(string scope, + PusherKind kind, + string rule_id) + { + return "pushrules/" + + Soup.URI.encode(scope, null) + + "/" + + Soup.URI.encode(_g_enum_value_to_nick( + typeof(Matrix.PusherKind), + kind), + null) + + "/" + + Soup.URI.encode(rule_id, null); + } + + private void + _pusher_modif(API.Callback? cb, + string method, + string scope, + PusherKind kind, + string rule_id) + throws Matrix.Error + { + _send(cb, + CallType.API, method, + _pusher_url(scope, kind, rule_id), + null, null, null, null, false); + } + + public void + delete_pusher(API.Callback? cb, + string scope, + PusherKind kind, + string rule_id) + throws Matrix.Error + { + _pusher_modif(cb, "DELETE", scope, kind, rule_id); + } + + public void + get_pusher(API.Callback? cb, + string scope, + PusherKind kind, + string rule_id) + throws Matrix.Error + { + _pusher_modif(cb, "GET", scope, kind, rule_id); + } + + public void + add_pusher(API.Callback? cb, + string scope, + PusherKind kind, + string rule_id, + string? before, + string? after, + List actions, + List? conditions) + throws Matrix.Error + { + Json.Builder builder; + HashTable parms = _create_query_params(); + + if (before != null) { + parms.replace("before", before); + } + + if (after != null) { + parms.replace("after", after); + } + + builder = new Json.Builder(); + builder.begin_object(); + + builder.set_member_name("actions"); + builder.begin_array(); + actions.foreach( + (entry) => { + builder.add_string_value(entry); + }); + builder.end_array(); + + if (conditions != null) { + builder.set_member_name("conditions"); + builder.begin_array(); + conditions.foreach( + (entry) => { + string? kind_string = _g_enum_value_to_nick( + typeof(Matrix.PusherConditionKind), + entry); + + if (kind_string == null) { + warning("Invalid condition kind"); + + return; + } + + builder.begin_object(); + builder.set_member_name("kind"); + builder.add_string_value(kind_string); + builder.end_object(); + }); + builder.end_array(); + } + + builder.end_object(); + + _send(cb, + CallType.API, "GET", + _pusher_url(scope, kind, rule_id), + parms, null, builder.get_root(), null, false); + } + + public void + toggle_pusher(API.Callback? cb, + string scope, + PusherKind kind, + string rule_id, + bool enabled) + throws Matrix.Error + { + Json.Builder builder; + + builder = new Json.Builder(); + builder.begin_object(); + + builder.set_member_name("enabled"); + builder.add_boolean_value(enabled); + + builder.end_object(); + + _send(cb, + CallType.API, "GET", + _pusher_url(scope, kind, rule_id), + null, null, builder.get_root(), null, false); + } + + /* Room creation */ + + public void + create_room(API.Callback? cb, + RoomPreset preset, + string? room_name, + string? room_alias, + string? topic, + RoomVisibility visibility, + Json.Node? creation_content, + List? initial_state, + List? invitees, + List<3PidCredential>? invite_3pids) + throws Matrix.Error + { + Json.Builder builder = new Json.Builder(); + + builder.begin_object(); + + if (creation_content != null) { + builder.set_member_name("creation_content"); + builder.add_value(creation_content); + } + + if (initial_state != null) { + builder.set_member_name("initial_state"); + builder.begin_array(); + initial_state.foreach( + (entry) => { + builder.add_value(entry.get_json_node()); + }); + builder.end_array(); + } + + if (invitees != null) { + builder.set_member_name("invite"); + builder.begin_array(); + invitees.foreach( + (entry) => { + builder.add_string_value(entry); + }); + builder.end_array(); + } + + if (invite_3pids != null) { + builder.set_member_name("invite_3pid"); + builder.begin_array(); + invite_3pids.foreach( + (entry) => { + try { + builder.add_value(entry.get_json_node()); + // TODO exceptions should be handled + // here somehow + } catch (Matrix.Error e) {} + }); + builder.end_array(); + } + + if (room_name != null) { + builder.set_member_name("name"); + builder.add_string_value(room_name); + } + + if (preset != RoomPreset.NONE) { + string? preset_string = _g_enum_value_to_nick( + typeof(RoomPreset), + preset); + + if (preset_string != null) { + builder.set_member_name("preset"); + builder.add_string_value(preset_string); + } else { + warning("Invalid room preset type"); + } + } + + if (room_alias != null) { + builder.set_member_name("room_alias_name"); + builder.add_string_value(room_alias); + } + + if (topic != null) { + builder.set_member_name("topic"); + builder.add_string_value(topic); + } + + if (visibility != RoomVisibility.DEFAULT) { + string? visibility_string = _g_enum_value_to_nick( + typeof(RoomVisibility), visibility); + + if (visibility_string != null) { + builder.set_member_name("visibility"); + builder.add_string_value(visibility_string); + } else { + warning("Invalid room visibility type"); + } + } + + _send(cb, + CallType.API, "POST", "createRoom", + null, null, builder.get_root(), null, false); + } + + /* Room directory */ + + public void + delete_room_alias(API.Callback? cb, + string room_alias) + throws Matrix.Error + { + string path = "room/" + Soup.URI.encode(room_alias, null); + + _send(cb, + CallType.API, "DELETE", path, + null, null, null, null, false); + } + + public void + get_room_id(API.Callback? cb, + string room_alias) + throws Matrix.Error + { + string path = "room/" + Soup.URI.encode(room_alias, null); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + create_room_alias(API.Callback? cb, + string room_id, + string room_alias) + throws Matrix.Error + { + Json.Builder builder; + string path = "room/" + Soup.URI.encode(room_alias, null); + + builder = new Json.Builder(); + builder.begin_object(); + + builder.set_member_name("room_id"); + builder.add_string_value(room_id); + + builder.end_object(); + + _send(cb, + CallType.API, "PUT", path, + null, null, builder.get_root(), null, false); + } + + /* Room discovery */ + + public void + list_public_rooms(API.Callback? cb) + throws Matrix.Error + { + _send(cb, + CallType.API, "GET", "publicRooms", + null, null, null, null, false); + } + + /* Room membership */ + + public void + ban_user(API.Callback? cb, + string room_id, + string user_id, + string? reason) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/ban"; + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("user_id"); + builder.add_string_value(user_id); + + if (reason != null) { + builder.set_member_name("reason"); + builder.add_string_value(reason); + } + + builder.end_object(); + + _send(cb, + CallType.API, "POST", path, + null, null, builder.get_root(), null, false); + } + + public void + forget_room(API.Callback? cb, + string room_id) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/forget"; + + _send(cb, + CallType.API, "POST", path, + null, null, null, null, false); + } + + public void + invite_user_3rdparty(API.Callback? cb, + string room_id, + Matrix.3PidCredential credential) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/invite"; + Json.Node? body; + + if ((body = credential.get_json_node()) == null) { + return; + } + + _send(cb, + CallType.API, "POST", path, + null, null, body, null, false); + } + + public void + invite_user(API.Callback? cb, + string room_id, + string user_id) + throws Matrix.Error + { + var builder = new Json.Builder(); + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/invite"; + + builder.begin_object(); + + builder.set_member_name("user_id"); + builder.add_string_value(user_id); + + builder.end_object(); + + _send(cb, + CallType.API, "POST", path, + null, null, builder.get_root(), null, false); + } + + public void + join_room(API.Callback? cb, + string room_id) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/join"; + + _send(cb, + CallType.API, "POST", path, + null, null, null, null, false); + } + + public void + leave_room(API.Callback? cb, + string room_id) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/leave"; + + _send(cb, + CallType.API, "POST", path, + null, null, null, null, false); + } + + /* Room participation */ + + public void + event_stream(API.Callback? cb, + string? from_token, + ulong timeout) + throws Matrix.Error + { + HashTable parms = _create_query_params(); + + if (from_token != null) { + parms.replace("from", from_token); + } + + if (timeout > 0) { + parms.replace("timeout", "%lu".printf(timeout)); + } + + _send(cb, + CallType.API, "GET", "events", + parms, null, null, null, false); + } + + public void + get_event(API.Callback? cb, + string event_id) + throws Matrix.Error + { + string path = "events/" + Soup.URI.encode(event_id, null); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + initial_sync(API.Callback? cb, + uint limit, + bool archived) + throws Matrix.Error + { + HashTable parms = _create_query_params(); + + if (limit != 0) { + parms.replace("limit", "%u".printf(limit)); + } + + if (archived) { + parms.replace("archived", "true"); + } + + _send(cb, + CallType.API, "GET", "initialSync", + parms, null, null, null, false); + } + + public void + get_event_context(API.Callback? cb, + string room_id, + string event_id, + uint limit) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/" + + Soup.URI.encode(event_id, null); + HashTable? parms = null; + + if (limit > 0) { + parms = _create_query_params(); + + parms.replace("limit", "%u".printf(limit)); + } + + _send(cb, + CallType.API, "GET", path, + parms, null, null, null, false); + } + + public void + initial_sync_room(API.Callback? cb, + string room_id) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/initialSync"; + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + list_room_members(API.Callback? cb, + string room_id) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/members"; + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + list_room_messages(API.Callback? cb, + string room_id, + string from_token, + EventDirection direction, + uint limit) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/messages"; + HashTable parms = _create_query_params(); + + parms.replace("from", from_token); + + switch (direction) { + case EventDirection.BACKWARD: + parms.replace("dir", "b"); + + break; + + case EventDirection.FORWARD: + parms.replace("dir", "f"); + + break; + } + + if (limit > 0) { + parms.replace("limit", "%u".printf(limit)); + } + + _send(cb, + CallType.API, "GET", path, + parms, null, null, null, false); + } + + public void + send_event_receipt(API.Callback? cb, + string room_id, + ReceiptType receipt_type, + string event_id, + Json.Node receipt) + throws Matrix.Error + { + string path = "rooms/" + + Soup.URI.encode(room_id, null) + + "/receipt/" + + Soup.URI.encode(_g_enum_value_to_nick( + typeof(ReceiptType), + receipt_type), + null) + + "/" + + Soup.URI.encode(event_id, null); + + _send(cb, + CallType.API, "POST", path, + null, null, receipt, null, false); + } + + public void + redact_event(API.Callback? cb, + string room_id, + string event_id, + string txn_id, + string? reason) + throws Matrix.Error + { + Json.Node? body = null; + string path = "rooms/%s/redact/%s/%s".printf( + Soup.URI.encode(room_id, null), + Soup.URI.encode(event_id, null), + Soup.URI.encode(txn_id, null)); + + if (reason != null) { + var builder = new Json.Builder(); + builder.begin_object(); + + builder.set_member_name("reason"); + builder.add_string_value(reason); + + builder.end_object(); + body = builder.get_root(); + } + + _send(cb, + CallType.API, "PUT", path, + null, null, body, null, false); + } + + public void + send_message_event(API.Callback? cb, + string room_id, + string event_type, + string txn_id, + owned Json.Node content) + throws Matrix.Error + { + string path = "rooms/%s/send/%s/%s".printf( + Soup.URI.encode(room_id, null), + Soup.URI.encode(event_type, null), + Soup.URI.encode(txn_id, null)); + + _send(cb, + CallType.API, "PUT", path, + null, null, content, null, false); + } + + public void + get_room_state(API.Callback? cb, + string room_id, + string? event_type, + string? state_key) + throws Matrix.Error + { + string path = "rooms/%s/state".printf( + Soup.URI.encode(room_id, null)); + + if (event_type != null) { + path += "/%s".printf(Soup.URI.encode(event_type, null)); + } + + if (state_key != null) { + path += "/%s".printf(Soup.URI.encode(state_key, null)); + } + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + send_room_event(API.Callback? cb, + string room_id, + string event_type, + string? state_key, + owned Json.Node content) + throws Matrix.Error + { + string path = "rooms/%s/state/%s".printf( + Soup.URI.encode(room_id, null), + Soup.URI.encode(event_type, null)); + + if (state_key != null) { + path += "/%s".printf(Soup.URI.encode(state_key, null)); + } + + _send(cb, + CallType.API, "PUT", path, + null, null, content, null, false); + } + + public void + notify_room_typing(API.Callback? cb, + string user_id, + string room_id, + uint timeout, + bool typing) + throws Matrix.Error + { + string path = "rooms/%s/typing/%s".printf( + Soup.URI.encode(room_id, null), + Soup.URI.encode(user_id, null)); + var builder = new Json.Builder(); + + builder.begin_object(); + + if (timeout > 0) { + builder.set_member_name("timeout"); + builder.add_int_value(timeout); + } + + builder.set_member_name("typing"); + builder.add_boolean_value(typing); + + _send(cb, + CallType.API, "PUT", path, + null, null, builder.get_root(), null, false); + } + + public void + sync(API.Callback? cb, + string? filter_id, + Filter? filter, + string? since, + bool full_state, + bool set_presence, + ulong timeout) + throws Matrix.Error + { + HashTable parms = _create_query_params(); + + if ((filter_id != null) && (filter != null)) { + throw new Matrix.Error.BAD_REQUEST( + "Cannot set both filter_id and filter"); + } + + if (filter_id != null) { + parms.replace("filter", filter_id); + } + + if (filter != null) { + parms.replace("filter", filter.get_json_data(null)); + } + + if (since != null) { + parms.replace("since", since); + } + + parms.replace("full_state", (full_state) ? "true" : "false"); + + if (!set_presence) { + parms.replace("set_presence", "offline"); + } + + if (timeout != 0) { + parms.replace("timeout", "%lu".printf(timeout)); + } + + _send(cb, + CallType.API, "GET", "sync", + parms, null, null, null, false); + } + + public void + create_filter(API.Callback? cb, + string user_id, + Filter filter) + throws Matrix.Error + { + string path = "user/%s/filter".printf( + Soup.URI.encode(user_id, null)); + + _send(cb, + CallType.API, "POST", path, + null, null, filter.get_json_node(), null, false); + } + + public void + download_filter(API.Callback? cb, + string user_id, + string filter_id) + throws Matrix.Error + { + string path = "user/%s/filter/%s".printf( + Soup.URI.encode(user_id, null), + Soup.URI.encode(filter_id, null)); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + /* Search */ + + /* Server administration */ + + public void + whois(API.Callback? cb, string user_id) + throws Matrix.Error + { + string path = "admin/whois/" + Soup.URI.encode(user_id, null); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + versions(API.Callback? cb) + throws Matrix.Error + { + _send(cb, + CallType.API, "GET", "versions", + null, null, null, null, false); + } + + /* Session management */ + + public void + login(API.Callback? cb, + string login_type, + Json.Node? content) + throws Matrix.Error + { + Json.Node body = _json_node_deep_copy(content); + + body.get_object().set_string_member("type", login_type); + + _send(cb, + CallType.API, "POST", "login", + null, null, body, null, false); + } + + public void + token_refresh(API.Callback? cb, + string? refresh_token) + throws Matrix.Error + { + if ((refresh_token == null) && (this.refresh_token == null)) { + throw new Matrix.Error.M_MISSING_TOKEN("No token available"); + } + + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("refresh_token"); + builder.add_string_value((refresh_token != null) + ? refresh_token + : this.refresh_token); + + builder.end_object(); + + _send(cb, + CallType.API, "POST", "tokenrefresh", + null, null, builder.get_root(), null, false); + } + + /* User data */ + + public void + get_3pids(API.Callback? cb) + throws Matrix.Error + { + _send(cb, + CallType.API, "GET", "account/3pid", + null, null, null, null, false); + } + + public void + add_3pid(API.Callback? cb, + bool bind_creds, + Matrix.3PidCredential creds) + throws Matrix.Error + { + var id_node = creds.get_json_node(); + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("bind"); + builder.add_boolean_value(bind_creds); + + builder.set_member_name("threePidCreds"); + builder.add_value(id_node); + + _send(cb, + CallType.API, "POST", "account/3pid", + null, null, builder.get_root(), null, false); + } + + public void + change_password(API.Callback? cb, + string new_password) + throws Matrix.Error + { + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("new_password"); + builder.add_string_value(new_password); + + builder.end_object(); + + _send(cb, + CallType.API, "POST", "account/password", + null, null, builder.get_root(), null, false); + } + + public void + get_profile(API.Callback? cb, + string user_id) + throws Matrix.Error + { + string path = "profile/%s".printf(Soup.URI.encode(user_id, null)); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + get_avatar_url(API.Callback? cb, + string user_id) + throws Matrix.Error + { + string path = "profile/%s/avatar_url".printf( + Soup.URI.encode(user_id, null)); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + set_avatar_url(API.Callback? cb, + string user_id, + string avatar_url) + throws Matrix.Error + { + string path = "profile/%s/avatar_url".printf( + Soup.URI.encode(user_id, null)); + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("avatar_url"); + builder.add_string_value(avatar_url); + + builder.end_object(); + + _send(cb, + CallType.API, "PUT", path, + null, null, builder.get_root(), null, false); + } + + public void + get_display_name(API.Callback? cb, + string user_id) + throws Matrix.Error + { + string path = "profile/%s/displayname".printf( + Soup.URI.encode(user_id, null)); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + set_display_name(API.Callback? cb, + string user_name, + string display_name) + throws Matrix.Error + { + string path = "profile/%s/displayname".printf( + Soup.URI.encode(user_id, null)); + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("displayname"); + builder.add_string_value(display_name); + + builder.end_object(); + + _send(cb, + CallType.API, "PUT", path, + null, null, builder.get_root(), null, false); + } + + public void + register_account(API.Callback? cb, + AccountKind account_kind, + bool bind_email, + string? username, + string password) + throws Matrix.Error + { + HashTable? parms = null; + var builder = new Json.Builder(); + + builder.begin_object(); + + builder.set_member_name("bind_email"); + builder.add_boolean_value(bind_email); + + if (username != null) { + builder.set_member_name("username"); + builder.add_string_value(username); + } + + builder.set_member_name("password"); + builder.add_string_value(password); + + builder.end_object(); + + if (account_kind != AccountKind.DEFAULT) { + string? kind_string = _g_enum_value_to_nick( + typeof(Matrix.AccountKind), account_kind); + + if (kind_string != null) { + parms = _create_query_params(); + + parms.replace("kind", kind_string); + } + } + + _send(cb, + CallType.API, "POST", "register", + parms, null, builder.get_root(), null, false); + } + + public void + set_account_data(API.Callback? cb, + string user_id, + string? room_id, + string event_type, + owned Json.Node content) + throws Matrix.Error + { + string path; + + if (room_id != null) { + path = "user/%s/rooms/%s/account_data/%s".printf( + Soup.URI.encode(user_id, null), + Soup.URI.encode(room_id, null), + Soup.URI.encode(event_type, null)); + } else { + path = "user/%s/account_data/%s".printf( + Soup.URI.encode(user_id, null), + Soup.URI.encode(event_type, null)); + } + + _send(cb, + CallType.API, "PUT", path, + null, null, content, null, false); + } + + public void + get_room_tags(API.Callback? cb, + string user_id, + string room_id) + throws Matrix.Error + { + string path = "user/%s/rooms/%s/tags".printf( + Soup.URI.encode(user_id, null), + Soup.URI.encode(room_id, null)); + + _send(cb, + CallType.API, "GET", path, + null, null, null, null, false); + } + + public void + delete_room_tag(API.Callback? cb, + string user_id, + string room_id, + string tag) + throws Matrix.Error + { + string path = "user/%s/rooms/%s/tags/%s".printf( + Soup.URI.encode(user_id, null), + Soup.URI.encode(room_id, null), + Soup.URI.encode(tag, null)); + + _send(cb, + CallType.API, "DELETE", path, + null, null, null, null, false); + } + + public void + add_room_tag(API.Callback? cb, + string user_id, + string room_id, + string tag, + owned Json.Node? content) + throws Matrix.Error + { + string path = "user/%s/rooms/%s/tags/%s".printf( + Soup.URI.encode(user_id, null), + Soup.URI.encode(room_id, null), + Soup.URI.encode(tag, null)); + + _send(cb, + CallType.API, "PUT", path, + null, null, content, null, false); + } + + /* VoIP */ + + public void + get_turn_server(API.Callback? cb) + throws Matrix.Error + { + _send(cb, + CallType.API, "GET", "voip/turnServer", + null, null, null, null, false); + } + + /* Non-spec methods */ + + public void + abort_pending() + { + _soup_session.abort(); + } +} diff --git a/src/matrix-http-client.h b/src/matrix-http-client.h index 28c066f..7391726 100644 --- a/src/matrix-http-client.h +++ b/src/matrix-http-client.h @@ -21,7 +21,6 @@ #include #include "matrix-glib.h" -#include "matrix-http-api.h" G_BEGIN_DECLS diff --git a/src/test-api-client.c b/src/test-api-client.c index 59d35a5..75dbcbd 100644 --- a/src/test-api-client.c +++ b/src/test-api-client.c @@ -20,7 +20,7 @@ #include #include -#include "matrix-http-api.h" +#include "matrix-glib.h" #define LOG_DOMAIN "Matrix-Test-Client" @@ -183,7 +183,7 @@ main(int argc, char *argv[]) g_info("Starting up: %s with %s:%s", *homeserver, user, password); - api = matrix_http_api_new(*homeserver, NULL); + api = MATRIX_API(matrix_http_api_new(*homeserver, NULL)); matrix_http_api_set_validate_certificate(MATRIX_HTTP_API(api), !no_validate_certs); builder = json_builder_new();