diff options
| -rw-r--r-- | .gitignore | 1 | ||||
| -rw-r--r-- | LICENSE | 25 | ||||
| -rw-r--r-- | README.md | 36 | ||||
| -rw-r--r-- | composer.json | 15 | ||||
| -rw-r--r-- | example/composer.json | 11 | ||||
| -rw-r--r-- | example/composer.lock | 37 | ||||
| -rw-r--r-- | example/create-tasks.php | 17 | ||||
| -rw-r--r-- | example/example.php | 14 | ||||
| -rw-r--r-- | example/vendor/autoload.php | 7 | ||||
| l--------- | example/vendor/ch1p/jobd-client | 1 | ||||
| -rw-r--r-- | example/vendor/composer/ClassLoader.php | 479 | ||||
| -rw-r--r-- | example/vendor/composer/InstalledVersions.php | 292 | ||||
| -rw-r--r-- | example/vendor/composer/LICENSE | 21 | ||||
| -rw-r--r-- | example/vendor/composer/autoload_classmap.php | 10 | ||||
| -rw-r--r-- | example/vendor/composer/autoload_namespaces.php | 9 | ||||
| -rw-r--r-- | example/vendor/composer/autoload_psr4.php | 10 | ||||
| -rw-r--r-- | example/vendor/composer/autoload_real.php | 55 | ||||
| -rw-r--r-- | example/vendor/composer/autoload_static.php | 36 | ||||
| -rw-r--r-- | example/vendor/composer/installed.json | 27 | ||||
| -rw-r--r-- | example/vendor/composer/installed.php | 33 | ||||
| -rw-r--r-- | src/Client.php | 153 | ||||
| -rw-r--r-- | src/Message.php | 36 | ||||
| -rw-r--r-- | src/RequestMessage.php | 40 | ||||
| -rw-r--r-- | src/ResponseMessage.php | 43 |
24 files changed, 1408 insertions, 0 deletions
diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..485dee6 --- /dev/null +++ b/.gitignore @@ -0,0 +1 @@ +.idea @@ -0,0 +1,25 @@ +BSD 2-Clause License + +Copyright (c) 2021, Evgeny Zinoviev +All rights reserved. + +Redistribution and use in source and binary forms, with or without +modification, are permitted provided that the following conditions are met: + +1. Redistributions of source code must retain the above copyright notice, this + list of conditions and the following disclaimer. + +2. Redistributions in binary form must reproduce the above copyright notice, + this list of conditions and the following disclaimer in the documentation + and/or other materials provided with the distribution. + +THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" +AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE +IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE +DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE +FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL +DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR +SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER +CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, +OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. diff --git a/README.md b/README.md new file mode 100644 index 0000000..80ab121 --- /dev/null +++ b/README.md @@ -0,0 +1,36 @@ +# php-jobd-client + +This is a simple PHP client for [jobd](https://github.com/gch1p/jobd). It can send +requests and read responses to/from *jobd* and *jobd-master* instances. + +## Installation + +``` +composer require ch1p/jobd-client +``` + +## Usage + +The API is compact and simple, just read the code of `Client.php`. + +Here's a small example. + +```php +try { + $jobd = new jobd\Client(jobd\Client::MASTER_PORT, '127.0.0.1'); +} catch (Exception $e) { + die('Failed to connect.'); +} + +// poke master to send poll requests to workers +$response = $jobd->poke(['target_name', 'another_name']); + +// get status from master +$response = $status = $jobd->status(); + +$jobd->close(); +``` + +## License + +BSD-2c
\ No newline at end of file diff --git a/composer.json b/composer.json new file mode 100644 index 0000000..8670223 --- /dev/null +++ b/composer.json @@ -0,0 +1,15 @@ +{ + "name": "ch1p/jobd-client", + "version": "1.0", + "repositories": [ + { + "type": "git", + "url": "https://github.com/gch1p/php-jobd-client" + } + ], + "autoload": { + "psr-4": { + "jobd\\": "src/" + } + } +}
\ No newline at end of file diff --git a/example/composer.json b/example/composer.json new file mode 100644 index 0000000..8bde4e7 --- /dev/null +++ b/example/composer.json @@ -0,0 +1,11 @@ +{ + "repositories": [ + { + "type": "path", + "url": "../" + } + ], + "require": { + "ch1p/jobd-client": "^1.0" + } +} diff --git a/example/composer.lock b/example/composer.lock new file mode 100644 index 0000000..c8416ff --- /dev/null +++ b/example/composer.lock @@ -0,0 +1,37 @@ +{ + "_readme": [ + "This file locks the dependencies of your project to a known state", + "Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies", + "This file is @generated automatically" + ], + "content-hash": "50c0d7581897dc28f75a92f41008c613", + "packages": [ + { + "name": "ch1p/jobd-client", + "version": "1.0", + "dist": { + "type": "path", + "url": "..", + "reference": "084d0d0e0ec68c71f414fa62c6c089aae51c1a9b" + }, + "type": "library", + "autoload": { + "psr-4": { + "jobd\\": "src/" + } + }, + "transport-options": { + "relative": true + } + } + ], + "packages-dev": [], + "aliases": [], + "minimum-stability": "stable", + "stability-flags": [], + "prefer-stable": false, + "prefer-lowest": false, + "platform": [], + "platform-dev": [], + "plugin-api-version": "2.0.0" +} diff --git a/example/create-tasks.php b/example/create-tasks.php new file mode 100644 index 0000000..35968a9 --- /dev/null +++ b/example/create-tasks.php @@ -0,0 +1,17 @@ +<?php + +$db = new mysqli(); +if (!$db->real_connect('10.211.55.6', 'jobd', 'password', 'jobd')) + die('Failed to connect.'); + +$target = 'server1'; +$slots = ['low', 'normal', 'high']; + +for ($i = 0; $i < 100; $i++) { + $slot = $slots[array_rand($slots)]; + $time = time(); + if (!$db->query("INSERT INTO jobs (target, slot, time_created, status) VALUES ('$target', '$slot', $time, 'waiting')")) + echo "{$db->error}\n"; +} + +$db->close();
\ No newline at end of file diff --git a/example/example.php b/example/example.php new file mode 100644 index 0000000..cc9cbd6 --- /dev/null +++ b/example/example.php @@ -0,0 +1,14 @@ +<?php + +require_once 'vendor/autoload.php'; + +try { + $client = new jobd\Client(jobd\Client::MASTER_PORT); +} catch (Exception $e) { + die($e->getMessage()); +} + +// $status = $client->status(); +// var_dump($status->getData()); + +var_dump($client->poke(['server1'])); diff --git a/example/vendor/autoload.php b/example/vendor/autoload.php new file mode 100644 index 0000000..c167c9a --- /dev/null +++ b/example/vendor/autoload.php @@ -0,0 +1,7 @@ +<?php + +// autoload.php @generated by Composer + +require_once __DIR__ . '/composer/autoload_real.php'; + +return ComposerAutoloaderInit5a87c37afe98e529b06f7be034379eab::getLoader(); diff --git a/example/vendor/ch1p/jobd-client b/example/vendor/ch1p/jobd-client new file mode 120000 index 0000000..1b20c9f --- /dev/null +++ b/example/vendor/ch1p/jobd-client @@ -0,0 +1 @@ +../../../
\ No newline at end of file diff --git a/example/vendor/composer/ClassLoader.php b/example/vendor/composer/ClassLoader.php new file mode 100644 index 0000000..247294d --- /dev/null +++ b/example/vendor/composer/ClassLoader.php @@ -0,0 +1,479 @@ +<?php + +/* + * This file is part of Composer. + * + * (c) Nils Adermann <naderman@naderman.de> + * Jordi Boggiano <j.boggiano@seld.be> + * + * For the full copyright and license information, please view the LICENSE + * file that was distributed with this source code. + */ + +namespace Composer\Autoload; + +/** + * ClassLoader implements a PSR-0, PSR-4 and classmap class loader. + * + * $loader = new \Composer\Autoload\ClassLoader(); + * + * // register classes with namespaces + * $loader->add('Symfony\Component', __DIR__.'/component'); + * $loader->add('Symfony', __DIR__.'/framework'); + * + * // activate the autoloader + * $loader->register(); + * + * // to enable searching the include path (eg. for PEAR packages) + * $loader->setUseIncludePath(true); + * + * In this example, if you try to use a class in the Symfony\Component + * namespace or one of its children (Symfony\Component\Console for instance), + * the autoloader will first look for the class under the component/ + * directory, and it will then fallback to the framework/ directory if not + * found before giving up. + * + * This class is loosely based on the Symfony UniversalClassLoader. + * + * @author Fabien Potencier <fabien@symfony.com> + * @author Jordi Boggiano <j.boggiano@seld.be> + * @see https://www.php-fig.org/psr/psr-0/ + * @see https://www.php-fig.org/psr/psr-4/ + */ +class ClassLoader +{ + private $vendorDir; + + // PSR-4 + private $prefixLengthsPsr4 = array(); + private $prefixDirsPsr4 = array(); + private $fallbackDirsPsr4 = array(); + + // PSR-0 + private $prefixesPsr0 = array(); + private $fallbackDirsPsr0 = array(); + + private $useIncludePath = false; + private $classMap = array(); + private $classMapAuthoritative = false; + private $missingClasses = array(); + private $apcuPrefix; + + private static $registeredLoaders = array(); + + public function __construct($vendorDir = null) + { + $this->vendorDir = $vendorDir; + } + + public function getPrefixes() + { + if (!empty($this->prefixesPsr0)) { + return call_user_func_array('array_merge', array_values($this->prefixesPsr0)); + } + + return array(); + } + + public function getPrefixesPsr4() + { + return $this->prefixDirsPsr4; + } + + public function getFallbackDirs() + { + return $this->fallbackDirsPsr0; + } + + public function getFallbackDirsPsr4() + { + return $this->fallbackDirsPsr4; + } + + public function getClassMap() + { + return $this->classMap; + } + + /** + * @param array $classMap Class to filename map + */ + public function addClassMap(array $classMap) + { + if ($this->classMap) { + $this->classMap = array_merge($this->classMap, $classMap); + } else { + $this->classMap = $classMap; + } + } + + /** + * Registers a set of PSR-0 directories for a given prefix, either + * appending or prepending to the ones previously set for this prefix. + * + * @param string $prefix The prefix + * @param array|string $paths The PSR-0 root directories + * @param bool $prepend Whether to prepend the directories + */ + public function add($prefix, $paths, $prepend = false) + { + if (!$prefix) { + if ($prepend) { + $this->fallbackDirsPsr0 = array_merge( + (array) $paths, + $this->fallbackDirsPsr0 + ); + } else { + $this->fallbackDirsPsr0 = array_merge( + $this->fallbackDirsPsr0, + (array) $paths + ); + } + + return; + } + + $first = $prefix[0]; + if (!isset($this->prefixesPsr0[$first][$prefix])) { + $this->prefixesPsr0[$first][$prefix] = (array) $paths; + + return; + } + if ($prepend) { + $this->prefixesPsr0[$first][$prefix] = array_merge( + (array) $paths, + $this->prefixesPsr0[$first][$prefix] + ); + } else { + $this->prefixesPsr0[$first][$prefix] = array_merge( + $this->prefixesPsr0[$first][$prefix], + (array) $paths + ); + } + } + + /** + * Registers a set of PSR-4 directories for a given namespace, either + * appending or prepending to the ones previously set for this namespace. + * + * @param string $prefix The prefix/namespace, with trailing '\\' + * @param array|string $paths The PSR-4 base directories + * @param bool $prepend Whether to prepend the directories + * + * @throws \InvalidArgumentException + */ + public function addPsr4($prefix, $paths, $prepend = false) + { + if (!$prefix) { + // Register directories for the root namespace. + if ($prepend) { + $this->fallbackDirsPsr4 = array_merge( + (array) $paths, + $this->fallbackDirsPsr4 + ); + } else { + $this->fallbackDirsPsr4 = array_merge( + $this->fallbackDirsPsr4, + (array) $paths + ); + } + } elseif (!isset($this->prefixDirsPsr4[$prefix])) { + // Register directories for a new namespace. + $length = strlen($prefix); + if ('\\' !== $prefix[$length - 1]) { + throw new \InvalidArgumentException("A non-empty PSR-4 prefix must end with a namespace separator."); + } + $this->prefixLengthsPsr4[$prefix[0]][$prefix] = $length; + $this->prefixDirsPsr4[$prefix] = (array) $paths; + } elseif ($prepend) { + // Prepend directories for an already registered namespace. + $this->prefixDirsPsr4[$prefix] = array_merge( + (array) $paths, + $this->prefixDirsPsr4[$prefix] + ); + } else { + // Append directories for an already registered namespace. + $this->prefixDirsPsr4[$prefix] = array_merge( + $this->prefixDirsPsr4[$prefix], + (array) $paths + ); + } + } + + /** + * Registers a set of PSR-0 directories for a given prefix, + * replacing any others previously set for this prefix. + * + * @param string $prefix The prefix + * @param array|string $paths The PSR-0 base directories + */ + public function set($prefix, $paths) + { + if (!$prefix) { + $this->fallbackDirsPsr0 = (array) $paths; + } else { + $this->prefixesPsr0[$prefix[0]][$prefix] = (array) $paths; + } + } + + /** + * Registers a set of PSR-4 directories for a given namespace, + * replacing any others previously set for this namespace. + * + * @param string $prefix The prefix/namespace, with trailing '\\' + * @param array|string $paths The PSR-4 base directories + * + * @throws \InvalidArgumentException + */ + public function setPsr4($prefix, $paths) + { + if (!$prefix) { + $this->fallbackDirsPsr4 = (array) $paths; + } else { + $length = strlen($prefix); + if ('\\' !== $prefix[$length - 1]) { + throw new \InvalidArgumentException("A non-empty PSR-4 prefix must end with a namespace separator."); + } + $this->prefixLengthsPsr4[$prefix[0]][$prefix] = $length; + $this->prefixDirsPsr4[$prefix] = (array) $paths; + } + } + + /** + * Turns on searching the include path for class files. + * + * @param bool $useIncludePath + */ + public function setUseIncludePath($useIncludePath) + { + $this->useIncludePath = $useIncludePath; + } + + /** + * Can be used to check if the autoloader uses the include path to check + * for classes. + * + * @return bool + */ + public function getUseIncludePath() + { + return $this->useIncludePath; + } + + /** + * Turns off searching the prefix and fallback directories for classes + * that have not been registered with the class map. + * + * @param bool $classMapAuthoritative + */ + public function setClassMapAuthoritative($classMapAuthoritative) + { + $this->classMapAuthoritative = $classMapAuthoritative; + } + + /** + * Should class lookup fail if not found in the current class map? + * + * @return bool + */ + public function isClassMapAuthoritative() + { + return $this->classMapAuthoritative; + } + + /** + * APCu prefix to use to cache found/not-found classes, if the extension is enabled. + * + * @param string|null $apcuPrefix + */ + public function setApcuPrefix($apcuPrefix) + { + $this->apcuPrefix = function_exists('apcu_fetch') && filter_var(ini_get('apc.enabled'), FILTER_VALIDATE_BOOLEAN) ? $apcuPrefix : null; + } + + /** + * The APCu prefix in use, or null if APCu caching is not enabled. + * + * @return string|null + */ + public function getApcuPrefix() + { + return $this->apcuPrefix; + } + + /** + * Registers this instance as an autoloader. + * + * @param bool $prepend Whether to prepend the autoloader or not + */ + public function register($prepend = false) + { + spl_autoload_register(array($this, 'loadClass'), true, $prepend); + + if (null === $this->vendorDir) { + return; + } + + if ($prepend) { + self::$registeredLoaders = array($this->vendorDir => $this) + self::$registeredLoaders; + } else { + unset(self::$registeredLoaders[$this->vendorDir]); + self::$registeredLoaders[$this->vendorDir] = $this; + } + } + + /** + * Unregisters this instance as an autoloader. + */ + public function unregister() + { + spl_autoload_unregister(array($this, 'loadClass')); + + if (null !== $this->vendorDir) { + unset(self::$registeredLoaders[$this->vendorDir]); + } + } + + /** + * Loads the given class or interface. + * + * @param string $class The name of the class + * @return bool|null True if loaded, null otherwise + */ + public function loadClass($class) + { + if ($file = $this->findFile($class)) { + includeFile($file); + + return true; + } + } + + /** + * Finds the path to the file where the class is defined. + * + * @param string $class The name of the class + * + * @return string|false The path if found, false otherwise + */ + public function findFile($class) + { + // class map lookup + if (isset($this->classMap[$class])) { + return $this->classMap[$class]; + } + if ($this->classMapAuthoritative || isset($this->missingClasses[$class])) { + return false; + } + if (null !== $this->apcuPrefix) { + $file = apcu_fetch($this->apcuPrefix.$class, $hit); + if ($hit) { + return $file; + } + } + + $file = $this->findFileWithExtension($class, '.php'); + + // Search for Hack files if we are running on HHVM + if (false === $file && defined('HHVM_VERSION')) { + $file = $this->findFileWithExtension($class, '.hh'); + } + + if (null !== $this->apcuPrefix) { + apcu_add($this->apcuPrefix.$class, $file); + } + + if (false === $file) { + // Remember that this class does not exist. + $this->missingClasses[$class] = true; + } + + return $file; + } + + /** + * Returns the currently registered loaders indexed by their corresponding vendor directories. + * + * @return self[] + */ + public static function getRegisteredLoaders() + { + return self::$registeredLoaders; + } + + private function findFileWithExtension($class, $ext) + { + // PSR-4 lookup + $logicalPathPsr4 = strtr($class, '\\', DIRECTORY_SEPARATOR) . $ext; + + $first = $class[0]; + if (isset($this->prefixLengthsPsr4[$first])) { + $subPath = $class; + while (false !== $lastPos = strrpos($subPath, '\\')) { + $subPath = substr($subPath, 0, $lastPos); + $search = $subPath . '\\'; + if (isset($this->prefixDirsPsr4[$search])) { + $pathEnd = DIRECTORY_SEPARATOR . substr($logicalPathPsr4, $lastPos + 1); + foreach ($this->prefixDirsPsr4[$search] as $dir) { + if (file_exists($file = $dir . $pathEnd)) { + return $file; + } + } + } + } + } + + // PSR-4 fallback dirs + foreach ($this->fallbackDirsPsr4 as $dir) { + if (file_exists($file = $dir . DIRECTORY_SEPARATOR . $logicalPathPsr4)) { + return $file; + } + } + + // PSR-0 lookup + if (false !== $pos = strrpos($class, '\\')) { + // namespaced class name + $logicalPathPsr0 = substr($logicalPathPsr4, 0, $pos + 1) + . strtr(substr($logicalPathPsr4, $pos + 1), '_', DIRECTORY_SEPARATOR); + } else { + // PEAR-like class name + $logicalPathPsr0 = strtr($class, '_', DIRECTORY_SEPARATOR) . $ext; + } + + if (isset($this->prefixesPsr0[$first])) { + foreach ($this->prefixesPsr0[$first] as $prefix => $dirs) { + if (0 === strpos($class, $prefix)) { + foreach ($dirs as $dir) { + if (file_exists($file = $dir . DIRECTORY_SEPARATOR . $logicalPathPsr0)) { + return $file; + } + } + } + } + } + + // PSR-0 fallback dirs + foreach ($this->fallbackDirsPsr0 as $dir) { + if (file_exists($file = $dir . DIRECTORY_SEPARATOR . $logicalPathPsr0)) { + return $file; + } + } + + // PSR-0 include paths. + if ($this->useIncludePath && $file = stream_resolve_include_path($logicalPathPsr0)) { + return $file; + } + + return false; + } +} + +/** + * Scope isolated include. + * + * Prevents access to $this/self from included files. + */ +function includeFile($file) +{ + include $file; +} diff --git a/example/vendor/composer/InstalledVersions.php b/example/vendor/composer/InstalledVersions.php new file mode 100644 index 0000000..bbb8f24 --- /dev/null +++ b/example/vendor/composer/InstalledVersions.php @@ -0,0 +1,292 @@ +<?php + + + + + + + + + + + +namespace Composer; + +use Composer\Autoload\ClassLoader; +use Composer\Semver\VersionParser; + + + + + + +class InstalledVersions +{ +private static $installed = array ( + 'root' => + array ( + 'pretty_version' => '1.0.0+no-version-set', + 'version' => '1.0.0.0', + 'aliases' => + array ( + ), + 'reference' => NULL, + 'name' => '__root__', + ), + 'versions' => + array ( + '__root__' => + array ( + 'pretty_version' => '1.0.0+no-version-set', + 'version' => '1.0.0.0', + 'aliases' => + array ( + ), + 'reference' => NULL, + ), + 'ch1p/jobd-client' => + array ( + 'pretty_version' => '1.0', + 'version' => '1.0.0.0', + 'aliases' => + array ( + ), + 'reference' => '084d0d0e0ec68c71f414fa62c6c089aae51c1a9b', + ), + ), +); +private static $canGetVendors; +private static $installedByVendor = array(); + + + + + + + +public static function getInstalledPackages() +{ +$packages = array(); +foreach (self::getInstalled() as $installed) { +$packages[] = array_keys($installed['versions']); +} + + +if (1 === \count($packages)) { +return $packages[0]; +} + +return array_keys(array_flip(\call_user_func_array('array_merge', $packages))); +} + + + + + + + + + +public static function isInstalled($packageName) +{ +foreach (self::getInstalled() as $installed) { +if (isset($installed['versions'][$packageName])) { +return true; +} +} + +return false; +} + + + + + + + + + + + + + + +public static function satisfies(VersionParser $parser, $packageName, $constraint) +{ +$constraint = $parser->parseConstraints($constraint); +$provided = $parser->parseConstraints(self::getVersionRanges($packageName)); + +return $provided->matches($constraint); +} + + + + + + + + + + +public static function getVersionRanges($packageName) +{ +foreach (self::getInstalled() as $installed) { +if (!isset($installed['versions'][$packageName])) { +continue; +} + +$ranges = array(); +if (isset($installed['versions'][$packageName]['pretty_version'])) { +$ranges[] = $installed['versions'][$packageName]['pretty_version']; +} +if (array_key_exists('aliases', $installed['versions'][$packageName])) { +$ranges = array_merge($ranges, $installed['versions'][$packageName]['aliases']); +} +if (array_key_exists('replaced', $installed['versions'][$packageName])) { +$ranges = array_merge($ranges, $installed['versions'][$packageName]['replaced']); +} +if (array_key_exists('provided', $installed['versions'][$packageName])) { +$ranges = array_merge($ranges, $installed['versions'][$packageName]['provided']); +} + +return implode(' || ', $ranges); +} + +throw new \OutOfBoundsException('Package "' . $packageName . '" is not installed'); +} + + + + + +public static function getVersion($packageName) +{ +foreach (self::getInstalled() as $installed) { +if (!isset($installed['versions'][$packageName])) { +continue; +} + +if (!isset($installed['versions'][$packageName]['version'])) { +return null; +} + +return $installed['versions'][$packageName]['version']; +} + +throw new \OutOfBoundsException('Package "' . $packageName . '" is not installed'); +} + + + + + +public static function getPrettyVersion($packageName) +{ +foreach (self::getInstalled() as $installed) { +if (!isset($installed['versions'][$packageName])) { +continue; +} + +if (!isset($installed['versions'][$packageName]['pretty_version'])) { +return null; +} + +return $installed['versions'][$packageName]['pretty_version']; +} + +throw new \OutOfBoundsException('Package "' . $packageName . '" is not installed'); +} + + + + + +public static function getReference($packageName) +{ +foreach (self::getInstalled() as $installed) { +if (!isset($installed['versions'][$packageName])) { +continue; +} + +if (!isset($installed['versions'][$packageName]['reference'])) { +return null; +} + +return $installed['versions'][$packageName]['reference']; +} + +throw new \OutOfBoundsException('Package "' . $packageName . '" is not installed'); +} + + + + + +public static function getRootPackage() +{ +$installed = self::getInstalled(); + +return $installed[0]['root']; +} + + + + + + + +public static function getRawData() +{ +return self::$installed; +} + + + + + + + + + + + + + + + + + + + +public static function reload($data) +{ +self::$installed = $data; +self::$installedByVendor = array(); +} + + + + +private static function getInstalled() +{ +if (null === self::$canGetVendors) { +self::$canGetVendors = method_exists('Composer\Autoload\ClassLoader', 'getRegisteredLoaders'); +} + +$installed = array(); + +if (self::$canGetVendors) { +foreach (ClassLoader::getRegisteredLoaders() as $vendorDir => $loader) { +if (isset(self::$installedByVendor[$vendorDir])) { +$installed[] = self::$installedByVendor[$vendorDir]; +} elseif (is_file($vendorDir.'/composer/installed.php')) { +$installed[] = self::$installedByVendor[$vendorDir] = require $vendorDir.'/composer/installed.php'; +} +} +} + +$installed[] = self::$installed; + +return $installed; +} +} diff --git a/example/vendor/composer/LICENSE b/example/vendor/composer/LICENSE new file mode 100644 index 0000000..f27399a --- /dev/null +++ b/example/vendor/composer/LICENSE @@ -0,0 +1,21 @@ + +Copyright (c) Nils Adermann, Jordi Boggiano + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is furnished +to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in all +copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. + diff --git a/example/vendor/composer/autoload_classmap.php b/example/vendor/composer/autoload_classmap.php new file mode 100644 index 0000000..b26f1b1 --- /dev/null +++ b/example/vendor/composer/autoload_classmap.php @@ -0,0 +1,10 @@ +<?php + +// autoload_classmap.php @generated by Composer + +$vendorDir = dirname(dirname(__FILE__)); +$baseDir = dirname($vendorDir); + +return array( + 'Composer\\InstalledVersions' => $vendorDir . '/composer/InstalledVersions.php', +); diff --git a/example/vendor/composer/autoload_namespaces.php b/example/vendor/composer/autoload_namespaces.php new file mode 100644 index 0000000..b7fc012 --- /dev/null +++ b/example/vendor/composer/autoload_namespaces.php @@ -0,0 +1,9 @@ +<?php + +// autoload_namespaces.php @generated by Composer + +$vendorDir = dirname(dirname(__FILE__)); +$baseDir = dirname($vendorDir); + +return array( +); diff --git a/example/vendor/composer/autoload_psr4.php b/example/vendor/composer/autoload_psr4.php new file mode 100644 index 0000000..98f76a0 --- /dev/null +++ b/example/vendor/composer/autoload_psr4.php @@ -0,0 +1,10 @@ +<?php + +// autoload_psr4.php @generated by Composer + +$vendorDir = dirname(dirname(__FILE__)); +$baseDir = dirname($vendorDir); + +return array( + 'jobd\\' => array($vendorDir . '/ch1p/jobd-client/src'), +); diff --git a/example/vendor/composer/autoload_real.php b/example/vendor/composer/autoload_real.php new file mode 100644 index 0000000..f67c9e6 --- /dev/null +++ b/example/vendor/composer/autoload_real.php @@ -0,0 +1,55 @@ +<?php + +// autoload_real.php @generated by Composer + +class ComposerAutoloaderInit5a87c37afe98e529b06f7be034379eab +{ + private static $loader; + + public static function loadClassLoader($class) + { + if ('Composer\Autoload\ClassLoader' === $class) { + require __DIR__ . '/ClassLoader.php'; + } + } + + /** + * @return \Composer\Autoload\ClassLoader + */ + public static function getLoader() + { + if (null !== self::$loader) { + return self::$loader; + } + + spl_autoload_register(array('ComposerAutoloaderInit5a87c37afe98e529b06f7be034379eab', 'loadClassLoader'), true, true); + self::$loader = $loader = new \Composer\Autoload\ClassLoader(\dirname(\dirname(__FILE__))); + spl_autoload_unregister(array('ComposerAutoloaderInit5a87c37afe98e529b06f7be034379eab', 'loadClassLoader')); + + $useStaticLoader = PHP_VERSION_ID >= 50600 && !defined('HHVM_VERSION') && (!function_exists('zend_loader_file_encoded') || !zend_loader_file_encoded()); + if ($useStaticLoader) { + require __DIR__ . '/autoload_static.php'; + + call_user_func(\Composer\Autoload\ComposerStaticInit5a87c37afe98e529b06f7be034379eab::getInitializer($loader)); + } else { + $map = require __DIR__ . '/autoload_namespaces.php'; + foreach ($map as $namespace => $path) { + $loader->set($namespace, $path); + } + + $map = require __DIR__ . '/autoload_psr4.php'; + foreach ($map as $namespace => $path) { + $loader->setPsr4($namespace, $path); + } + + $classMap = require __DIR__ . '/autoload_classmap.php'; + if ($classMap) { + $loader->addClassMap($classMap); + } + } + + $loader->register(true); + + return $loader; + } +} diff --git a/example/vendor/composer/autoload_static.php b/example/vendor/composer/autoload_static.php new file mode 100644 index 0000000..f83e924 --- /dev/null +++ b/example/vendor/composer/autoload_static.php @@ -0,0 +1,36 @@ +<?php + +// autoload_static.php @generated by Composer + +namespace Composer\Autoload; + +class ComposerStaticInit5a87c37afe98e529b06f7be034379eab +{ + public static $prefixLengthsPsr4 = array ( + 'j' => + array ( + 'jobd\\' => 5, + ), + ); + + public static $prefixDirsPsr4 = array ( + 'jobd\\' => + array ( + 0 => __DIR__ . '/..' . '/ch1p/jobd-client/src', + ), + ); + + public static $classMap = array ( + 'Composer\\InstalledVersions' => __DIR__ . '/..' . '/composer/InstalledVersions.php', + ); + + public static function getInitializer(ClassLoader $loader) + { + return \Closure::bind(function () use ($loader) { + $loader->prefixLengthsPsr4 = ComposerStaticInit5a87c37afe98e529b06f7be034379eab::$prefixLengthsPsr4; + $loader->prefixDirsPsr4 = ComposerStaticInit5a87c37afe98e529b06f7be034379eab::$prefixDirsPsr4; + $loader->classMap = ComposerStaticInit5a87c37afe98e529b06f7be034379eab::$classMap; + + }, null, ClassLoader::class); + } +} diff --git a/example/vendor/composer/installed.json b/example/vendor/composer/installed.json new file mode 100644 index 0000000..2b56af1 --- /dev/null +++ b/example/vendor/composer/installed.json @@ -0,0 +1,27 @@ +{ + "packages": [ + { + "name": "ch1p/jobd-client", + "version": "1.0", + "version_normalized": "1.0.0.0", + "dist": { + "type": "path", + "url": "..", + "reference": "084d0d0e0ec68c71f414fa62c6c089aae51c1a9b" + }, + "type": "library", + "installation-source": "dist", + "autoload": { + "psr-4": { + "jobd\\": "src/" + } + }, + "transport-options": { + "relative": true + }, + "install-path": "../ch1p/jobd-client" + } + ], + "dev": true, + "dev-package-names": [] +} diff --git a/example/vendor/composer/installed.php b/example/vendor/composer/installed.php new file mode 100644 index 0000000..340e0fe --- /dev/null +++ b/example/vendor/composer/installed.php @@ -0,0 +1,33 @@ +<?php return array ( + 'root' => + array ( + 'pretty_version' => '1.0.0+no-version-set', + 'version' => '1.0.0.0', + 'aliases' => + array ( + ), + 'reference' => NULL, + 'name' => '__root__', + ), + 'versions' => + array ( + '__root__' => + array ( + 'pretty_version' => '1.0.0+no-version-set', + 'version' => '1.0.0.0', + 'aliases' => + array ( + ), + 'reference' => NULL, + ), + 'ch1p/jobd-client' => + array ( + 'pretty_version' => '1.0', + 'version' => '1.0.0.0', + 'aliases' => + array ( + ), + 'reference' => '084d0d0e0ec68c71f414fa62c6c089aae51c1a9b', + ), + ), +); diff --git a/src/Client.php b/src/Client.php new file mode 100644 index 0000000..54427f4 --- /dev/null +++ b/src/Client.php @@ -0,0 +1,153 @@ +<?php + +namespace jobd; + + +class Client { + + const WORKER_PORT = 13596; + const MASTER_PORT = 13597; + + const EOT = "\4"; + + protected $host; + protected $port; + protected $password; + protected $sock; + + /** + * JobdClient constructor. + * @param int $port + * @param string $host + * @param string $password + */ + public function __construct(int $port, string $host = '127.0.0.1', string $password = '') { + $this->port = $port; + $this->host = $host; + $this->password = $password; + + $this->sock = fsockopen($this->host, $this->port); + if (!$this->sock) + throw new \Exception("Failed to connect to {$this->host}:{$this->port}"); + } + + /** + * @return mixed + */ + public function ping() { + $this->send(new RequestMessage('ping')); + return $this->recv(); + } + + /** + * @param array $targets + * @return mixed + */ + public function poke(array $targets) { + $this->send(new RequestMessage('poke', ['targets' => $targets])); + return $this->recv(); + } + + /** + * @return mixed + */ + public function status() { + $this->send(new RequestMessage('status')); + return $this->recv(); + } + + public function poll(array $targets) { + $this->send(new RequestMessage('poll', ['targets' => $targets])); + return $this->recv(); + } + + /** + * @param int $id + * @return mixed + */ + public function runManual(int $id) { + $this->send(new RequestMessage('run-manual', ['id' => $id])); + return $this->recv(); + } + + /** + * @param RequestMessage $request + */ + public function send(RequestMessage $request) { + if ($this->password) + $request->setPassword($this->password); + + $serialized = $request->serialize(); + + fwrite($this->sock, $serialized . self::EOT); + } + + /** + * @return mixed + */ + public function recv() { + $messages = []; + $buf = ''; + while (!feof($this->sock)) { + $buf .= fread($this->sock, 1024); + $buflen = strlen($buf); + if ($buflen > 0 && $buf[$buflen-1] == self::EOT) + break; + } + + $offset = 0; + $eot_pos = 0; + do { + $eot_pos = strpos($buf, self::EOT, $offset); + if ($eot_pos !== false) { + $message = substr($buf, $offset, $eot_pos); + $messages[] = $message; + + $offset = $eot_pos + 1; + } + } while ($eot_pos !== false && $offset < $buflen-1); + + if (empty($message)) + throw new \Exception("Malformed response: no messages found. Response: {$buf}"); + + if (count($messages) > 1) + trigger_error(__METHOD__.": received more than one message"); + + return self::parseMessage($messages[0]); + } + + protected static function parseMessage(string $raw_string) { + $raw = json_decode($raw_string, true); + if (!is_array($raw) || count($raw) != 2) + throw new \Exception("Malformed response: {$raw_string}"); + + list($type, $data) = $raw; + + switch ($type) { + case Message::REQUEST: + if (!$data || !is_array($data) || !isset($data['type']) || !is_string($data['type'])) + throw new \Exception('Malformed REQUEST message'); + + $message = new RequestMessage($data['type'], $data['data'] ?? null); + if (isset($data['password'])) + $message->setPassword($data['password']); + + return $message; + + case Message::RESPONSE: + if (!is_array($data) || count($data) < 2) + throw new \Exception('Malformed RESPONSE message'); + + $message = new ResponseMessage(...$data); + return $message; + } + } + + /** + * @return bool + */ + public function close() { + return fclose($this->sock); + } + +}
\ No newline at end of file diff --git a/src/Message.php b/src/Message.php new file mode 100644 index 0000000..647afad --- /dev/null +++ b/src/Message.php @@ -0,0 +1,36 @@ +<?php + +namespace jobd; + + +abstract class Message { + + const REQUEST = 0; + const RESPONSE = 1; + + protected $type; + + /** + * Message constructor. + * @param int $type + */ + public function __construct(int $type) { + $this->type = $type; + } + + /** + * @return array + */ + abstract protected function getContent(): array; + + /** + * @return string + */ + public function serialize(): string { + return json_encode([ + $this->type, + $this->getContent() + ]); + } + +}
\ No newline at end of file diff --git a/src/RequestMessage.php b/src/RequestMessage.php new file mode 100644 index 0000000..46dfba3 --- /dev/null +++ b/src/RequestMessage.php @@ -0,0 +1,40 @@ +<?php + +namespace jobd; + +class RequestMessage extends Message { + + protected $requestType; + protected $requestData; + protected $password; + + /** + * Request constructor. + * @param string $request_type + * @param null $request_data + */ + public function __construct(string $request_type, $request_data = null) { + parent::__construct(Message::REQUEST); + + $this->requestData = $request_data; + $this->requestType = $request_type; + } + + /** + * @param string $password + */ + public function setPassword(string $password) { + $this->password = $password; + } + + /** + * @return string[] + */ + public function getContent(): array { + $request = ['type' => $this->requestType]; + if (!is_null($this->requestData)) + $request['data'] = $this->requestData; + return $request; + } + +}
\ No newline at end of file diff --git a/src/ResponseMessage.php b/src/ResponseMessage.php new file mode 100644 index 0000000..fa54c29 --- /dev/null +++ b/src/ResponseMessage.php @@ -0,0 +1,43 @@ +<?php + +namespace jobd; + +class ResponseMessage extends Message { + + protected $error; + protected $data; + + /** + * Response constructor. + * @param null $error + * @param null $data + */ + public function __construct($error = null, $data = null) { + parent::__construct(Message::RESPONSE); + + $this->error = $error; + $this->data = $data; + } + + /** + * @return array + */ + public function getContent(): array { + return [$this->error, $this->data]; + } + + /** + * @return mixed + */ + public function getError() { + return $this->error; + } + + /** + * @return mixed + */ + public function getData() { + return $this->data; + } + +}
\ No newline at end of file |