non-functional.js

const pgp = require("pg-promise")({});
const cn = 'postgres://postgres:postgres@localhost:5432/moonbeans';
const db = pgp(cn);
const fs = require("fs").promises;
const Web3 = require("web3");

const provider = new Web3.providers.WebsocketProvider("wss://moonriver.api.onfinality.io/public-ws", {
        clientConfig: {
            maxReceivedFrameSize: 100000000,
            maxReceivedMessageSize: 100000000,
            keepalive: true,
            keepaliveInterval: -1
        },
    
        reconnect: {
            auto: true,
            delay: 50000000,
            maxAttempts: 5,
            onTimeout: true
        },
    
        timeout: 30000000
    })
    const web3 = new Web3(provider);

async function main() {
    let mnbeansAsks = [];
    const collections = JSON.parse(await fs.readFile('./collections.json'));
    let collectionAddresses = {};

    for (let [key, val] of Object.entries(collections)) {
        collectionAddresses[val['contractAddress']] = val['title'];
    }

    let oldAsks = [];
    mnbeansAsks = await db.manyOrNone('SELECT "tokenId", "collectionId", "timestamp", "tokenNumber", "transactionHash" FROM "asks"');
    console.log("Listed tokens: ", mnbeansAsks.length)
    if (mnbeansAsks.length > 0) {
        console.log("Processing token list..");
        try {
            while (mnbeansAsks.length > 0) {
                ask = mnbeansAsks[0];
                if (!(ask['collectionId'] in collectionAddresses)) {
                    mnbeansAsks.shift();
                    continue;
                }

                let holder = await db.oneOrNone('SELECT "currentOwner", "lastTransfer" FROM "holders" WHERE "id" = $1', [ask['tokenId']]);
                if (holder === null) {
                    console.log("Skipping", ask['tokenId']);
                    mnbeansAsks.shift();
                    continue;
                }

                if (ask['timestamp'] < holder['lastTransfer']) {
                    let tx = await web3.eth.getTransaction(ask['transactionHash']);

                    if (tx['from'] != holder['currentOwner']) {
                        oldAsks.push(Object.assign({}, ask, holder));
                    }
                }

                mnbeansAsks.shift();
            }
        } catch (e) {
            console.log(e);
            console.log("Retrying...");
            await sleep(120000);
        }
    }

    console.log("Token Transfers after their listing: ", oldAsks.length);

    let oldContracts = {};
    let tokenIds = [];
    for (let oldAsk of oldAsks) {
        if (!(oldAsk['collectionId'] in oldContracts)) {
            oldContracts[oldAsk['collectionId']] = {
                title: collectionAddresses[oldAsk['collectionId']],
                count: 0,
                entities: []
            }
        }

        oldContracts[oldAsk['collectionId']]['count']++;
        oldContracts[oldAsk['collectionId']]['entities'].push(oldAsk['tokenNumber']);
        tokenIds.push(oldAsk['tokenId']);
    }

    console.log(oldContracts);

    if (tokenIds.length) {
        console.log(`DELETE FROM "asks" WHERE "tokenId" IN ('${tokenIds.join("','")}');`);
        console.log(`UPDATE "tokens" SET "currentAsk" = 0 WHERE "id" IN ('${tokenIds.join("','")}');`);
        for (let collectionId in oldContracts) {
            console.log(`UPDATE "collections" SET "ceilingPrice" = (SELECT MAX("value") FROM "asks" WHERE "collectionId" = '${collectionId}'), "floorPrice" = (SELECT MIN("value") FROM "asks" WHERE "collectionId" = '${collectionId}') WHERE "id" = '${collectionId}';`);
        }
    }   
}

function sleep(ms) {
    return new Promise((resolve) => {
        setTimeout(resolve, ms);
    });
}

main().then((e => {
    console.log('Done'); 
    process.exit()
}))