PhpFloBundle
, (*1)
This bundle is based on Henri Bergius library phpflo whose README I really suggest to read :-)
The intention for creating this bundle is an easier inclusion into e.g. symfony environments with the need for flow programming.
I had to rewrite part of the initial Network class to make use of a component registry to easily manage components via DIC. Also all component services should be defined as "public: false" to not clutter the DIC., (*2)
Installation
You can either just add via:, (*3)
$ composer.phar require phpflo/phpflo-bundle
Attention: This need minimum-stability: dev set on rootlevel
Otherwise you can first add phpflo and then the bundle., (*4)
$ composer.phar require phpflo/phpflo dev-master
$ composer.phar require phpflo/phpflo-bundle
This will first add phpflo with dev stability and the the bundle. This is due to composer's handling of stabilities for indirect dependencies., (*5)
Configuration
<?php
// AppKernel.php
// ...
$bundles = [
// ...
new PhpFlo\PhpFloBundle\PhpFloBundle(),
];
// ...
After adding the bundle, you have a new factory service phpflo.network which uses a registry of all your accordingly tagged services.
Another possibility is to use phpflo.network_di service.
The difference between these services is: network uses a registry and components are registered only once and collected during compile time. This is useful when using the network within on request cycle and build it only once.
If you are working e.g. with a long running process, you should us the network_di where every component will be fetched as a fresh object from DIC for every network build.
You can add components using following steps:, (*6)
Component class, (*7)
<?php
namespace AppBundle\Component;
// AppBundle/Component/ReadFile.php
use PhpFlo\Component;
use PhpFlo\Port;
class ReadFile extends Component
{
public function __construct()
{
$this->inPorts()->add('source', ['type' => 'string]);
$this->outPorts()->add('out', []);
$this->outPorts()->add('error', [];
$this->inPorts()->source->on('data', [$this, 'readFile']);
}
public function readFile($data)
{
// ...
}
}
Keep in mind to extend the PhpFlo\Component or implement PhpFlo\ComponentInterface!, (*8)
service definition (phpflo.network), (*9)
# app/config/services.yml
services:
app.read_file:
public: false
class: AppBundle\Component\ReadFile
tags:
- {name: phpflo.component, alias: read_file}
You can name the service whatever you want: The only two important things are the tags. It needs name "phpflo.component" to be found in compiler pass and the alias will be used as component name for the graph file., (*10)
service definition (phpflo.network_di), (*11)
# app/config/services.yml
services:
app.read_file:
lazy: true
shared: false # force instantiation
class: AppBundle\Component\ReadFile
tags: # optional
- {name: phpflo.component, alias: read_file}
graph file (app/config/my_graph.json), (*12)
{
"properties": {
"name": "Count lines in a file"
},
"processes": {
"ReadFile": {
"component": "read_file"
},
"SplitbyLines": {
"component": "split_str"
},
"CountLines": {
"component": "counter"
},
"Display": {
"component": "output"
}
},
"connections": [
{
"src": {
"process": "ReadFile",
"port": "out"
},
"tgt": {
"process": "SplitbyLines",
"port": "in"
}
},
{
"src": {
"process": "ReadFile",
"port": "error"
},
"tgt": {
"process": "Display",
"port": "in"
}
},
{
"src": {
"process": "SplitbyLines",
"port": "out"
},
"tgt": {
"process": "CountLines",
"port": "in"
}
},
{
"src": {
"process": "CountLines",
"port": "count"
},
"tgt": {
"process": "Display",
"port": "in"
}
}
]
}
The builder will automatically search for the provided graph file in '''app/config''' - if you need subdirectories, you can provide the filename in the formate '''subdir/graph.json''', (*13)
processes definition (network_di), (*14)
{
...
"processes": {
"ReadFile": {
"component": "app.read_file"
},
"SplitbyLines": {
"component": "split_str"
},
"CountLines": {
"component": "counter"
},
"Display": {
"component": "output"
}
},
...
}
Add the service name as component name!, (*15)
Example
Within a symfony controller with access to the DIC, you can simply create a graph like this:, (*16)
<?php
/** @var \PhpFlo\PhpFloBundle\Flow\Builder $builder */
$network = $this->get('phpflo')
->fromFile('my_graph.json');
$network->getGraph()
->addInitial(
$this->getParameter('kernel.root_dir') . '/config/my_graph.json', "ReadFile", "source"
);
License
PhpFloBundle is licensed under the MIT license. See the LICENSE for the full license text.
Free Software, Hell Yeah!, (*17)
Wallogit.com
