forked from cwtch.im/cwtch
Upgrade SendMessageToGroup to return the signature for UX tracking purposes
This commit is contained in:
parent
f056407cd0
commit
a210986140
|
@ -44,6 +44,7 @@ type CwtchPeer interface {
|
||||||
|
|
||||||
JoinServer(string)
|
JoinServer(string)
|
||||||
SendMessageToGroup(string, string) error
|
SendMessageToGroup(string, string) error
|
||||||
|
SendMessageToGroupTracked(string, string) (string, error)
|
||||||
|
|
||||||
GetProfile() *model.Profile
|
GetProfile() *model.Profile
|
||||||
|
|
||||||
|
@ -226,10 +227,18 @@ func (cp *cwtchPeer) JoinServer(onion string) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// SendMessageToGroup attempts to sent the given message to the given group id.
|
// SendMessageToGroup attempts to sent the given message to the given group id.
|
||||||
|
// TODO: Deprecate in favour of SendMessageToGroupTracked
|
||||||
func (cp *cwtchPeer) SendMessageToGroup(groupid string, message string) error {
|
func (cp *cwtchPeer) SendMessageToGroup(groupid string, message string) error {
|
||||||
|
_, err := cp.SendMessageToGroupTracked(groupid, message)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// SendMessageToGroup attempts to sent the given message to the given group id.
|
||||||
|
// It returns the signature of the message which can be used to identify it in any UX layer.
|
||||||
|
func (cp *cwtchPeer) SendMessageToGroupTracked(groupid string, message string) (string, error) {
|
||||||
group := cp.Profile.GetGroupByGroupID(groupid)
|
group := cp.Profile.GetGroupByGroupID(groupid)
|
||||||
if group == nil {
|
if group == nil {
|
||||||
return errors.New("invalid group id")
|
return "", errors.New("invalid group id")
|
||||||
}
|
}
|
||||||
ct, sig, err := cp.Profile.EncryptMessageToGroup(message, groupid)
|
ct, sig, err := cp.Profile.EncryptMessageToGroup(message, groupid)
|
||||||
|
|
||||||
|
@ -237,7 +246,7 @@ func (cp *cwtchPeer) SendMessageToGroup(groupid string, message string) error {
|
||||||
cp.eventBus.Publish(event.NewEvent(event.SendMessageToGroup, map[event.Field]string{event.GroupServer: group.GroupServer, event.Ciphertext: string(ct), event.Signature: string(sig)}))
|
cp.eventBus.Publish(event.NewEvent(event.SendMessageToGroup, map[event.Field]string{event.GroupServer: group.GroupServer, event.Ciphertext: string(ct), event.Signature: string(sig)}))
|
||||||
}
|
}
|
||||||
|
|
||||||
return err
|
return string(sig), err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cp *cwtchPeer) SendMessageToPeer(onion string, message string) string {
|
func (cp *cwtchPeer) SendMessageToPeer(onion string, message string) string {
|
||||||
|
|
Loading…
Reference in New Issue