feat: Add transaction message filter in GraphQL

go.mod

@@ -24,6 +24,7 @@ require (
  github.com/beorn7/perks v1.0.1 // indirect
  github.com/cespare/xxhash v1.1.0 // indirect
  github.com/cespare/xxhash/v2 v2.2.0 // indirect
+ github.com/cockroachdb/apd/v3 v3.2.1 // indirect
  github.com/cockroachdb/errors v1.11.1 // indirect
  github.com/cockroachdb/logtags v0.0.0-20230118201751-21c54148d20b // indirect
  github.com/cockroachdb/redact v1.1.5 // indirect

go.sum

@@ -51,6 +51,8 @@ github.com/cespare/xxhash/v2 v2.1.1/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XL
 github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
 github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
 github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
+github.com/cockroachdb/apd/v3 v3.2.1 h1:U+8j7t0axsIgvQUqthuNm82HIrYXodOV2iWLWtEaIwg=
+github.com/cockroachdb/apd/v3 v3.2.1/go.mod h1:klXJcjp+FffLTHlhIG69tezTDvdP065naDsHzKhYSqc=
 github.com/cockroachdb/datadriven v1.0.3-0.20230413201302-be42291fc80f h1:otljaYPt5hWxV3MUfO5dFPFiOXg9CyG5/kCfayTqsJ4=
 github.com/cockroachdb/datadriven v1.0.3-0.20230413201302-be42291fc80f/go.mod h1:a9RdTaap04u637JoCzcUoIcDmvwSUtcUFtT/C3kJlTU=
 github.com/cockroachdb/errors v1.11.1 h1:xSEW75zKaKCWzR3OfxXUxgrk/NtT4G1MiOv5lWZazG8=
@@ -178,6 +180,8 @@ github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
+github.com/lib/pq v1.10.7 h1:p7ZhMD+KsSRozJr34udlUrhboJwWAgCg34+/ZZNvZZw=
+github.com/lib/pq v1.10.7/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
 github.com/libp2p/go-buffer-pool v0.1.0 h1:oK4mSFcQz7cTQIfqbe4MIj9gLW+mnanjyFtc6cdF0Y8=
 github.com/libp2p/go-buffer-pool v0.1.0/go.mod h1:N+vh8gMqimBzdKkSMVuydVDq+UV5QTWy5HSiZacSbPg=
 github.com/linxGnu/grocksdb v1.8.5 h1:Okfk5B1h0ikCYdDM7Tc5yJUS8LTwAmMBq5IPWTmOLPs=

gqlgen.yml

@@ -1,6 +1,7 @@
 # Where are all the schema files located? globs are supported eg src/**/*.graphql
 schema:
- - serve/graph/*.graphql
+ - serve/graph/schema/*.graphql
+ - serve/graph/schema/**/*.graphql
 
 # Where should the generated server code go?
 exec:
@@ -85,4 +86,7 @@ models:
  - github.com/gnolang/tx-indexer/serve/graph/model.Block
  Transaction:
  model:
- - github.com/gnolang/tx-indexer/serve/graph/model.Transaction
+ - github.com/gnolang/tx-indexer/serve/graph/model.Transaction
+ TransactionMessage:
+ model:
+ - github.com/gnolang/tx-indexer/serve/graph/model.TransactionMessage

serve/graph/block_filter.go

@@ -0,0 +1,31 @@
+package graph
+
+import (
+ "time"
+
+ "github.com/gnolang/tx-indexer/serve/graph/model"
+)
+
+// `FilteredBlockBy` checks for conditions in BlockTime.
+// By default, the condition is only checked if the input parameter exists.
+func FilteredBlockBy(block *model.Block, filter model.BlockFilter) bool {
+ if block == nil {
+ return false
+ }
+
+ return filteredBlockByBlockTime(block, filter.FromTime, filter.ToTime)
+}
+
+// `filteredBlockByBlockTime` checks block based on block time.
+func filteredBlockByBlockTime(block *model.Block, filterFromTime, filterToTime *time.Time) bool {
+ fromTime := deref(filterFromTime)
+ toTime := deref(filterToTime)
+
+ if filterToTime == nil {
+ toTime = time.Now()
+ }
+
+ blockTime := block.Time()
+
+ return (blockTime.After(fromTime) || blockTime.Equal(fromTime)) && (toTime.IsZero() || blockTime.Before(toTime))
+}