chore: node adapters (#7108)

* chore: node adapters

* chore: remove Adapter suffix

Author: igor-sirotin

api/geth_backend.go

@@ -46,6 +46,7 @@ import (
 	multiacccommon "github.com/status-im/status-go/multiaccounts/common"
 	"github.com/status-im/status-go/multiaccounts/settings"
 	"github.com/status-im/status-go/node"
+	"github.com/status-im/status-go/node/adapters"
 	"github.com/status-im/status-go/nodecfg"
 	"github.com/status-im/status-go/params"
 	"github.com/status-im/status-go/pkg/sentry"
@@ -2269,8 +2270,8 @@ func (b *GethStatusBackend) initProtocol() error {
 	b.statusNode.ChatService(accDB).Init(messenger)
 	b.statusNode.EnsService().Init(messenger.SyncEnsNamesWithDispatchMessage)
 	b.statusNode.CommunityTokensService().Init(messenger)
-	b.statusNode.SharedUrlsService().SetDataProvider(node.NewSharedUrlsMessengerAdapter(messenger))
-	b.statusNode.NewsFeedService().SetActivityCenter(node.NewNewsFeedActivityCenterAdapter(messenger))
+	b.statusNode.SharedUrlsService().SetDataProvider(adapters.NewSharedUrlsMessengerAdapter(messenger))
+	b.statusNode.NewsFeedService().SetActivityCenter(adapters.NewNewsFeedActivityCenterAdapter(messenger))
 
 	return nil
 }

node/adapters.go

@@ -0,0 +1,9 @@
+package adapters
+
+import (
+	"errors"
+)
+
+var (
+	ErrMessengerNotReady = errors.New("messenger not ready")
+)

node/adapters/errors.go

@@ -0,0 +1,22 @@
+package adapters
+
+import (
+	"github.com/status-im/status-go/protocol"
+)
+
+type NewsFeedActivityCenter struct {
+	messenger *protocol.Messenger
+}
+
+func NewNewsFeedActivityCenterAdapter(messenger *protocol.Messenger) *NewsFeedActivityCenter {
+	return &NewsFeedActivityCenter{
+		messenger: messenger,
+	}
+}
+
+func (p *NewsFeedActivityCenter) AddNotification(response *protocol.MessengerResponse, notification *protocol.ActivityCenterNotification) error {
+	if p.messenger == nil {
+		return ErrMessengerNotReady
+	}
+	return p.messenger.AddActivityCenterNotification(response, notification, nil)
+}

node/adapters/newsfeed.go

@@ -0,0 +1,35 @@
+package adapters
+
+import (
+	"github.com/status-im/status-go/crypto/types"
+	"github.com/status-im/status-go/protocol"
+	"github.com/status-im/status-go/protocol/communities"
+	"github.com/status-im/status-go/protocol/contacts"
+)
+
+// SharedUrlsMessenger is a wrapper around the messenger to make it compatible with the sharedurls service.
+// This is to `return (contact, error)` in `GetContactByID`, which Messenger didn't do atm.
+// The return error is needed to enable returning errNoDataProvider in NopDataProvider (nil object pattern).
+type SharedUrlsMessenger struct {
+	messenger *protocol.Messenger
+}
+
+func NewSharedUrlsMessengerAdapter(messenger *protocol.Messenger) *SharedUrlsMessenger {
+	return &SharedUrlsMessenger{
+		messenger: messenger,
+	}
+}
+
+func (p *SharedUrlsMessenger) GetCommunityByID(communityID types.HexBytes) (*communities.Community, error) {
+	if p.messenger == nil {
+		return nil, ErrMessengerNotReady
+	}
+	return p.messenger.GetCommunityByID(communityID)
+}
+
+func (p *SharedUrlsMessenger) GetContactByID(pubKey string) (*contacts.Contact, error) {
+	if p.messenger == nil {
+		return nil, ErrMessengerNotReady
+	}
+	return p.messenger.GetContactByID(pubKey), nil
+}

node/adapters/sharedurls.go

@@ -8,6 +8,7 @@ import (
 	"go.uber.org/zap"
 
 	"github.com/status-im/status-go/internal/timesource"
+	"github.com/status-im/status-go/node/adapters"
 	"github.com/status-im/status-go/pkg/featureflags"
 	"github.com/status-im/status-go/pkg/pubsub"
 	"github.com/status-im/status-go/server"
@@ -328,7 +329,7 @@ func (b *StatusNode) sharedUrlsService() *sharedurls.Service {
 	if b.sharedUrlsSrvc == nil {
 		b.sharedUrlsSrvc = sharedurls.NewService(nil)
 		if extService := b.WakuV2ExtService(); extService != nil {
-			provider := NewSharedUrlsMessengerAdapter(extService.Messenger())
+			provider := adapters.NewSharedUrlsMessengerAdapter(extService.Messenger())
 			b.sharedUrlsSrvc.SetDataProvider(provider)
 		}
 	}
@@ -435,7 +436,7 @@ func (b *StatusNode) NewsFeedService() *newsfeed.Service {
 		)
 
 		if wakuext := b.WakuV2ExtService(); wakuext != nil && wakuext.Messenger() != nil {
-			ac := NewNewsFeedActivityCenterAdapter(wakuext.Messenger())
+			ac := adapters.NewNewsFeedActivityCenterAdapter(wakuext.Messenger())
 			b.newsfeedSrvc.SetActivityCenter(ac)
 		}
 	}