Managed Groups First Cut

@@ -44,0 +62,4 @@
+						profile.PublishEvent(ev)
+					}
+				}
+				messsages, _ = profile.GetMostRecentMessages(ci.ID, 2, 0, uint(100))

@@ -44,0 +57,4 @@
+						body := message.Body
+						ev := event.NewEvent(event.SendMessageToPeer, map[event.Field]string{event.ConversationID: strconv.Itoa(ci.ID), event.RemotePeer: ci.Handle, event.Data: body})
+						ev.EventID = message.Signature // we need this ensure that we correctly ack this in the db when it comes back
+						// TODO: The EventBus is becoming very noisy...we may want to consider a one-way shortcut to Engine i.e. profile.Engine.SendMessageToPeer

@@ -0,0 +62,4 @@
+}
+
+// This file contains code for the Hybrid Group / Managed Group types..
+type HybridGroupMessage struct {

@@ -0,0 +34,4 @@
+// OnEvent handles File Sharing Hooks like Manifest Received and FileDownloaded
+func (f *GroupManagerFunctionality) OnEvent(ev event.Event, profile peer.CwtchPeer) {
+	switch ev.EventType {
+	case event.PeerStateChange:

@@ -0,0 +38,4 @@
+		handle := ev.Data["RemotePeer"]
+		// check that we have authenticated with this peer
+		if connections.ConnectionStateToType()[ev.Data[event.ConnectionState]] == connections.AUTHENTICATED {
+			mg, err := f.GetManagedGroup(profile)

@@ -0,0 +142,4 @@
+
+// Establish a new Managed Group and return its conversation id
+func (f *GroupManagerFunctionality) ManageNewGroup(profile peer.CwtchPeer) (int, error) {
+	ac := model.DefaultP2PAccessControl()

@@ -0,0 +146,4 @@
+	// by setting the ManageGroup permission in this ACL we are allowing the manage to
+	// take control of how this group is structured, see OnEvent above...
+	ac.ManageGroup = true
+	// note: a manager can only manage one group. This will (probably) always be true and has a few benefits

@@ -0,0 +148,4 @@
+	ac.ManageGroup = true
+	// note: a manager can only manage one group. This will (probably) always be true and has a few benefits
+	// and downsides.
+	// The main downside is that it requires a new manager per group (and thus an onion service per group)

@@ -0,0 +152,4 @@
+	// However, it means that we can lean on p2p functionality like profile images / metadata / name
+	// etc. for group metadata and effectively get that for-free in the client.
+	// HOWEVER: hedging our bets here by giving this group a numeric handle...
+	handle := fmt.Sprintf("managed:%d", 000)

@@ -0,0 +168,4 @@
+// AddHybridContact is a wrapper arround NewContactConversation which sets the contact
+// up for Hybrid Group channel messages...
+// TODO this function assumes that authorization has been done at a higher level..
+func (f *GroupManagerFunctionality) AddHybridContact(profile peer.CwtchPeer, handle string) error {

@@ -0,0 +26,4 @@
+}
+
+func (f ManagedGroupFunctionality) EventsToRegister() []event.Type {
+	return []event.Type{event.ProtocolEngineCreated, event.NewMessageFromPeerEngine}

@@ -0,0 +47,4 @@
+		}
+
+		// We reject managed group requests for groups not setup as managed groups...
+		if ci.ACL[handle].ManageGroup {

@@ -0,0 +107,4 @@
+
+// handleAddMemberEvent adds a group member to the conversation ACL
+// assumes we are called after an event provided by an authorized peer (i.e. ManageGroup == true)
+func (f *ManagedGroupFunctionality) handleAddMemberEvent(profile peer.CwtchPeer, conversation model.Conversation, ame AddMemberEvent) {

@@ -0,0 +126,4 @@
+func (f *ManagedGroupFunctionality) handleRotateKeyEvent(profile peer.CwtchPeer, conversation model.Conversation, rke RotateKeyEvent) {
+	keyScope := attr.LocalScope.ConstructScopedZonedPath(attr.ConversationZone.ConstructZonedPath("key"))
+	keyB64 := base64.StdEncoding.EncodeToString(rke.Key)
+	profile.SetConversationAttribute(conversation.ID, keyScope, keyB64)

@@ -0,0 +11,4 @@
+// CwtchProfile function that combines some core-functionalities like Hybrid Groups so that
+// they can be transparently exposed in autobindings.
+// DEV NOTE: consider moving other cross-cutting interface functions here to simplfy CwtchPeer
+type InterfaceFunctionality struct {

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

@@ -0,0 +90,4 @@
+	settings := app.ReadSettings()
+	settings.ExperimentsEnabled = true
+	settings.Experiments[constants.GroupsExperiment] = true
+	settings.Experiments[constants.GroupManagerExperiment] = false

@@ -0,0 +97,4 @@
+	managerSettings := managerApp.ReadSettings()
+	managerSettings.ExperimentsEnabled = true
+	managerSettings.Experiments[constants.GroupsExperiment] = true
+	managerSettings.Experiments[constants.GroupManagerExperiment] = true

@@ -0,0 +129,4 @@
+	// Now we can allow alice, bob and carol to create a new hybrid group...
+	log.Infof("now we can allow alice  bob and carol to join the hybrid group")
+	inter := inter.InterfaceFunctionality{}
+	err = inter.ImportBundle(alice, "managed:"+manager.GetOnion())

@@ -0,0 +207,4 @@
+	pprof.Lookup("goroutine").WriteTo(os.Stdout, 1)
+	fmt.Println("")
+
+	if numGoRoutinesStart != numGoRoutinesPostAppShutdown {

@@ -0,0 +11,4 @@
+	"time"
+)
+
+func WaitForConnection(t *testing.T, peer peer.CwtchPeer, addr string, target connections.ConnectionState) {