send wallet events for watch only accounts

Author: jrainville

services/wallet/localbackup/service.go

@@ -1,13 +1,17 @@
 package localbackup
 
 import (
+	"encoding/json"
 	"errors"
 
+	"github.com/ethereum/go-ethereum/event"
 	"github.com/golang/protobuf/proto"
 	"github.com/status-im/status-go/eth-node/types"
 	"github.com/status-im/status-go/multiaccounts/accounts"
 	multiaccountscommon "github.com/status-im/status-go/multiaccounts/common"
 	"github.com/status-im/status-go/protocol/protobuf"
+	"github.com/status-im/status-go/protocol/wakusync"
+	"github.com/status-im/status-go/services/wallet/walletevent"
 )
 
 // TODO this is duplicated
@@ -16,14 +20,20 @@ var (
 	ErrTryingToStoreOldWalletAccount = errors.New("trying to store an old wallet account")
 )
 
+const (
+	EventWatchOnlyAccountRetrieved walletevent.EventType = "wallet-watch-only-account-retrieved"
+)
+
 // Service is a wallet local backup service.
 type Service struct {
 	accountsDB *accounts.Database
+	feed       *event.Feed
 }
 
-func NewService(accountsDB *accounts.Database) *Service {
+func NewService(accountsDB *accounts.Database, feed *event.Feed) *Service {
 	return &Service{
 		accountsDB: accountsDB,
+		feed:       feed,
 	}
 }
 
@@ -138,19 +148,6 @@ func (s *Service) handleSyncWatchOnlyAccount(message *protobuf.SyncAccount) (*ac
 		return nil, err
 	}
 
-	// TODO is this useful?
-	// if m.config.accountsFeed != nil {
-	// 	var eventType accountsevent.EventType
-	// 	if acc.Removed {
-	// 		eventType = accountsevent.EventTypeRemoved
-	// 	} else {
-	// 		eventType = accountsevent.EventTypeAdded
-	// 	}
-	// 	m.config.accountsFeed.Send(accountsevent.Event{
-	// 		Type:     eventType,
-	// 		Accounts: []gethcommon.Address{gethcommon.Address(acc.Address)},
-	// 	})
-	// }
 	return acc, nil
 }
 
@@ -159,18 +156,22 @@ func (s *Service) handleWatchOnlyAccount(message *protobuf.SyncAccount) error {
 		return nil
 	}
 
-	_, err := s.handleSyncWatchOnlyAccount(message)
+	acc, err := s.handleSyncWatchOnlyAccount(message)
 	if err != nil {
 		return err
 	}
-	// TODO send the account trhough a signal?
-	// if m.config.messengerSignalsHandler != nil {
-	// 	response := wakusync.WakuBackedUpDataResponse{
-	// 		WatchOnlyAccount: acc,
-	// 	}
-
-	// 	m.config.messengerSignalsHandler.SendWakuBackedUpWatchOnlyAccount(&response)
-	// }
+	response := wakusync.WakuBackedUpDataResponse{
+		WatchOnlyAccount: acc,
+	}
+	encodedmessage, err := json.Marshal(response)
+	if err != nil {
+		return err
+	}
+	event := walletevent.Event{
+		Type:    EventWatchOnlyAccountRetrieved,
+		Message: string(encodedmessage),
+	}
+	s.feed.Send(event)
 
 	return nil
 }

services/wallet/service.go

@@ -199,7 +199,7 @@ func NewService(
 
 	activity := activity.NewService(db, accountsDB, tokenManager, collectiblesManager, feed)
 
-	localBackup := localbackup.NewService(accountsDB)
+	localBackup := localbackup.NewService(accountsDB, feed)
 
 	router := router.NewRouter(rpcClient, transactor, tokenManager, marketManager, collectibles,
 		collectiblesManager)