1 files changed, 76 insertions, 0 deletions
diff --git a/src/com/isode/stroke/whiteboard/OutgoingWhiteboardSession.java b/src/com/isode/stroke/whiteboard/OutgoingWhiteboardSession.java
new file mode 100644
index 0000000..3a79a4c
--- /dev/null
+++ b/src/com/isode/stroke/whiteboard/OutgoingWhiteboardSession.java
@@ -0,0 +1,76 @@
+/*  Copyright (c) 2016, Isode Limited, London, England.
+ *  All rights reserved.
+ *
+ *  Acquisition and use of this software and related materials for any
+ *  purpose requires a written license agreement from Isode Limited,
+ *  or a written license from an organisation licensed by Isode Limited
+ *  to grant such a license.
+ *
+ */
+package com.isode.stroke.whiteboard;
+
+import com.isode.stroke.elements.ErrorPayload;
+import com.isode.stroke.elements.IQ;
+import com.isode.stroke.elements.WhiteboardOperation;
+import com.isode.stroke.elements.WhiteboardPayload;
+import com.isode.stroke.jid.JID;
+import com.isode.stroke.queries.GenericRequest;
+import com.isode.stroke.queries.IQRouter;
+import com.isode.stroke.signals.Slot2;
+
+public class OutgoingWhiteboardSession extends WhiteboardSession {
+
+    private final WhiteboardServer server = new WhiteboardServer();
+    
+    public OutgoingWhiteboardSession(JID jid, IQRouter router) {
+        super(jid, router);
+    }
+    
+    public void startSession() {
+        
+        WhiteboardPayload payload = new WhiteboardPayload(WhiteboardPayload.Type.SessionRequest);
+        GenericRequest<WhiteboardPayload> request = 
+                new GenericRequest<WhiteboardPayload>(IQ.Type.Set, toJID_, payload, router_);
+        request.onResponse.connect(new Slot2<WhiteboardPayload, ErrorPayload>() {
+            
+            @Override
+            public void call(WhiteboardPayload payload, ErrorPayload error) {
+                handleRequestResponse(payload, error);
+            }
+            
+        });
+        request.send();
+    }
+    
+    private void handleRequestResponse(WhiteboardPayload payload,ErrorPayload error) {
+        if (error != null) {
+            onRequestRejected.emit(toJID_);
+        }
+    }
+
+    @Override
+    public void sendOperation(WhiteboardOperation operation) {
+        operation.setID(idGenerator_.generateID());
+        operation.setParentID(lastOpID_);
+        lastOpID_ = operation.getID();
+
+        server.handleLocalOperationReceived(operation);
+        WhiteboardPayload payload = new WhiteboardPayload();
+        payload.setOperation(operation);
+        sendPayload(payload);
+    }
+
+    @Override
+    protected void handleIncomingOperation(WhiteboardOperation operation) {
+        WhiteboardOperation op = server.handleClientOperationReceived(operation);
+        if (op.getPos() != -1) {
+            onOperationReceived.emit(op);
+        }
+        lastOpID_ = op.getID();
+
+        WhiteboardPayload payload = new WhiteboardPayload();
+        payload.setOperation(op);
+        sendPayload(payload);
+    }
+
+}