From 7e83529afcd0ccfff5c65c99e4427bd6cf3f82ac Mon Sep 17 00:00:00 2001
From: fiaxh <git@mx.ax.lt>
Date: Tue, 31 Oct 2017 15:19:30 +0100
Subject: Blocking setting in Contact Details

---
 libdino/src/application.vala              |  1 +
 libdino/src/service/blocking_manager.vala | 44 +++++++++++++++++++++++++++++++
 2 files changed, 45 insertions(+)
 create mode 100644 libdino/src/service/blocking_manager.vala

(limited to 'libdino/src')

diff --git a/libdino/src/application.vala b/libdino/src/application.vala
index c18b28f9..c9283127 100644
--- a/libdino/src/application.vala
+++ b/libdino/src/application.vala
@@ -31,6 +31,7 @@ public interface Dino.Application : GLib.Application {
         MessageStorage.start(stream_interactor, db);
         CounterpartInteractionManager.start(stream_interactor);
         PresenceManager.start(stream_interactor);
+        BlockingManager.start(stream_interactor);
         MucManager.start(stream_interactor);
         RosterManager.start(stream_interactor, db);
         ConversationManager.start(stream_interactor, db);
diff --git a/libdino/src/service/blocking_manager.vala b/libdino/src/service/blocking_manager.vala
new file mode 100644
index 00000000..de79b4d4
--- /dev/null
+++ b/libdino/src/service/blocking_manager.vala
@@ -0,0 +1,44 @@
+using Gee;
+
+using Xmpp;
+using Dino.Entities;
+
+namespace Dino {
+
+public class BlockingManager : StreamInteractionModule, Object {
+    public static ModuleIdentity<BlockingManager> IDENTITY = new ModuleIdentity<BlockingManager>("blocking_manager");
+    public string id { get { return IDENTITY.id; } }
+
+    private StreamInteractor stream_interactor;
+
+    public static void start(StreamInteractor stream_interactor) {
+        BlockingManager m = new BlockingManager(stream_interactor);
+        stream_interactor.add_module(m);
+    }
+
+    private BlockingManager(StreamInteractor stream_interactor) {
+        this.stream_interactor = stream_interactor;
+    }
+
+    public bool is_blocked(Account account, Jid jid) {
+        Core.XmppStream stream = stream_interactor.get_stream(account);
+        return stream != null && stream.get_module(Xmpp.Xep.BlockingCommand.Module.IDENTITY).is_blocked(stream, jid.to_string());
+    }
+
+    public void block(Account account, Jid jid) {
+        Core.XmppStream stream = stream_interactor.get_stream(account);
+        stream.get_module(Xmpp.Xep.BlockingCommand.Module.IDENTITY).block(stream, new ArrayList<string>.wrap(new string[] {jid.to_string()}));
+    }
+
+    public void unblock(Account account, Jid jid) {
+        Core.XmppStream stream = stream_interactor.get_stream(account);
+        stream.get_module(Xmpp.Xep.BlockingCommand.Module.IDENTITY).unblock(stream, new ArrayList<string>.wrap(new string[] {jid.to_string()}));
+    }
+
+    public bool is_supported(Account account) {
+        Core.XmppStream stream = stream_interactor.get_stream(account);
+        return stream != null && stream.get_module(Xmpp.Xep.BlockingCommand.Module.IDENTITY).is_supported(stream);
+    }
+}
+
+}
-- 
cgit v1.2.3-54-g00ecf