Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Event fetching with infura #7

Merged
merged 2 commits into from
Oct 12, 2023
+114 −69
Merged

Event fetching with infura #7

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
8cb9802
Prettier
0xjocke Oct 5, 2023
067ca57
Make sure to always fetch events with infura
0xjocke Oct 5, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
183 changes: 114 additions & 69 deletions frontend/lib/store/events.js
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,93 +1,138 @@
import { atom, selector, selectorFamily } from "recoil";
import { ethers } from 'ethers'
import erc20Abi from '../../abis/SampleToken.json'
import vesterAbi from '../../abis/Vester.json'
import { ethers } from "ethers";
import erc20Abi from "../../abis/SampleToken.json";
import vesterAbi from "../../abis/Vester.json";

/**** STATE ****/

export const eventsState = atom({
key: 'eventsState',
default: {}
key: "eventsState",
default: {},
});

export const getEvents = selector({
key: 'getEvents',
get: ({ get }) => {
return Object.values(get(eventsState))
key: "getEvents",
get: ({ get }) => {
return Object.values(get(eventsState));
},
set:
() =>
({ get, set }, newValue) => {
set(eventsState, Object.assign({}, get(eventsState), newValue));
},
set: () => ({ get, set }, newValue) => {
set(eventsState, Object.assign({}, get(eventsState), newValue))
}
});

export const getEventsByTokenId = selectorFamily({
key: 'getEventsByTokenId',
get: (tokenId) => ({ get }) => {
return Object.values(get(eventsState)).filter((e) => e.tokenId == tokenId)
key: "getEventsByTokenId",
get:
(tokenId) =>
({ get }) => {
return Object.values(get(eventsState)).filter(
(e) => e.tokenId == tokenId
);
},
set:
() =>
({ get, set }, newValue) => {
set(eventsState, Object.assign({}, get(eventsState), newValue));
},
set: () => ({ get, set }, newValue) => {
set(eventsState, Object.assign({}, get(eventsState), newValue))
}
});


const networkIdToName = {
1: "mainnet",
10: "optimism-mainnet",
};
/**** ACTIONS ****/

export const fetchEvents = async (setEvents) => {
const provider = new ethers.providers.Web3Provider(window?.ethereum)
const vesterContract = new ethers.Contract(process.env.NEXT_PUBLIC_VESTER_CONTRACT_ADDRESS, vesterAbi.abi, provider); // should be provider.getSigner() ?
const networkId = window.ethereum.networkVersion;
const infuraName = networkIdToName[networkId];
if (!infuraName) {
console.error(`Invalid network id ${networkId}, check events.js`);
throw Error("Invalid network id:" + networkId);
}
// Always use infura for fetching events, provider from wallet can be really slow
const provider = new ethers.providers.JsonRpcProvider(
`https://${networkIdToName}.infura.io/v3/8c6bfe963db94518b16b17114e29e628`
);

let newEvents = {}
const vesterContract = new ethers.Contract(
process.env.NEXT_PUBLIC_VESTER_CONTRACT_ADDRESS,
vesterAbi.abi,
provider
); // should be provider.getSigner() ?

// TODO: Make below more abstract, just gather all events
const redemptionsFilter = vesterContract.filters.Redemption();
const redemptionsEvents = await vesterContract.queryFilter(redemptionsFilter, 0, "latest");
for (const log of redemptionsEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Redemption",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args
}
}
let newEvents = {};
// TODO: Make below more abstract, just gather all events
const redemptionsFilter = vesterContract.filters.Redemption();
const redemptionsEvents = await vesterContract.queryFilter(
redemptionsFilter,
0,
"latest"
);
for (const log of redemptionsEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Redemption",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args,
};
}

const grantCreatedFilter = vesterContract.filters.GrantCreated();
const grantCreatedEvents = await vesterContract.queryFilter(grantCreatedFilter, 0, "latest");
for (const log of grantCreatedEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Grant Created",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args
}
}
const grantCreatedFilter = vesterContract.filters.GrantCreated();
const grantCreatedEvents = await vesterContract.queryFilter(
grantCreatedFilter,
0,
"latest"
);
for (const log of grantCreatedEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Grant Created",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args,
};
}

const grantCancelledFilter = vesterContract.filters.GrantCancelled();
const grantCancelledEvents = await vesterContract.queryFilter(grantCancelledFilter, 0, "latest");
for (const log of grantCancelledEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Grant Cancelled",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args
}
}
const grantCancelledFilter = vesterContract.filters.GrantCancelled();
const grantCancelledEvents = await vesterContract.queryFilter(
grantCancelledFilter,
0,
"latest"
);
for (const log of grantCancelledEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Grant Cancelled",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args,
};
}

const supplyFilter = vesterContract.filters.Supply();
const supplyEvents = await vesterContract.queryFilter(supplyFilter, 0, "latest");
for (const log of supplyEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Tokens Supplied",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args
}
}
const supplyFilter = vesterContract.filters.Supply();
const supplyEvents = await vesterContract.queryFilter(
supplyFilter,
0,
"latest"
);
for (const log of supplyEvents) {
newEvents[`${log.transactionHash}-${log.logIndex}`] = {
type: "Tokens Supplied",
blockNumber: log.blockNumber,
timestamp: (await provider.getBlock(log.blockNumber)).timestamp,
transactionHash: log.transactionHash,
...log.args,
};
}

setEvents(newEvents)
return Promise.all([redemptionsEvents, grantCreatedEvents, grantCancelledEvents, supplyEvents])
}
setEvents(newEvents);
return Promise.all([
redemptionsEvents,
grantCreatedEvents,
grantCancelledEvents,
supplyEvents,
]);
};
Loading