* * @author Marcel Klehr * * @license GNU AGPL version 3 or any later version * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as * published by the Free Software Foundation, either version 3 of the * License, or (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . */ namespace OC\TextProcessing\Db; use OCP\AppFramework\Db\Entity; use OCP\TextProcessing\Task as OCPTask; /** * @method setType(string $type) * @method string getType() * @method setLastUpdated(int $lastUpdated) * @method int getLastUpdated() * @method setInput(string $type) * @method string getInput() * @method setOutput(string $type) * @method string getOutput() * @method setStatus(int $type) * @method int getStatus() * @method setUserId(?string $userId) * @method string|null getUserId() * @method setAppId(string $type) * @method string getAppId() * @method setIdentifier(string $identifier) * @method string getIdentifier() * @method setCompletionExpectedAt(null|\DateTime $completionExpectedAt) * @method null|\DateTime getCompletionExpectedAt() */ class Task extends Entity { protected $lastUpdated; protected $type; protected $input; protected $output; protected $status; protected $userId; protected $appId; protected $identifier; protected $completionExpectedAt; /** * @var string[] */ public static array $columns = ['id', 'last_updated', 'type', 'input', 'output', 'status', 'user_id', 'app_id', 'identifier', 'completion_expected_at']; /** * @var string[] */ public static array $fields = ['id', 'lastUpdated', 'type', 'input', 'output', 'status', 'userId', 'appId', 'identifier', 'completionExpectedAt']; public function __construct() { // add types in constructor $this->addType('id', 'integer'); $this->addType('lastUpdated', 'integer'); $this->addType('type', 'string'); $this->addType('input', 'string'); $this->addType('output', 'string'); $this->addType('status', 'integer'); $this->addType('userId', 'string'); $this->addType('appId', 'string'); $this->addType('identifier', 'string'); $this->addType('completionExpectedAt', 'datetime'); } public function toRow(): array { return array_combine(self::$columns, array_map(function ($field) { return $this->{'get'.ucfirst($field)}(); }, self::$fields)); } public static function fromPublicTask(OCPTask $task): Task { /** @var Task $task */ $task = Task::fromParams([ 'id' => $task->getId(), 'type' => $task->getType(), 'lastUpdated' => time(), 'status' => $task->getStatus(), 'input' => $task->getInput(), 'output' => $task->getOutput(), 'userId' => $task->getUserId(), 'appId' => $task->getAppId(), 'identifier' => $task->getIdentifier(), 'completionExpectedAt' => $task->getCompletionExpectedAt(), ]); return $task; } public function toPublicTask(): OCPTask { $task = new OCPTask($this->getType(), $this->getInput(), $this->getAppId(), $this->getuserId(), $this->getIdentifier()); $task->setId($this->getId()); $task->setStatus($this->getStatus()); $task->setOutput($this->getOutput()); $task->setCompletionExpectedAt($this->getCompletionExpectedAt()); return $task; } }