community-repo/scripts/validator-report-backend/src/block_range_import.ts

import { addBlockRange, processNext } from './joystream';
import { connectUpstream } from './joystream/ws';
import {findLastProcessedBlockId} from './db/models/block'
import {
    StartBlock
} from './db/models'

async function main () {

    const api = await connectUpstream();

    const firstBlock:number = parseInt(process.env.START_BLOCK);
    const lastBlock:number = parseInt(process.env.END_BLOCK) ||  (await StartBlock.findAll())[0].get({plain: true}).block - 1;

    console.log(`[Joystream] Importing block range [${firstBlock} - ${lastBlock}] started`);
    
    const lastImportedBlockHeight = await findLastProcessedBlockId(firstBlock, lastBlock);
    if (lastImportedBlockHeight && lastImportedBlockHeight > 0 && lastImportedBlockHeight < lastBlock) {
        console.log(`[Joystream] Found last imported block ${lastImportedBlockHeight}. Resuming processing from the next one`);
        await addBlockRange(api, lastImportedBlockHeight + 1, lastBlock);
    } else {
        await addBlockRange(api, firstBlock, lastBlock);
    }
    
    processNext();
}  

main()