Signed-off-by: Christopher Ng <chrng8@gmail.com>pull/39651/head
parent
9a7e2b1558
commit
e16001b8eb
@ -0,0 +1,56 @@ |
||||
<?php |
||||
|
||||
declare(strict_types=1); |
||||
|
||||
/** |
||||
* @copyright 2023 Christopher Ng <chrng8@gmail.com> |
||||
* |
||||
* @author Christopher Ng <chrng8@gmail.com> |
||||
* |
||||
* @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 <http://www.gnu.org/licenses/>. |
||||
* |
||||
*/ |
||||
|
||||
namespace OCA\FilesReminders\Db; |
||||
|
||||
use OCP\AppFramework\Db\Entity; |
||||
|
||||
/** |
||||
* @method void setUserId(string $userId) |
||||
* @method string getUserId() |
||||
* |
||||
* @method void setFileId(int $fileId) |
||||
* @method int getFileId() |
||||
* |
||||
* @method void setRemindAt(int $remindAt) |
||||
* @method int getRemindAt() |
||||
* |
||||
* @method void setNotified(bool $notified) |
||||
* @method bool getNotified() |
||||
*/ |
||||
class Reminder extends Entity { |
||||
protected string $userId; |
||||
protected int $fileId; |
||||
protected int $remindAt; |
||||
protected bool $notified = false; |
||||
|
||||
public function __construct() { |
||||
$this->addType('userId', 'string'); |
||||
$this->addType('fileId', 'integer'); |
||||
$this->addType('remindAt', 'integer'); |
||||
$this->addType('notified', 'boolean'); |
||||
} |
||||
} |
@ -0,0 +1,67 @@ |
||||
<?php |
||||
|
||||
declare(strict_types=1); |
||||
|
||||
/** |
||||
* @copyright 2023 Christopher Ng <chrng8@gmail.com> |
||||
* |
||||
* @author Christopher Ng <chrng8@gmail.com> |
||||
* |
||||
* @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 <http://www.gnu.org/licenses/>. |
||||
* |
||||
*/ |
||||
|
||||
namespace OCA\FilesReminders\Db; |
||||
|
||||
use OCP\AppFramework\Db\QBMapper; |
||||
use OCP\DB\QueryBuilder\IQueryBuilder; |
||||
use OCP\IDBConnection; |
||||
|
||||
/** |
||||
* @template-extends QBMapper<Reminder> |
||||
*/ |
||||
class ReminderMapper extends QBMapper { |
||||
public const TABLE_NAME = 'files_reminders'; |
||||
|
||||
public function __construct(IDBConnection $db) { |
||||
parent::__construct( |
||||
$db, |
||||
static::TABLE_NAME, |
||||
Reminder::class, |
||||
); |
||||
} |
||||
|
||||
public function markNotified(Reminder $reminder): Reminder { |
||||
$reminderUpdate = new Reminder(); |
||||
$reminderUpdate->setId($reminder->getId()); |
||||
$reminderUpdate->setNotified(true); |
||||
return parent::update($reminderUpdate); |
||||
} |
||||
|
||||
/** |
||||
* @return Reminder[] |
||||
*/ |
||||
public function findToRemind() { |
||||
$qb = $this->db->getQueryBuilder(); |
||||
|
||||
$qb->select('user_id', 'file_id', 'remind_at') |
||||
->from($this->getTableName()) |
||||
->where($qb->expr()->lt('remind_at', $qb->createFunction('NOW()'))) |
||||
->andWhere($qb->expr()->eq('notified', $qb->createNamedParameter(false, IQueryBuilder::PARAM_BOOL))); |
||||
|
||||
return $this->findEntities($qb); |
||||
} |
||||
} |
@ -0,0 +1,71 @@ |
||||
<?php |
||||
|
||||
declare(strict_types=1); |
||||
|
||||
/** |
||||
* @copyright 2023 Christopher Ng <chrng8@gmail.com> |
||||
* |
||||
* @author Christopher Ng <chrng8@gmail.com> |
||||
* |
||||
* @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 <http://www.gnu.org/licenses/>. |
||||
* |
||||
*/ |
||||
|
||||
namespace OCA\FilesReminders\Migration; |
||||
|
||||
use Closure; |
||||
use OCA\FilesReminders\Db\ReminderMapper; |
||||
use OCP\DB\ISchemaWrapper; |
||||
use OCP\DB\Types; |
||||
use OCP\Migration\IOutput; |
||||
use OCP\Migration\SimpleMigrationStep; |
||||
|
||||
class Version10000Date20230725162149 extends SimpleMigrationStep { |
||||
/** |
||||
* @param Closure $schemaClosure The `\Closure` returns a `ISchemaWrapper` |
||||
*/ |
||||
public function changeSchema(IOutput $output, Closure $schemaClosure, array $options): ?ISchemaWrapper { |
||||
/** @var ISchemaWrapper $schema */ |
||||
$schema = $schemaClosure(); |
||||
|
||||
$table = $schema->createTable(ReminderMapper::TABLE_NAME); |
||||
$table->addColumn('id', Types::BIGINT, [ |
||||
'autoincrement' => true, |
||||
'notnull' => true, |
||||
'length' => 20, |
||||
'unsigned' => true, |
||||
]); |
||||
$table->addColumn('user_id', Types::STRING, [ |
||||
'notnull' => true, |
||||
'length' => 64, |
||||
]); |
||||
$table->addColumn('file_id', Types::BIGINT, [ |
||||
'notnull' => true, |
||||
'length' => 20, |
||||
]); |
||||
$table->addColumn('remind_at', Types::BIGINT, [ |
||||
'notnull' => true, |
||||
]); |
||||
$table->addColumn('notified', Types::BOOLEAN, [ |
||||
'notnull' => false, |
||||
'default' => false, |
||||
]); |
||||
$table->setPrimaryKey(['id']); |
||||
$table->addUniqueIndex(['user_id', 'file_id', 'remind_at'], 'reminders_uniq_idx'); |
||||
|
||||
return $schema; |
||||
} |
||||
} |
Loading…
Reference in new issue