feat: Add a --since option to the manage command

Signed-off-by: Côme Chilliet <come.chilliet@nextcloud.com>

Author: come-nc

lib/Command/Manage.php

@@ -13,6 +13,7 @@
 use OCA\UserMigration\AppInfo\Application;
 use OCA\UserMigration\Service\UserMigrationService;
 use OCP\AppFramework\Utility\ITimeFactory;
+use OCP\DB\QueryBuilder\IQueryBuilder;
 use OCP\IConfig;
 use OCP\IDBConnection;
 use OCP\IUserManager;
@@ -45,6 +46,12 @@ protected function configure(): void {
 				'Limit the number of listed users',
 				100,
 			)
+			->addOption(
+				'since',
+				null,
+				InputOption::VALUE_REQUIRED,
+				'Filter by minimum export date',
+			)
 			->addOption(
 				'delete',
 				null,
@@ -54,7 +61,13 @@ protected function configure(): void {
 	}
 
 	protected function execute(InputInterface $input, OutputInterface $output): int {
-		$values = iterator_to_array($this->queryUsers((int)$input->getOption('limit')));
+		if ((string)$input->getOption('since') !== '') {
+			$since = new \DateTime($input->getOption('since'));
+			$output->writeln('<info>Since ' . $since->format(\DateTimeInterface::ATOM) . '</info>');
+		} else {
+			$since = null;
+		}
+		$values = iterator_to_array($this->queryUsers((int)$input->getOption('limit'), $since));
 		$this->writeTableInOutputFormat($input, $output, $values);
 		if ($input->getOption('delete')) {
 			/** @var QuestionHelper $helper */
@@ -73,13 +86,18 @@ protected function execute(InputInterface $input, OutputInterface $output): int
 		return self::SUCCESS;
 	}
 
-	private function queryUsers(int $limit): \Generator {
+	private function queryUsers(int $limit, ?\DateTime $since): \Generator {
 		$qb = $this->connection->getQueryBuilder();
 		$qb->select('userid', 'configvalue')
 			->from('preferences')
 			->where($qb->expr()->eq('appid', $qb->createNamedParameter(Application::APP_ID)))
-			->andWhere($qb->expr()->eq('configkey', $qb->createNamedParameter('lastExport')))
-			->orderBy('configvalue')
+			->andWhere($qb->expr()->eq('configkey', $qb->createNamedParameter('lastExport')));
+
+		if ($since !== null) {
+			$qb->andWhere($qb->expr()->gte('configvalue', $qb->createNamedParameter($since->getTimestamp(), IQueryBuilder::PARAM_INT)));
+		}
+
+		$qb->orderBy('configvalue')
 			->setMaxResults($limit);
 
 		$result = $qb->executeQuery();