Initial Beta System

[annopkdd]

To do

• Receiver
• Command
• Command Register
• Command Bus
• Middleware
• Handle
• Message Template/Message Factory

[liverbool]

@criticalnooks Can you port this php function to python?

    /**
     * @param Middleware[] $middlewareList
     *
     * @return callable
     */
    function createExecutionChain(array $middlewareList)
    {
        $lastCallable = function () {
            // the final callable is a no-op
        };

        while ($middleware = array_pop($middlewareList)) {
            $lastCallable = function ($command) use ($middleware, $lastCallable) {
                return $middleware->execute($command, $lastCallable);
            };
        }

        return $lastCallable;
    }

[liverbool]

👍 looks good!

I thinks we need to small change to something like this (?)

pseudo code

class DefaultCommand():
    property name = 'DefaultCommand'
    property cmd = ''
    property template = None

    private event;

    self. __init__(event):
        self.event = event;

    self.isValidCmd():
        return self.cmd == self.event.input

class CommandA():
    property name = 'CommandA'
    property cmd = '/a'
    property template = None

    private event;

    self. __init__(event):
        self.event = event;

    self.isValidCmd():
        return self.cmd == self.event.input

class CommandB():
    property name = 'CommandB'
    property cmd = '/b'
    property template = None

    private event;

    self. __init__(event):
        self.event = event;

    self.isValidCmd():
        return self.cmd == self.event.input

class CommandRegistry():
    private commands = []

    def add(command):
        self.commands.push(command)

    def find(event):
        for (self.commands as command) {
            command = new command(event);
            if (command.isValidCmd()) {
                return command;
            }
        }

        return new DefaultCommand(event);

# Usage
commandRegistry = new CommandRegistry();
commandRegistry.add(CommandA)
commandRegistry.add(CommandB)

# middleware
class MiddlewareX():
    def execute(command):
        if (command.name != 'CommandA') {
            return;
        }

        # i want to tell this command to send vdo message
        command.template = new VdoMessageTemplate(....);

Command should have Abstract -- to handle common logic of commands.

from abc import ABCMeta, abstractmethod

class Command:
    __metaclass__ = ABCMeta
    
    property event;
    property template;

    def setEvent(event):
        self.event = event;

    @abstractmethod
    def isValidCmd(self): pass

class CommandA(Command):
    property cmd
    property name

    def isValidCmd():
        return self.cmd === self.event.input

# in CommandRegistry.find(event) 
....
    command = new CommandA()
    command.setEvent(event)
....