Merge pull request #143 from s7techlab/16719-peer-endpoint-for-fetcher

peer endpoint for fetcher

observer/channel_peer.go

@@ -42,11 +42,13 @@ type (
 	}
 
 	PeerChannelsFetcher interface {
+		Uri() string
 		api.ChannelListGetter
 		api.ChainInfoGetter
 	}
 
 	PeerChannels interface {
+		Uri() string
 		Channels() map[string]*ChannelInfo
 	}
 
@@ -135,6 +137,10 @@ func (cp *ChannelPeer) Observe(ctx context.Context) {
 	}()
 }
 
+func (cp *ChannelPeer) Uri() string {
+	return cp.channelFetcher.Uri()
+}
+
 func (cp *ChannelPeer) Channels() map[string]*ChannelInfo {
 	cp.mu.Lock()
 	defer cp.mu.Unlock()

observer/channel_peer_fetcher_mock.go

@@ -18,6 +18,10 @@ func NewChannelPeerFetcherMock(channels map[string]uint64) *ChannelPeerFetcherMo
 	}
 }
 
+func (c *ChannelPeerFetcherMock) Uri() string {
+	return "mock"
+}
+
 func (c *ChannelPeerFetcherMock) GetChannels(context.Context) (*peer.ChannelQueryResponse, error) {
 	var channels []*peer.ChannelInfo
 	for channelName := range c.channels {

observer/channel_peer_mock.go

@@ -9,6 +9,10 @@ type ChannelPeerMock struct {
 	channelsInfo map[string]*ChannelInfo
 }
 
+func (m *ChannelPeerMock) Uri() string {
+	return "mock"
+}
+
 func NewChannelPeerMock(channelsInfo ...*ChannelInfo) *ChannelPeerMock {
 	channels := make(map[string]*ChannelInfo, len(channelsInfo))
 	for _, channelInfo := range channelsInfo {