Flow Based Programming Experiments

fbpe.py

import inspect
import functools


def multiply(x, y):
    return x * y


def add(x, y):
    return x + y


def x():
    return 1


# Assign "process" method to components values
def resolve_connections(connections):
    for connection in connections:
        source = connection[0]
        target = connection[1]
        argument = connection[2]
        target.__dict__[argument] = functools.partial(source.process)


class component(object):

    def __init__(self, method):
        self.method = method

    def process(self):
        arguments = []
        for arg in inspect.getargspec(self.method).args:
            arguments.append(self.__dict__[arg]())

        return self.method(*arguments)


x1 = component(x)
add1 = component(add)
add2 = component(add)
multipy1 = component(multiply)

connections = [
    (x1, add1, "x"),
    (x1, add1, "y"),
    (x1, add2, "x"),
    (add1, add2, "y"),
    (add2, multipy1, "x"),
    (add1, multipy1, "y"),
]

resolve_connections(connections)
print multipy1.process()