change event sig type, assigning subkey values to idx, remove unused …

…code

pkg/solana/logpoller/loader.go

@@ -21,15 +21,6 @@ type Block struct {
 	Events     []ProgramEvent
 }
 
-type ProgramEventProcessor interface {
-	// Process should take a ProgramEvent and parseProgramLogs it based on log signature
-	// and expected encoding. Only return errors that cannot be handled and
-	// should exit further transaction processing on the running thread.
-	//
-	// Process should be thread safe.
-	Process(Block) error
-}
-
 type RPCClient interface {
 	GetBlockWithOpts(context.Context, uint64, *rpc.GetBlockOpts) (*rpc.GetBlockResult, error)
 	GetSignaturesForAddressWithOpts(context.Context, solana.PublicKey, *rpc.GetSignaturesForAddressOpts) ([]*rpc.TransactionSignature, error)

pkg/solana/logpoller/log_poller.go

@@ -175,17 +175,23 @@ func (lp *Service) Process(ctx context.Context, programEvent ProgramEvent) (err
 			return err
 		}
 
-		log.SubkeyValues = make([]IndexedValue, 0, len(filter.SubkeyPaths))
-		for _, path := range filter.SubkeyPaths {
+		log.SubkeyValues = make([]IndexedValue, len(filter.SubkeyPaths))
+		for idx, path := range filter.SubkeyPaths {
+			if len(path) == 0 {
+				continue
+			}
+
 			subKeyVal, decodeSubKeyErr := lp.filters.DecodeSubKey(ctx, lp.lggr, log.Data, filter.ID, path)
 			if decodeSubKeyErr != nil {
 				return decodeSubKeyErr
 			}
+
 			indexedVal, newIndexedValErr := newIndexedValue(subKeyVal)
 			if newIndexedValErr != nil {
 				return newIndexedValErr
 			}
-			log.SubkeyValues = append(log.SubkeyValues, indexedVal)
+
+			log.SubkeyValues[idx] = indexedVal
 		}
 
 		log.SequenceNum = lp.filters.IncrementSeqNum(filter.ID)

pkg/solana/logpoller/parser.go

@@ -429,12 +429,16 @@ func (f *addressFilter) Accept(visitor primitives.Visitor) {
 }
 
 type eventSigFilter struct {
-	eventSig []byte
+	eventSig EventSignature
 }
 
 func NewEventSigFilter(sig []byte) query.Expression {
+	var eventSig EventSignature
+
+	copy(eventSig[:], sig[:])
+
 	return query.Expression{
-		Primitive: &eventSigFilter{eventSig: sig},
+		Primitive: &eventSigFilter{eventSig: eventSig},
 	}
 }