OCA\Analytics\ContextChat\ContextChatManager

Complexity

Total Complexity

3

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	1
A	isActiveForDataset()	0	3	1
A	submitContent()	0	23	1

<?php
/**
 * Analytics
 *
 * SPDX-FileCopyrightText: 2024 Marcel Scherello
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

namespace OCA\Analytics\ContextChat;

use OCP\DB\Exception;

The type OCP\DB\Exception was not found. Maybe you did not declare it correctly or list all dependencies?

use OCP\IL10N;

The type OCP\IL10N was not found. Maybe you did not declare it correctly or list all dependencies?

use Psr\Log\LoggerInterface;

The type Psr\Log\LoggerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use OCA\ContextChat\Public\ContentItem;

The type OCA\ContextChat\Public\ContentItem was not found. Maybe you did not declare it correctly or list all dependencies?

use OCA\ContextChat\Public\ContentManager;

The type OCA\ContextChat\Public\ContentManager was not found. Maybe you did not declare it correctly or list all dependencies?

use OCA\Analytics\Service\StorageService;
use OCA\Analytics\Service\DatasetService;

class ContextChatManager {
	private $userId;
	private $logger;
	private $l10n;
	private $StorageService;
	private $DatasetService;
	private $ContentManager;

	public function __construct(
		$userId,
		IL10N $l10n,
		LoggerInterface $logger,
		StorageService $StorageService,
		DatasetService $DatasetService,
		ContentManager $ContentManager
	) {
		$this->userId = $userId;
		$this->l10n = $l10n;
		$this->logger = $logger;
		$this->StorageService = $StorageService;
		$this->DatasetService = $DatasetService;
		$this->ContentManager = $ContentManager;
	}

	/**
	 * Providers can use this to submit content for indexing in context chat
	 *
	 * @param int $datasetId
	 * @return void
	 * @throws Exception
	 */
	public function submitContent(int $datasetId): void {
		$storageData = $this->StorageService->read($datasetId, null);
		$datasetMetadata = $this->DatasetService->read($datasetId);

		$columns = $datasetMetadata['dimension1'] .', '.$datasetMetadata['dimension2'].', '.$datasetMetadata['value'];

		$data = array_map(function ($subArray) {
			return implode(",", $subArray);
		}, $storageData['data']);
		$dataString = implode("\n", $data);

		$content = 'This is a report of statistical data. ' . $datasetMetadata['subheader'] . '. ';
		$content .= 'The data comes in multiple rows which 3 columns separated by a comma. ';
		$content .= 'The columns are ' . $columns . '. ';
		$content .= 'The data is: ' . $dataString;

		$contentItem = new ContentItem($datasetId, 'report', $datasetMetadata['name'], $content, 'Report', new \DateTime(), ['admin']);

		$contentItems = [$contentItem];
		//$this->ContentManager->removeContentForUsers('analytics', 'report', $dataset, ['admin']);
		$this->logger->debug('adding item: ' . json_encode($contentItem));
		$this->ContentManager->submitContent('analytics', $contentItems);
		return;
	}

	/**
	 * return true if the data set has indexing activated
	 *
	 * @param int $datasetId
	 * @return bool
	 * @throws Exception
	 */
	public function isActiveForDataset(int $datasetId) {
		$datasetMetadata = $this->DatasetService->read($datasetId);
		return $datasetMetadata['ai_index'] === 1;
	}
}