This background process should analyze vaas stored on the duplicatedVaas collection mentioned on #1283 and #1300 to check whether the transactions they were emitted from actually made it to the final state of the blockchain.
For new VAAs inserted into the collection that were not yet processed by this worker, retrieve the VAA from the Guardian API and check their digests. If they are the same, then the vaa should be on the main vaas collection instead, so perform the swap (either delete and insert again or replace entirely) and trigger a reprocess through the pipeline; if it's not, then the it should remain on the duplicates collection.
This background process should analyze vaas stored on the
duplicatedVaas
collection mentioned on #1283 and #1300 to check whether the transactions they were emitted from actually made it to the final state of the blockchain.For new VAAs inserted into the collection that were not yet processed by this worker, retrieve the VAA from the Guardian API and check their digests. If they are the same, then the vaa should be on the main
vaas
collection instead, so perform the swap (either delete and insert again or replace entirely) and trigger a reprocess through the pipeline; if it's not, then the it should remain on the duplicates collection.