pera-swarm / mqtt-router Goto Github PK

Need to have support for options for each message in mqtt-router publish queue.

Like this:
mqttRouter.pushToPublishQueue(topic, message, options)

Requirements

• Need to implement a queue for message publication.
• MQTT class (MQTT router + this implementation) should frequently check the queue and publish the message in the queue.

MQTT Channel Resolver migration from staging environment.

Summary

Need to implement a locking mechanism for registering only one router instance for a particular MQTT Channel. Find more information on the protocol documentation.

Checklist:

• /service/discovery route handler function
• /service/terminate/{UUID} route handler function
• Swarm server time-out and exit event upon terminate request

Summary

Need to idiot proof the library. Don't want to crash the entire applications for TypeErrors. Certain Errors would be okay to crash the whole application.

Summary

We need to implement a way to handle the logics for both allowedRetain: true and allowedRetain: false as separately. We may also need to configure the route handler function in this implementation as well.

Summary

We need to implement the functionality to unsubscribe from certain routes declared in the routes array and add other subscriptions and routes after starting the router. Also we need to consider the publishers as well.

Following should be added to router.ts & update the documentation.

    /**
     * method for adding multiple routes to the list
     * @param {Route[]} route[] list of route objects to be added to the subscriber list
     */
    addRoutes = (routes: Route[]) => {
        for (let i = 0; i < routes.length; i++) {
            //console.log(routes[i].topic);
            this.addRoute(routes[i]);
        }
    };