WIP: Hybrid Groups Initial Sketch

@@ -405,3 +408,3 @@
 				log.Debugf("restartFlow: Creating a New Protocol Engine...")
 				app.engines[profile.GetOnion()] = engine
-				eventBus.Publish(event.NewEventList(event.ProtocolEngineCreated))
+				eventBus.Publish(event.NewEventList(event.ProtocolEngineCreated, event.Handle, profile.GetOnion()))

@@ -515,6 +518,7 @@ func (app *application) eventHandler() {
 									log.Infof("peer appearing offline, not launching listen threads or connecting jobs")
 									app.ConfigureConnections(onion, false, false, false)
 								} else {
+									log.Infof("configuring online connections for peer")

@@ -54,6 +54,7 @@ func (q *infiniteQueue) resize() {
 
 // Add puts an element on the end of the queue.
 func (q *infiniteQueue) Add(elem Event) {
+

@@ -0,0 +56,4 @@
+// This file contains code for the Hybrid Group / Managed Group types..
+type HybridGroupMessage struct {
+	Author          string // the authors cwtch address
+	MemberGroupID   uint32

@@ -0,0 +67,4 @@
+func AuthenticateMessage(message HybridGroupMessage) bool {
+	messageCopy := message
+	messageCopy.Signature = []byte{}
+	// Otherwise we derive the public key from the sender and check it against that.

@@ -0,0 +72,4 @@
+	if err == nil {
+		data, err := json.Marshal(messageCopy)
+		if err == nil && len(decodedPub) >= 32 {
+			return ed25519.Verify(decodedPub[:32], data, message.Signature)

@@ -0,0 +121,4 @@
+
+// handleRotateKeyEvent rotates the encryption key for a given group
+// assumes we are called after an event provided by an authorized peer (i.e. ManageGroup == true)
+func (f *ManagedGroupFunctionality) handleRotateKeyEvent(profile peer.CwtchPeer, conversation model.Conversation, rke RotateKeyEvent) {

@@ -0,0 +127,4 @@
+	profile.SetConversationAttribute(conversation.ID, keyScope, keyB64)
+}
+
+func (f *ManagedGroupFunctionality) handleNewMessageEvent(profile peer.CwtchPeer, conversation model.Conversation, nme NewMessageEvent) {

@@ -0,0 +141,4 @@
+			log.Errorf("unable to decrypt hybrid group message: %v", err)
+			return
+		}
+		//

@@ -0,0 +145,4 @@
+	}
+}
+
+func (f *ManagedGroupFunctionality) handleNewClearMessageEvent(profile peer.CwtchPeer, conversation model.Conversation, nme NewClearMessageEvent) {

@@ -0,0 +129,4 @@
+	if err != nil {
+		return err
+	}
+	// enable channel 2 on this conversation (hybrid groups management channel)

@@ -88,0 +96,4 @@
+		return true
+	}
+	if requestedChannel == 1 {
+		return false // channel 1 is mapped to channel 0 for backwards compatibility

@@ -19,1 +26,4 @@
 const OverlayFileSharing = 200
+
+// ManageGroupEvent is the canonical identifier for the manage group overlay
+const OverlayManageGroupEvent = 0x302

@@ -424,0 +443,4 @@
+}
+
+func (cp *cwtchPeer) resolveChannel(overlay int) int {
+	requestedChannel := overlay & 0xFF

@@ -439,0 +469,4 @@
+			var cm model.MessageWrapper
+			err = json.Unmarshal([]byte(message), &cm)
+
+			// we are now explictly rejecting invalidly encoded messages...

@@ -439,0 +476,4 @@
+			requestedChannel := cp.resolveChannel(cm.Overlay)
+			// if this channel has not been registered for a particular conversation
+			// then default to channel = 0;
+			if conversationInfo.HasChannel(requestedChannel) {

@@ -1482,9 +1558,23 @@ func (cp *cwtchPeer) storeMessage(handle string, message string, sent time.Time)
 		}
 	}
 
+	var cm model.MessageWrapper

@@ -0,0 +79,4 @@
+	// ***** Cwtch Server management *****
+
+	app := app2.NewApp(acn, "./storage", app2.LoadAppSettings("./storage"))
+	managerApp := app2.NewApp(acn, "./managerstorage", app2.LoadAppSettings("./managerstorage"))

@@ -0,0 +122,4 @@
+		t.Fatalf("could not create hybrid contact (bob): %v", err)
+	}
+
+	// Now we can allow alice, bob and carol to create a new hybrid group...