mirror of
https://github.com/matrix-construct/construct
synced 2024-12-28 16:34:13 +01:00
116 lines
3.1 KiB
JavaScript
116 lines
3.1 KiB
JavaScript
/*
|
|
// Matrix Construct
|
|
//
|
|
// Copyright (C) Matrix Construct Developers, Authors & Contributors
|
|
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
|
|
//
|
|
// Permission to use, copy, modify, and/or distribute this software for any
|
|
// purpose with or without fee is hereby granted, provided that the above
|
|
// copyright notice and this permission notice is present in all copies. The
|
|
// full license for this software is available in the LICENSE file.
|
|
*/
|
|
|
|
'use strict';
|
|
|
|
/******************************************************************************
|
|
* Event
|
|
*
|
|
*/
|
|
mc.event = class
|
|
{
|
|
constructor(event = {})
|
|
{
|
|
Object.update(this, event);
|
|
Object.defaults(this,
|
|
{
|
|
event_id: mc.m.random.mxid("$"),
|
|
origin_server_ts: mc.now(),
|
|
});
|
|
}
|
|
|
|
// functors
|
|
static is_state(event) { return event.state_key !== undefined; }
|
|
static is_not_state(event) { return !mc.event.is_state(event); }
|
|
static is_type(type, event) { return event.type == type; }
|
|
static is_pending(event) { return !event.event_id.startsWith("$"); }
|
|
static is_local(event) { return mc.m.domid(event.event_id) == "mc"; }
|
|
static is_not_local(event) { return !mc.event.is_local(event); }
|
|
static cmp(a, b) { return a.cmp(b); }
|
|
};
|
|
|
|
/**
|
|
* Get events surrounding this event
|
|
*/
|
|
mc.event.prototype.context = function(opts = {})
|
|
{
|
|
if(!this.room_id || !this.event_id)
|
|
return false;
|
|
|
|
let handler = (error, data) => callback(arguments, error, data);
|
|
return mc.m.rooms.context.get(this.room_id, this.event_id, opts, handler);
|
|
};
|
|
|
|
/**
|
|
* Ordering comparator for events.
|
|
*/
|
|
mc.event.prototype.cmp = function(other)
|
|
{
|
|
let cmp = (a, b) =>
|
|
a == undefined? undefined:
|
|
b == undefined? undefined:
|
|
a < b? -1:
|
|
a > b? 1:
|
|
a == b? 0:
|
|
undefined;
|
|
|
|
let depth_a = maybe(() => this.depth);
|
|
let depth_b = maybe(() => other.depth);
|
|
let ret = cmp(depth_a, depth_b);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
|
|
// The origin server ts is used next to calculate the age
|
|
let ts_a = maybe(() => this.origin_server_ts);
|
|
let ts_b = maybe(() => other.origin_server_ts);
|
|
ret = cmp(ts_a, ts_b);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
|
|
// Make an attempt to salvage any time data we actually have to compare
|
|
if((age_a || ts_a) && (age_b || ts_b))
|
|
{
|
|
let now = mc.now();
|
|
if(age_a && !ts_a)
|
|
ts_a = now - age_a;
|
|
|
|
if(age_b && !ts_b)
|
|
ts_b = now - age_b;
|
|
|
|
ret = cmp(ts_a, ts_b);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
}
|
|
|
|
// Sort by room ID
|
|
ret = cmp(this.room_id, other.room_id);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
|
|
// Sort by event ID
|
|
ret = cmp(this.event_id, other.event_id);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
|
|
// Sort by sender
|
|
ret = cmp(this.sender, other.sender);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
|
|
// Sort by content
|
|
ret = cmp(this.content, other.content);
|
|
if(ret !== undefined)
|
|
return ret;
|
|
|
|
// Final attempt
|
|
return cmp(this, other);
|
|
};
|