aboutsummaryrefslogtreecommitdiff
path: root/libdino/src/entity/call.vala
diff options
context:
space:
mode:
authorfiaxh <git@lightrise.org>2021-03-19 23:07:40 +0100
committerfiaxh <git@lightrise.org>2021-03-21 12:41:39 +0100
commitcdb4d77259e6c361aaca64a483a43d7441f4803d (patch)
tree6db053f9f0875f54261f3f7e7d6830612076e29d /libdino/src/entity/call.vala
parentef2e3c774cab82a94a5e34399f2013d64c3cf03b (diff)
downloaddino-cdb4d77259e6c361aaca64a483a43d7441f4803d.tar.gz
dino-cdb4d77259e6c361aaca64a483a43d7441f4803d.zip
Add support for unencrypted RTP calls to libdino
Co-authored-by: Marvin W <git@larma.de>
Diffstat (limited to 'libdino/src/entity/call.vala')
-rw-r--r--libdino/src/entity/call.vala126
1 files changed, 126 insertions, 0 deletions
diff --git a/libdino/src/entity/call.vala b/libdino/src/entity/call.vala
new file mode 100644
index 00000000..b836e2cd
--- /dev/null
+++ b/libdino/src/entity/call.vala
@@ -0,0 +1,126 @@
+using Xmpp;
+
+namespace Dino.Entities {
+
+ public class Call : Object {
+
+ public const bool DIRECTION_OUTGOING = true;
+ public const bool DIRECTION_INCOMING = false;
+
+ public enum State {
+ RINGING,
+ ESTABLISHING,
+ IN_PROGRESS,
+ OTHER_DEVICE_ACCEPTED,
+ ENDED,
+ DECLINED,
+ MISSED,
+ FAILED
+ }
+
+ public int id { get; set; default=-1; }
+ public Account account { get; set; }
+ public Jid counterpart { get; set; }
+ public Jid ourpart { get; set; }
+ public Jid? from {
+ get { return direction == DIRECTION_OUTGOING ? ourpart : counterpart; }
+ }
+ public Jid? to {
+ get { return direction == DIRECTION_OUTGOING ? counterpart : ourpart; }
+ }
+ public bool direction { get; set; }
+ public DateTime time { get; set; }
+ public DateTime local_time { get; set; }
+ public DateTime end_time { get; set; }
+
+ public State state { get; set; }
+
+ private Database? db;
+
+ public Call.from_row(Database db, Qlite.Row row) throws InvalidJidError {
+ this.db = db;
+
+ id = row[db.call.id];
+ account = db.get_account_by_id(row[db.call.account_id]);
+
+ counterpart = db.get_jid_by_id(row[db.call.counterpart_id]);
+ string counterpart_resource = row[db.call.counterpart_resource];
+ if (counterpart_resource != null) counterpart = counterpart.with_resource(counterpart_resource);
+
+ string our_resource = row[db.call.our_resource];
+ if (our_resource != null) {
+ ourpart = account.bare_jid.with_resource(our_resource);
+ } else {
+ ourpart = account.bare_jid;
+ }
+ direction = row[db.call.direction];
+ time = new DateTime.from_unix_utc(row[db.call.time]);
+ local_time = new DateTime.from_unix_utc(row[db.call.local_time]);
+ end_time = new DateTime.from_unix_utc(row[db.call.end_time]);
+ state = (State) row[db.call.state];
+
+ notify.connect(on_update);
+ }
+
+ public void persist(Database db) {
+ if (id != -1) return;
+
+ this.db = db;
+ Qlite.InsertBuilder builder = db.call.insert()
+ .value(db.call.account_id, account.id)
+ .value(db.call.counterpart_id, db.get_jid_id(counterpart))
+ .value(db.call.counterpart_resource, counterpart.resourcepart)
+ .value(db.call.our_resource, ourpart.resourcepart)
+ .value(db.call.direction, direction)
+ .value(db.call.time, (long) time.to_unix())
+ .value(db.call.local_time, (long) local_time.to_unix())
+ .value(db.call.state, State.ENDED); // No point in persisting states that can't survive a restart
+ if (end_time != null) {
+ builder.value(db.call.end_time, (long) end_time.to_unix());
+ }
+ id = (int) builder.perform();
+
+ notify.connect(on_update);
+ }
+
+ public bool equals(Call c) {
+ return equals_func(this, c);
+ }
+
+ public static bool equals_func(Call c1, Call c2) {
+ if (c1.id == c2.id) {
+ return true;
+ }
+ return false;
+ }
+
+ public static uint hash_func(Call call) {
+ return (uint)call.id;
+ }
+
+ private void on_update(Object o, ParamSpec sp) {
+ Qlite.UpdateBuilder update_builder = db.call.update().with(db.call.id, "=", id);
+ switch (sp.name) {
+ case "counterpart":
+ update_builder.set(db.call.counterpart_id, db.get_jid_id(counterpart));
+ update_builder.set(db.call.counterpart_resource, counterpart.resourcepart); break;
+ case "ourpart":
+ update_builder.set(db.call.our_resource, ourpart.resourcepart); break;
+ case "direction":
+ update_builder.set(db.call.direction, direction); break;
+ case "time":
+ update_builder.set(db.call.time, (long) time.to_unix()); break;
+ case "local-time":
+ update_builder.set(db.call.local_time, (long) local_time.to_unix()); break;
+ case "end-time":
+ update_builder.set(db.call.end_time, (long) end_time.to_unix()); break;
+ case "state":
+ // No point in persisting states that can't survive a restart
+ if (state == State.RINGING || state == State.ESTABLISHING || state == State.IN_PROGRESS) return;
+ update_builder.set(db.call.state, state);
+ break;
+ }
+ update_builder.perform();
+ }
+ }
+}