Merge pull request #63 from goverland-labs/feature/votes_search

Search for votes.

CHANGELOG.md

@@ -7,6 +7,11 @@ to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
 
+## [0.1.22] - 2024-07-22
+
+### Added
+- Search for votes
+
 ## [0.1.21] - 2024-07-06
 
 ### Changed

internal/vote/filters.go

@@ -52,3 +52,11 @@ type ExcludeVoterFilter struct {
 func (f ExcludeVoterFilter) Apply(db *gorm.DB) *gorm.DB {
 	return db.Where("voter != ?", f.Voter)
 }
+
+type NameFilter struct {
+	Name string
+}
+
+func (f NameFilter) Apply(db *gorm.DB) *gorm.DB {
+	return db.Where("voter = ? or ens_name = ?", f.Name, f.Name)
+}

internal/vote/server.go

@@ -61,6 +61,10 @@ func (s *Server) GetVotes(_ context.Context, req *storagepb.VotesFilterRequest)
 		filters = append(filters, VoterFilter{Voter: req.GetVoter()})
 	}
 
+	if req.GetName() != "" {
+		filters = append(filters, NameFilter{Name: req.GetName()})
+	}
+
 	list, err := s.sp.GetByFilters(filters, limit, offset, req.GetOrderByVoter())
 	if err != nil {
 		log.Error().Err(err).Msgf("get votes by filter: %+v", req)

protocol/storagepb/vote.proto

@@ -18,8 +18,9 @@ message VotesFilterRequest {
   repeated string proposal_ids = 1;
   optional string voter = 2;
   optional string order_by_voter = 3;
-  optional uint64 limit = 4;
-  optional uint64 offset = 5;
+  optional string name = 4;
+  optional uint64 limit = 5;
+  optional uint64 offset = 6;
 }
 
 message VoteInfo {

resources/V9_db_speed_up_votes.sql

@@ -1,2 +1,5 @@
 create index votes_proposal_vp_idx
-    on votes (proposal_id, vp);
+    on votes (proposal_id, vp);
+
+create index votes_proposal_ens_idx
+    on votes (proposal_id, ens_name);