app.ts

import 'dotenv/config';
import { FormantClient } from './src/formant-client';

interface SessionInfo {
    sessionId: string;
    peers: {
        deviceId?: string;
        deviceName?: string;
        userId?: string;
        userName?: string;
    }[];
}

async function main() {
    try {
        const client = new FormantClient();
        
        // Authenticate
        await client.authenticate(
            process.env.FORMANT_EMAIL || '',
            process.env.FORMANT_PASSWORD || ''
        );

        // Get peers
        const peers = await client.getPeers();
        
        // Create a map of sessions to their connected peers
        const sessionMap = new Map<string, SessionInfo>();
        
        // First pass: collect all sessions and their peers
        for (const peer of peers) {
            for (const sessionId of peer.session_ids) {
                if (!sessionMap.has(sessionId)) {
                    sessionMap.set(sessionId, {
                        sessionId,
                        peers: []
                    });
                }
                
                const peerInfo: SessionInfo['peers'][0] = {};
                
                // Add device information if available
                if (peer.device_id?.value) {
                    try {
                        const device = await client.getDevice(peer.device_id.value);
                        peerInfo.deviceId = peer.device_id.value;
                        peerInfo.deviceName = device.name;
                    } catch (error) {
                        console.error(`Failed to get device info for ${peer.device_id.value}`);
                    }
                }

                // Add user information if available
                if (peer.user_id?.value) {
                    try {
                        const user = await client.getUser(peer.user_id.value);
                        peerInfo.userId = peer.user_id.value;
                        peerInfo.userName = [user.firstName, user.lastName]
                            .filter(Boolean)
                            .join(' ') || user.email;
                    } catch (error) {
                        console.error(`Failed to get user info for ${peer.user_id.value}`);
                    }
                }

                sessionMap.get(sessionId)?.peers.push(peerInfo);
            }
        }

        // Display sessions and their connected peers
        console.log('Active Sessions:');
        console.log('---------------');
        
        for (const [sessionId, session] of sessionMap) {
            console.log(`Session: ${sessionId}`);
            console.log('Connected Peers:');
            
            for (const peer of session.peers) {
                if (peer.deviceId) {
                    console.log(`  Device: ${peer.deviceName} (${peer.deviceId})`);
                }
                if (peer.userId) {
                    console.log(`  User: ${peer.userName} (${peer.userId})`);
                }
            }
            console.log('---------------');
        }
        
    } catch (error) {
        console.error('Error:', error);
    }
}

main();