In-Band Registration

3 files changed, 71 insertions, 3 deletions

diff --git a/xmpp-vala/src/module/stanza_error.vala b/xmpp-vala/src/module/stanza_error.vala
index 51aa2629..c45ff4e3 100644
--- a/xmpp-vala/src/module/stanza_error.vala
+++ b/xmpp-vala/src/module/stanza_error.vala
@@ -36,6 +36,10 @@ namespace Xmpp {
             get { return error_node.get_attribute("by"); }
         }
 
+        public string? text {
+            get { return error_node.get_deep_string_content("urn:ietf:params:xml:ns:xmpp-stanzas:text"); }
+        }
+
         public string condition {
             get {
                 Gee.List<StanzaNode> subnodes = error_node.sub_nodes;
@@ -57,7 +61,7 @@ namespace Xmpp {
         }
 
         public StanzaNode stanza;
-        private StanzaNode error_node;
+        public StanzaNode error_node;
 
         public ErrorStanza.from_stanza(StanzaNode stanza) {
             this.stanza = stanza;
diff --git a/xmpp-vala/src/module/xep/0004_data_forms.vala b/xmpp-vala/src/module/xep/0004_data_forms.vala
index 69c14b08..cc0a1a28 100644
--- a/xmpp-vala/src/module/xep/0004_data_forms.vala
+++ b/xmpp-vala/src/module/xep/0004_data_forms.vala
@@ -78,7 +78,7 @@ public class DataForm {
             return ret;
         }
 
-        internal string get_value_string() {
+        public string get_value_string() {
             Gee.List<string> values = get_values();
             return values.size > 0 ? values[0] : "";
         }
@@ -197,7 +197,7 @@ public class DataForm {
 
     // TODO text-multi
 
-    internal DataForm.from_node(StanzaNode node, XmppStream stream, owned OnResult listener) {
+    internal DataForm.from_node(StanzaNode node, XmppStream stream, owned OnResult? listener = null) {
         this.stanza_node = node;
         this.stream = stream;
         this.on_result = (owned)listener;
diff --git a/xmpp-vala/src/module/xep/0077_in_band_registration.vala b/xmpp-vala/src/module/xep/0077_in_band_registration.vala
new file mode 100644
index 00000000..1c544c18
--- /dev/null
+++ b/xmpp-vala/src/module/xep/0077_in_band_registration.vala
@@ -0,0 +1,64 @@
+using Gee;
+
+namespace Xmpp.Xep.InBandRegistration {
+
+public const string NS_URI = "jabber:iq:register";
+
+public class Module : XmppStreamNegotiationModule {
+    public static ModuleIdentity<Module> IDENTITY = new ModuleIdentity<Module>(NS_URI, "0077_in_band_registration");
+
+    public async Form? get_from_server(XmppStream stream, Jid jid) {
+        Iq.Stanza request_form_iq = new Iq.Stanza.get(new StanzaNode.build("query", NS_URI).add_self_xmlns());
+        request_form_iq.to = jid;
+        SourceFunc callback = get_from_server.callback;
+        Form? form = null;
+        stream.get_module(Iq.Module.IDENTITY).send_iq(stream, request_form_iq, (stream, response_iq) => {
+            form = new Form.from_node(stream, response_iq);
+            Idle.add((owned)callback);
+        });
+        yield;
+        return form;
+    }
+
+    public async string submit_to_server(XmppStream stream, Jid jid, Form form) {
+        StanzaNode query_node = new StanzaNode.build("query", NS_URI).add_self_xmlns();
+        query_node.put_node(form.get_submit_node());
+        Iq.Stanza iq = new Iq.Stanza.set(query_node);
+        iq.to = jid;
+        string? error_message = null;
+        SourceFunc callback = submit_to_server.callback;
+        stream.get_module(Iq.Module.IDENTITY).send_iq(stream, iq, (stream, response_iq) => {
+            if (response_iq.is_error()) {
+                ErrorStanza? error_stanza = response_iq.get_error();
+                error_message = error_stanza.text ?? "Error";
+            }
+            Idle.add((owned)callback);
+        });
+        yield;
+        return error_message;
+    }
+
+    public override bool mandatory_outstanding(XmppStream stream) { return false; }
+
+    public override bool negotiation_active(XmppStream stream) { return false; }
+
+    public override void attach(XmppStream stream) { }
+
+    public override void detach(XmppStream stream) { }
+
+    public override string get_ns() { return NS_URI; }
+    public override string get_id() { return IDENTITY.id; }
+}
+
+public class Form : DataForms.DataForm {
+    public string? oob = null;
+
+    internal Form.from_node(XmppStream stream, Iq.Stanza iq) {
+        StanzaNode? x_node = iq.stanza.get_deep_subnode(NS_URI + ":query", DataForms.NS_URI + ":x");
+        base.from_node(x_node ?? new StanzaNode.build("x", NS_URI).add_self_xmlns(), stream);
+
+        oob = iq.stanza.get_deep_string_content(NS_URI + ":query", "jabber:x:oob:x", "url");
+    }
+}
+
+}