Added lock and unlock

Author: Miljan9602

.idea/workspace.xml

@@ -16,5 +16,8 @@
         }
     },
     "minimum-stability": "dev",
-    "require": {}
+    "require": {
+        "ext-pgsql": "*",
+        "ext-json": "*"
+    }
 }

composer.json

@@ -41,9 +41,13 @@ public function sendTask() {
 
         $payload['webhook'] = $webhook;
 
-		$taskResponse = $this->sendRequest($url, $payload);
+        $this->client->getTaskStore()->lock();
 
+		$taskResponse = $this->sendRequest($url, $payload);
 		$this->client->getTaskStore()->setTask($taskResponse["taskID"], $this);
+
+        $this->client->getTaskStore()->unlock();
+
 		return $taskResponse["taskID"];
 	}
 

src/WorkerJS/PHPClient/HTTPClientTask.php

@@ -37,5 +37,13 @@ public function getTask($taskID) {
 	public function setTask($taskID, Task $task) {
 		pg_query($this->connection, "INSERT INTO tasks (\"taskID\", task) VALUES ('".pg_escape_string($this->connection, $taskID)."', '".pg_escape_string($this->connection, json_encode($task->getTask()))."')");
 	}
+
+	public function lock() {
+        pg_query($this->connection,"BEGIN WORK; LOCK TABLE tasks IN ACCESS EXCLUSIVE MODE;");
+    }
+
+    public function unlock() {
+        pg_query($this->connection,"COMMIT WORK;");
+    }
  }
 

src/WorkerJS/PHPClient/PostgresTaskStore.php

@@ -17,6 +17,11 @@ public function __construct($client) {
 		$this->client = $client;
 	}
 
+    /**
+     * @param $taskID
+     * @param Task $task
+     * @return mixed
+     */
 	abstract public function setTask($taskID, Task $task);
 
 	/**
@@ -25,5 +30,15 @@ abstract public function setTask($taskID, Task $task);
 	 * @throws TaskNotFoundException
 	 */
 	abstract public function getTask($taskID);
+
+    /**
+     * @return mixed
+     */
+    abstract public function lock();
+
+    /**
+     * @return mixed
+     */
+    abstract public function unlock();
 }