first commit

chenyc

2026-05-20 c8ba0f92b3f84273a78f06de25359db20c1b2a4d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
const assert = require('assert');
const { MqttService } = require('../mqtt-service');
 
describe('MqttService', () => {
  it('builds topic with default prefix', () => {
    const service = new MqttService({ defaultTopicPrefix: 'touxiji' });
 
    assert.strictEqual(service.buildTopic({ deviceId: 'JH-001', ip: '127.0.0.1' }), 'touxiji/JH-001');
  });
 
  it('builds topic with template', () => {
    const service = new MqttService({ topicTemplate: 'site/{deviceId}/{ip}' });
 
    assert.strictEqual(service.buildTopic({ deviceId: 'JH-001', ip: '127.0.0.1' }), 'site/JH-001/127.0.0.1');
  });
});