test-simulator.js

/**
 * RFID Reader Simulator for Testing
 * This simulates an RFID reader for development and testing purposes
 */

const net = require('net');

class RFIDSimulator {
    constructor(port = 6677) {
        this.port = port;
        this.server = null;
        this.clients = new Set();
        this.isRunning = false;
        this.autoReadInterval = null;
    }

    start() {
        this.server = net.createServer((socket) => {
            console.log('Client connected to RFID simulator');
            this.clients.add(socket);

            // Send welcome message
            socket.write('Equicus RFID Reader Simulator v1.0\r\n');

            socket.on('data', (data) => {
                const command = data.toString().trim();
                console.log(`Received command: ${command}`);
                this.handleCommand(socket, command);
            });

            socket.on('close', () => {
                console.log('Client disconnected from RFID simulator');
                this.clients.delete(socket);
            });

            socket.on('error', (error) => {
                console.log('Client connection error:', error.message);
                this.clients.delete(socket);
            });
        });

        this.server.listen(this.port, () => {
            console.log(`RFID Simulator running on port ${this.port}`);
            this.isRunning = true;
        });

        this.server.on('error', (error) => {
            console.error('Server error:', error.message);
        });
    }

    handleCommand(socket, command) {
        // Remove @ prefix if present (machine mode)
        const cleanCommand = command.replace(/^@/, '');
        
        switch (cleanCommand.toLowerCase()) {
            case 'sv':
                // Software version
                socket.write('D24D0C70\r\n');
                break;

            case 'param':
                // Parameters
                socket.write('freq=125\r\n');
                socket.write('power=30\r\n');
                socket.write('mode=auto\r\n');
                break;

            case 'ata':
                // Antenna tuning A
                socket.write('+ CA0000AA\r\n');
                break;

            case 'atb':
                // Antenna tuning B
                socket.write('+ CB0000BB\r\n');
                break;

            case 'se':
                // Status
                socket.write('+ OK\r\n');
                break;

            case 'fmt 15':
                // Set format to show all fields
                socket.write('+ OK\r\n');
                break;

            case 'fmt 2':
                // Set format to ID only
                socket.write('+ OK\r\n');
                break;

            case 'sa 1':
                // Start autoread
                socket.write('+ OK\r\n');
                this.startAutoRead(socket);
                break;

            case 'sa 0':
                // Stop autoread
                socket.write('+ OK\r\n');
                this.stopAutoRead();
                break;

            default:
                // Unknown command
                socket.write('+ ERROR: Unknown command\r\n');
                break;
        }
    }

    startAutoRead(socket) {
        console.log('Starting simulated autoread...');
        
        // Generate random tag IDs
        const tagIds = [
            'A1B2C3D4E5',
            'F6G7H8I9J0',
            'K1L2M3N4O5',
            'P6Q7R8S9T0',
            'U1V2W3X4Y5'
        ];

        this.autoReadInterval = setInterval(() => {
            if (this.clients.has(socket)) {
                const randomTag = tagIds[Math.floor(Math.random() * tagIds.length)];
                const channel = Math.random() > 0.5 ? 'a' : 'b';
                const speed = Math.random() > 0.5 ? '2' : '4';
                const polarity = Math.random() > 0.5 ? '+' : '-';
                const signalStrength = Math.floor(Math.random() * 50) + 10;
                const timestamp = Date.now() % 1000000;

                const tagData = `${channel}${speed}${polarity}: ${randomTag} ${signalStrength} :${timestamp}\r\n`;
                socket.write(tagData);
            }
        }, 2000); // Send tag every 2 seconds
    }

    stopAutoRead() {
        console.log('Stopping simulated autoread...');
        if (this.autoReadInterval) {
            clearInterval(this.autoReadInterval);
            this.autoReadInterval = null;
        }
    }

    stop() {
        if (this.autoReadInterval) {
            this.stopAutoRead();
        }

        if (this.server) {
            this.server.close(() => {
                console.log('RFID Simulator stopped');
                this.isRunning = false;
            });
        }
    }
}

// Start simulator if this file is run directly
if (require.main === module) {
    const simulator = new RFIDSimulator(6677);
    
    console.log('Starting Equicus RFID Reader Simulator...');
    console.log('Connect your application to localhost:6677');
    console.log('Press Ctrl+C to stop');
    
    simulator.start();

    process.on('SIGINT', () => {
        console.log('\nStopping simulator...');
        simulator.stop();
        process.exit(0);
    });
}

module.exports = RFIDSimulator;