/** * OffChainServices Component - Integration with state anchoring and transaction mirroring services */ import { useState, useEffect } from 'react' import { CONTRACT_ADDRESSES } from '../../config/contracts' import { chain138 } from '../../config/networks' interface ServiceStatus { name: string status: 'running' | 'stopped' | 'unknown' lastUpdate: number | null endpoint?: string } const INITIAL_SERVICES: ServiceStatus[] = [ { name: 'State Anchoring Service', status: 'unknown', lastUpdate: null, endpoint: 'http://192.168.11.221:8545', // Chain 138 RPC (VMID 2201, public/monitoring) }, { name: 'Transaction Mirroring Service', status: 'unknown', lastUpdate: null, endpoint: 'http://192.168.11.221:8545', }, ] export default function OffChainServices() { const [services, setServices] = useState(INITIAL_SERVICES) const checkServiceStatus = async (service: ServiceStatus): Promise => { if (!service.endpoint) { return { ...service, status: 'unknown' as 'running' | 'stopped' | 'unknown', lastUpdate: Date.now(), } } try { // Try to check if it's an RPC endpoint if (service.endpoint.includes('8545') || service.endpoint.includes('rpc')) { // For RPC endpoints, try a simple eth_blockNumber call const response = await fetch(service.endpoint, { method: 'POST', headers: { 'Content-Type': 'application/json', }, body: JSON.stringify({ jsonrpc: '2.0', method: 'eth_blockNumber', params: [], id: 1, }), signal: AbortSignal.timeout(5000), // 5 second timeout }) if (response.ok) { const data = await response.json() if (data.result) { return { ...service, status: 'running' as 'running' | 'stopped' | 'unknown', lastUpdate: Date.now(), } } } } else { // For HTTP endpoints, try a simple GET request const response = await fetch(service.endpoint, { method: 'GET', signal: AbortSignal.timeout(5000), // 5 second timeout }) if (response.ok) { return { ...service, status: 'running' as 'running' | 'stopped' | 'unknown', lastUpdate: Date.now(), } } } return { ...service, status: 'stopped' as 'running' | 'stopped' | 'unknown', lastUpdate: Date.now(), } } catch (error: unknown) { // Timeout or network error console.error(`Health check failed for ${service.name}:`, error) return { ...service, status: 'stopped' as 'running' | 'stopped' | 'unknown', lastUpdate: Date.now(), } } } useEffect(() => { const checkAllServices = async () => { const updated = await Promise.all(INITIAL_SERVICES.map(checkServiceStatus)) setServices(updated) } checkAllServices() const interval = setInterval(checkAllServices, 30000) // Check every 30 seconds return () => clearInterval(interval) }, []) const getStatusColor = (status: string) => { switch (status) { case 'running': return 'bg-green-500/20 text-green-300 border-green-500/50' case 'stopped': return 'bg-red-500/20 text-red-300 border-red-500/50' default: return 'bg-yellow-500/20 text-yellow-300 border-yellow-500/50' } } return (

Off-Chain Services

Monitor and manage off-chain services that interact with admin contracts.

{services.map((service, index) => (

{service.name}

{service.status.toUpperCase()}
{service.endpoint && (

{service.endpoint}

)} {service.lastUpdate && (

Last checked: {new Date(service.lastUpdate).toLocaleString()}

)}
))}

Service Information

State Anchoring Service

Monitors {chain138.name} blocks and submits state proofs to MainnetTether contract.

Contract: {CONTRACT_ADDRESSES.mainnet.MAINNET_TETHER}

Transaction Mirroring Service

Monitors {chain138.name} transactions and mirrors them to TransactionMirror contract.

Contract: {CONTRACT_ADDRESSES.mainnet.TRANSACTION_MIRROR}

) }