CCIP-1288 LogPoller - Ability to pass custom search queries

[mateusz-sekara]

Adding the ability to create custom read queries in LogPoller. It's the 2nd part of improvements to LogPoller, which CCIP requires. TestSelectAny contains an example query we will use in CCIP to speed up execution and reduce the number of records fetched from the database.

[github-actions]

I see that you haven't updated any CHANGELOG files. Would it make sense to do so?

[mateusz-sekara]

As a next step, I want to cache lastBlock in the memory. This would simplify queries to sth like this

	args := logpoller.NewQueryArgs().
		WithNamedHash("commit_store_addr", commitStore).
		WithNamedHash("commit_store_event", commitStoreEvent).
		WithNamedHash("offramp_addr", offramp).
		WithNamedHash("offramp_event", offrampEvent).
		WithNamedArg("after", time.Now().Add(-time.Hour)).
		WithConfs("confirmed_at_block", confs)

	query := `
		SELECT reports.* FROM evm.logs reports
		    WHERE reports.evm_chain_id = :evm_chain_id 
			AND reports.address = :commit_store_addr
			AND reports.event_sig = :commit_store_event
			AND reports.block_timestamp > :after
			AND reports.block_number > :confirmed_at_block
	`

	logs, err := th.ORM.SelectAnyLogs("ccipUnexpiredRoots", query, *args)

WithConf will pick the proper value from cache:

if confs == Finalized {
    return cache.latest_finalized_block
} else {
   return cache.last_block - confs
}

[cl-sonarqube-production]

SonarQube Quality Gate

0 Bugs
0 Vulnerabilities
0 Security Hotspots
0 Code Smells

82.9% Coverage
0.0% Duplication