harivansh-afk/betterNAS
1
1
Fork 0
mirror of https://github.com/harivansh-afk/betterNAS.git synced 2026-04-15 17:00:58 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

add nextcloud shell

Browse source 
Co-authored-by: Codex <noreply@openai.com>
This commit is contained in:
Harivansh Rathi 2026-03-31 21:25:48 +00:00
parent 57f221fb72
commit eea46f28ad
9 changed files with 337 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

88
apps/ainas-controlplane/lib/Service/ControlPlaneClient.php Normal file
View file

@ -0,0 +1,88 @@
<?php
declare(strict_types=1);
namespace OCA\AinasControlplane\Service;
use OCP\Http\Client\IClientService;
use OCP\Http\Client\IResponse;
use Psr\Log\LoggerInterface;
class ControlPlaneClient {
public function __construct(
private readonly IClientService $clientService,
private readonly ControlPlaneConfig $controlPlaneConfig,
private readonly LoggerInterface $logger,
) {
}
/**
* @return array<string, mixed>
*/
public function fetchSnapshot(): array {
$baseUrl = $this->controlPlaneConfig->getBaseUrl();
try {
$healthResponse = $this->request($baseUrl . '/health');
$versionResponse = $this->request($baseUrl . '/version');
return [
'available' => $healthResponse['statusCode'] === 200,
'url' => $baseUrl,
'health' => $healthResponse['body'],
'version' => $versionResponse['body'],
];
} catch (\Throwable $exception) {
$this->logger->warning('Failed to reach aiNAS control plane', [
'exception' => $exception,
'url' => $baseUrl,
]);
return [
'available' => false,
'url' => $baseUrl,
'error' => $exception->getMessage(),
];
}
}
/**
* @return array{statusCode: int, body: array<string, mixed>}
*/
private function request(string $url): array {
$client = $this->clientService->newClient();
$response = $client->get($url, [
'headers' => [
'Accept' => 'application/json',
],
'http_errors' => false,
'timeout' => 2,
'nextcloud' => [
'allow_local_address' => true,
],
]);
return [
'statusCode' => $response->getStatusCode(),
'body' => $this->decodeBody($response),
];
}
/**
* @return array<string, mixed>
*/
private function decodeBody(IResponse $response): array {
$body = $response->getBody();
if ($body === '') {
return [];
}
$decoded = json_decode($body, true, 512, JSON_THROW_ON_ERROR);
if (!is_array($decoded)) {
return [];
}
return $decoded;
}
}