Files
nc-talk-ai/lib/Jobs/CleanupConversationsJob.php
T
Pascal Kienast 0739d3da6a Initial open-source release of Talk AI
Talk AI is a multi-bot AI assistant manager for Nextcloud Talk:
per-bot prompts and models, agentic tool calling (MCP + built-in
tools), RAG over Nextcloud files, room-document search, vision and
speech-to-text attachments, persistent bot wikis, approval workflows,
rate limiting, and multi-provider LLM support (any OpenAI-compatible
endpoint).

Developed within EDUC - the European Digital UniverCity
(https://educalliance.eu), where it runs as the 'EDUC AI' assistant on
the alliance-wide Nextcloud portal. This public repository is the
upstream point of truth; deployment-specific tools plug in via the
tool-provider extension point (docs/TOOL_PROVIDERS.md).

License: AGPL-3.0-or-later.
2026-07-08 21:13:13 +02:00

77 lines
2.4 KiB
PHP

<?php
declare(strict_types=1);
namespace OCA\EducAI\Jobs;
use OCA\EducAI\Db\ConversationMapper;
use OCP\AppFramework\Utility\ITimeFactory;
use OCP\BackgroundJob\TimedJob;
use Psr\Log\LoggerInterface;
/**
* Background job that cleans up old conversation history.
*
* Runs daily and removes conversations older than the retention period
* to prevent unbounded database growth and reduce storage costs.
*/
class CleanupConversationsJob extends TimedJob {
/**
* Default retention period in days.
* Conversations older than this will be deleted.
*/
private const DEFAULT_RETENTION_DAYS = 30;
private ConversationMapper $conversationMapper;
private LoggerInterface $logger;
public function __construct(
ITimeFactory $time,
ConversationMapper $conversationMapper,
LoggerInterface $logger
) {
parent::__construct($time);
$this->conversationMapper = $conversationMapper;
$this->logger = $logger;
// Run once per day (24 hours = 86400 seconds)
$this->setInterval(86400);
// Use random time-sensitivity to spread load across instances
// This prevents all instances from running cleanup at the exact same time
$this->setTimeSensitivity(self::TIME_INSENSITIVE);
}
/**
* @param array<string,mixed> $arguments
*/
protected function run($arguments): void {
$retentionDays = $arguments['retention_days'] ?? self::DEFAULT_RETENTION_DAYS;
if (!is_int($retentionDays) || $retentionDays < 1) {
$retentionDays = self::DEFAULT_RETENTION_DAYS;
}
// Calculate cutoff timestamp
$cutoffTimestamp = time() - ($retentionDays * 24 * 60 * 60);
$this->logger->info('EducAI: Starting conversation cleanup job', [
'retention_days' => $retentionDays,
'cutoff_date' => date('Y-m-d H:i:s', $cutoffTimestamp),
]);
try {
$this->conversationMapper->deleteOlderThan($cutoffTimestamp);
$this->logger->info('EducAI: Conversation cleanup completed successfully', [
'cutoff_timestamp' => $cutoffTimestamp,
]);
} catch (\Throwable $e) {
$this->logger->error('EducAI: Conversation cleanup failed', [
'exception' => $e->getMessage(),
'trace' => $e->getTraceAsString(),
]);
}
}
}