|
|
|
@ -11,15 +11,14 @@ import (
|
|
|
|
|
)
|
|
|
|
|
import "cwtch.im/cwtch/event"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
type EventProfileEnvelope struct {
|
|
|
|
|
event event.Event
|
|
|
|
|
event event.Event
|
|
|
|
|
profile string
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
type EventHandler struct {
|
|
|
|
|
app app.Application
|
|
|
|
|
appBusQueue event.Queue
|
|
|
|
|
app app.Application
|
|
|
|
|
appBusQueue event.Queue
|
|
|
|
|
profileEvents chan EventProfileEnvelope
|
|
|
|
|
|
|
|
|
|
profileQueues map[string]event.Queue
|
|
|
|
@ -34,7 +33,7 @@ func NewEventHandler(application app.Application) *EventHandler {
|
|
|
|
|
application.GetPrimaryBus().Subscribe(event.ReloadDone, appBusQueue)
|
|
|
|
|
application.GetPrimaryBus().Subscribe(event.ACNVersion, appBusQueue)
|
|
|
|
|
|
|
|
|
|
return &EventHandler{ appBusQueue: appBusQueue, profileQueues: make(map[string]event.Queue), profileEvents: make(chan EventProfileEnvelope)}
|
|
|
|
|
return &EventHandler{appBusQueue: appBusQueue, profileQueues: make(map[string]event.Queue), profileEvents: make(chan EventProfileEnvelope)}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (eh *EventHandler) GetNextEvent() string {
|
|
|
|
@ -104,15 +103,15 @@ func (eh *EventHandler) handleProfileEvent(ev *EventProfileEnvelope) string {
|
|
|
|
|
switch ev.event.EventType {
|
|
|
|
|
|
|
|
|
|
/*case event.NetworkStatus:
|
|
|
|
|
online, _ := peer.GetAttribute(attr.GetLocalScope(constants.PeerOnline))
|
|
|
|
|
if e.Data[event.Status] == plugins.NetworkCheckSuccess && online == event.False {
|
|
|
|
|
peer.SetAttribute(attr.GetLocalScope(constants.PeerOnline), event.True)
|
|
|
|
|
uiManager.UpdateNetworkStatus(true)
|
|
|
|
|
// TODO we may have to reinitialize the peer
|
|
|
|
|
} else if e.Data[event.Status] == plugins.NetworkCheckError && online == event.True {
|
|
|
|
|
peer.SetAttribute(attr.GetLocalScope(constants.PeerOnline), event.False)
|
|
|
|
|
uiManager.UpdateNetworkStatus(false)
|
|
|
|
|
}*/
|
|
|
|
|
online, _ := peer.GetAttribute(attr.GetLocalScope(constants.PeerOnline))
|
|
|
|
|
if e.Data[event.Status] == plugins.NetworkCheckSuccess && online == event.False {
|
|
|
|
|
peer.SetAttribute(attr.GetLocalScope(constants.PeerOnline), event.True)
|
|
|
|
|
uiManager.UpdateNetworkStatus(true)
|
|
|
|
|
// TODO we may have to reinitialize the peer
|
|
|
|
|
} else if e.Data[event.Status] == plugins.NetworkCheckError && online == event.True {
|
|
|
|
|
peer.SetAttribute(attr.GetLocalScope(constants.PeerOnline), event.False)
|
|
|
|
|
uiManager.UpdateNetworkStatus(false)
|
|
|
|
|
}*/
|
|
|
|
|
|
|
|
|
|
case event.NewMessageFromPeer: //event.TimestampReceived, event.RemotePeer, event.Data
|
|
|
|
|
// I Don't think we need to enrich
|
|
|
|
@ -134,17 +133,17 @@ func (eh *EventHandler) handleProfileEvent(ev *EventProfileEnvelope) string {
|
|
|
|
|
// No enrichement required
|
|
|
|
|
//Acknowledge(ev.event.Data[event.RemotePeer], ev.event.Data[event.EventID])
|
|
|
|
|
/*
|
|
|
|
|
case event.NewMessageFromGroup: //event.TimestampReceived, event.TimestampSent, event.Data, event.GroupID, event.RemotePeer
|
|
|
|
|
ts, _ := time.Parse(time.RFC3339Nano, e.Data[event.TimestampSent])
|
|
|
|
|
uiManager.AddMessage(e.Data[event.GroupID], e.Data[event.RemotePeer], e.Data[event.Data], e.Data[event.RemotePeer] == peer.GetOnion(), hex.EncodeToString([]byte(e.Data[event.Signature])), ts, true)
|
|
|
|
|
case event.NewMessageFromGroup: //event.TimestampReceived, event.TimestampSent, event.Data, event.GroupID, event.RemotePeer
|
|
|
|
|
ts, _ := time.Parse(time.RFC3339Nano, e.Data[event.TimestampSent])
|
|
|
|
|
uiManager.AddMessage(e.Data[event.GroupID], e.Data[event.RemotePeer], e.Data[event.Data], e.Data[event.RemotePeer] == peer.GetOnion(), hex.EncodeToString([]byte(e.Data[event.Signature])), ts, true)
|
|
|
|
|
|
|
|
|
|
case event.NewGroupInvite:
|
|
|
|
|
gid, err := peer.ProcessInvite(e.Data[event.GroupInvite], e.Data[event.RemotePeer])
|
|
|
|
|
group := peer.GetGroup(gid)
|
|
|
|
|
if err == nil && group != nil {
|
|
|
|
|
uiManager.AddContact(gid)
|
|
|
|
|
}
|
|
|
|
|
*/
|
|
|
|
|
case event.NewGroupInvite:
|
|
|
|
|
gid, err := peer.ProcessInvite(e.Data[event.GroupInvite], e.Data[event.RemotePeer])
|
|
|
|
|
group := peer.GetGroup(gid)
|
|
|
|
|
if err == nil && group != nil {
|
|
|
|
|
uiManager.AddContact(gid)
|
|
|
|
|
}
|
|
|
|
|
*/
|
|
|
|
|
case event.PeerCreated:
|
|
|
|
|
handle := ev.event.Data[event.RemotePeer]
|
|
|
|
|
err := EnrichNewPeer(handle, ph, ev)
|
|
|
|
@ -152,10 +151,10 @@ func (eh *EventHandler) handleProfileEvent(ev *EventProfileEnvelope) string {
|
|
|
|
|
return err.Error()
|
|
|
|
|
}
|
|
|
|
|
/*
|
|
|
|
|
case event.SendMessageToGroupError:
|
|
|
|
|
uiManager.AddSendMessageError(e.Data[event.GroupServer], e.Data[event.Signature], e.Data[event.Error])
|
|
|
|
|
case event.SendMessageToPeerError:
|
|
|
|
|
uiManager.AddSendMessageError(e.Data[event.RemotePeer], e.Data[event.EventID], e.Data[event.Error])
|
|
|
|
|
case event.SendMessageToGroupError:
|
|
|
|
|
uiManager.AddSendMessageError(e.Data[event.GroupServer], e.Data[event.Signature], e.Data[event.Error])
|
|
|
|
|
case event.SendMessageToPeerError:
|
|
|
|
|
uiManager.AddSendMessageError(e.Data[event.RemotePeer], e.Data[event.EventID], e.Data[event.Error])
|
|
|
|
|
*/
|
|
|
|
|
case event.PeerStateChange:
|
|
|
|
|
cxnState := connections.ConnectionStateToType[ev.event.Data[event.ConnectionState]]
|
|
|
|
@ -182,45 +181,45 @@ func (eh *EventHandler) handleProfileEvent(ev *EventProfileEnvelope) string {
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/*case event.NewRetValMessageFromPeer:
|
|
|
|
|
onion := e.Data[event.RemotePeer]
|
|
|
|
|
scope := e.Data[event.Scope]
|
|
|
|
|
path := e.Data[event.Path]
|
|
|
|
|
val := e.Data[event.Data]
|
|
|
|
|
exists, _ := strconv.ParseBool(e.Data[event.Exists])
|
|
|
|
|
/*case event.NewRetValMessageFromPeer:
|
|
|
|
|
onion := e.Data[event.RemotePeer]
|
|
|
|
|
scope := e.Data[event.Scope]
|
|
|
|
|
path := e.Data[event.Path]
|
|
|
|
|
val := e.Data[event.Data]
|
|
|
|
|
exists, _ := strconv.ParseBool(e.Data[event.Exists])
|
|
|
|
|
|
|
|
|
|
if exists && scope == attr.PublicScope {
|
|
|
|
|
switch path {
|
|
|
|
|
case constants.Name:
|
|
|
|
|
peer.SetContactAttribute(onion, attr.GetPeerScope(constants.Name), val)
|
|
|
|
|
uiManager.UpdateContactDisplayName(onion)
|
|
|
|
|
case constants.Picture:
|
|
|
|
|
peer.SetContactAttribute(onion, attr.GetPeerScope(constants.Picture), val)
|
|
|
|
|
uiManager.UpdateContactPicture(onion)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
case event.ServerStateChange:
|
|
|
|
|
serverOnion := e.Data[event.GroupServer]
|
|
|
|
|
state := connections.ConnectionStateToType[e.Data[event.ConnectionState]]
|
|
|
|
|
groups := peer.GetGroups()
|
|
|
|
|
for _, groupID := range groups {
|
|
|
|
|
group := peer.GetGroup(groupID)
|
|
|
|
|
if group != nil && group.GroupServer == serverOnion {
|
|
|
|
|
group.State = e.Data[event.ConnectionState]
|
|
|
|
|
loading := false
|
|
|
|
|
if state == connections.AUTHENTICATED {
|
|
|
|
|
loading = true
|
|
|
|
|
if exists && scope == attr.PublicScope {
|
|
|
|
|
switch path {
|
|
|
|
|
case constants.Name:
|
|
|
|
|
peer.SetContactAttribute(onion, attr.GetPeerScope(constants.Name), val)
|
|
|
|
|
uiManager.UpdateContactDisplayName(onion)
|
|
|
|
|
case constants.Picture:
|
|
|
|
|
peer.SetContactAttribute(onion, attr.GetPeerScope(constants.Picture), val)
|
|
|
|
|
uiManager.UpdateContactPicture(onion)
|
|
|
|
|
}
|
|
|
|
|
uiManager.UpdateContactStatus(groupID, int(state), loading)
|
|
|
|
|
uiManager.UpdateContactStatus(serverOnion, int(state), loading)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
case event.DeletePeer:
|
|
|
|
|
log.Infof("PeerHandler got DeletePeer, SHUTTING down!\n")
|
|
|
|
|
uiManager.ReloadProfiles()
|
|
|
|
|
return
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
case event.ServerStateChange:
|
|
|
|
|
serverOnion := e.Data[event.GroupServer]
|
|
|
|
|
state := connections.ConnectionStateToType[e.Data[event.ConnectionState]]
|
|
|
|
|
groups := peer.GetGroups()
|
|
|
|
|
for _, groupID := range groups {
|
|
|
|
|
group := peer.GetGroup(groupID)
|
|
|
|
|
if group != nil && group.GroupServer == serverOnion {
|
|
|
|
|
group.State = e.Data[event.ConnectionState]
|
|
|
|
|
loading := false
|
|
|
|
|
if state == connections.AUTHENTICATED {
|
|
|
|
|
loading = true
|
|
|
|
|
}
|
|
|
|
|
uiManager.UpdateContactStatus(groupID, int(state), loading)
|
|
|
|
|
uiManager.UpdateContactStatus(serverOnion, int(state), loading)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
case event.DeletePeer:
|
|
|
|
|
log.Infof("PeerHandler got DeletePeer, SHUTTING down!\n")
|
|
|
|
|
uiManager.ReloadProfiles()
|
|
|
|
|
return
|
|
|
|
|
*/
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
json, _ := json.Marshal(ev)
|
|
|
|
@ -251,7 +250,7 @@ func (eh *EventHandler) startHandlingPeer(onion string) {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (eh *EventHandler) forwardProfileMessages(onion string, q event.Queue) {
|
|
|
|
|
for {
|
|
|
|
|
for {
|
|
|
|
|
e := q.Next()
|
|
|
|
|
ev := EventProfileEnvelope{event: *e, profile: onion}
|
|
|
|
|
eh.profileEvents <- ev
|
|
|
|
|