Compare commits

...

2 Commits

Author SHA1 Message Date
e6e2e0a291
Update git commit 2025-07-07 07:21:21 +00:00
e5f1b6f91c
Support workers from subgraph 2025-07-07 07:20:31 +00:00
3 changed files with 22 additions and 28 deletions

View File

@ -16,7 +16,7 @@ RUN ipfs init
ENV GIT_REPOSITORY=https://codeberg.org/tornadocash/relayers-network-ui.git
# From development branch, double check with tornado.ws
ENV GIT_COMMIT_HASH=382fe5a1274a9c553cf962721e96a93b274ff823
ENV GIT_COMMIT_HASH=e5f1b6f91c372fc58a7a6eb463e21a62a059db3b
# clone the repository
RUN mkdir /app/

View File

@ -6,6 +6,5 @@ export const GRAPHQL_LIMIT = 1000
* todo: add support for subgraph on thegraph & API keys
*/
export const RELAYER_SUBGRAPH_LIST: Record<number, string> = {
[ChainId.MAINNET]:
process.env.MAINNET_SUBGRAPH ?? 'https://tornadocash-rpc.com/subgraphs/name/tornadocash/tornado-relayer-registry',
[ChainId.MAINNET]: process.env.MAINNET_SUBGRAPH ?? 'https://tornadocash-rpc.com/subgraphs/name/tornadocash/tornado-governance',
}

View File

@ -8,20 +8,22 @@ import { getRelayerRegistry } from '@/contracts'
import { DEPLOYED_BLOCK, GRAPHQL_LIMIT, RELAYER_SUBGRAPH_LIST, errors, numbers } from '@/constants'
import { ensService, tornadoRelayerService } from '@/services'
import { errorParser, fromWei, toDecimalsPlaces } from '@/utilities'
import { getAddress } from 'ethers/lib/utils'
import { getAddress, parseEther } from 'ethers/lib/utils'
import { BigNumber } from 'ethers'
interface GraphRelayer {
id: string
address: string
ensName: string
ensHash: string
workers: string[]
stakeBalance: string
blockRegistration: string
}
interface GraphRelayerFormatted extends Omit<GraphRelayer, 'id' | 'blockRegistration'> {
interface GraphRelayerFormatted extends Omit<GraphRelayer, 'stakeBalance' | 'blockRegistration'> {
stakeBalance: BigNumber
registerBlock: number
registerTx: string
registerLogIndex: number
}
export const actions: ActionTree<RelayerState, RootState> = {
@ -67,9 +69,6 @@ export const actions: ActionTree<RelayerState, RootState> = {
}
},
/**
* todo: add worker events to relayer registry subgraph
*/
async getRelayersFromGraph({ getters }) {
try {
const { chainId } = getters.dependencies
@ -85,10 +84,12 @@ export const actions: ActionTree<RelayerState, RootState> = {
query: `
query getRelayers($first: Int) {
relayers(first: $first, orderBy: blockRegistration, orderDirection: asc) {
id
address
ensName
ensHash
workers
stakeBalance
blockRegistration
}
_meta {
@ -115,22 +116,22 @@ export const actions: ActionTree<RelayerState, RootState> = {
throw new Error(`Error from graph: ${JSON.stringify(errors)}`)
}
/**
if (data?._meta?.hasIndexingErrors) {
throw new Error('Subgraph has indexing errors');
throw new Error('Subgraph has indexing errors')
}
**/
return (data.relayers as GraphRelayer[]).map(({ id, address, ensName, ensHash, blockRegistration }) => {
const [registerTx, registerLogIndex] = id.split('-')
return (data.relayers as GraphRelayer[]).map(({ address, ensName, ensHash, workers, stakeBalance, blockRegistration }) => {
if (!workers.includes(address)) {
workers.push(getAddress(address))
}
return {
address: getAddress(address),
ensName,
ensHash,
workers,
stakeBalance: parseEther(stakeBalance),
registerBlock: Number(blockRegistration),
registerTx,
registerLogIndex: Number(registerLogIndex),
}
})
} catch (err) {
@ -163,9 +164,8 @@ export const actions: ActionTree<RelayerState, RootState> = {
async getRelayers({ getters, commit, dispatch }) {
try {
const { walletAddress, chainId } = getters.dependencies
const { walletAddress } = getters.dependencies
// todo: add worker data
const relayers = (await dispatch('getRelayersFromGraph')) as GraphRelayerFormatted[]
const relayer = relayers.find((r) => r.address === walletAddress)
@ -174,13 +174,8 @@ export const actions: ActionTree<RelayerState, RootState> = {
throw new Error(`No relayer found for ${walletAddress}`)
}
const registryContract = getRelayerRegistry(chainId)
const { balance } = await registryContract.callStatic.relayers(walletAddress)
// todo: add worker data
commit(RelayerMutation.SET_WORKERS, [walletAddress])
commit(RelayerMutation.SET_BALANCE, balance)
commit(RelayerMutation.SET_WORKERS, relayer.workers)
commit(RelayerMutation.SET_BALANCE, relayer.stakeBalance)
await dispatch('getRelayerENSData', relayer.ensName)
} catch (err) {