Download & inline display images

1 files changed, 120 insertions, 0 deletions

diff --git a/libdino/src/entity/file_transfer.vala b/libdino/src/entity/file_transfer.vala
new file mode 100644
index 00000000..7a752518
--- /dev/null
+++ b/libdino/src/entity/file_transfer.vala
@@ -0,0 +1,120 @@
+namespace Dino.Entities {
+
+public class FileTransfer : Object {
+
+    public const bool DIRECTION_SENT = true;
+    public const bool DIRECTION_RECEIVED = false;
+
+    public enum State {
+        COMPLETE,
+        IN_PROCESS,
+        NOT_STARTED,
+        FAILED
+    }
+
+    public int id { get; set; default=-1; }
+    public Account account { get; set; }
+    public Jid counterpart { get; set; }
+    public Jid ourpart { get; set; }
+    public bool direction { get; set; }
+    public DateTime time { get; set; }
+    public DateTime? local_time { get; set; }
+    public Encryption encryption { get; set; }
+
+    public InputStream input_stream { get; set; }
+    public OutputStream output_stream { get; set; }
+
+    public string file_name { get; set; }
+    public string path { get; set; }
+    public string mime_type { get; set; }
+    public int size { get; set; }
+
+    public State state { get; set; }
+    public int provider { get; set; }
+    public string info { get; set; }
+
+    private Database? db;
+
+    public FileTransfer.from_row(Database db, Qlite.Row row) {
+        this.db = db;
+
+        id = row[db.file_transfer.id];
+        account = db.get_account_by_id(row[db.file_transfer.account_id]); // TODO dont have to generate acc new
+
+        string counterpart_jid = db.get_jid_by_id(row[db.file_transfer.counterpart_id]);
+        string counterpart_resource = row[db.file_transfer.counterpart_resource];
+        counterpart = counterpart_resource != null ? new Jid.with_resource(counterpart_jid, counterpart_resource) : new Jid(counterpart_jid);
+
+        string our_resource = row[db.file_transfer.our_resource];
+        if (our_resource != null) {
+            ourpart = new Jid.with_resource(account.bare_jid.to_string(), our_resource);
+        } else {
+            ourpart = account.bare_jid;
+        }
+        direction = row[db.file_transfer.direction];
+        time = new DateTime.from_unix_local(row[db.file_transfer.time]);
+        local_time = new DateTime.from_unix_local(row[db.file_transfer.time]);
+        encryption = (Encryption) row[db.file_transfer.encryption];
+        file_name = row[db.file_transfer.file_name];
+        path = row[db.file_transfer.path];
+        mime_type = row[db.file_transfer.mime_type];
+        size = row[db.file_transfer.size];
+        state = (State) row[db.file_transfer.state];
+        provider = row[db.file_transfer.provider];
+        info = row[db.file_transfer.info];
+
+        notify.connect(on_update);
+    }
+
+    public void persist(Database db) {
+        if (id != -1) return;
+
+        this.db = db;
+        Qlite.InsertBuilder builder = db.file_transfer.insert()
+            .value(db.file_transfer.account_id, account.id)
+            .value(db.file_transfer.counterpart_id, db.get_jid_id(counterpart))
+            .value(db.file_transfer.counterpart_resource, counterpart.resourcepart)
+            .value(db.file_transfer.our_resource, ourpart.resourcepart)
+            .value(db.file_transfer.direction, direction)
+            .value(db.file_transfer.time, (long) time.to_unix())
+            .value(db.file_transfer.local_time, (long) local_time.to_unix())
+            .value(db.file_transfer.encryption, encryption)
+            .value(db.file_transfer.file_name, file_name)
+            .value(db.file_transfer.path, path)
+            .value(db.file_transfer.mime_type, mime_type)
+            .value(db.file_transfer.size, size)
+            .value(db.file_transfer.state, state)
+            .value(db.file_transfer.provider, provider)
+            .value(db.file_transfer.info, info);
+        id = (int) builder.perform();
+        notify.connect(on_update);
+    }
+
+    private void on_update(Object o, ParamSpec sp) {
+        Qlite.UpdateBuilder update_builder = db.file_transfer.update().with(db.file_transfer.id, "=", id);
+        switch (sp.name) {
+            case "counterpart":
+                update_builder.set(db.file_transfer.counterpart_id, db.get_jid_id(counterpart));
+                update_builder.set(db.file_transfer.counterpart_resource, counterpart.resourcepart); break;
+            case "ourpart":
+                update_builder.set(db.file_transfer.our_resource, ourpart.resourcepart); break;
+            case "direction":
+                update_builder.set(db.file_transfer.direction, direction); break;
+            case "time":
+                update_builder.set(db.file_transfer.time, (long) time.to_unix()); break;
+            case "local-time":
+                update_builder.set(db.file_transfer.local_time, (long) local_time.to_unix()); break;
+            case "encryption":
+                update_builder.set(db.file_transfer.encryption, encryption); break;
+            case "state":
+                update_builder.set(db.file_transfer.state, state); break;
+            case "provider":
+                update_builder.set(db.file_transfer.provider, provider); break;
+            case "info":
+                update_builder.set(db.file_transfer.info, info); break;
+        }
+        update_builder.perform();
+    }
+}
+
+}