Skip to content

Commit ffa930e

Browse files
committed
Improve API
1 parent 4deaa44 commit ffa930e

File tree

3 files changed

+21
-6
lines changed

3 files changed

+21
-6
lines changed

src/WorkerJS/PHPClient/Client.php

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,17 @@ public function getSetting($name){
4646
}
4747
}
4848

49+
public function getTaskByID($taskID){
50+
$taskStore = $this->getTaskStore();
51+
52+
$task = $taskStore->getTask($taskID);
53+
$task["taskID"] = $taskID;
54+
55+
$task = $this->newTask($task);
56+
57+
return $task;
58+
}
59+
4960
public function getTaskMessageRouter(){
5061
return $this->taskMessageRouter;
5162
}

src/WorkerJS/PHPClient/Task.php

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,15 @@ public function getTask()
3333
return $this->task;
3434
}
3535

36+
public function getTaskID()
37+
{
38+
if(isset($this->task["taskID"])){
39+
return $this->task["taskID"];
40+
} else {
41+
throw \Exception("TaskID is not defined yet, you need to send task first. ");
42+
}
43+
}
44+
3645
public function setParams($body){
3746
$this->task["task"] = $body;
3847
$this->preProcessParams();

src/WorkerJS/PHPClient/TaskMessageRequestHandler.php

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -21,12 +21,7 @@ public function handleRequest(string $body){
2121

2222
$taskID = $body->taskID;
2323

24-
$taskStore = $this->client->getTaskStore();
25-
26-
$task = $taskStore->getTask($taskID);
27-
$task["taskID"] = $taskID;
28-
29-
$task = $this->client->newTask($task);
24+
$task = $this->client->getTaskByID($taskID);
3025

3126
$handlerName = $body->name;
3227

0 commit comments

Comments
 (0)