1914 lines
53 KiB
Vala
1914 lines
53 KiB
Vala
/*
|
|
* 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
|
|
* <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
/**
|
|
* 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;
|
|
_base_url = value;
|
|
|
|
_token = null;
|
|
_refresh_token = null;
|
|
_homeserver = null;
|
|
_user_id = null;
|
|
|
|
if (Config.DEBUG) {
|
|
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;
|
|
}
|
|
}
|
|
protected 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; }
|
|
protected 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;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Create a new MatrixHTTPAPI object.
|
|
*
|
|
* @param base_url the base URL of the homeserver to use
|
|
* @param token an access token to use
|
|
* @param refresh_token a refresh token to use
|
|
* @return a new MatrixHTTPAPI object
|
|
*/
|
|
protected
|
|
HTTPAPI(string base_url, string? token = null, string? refresh_token = null)
|
|
{
|
|
Object(base_url : base_url,
|
|
token : token,
|
|
refresh_token : refresh_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<string, string>? 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) {
|
|
if (Config.DEBUG) {
|
|
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;
|
|
request_data[request_data.length] = 0;
|
|
} else if (raw_content != null) {
|
|
request_data = raw_content.data;
|
|
} else {
|
|
request_data = "{}".data;
|
|
request_data[2] = 0;
|
|
}
|
|
|
|
if (Config.DEBUG) {
|
|
debug("Sending %d bytes (%s %s): %s",
|
|
request_data.length,
|
|
method,
|
|
request_path.to_string(false),
|
|
(raw_content != null)
|
|
? "<Binary data>"
|
|
: (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) {
|
|
if (Config.DEBUG) {
|
|
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) {
|
|
if (Config.DEBUG) {
|
|
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) {
|
|
if (Config.DEBUG) {
|
|
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();
|
|
|
|
if (Config.DEBUG) {
|
|
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();
|
|
|
|
if (Config.DEBUG) {
|
|
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);
|
|
|
|
if (Config.DEBUG) {
|
|
debug("Binary data (%s): %u bytes",
|
|
request_url, (uint)datalen);
|
|
}
|
|
} else {
|
|
err = new Matrix.Error.BAD_RESPONSE(
|
|
"Malformed response (invalid JSON)");
|
|
|
|
if (Config.DEBUG) {
|
|
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<string, string>
|
|
_create_query_params()
|
|
{
|
|
return new HashTable<string, string>(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<string, string> 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,
|
|
string[] drop_ids,
|
|
string[] 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.length > 0) {
|
|
builder.set_member_name("drop");
|
|
builder.begin_array();
|
|
|
|
foreach (var entry in drop_ids) {
|
|
builder.add_string_value(entry);
|
|
}
|
|
|
|
builder.end_array();
|
|
}
|
|
|
|
if (invite_ids.length > 0) {
|
|
builder.set_member_name("invite");
|
|
builder.begin_array();
|
|
|
|
foreach (var entry in invite_ids) {
|
|
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_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_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_pushrule(API.Callback? cb,
|
|
string scope,
|
|
PusherKind kind,
|
|
string rule_id)
|
|
throws Matrix.Error
|
|
{
|
|
_pusher_modif(cb, "DELETE", scope, kind, rule_id);
|
|
}
|
|
|
|
public void
|
|
get_pushrule(API.Callback? cb,
|
|
string scope,
|
|
PusherKind kind,
|
|
string rule_id)
|
|
throws Matrix.Error
|
|
{
|
|
_pusher_modif(cb, "GET", scope, kind, rule_id);
|
|
}
|
|
|
|
public void
|
|
add_pushrule(API.Callback? cb,
|
|
string scope,
|
|
PusherKind kind,
|
|
string rule_id,
|
|
string? before,
|
|
string? after,
|
|
string[] actions,
|
|
PusherConditionKind[] conditions)
|
|
throws Matrix.Error
|
|
{
|
|
Json.Builder builder;
|
|
HashTable<string, string> 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();
|
|
foreach (var entry in actions) {
|
|
builder.add_string_value(entry);
|
|
}
|
|
builder.end_array();
|
|
|
|
if (conditions.length > 0) {
|
|
builder.set_member_name("conditions");
|
|
builder.begin_array();
|
|
|
|
foreach (var entry in conditions) {
|
|
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_pushrule(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);
|
|
}
|
|
|
|
public void
|
|
get_pushrules(API.Callback? cb)
|
|
throws Matrix.Error
|
|
{
|
|
_send(cb,
|
|
CallType.API, "GET", "pushrules",
|
|
null, null, null, 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,
|
|
Matrix.Event.State[] initial_state,
|
|
string[] invitees,
|
|
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.length > 0) {
|
|
builder.set_member_name("initial_state");
|
|
builder.begin_array();
|
|
|
|
foreach (var entry in initial_state) {
|
|
builder.add_value(entry.json);
|
|
}
|
|
|
|
builder.end_array();
|
|
}
|
|
|
|
if (invitees.length > 0) {
|
|
builder.set_member_name("invite");
|
|
builder.begin_array();
|
|
|
|
foreach (var entry in invitees) {
|
|
builder.add_string_value(entry);
|
|
}
|
|
|
|
builder.end_array();
|
|
}
|
|
|
|
if (invite_3pids.length > 0) {
|
|
builder.set_member_name("invite_3pid");
|
|
builder.begin_array();
|
|
|
|
foreach (var entry in invite_3pids) {
|
|
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
|
|
unban_user(API.Callback? cb,
|
|
string room_id,
|
|
string user_id)
|
|
throws Matrix.Error
|
|
{
|
|
string path = "rooms/"
|
|
+ Soup.URI.encode(room_id, null)
|
|
+ "/unban";
|
|
var builder = new Json.Builder();
|
|
|
|
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
|
|
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);
|
|
}
|
|
|
|
public void
|
|
join_room_id_or_alias(API.Callback? cb, string room_id_or_alias)
|
|
throws Matrix.Error
|
|
{
|
|
var path = "join/" + Soup.URI.encode(room_id_or_alias, null);
|
|
|
|
_send(cb, CallType.API, "POST", path,
|
|
null, null, null, null, false);
|
|
}
|
|
|
|
public void
|
|
kick_user(API.Callback? cb,
|
|
string room_id, string user_id, string? reason)
|
|
throws Matrix.Error
|
|
{
|
|
var path = "rooms/" + Soup.URI.encode(room_id, null) + "/kick";
|
|
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);
|
|
}
|
|
|
|
/* Room participation */
|
|
|
|
public void
|
|
event_stream(API.Callback? cb,
|
|
string? from_token,
|
|
ulong timeout)
|
|
throws Matrix.Error
|
|
{
|
|
HashTable<string, string> 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<string, string> 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<string, string>? 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<string, string> 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_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_state_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<string, string> 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 */
|
|
|
|
public void
|
|
search(Matrix.API.Callback? cb,
|
|
string? next_batch,
|
|
SearchCategories search_categories)
|
|
throws Matrix.Error
|
|
{
|
|
HashTable<string, string>? parms = null;
|
|
|
|
if (next_batch == null) {
|
|
parms = _create_query_params();
|
|
|
|
parms.replace("next_batch", next_batch);
|
|
}
|
|
|
|
_send(cb,
|
|
CallType.API, "POST", "search",
|
|
parms, null, search_categories.get_json_node(), null, false);
|
|
}
|
|
|
|
/* 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);
|
|
}
|
|
|
|
public void
|
|
logout(API.Callback? cb)
|
|
throws Matrix.Error
|
|
{
|
|
_send(cb,
|
|
CallType.API, "POST", "logout",
|
|
null, null, null, 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<string, string>? 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);
|
|
}
|
|
|
|
public void
|
|
deactivate_account(API.Callback? cb, string? session, string? login_type)
|
|
throws Matrix.Error
|
|
{
|
|
Json.Builder? builder = null;
|
|
|
|
if (login_type != null) {
|
|
builder = new Json.Builder();
|
|
|
|
builder.begin_object();
|
|
|
|
builder.set_member_name("auth");
|
|
builder.begin_object();
|
|
|
|
if (session != null) {
|
|
builder.set_member_name("session");
|
|
builder.add_string_value(session);
|
|
}
|
|
|
|
builder.set_member_name("type");
|
|
builder.add_string_value(login_type);
|
|
|
|
builder.end_object();
|
|
builder.end_object();
|
|
}
|
|
|
|
_send(cb, CallType.API, "POST", "account/deactivate",
|
|
null, null, (builder != null) ? builder.get_root() : null, 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();
|
|
}
|
|
}
|