Merge pull request #36 from spryker-middleware/dev

Release 1.0.0

.scrutinizer.yml

@@ -0,0 +1,18 @@
+build:
+    dependencies:
+        before:
+            - composer config repositories.spryker composer https://code.spryker.com/repo/private
+    environment:
+        php:
+            version: 7.1
+
+checks:
+    php:
+        code_rating: true
+
+filter:
+    excluded_paths:
+        - config/*
+        - tests/*
+        - src/Generated/*
+        - src/Pyz/*

.travis.yml

@@ -0,0 +1,47 @@
+language: php
+
+notifications:
+  email: false
+
+sudo: required
+
+matrix:
+  fast_finish: true
+  include:
+     - php: "7.1"
+
+services:
+  - postgresql
+  - redis
+  - rabbitmq
+
+addons:
+  postgresql: 9.4
+
+  apt:
+    packages:
+      - graphviz
+
+  hosts:
+    - zed.de.spryker.test
+    - www.de.spryker.test
+
+env:
+  global:
+    - APPLICATION_ENV=devtest
+    - APPLICATION_STORE=DE
+    - MODULE_DIR=module
+    - SHOP_DIR=current
+    - MODULE_NAME=process
+
+cache:
+  directories:
+    - $SHOP_DIR/current/vendor
+    - $HOME/.composer/cache
+
+before_install:
+  - echo "extension = redis.so" >> ~/.phpenv/versions/$(phpenv version-name)/etc/php.ini
+
+script:
+  - git clone -b master https://github.com/spryker-middleware/middleware-ci.git middleware-ci
+  - ./middleware-ci/build/travis.sh

README.md

@@ -1,6 +1,8 @@
 # Process Module
 
 Process module is a module that contains all basic staff for middleware processes.
+[![Build Status](https://travis-ci.org/spryker-middleware/process.svg?branch=master)](https://travis-ci.org/spryker-middleware/process)
+
 
 ## Installation
 

codeception.yml

@@ -0,0 +1,21 @@
+namespace: SprykerMiddleware
+actor: Tester
+
+include:
+    - tests/SprykerMiddlewareTest/Zed/Process
+
+paths:
+    tests: tests
+    log: tests/_output
+    data: tests/_data
+    support: tests/_support
+    envs: tests/_envs
+settings:
+    bootstrap: _bootstrap.php
+    suite_class: \PHPUnit_Framework_TestSuite
+    colors: true
+    memory_limit: 1024M
+    log: true
+coverage:
+    enabled: true
+    whitelist: { include: ['src/*'] }

composer.json

@@ -4,20 +4,38 @@
     "license": "MIT",
     "minimum-stability": "dev",
     "require": {
-        "league/pipeline": "^0.3.0",
-        "spryker/console": "^3.0.0",
+        "php": ">=7.1",
+        "spryker/console": "^4.0.0",
         "spryker/development": "^3.0.0",
-        "spryker/transfer": "^3.4.0"
+        "spryker/transfer": "^3.4.0",
+        "spryker/util-encoding": "^2.0.0",
+        "spryker-middleware/logger": "^1.0.0"
+    },
+    "require-dev": {
+        "spryker/calculation": "*",
+        "spryker/cart": "*",
+        "spryker/code-sniffer": "*",
+        "spryker/propel": "*",
+        "spryker/silex": "*",
+        "spryker/testify": "*",
+        "spryker/transfer": "*"
     },
     "autoload": {
         "psr-4": {
-          "SprykerMiddleware\\": "src/SprykerMiddleware/"
+          "SprykerMiddleware\\": "src/SprykerMiddleware/",
+          "SprykerMiddlewareTest\\": "tests/SprykerMiddlewareTest/"
         }
     },
     "prefer-stable": true,
     "config": {
         "preferred-install": "dist",
         "sort-packages": true,
         "process-timeout": 600
-    }
+    },
+    "repositories": [
+        {
+            "type": "composer",
+            "url": "https://code.spryker.com/repo/private"
+        }
+    ]
 }

src/SprykerMiddleware/Service/Process/Model/StreamService.php

@@ -0,0 +1,43 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Service\Process\Model;
+
+use SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface;
+use SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface;
+
+class StreamService implements StreamServiceInterface
+{
+    /**
+     * Stream service
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface $stream
+     *
+     * @return mixed
+     */
+    public function read(ReadStreamInterface $stream)
+    {
+        return $stream->read();
+    }
+
+    /**
+     * Stream service
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface $stream
+     * @param array $data
+     *
+     * @return bool|int
+     */
+    public function write(WriteStreamInterface $stream, $data)
+    {
+        return $stream->write($data);
+    }
+}

src/SprykerMiddleware/Service/Process/Model/StreamServiceInterface.php

@@ -0,0 +1,37 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Service\Process\Model;
+
+use SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface;
+use SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface;
+
+interface StreamServiceInterface
+{
+    /**
+     * Stream service interface.
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface $stream
+     *
+     * @return mixed
+     */
+    public function read(ReadStreamInterface $stream);
+
+    /**
+     * Stream service interface.
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface $stream
+     * @param mixed $data
+     *
+     * @return mixed
+     */
+    public function write(WriteStreamInterface $stream, $data);
+}

src/SprykerMiddleware/Service/Process/ProcessDependencyProvider.php

@@ -0,0 +1,14 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Service\Process;
+
+use Spryker\Service\Kernel\AbstractBundleDependencyProvider;
+
+class ProcessDependencyProvider extends AbstractBundleDependencyProvider
+{
+}

src/SprykerMiddleware/Service/Process/ProcessService.php

@@ -0,0 +1,51 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Service\Process;
+
+use Spryker\Service\Kernel\AbstractService;
+use SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface;
+use SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface;
+
+/**
+ * @method \SprykerMiddleware\Service\Process\ProcessServiceFactory getFactory();
+ */
+class ProcessService extends AbstractService implements ProcessServiceInterface
+{
+    /**
+     * {@inheritdoc}
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface $stream
+     *
+     * @return mixed
+     */
+    public function read(ReadStreamInterface $stream)
+    {
+        return $this->getFactory()
+            ->createStreamService()
+            ->read($stream);
+    }
+
+    /**
+     * {@inheritdoc}
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface $stream
+     * @param mixed $data
+     *
+     * @return int
+     */
+    public function write(WriteStreamInterface $stream, $data): int
+    {
+        return $this->getFactory()
+            ->createStreamService()
+            ->write($stream, $data);
+    }
+}

src/SprykerMiddleware/Service/Process/ProcessServiceFactory.php

@@ -0,0 +1,23 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Service\Process;
+
+use Spryker\Service\Kernel\AbstractServiceFactory;
+use SprykerMiddleware\Service\Process\Model\StreamService;
+use SprykerMiddleware\Service\Process\Model\StreamServiceInterface;
+
+class ProcessServiceFactory extends AbstractServiceFactory
+{
+    /**
+     * @return \SprykerMiddleware\Service\Process\Model\StreamServiceInterface
+     */
+    public function createStreamService(): StreamServiceInterface
+    {
+        return new StreamService();
+    }
+}

src/SprykerMiddleware/Service/Process/ProcessServiceInterface.php

@@ -0,0 +1,39 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Service\Process;
+
+use SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface;
+use SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface;
+
+interface ProcessServiceInterface
+{
+    /**
+     * Specification:
+     * - Read data from given stream.
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\ReadStreamInterface $stream
+     *
+     * @return mixed
+     */
+    public function read(ReadStreamInterface $stream);
+
+    /**
+     * Specification:
+     * - Write given data to given stream.
+     *
+     * @api
+     *
+     * @param \SprykerMiddleware\Shared\Process\Stream\WriteStreamInterface $stream
+     * @param mixed $data
+     *
+     * @return int
+     */
+    public function write(WriteStreamInterface $stream, $data): int;
+}

src/SprykerMiddleware/Shared/Process/ProcessConstants.php

@@ -0,0 +1,12 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Shared\Process;
+
+interface ProcessConstants
+{
+}

src/SprykerMiddleware/Shared/Process/Stream/ReadStreamInterface.php

@@ -0,0 +1,16 @@
+<?php
+
+/**
+ * Copyright © 2016-present Spryker Systems GmbH. All rights reserved.
+ * Use of this software requires acceptance of the Evaluation License Agreement. See LICENSE file.
+ */
+
+namespace SprykerMiddleware\Shared\Process\Stream;
+
+interface ReadStreamInterface extends StreamInterface
+{
+    /**
+     * @return mixed
+     */
+    public function read();
+}