status-im
/
status-go
mirror of https://github.com/status-im/status-go.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Sync activity center (#2443) 

sync activity center
This commit is contained in:
Michele Balistreri 2021-12-02 17:23:02 +03:00 committed by GitHub
parent ea95ce2d4b
commit 0867458f16
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
12 changed files with 587 additions and 117 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
VERSION
View File

@ -1 +1 @@
0.91.12
0.91.14

60
protocol/activity_center_persistence.go
View File

@ -269,6 +269,66 @@ func (db sqlitePersistence) buildActivityCenterQuery(tx *sql.Tx, cursor string,
return db.unmarshalActivityCenterNotificationRows(rows)
}
func (db sqlitePersistence) runActivityCenterIDQuery(query string) ([][]byte, error) {
rows, err := db.db.Query(query)
if err != nil {
return nil, err
}
var ids [][]byte
for rows.Next() {
var id []byte
err = rows.Scan(&id)
if err != nil {
return nil, err
}
ids = append(ids, id)
}
return ids, nil
}
func (db sqlitePersistence) GetNotReadActivityCenterNotificationIds() ([][]byte, error) {
return db.runActivityCenterIDQuery("SELECT a.id FROM activity_center_notifications a WHERE NOT a.read")
}
func (db sqlitePersistence) GetToProcessActivityCenterNotificationIds() ([][]byte, error) {
return db.runActivityCenterIDQuery("SELECT a.id FROM activity_center_notifications a WHERE NOT a.dismissed AND NOT a.accepted")
}
func (db sqlitePersistence) GetActivityCenterNotificationsByID(ids []types.HexBytes) ([]*ActivityCenterNotification, error) {
idsArgs := make([]interface{}, 0, len(ids))
for _, id := range ids {
idsArgs = append(idsArgs, id)
}
inVector := strings.Repeat("?, ", len(ids)-1) + "?"
rows, err := db.db.Query("SELECT a.id, a.read, a.accepted, a.dismissed FROM activity_center_notifications a WHERE a.id IN ("+inVector+")", idsArgs...) // nolint: gosec
if err != nil {
return nil, err
}
var notifications []*ActivityCenterNotification
for rows.Next() {
notification := &ActivityCenterNotification{}
err := rows.Scan(
&notification.ID,
&notification.Read,
&notification.Accepted,
&notification.Dismissed)
if err != nil {
return nil, err
}
notifications = append(notifications, notification)
}
return notifications, nil
}
func (db sqlitePersistence) ActivityCenterNotifications(currCursor string, limit uint64) (string, []*ActivityCenterNotification, error) {
var tx *sql.Tx
var err error

48
protocol/messenger.go
View File

@ -2994,6 +2994,54 @@ func (m *Messenger) handleRetrievedMessages(chatWithMessages map[transport.Filte
continue
}
case protobuf.SyncActivityCenterRead:
if !common.IsPubKeyEqual(messageState.CurrentMessageState.PublicKey, &m.identity.PublicKey) {
logger.Warn("not coming from us, ignoring")
continue
}
a := msg.ParsedMessage.Interface().(protobuf.SyncActivityCenterRead)
logger.Debug("Handling SyncActivityCenterRead", zap.Any("message", a))
err = m.handleActivityCenterRead(messageState, a)
if err != nil {
logger.Warn("failed to handle SyncActivityCenterRead", zap.Error(err))
allMessagesProcessed = false
continue
}
case protobuf.SyncActivityCenterAccepted:
if !common.IsPubKeyEqual(messageState.CurrentMessageState.PublicKey, &m.identity.PublicKey) {
logger.Warn("not coming from us, ignoring")
continue
}
a := msg.ParsedMessage.Interface().(protobuf.SyncActivityCenterAccepted)
logger.Debug("Handling SyncActivityCenterAccepted", zap.Any("message", a))
err = m.handleActivityCenterAccepted(messageState, a)
if err != nil {
logger.Warn("failed to handle SyncActivityCenterAccepted", zap.Error(err))
allMessagesProcessed = false
continue
}
case protobuf.SyncActivityCenterDismissed:
if !common.IsPubKeyEqual(messageState.CurrentMessageState.PublicKey, &m.identity.PublicKey) {
logger.Warn("not coming from us, ignoring")
continue
}
a := msg.ParsedMessage.Interface().(protobuf.SyncActivityCenterDismissed)
logger.Debug("Handling SyncActivityCenterDismissed", zap.Any("message", a))
err = m.handleActivityCenterDismissed(messageState, a)
if err != nil {
logger.Warn("failed to handle SyncActivityCenterDismissed", zap.Error(err))
allMessagesProcessed = false
continue
}
case protobuf.RequestAddressForTransaction:
command := msg.ParsedMessage.Interface().(protobuf.RequestAddressForTransaction)
logger.Debug("Handling RequestAddressForTransaction", zap.Any("message", command))

199
protocol/messenger_activity_center.go
View File

@ -1,26 +1,91 @@
package protocol
import (
"context"
"github.com/golang/protobuf/proto"
"github.com/status-im/status-go/eth-node/types"
"github.com/status-im/status-go/protocol/common"
"github.com/status-im/status-go/protocol/protobuf"
)
func (m *Messenger) UnreadActivityCenterNotificationsCount() (uint64, error) {
return m.persistence.UnreadActivityCenterNotificationsCount()
}
func (m *Messenger) MarkAllActivityCenterNotificationsRead() error {
func toHexBytes(b [][]byte) []types.HexBytes {
hb := make([]types.HexBytes, len(b))
for i, v := range b {
hb[i] = types.HexBytes(v)
}
return hb
}
func fromHexBytes(hb []types.HexBytes) [][]byte {
b := make([][]byte, len(hb))
for i, v := range hb {
b[i] = v
}
return b
}
func (m *Messenger) MarkAllActivityCenterNotificationsRead(ctx context.Context) error {
if m.hasPairedDevices() {
ids, err := m.persistence.GetNotReadActivityCenterNotificationIds()
if err != nil {
return err
}
_, err = m.MarkActivityCenterNotificationsRead(ctx, toHexBytes(ids), true)
return err
}
return m.persistence.MarkAllActivityCenterNotificationsRead()
}
func (m *Messenger) MarkActivityCenterNotificationsRead(ids []types.HexBytes) error {
return m.persistence.MarkActivityCenterNotificationsRead(ids)
func (m *Messenger) MarkActivityCenterNotificationsRead(ctx context.Context, ids []types.HexBytes, sync bool) (*MessengerResponse, error) {
err := m.persistence.MarkActivityCenterNotificationsRead(ids)
if err != nil {
return nil, err
}
if !sync {
notifications, err := m.persistence.GetActivityCenterNotificationsByID(ids)
if err != nil {
return nil, err
}
return m.processActivityCenterNotifications(notifications, true)
}
syncMessage := &protobuf.SyncActivityCenterRead{
Clock: m.getTimesource().GetCurrentTime(),
Ids: fromHexBytes(ids),
}
encodedMessage, err := proto.Marshal(syncMessage)
if err != nil {
return nil, err
}
err = m.sendToPairedDevices(ctx, common.RawMessage{
Payload: encodedMessage,
MessageType: protobuf.ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_READ,
ResendAutomatically: true,
})
return nil, err
}
func (m *Messenger) MarkActivityCenterNotificationsUnread(ids []types.HexBytes) error {
return m.persistence.MarkActivityCenterNotificationsUnread(ids)
}
func (m *Messenger) processAcceptedActivityCenterNotifications(notifications []*ActivityCenterNotification) (*MessengerResponse, error) {
func (m *Messenger) processActivityCenterNotifications(notifications []*ActivityCenterNotification, addNotifications bool) (*MessengerResponse, error) {
response := &MessengerResponse{}
var chats []*Chat
for _, notification := range notifications {
@ -36,6 +101,10 @@ func (m *Messenger) processAcceptedActivityCenterNotifications(notifications []*
chats = append(chats, chat)
response.AddChat(chat)
}
if addNotifications {
response.AddActivityCenterNotification(notification)
}
}
if len(chats) != 0 {
err := m.saveChats(chats)
@ -46,28 +115,103 @@ func (m *Messenger) processAcceptedActivityCenterNotifications(notifications []*
return response, nil
}
func (m *Messenger) AcceptAllActivityCenterNotifications() (*MessengerResponse, error) {
func (m *Messenger) processAcceptedActivityCenterNotifications(ctx context.Context, notifications []*ActivityCenterNotification, sync bool) (*MessengerResponse, error) {
ids := make([][]byte, len(notifications))
for i := range notifications {
ids[i] = notifications[i].ID
notifications[i].Accepted = true
}
if sync {
syncMessage := &protobuf.SyncActivityCenterAccepted{
Clock: m.getTimesource().GetCurrentTime(),
Ids: ids,
}
encodedMessage, err := proto.Marshal(syncMessage)
if err != nil {
return nil, err
}
err = m.sendToPairedDevices(ctx, common.RawMessage{
Payload: encodedMessage,
MessageType: protobuf.ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_ACCEPTED,
ResendAutomatically: true,
})
if err != nil {
return nil, err
}
}
return m.processActivityCenterNotifications(notifications, !sync)
}
func (m *Messenger) AcceptAllActivityCenterNotifications(ctx context.Context) (*MessengerResponse, error) {
notifications, err := m.persistence.AcceptAllActivityCenterNotifications()
if err != nil {
return nil, err
}
return m.processAcceptedActivityCenterNotifications(notifications)
return m.processAcceptedActivityCenterNotifications(ctx, notifications, true)
}
func (m *Messenger) AcceptActivityCenterNotifications(ids []types.HexBytes) (*MessengerResponse, error) {
func (m *Messenger) AcceptActivityCenterNotifications(ctx context.Context, ids []types.HexBytes, sync bool) (*MessengerResponse, error) {
notifications, err := m.persistence.AcceptActivityCenterNotifications(ids)
if err != nil {
return nil, err
}
return m.processAcceptedActivityCenterNotifications(notifications)
return m.processAcceptedActivityCenterNotifications(ctx, notifications, sync)
}
func (m *Messenger) DismissAllActivityCenterNotifications() error {
func (m *Messenger) DismissAllActivityCenterNotifications(ctx context.Context) error {
if m.hasPairedDevices() {
ids, err := m.persistence.GetToProcessActivityCenterNotificationIds()
if err != nil {
return err
}
_, err = m.DismissActivityCenterNotifications(ctx, toHexBytes(ids), true)
return err
}
return m.persistence.DismissAllActivityCenterNotifications()
}
func (m *Messenger) DismissActivityCenterNotifications(ids []types.HexBytes) error {
return m.persistence.DismissActivityCenterNotifications(ids)
func (m *Messenger) DismissActivityCenterNotifications(ctx context.Context, ids []types.HexBytes, sync bool) (*MessengerResponse, error) {
err := m.persistence.DismissActivityCenterNotifications(ids)
if err != nil {
return nil, err
}
if !sync {
notifications, err := m.persistence.GetActivityCenterNotificationsByID(ids)
if err != nil {
return nil, err
}
return m.processActivityCenterNotifications(notifications, true)
}
syncMessage := &protobuf.SyncActivityCenterDismissed{
Clock: m.getTimesource().GetCurrentTime(),
Ids: fromHexBytes(ids),
}
encodedMessage, err := proto.Marshal(syncMessage)
if err != nil {
return nil, err
}
err = m.sendToPairedDevices(ctx, common.RawMessage{
Payload: encodedMessage,
MessageType: protobuf.ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_DISMISSED,
ResendAutomatically: true,
})
return nil, err
}
func (m *Messenger) ActivityCenterNotifications(cursor string, limit uint64) (*ActivityCenterPaginationResponse, error) {
@ -81,3 +225,36 @@ func (m *Messenger) ActivityCenterNotifications(cursor string, limit uint64) (*A
Notifications: notifications,
}, nil
}
func (m *Messenger) handleActivityCenterRead(state *ReceivedMessageState, message protobuf.SyncActivityCenterRead) error {
m.logger.Info("HANDLING SYNC ACTIVITY CENTER READ")
resp, err := m.MarkActivityCenterNotificationsRead(context.TODO(), toHexBytes(message.Ids), false)
if err != nil {
return err
}
return state.Response.Merge(resp)
}
func (m *Messenger) handleActivityCenterAccepted(state *ReceivedMessageState, message protobuf.SyncActivityCenterAccepted) error {
m.logger.Info("HANDLING SYNC ACTIVITY CENTER ACCEPTED")
resp, err := m.AcceptActivityCenterNotifications(context.TODO(), toHexBytes(message.Ids), false)
if err != nil {
return err
}
return state.Response.Merge(resp)
}
func (m *Messenger) handleActivityCenterDismissed(state *ReceivedMessageState, message protobuf.SyncActivityCenterDismissed) error {
m.logger.Info("HANDLING SYNC ACTIVITY CENTER DISMISS")
resp, err := m.DismissActivityCenterNotifications(context.TODO(), toHexBytes(message.Ids), false)
if err != nil {
return err
}
return state.Response.Merge(resp)
}

4
protocol/messenger_activity_center_test.go
View File

@ -86,7 +86,7 @@ func (s *MessengerActivityCenterMessageSuite) TestDismissOneToOneMessage() {
s.Require().Len(response.ActivityCenterNotifications(), 1)
// Dismiss all
s.Require().NoError(s.m.DismissAllActivityCenterNotifications())
s.Require().NoError(s.m.DismissAllActivityCenterNotifications(context.Background()))
// Send another message
inputMessage = buildTestMessage(*theirChat)
@ -130,7 +130,7 @@ func (s *MessengerActivityCenterMessageSuite) TestDeleteOneToOneChat() {
s.Require().Len(response.ActivityCenterNotifications(), 1)
// accept notification
_, err = s.m.AcceptAllActivityCenterNotifications()
_, err = s.m.AcceptAllActivityCenterNotifications(context.Background())
s.Require().NoError(err)
request := &requests.DeactivateChat{ID: response.Chats()[0].ID}

1
protocol/messenger_response.go
View File

@ -183,6 +183,7 @@ func (r *MessengerResponse) Merge(response *MessengerResponse) error {
r.AddMessages(response.Messages())
r.AddCommunities(response.Communities())
r.AddPinMessages(response.PinMessages())
r.AddActivityCenterNotifications(response.ActivityCenterNotifications())
return nil
}

95
protocol/protobuf/application_metadata_message.pb.go
View File

@ -60,6 +60,9 @@ const (
ApplicationMetadataMessage_SYNC_CHAT_REMOVED ApplicationMetadataMessage_Type = 34
ApplicationMetadataMessage_SYNC_CHAT_MESSAGES_READ ApplicationMetadataMessage_Type = 35
ApplicationMetadataMessage_BACKUP ApplicationMetadataMessage_Type = 36
ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_READ ApplicationMetadataMessage_Type = 37
ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_ACCEPTED ApplicationMetadataMessage_Type = 38
ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_DISMISSED ApplicationMetadataMessage_Type = 39
)
var ApplicationMetadataMessage_Type_name = map[int32]string{
@ -100,6 +103,9 @@ var ApplicationMetadataMessage_Type_name = map[int32]string{
34: "SYNC_CHAT_REMOVED",
35: "SYNC_CHAT_MESSAGES_READ",
36: "BACKUP",
37: "SYNC_ACTIVITY_CENTER_READ",
38: "SYNC_ACTIVITY_CENTER_ACCEPTED",
39: "SYNC_ACTIVITY_CENTER_DISMISSED",
}
var ApplicationMetadataMessage_Type_value = map[string]int32{
@ -140,6 +146,9 @@ var ApplicationMetadataMessage_Type_value = map[string]int32{
"SYNC_CHAT_REMOVED": 34,
"SYNC_CHAT_MESSAGES_READ": 35,
"BACKUP": 36,
"SYNC_ACTIVITY_CENTER_READ": 37,
"SYNC_ACTIVITY_CENTER_ACCEPTED": 38,
"SYNC_ACTIVITY_CENTER_DISMISSED": 39,
}
func (x ApplicationMetadataMessage_Type) String() string {
@ -218,46 +227,48 @@ func init() {
}
var fileDescriptor_ad09a6406fcf24c7 = []byte{
// 642 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x54, 0x5b, 0x4f, 0x1b, 0x3d,
0x10, 0xfd, 0x02, 0x7c, 0x5c, 0x26, 0x5c, 0x8c, 0xb9, 0x85, 0x70, 0x0b, 0x01, 0xb5, 0xb4, 0x95,
0x52, 0xa9, 0x7d, 0xac, 0xfa, 0xe0, 0x78, 0x07, 0x62, 0xc8, 0xda, 0x8b, 0xed, 0xa5, 0x4a, 0x5f,
0xac, 0xa5, 0xa4, 0x08, 0x09, 0x48, 0x04, 0xe1, 0x81, 0x1f, 0xd0, 0x5f, 0xd1, 0x3f, 0x5b, 0x79,
0x73, 0xd9, 0x50, 0x42, 0x79, 0x4a, 0xf6, 0x9c, 0x33, 0x33, 0x3b, 0x67, 0x66, 0x16, 0xca, 0x49,
0xbb, 0x7d, 0x7d, 0xf5, 0x23, 0xe9, 0x5c, 0xb5, 0x6e, 0xdd, 0x4d, 0xb3, 0x93, 0x5c, 0x24, 0x9d,
0xc4, 0xdd, 0x34, 0xef, 0xef, 0x93, 0xcb, 0x66, 0xa5, 0x7d, 0xd7, 0xea, 0xb4, 0xe8, 0x74, 0xfa,
0x73, 0xfe, 0xf0, 0xb3, 0xfc, 0x7b, 0x06, 0x8a, 0x2c, 0x0b, 0x08, 0x7b, 0xfa, 0xb0, 0x2b, 0xa7,
0x9b, 0x30, 0x73, 0x7f, 0x75, 0x79, 0x9b, 0x74, 0x1e, 0xee, 0x9a, 0x85, 0x5c, 0x29, 0x77, 0x30,
0xab, 0x33, 0x80, 0x16, 0x60, 0xaa, 0x9d, 0x3c, 0x5e, 0xb7, 0x92, 0x8b, 0xc2, 0x58, 0xca, 0xf5,
0x1f, 0xe9, 0x57, 0x98, 0xe8, 0x3c, 0xb6, 0x9b, 0x85, 0xf1, 0x52, 0xee, 0x60, 0xfe, 0xd3, 0xbb,
0x4a, 0xbf, 0x5e, 0xe5, 0xe5, 0x5a, 0x15, 0xfb, 0xd8, 0x6e, 0xea, 0x34, 0xac, 0xfc, 0x6b, 0x1a,
0x26, 0xfc, 0x23, 0xcd, 0xc3, 0x54, 0x2c, 0x4f, 0xa4, 0xfa, 0x26, 0xc9, 0x7f, 0x94, 0xc0, 0x2c,
0xaf, 0x31, 0xeb, 0x42, 0x34, 0x86, 0x1d, 0x21, 0xc9, 0x51, 0x0a, 0xf3, 0x5c, 0x49, 0xcb, 0xb8,
0x75, 0x71, 0x14, 0x30, 0x8b, 0x64, 0x8c, 0x6e, 0xc1, 0x7a, 0x88, 0x61, 0x15, 0xb5, 0xa9, 0x89,
0xa8, 0x07, 0x0f, 0x42, 0xc6, 0xe9, 0x0a, 0x2c, 0x46, 0x4c, 0x68, 0x27, 0xa4, 0xb1, 0xac, 0x5e,
0x67, 0x56, 0x28, 0x49, 0x26, 0x3c, 0x6c, 0x1a, 0x92, 0x3f, 0x85, 0xff, 0xa7, 0x7b, 0xb0, 0xa3,
0xf1, 0x34, 0x46, 0x63, 0x1d, 0x0b, 0x02, 0x8d, 0xc6, 0xb8, 0x43, 0xa5, 0x9d, 0xd5, 0x4c, 0x1a,
0xc6, 0x53, 0xd1, 0x24, 0x7d, 0x0f, 0x6f, 0x18, 0xe7, 0x18, 0x59, 0xf7, 0x9a, 0x76, 0x8a, 0x7e,
0x80, 0xb7, 0x01, 0xf2, 0xba, 0x90, 0xf8, 0xaa, 0x78, 0x9a, 0xae, 0xc1, 0x52, 0x5f, 0x34, 0x4c,
0xcc, 0xd0, 0x65, 0x20, 0x06, 0x65, 0xf0, 0x04, 0x05, 0xba, 0x03, 0x1b, 0x7f, 0xe7, 0x1e, 0x16,
0xe4, 0xbd, 0x35, 0xcf, 0x9a, 0x74, 0x3d, 0x03, 0xc9, 0xec, 0x68, 0x9a, 0x71, 0xae, 0x62, 0x69,
0xc9, 0x1c, 0xdd, 0x85, 0xad, 0xe7, 0x74, 0x14, 0x57, 0xeb, 0x82, 0x3b, 0x3f, 0x17, 0x32, 0x4f,
0xb7, 0xa1, 0xd8, 0x9f, 0x07, 0x57, 0x01, 0x3a, 0x16, 0x9c, 0xa1, 0xb6, 0xc2, 0x60, 0x88, 0xd2,
0x92, 0x05, 0x5a, 0x86, 0xed, 0x28, 0x36, 0x35, 0x27, 0x95, 0x15, 0x87, 0x82, 0x77, 0x53, 0x68,
0x3c, 0x12, 0xc6, 0xea, 0xae, 0xe5, 0xc4, 0x3b, 0xf4, 0x6f, 0x8d, 0xd3, 0x68, 0x22, 0x25, 0x0d,
0x92, 0x45, 0xba, 0x01, 0x6b, 0xcf, 0xc5, 0xa7, 0x31, 0xea, 0x06, 0xa1, 0x74, 0x1f, 0x4a, 0x2f,
0x90, 0x59, 0x8a, 0x25, 0xdf, 0xf5, 0xa8, 0x7a, 0xa9, 0x7f, 0x64, 0xd9, 0xb7, 0x34, 0x8a, 0xee,
0x85, 0xaf, 0xf8, 0x15, 0xc4, 0x50, 0x1d, 0x0b, 0xa7, 0xb1, 0xe7, 0xf3, 0x2a, 0x5d, 0x87, 0x95,
0x23, 0xad, 0xe2, 0x28, 0xb5, 0xc5, 0x09, 0x79, 0x26, 0x6c, 0xb7, 0xbb, 0x35, 0xba, 0x08, 0x73,
0x5d, 0x30, 0x40, 0x69, 0x85, 0x6d, 0x90, 0x82, 0x57, 0x73, 0x15, 0x86, 0xb1, 0x14, 0xb6, 0xe1,
0x02, 0x34, 0x5c, 0x8b, 0x28, 0x55, 0xaf, 0xd3, 0x02, 0x2c, 0x67, 0xd4, 0x50, 0x9e, 0xa2, 0x7f,
0xeb, 0x8c, 0x19, 0x4c, 0x5b, 0xb9, 0x63, 0x25, 0x24, 0xd9, 0xa0, 0x0b, 0x90, 0x8f, 0x84, 0x1c,
0xac, 0xfd, 0xa6, 0xbf, 0x1d, 0x0c, 0x44, 0x76, 0x3b, 0x5b, 0xfe, 0x4d, 0x8c, 0x65, 0x36, 0x36,
0xfd, 0xd3, 0xd9, 0xf6, 0xbd, 0x04, 0x58, 0xc7, 0xa1, 0x7b, 0xd9, 0xf1, 0x4b, 0x35, 0x6a, 0x67,
0x7a, 0xa5, 0x49, 0x89, 0x16, 0x61, 0x95, 0x49, 0x25, 0x1b, 0xa1, 0x8a, 0x8d, 0x0b, 0xd1, 0x6a,
0xc1, 0x5d, 0x95, 0x59, 0x5e, 0x23, 0xbb, 0x83, 0xab, 0x4a, 0x5b, 0xd6, 0x18, 0xaa, 0x33, 0x0c,
0x48, 0xd9, 0x4f, 0x2d, 0x83, 0x7b, 0xa5, 0x8c, 0x37, 0x30, 0x20, 0x7b, 0x14, 0x60, 0xb2, 0xca,
0xf8, 0x49, 0x1c, 0x91, 0xfd, 0xea, 0xdc, 0xf7, 0x7c, 0xe5, 0xe3, 0x97, 0xfe, 0xc7, 0xe3, 0x7c,
0x32, 0xfd, 0xf7, 0xf9, 0x4f, 0x00, 0x00, 0x00, 0xff, 0xff, 0xb8, 0x9b, 0x17, 0x3b, 0xe3, 0x04,
0x00, 0x00,
// 675 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x54, 0x5b, 0x4f, 0x33, 0x37,
0x10, 0x6d, 0xbe, 0x8f, 0x72, 0x99, 0x70, 0x31, 0xe6, 0x16, 0xc2, 0x2d, 0x04, 0x0a, 0xb4, 0x95,
0x52, 0xa9, 0x7d, 0xac, 0xfa, 0xe0, 0xd8, 0x03, 0x31, 0x64, 0xed, 0xc5, 0xf6, 0xa6, 0x4a, 0x5f,
0xac, 0xa5, 0xa4, 0x08, 0x09, 0x48, 0x04, 0xe1, 0x81, 0xc7, 0xfe, 0xde, 0xfe, 0x89, 0xca, 0x9b,
0x2b, 0x10, 0x3e, 0x9e, 0x92, 0x9d, 0x73, 0x66, 0x66, 0xe7, 0xcc, 0x99, 0x85, 0x72, 0xda, 0xe9,
0xdc, 0xdd, 0xfe, 0x9d, 0x76, 0x6f, 0xdb, 0x0f, 0xfe, 0xbe, 0xd5, 0x4d, 0xaf, 0xd3, 0x6e, 0xea,
0xef, 0x5b, 0x4f, 0x4f, 0xe9, 0x4d, 0xab, 0xd2, 0x79, 0x6c, 0x77, 0xdb, 0x74, 0x36, 0xfb, 0xb9,
0x7a, 0xfe, 0xa7, 0xfc, 0x2f, 0x40, 0x91, 0x8d, 0x12, 0xa2, 0x3e, 0x3f, 0xea, 0xd1, 0xe9, 0x36,
0xcc, 0x3d, 0xdd, 0xde, 0x3c, 0xa4, 0xdd, 0xe7, 0xc7, 0x56, 0x21, 0x57, 0xca, 0x9d, 0xcc, 0x9b,
0x51, 0x80, 0x16, 0x60, 0xa6, 0x93, 0xbe, 0xdc, 0xb5, 0xd3, 0xeb, 0xc2, 0x97, 0x0c, 0x1b, 0x3c,
0xd2, 0x3f, 0x60, 0xaa, 0xfb, 0xd2, 0x69, 0x15, 0xbe, 0x96, 0x72, 0x27, 0x8b, 0xbf, 0xfe, 0x58,
0x19, 0xf4, 0xab, 0x7c, 0xdc, 0xab, 0xe2, 0x5e, 0x3a, 0x2d, 0x93, 0xa5, 0x95, 0xff, 0x9b, 0x85,
0xa9, 0xf0, 0x48, 0xf3, 0x30, 0x93, 0xa8, 0x0b, 0xa5, 0xff, 0x54, 0xe4, 0x3b, 0x4a, 0x60, 0x9e,
0xd7, 0x98, 0xf3, 0x11, 0x5a, 0xcb, 0xce, 0x90, 0xe4, 0x28, 0x85, 0x45, 0xae, 0x95, 0x63, 0xdc,
0xf9, 0x24, 0x16, 0xcc, 0x21, 0xf9, 0x42, 0x77, 0x60, 0x33, 0xc2, 0xa8, 0x8a, 0xc6, 0xd6, 0x64,
0xdc, 0x0f, 0x0f, 0x53, 0xbe, 0xd2, 0x35, 0x58, 0x8e, 0x99, 0x34, 0x5e, 0x2a, 0xeb, 0x58, 0xbd,
0xce, 0x9c, 0xd4, 0x8a, 0x4c, 0x85, 0xb0, 0x6d, 0x2a, 0xfe, 0x3a, 0xfc, 0x3d, 0x3d, 0x80, 0x3d,
0x83, 0x97, 0x09, 0x5a, 0xe7, 0x99, 0x10, 0x06, 0xad, 0xf5, 0xa7, 0xda, 0x78, 0x67, 0x98, 0xb2,
0x8c, 0x67, 0xa4, 0x69, 0xfa, 0x13, 0x1c, 0x31, 0xce, 0x31, 0x76, 0xfe, 0x33, 0xee, 0x0c, 0xfd,
0x19, 0x8e, 0x05, 0xf2, 0xba, 0x54, 0xf8, 0x29, 0x79, 0x96, 0x6e, 0xc0, 0xca, 0x80, 0x34, 0x0e,
0xcc, 0xd1, 0x55, 0x20, 0x16, 0x95, 0x78, 0x15, 0x05, 0xba, 0x07, 0x5b, 0x6f, 0x6b, 0x8f, 0x13,
0xf2, 0x41, 0x9a, 0x77, 0x43, 0xfa, 0xbe, 0x80, 0x64, 0x7e, 0x32, 0xcc, 0x38, 0xd7, 0x89, 0x72,
0x64, 0x81, 0xee, 0xc3, 0xce, 0x7b, 0x38, 0x4e, 0xaa, 0x75, 0xc9, 0x7d, 0xd8, 0x0b, 0x59, 0xa4,
0xbb, 0x50, 0x1c, 0xec, 0x83, 0x6b, 0x81, 0x9e, 0x89, 0x06, 0x1a, 0x27, 0x2d, 0x46, 0xa8, 0x1c,
0x59, 0xa2, 0x65, 0xd8, 0x8d, 0x13, 0x5b, 0xf3, 0x4a, 0x3b, 0x79, 0x2a, 0x79, 0xaf, 0x84, 0xc1,
0x33, 0x69, 0x9d, 0xe9, 0x49, 0x4e, 0x82, 0x42, 0xdf, 0xe6, 0x78, 0x83, 0x36, 0xd6, 0xca, 0x22,
0x59, 0xa6, 0x5b, 0xb0, 0xf1, 0x9e, 0x7c, 0x99, 0xa0, 0x69, 0x12, 0x4a, 0x0f, 0xa1, 0xf4, 0x01,
0x38, 0x2a, 0xb1, 0x12, 0xa6, 0x9e, 0xd4, 0x2f, 0xd3, 0x8f, 0xac, 0x86, 0x91, 0x26, 0xc1, 0xfd,
0xf4, 0xb5, 0x60, 0x41, 0x8c, 0xf4, 0xb9, 0xf4, 0x06, 0xfb, 0x3a, 0xaf, 0xd3, 0x4d, 0x58, 0x3b,
0x33, 0x3a, 0x89, 0x33, 0x59, 0xbc, 0x54, 0x0d, 0xe9, 0x7a, 0xd3, 0x6d, 0xd0, 0x65, 0x58, 0xe8,
0x05, 0x05, 0x2a, 0x27, 0x5d, 0x93, 0x14, 0x02, 0x9b, 0xeb, 0x28, 0x4a, 0x94, 0x74, 0x4d, 0x2f,
0xd0, 0x72, 0x23, 0xe3, 0x8c, 0xbd, 0x49, 0x0b, 0xb0, 0x3a, 0x82, 0xc6, 0xea, 0x14, 0xc3, 0x5b,
0x8f, 0x90, 0xe1, 0xb6, 0xb5, 0x3f, 0xd7, 0x52, 0x91, 0x2d, 0xba, 0x04, 0xf9, 0x58, 0xaa, 0xa1,
0xed, 0xb7, 0xc3, 0xed, 0xa0, 0x90, 0xa3, 0xdb, 0xd9, 0x09, 0x6f, 0x62, 0x1d, 0x73, 0x89, 0x1d,
0x9c, 0xce, 0x6e, 0x98, 0x45, 0x60, 0x1d, 0xc7, 0xee, 0x65, 0x2f, 0x98, 0x6a, 0x92, 0x67, 0xfa,
0xad, 0x49, 0x89, 0x16, 0x61, 0x9d, 0x29, 0xad, 0x9a, 0x91, 0x4e, 0xac, 0x8f, 0xd0, 0x19, 0xc9,
0x7d, 0x95, 0x39, 0x5e, 0x23, 0xfb, 0xc3, 0xab, 0xca, 0x46, 0x36, 0x18, 0xe9, 0x06, 0x0a, 0x52,
0x0e, 0x5b, 0x1b, 0x85, 0xfb, 0xad, 0x6c, 0x10, 0x50, 0x90, 0x03, 0x0a, 0x30, 0x5d, 0x65, 0xfc,
0x22, 0x89, 0xc9, 0xe1, 0xd0, 0x91, 0x41, 0xd9, 0x46, 0x98, 0x94, 0xa3, 0x72, 0x68, 0x7a, 0xd4,
0x1f, 0x86, 0x8e, 0x7c, 0x0b, 0xf7, 0xae, 0x11, 0x05, 0x39, 0x0a, 0x8e, 0x9b, 0x48, 0x11, 0xd2,
0x46, 0xd2, 0x5a, 0x14, 0xe4, 0xb8, 0xba, 0xf0, 0x57, 0xbe, 0xf2, 0xcb, 0xef, 0x83, 0x4f, 0xd4,
0xd5, 0x74, 0xf6, 0xef, 0xb7, 0xff, 0x03, 0x00, 0x00, 0xff, 0xff, 0x8c, 0xb4, 0xe9, 0x28, 0x49,
0x05, 0x00, 0x00,
}

3
protocol/protobuf/application_metadata_message.proto
View File

@ -50,5 +50,8 @@ message ApplicationMetadataMessage {
SYNC_CHAT_REMOVED = 34;
SYNC_CHAT_MESSAGES_READ = 35;
BACKUP = 36;
SYNC_ACTIVITY_CENTER_READ = 37;
SYNC_ACTIVITY_CENTER_ACCEPTED = 38;
SYNC_ACTIVITY_CENTER_DISMISSED = 39;
}
}

245
protocol/protobuf/pairing.pb.go
View File

@ -793,6 +793,147 @@ func (m *SyncChatMessagesRead) GetId() string {
return ""
}
type SyncActivityCenterRead struct {
Clock uint64 `protobuf:"varint,1,opt,name=clock,proto3" json:"clock,omitempty"`
Ids [][]byte `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SyncActivityCenterRead) Reset() { *m = SyncActivityCenterRead{} }
func (m *SyncActivityCenterRead) String() string { return proto.CompactTextString(m) }
func (*SyncActivityCenterRead) ProtoMessage() {}
func (*SyncActivityCenterRead) Descriptor() ([]byte, []int) {
return fileDescriptor_d61ab7221f0b5518, []int{11}
}
func (m *SyncActivityCenterRead) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SyncActivityCenterRead.Unmarshal(m, b)
}
func (m *SyncActivityCenterRead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SyncActivityCenterRead.Marshal(b, m, deterministic)
}
func (m *SyncActivityCenterRead) XXX_Merge(src proto.Message) {
xxx_messageInfo_SyncActivityCenterRead.Merge(m, src)
}
func (m *SyncActivityCenterRead) XXX_Size() int {
return xxx_messageInfo_SyncActivityCenterRead.Size(m)
}
func (m *SyncActivityCenterRead) XXX_DiscardUnknown() {
xxx_messageInfo_SyncActivityCenterRead.DiscardUnknown(m)
}
var xxx_messageInfo_SyncActivityCenterRead proto.InternalMessageInfo
func (m *SyncActivityCenterRead) GetClock() uint64 {
if m != nil {
return m.Clock
}
return 0
}
func (m *SyncActivityCenterRead) GetIds() [][]byte {
if m != nil {
return m.Ids
}
return nil
}
type SyncActivityCenterAccepted struct {
Clock uint64 `protobuf:"varint,1,opt,name=clock,proto3" json:"clock,omitempty"`
Ids [][]byte `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SyncActivityCenterAccepted) Reset() { *m = SyncActivityCenterAccepted{} }
func (m *SyncActivityCenterAccepted) String() string { return proto.CompactTextString(m) }
func (*SyncActivityCenterAccepted) ProtoMessage() {}
func (*SyncActivityCenterAccepted) Descriptor() ([]byte, []int) {
return fileDescriptor_d61ab7221f0b5518, []int{12}
}
func (m *SyncActivityCenterAccepted) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SyncActivityCenterAccepted.Unmarshal(m, b)
}
func (m *SyncActivityCenterAccepted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SyncActivityCenterAccepted.Marshal(b, m, deterministic)
}
func (m *SyncActivityCenterAccepted) XXX_Merge(src proto.Message) {
xxx_messageInfo_SyncActivityCenterAccepted.Merge(m, src)
}
func (m *SyncActivityCenterAccepted) XXX_Size() int {
return xxx_messageInfo_SyncActivityCenterAccepted.Size(m)
}
func (m *SyncActivityCenterAccepted) XXX_DiscardUnknown() {
xxx_messageInfo_SyncActivityCenterAccepted.DiscardUnknown(m)
}
var xxx_messageInfo_SyncActivityCenterAccepted proto.InternalMessageInfo
func (m *SyncActivityCenterAccepted) GetClock() uint64 {
if m != nil {
return m.Clock
}
return 0
}
func (m *SyncActivityCenterAccepted) GetIds() [][]byte {
if m != nil {
return m.Ids
}
return nil
}
type SyncActivityCenterDismissed struct {
Clock uint64 `protobuf:"varint,1,opt,name=clock,proto3" json:"clock,omitempty"`
Ids [][]byte `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SyncActivityCenterDismissed) Reset() { *m = SyncActivityCenterDismissed{} }
func (m *SyncActivityCenterDismissed) String() string { return proto.CompactTextString(m) }
func (*SyncActivityCenterDismissed) ProtoMessage() {}
func (*SyncActivityCenterDismissed) Descriptor() ([]byte, []int) {
return fileDescriptor_d61ab7221f0b5518, []int{13}
}
func (m *SyncActivityCenterDismissed) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SyncActivityCenterDismissed.Unmarshal(m, b)
}
func (m *SyncActivityCenterDismissed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SyncActivityCenterDismissed.Marshal(b, m, deterministic)
}
func (m *SyncActivityCenterDismissed) XXX_Merge(src proto.Message) {
xxx_messageInfo_SyncActivityCenterDismissed.Merge(m, src)
}
func (m *SyncActivityCenterDismissed) XXX_Size() int {
return xxx_messageInfo_SyncActivityCenterDismissed.Size(m)
}
func (m *SyncActivityCenterDismissed) XXX_DiscardUnknown() {
xxx_messageInfo_SyncActivityCenterDismissed.DiscardUnknown(m)
}
var xxx_messageInfo_SyncActivityCenterDismissed proto.InternalMessageInfo
func (m *SyncActivityCenterDismissed) GetClock() uint64 {
if m != nil {
return m.Clock
}
return 0
}
func (m *SyncActivityCenterDismissed) GetIds() [][]byte {
if m != nil {
return m.Ids
}
return nil
}
func init() {
proto.RegisterType((*Backup)(nil), "protobuf.Backup")
proto.RegisterType((*PairInstallation)(nil), "protobuf.PairInstallation")
@ -805,6 +946,9 @@ func init() {
proto.RegisterType((*SyncInstallation)(nil), "protobuf.SyncInstallation")
proto.RegisterType((*SyncChatRemoved)(nil), "protobuf.SyncChatRemoved")
proto.RegisterType((*SyncChatMessagesRead)(nil), "protobuf.SyncChatMessagesRead")
proto.RegisterType((*SyncActivityCenterRead)(nil), "protobuf.SyncActivityCenterRead")
proto.RegisterType((*SyncActivityCenterAccepted)(nil), "protobuf.SyncActivityCenterAccepted")
proto.RegisterType((*SyncActivityCenterDismissed)(nil), "protobuf.SyncActivityCenterDismissed")
}
func init() {
@ -812,53 +956,56 @@ func init() {
}
var fileDescriptor_d61ab7221f0b5518 = []byte{
// 763 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x54, 0xcd, 0x6e, 0xdb, 0x38,
0x10, 0x86, 0x6c, 0xc7, 0x76, 0xc6, 0xb2, 0x13, 0x10, 0xc1, 0x86, 0xc9, 0x62, 0x11, 0x47, 0xd9,
0x60, 0x7d, 0xf2, 0x2e, 0xb2, 0x87, 0xc5, 0x22, 0xbb, 0x28, 0x92, 0x1c, 0x0a, 0xf7, 0x27, 0x0d,
0xd4, 0xa4, 0x87, 0x5e, 0x04, 0x5a, 0x62, 0x6c, 0xd6, 0x92, 0xa8, 0x8a, 0x94, 0x0b, 0xbd, 0x40,
0x0f, 0x3d, 0xb6, 0x0f, 0xd6, 0xf7, 0xe8, 0x53, 0x14, 0x24, 0x65, 0x45, 0x49, 0xea, 0xc4, 0xd7,
0x9e, 0xa4, 0xf9, 0x66, 0xc8, 0xf9, 0xf8, 0xcd, 0x0f, 0x74, 0x13, 0xc2, 0x52, 0x16, 0x4f, 0x86,
0x49, 0xca, 0x25, 0x47, 0x6d, 0xfd, 0x19, 0x67, 0xd7, 0x0e, 0x87, 0xe6, 0x29, 0xf1, 0x67, 0x59,
0x82, 0xb6, 0x60, 0xcd, 0x0f, 0xb9, 0x3f, 0xc3, 0x56, 0xdf, 0x1a, 0x34, 0x5c, 0x63, 0xa0, 0x1e,
0xd4, 0x58, 0x80, 0x6b, 0x7d, 0x6b, 0xb0, 0xee, 0xd6, 0x58, 0x80, 0x9e, 0x40, 0xdb, 0xe7, 0xb1,
0x24, 0xbe, 0x14, 0xb8, 0xde, 0xaf, 0x0f, 0x3a, 0x47, 0x07, 0xc3, 0xc5, 0x65, 0xc3, 0xd7, 0x79,
0xec, 0x8f, 0x62, 0x21, 0x49, 0x18, 0x12, 0xc9, 0x78, 0x7c, 0x66, 0x22, 0xdf, 0x1c, 0xb9, 0xe5,
0x21, 0xe7, 0xa3, 0x05, 0x9b, 0x17, 0x84, 0xa5, 0xd5, 0xb8, 0x25, 0xb9, 0xff, 0x80, 0x0d, 0x56,
0x89, 0xf2, 0x4a, 0x22, 0xbd, 0x2a, 0x3c, 0x0a, 0xd0, 0x1e, 0x74, 0x02, 0x3a, 0x67, 0x3e, 0xf5,
0x64, 0x9e, 0x50, 0x5c, 0xd7, 0x41, 0x60, 0xa0, 0xcb, 0x3c, 0xa1, 0x08, 0x41, 0x23, 0x26, 0x11,
0xc5, 0x0d, 0xed, 0xd1, 0xff, 0xce, 0x37, 0x0b, 0xb6, 0x97, 0x10, 0x5e, 0x51, 0x8b, 0x03, 0xe8,
0x26, 0x29, 0xbf, 0x66, 0x21, 0xf5, 0x58, 0x44, 0x26, 0x8b, 0xc4, 0x76, 0x01, 0x8e, 0x14, 0x86,
0x76, 0xa0, 0x4d, 0x63, 0xe1, 0x55, 0xd2, 0xb7, 0x68, 0x2c, 0xce, 0x49, 0x44, 0xd1, 0x3e, 0xd8,
0x21, 0x11, 0xd2, 0xcb, 0x92, 0x80, 0x48, 0x1a, 0xe0, 0x35, 0x9d, 0xac, 0xa3, 0xb0, 0x2b, 0x03,
0xa9, 0x97, 0x89, 0x5c, 0x48, 0x1a, 0x79, 0x92, 0x4c, 0x04, 0x6e, 0xf6, 0xeb, 0xea, 0x65, 0x06,
0xba, 0x24, 0x13, 0x81, 0x0e, 0xa1, 0x17, 0x72, 0x9f, 0x84, 0x5e, 0xcc, 0xfc, 0x99, 0x4e, 0xd2,
0xd2, 0x49, 0xba, 0x1a, 0x3d, 0x2f, 0x40, 0xe7, 0x53, 0x1d, 0x76, 0x96, 0x56, 0x07, 0xfd, 0x05,
0x5b, 0x55, 0x22, 0x9e, 0x3e, 0x1b, 0xe6, 0xc5, 0xeb, 0x51, 0x85, 0xd0, 0x0b, 0xe3, 0xf9, 0x89,
0xa5, 0x50, 0xb5, 0x25, 0x41, 0x40, 0x03, 0xbc, 0xde, 0xb7, 0x06, 0x6d, 0xd7, 0x18, 0x08, 0x43,
0x6b, 0xac, 0x8a, 0x4c, 0x03, 0x0c, 0x1a, 0x5f, 0x98, 0x2a, 0x3e, 0xca, 0x14, 0xa7, 0x8e, 0x89,
0xd7, 0x86, 0x8a, 0x4f, 0x69, 0xc4, 0xe7, 0x34, 0xc0, 0xb6, 0x89, 0x2f, 0x4c, 0xd4, 0x07, 0x7b,
0x4a, 0x84, 0xa7, 0xaf, 0xf5, 0x32, 0x81, 0xbb, 0xda, 0x0d, 0x53, 0x22, 0x4e, 0x14, 0x74, 0x25,
0x9c, 0x0f, 0xf7, 0x1b, 0xef, 0xc4, 0xf7, 0x79, 0x16, 0x2f, 0x6b, 0xbc, 0x7b, 0xea, 0xd6, 0x7e,
0xa0, 0xee, 0x5d, 0x09, 0xeb, 0xf7, 0x24, 0x74, 0x4e, 0x61, 0xf7, 0x6e, 0xe2, 0x8b, 0x6c, 0x1c,
0x32, 0xff, 0x6c, 0x4a, 0x56, 0x6c, 0x7a, 0xe7, 0x4b, 0x0d, 0xba, 0xea, 0x92, 0x33, 0x1e, 0x45,
0x59, 0xcc, 0x64, 0xfe, 0xe8, 0x39, 0x5b, 0x77, 0xc8, 0x1e, 0x74, 0x92, 0x94, 0xcd, 0x89, 0xa4,
0xde, 0x8c, 0xe6, 0x9a, 0x9d, 0xed, 0x42, 0x01, 0x3d, 0xa7, 0x39, 0xea, 0xab, 0x21, 0x16, 0x7e,
0xca, 0x12, 0xc5, 0x4b, 0x37, 0x88, 0xed, 0x56, 0x21, 0xf4, 0x0b, 0x34, 0xdf, 0x71, 0x16, 0x17,
0xed, 0xd1, 0x76, 0x0b, 0x0b, 0xed, 0x42, 0x7b, 0x4e, 0x53, 0x76, 0xcd, 0x68, 0x80, 0x9b, 0xda,
0x53, 0xda, 0x37, 0xd5, 0x6b, 0x55, 0xab, 0xf7, 0x0a, 0x36, 0x53, 0xfa, 0x3e, 0xa3, 0x42, 0x0a,
0x4f, 0x72, 0x4f, 0xdd, 0x83, 0xdb, 0x7a, 0x9b, 0x1d, 0xde, 0xde, 0x66, 0xe5, 0x2b, 0xdd, 0x22,
0xfc, 0x92, 0x3f, 0xe3, 0x2c, 0x76, 0x7b, 0xe9, 0x2d, 0xdb, 0xf9, 0x6a, 0xc1, 0xaf, 0x0f, 0xc4,
0x17, 0x6a, 0x58, 0xa5, 0x1a, 0xbf, 0x01, 0x24, 0x5a, 0x79, 0x2d, 0x86, 0x51, 0x77, 0xdd, 0x20,
0x4a, 0x8b, 0x52, 0xd2, 0x7a, 0x55, 0xd2, 0x07, 0xe6, 0x67, 0x1b, 0x5a, 0xfe, 0x94, 0x48, 0xb5,
0x22, 0xd7, 0xb4, 0xa7, 0xa9, 0xcc, 0x51, 0xa0, 0xba, 0xc2, 0x5f, 0x70, 0x52, 0xde, 0xa6, 0x91,
0xb5, 0xc4, 0x46, 0x5a, 0x22, 0x21, 0x89, 0x34, 0xe3, 0xd2, 0x70, 0x8d, 0xe1, 0x7c, 0xae, 0xc1,
0xe6, 0xdd, 0x66, 0x41, 0xff, 0x57, 0xb6, 0xbf, 0xa5, 0xf5, 0xda, 0x7f, 0x74, 0xfb, 0xdf, 0xec,
0x7e, 0xf4, 0x14, 0xec, 0xe2, 0xd5, 0x8a, 0x9d, 0xc0, 0x35, 0x7d, 0xc5, 0xef, 0xcb, 0xaf, 0xb8,
0xe9, 0x4e, 0xb7, 0x93, 0x94, 0xff, 0x02, 0x1d, 0x43, 0x8b, 0x98, 0x89, 0xd1, 0x0a, 0x3d, 0x48,
0xa3, 0x18, 0x2d, 0x77, 0x71, 0x02, 0xfd, 0x0b, 0xe5, 0xf3, 0x19, 0x15, 0xb8, 0xa1, 0x49, 0x6c,
0x2f, 0xab, 0x7b, 0x35, 0xd6, 0xf9, 0x07, 0x36, 0xb4, 0x57, 0x11, 0x2a, 0xc6, 0x7d, 0xb5, 0xa9,
0xf9, 0x0f, 0xb6, 0x16, 0x07, 0x5f, 0x52, 0x21, 0xc8, 0x84, 0x0a, 0x97, 0x92, 0x15, 0x4f, 0x9f,
0x76, 0xdf, 0x76, 0x86, 0x7f, 0x1e, 0x2f, 0x08, 0x8e, 0x9b, 0xfa, 0xef, 0xef, 0xef, 0x01, 0x00,
0x00, 0xff, 0xff, 0x9c, 0x69, 0xcf, 0x28, 0xd5, 0x07, 0x00, 0x00,
// 814 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xd4, 0x54, 0xdd, 0x6e, 0xe3, 0x44,
0x14, 0x96, 0xe3, 0x34, 0x49, 0x4f, 0x9c, 0x6c, 0x34, 0xaa, 0xb6, 0xb3, 0x8b, 0xd0, 0x66, 0xbd,
0xac, 0xc8, 0x55, 0x40, 0xe5, 0x02, 0xa1, 0x82, 0x20, 0x4d, 0x11, 0x0a, 0x3f, 0xa5, 0x32, 0x2d,
0x17, 0xdc, 0x58, 0x93, 0xf1, 0x34, 0x19, 0xe2, 0x3f, 0x3c, 0xe3, 0x20, 0xbf, 0x00, 0x17, 0x5c,
0xc2, 0x83, 0xf1, 0x1e, 0x3c, 0x05, 0x9a, 0x19, 0xc7, 0x75, 0x5a, 0x92, 0xe6, 0x76, 0xaf, 0xec,
0xf3, 0x9d, 0xbf, 0x6f, 0xbe, 0x39, 0x67, 0xa0, 0x97, 0x12, 0x9e, 0xf1, 0x78, 0x31, 0x4e, 0xb3,
0x44, 0x26, 0xa8, 0xa3, 0x3f, 0xf3, 0xfc, 0xce, 0x4d, 0xa0, 0x75, 0x41, 0xe8, 0x2a, 0x4f, 0xd1,
0x09, 0x1c, 0xd1, 0x30, 0xa1, 0x2b, 0x6c, 0x0d, 0xad, 0x51, 0xd3, 0x33, 0x06, 0xea, 0x43, 0x83,
0x07, 0xb8, 0x31, 0xb4, 0x46, 0xc7, 0x5e, 0x83, 0x07, 0xe8, 0x4b, 0xe8, 0xd0, 0x24, 0x96, 0x84,
0x4a, 0x81, 0xed, 0xa1, 0x3d, 0xea, 0x9e, 0xbd, 0x19, 0x6f, 0x8a, 0x8d, 0x7f, 0x2a, 0x62, 0x3a,
0x8b, 0x85, 0x24, 0x61, 0x48, 0x24, 0x4f, 0xe2, 0xa9, 0x89, 0xfc, 0xf9, 0xcc, 0xab, 0x92, 0xdc,
0x3f, 0x2c, 0x18, 0x5c, 0x13, 0x9e, 0xd5, 0xe3, 0x76, 0xf4, 0xfe, 0x10, 0x9e, 0xf1, 0x5a, 0x94,
0x5f, 0x11, 0xe9, 0xd7, 0xe1, 0x59, 0x80, 0x5e, 0x41, 0x37, 0x60, 0x6b, 0x4e, 0x99, 0x2f, 0x8b,
0x94, 0x61, 0x5b, 0x07, 0x81, 0x81, 0x6e, 0x8a, 0x94, 0x21, 0x04, 0xcd, 0x98, 0x44, 0x0c, 0x37,
0xb5, 0x47, 0xff, 0xbb, 0xff, 0x5a, 0x70, 0xba, 0x83, 0xf0, 0x81, 0x5a, 0xbc, 0x81, 0x5e, 0x9a,
0x25, 0x77, 0x3c, 0x64, 0x3e, 0x8f, 0xc8, 0x62, 0xd3, 0xd8, 0x29, 0xc1, 0x99, 0xc2, 0xd0, 0x0b,
0xe8, 0xb0, 0x58, 0xf8, 0xb5, 0xf6, 0x6d, 0x16, 0x8b, 0x2b, 0x12, 0x31, 0xf4, 0x1a, 0x9c, 0x90,
0x08, 0xe9, 0xe7, 0x69, 0x40, 0x24, 0x0b, 0xf0, 0x91, 0x6e, 0xd6, 0x55, 0xd8, 0xad, 0x81, 0xd4,
0xc9, 0x44, 0x21, 0x24, 0x8b, 0x7c, 0x49, 0x16, 0x02, 0xb7, 0x86, 0xb6, 0x3a, 0x99, 0x81, 0x6e,
0xc8, 0x42, 0xa0, 0xb7, 0xd0, 0x0f, 0x13, 0x4a, 0x42, 0x3f, 0xe6, 0x74, 0xa5, 0x9b, 0xb4, 0x75,
0x93, 0x9e, 0x46, 0xaf, 0x4a, 0xd0, 0xfd, 0xd3, 0x86, 0x17, 0x3b, 0x6f, 0x07, 0x7d, 0x0c, 0x27,
0x75, 0x22, 0xbe, 0xce, 0x0d, 0x8b, 0xf2, 0xf4, 0xa8, 0x46, 0xe8, 0x7b, 0xe3, 0x79, 0x87, 0xa5,
0x50, 0x77, 0x4b, 0x82, 0x80, 0x05, 0xf8, 0x78, 0x68, 0x8d, 0x3a, 0x9e, 0x31, 0x10, 0x86, 0xf6,
0x5c, 0x5d, 0x32, 0x0b, 0x30, 0x68, 0x7c, 0x63, 0xaa, 0xf8, 0x28, 0x57, 0x9c, 0xba, 0x26, 0x5e,
0x1b, 0x2a, 0x3e, 0x63, 0x51, 0xb2, 0x66, 0x01, 0x76, 0x4c, 0x7c, 0x69, 0xa2, 0x21, 0x38, 0x4b,
0x22, 0x7c, 0x5d, 0xd6, 0xcf, 0x05, 0xee, 0x69, 0x37, 0x2c, 0x89, 0x98, 0x28, 0xe8, 0x56, 0xb8,
0xbf, 0x3f, 0x1e, 0xbc, 0x09, 0xa5, 0x49, 0x1e, 0xef, 0x1a, 0xbc, 0x47, 0xea, 0x36, 0xfe, 0x47,
0xdd, 0x87, 0x12, 0xda, 0x8f, 0x24, 0x74, 0x2f, 0xe0, 0xe5, 0xc3, 0xc6, 0xd7, 0xf9, 0x3c, 0xe4,
0x74, 0xba, 0x24, 0x07, 0x0e, 0xbd, 0xfb, 0x77, 0x03, 0x7a, 0xaa, 0xc8, 0x34, 0x89, 0xa2, 0x3c,
0xe6, 0xb2, 0x78, 0x32, 0xcf, 0xd1, 0x13, 0xf2, 0x0a, 0xba, 0x69, 0xc6, 0xd7, 0x44, 0x32, 0x7f,
0xc5, 0x0a, 0xcd, 0xce, 0xf1, 0xa0, 0x84, 0xbe, 0x63, 0x05, 0x1a, 0xaa, 0x25, 0x16, 0x34, 0xe3,
0xa9, 0xe2, 0xa5, 0x07, 0xc4, 0xf1, 0xea, 0x10, 0x7a, 0x0e, 0xad, 0x5f, 0x13, 0x1e, 0x97, 0xe3,
0xd1, 0xf1, 0x4a, 0x0b, 0xbd, 0x84, 0xce, 0x9a, 0x65, 0xfc, 0x8e, 0xb3, 0x00, 0xb7, 0xb4, 0xa7,
0xb2, 0xef, 0x6f, 0xaf, 0x5d, 0xbf, 0xbd, 0x1f, 0x61, 0x90, 0xb1, 0xdf, 0x72, 0x26, 0xa4, 0xf0,
0x65, 0xe2, 0xab, 0x3a, 0xb8, 0xa3, 0x5f, 0xb3, 0xb7, 0xdb, 0xaf, 0x59, 0x75, 0x4a, 0xaf, 0x0c,
0xbf, 0x49, 0xbe, 0x4d, 0x78, 0xec, 0xf5, 0xb3, 0x2d, 0xdb, 0xfd, 0xc7, 0x82, 0xf7, 0xf6, 0xc4,
0x97, 0x6a, 0x58, 0x95, 0x1a, 0xef, 0x03, 0xa4, 0x5a, 0x79, 0x2d, 0x86, 0x51, 0xf7, 0xd8, 0x20,
0x4a, 0x8b, 0x4a, 0x52, 0xbb, 0x2e, 0xe9, 0x9e, 0xfd, 0x39, 0x85, 0x36, 0x5d, 0x12, 0xa9, 0x9e,
0xc8, 0x23, 0xed, 0x69, 0x29, 0x73, 0x16, 0xa8, 0xa9, 0xa0, 0x1b, 0x4e, 0xca, 0xdb, 0x32, 0xb2,
0x56, 0xd8, 0x4c, 0x4b, 0x24, 0x24, 0x91, 0x66, 0x5d, 0x9a, 0x9e, 0x31, 0xdc, 0xbf, 0x1a, 0x30,
0x78, 0x38, 0x2c, 0xe8, 0x8b, 0xda, 0xeb, 0x6f, 0x69, 0xbd, 0x5e, 0x3f, 0xf9, 0xfa, 0xdf, 0xbf,
0xfd, 0xe8, 0x1b, 0x70, 0xca, 0x53, 0x2b, 0x76, 0x02, 0x37, 0x74, 0x89, 0x0f, 0x76, 0x97, 0xb8,
0x9f, 0x4e, 0xaf, 0x9b, 0x56, 0xff, 0x02, 0x9d, 0x43, 0x9b, 0x98, 0x8d, 0xd1, 0x0a, 0xed, 0xa5,
0x51, 0xae, 0x96, 0xb7, 0xc9, 0x40, 0x9f, 0x41, 0x75, 0x7c, 0xce, 0x04, 0x6e, 0x6a, 0x12, 0xa7,
0xbb, 0xee, 0xbd, 0x1e, 0xeb, 0x7e, 0x0a, 0xcf, 0xb4, 0x57, 0x11, 0x2a, 0xd7, 0xfd, 0xb0, 0xad,
0xf9, 0x1c, 0x4e, 0x36, 0x89, 0x3f, 0x30, 0x21, 0xc8, 0x82, 0x09, 0x8f, 0x91, 0x43, 0xb3, 0xbf,
0x82, 0xe7, 0x2a, 0x7b, 0x42, 0x25, 0x5f, 0x73, 0x59, 0x4c, 0x59, 0x2c, 0x59, 0xb6, 0x27, 0x7f,
0x00, 0x36, 0x0f, 0x8c, 0xbc, 0x8e, 0xa7, 0x7e, 0xdd, 0x4b, 0xb3, 0xf9, 0xdb, 0x15, 0x26, 0x94,
0xb2, 0x54, 0xb2, 0xc3, 0xab, 0x7c, 0x6d, 0x86, 0x7c, 0xbb, 0xca, 0x25, 0x17, 0x11, 0x17, 0xe2,
0xf0, 0x32, 0x17, 0xbd, 0x5f, 0xba, 0xe3, 0x8f, 0xce, 0x37, 0x7a, 0xcf, 0x5b, 0xfa, 0xef, 0x93,
0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x59, 0x97, 0x1e, 0x7c, 0xa4, 0x08, 0x00, 0x00,
}

15
protocol/protobuf/pairing.proto
View File

@ -90,3 +90,18 @@ message SyncChatMessagesRead {
uint64 clock = 1;
string id = 2;
}
message SyncActivityCenterRead {
uint64 clock = 1;
repeated bytes ids = 2;
}
message SyncActivityCenterAccepted {
uint64 clock = 1;
repeated bytes ids = 2;
}
message SyncActivityCenterDismissed {
uint64 clock = 1;
repeated bytes ids = 2;
}

6
protocol/v1/status_message.go
View File

@ -257,6 +257,12 @@ func (m *StatusMessage) HandleApplication() error {
return m.unmarshalProtobufData(new(protobuf.SyncChatMessagesRead))
case protobuf.ApplicationMetadataMessage_BACKUP:
return m.unmarshalProtobufData(new(protobuf.Backup))
case protobuf.ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_READ:
return m.unmarshalProtobufData(new(protobuf.SyncActivityCenterRead))
case protobuf.ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_ACCEPTED:
return m.unmarshalProtobufData(new(protobuf.SyncActivityCenterAccepted))
case protobuf.ApplicationMetadataMessage_SYNC_ACTIVITY_CENTER_DISMISSED:
return m.unmarshalProtobufData(new(protobuf.SyncActivityCenterDismissed))
}
return nil
}

26
services/ext/api.go
View File

@ -871,32 +871,34 @@ func (api *PublicAPI) UnreadActivityCenterNotificationsCount() (uint64, error) {
return api.service.messenger.UnreadActivityCenterNotificationsCount()
}
func (api *PublicAPI) MarkAllActivityCenterNotificationsRead() error {
return api.service.messenger.MarkAllActivityCenterNotificationsRead()
func (api *PublicAPI) MarkAllActivityCenterNotificationsRead(ctx context.Context) error {
return api.service.messenger.MarkAllActivityCenterNotificationsRead(ctx)
}
func (api *PublicAPI) MarkActivityCenterNotificationsRead(ids []types.HexBytes) error {
return api.service.messenger.MarkActivityCenterNotificationsRead(ids)
func (api *PublicAPI) MarkActivityCenterNotificationsRead(ctx context.Context, ids []types.HexBytes) error {
_, err := api.service.messenger.MarkActivityCenterNotificationsRead(ctx, ids, true)
return err
}
func (api *PublicAPI) MarkActivityCenterNotificationsUnread(ids []types.HexBytes) error {
return api.service.messenger.MarkActivityCenterNotificationsUnread(ids)
}
func (api *PublicAPI) AcceptAllActivityCenterNotifications() (*protocol.MessengerResponse, error) {
return api.service.messenger.AcceptAllActivityCenterNotifications()
func (api *PublicAPI) AcceptAllActivityCenterNotifications(ctx context.Context) (*protocol.MessengerResponse, error) {
return api.service.messenger.AcceptAllActivityCenterNotifications(ctx)
}
func (api *PublicAPI) AcceptActivityCenterNotifications(ids []types.HexBytes) (*protocol.MessengerResponse, error) {
return api.service.messenger.AcceptActivityCenterNotifications(ids)
func (api *PublicAPI) AcceptActivityCenterNotifications(ctx context.Context, ids []types.HexBytes) (*protocol.MessengerResponse, error) {
return api.service.messenger.AcceptActivityCenterNotifications(ctx, ids, true)
}
func (api *PublicAPI) DismissAllActivityCenterNotifications() error {
return api.service.messenger.DismissAllActivityCenterNotifications()
func (api *PublicAPI) DismissAllActivityCenterNotifications(ctx context.Context) error {
return api.service.messenger.DismissAllActivityCenterNotifications(ctx)
}
func (api *PublicAPI) DismissActivityCenterNotifications(ids []types.HexBytes) error {
return api.service.messenger.DismissActivityCenterNotifications(ids)
func (api *PublicAPI) DismissActivityCenterNotifications(ctx context.Context, ids []types.HexBytes) error {
_, err := api.service.messenger.DismissActivityCenterNotifications(ctx, ids, true)
return err
}
func (api *PublicAPI) ActivityCenterNotifications(cursor string, limit uint64) (*protocol.ActivityCenterPaginationResponse, error) {