address feedback

smartcontractkit · Feb 6, 2025 · 25c59c9 · 25c59c9
1 parent 0a862d4
commit 25c59c9
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 12 deletions.
diff --git a/pkg/solana/chainreader/batch.go b/pkg/solana/chainreader/batch.go
@@ -51,7 +51,7 @@ func doMethodBatchCall(ctx context.Context, client MultipleAccountGetter, bindin
 			return nil, fmt.Errorf("failed to get address for %s account read: %w", call.ReadName, err)
 		}
 
-		lvBinding, ok := binding.(latestValueBinding)
+		eBinding, ok := binding.(eventBinding)
 		if ok {
 			results[idx] = batchResultWithErr{
 				address:      key.String(),
@@ -60,8 +60,7 @@ func doMethodBatchCall(ctx context.Context, client MultipleAccountGetter, bindin
 				returnVal:    call.ReturnVal,
 			}
 
-			// is an event read
-			results[idx].err = lvBinding.GetLatestValue(ctx, call.Params, results[idx].returnVal)
+			results[idx].err = eBinding.GetLatestValue(ctx, call.Params, results[idx].returnVal)
 
 			continue
 		}

diff --git a/pkg/solana/chainreader/bindings.go b/pkg/solana/chainreader/bindings.go
@@ -20,11 +20,8 @@ type readBinding interface {
 	Decode(context.Context, []byte, any) error
 }
 
-type latestValueBinding interface {
+type eventBinding interface {
 	GetLatestValue(_ context.Context, params, returnVal any) error
-}
-
-type queryBinding interface {
 	QueryKey(context.Context, query.KeyFilter, query.LimitAndSort, any) ([]types.Sequence, error)
 }
 

diff --git a/pkg/solana/chainreader/chain_reader.go b/pkg/solana/chainreader/chain_reader.go
@@ -223,22 +223,22 @@ func (s *ContractReaderService) QueryKey(ctx context.Context, contract types.Bou
 		return nil, err
 	}
 
-	qBinding, ok := binding.(queryBinding)
+	eBinding, ok := binding.(eventBinding)
 	if !ok {
 		return nil, fmt.Errorf("%w: invalid binding type for %s", types.ErrInvalidType, contract.Name)
 	}
 
 	_, isValuePtr := sequenceDataType.(*values.Value)
 	if !isValuePtr {
-		return qBinding.QueryKey(ctx, filter, limitAndSort, sequenceDataType)
+		return eBinding.QueryKey(ctx, filter, limitAndSort, sequenceDataType)
 	}
 
 	dataTypeFromReadIdentifier, err := s.CreateContractType(contract.ReadIdentifier(filter.Key), false)
 	if err != nil {
 		return nil, err
 	}
 
-	sequence, err := qBinding.QueryKey(ctx, filter, limitAndSort, dataTypeFromReadIdentifier)
+	sequence, err := eBinding.QueryKey(ctx, filter, limitAndSort, dataTypeFromReadIdentifier)
 	if err != nil {
 		return nil, err
 	}

diff --git a/pkg/solana/chainreader/event_read_binding.go b/pkg/solana/chainreader/event_read_binding.go
@@ -174,13 +174,13 @@ func (b *eventReadBinding) normalizeParams(value any, itemType string) (any, err
 	return offChain, nil
 }
 
-func (b *eventReadBinding) extractFilterSubkeys(offChainValue any) (query.Expression, error) {
+func (b *eventReadBinding) extractFilterSubkeys(offChainParams any) (query.Expression, error) {
 	var expressions []query.Expression
 
 	for offChainKey, idx := range b.indexedSubKeys {
 		itemType := codec.WrapItemType(true, b.namespace, b.genericName+"."+offChainKey)
 
-		onChainValue, err := b.modifier.TransformToOnChain(offChainValue, itemType)
+		onChainValue, err := b.modifier.TransformToOnChain(offChainParams, itemType)
 		if err != nil {
 			return query.Expression{}, fmt.Errorf("%w: failed to apply on-chain transformation for key %s", types.ErrInternal, offChainKey)
 		}