const assert = require('assert');
const { formatReceivedTimestamp, normalizeIp, TcpService } = require('../tcp-service');
const { buildFrame, buildBloodPressurePayload } = require('../tcp-simulator');

describe('tcp-service', () => {
  it('normalizes IPv4 mapped addresses', () => {
    assert.strictEqual(normalizeIp('::ffff:192.168.1.10'), '192.168.1.10');
    assert.strictEqual(normalizeIp('127.0.0.1'), '127.0.0.1');
  });

  it('formats receive timestamp', () => {
    assert.strictEqual(formatReceivedTimestamp(new Date('2026-05-12T10:20:30')), '2026-05-12 10:20:30');
  });

  it('adds M when blood pressure frame is handled', async () => {
    let receivedMetric = null;
    const service = new TcpService({
      tcpConfig: { maxBufferBytes: 8192 },
      devices: [],
      alModelPath: './alModel.json',
      logger: { info() {}, warn() {}, error() {}, debug() {} },
      onMetric(_device, metric) {
        receivedMetric = metric;
      },
    });
    const fakeSocket = {};

    service.sessions.set(fakeSocket, {
      device: { deviceId: 'JH-001', ip: '127.0.0.1' },
      decoder: {
        push() {
          return [{
            ok: true,
            publish: true,
            messageType: 'blood-pressure',
            metric: { N: 120, O: 80, P: 76 },
          }];
        },
      },
    });

    service.handleData(fakeSocket, buildFrame(1, 0x01, 0x01, buildBloodPressurePayload()));

    assert.strictEqual(receivedMetric.N, 120);
    assert.strictEqual(receivedMetric.O, 80);
    assert.strictEqual(receivedMetric.P, 76);
    assert.match(receivedMetric.M, /^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}$/);
  });
});