2018-11-22 00:01:17 +00:00
|
|
|
package gothings
|
|
|
|
|
|
|
|
import (
|
2018-11-28 22:14:02 +00:00
|
|
|
"cwtch.im/ui/go/constants"
|
|
|
|
"cwtch.im/ui/go/gobjects"
|
|
|
|
"cwtch.im/ui/go/the"
|
2018-11-22 00:01:17 +00:00
|
|
|
"encoding/base32"
|
2018-12-05 16:05:39 +00:00
|
|
|
"git.openprivacy.ca/openprivacy/libricochet-go/log"
|
2019-02-04 23:00:12 +00:00
|
|
|
"runtime/debug"
|
2018-11-28 20:34:49 +00:00
|
|
|
"strings"
|
2018-11-22 00:01:17 +00:00
|
|
|
)
|
|
|
|
|
|
|
|
type InterfaceState struct {
|
|
|
|
parentGcd *GrandCentralDispatcher
|
2018-11-28 20:34:49 +00:00
|
|
|
contacts map[string]*gobjects.Contact
|
|
|
|
messages map[string][]*gobjects.Message
|
2018-11-22 00:01:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func NewUIState(gcd *GrandCentralDispatcher) (uis InterfaceState) {
|
|
|
|
uis = InterfaceState{gcd, make(map[string]*gobjects.Contact), make(map[string][]*gobjects.Message)}
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
func (this *InterfaceState) AddContact(c *gobjects.Contact) {
|
|
|
|
if len(c.Handle) == 32 { // ADD GROUP
|
|
|
|
//TODO: we should handle group creation here too probably? the code for groups vs individuals is weird right now ^ea
|
|
|
|
|
|
|
|
if _, found := this.contacts[c.Handle]; !found {
|
|
|
|
this.contacts[c.Handle] = c
|
|
|
|
this.parentGcd.AddContact(c.Handle, c.DisplayName, c.Image, c.Server, c.Badge, c.Status, c.Trusted)
|
|
|
|
}
|
|
|
|
|
|
|
|
return
|
|
|
|
} else if len(c.Handle) != 56 {
|
2018-12-05 16:05:39 +00:00
|
|
|
log.Errorf("sorry, unable to handle AddContact(%v)", c.Handle)
|
2019-02-04 23:00:12 +00:00
|
|
|
debug.PrintStack()
|
2018-11-22 00:01:17 +00:00
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
if the.Peer.GetContact(c.Handle) == nil {
|
|
|
|
decodedPub, _ := base32.StdEncoding.DecodeString(strings.ToUpper(c.Handle))
|
2019-02-03 01:19:51 +00:00
|
|
|
the.Peer.AddContact(c.DisplayName, c.Handle, decodedPub, c.Trusted)
|
2018-11-22 00:01:17 +00:00
|
|
|
go the.Peer.PeerWithOnion(c.Handle)
|
|
|
|
}
|
|
|
|
|
|
|
|
if _, found := this.contacts[c.Handle]; !found {
|
|
|
|
this.contacts[c.Handle] = c
|
|
|
|
this.parentGcd.AddContact(c.Handle, c.DisplayName, c.Image, c.Server, c.Badge, c.Status, c.Trusted)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func (this *InterfaceState) GetContact(handle string) *gobjects.Contact {
|
|
|
|
return this.contacts[handle]
|
|
|
|
}
|
|
|
|
|
|
|
|
func (this *InterfaceState) AddMessage(m *gobjects.Message) {
|
|
|
|
_, found := this.contacts[m.Handle]
|
|
|
|
if !found {
|
|
|
|
this.AddContact(&gobjects.Contact{
|
|
|
|
m.DisplayName,
|
|
|
|
m.Image,
|
|
|
|
m.Handle,
|
|
|
|
"",
|
|
|
|
1,
|
|
|
|
0,
|
|
|
|
false,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
c := the.Peer.GetContact(m.Handle)
|
|
|
|
if c == nil {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
_, found = this.messages[m.Handle]
|
|
|
|
if !found {
|
|
|
|
this.messages[m.Handle] = make([]*gobjects.Message, 0)
|
|
|
|
}
|
|
|
|
|
2019-02-04 22:22:58 +00:00
|
|
|
if m.Message == "ack" {
|
|
|
|
// If an ack, swallow the message and ack from the list.
|
|
|
|
acklist := the.AcknowledgementIDs[m.From]
|
|
|
|
for _,ack := range acklist {
|
|
|
|
this.parentGcd.Acknowledged(ack)
|
2018-11-22 00:01:17 +00:00
|
|
|
}
|
|
|
|
} else {
|
2019-02-04 22:22:58 +00:00
|
|
|
this.messages[m.Handle] = append(this.messages[m.Handle], m)
|
|
|
|
|
|
|
|
if this.parentGcd.CurrentOpenConversation() == m.Handle {
|
|
|
|
this.parentGcd.AppendMessage(m.Handle, m.From, m.DisplayName, m.Message, m.Image, uint(m.MessageID), m.FromMe, m.Timestamp.Format(constants.TIME_FORMAT))
|
|
|
|
} else {
|
|
|
|
c := this.GetContact(m.Handle)
|
|
|
|
c.Badge++
|
|
|
|
this.UpdateContact(c.Handle)
|
|
|
|
}
|
2018-11-22 00:01:17 +00:00
|
|
|
}
|
2019-02-04 22:22:58 +00:00
|
|
|
|
2018-11-22 00:01:17 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
func (this *InterfaceState) GetMessages(handle string) []*gobjects.Message {
|
|
|
|
_, found := this.messages[handle]
|
|
|
|
if !found {
|
|
|
|
this.messages[handle] = make([]*gobjects.Message, 0)
|
|
|
|
}
|
|
|
|
return this.messages[handle]
|
|
|
|
}
|
|
|
|
|
|
|
|
func (this *InterfaceState) UpdateContact(handle string) {
|
|
|
|
c, found := this.contacts[handle]
|
|
|
|
if found {
|
|
|
|
this.parentGcd.UpdateContact(c.Handle, c.DisplayName, c.Image, c.Server, c.Badge, c.Status, c.Trusted)
|
|
|
|
}
|
2018-11-28 20:34:49 +00:00
|
|
|
}
|