passing no evaluation criteria checker i.e. always return true

itzmeanjan · Mar 9, 2021 · bc95d51 · bc95d51
1 parent 3484e22
commit bc95d51
Showing 1 changed file with 25 additions and 4 deletions.
diff --git a/app/graph/schema.resolvers.go b/app/graph/schema.resolvers.go
@@ -6,6 +6,7 @@ package graph
 import (
 	"context"
 	"errors"
+	"fmt"
 
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/itzmeanjan/harmony/app/config"
@@ -146,7 +147,8 @@ func (r *subscriptionResolver) NewPendingTx(ctx context.Context) (<-chan *model.
 
 	comm := make(chan *model.MemPoolTx, 1)
 
-	go ListenToMessages(ctx, _pubsub, config.GetPendingTxEntryPublishTopic(), comm)
+	// Because client wants to listen to any tx being published on this topic
+	go ListenToMessages(ctx, _pubsub, config.GetPendingTxEntryPublishTopic(), NoEvaluationCriteria, comm)
 
 	return comm, nil
 
@@ -161,7 +163,8 @@ func (r *subscriptionResolver) NewQueuedTx(ctx context.Context) (<-chan *model.M
 
 	comm := make(chan *model.MemPoolTx, 1)
 
-	go ListenToMessages(ctx, _pubsub, config.GetQueuedTxEntryPublishTopic(), comm)
+	// Because client wants to listen to any tx being published on this topic
+	go ListenToMessages(ctx, _pubsub, config.GetQueuedTxEntryPublishTopic(), NoEvaluationCriteria, comm)
 
 	return comm, nil
 
@@ -176,7 +179,8 @@ func (r *subscriptionResolver) NewConfirmedTx(ctx context.Context) (<-chan *mode
 
 	comm := make(chan *model.MemPoolTx, 1)
 
-	go ListenToMessages(ctx, _pubsub, config.GetPendingTxExitPublishTopic(), comm)
+	// Because client wants to listen to any tx being published on this topic
+	go ListenToMessages(ctx, _pubsub, config.GetPendingTxExitPublishTopic(), NoEvaluationCriteria, comm)
 
 	return comm, nil
 
@@ -191,12 +195,29 @@ func (r *subscriptionResolver) NewUnstuckTx(ctx context.Context) (<-chan *model.
 
 	comm := make(chan *model.MemPoolTx, 1)
 
-	go ListenToMessages(ctx, _pubsub, config.GetQueuedTxExitPublishTopic(), comm)
+	// Because client wants to listen to any tx being published on this topic
+	go ListenToMessages(ctx, _pubsub, config.GetQueuedTxExitPublishTopic(), NoEvaluationCriteria, comm)
 
 	return comm, nil
 
 }
 
+func (r *subscriptionResolver) NewPendingTxFrom(ctx context.Context, address string) (<-chan *model.MemPoolTx, error) {
+	panic(fmt.Errorf("not implemented"))
+}
+
+func (r *subscriptionResolver) NewQueuedTxFrom(ctx context.Context, address string) (<-chan *model.MemPoolTx, error) {
+	panic(fmt.Errorf("not implemented"))
+}
+
+func (r *subscriptionResolver) NewConfirmedTxFrom(ctx context.Context, address string) (<-chan *model.MemPoolTx, error) {
+	panic(fmt.Errorf("not implemented"))
+}
+
+func (r *subscriptionResolver) NewUnstuckTxFrom(ctx context.Context, address string) (<-chan *model.MemPoolTx, error) {
+	panic(fmt.Errorf("not implemented"))
+}
+
 // Query returns generated.QueryResolver implementation.
 func (r *Resolver) Query() generated.QueryResolver { return &queryResolver{r} }