Add example

Author: aganttor

README.md

@@ -52,6 +52,12 @@ The following versions of PHP are supported by this version.
 
 Please see [CHANGELOG](CHANGELOG.md) for more information what has changed recently.
 
+## Usage
+
+> We are beaming Kirk and Spock from Enterprise to Earth.
+
+The [client](example/client.php) sends data to an [endpoint](example/endpoint.php) and process received data from endpoint.
+ 
 ## Testing
 
 ``` bash

example/client.php

@@ -0,0 +1,70 @@
+<?php
+
+require_once __DIR__ . '/../vendor/autoload.php';
+
+$data = [
+    'beam' => ['kirk', 'spock'],
+    'to' => 'earth'
+];
+
+$outputStream = new \Hawkbit\DataStream\OutputStream($data);
+
+echo 'Capture beaming sequence ' . $outputStream . PHP_EOL . PHP_EOL;
+echo 'Beaming sequence ';
+
+sleep(1);
+
+echo 'initiated!' . PHP_EOL;
+
+sleep(1);
+
+echo 'Beaming ';
+
+// perform inter-process communication
+// send data via cli, rest, pubsub or something like that
+// we send data to endpoint.php and also want to receive data from endpoint php
+$payload = exec(sprintf('php endpoint.php %s', $outputStream));
+
+echo 'finished' . PHP_EOL . PHP_EOL;
+echo 'Receive beaming feedback sequence ';
+sleep(3);
+
+echo $payload . PHP_EOL . PHP_EOL;
+
+// create input stream from input and read data
+$inputStream = new \Hawkbit\DataStream\InputStream($payload);
+$result = $inputStream->getData();
+
+echo 'Destination: ';
+
+sleep(1);
+
+// check that kirk and spock has been beamed
+if($result['destination'] !== $data['to']){
+    echo 'Not OK!' . PHP_EOL;
+    echo sprintf('Oh no! Expected destination to be %s and not %s', $data['to'],
+        $result['destination']) . PHP_EOL;
+}
+
+echo 'OK!' . PHP_EOL;
+
+$beam = implode(' and ', $data['beam']);
+$beamed = implode(' and ', $result['beamed']);
+
+echo 'Persons: ';
+
+sleep(2);
+
+if($beam !== $beamed){
+    echo 'Not OK!' . PHP_EOL;
+    echo sprintf('Oh no! Expected beamed persons to be %s and not %s', $beam, $beamed) . PHP_EOL;
+}
+
+echo 'OK!' . PHP_EOL . PHP_EOL;
+
+usleep(800);
+
+echo sprintf('%s beamed to %s', $beamed, $result['destination']);
+
+
+

example/endpoint.php

@@ -0,0 +1,18 @@
+<?php
+
+require_once __DIR__ . '/../vendor/autoload.php';
+
+// read payload for input stream
+$payload = $argv[1];
+
+// create input stream
+$inputStream = new \Hawkbit\DataStream\InputStream($payload);
+$data = $inputStream->getData();
+
+$output = [
+    'beamed' => $data['beam'],
+    'destination' => $data['to']
+];
+
+echo new \Hawkbit\DataStream\OutputStream($output);
+exit(1);

tests/DataStreamTest.php

@@ -35,9 +35,11 @@ public function testDefaultOutput(): OutputStream
         $dataStream = new $className($this->dto);
 
         $this->assertInstanceOf(DataStream::class, $dataStream);
-        $this->assertEquals(hash('adler32', $dataStream->getSerializer()->serialize($dataStream->getRaw())), $dataStream->getFingerprint());
-
+        $this->assertEquals($dataStream->getHasher()->hash($dataStream->getSerializer()->serialize($dataStream->getRaw()
+    )),
+        $dataStream->getFingerprint());
         $this->assertGreaterThan(time(), $dataStream->getExpirationTime());
+        $this->assertEquals($dataStream->getData(), (string)$dataStream);
 
         return $dataStream;
     }