Add event handler for m.receipt
This commit is contained in:
parent
0aaab4af7e
commit
13abc13adc
1
.gitignore
vendored
1
.gitignore
vendored
@ -62,3 +62,4 @@ Makefile.in
|
||||
/src/matrix-event-room-topic.c
|
||||
/src/matrix-event-typing.c
|
||||
/src/matrix-event-room-aliases.c
|
||||
/src/matrix-event-receipt.c
|
||||
|
@ -32,6 +32,7 @@ libmatrix_glib_0_0_la_VALA_SOURCES = \
|
||||
matrix-event-room-topic.vala \
|
||||
matrix-event-typing.vala \
|
||||
matrix-event-room-aliases.vala \
|
||||
matrix-event-receipt.vala \
|
||||
$(NULL)
|
||||
|
||||
AM_CPPFLAGS += \
|
||||
|
88
src/matrix-event-receipt.vala
Normal file
88
src/matrix-event-receipt.vala
Normal file
@ -0,0 +1,88 @@
|
||||
/*
|
||||
* 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/>.
|
||||
*/
|
||||
|
||||
/**
|
||||
* Class to hold m.receipt events.
|
||||
*
|
||||
* Informs the client of new receipts.
|
||||
*/
|
||||
public class Matrix.Event.Receipt : Matrix.Event.Base {
|
||||
public string? room_id { get; set; default = null; }
|
||||
|
||||
private struct ReceiptData {
|
||||
string event_id;
|
||||
string typ;
|
||||
string user;
|
||||
}
|
||||
|
||||
private HashTable<ReceiptData?, ulong?> _receipt_data = null;
|
||||
|
||||
private static bool
|
||||
_rd_equal(ReceiptData k1, ReceiptData k2)
|
||||
{
|
||||
return ((k1.event_id == k2.event_id)
|
||||
&& (k1.typ == k2.typ)
|
||||
&& (k1.user == k2.user));
|
||||
}
|
||||
|
||||
private void
|
||||
_init_receipt_data()
|
||||
{
|
||||
_receipt_data = new HashTable<ReceiptData?, ulong?>(
|
||||
direct_hash, (EqualFunc)_rd_equal);
|
||||
}
|
||||
|
||||
protected override void
|
||||
from_json(Json.Node json_data)
|
||||
throws Matrix.Error
|
||||
{
|
||||
var root = json_data.get_object();
|
||||
var content_root = root.get_member("content").get_object();
|
||||
Json.Node? node;
|
||||
|
||||
if ((node = root.get_member("room_id")) != null) {
|
||||
_room_id = node.get_string();
|
||||
} else {
|
||||
warning("room_id is missing from a m.presence event");
|
||||
}
|
||||
|
||||
content_root.foreach_member((obj, event_id, event_content) => {
|
||||
if ((node = event_content.get_object()
|
||||
.get_member("m.read")) != null) {
|
||||
var read_obj = node.get_object();
|
||||
read_obj.foreach_member((robj, r_user_id, r_content) => {
|
||||
if (_receipt_data == null) {
|
||||
_init_receipt_data();
|
||||
}
|
||||
|
||||
ReceiptData rd_key = ReceiptData() {
|
||||
event_id = event_id,
|
||||
typ = "m.read",
|
||||
user = r_user_id
|
||||
};
|
||||
|
||||
_receipt_data.replace(
|
||||
rd_key,
|
||||
(ulong)r_content.get_object().get_member("ts").get_int());
|
||||
});
|
||||
} else {
|
||||
warning("content.$event-id.m.read is missing from a m.presence event");
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
@ -170,6 +170,9 @@ matrix_event_types_ctor(void)
|
||||
matrix_event_register_type("m.room.aliases",
|
||||
MATRIX_EVENT_TYPE_ROOM_ALIASES,
|
||||
NULL);
|
||||
matrix_event_register_type("m.receipt",
|
||||
MATRIX_EVENT_TYPE_RECEIPT,
|
||||
NULL);
|
||||
}
|
||||
|
||||
void
|
||||
|
Loading…
Reference in New Issue
Block a user