Removed codec CreateType

Author: amit-momin

pkg/solana/ccip/chainaccessor/event.go

@@ -224,11 +224,7 @@ func (a *SolanaAccessor) registerFilterIfNotExists(
 // one-to-one mapping of event fields from the Solana format to the standard CCIP format.
 func (a *SolanaAccessor) convertCCIPMessageSent(ctx context.Context, logs []logpollertypes.Log, onrampAddr solana.PublicKey) ([]*chainaccessor.SendRequestedEvent, error) {
 	itemType := codec.WrapItemType(false, consts.ContractNameOnRamp, consts.EventNameCCIPMessageSent)
-	eventType, err := a.codec.CreateType(itemType, false)
-	if err != nil {
-		return nil, fmt.Errorf("failed to create type to decode event into: %w", err)
-	}
-	iter, err := a.decodeLogsIntoSequences(ctx, itemType, logs, &eventType)
+	iter, err := a.decodeLogsIntoSequences(ctx, itemType, logs, &ccip.EventCCIPMessageSent{})
 	if err != nil {
 		return nil, fmt.Errorf("failed to decode logs into sequences: %w", err)
 	}
@@ -241,7 +237,7 @@ func (a *SolanaAccessor) convertCCIPMessageSent(ctx context.Context, logs []logp
 	for i, seq := range iter {
 		event, ok := seq.Data.(*ccip.EventCCIPMessageSent)
 		if !ok {
-			return nil, fmt.Errorf("failed to cast %v to EventCCIPMessageSent", seq.Data)
+			return nil, fmt.Errorf("failed to cast %T to EventCCIPMessageSent", seq.Data)
 		}
 		msg := ccipocr3.Message{
 			Header: ccipocr3.RampMessageHeader{
@@ -325,11 +321,7 @@ func (a *SolanaAccessor) processCommitReports(
 	ctx context.Context, logs []logpollertypes.Log, ts time.Time, limit int,
 ) ([]ccipocr3.CommitPluginReportWithMeta, error) {
 	itemType := codec.WrapItemType(false, consts.ContractNameOffRamp, consts.EventNameCommitReportAccepted)
-	eventType, err := a.codec.CreateType(itemType, false)
-	if err != nil {
-		return nil, fmt.Errorf("failed to create type to decode event into: %w", err)
-	}
-	iter, err := a.decodeLogsIntoSequences(ctx, itemType, logs, &eventType)
+	iter, err := a.decodeLogsIntoSequences(ctx, itemType, logs, &ccip.EventCommitReportAccepted{})
 	if err != nil {
 		return nil, fmt.Errorf("failed to decode logs into sequences: %w", err)
 	}
@@ -382,7 +374,7 @@ func validateCommitReportAcceptedEvent(
 ) (*ccip.EventCommitReportAccepted, error) {
 	ev, is := (seq.Data).(*ccip.EventCommitReportAccepted)
 	if !is {
-		return nil, fmt.Errorf("unexpected type %T while expecting a commit report", seq)
+		return nil, fmt.Errorf("unexpected type %T while expecting EventCommitReportAccepted", seq.Data)
 	}
 
 	if ev == nil {
@@ -551,11 +543,7 @@ func createExecutedMessagesKeyFilter(rangesPerChain map[ccipocr3.ChainSelector][
 
 func (a *SolanaAccessor) processExecutionStateChangesEvents(ctx context.Context, logs []logpollertypes.Log, nonEmptyRangesPerChain map[ccipocr3.ChainSelector][]ccipocr3.SeqNumRange) (map[ccipocr3.ChainSelector][]ccipocr3.SeqNum, error) {
 	itemType := codec.WrapItemType(false, consts.ContractNameOffRamp, consts.EventNameExecutionStateChanged)
-	eventType, err := a.codec.CreateType(itemType, false)
-	if err != nil {
-		return nil, fmt.Errorf("failed to create type to decode event into: %w", err)
-	}
-	iter, err := a.decodeLogsIntoSequences(ctx, itemType, logs, &eventType)
+	iter, err := a.decodeLogsIntoSequences(ctx, itemType, logs, &ccip.EventExecutionStateChanged{})
 	if err != nil {
 		return nil, fmt.Errorf("failed to decode logs into sequences: %w", err)
 	}