initial

src/log.ts

@@ -0,0 +1,50 @@
+import * as chalk from 'chalk'
+import * as moment from 'moment'
+
+enum Level {
+    All,
+    NoDebug,
+    NoDebugNoInfo,
+    NoDebugNoInfoNoWarning
+}
+
+var level = Level.NoDebug
+
+function timestamp(): string {
+    return moment().format('HH:mm:ss.SSS')
+}
+
+export function setLevel(value: string): void {
+    switch (value) {
+        case 'info':  level = Level.NoDebug; break
+        case 'warn':  level = Level.NoDebugNoInfo; break
+        case 'error': level = Level.NoDebugNoInfoNoWarning; break
+        default:      level = Level.All
+    }
+}
+
+export function info(message: string): void {
+    if (level < Level.NoDebugNoInfo) {
+        console.log(`${timestamp()} ${chalk.bold.cyan('[ II ]')} ${message}`)
+    }
+}
+
+export function warn(message: string): void {
+    if (level < Level.NoDebugNoInfoNoWarning) {
+        console.log(`${timestamp()} ${chalk.bold.yellow('[ WW ]')} ${message}`)
+    }
+}
+
+export function error(message: string): void {
+    console.log(`${timestamp()} ${chalk.bold.red('[ EE ]')} ${message}`)
+}
+
+export function success(message: string): void {
+    console.log(`${timestamp()} ${chalk.bold.green('[ OK ]')} ${message}`)
+}
+
+export function debug(message: string): void {
+    if (level < Level.NoDebug) {
+        console.log(`${timestamp()} ${chalk.bold.magenta('[ DB ]')} ${message}`)
+    }
+}

src/main.ts

@@ -0,0 +1,27 @@
+import * as log from './log'
+import * as MqttClient from './mqttclient'
+
+class Dispatcher {
+    private _mqttClient: MqttClient.MqttClient
+
+    constructor() {
+        this._mqttClient = new MqttClient.MqttClient()
+
+        this._mqttClient.register('IoT/test', null)
+        this._mqttClient.register('IoT/Device/#', null)
+    }
+
+    exec() : void {
+        log.info("Dispatcher starting")
+
+        this._mqttClient.exec()
+    }
+}
+
+
+const dispatcher = new Dispatcher()
+dispatcher.exec()
+
+
+
+

src/mqttclient.ts

@@ -0,0 +1,71 @@
+import * as Mqtt from 'mqtt'
+import * as log from './log'
+
+const MQTT_BROKER_DEFAULT_URL : string = "mqtt://localhost"
+
+type TopicHandlerCallback = (message: Buffer) => void
+
+type TopicHandler = {
+    topic: string,
+    callback: TopicHandlerCallback|null
+}
+export class MqttClient {
+    private _mqttClient: Mqtt.Client
+    private _mqttBrokerUrl: string
+    private _topicHandlers: TopicHandler[]
+
+    constructor(mqttBrokerUrl? : string) {
+        this._mqttBrokerUrl = (mqttBrokerUrl) ? mqttBrokerUrl : MQTT_BROKER_DEFAULT_URL
+        this._topicHandlers = []
+    }
+
+    register(topic: string, callback: TopicHandlerCallback|null) : void {
+        this._topicHandlers.push({topic, callback})
+        log.info(`handler registered for topic ${topic}`)
+    }
+
+    exec() : void {
+        this._mqttClient = Mqtt.connect(this._mqttBrokerUrl)
+        this._mqttClient.on('error', log.error)
+        this._mqttClient.on('connect', (): void => {
+            log.info("connected to mqtt broker")
+            for (let topicHandler of this._topicHandlers) {
+                this._mqttClient.subscribe(topicHandler.topic)
+            }
+        })
+        this._mqttClient.on('message', (topic: string, payload: Buffer): void => {
+            log.info(`message received, topic ${topic}, payload ${payload}`)
+            for (let topicHandler of this._topicHandlers) {
+                if (this.topicMatch(topicHandler.topic, topic)) {
+                    log.info(`received topic ${topic} matches registered topic ${topicHandler.topic}`)
+                }
+            }
+        })
+    }
+
+    private topicMatch(registeredTopic: string, receivedTopic: string) : boolean {
+        let registeredTopicFields = registeredTopic.split('/')
+        let receivedTopicFields = receivedTopic.split('/')
+        for (let field in registeredTopicFields) {
+            let regField = registeredTopicFields[field]
+            let recvField = receivedTopicFields[field]
+            log.info(`recv: ${recvField}, reg: ${regField}`)
+            if (regField === "#") {
+                log.info('true')
+                return true
+            }
+            if (regField != recvField && regField != "+") {
+                log.info('false')
+                return false
+            }
+        }
+        if (registeredTopicFields.length == receivedTopicFields.length) {
+            log.info('true')
+            return true
+        } else {
+            log.info('false')
+            return false
+        }
+
+    }
+}