5 void MX_Nick_(entity fh, entity pass, int status);
6 void MX_Nick(string name)
8 entity pass = new_pure(mx);
11 sprintf("%s/_matrix/client/r0/profile/%s/displayname?access_token=%s", autocvar_matrix_server, matrix_user, matrix_access_token),
17 void MX_Nick_(entity fh, entity pass, int status)
20 case URL_READY_CANWRITE: {
22 fh.url_content_type = "application/json";
23 url_fputs(fh, sprintf("{\"displayname\": \"%s\"}", pass.message));
32 void MX_Messages_(entity fh, entity pass, int status);
33 void MX_Messages(string from)
35 string s = sprintf("%s/_matrix/client/r0/events?room_id=%s&limit=50&timeout=30000&from=%s&access_token=%s", autocvar_matrix_server, matrix_room, from, matrix_access_token);
43 void MX_Messages_(entity fh, entity pass, int status)
47 LOG_WARNINGF("status: %d", status);
50 case URL_READY_CLOSED: break;
51 case URL_READY_CANREAD: {
53 for (string s; (s = url_fgets(fh)); ) { json = strcat(json, s, "\n"); }
55 int buf = json_parse(json, _json_parse_object);
57 for (int i = 0, n = stof(json_get(buf, "chunk.length")); i < n; ++i) {
58 MX_Handle(buf, sprintf("chunk.%d", i));
60 MX_Messages(json_get(buf, "end"));
67 void MX_Sync_(entity fh, entity pass, int status);
68 void MX_Sync(string since)
70 string s = strcat(autocvar_matrix_server, "/_matrix/client/r0/sync?");
75 sprintf("filter={\"account_data\":{\"types\":[]},\"presence\":{\"types\":[]},\"room\":{\"rooms\":[\"%s\"]}}&", matrix_room)
80 "filter={\"account_data\":{\"types\":[]},\"presence\":{\"types\":[]},\"room\":{\"rooms\":[]}}&"
83 s = strcat(s, "access_token=", matrix_access_token);
84 url_single_fopen(s, FILE_READ, MX_Sync_, NULL);
86 void MX_Sync_(entity fh, entity pass, int status)
90 LOG_WARNINGF("status: %d", status);
93 case URL_READY_CLOSED: break;
94 case URL_READY_CANREAD: {
96 for (string s; (s = url_fgets(fh)); ) { json = strcat(json, s, "\n"); }
98 int buf = json_parse(json, _json_parse_object);
100 string arr = sprintf("rooms.join.%s.timeline.events", matrix_room);
101 for (int i = 0, n = stof(json_get(buf, sprintf("%s.length", arr))); i < n; ++i) {
102 MX_Handle(buf, sprintf("%s.%d", arr, i));
104 MX_Sync(json_get(buf, "next_batch"));
111 void MX_JLF_(entity fh, entity pass, int status);
112 void MX_Join(string room)
115 sprintf("%s/_matrix/client/r0/rooms/%s/join?access_token=%s", autocvar_matrix_server, matrix_room, matrix_access_token),
121 void MX_Leave(string room)
124 sprintf("%s/_matrix/client/r0/rooms/%s/leave?access_token=%s", autocvar_matrix_server, matrix_room, matrix_access_token),
130 void MX_Forget(string room)
133 sprintf("%s/_matrix/client/r0/rooms/%s/forget?access_token=%s", autocvar_matrix_server, matrix_room, matrix_access_token),
139 void MX_JLF_(entity fh, entity pass, int status)
142 case URL_READY_CANWRITE: {
143 fh.url_content_type = "application/json";
144 url_fputs(fh, sprintf("{}", pass.message));
152 void MX_Typing_(entity fh, entity pass, int status);
153 void MX_Typing(bool state)
155 entity pass = new_pure(mx);
156 pass.message = state ? "true" : "false";
158 sprintf("%s/_matrix/client/r0/rooms/%s/typing/%s?access_token=%s", autocvar_matrix_server, matrix_room, matrix_user, matrix_access_token),
164 void MX_Typing_(entity fh, entity pass, int status)
167 case URL_READY_CANWRITE: {
169 fh.url_content_type = "application/json";
170 url_fputs(fh, sprintf("{\"typing\": %s, \"timeout\": 30000}", pass.message));
179 void MX_Say_(entity fh, entity pass, int status);
180 void MX_Say(string body)
183 entity pass = new_pure(mx);
184 pass.message = strzone(body);
186 sprintf("%s/_matrix/client/r0/rooms/%s/send/m.room.message/%d?access_token=%s", autocvar_matrix_server, matrix_room, ++txnid, matrix_access_token),
192 void MX_Say_(entity fh, entity pass, int status)
195 case URL_READY_CANWRITE: {
197 fh.url_content_type = "application/json";
198 url_fputs(fh, sprintf("{\"msgtype\": \"m.text\", \"body\": \"%s\"}", pass.message));
199 strunzone(pass.message); remove(pass);