Function handler

FirebaseScripts/scripts/read_events.ts:44–127

()

// Initialize Firebase

async function handler() {
    const provider = new ethers.providers.AlchemyProvider("mainnet", "-HC6HC2R9crhQe3tcu4h4Qq2nYfCRc9t");
    const RfB = RockafellerBotL1__factory.connect(L1_CONTRACT_ADDR, provider);
    const url = "https://min-api.cryptocompare.com/data/price?fsym=WETH&tsyms=USDC";

    const apiCall = await axios({
        method:'get',
        url
    })
    const exchangeRate = new BigFloat(apiCall.data.USDC);

    const app = initializeApp(firebaseConfig);
    const db = getFirestore(app);
    var promises: Array<Promise<any>> = new Array<Promise<any>>()

    //get rocky trades
    {
        console.log("getting trades!");
        const trades = await RfB.queryFilter(RfB.filters.executedTrade());
        const tradeDocuments: [RockyTradesDocument, Date][]  = await Promise.all(trades.map(async (trade) => {

            var amountToken = new BigFloat(trade.args.amount.toString())
            if(trade.args.instruction == 0) var amountUSD = amountToken.div(10**6);
            else var amountUSD = amountToken.div(new BigFloat(10).pow(18)).mul(exchangeRate);

            var blockTimestamp = new Date((await trade.getBlock()).timestamp*1000);
            return [{
                action_type: trade.args.instruction == 0 ? "BUY" : "SELL",
                amount: amountUSD.toString(),
                timestamp: new Timestamp(Math.ceil(blockTimestamp.getTime()/1000), 0) as Timestamp_Fake
            }, blockTimestamp]
        }));
        console.log("writing trades!");
        tradeDocuments.forEach((tradeDocument) => {
            promises.push(db.collection("rocky_trades").doc(tradeDocument[1].getTime().toString()).set(tradeDocument[0]));
        });
        console.log("done with trades");
    }

    //get rocky donations
    {
        console.log("getting donations!");
        const donations = await RfB.queryFilter(RfB.filters.receivedFunds());
        const donationDocuments: [RockyDonationsDocument, Date][] = await Promise.all(donations.map(async (trade) => {
            var ens = await provider.lookupAddress(trade.args.sender);
            var blockTimestamp = new Date((await trade.getBlock()).timestamp*1000);
            return [{
                amount: trade.args.amount.toString(),
                contributor_address: ens ?? trade.args.sender,
                timestamp: new Timestamp(Math.ceil(blockTimestamp.getTime()/1000), 0) as Timestamp_Fake,
                token: trade.args.tokenType == 0 ? "USDC" : "WETH"
            }, blockTimestamp]
        }));
        console.log("writing donations!");
        console.log(donationDocuments.length);
        donationDocuments.forEach((donationDocument) => {
            promises.push(db.collection("rocky_donations").doc(donationDocument[1].getTime().toString()).set(donationDocument[0]));
        });