-
Notifications
You must be signed in to change notification settings - Fork 0
/
block.php
73 lines (52 loc) · 1.69 KB
/
block.php
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
<?php
require( "vendor/autoload.php" );
// create a log channel
$log = new \Monolog\Logger('NinjaBlock');
$log->pushHandler(new Monolog\Handler\StreamHandler('php://stdout', \Monolog\Logger::INFO));
if ( ! isset( $argv[1] ) )
die( "You need to set a block id! (arg 1)");
$block_id = $argv[1];
if ( isset( $argv[2] ) )
{
$writeCmd = $argv[2];
}
else
{
$writeCmd = false;
}
// Create the event loop;
$loop = \React\EventLoop\Factory::create();
// Create the NinaBlock Client
$client = new NinjaBlock\Client( $block_id );
$block = new NinjaBlock\Block( $loop, $client );
$mqtt = new NinjaBlock\MQTTClient("dns.lan", 1883, "NinjaBlock", $loop);
addLogger( $client, $log );
addLogger( $block, $log );
addLogger( $mqtt, $log );
$readStream = new \React\Stream\ThroughStream();
$writeStream = new \React\Stream\ThroughStream();
$block->setReadStream( $readStream );
$block->setWriteStream( $writeStream );
$mqtt->on( 'connect', function() use ($mqtt, $readStream, $block_id) {
$mqtt->log( 'info', "MQTT Connected" );
$topic = sprintf( "RedNinja/%s/read", $block_id );
$mqtt->log( 'info', "Subscribing: " . $topic );
$mqtt->subscribe([
$topic => ["qos" => 0 ]
]);
});
$mqtt->on( 'message', function( $topic, $message) use ( $readStream ) {
$readStream->write( $message );
});
$mqtt->on( 'timeout', function( ) { echo "TIMEOUT" .PHP_EOL; });
$client->on( 'write', function( $command ) use ($mqtt, $block_id) {
$mqtt->log( "debug", "Publishing: " . json_encode( $command ) );
$mqtt->publish( sprintf( "RedNinja/%s/write", $block_id ), json_encode( $command ) );
});
$block->on( 'connect', function() use ($mqtt) {
if ( ! $mqtt->isConnected() )
$mqtt->connect();
});
$block->connect();
$loop->run();
?>