import WebSocket from 'ws';
interface TransactionUpdate {
signature: string;
status: 'pending' | 'confirmed' | 'finalized' | 'failed';
confirmations: number;
amount_lamports: number;
fee_lamports: number;
block_time?: string;
}
class AgentTransactionMonitor {
private ws: WebSocket | null = null;
constructor(
private apiKey: string,
private walletAddress: string
) {}
connect(): void {
this.ws = new WebSocket('wss://api.clawfirst.xyz/v1/transactions/stream');
this.ws.on('open', () => {
console.log('Connected to transaction stream');
// Authenticate
this.send({
type: 'authenticate',
api_key: this.apiKey
});
// Subscribe to agent wallet
this.send({
type: 'subscribe',
wallet: this.walletAddress
});
});
this.ws.on('message', (data: string) => {
const update: TransactionUpdate = JSON.parse(data);
this.handleUpdate(update);
});
this.ws.on('error', (error) => {
console.error('WebSocket error:', error);
});
this.ws.on('close', () => {
console.log('Disconnected, reconnecting in 5s...');
setTimeout(() => this.connect(), 5000);
});
}
private send(data: any): void {
if (this.ws?.readyState === WebSocket.OPEN) {
this.ws.send(JSON.stringify(data));
}
}
private handleUpdate(update: TransactionUpdate): void {
console.log(`TX ${update.signature.slice(0, 8)}...`);
console.log(` Status: ${update.status}`);
console.log(` Confirmations: ${update.confirmations}`);
if (update.status === 'finalized') {
console.log(' ✅ Finalized');
}
}
disconnect(): void {
this.ws?.close();
}
}
// Usage
const monitor = new AgentTransactionMonitor(
process.env.CLAWFIRST_API_KEY!,
'YOUR_AGENT_WALLET'
);
monitor.connect();
