120 lines
4.7 KiB
Go
120 lines
4.7 KiB
Go
package extensions
|
|
|
|
import (
|
|
"cwtch.im/cwtch/event"
|
|
"cwtch.im/cwtch/model"
|
|
"cwtch.im/cwtch/model/attr"
|
|
"cwtch.im/cwtch/model/constants"
|
|
"cwtch.im/cwtch/peer"
|
|
"cwtch.im/cwtch/protocol/connections"
|
|
"cwtch.im/cwtch/settings"
|
|
"git.openprivacy.ca/openprivacy/log"
|
|
"strconv"
|
|
)
|
|
|
|
// ProfileValueExtension implements custom Profile Names over Cwtch
|
|
type ProfileValueExtension struct {
|
|
}
|
|
|
|
func (pne ProfileValueExtension) NotifySettingsUpdate(_ settings.GlobalSettings) {
|
|
}
|
|
|
|
func (pne ProfileValueExtension) EventsToRegister() []event.Type {
|
|
return []event.Type{event.PeerStateChange, event.Heartbeat}
|
|
}
|
|
|
|
func (pne ProfileValueExtension) ExperimentsToRegister() []string {
|
|
return nil
|
|
}
|
|
|
|
func (pne ProfileValueExtension) requestProfileInfo(profile peer.CwtchPeer, ci *model.Conversation) {
|
|
profile.SendScopedZonedGetValToContact(ci.ID, attr.PublicScope, attr.ProfileZone, constants.Name)
|
|
profile.SendScopedZonedGetValToContact(ci.ID, attr.PublicScope, attr.ProfileZone, constants.ProfileStatus)
|
|
profile.SendScopedZonedGetValToContact(ci.ID, attr.PublicScope, attr.ProfileZone, constants.ProfileAttribute1)
|
|
profile.SendScopedZonedGetValToContact(ci.ID, attr.PublicScope, attr.ProfileZone, constants.ProfileAttribute2)
|
|
profile.SendScopedZonedGetValToContact(ci.ID, attr.PublicScope, attr.ProfileZone, constants.ProfileAttribute3)
|
|
}
|
|
|
|
func (pne ProfileValueExtension) OnEvent(ev event.Event, profile peer.CwtchPeer) {
|
|
switch ev.EventType {
|
|
case event.Heartbeat:
|
|
// once every heartbeat, loop through conversations and, if they are online, request an update to any long info..
|
|
conversations, err := profile.FetchConversations()
|
|
if err == nil {
|
|
for _, ci := range conversations {
|
|
if profile.GetPeerState(ci.Handle) == connections.AUTHENTICATED {
|
|
pne.requestProfileInfo(profile, ci)
|
|
}
|
|
}
|
|
}
|
|
case event.PeerStateChange:
|
|
ci, err := profile.FetchConversationInfo(ev.Data["RemotePeer"])
|
|
if err == nil {
|
|
// if we have re-authenticated with thie peer then request their profile image...
|
|
if connections.ConnectionStateToType()[ev.Data[event.ConnectionState]] == connections.AUTHENTICATED {
|
|
// Request some profile information...
|
|
pne.requestProfileInfo(profile, ci)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
// OnContactReceiveValue for ProfileValueExtension handles saving specific Public Profile Values like Profile Name
|
|
func (pne ProfileValueExtension) OnContactReceiveValue(profile peer.CwtchPeer, conversation model.Conversation, szp attr.ScopedZonedPath, value string, exists bool) {
|
|
// Allow public profile parameters to be added as contact specific attributes...
|
|
scope, zone, _ := szp.GetScopeZonePath()
|
|
if exists && scope.IsPublic() && zone == attr.ProfileZone {
|
|
|
|
// Check the current value of the attribute
|
|
currentValue, err := profile.GetConversationAttribute(conversation.ID, szp)
|
|
if err == nil && currentValue == value {
|
|
// Value exists and the value is the same, short-circuit
|
|
return
|
|
}
|
|
|
|
// Save the new Attribute
|
|
err = profile.SetConversationAttribute(conversation.ID, szp, value)
|
|
if err != nil {
|
|
// Something else wen't wrong.. short-circuit
|
|
log.Errorf("error setting conversation attribute %v", err)
|
|
return
|
|
}
|
|
|
|
// Finally publish an update for listeners to react to.
|
|
scope, zone, zpath := szp.GetScopeZonePath()
|
|
profile.PublishEvent(event.NewEvent(event.UpdatedConversationAttribute, map[event.Field]string{
|
|
event.Scope: string(scope),
|
|
event.Path: string(zone.ConstructZonedPath(zpath)),
|
|
event.Data: value,
|
|
event.RemotePeer: conversation.Handle,
|
|
event.ConversationID: strconv.Itoa(conversation.ID),
|
|
}))
|
|
}
|
|
}
|
|
|
|
// OnContactRequestValue for ProfileValueExtension handles returning Public Profile Values
|
|
func (pne ProfileValueExtension) OnContactRequestValue(profile peer.CwtchPeer, conversation model.Conversation, eventID string, szp attr.ScopedZonedPath) {
|
|
scope, zone, zpath := szp.GetScopeZonePath()
|
|
log.Debugf("Looking up public | conversation scope/zone %v", szp.ToString())
|
|
if scope.IsPublic() || scope.IsConversation() {
|
|
val, exists := profile.GetScopedZonedAttribute(scope, zone, zpath)
|
|
|
|
// NOTE: Temporary Override because UI currently wipes names if it can't find them...
|
|
if !exists && zone == attr.UnknownZone && zpath == constants.Name {
|
|
val, exists = profile.GetScopedZonedAttribute(attr.PublicScope, attr.ProfileZone, constants.Name)
|
|
}
|
|
|
|
// Construct a Response
|
|
resp := event.NewEvent(event.SendRetValMessageToPeer, map[event.Field]string{event.ConversationID: strconv.Itoa(conversation.ID), event.RemotePeer: conversation.Handle, event.Exists: strconv.FormatBool(exists)})
|
|
resp.EventID = eventID
|
|
if exists {
|
|
resp.Data[event.Data] = val
|
|
} else {
|
|
resp.Data[event.Data] = ""
|
|
}
|
|
|
|
log.Debugf("Responding with SendRetValMessageToPeer exists:%v data: %v\n", exists, val)
|
|
profile.PublishEvent(resp)
|
|
}
|
|
}
|