Add methods uploadUpstream uploadUpstreamsFromFile

Author: Pavlusha311245

src/Config.php

@@ -16,7 +16,7 @@
  *
  * @implements ConfigInterface
  */
-class Config implements ConfigInterface
+class Config implements ConfigInterface, Arrayable
 {
     /**
      * Listeners that accept requests
@@ -410,6 +410,54 @@ public function getUpstreams(): array
         return $this->_upstreams;
     }
 
+    /**
+     * @inheritDoc
+     * @throws UnitException
+     */
+    public function uploadUpstream(Upstream $upstream, string $name = ''): bool
+    {
+        if (empty($upstream->getName()) && empty($name)) {
+            throw new UnitException('Name isn\'t be empty');
+        }
+
+        $upstreamName = empty($upstream->getName()) ? $name : $upstream->getName();
+
+        try {
+            $this->_unitRequest->setMethod(HttpMethodsEnum::PUT->value);
+            $this->_unitRequest->setData(json_encode($upstream->toJson()));
+            $this->_unitRequest->send("/config/upstreams/{$upstreamName}");
+        } catch (UnitException $exception) {
+            print_r($exception->getMessage());
+            return false;
+        }
+
+        return true;
+    }
+
+    public function uploadUpstreamsFromFile(string $path): bool
+    {
+        $fileContent = file_get_contents($path);
+
+        if (!$fileContent) {
+            throw new FileNotFoundException();
+        }
+
+        if (empty(json_decode($fileContent, true))) {
+            throw new UnitException('It\'s not a JSON file');
+        }
+
+        try {
+            $this->_unitRequest->setMethod(HttpMethodsEnum::PUT->value);
+            $this->_unitRequest->setData(json_encode($fileContent));
+            $this->_unitRequest->send('/config/upstreams');
+        } catch (UnitException $exception) {
+            print_r($exception->getMessage());
+            return false;
+        }
+
+        return true;
+    }
+
     /**
      * @inheritDoc
      */

src/Contracts/ConfigInterface.php

@@ -114,6 +114,23 @@ public function removeApplication(ApplicationAbstract|string $application): bool
      */
     public function getUpstreams(): array;
 
+    /**
+     * Upload Upstream object to nginx Unit
+     *
+     * @param Upstream $upstream
+     * @param string $name
+     * @return mixed
+     */
+    public function uploadUpstream(Upstream $upstream, string $name): bool;
+
+    /**
+     * Upload all upstreams from file to Nginx Unit
+     *
+     * @param string $path
+     * @return mixed
+     */
+    public function uploadUpstreamsFromFile(string $path): bool;
+
     /**
      * Setup access log file
      *