-
-
+
@@ -157,15 +224,19 @@ function Layout() {
+
{item.name}
-
))}
{item.description}
++ {item.description} +
-
+
@@ -236,9 +315,15 @@ function Layout() {
Open main menu
{open ? (
-
+
) : (
-
+
)}
@@ -258,7 +343,7 @@ function Layout() {
+
{item.name}
-
))}
{item.description}
++ {item.description} +
loading
+ const { latestBlock, logs } = data
+
+ function toggleStaging() {
+ if (isProd) {
+ navigate(location.pathname.replace('prod', 'stage'))
+ } else {
+ navigate(location.pathname.replace('stage', 'prod'))
+ }
+ }
+
+ function showOlder() {
+ const no = logs[logs.length - 1].blockNumber
+ searchParams.set('block', no)
+ setSearchParams(searchParams)
+ }
+
+ function setBlock(b: string) {
+ searchParams.set('block', b)
+ setSearchParams(searchParams)
+ }
+
+ return (
+
+
+
+
+
+
+
+ )
+}
diff --git a/monitoring/healthz/src/pages/TXDetail.tsx b/monitoring/healthz/src/pages/TXDetail.tsx
new file mode 100644
index 00000000000..0c83ef071c0
--- /dev/null
+++ b/monitoring/healthz/src/pages/TXDetail.tsx
@@ -0,0 +1,190 @@
+import { useQuery } from '@tanstack/react-query'
+import { Link, useParams } from 'react-router-dom'
+import { fetcher } from '../query'
+import {
+ decodeEmLog,
+ useEthersProvider,
+ useSomeContentEndpoint,
+ useSomeDiscoveryEndpoint,
+} from '../utils/acdc-client'
+
+// @ts-expect-error (so we can JSON.stringify the abi params)
+BigInt.prototype.toJSON = function () {
+ return this.toString() + 'n'
+}
+
+const preClass = ``
+const classes = {
+ chip: `niceChip`,
+}
+
+export function TxDetail() {
+ const params = useParams()
+ const provider = useEthersProvider()
+
+ const { data } = useQuery([params.tx!], async () => {
+ const receipt = await provider.getTransactionReceipt(params.tx!)
+ if (!receipt) return {}
+ const em = decodeEmLog(receipt.logs[0].data)
+ return { receipt, em }
+ })
+
+ if (!data || !data.receipt || !data.em) return
+
+
+
+
+
+
+ Recent Transactions
+
+
+
+ Block:
+ setBlock(e.target.value)}
+ placeholder="block number"
+ className="p-2 my-2 rounded niceBorder"
+ value={latestBlock.toString()}
+ />
+ | block no | +tx hash | +signed by | +user id | +action | +type | +id | +metadata | +
|---|---|---|---|---|---|---|---|
| + + {log.blockNumber.toString()} + + | ++ + {log.transactionHash.substring(0, 15)}... + + | +
+
+
+ {em._signer}
+
+
+ |
+ + + {em._userId.toString()} + + | +{em._action} | +{em._entityType} | +{em._entityId.toString()} | +
+ {em._metadata}
+ |
+
loading
+ const { receipt, em } = data
+ const metadata = em._metadata ? JSON.parse(em._metadata) : undefined
+
+ return (
+
+
+ back to logs
+
+
+
+ )
+}
+
+function UserChip({ id, signer }: { id: string; signer?: string }) {
+ const DISCOVERY = useSomeDiscoveryEndpoint()
+ const { data } = useQuery([id], async () => {
+ return fetcher(`${DISCOVERY}/users?id=${id}`)
+ })
+
+ const user = data?.data[0]
+ if (!user) return null
+ return (
+
+
+
+
+
+ {em._action} {em._entityType}
+
+
+
+
+ TX Receipt
+{JSON.stringify(receipt, undefined, 2)}
+
+
+
+ {metadata ? (
+ Decoded ABI
+
+ {JSON.stringify(em.toObject(), undefined, 2)}
+
+
+
+ ) : null}
+ _metadata
+
+ {JSON.stringify(metadata, undefined, 2)}
+
+
+ {user.handle}
+ {signer && signer.toLowerCase() != user.wallet.toLowerCase() && (
+
+
+ )
+}
+
+function ObjectChip({
+ entityType,
+ entityId,
+}: {
+ entityType: string
+ entityId: string
+}) {
+ switch (entityType) {
+ case 'Track':
+ return
+ signed by {signer}
+
+ )}
+ unknown type: {entityType}
+ }
+}
+
+function TrackChip({ id }: { id: string }) {
+ const DISCOVERY = useSomeDiscoveryEndpoint()
+ const { data } = useQuery([id], async () => {
+ return fetcher(`${DISCOVERY}/tracks?id=${id}`)
+ })
+
+ const track = data?.data[0]
+ if (!track) return null
+ return (
+ console.log(track)}
+ >
+ {track.title}
+
+ )
+}
+
+function PlaylistChip({ id }: { id: string }) {
+ const DISCOVERY = useSomeDiscoveryEndpoint()
+ const { data } = useQuery([id], async () => {
+ return fetcher(`${DISCOVERY}/playlists?id=${id}`)
+ })
+
+ const playlist = data?.data[0]
+ if (!playlist) return null
+
+ return (
+ console.log(playlist)}
+ >
+ 
+}
diff --git a/monitoring/healthz/src/utils/acdc-client.ts b/monitoring/healthz/src/utils/acdc-client.ts
new file mode 100644
index 00000000000..ea5889dc7f4
--- /dev/null
+++ b/monitoring/healthz/src/utils/acdc-client.ts
@@ -0,0 +1,86 @@
+import { Interface, ethers } from 'ethers'
+import { useEnvironmentSelection } from '../components/EnvironmentSelector'
+import { useMemo } from 'react'
+import { useLocation } from 'react-router-dom'
+
+// todo: env config
+export const EM_ADDRESS = '0x1cd8a543596d499b9b6e7a6ec15ecd2b7857fd64'
+
+export function useEthersProvider() {
+ const [env] = useEnvironmentSelection()
+ const isProd = useLocation().pathname.indexOf('/prod') == 0
+ const rpcEndpoint = isProd
+ ? 'https://acdc-gateway.audius.co'
+ : 'https://acdc-gateway.staging.audius.co'
+
+ return useMemo(() => {
+ return new ethers.JsonRpcProvider(rpcEndpoint, undefined, {
+ // lua script doesn't handle multiple RPCs in one request atm
+ batchMaxSize: 1,
+ })
+ }, [rpcEndpoint])
+}
+
+export function useSomeDiscoveryEndpoint() {
+ const isProd = useLocation().pathname.indexOf('/prod') == 0
+ return isProd
+ ? 'https://discoveryprovider.audius.co'
+ : 'https://discoveryprovider.staging.audius.co'
+}
+
+export function useSomeContentEndpoint() {
+ const isProd = useLocation().pathname.indexOf('/prod') == 0
+ return isProd
+ ? 'https://creatornode2.audius.co'
+ : 'https://creatornode12.staging.audius.co'
+}
+
+const iface = new Interface([
+ {
+ anonymous: false,
+ inputs: [
+ {
+ indexed: false,
+ internalType: 'uint256',
+ name: '_userId',
+ type: 'uint256',
+ },
+ {
+ indexed: false,
+ internalType: 'address',
+ name: '_signer',
+ type: 'address',
+ },
+ {
+ indexed: false,
+ internalType: 'string',
+ name: '_entityType',
+ type: 'string',
+ },
+ {
+ indexed: false,
+ internalType: 'uint256',
+ name: '_entityId',
+ type: 'uint256',
+ },
+ {
+ indexed: false,
+ internalType: 'string',
+ name: '_metadata',
+ type: 'string',
+ },
+ {
+ indexed: false,
+ internalType: 'string',
+ name: '_action',
+ type: 'string',
+ },
+ ],
+ name: 'ManageEntity',
+ type: 'event',
+ },
+])
+
+export function decodeEmLog(data: string) {
+ return iface.decodeEventLog('ManageEntity', data)
+}