Source code for platypush.backend.nodered

import inspect
import os
import subprocess
import sys

from platypush.backend import Backend




class NoderedBackend(Backend):
    """
    This backend publishes platypush actions to a Node-RED instance.
    If you enable this backend on a host that runs Node-RED then a new block (platypush -> run) can be
    used in your flows. This block will accept JSON requests as input in the format
    ``{"type":"request", "action":"plugin.name.action_name", "args": {...}}`` and return the output
    of the action as block output, or raise an exception if the action failed.
    """



    def __init__(self, port: int = 5051, *args, **kwargs):
        """
        :param port: Listening port for the local publishing web server (default: 5051)
        """
        super().__init__(*args, **kwargs)
        self.port = port
        self._runner_path = os.path.join(
            os.path.dirname(inspect.getfile(self.__class__)), 'runner.py'
        )
        self._server = None




    def on_stop(self):
        super().on_stop()
        if self._server:
            self._server.terminate()
            self._server = None




    def run(self):
        super().run()
        self.register_service(port=self.port, name='node')

        self._server = subprocess.Popen(
            [
                sys.executable,
                '-m',
                'pynodered.server',
                '--port',
                str(self.port),
                self._runner_path,
            ]
        )

        self.logger.info('Started Node-RED backend on port {}'.format(self.port))
        self._server.wait()




# vim:sw=4:ts=4:et: