feat(dao): OwnersByCollection

api/marketplace/v1/marketplace.proto

@@ -17,6 +17,7 @@ service MarketplaceService {
   rpc DAppsGroups(DAppsGroupsRequest) returns (DAppsGroupsResponse);
   rpc SearchNames(SearchNamesRequest) returns (SearchNamesResponse);
   rpc SearchCollections(SearchCollectionsRequest) returns (SearchCollectionsResponse);
+  rpc OwnersByCollection(OwnersByCollectionRequest) returns (OwnersByCollectionResponse);
 }
 
 enum Sort {
@@ -310,3 +311,11 @@ message SearchCollectionsRequest {
 message SearchCollectionsResponse {
   repeated Collection collections = 1;
 }
+
+message OwnersByCollectionRequest {
+  string collection_id = 1;
+}
+
+message OwnersByCollectionResponse {
+  repeated string owners = 1;
+}

go/pkg/marketplace/marketplace_service.go

@@ -1056,3 +1056,34 @@ func (s *MarkteplaceService) SearchCollections(ctx context.Context, req *marketp
 	}
 	return &marketplacepb.SearchCollectionsResponse{Collections: pbCollections}, nil
 }
+
+func (s *MarkteplaceService) OwnersByCollection(ctx context.Context, req *marketplacepb.OwnersByCollectionRequest) (*marketplacepb.OwnersByCollectionResponse, error) {
+
+	collectionId := req.CollectionId
+
+	type Owners struct {
+		Owner string
+	}
+	var owners []Owners
+
+	_ = s.conf.IndexerDB.Raw(`
+            select nfts.id, max(a.time) atime, COALESCE(m.buyer_id, t.buyer_id, tn.receiver) as owner
+            from nfts
+            join activities a on nfts.id = a.nft_id
+            left join mints m on a.id = m.activity_id
+            left join trades t on a.id = t.activity_id
+            left join transfer_nfts tn on a.id = tn.activity_id
+            where collection_id  = ? and a.kind in ('mint', 'trade','transfer-nft') and a.kind != 'burn'
+            group by nfts.id, m.buyer_id, t.buyer_id, tn.receiver
+            order by atime desc`, collectionId).Scan(
+		&owners,
+	).Error
+
+	var out []string
+	for _, owner := range owners {
+		out = append(out, owner.Owner)
+	}
+
+	return &marketplacepb.OwnersByCollectionResponse{Owners: out}, nil
+
+}