}, array{}> * * 200: References returned */ #[NoAdminRequired] #[ApiRoute(verb: 'POST', url: '/extract', root: '/references')] public function extract(string $text, bool $resolve = false, int $limit = 1): DataResponse { $references = $this->referenceManager->extractReferences($text); $result = []; $index = 0; foreach ($references as $reference) { if ($index++ >= $limit) { break; } $result[$reference] = $resolve ? $this->referenceManager->resolveReference($reference)->jsonSerialize() : null; } return new DataResponse([ 'references' => $result ]); } /** * Extract references from a text * * @param string $text Text to extract from * @param string $sharingToken Token of the public share * @param bool $resolve Resolve the references * @param int $limit Maximum amount of references to extract, limited to 15 * @return DataResponse}, array{}> * * 200: References returned */ #[ApiRoute(verb: 'POST', url: '/extractPublic', root: '/references')] #[PublicPage] #[AnonRateLimit(limit: 10, period: 120)] public function extractPublic(string $text, string $sharingToken, bool $resolve = false, int $limit = 1): DataResponse { $references = $this->referenceManager->extractReferences($text); $result = []; $index = 0; foreach ($references as $reference) { if ($index++ >= min($limit, self::LIMIT_MAX)) { break; } $result[$reference] = $resolve ? $this->referenceManager->resolveReference($reference, true, $sharingToken)?->jsonSerialize() : null; } return new DataResponse([ 'references' => $result ]); } /** * Resolve a reference * * @param string $reference Reference to resolve * @return DataResponse}, array{}> * * 200: Reference returned */ #[NoAdminRequired] #[ApiRoute(verb: 'GET', url: '/resolve', root: '/references')] public function resolveOne(string $reference): DataResponse { /** @var ?CoreReference $resolvedReference */ $resolvedReference = $this->referenceManager->resolveReference(trim($reference))?->jsonSerialize(); $response = new DataResponse(['references' => [$reference => $resolvedReference]]); $response->cacheFor(3600, false, true); return $response; } /** * Resolve from a public page * * @param string $reference Reference to resolve * @param string $sharingToken Token of the public share * @return DataResponse}, array{}> * * 200: Reference returned */ #[ApiRoute(verb: 'GET', url: '/resolvePublic', root: '/references')] #[PublicPage] #[AnonRateLimit(limit: 25, period: 120)] public function resolveOnePublic(string $reference, string $sharingToken): DataResponse { /** @var ?CoreReference $resolvedReference */ $resolvedReference = $this->referenceManager->resolveReference(trim($reference), true, trim($sharingToken))?->jsonSerialize(); $response = new DataResponse(['references' => [$reference => $resolvedReference]]); $response->cacheFor(3600, false, true); return $response; } /** * Resolve multiple references * * @param list $references References to resolve * @param int $limit Maximum amount of references to resolve * @return DataResponse}, array{}> * * 200: References returned */ #[NoAdminRequired] #[ApiRoute(verb: 'POST', url: '/resolve', root: '/references')] public function resolve(array $references, int $limit = 1): DataResponse { $result = []; $index = 0; foreach ($references as $reference) { if ($index++ >= $limit) { break; } $result[$reference] = $this->referenceManager->resolveReference($reference)?->jsonSerialize(); } return new DataResponse([ 'references' => $result ]); } /** * Resolve multiple references from a public page * * @param list $references References to resolve * @param string $sharingToken Token of the public share * @param int $limit Maximum amount of references to resolve, limited to 15 * @return DataResponse}, array{}> * * 200: References returned */ #[ApiRoute(verb: 'POST', url: '/resolvePublic', root: '/references')] #[PublicPage] #[AnonRateLimit(limit: 10, period: 120)] public function resolvePublic(array $references, string $sharingToken, int $limit = 1): DataResponse { $result = []; $index = 0; foreach ($references as $reference) { if ($index++ >= min($limit, self::LIMIT_MAX)) { break; } $result[$reference] = $this->referenceManager->resolveReference($reference, true, $sharingToken)?->jsonSerialize(); } return new DataResponse([ 'references' => $result ]); } /** * Get the providers * * @return DataResponse, array{}> * * 200: Providers returned */ #[NoAdminRequired] #[ApiRoute(verb: 'GET', url: '/providers', root: '/references')] public function getProvidersInfo(): DataResponse { $providers = $this->referenceManager->getDiscoverableProviders(); $jsonProviders = array_values(array_map(static function (IDiscoverableReferenceProvider $provider) { return $provider->jsonSerialize(); }, $providers)); return new DataResponse($jsonProviders); } /** * Touch a provider * * @param string $providerId ID of the provider * @param int|null $timestamp Timestamp of the last usage * @return DataResponse * * 200: Provider touched */ #[NoAdminRequired] #[ApiRoute(verb: 'PUT', url: '/provider/{providerId}', root: '/references')] public function touchProvider(string $providerId, ?int $timestamp = null): DataResponse { if ($this->userId !== null) { $success = $this->referenceManager->touchProvider($this->userId, $providerId, $timestamp); return new DataResponse(['success' => $success]); } return new DataResponse(['success' => false]); } } ar'>artonge/fix/displayname_in_sidebar Nextcloud server, a safe home for all your data: https://github.com/nextcloud/serverwww-data
aboutsummaryrefslogtreecommitdiffstats
blob: 933192c95c18cb42b5518df57f92d0b074b507f3 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
<?php
/**
 * SPDX-FileCopyrightText: 2023 Nextcloud GmbH and Nextcloud contributors
 * SPDX-License-Identifier: AGPL-3.0-or-later
 */

declare(strict_types=1);

namespace OCA\Testing\TaskProcessing;

use OCA\Testing\AppInfo\Application;
use OCP\AppFramework\Services\IAppConfig;
use OCP\Files\File;
use OCP\TaskProcessing\Exception\ProcessingException;
use OCP\TaskProcessing\ISynchronousProvider;
use OCP\TaskProcessing\TaskTypes\AudioToText;
use RuntimeException;

class FakeTranscribeProvider implements ISynchronousProvider {

	public function __construct(
		protected IAppConfig $appConfig,
	) {
	}

	public function getId(): string {
		return Application::APP_ID . '-audio2text';
	}

	public function getName(): string {
		return 'Fake audio2text task processing provider';
	}

	public function getTaskTypeId(): string {
		return AudioToText::ID;
	}

	public function getExpectedRuntime(): int {
		return 1;
	}

	public function getInputShapeEnumValues(): array {
		return [];
	}

	public function getInputShapeDefaults(): array {
		return [];
	}

	public function getOptionalInputShape(): array {
		return [];
	}

	public function getOptionalInputShapeEnumValues(): array {
		return [];
	}

	public function getOptionalInputShapeDefaults(): array {
		return [];
	}

	public function getOutputShapeEnumValues(): array {
		return [];
	}

	public function getOptionalOutputShape(): array {
		return [];
	}

	public function getOptionalOutputShapeEnumValues(): array {
		return [];
	}

	public function process(?string $userId, array $input, callable $reportProgress): array {
		if (!isset($input['input']) || !$input['input'] instanceof File || !$input['input']->isReadable()) {
			throw new RuntimeException('Invalid input file');
		}
		if ($this->appConfig->getAppValueBool('fail-' . $this->getId())) {
			throw new ProcessingException('Failing as set by AppConfig');
		}

		$inputFile = $input['input'];
		$transcription = 'Fake transcription result';

		return ['output' => $transcription];
	}
}