deal with unfinalized blocks

[shunjizhan]

deal with unfinalized blocks

[xlc]

Something like this. This allow constant time add and purge block data and usually identify tx data in 1 or 2 lookup.

interface BlockData {
  blockNumber: number
  block: Block
}

interface BucketData {
  bucket: number
  blocks: BlockData[]
  transactions: Record<string, Tranasction> // txhash => tx
}

const BUCKET_SIZE = 5

export class UnfinalizedBlockCache {
  buckets: BucketData[] = []
  txpool: Record<string, Tranasction> = {}

  addBlock(block: Block) {
    const bucket = Math.floor(block.number / BUCKET_SIZE)
    const startBucket = this.buckets[0]?.bucket
    const idx = bucket - startBucket
    this.buckets[idx] = this.buckets[idx] ?? { bucket, blocks: [], transactions: {} }
    const bucketData = {
     bucket
     // other fields
    }
    this.buckets[idx].blocks[block.number % BUCKET_SIZE] = bucketData
    // update this.buckets[idx].transactions
  }

  updateFinalizedHead(blockNumber: number) {
    const bucket = Math.floor(blockNumber / BUCKET_SIZE)
    const startBucket = this.buckets[0]?.bucket
    if (startBucket != null && bucket > startBucket) {
      const idx = bucket - startBucket
      this.buckets.splice(0, idx + 1) // make sure this can handle holes
    }
  }

  queryTransactionByHash(hash: string) {
    for (const i = this.buckets.length - 1; i >= 0; --i ) {
      const bucketData = this.buckets[i]  // search from latest bucket
      const tx = bucketData.transactions[hash]
      if (tx) {
        return tx
      }
    }
    if (this.txpool[hash]) {
      return this.txpool[hash]
    }
    // not found
    // update txpool and search it again
  }
}

function createUnfinalizedBlockCache(api: ApiPromise) {
  const cache = new UnfinalizedBlockCache()
  let lastProcessedBlock = undefined

  // subscribe to new head
  // retry on error
    // while lastProcessedBlock !== undefiled && lastProcessedBlock < latestBlockNumber
      // let block = getBlock(lastProcessedBlock + 1)
      // cache.addBlock(block)
      // lastProcessedBlock = block.number

  // subscribe to finalized haed
  // retry on error
    // lastProcessedBlock = max(lastProcessedBlock, blockNumber)
    // cache.updateFinalizedHead(blockNumber)
  return cache
}

[shunjizhan]

closes with #131