From ddbb00ee56ca8ddc5db3ed9b6f4003bb6020ed6b Mon Sep 17 00:00:00 2001
From: fiaxh <git@lightrise.org>
Date: Fri, 22 May 2026 17:09:04 +0200
Subject: Add support for MUC affiliations versioning (XEP-0463), add
 affiliation storage

---
 libdino/src/service/muc_affiliations.vala | 82 +++++++++++++++++++++++++++++++
 1 file changed, 82 insertions(+)
 create mode 100644 libdino/src/service/muc_affiliations.vala

(limited to 'libdino/src/service/muc_affiliations.vala')

diff --git a/libdino/src/service/muc_affiliations.vala b/libdino/src/service/muc_affiliations.vala
new file mode 100644
index 00000000..41107a93
--- /dev/null
+++ b/libdino/src/service/muc_affiliations.vala
@@ -0,0 +1,82 @@
+using Gee;
+
+using Dino.Entities;
+using Xmpp;
+using Xmpp.Xep;
+
+namespace Dino {
+    public class MucAffiliations {
+
+        private Database db;
+
+        public MucAffiliations(Database db) {
+            this.db = db;
+        }
+
+        public string? get_mav_version(Account account, Jid muc_jid) {
+            Qlite.RowOption version_rowopt = db.muc_affiliation_version.select()
+                .with(db.muc_affiliation_version.account_id, "=", account.id)
+                .with(db.muc_affiliation_version.muc_jid_id, "=", db.get_jid_id(muc_jid))
+                .single()
+                .row();
+
+            return version_rowopt.is_present() ? version_rowopt.inner[db.muc_affiliation_version.version] : null;
+        }
+
+        public void clear_affiliations(Account account, Jid muc_jid) {
+            db.muc_affiliation.delete()
+                .with(db.muc_affiliation.account_id, "=", account.id)
+                .with(db.muc_affiliation.muc_jid_id, "=", db.get_jid_id(muc_jid))
+                .perform();
+        }
+
+        public void clear_mav_version(Account account, Jid muc_jid) {
+            db.muc_affiliation_version.delete()
+                .with(db.muc_affiliation_version.account_id, "=", account.id)
+                .with(db.muc_affiliation_version.muc_jid_id, "=", db.get_jid_id(muc_jid))
+                .perform();
+        }
+
+        public void update_affiliations(Account account, Jid muc_jid, HashMap<Jid, Muc.Affiliation> affiliations, string? mav_since, string? mav_until) {
+            // Update version (if MUC affiliation versioning is used)
+            if (mav_until != null && mav_since == null) {
+                clear_affiliations(account, muc_jid);
+            } else if (mav_until != null) {
+                string? previous_version = get_mav_version(account, muc_jid);
+                if (mav_since != previous_version) {
+                    warning("Got an unexpected affiliations version 'since'. Expected %s; got %s", previous_version, mav_since);
+                    clear_affiliations(account, muc_jid);
+                    clear_mav_version(account, muc_jid);
+                }
+            }
+
+            if (mav_until != null) {
+                db.muc_affiliation_version.upsert()
+                    .value(db.muc_affiliation_version.account_id, account.id, true)
+                    .value(db.muc_affiliation_version.muc_jid_id, db.get_jid_id(muc_jid), true)
+                    .value(db.muc_affiliation_version.version, mav_until)
+                    .perform();
+            }
+
+            // Update affiliations
+            foreach (Jid real_jid in affiliations.keys) {
+                Muc.Affiliation affiliation = affiliations[real_jid];
+
+                if (affiliation == Muc.Affiliation.NONE) {
+                    db.muc_affiliation.delete()
+                        .with(db.muc_affiliation.account_id, "=", account.id)
+                        .with(db.muc_affiliation.muc_jid_id, "=", db.get_jid_id(muc_jid))
+                        .with(db.muc_affiliation.real_jid_id, "=", db.get_jid_id(real_jid))
+                        .perform();
+                } else {
+                    db.muc_affiliation.insert()
+                        .value(db.muc_affiliation.account_id, account.id)
+                        .value(db.muc_affiliation.muc_jid_id, db.get_jid_id(muc_jid))
+                        .value(db.muc_affiliation.real_jid_id, db.get_jid_id(real_jid))
+                        .value(db.muc_affiliation.affiliation, (int)affiliation)
+                        .perform();
+                }
+            }
+        }
+    }
+}
\ No newline at end of file
-- 
cgit v1.3