starred/panel-pelican-dev
1
0
Fork 0
mirror of https://github.com/pelican-dev/panel.git synced 2026-07-16 04:03:50 +03:00
Code Issues 41 Packages Projects Releases 10 Wiki Activity

Remove DaemonConnectionException (#885)

Browse Source 
* remove DaemonConnectionException

* update tests
This commit is contained in:
Boy132
2025-01-07 22:58:04 +01:00
committed by GitHub
parent 6fcf4173d3
commit c93a836ad8
33 changed files with 237 additions and 484 deletions
Download Patch File Download Diff File Expand all files Collapse all files

262
app/Repositories/Daemon/DaemonFileRepository.php
View File

@@ -2,15 +2,10 @@
namespace App\Repositories\Daemon;
use Carbon\CarbonInterval;
use Illuminate\Contracts\Filesystem\FileNotFoundException;
use Illuminate\Http\Client\Response;
use Webmozart\Assert\Assert;
use App\Models\Server;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Exception\TransferException;
use App\Exceptions\Http\Server\FileSizeTooLargeException;
use App\Exceptions\Http\Connection\DaemonConnectionException;
use Illuminate\Http\Client\ConnectionException;
class DaemonFileRepository extends DaemonRepository
{
@@ -19,23 +14,16 @@ class DaemonFileRepository extends DaemonRepository
*
* @param int|null $notLargerThan the maximum content length in bytes
*
* @throws \GuzzleHttp\Exception\TransferException
* @throws \App\Exceptions\Http\Server\FileSizeTooLargeException
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
* @throws FileSizeTooLargeException
* @throws ConnectionException
* @throws FileNotFoundException
*/
public function getContent(string $path, ?int $notLargerThan = null): string
{
Assert::isInstanceOf($this->server, Server::class);
try {
$response = $this->getHttpClient()->get(
sprintf('/api/servers/%s/files/contents', $this->server->uuid),
['file' => $path]
);
} catch (ClientException|TransferException $exception) {
throw new DaemonConnectionException($exception);
}
$response = $this->getHttpClient()->get("/api/servers/{$this->server->uuid}/files/contents",
['file' => $path]
);
$length = $response->header('Content-Length');
if ($notLargerThan && $length > $notLargerThan) {
@@ -53,215 +41,145 @@ class DaemonFileRepository extends DaemonRepository
* Save new contents to a given file. This works for both creating and updating
* a file.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function putContent(string $path, string $content): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()
->withQueryParameters(['file' => $path])
->withBody($content)
->post(sprintf('/api/servers/%s/files/write', $this->server->uuid));
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()
->withQueryParameters(['file' => $path])
->withBody($content)
->post("/api/servers/{$this->server->uuid}/files/write");
}
/**
* Return a directory listing for a given path.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function getDirectory(string $path): array
{
Assert::isInstanceOf($this->server, Server::class);
try {
$response = $this->getHttpClient()->get(
sprintf('/api/servers/%s/files/list-directory', $this->server->uuid),
['directory' => $path]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $response->json();
return $this->getHttpClient()->get("/api/servers/{$this->server->uuid}/files/list-directory",
['directory' => $path]
)->json();
}
/**
* Creates a new directory for the server in the given $path.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function createDirectory(string $name, string $path): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()->post(
sprintf('/api/servers/%s/files/create-directory', $this->server->uuid),
[
'name' => $name,
'path' => $path,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()->post("/api/servers/{$this->server->uuid}/files/create-directory",
[
'name' => $name,
'path' => $path,
]
);
}
/**
* Renames or moves a file on the remote machine.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function renameFiles(?string $root, array $files): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()->put(
sprintf('/api/servers/%s/files/rename', $this->server->uuid),
[
'root' => $root ?? '/',
'files' => $files,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()->put("/api/servers/{$this->server->uuid}/files/rename",
[
'root' => $root ?? '/',
'files' => $files,
]
);
}
/**
* Copy a given file and give it a unique name.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function copyFile(string $location): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()->post(
sprintf('/api/servers/%s/files/copy', $this->server->uuid),
[
'location' => $location,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()->post("/api/servers/{$this->server->uuid}/files/copy",
['location' => $location]
);
}
/**
* Delete a file or folder for the server.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function deleteFiles(?string $root, array $files): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()->post(
sprintf('/api/servers/%s/files/delete', $this->server->uuid),
[
'root' => $root ?? '/',
'files' => $files,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()->post("/api/servers/{$this->server->uuid}/files/delete",
[
'root' => $root ?? '/',
'files' => $files,
]
);
}
/**
* Compress the given files or folders in the given root.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function compressFiles(?string $root, array $files): array
{
Assert::isInstanceOf($this->server, Server::class);
try {
$response = $this->getHttpClient()
// Wait for up to 15 minutes for the archive to be completed when calling this endpoint
// since it will likely take quite awhile for large directories.
->timeout(60 * 15)
->post(
sprintf('/api/servers/%s/files/compress', $this->server->uuid),
[
'root' => $root ?? '/',
'files' => $files,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $response->json();
return $this->getHttpClient()
// Wait for up to 15 minutes for the archive to be completed when calling this endpoint
// since it will likely take quite awhile for large directories.
->timeout(60 * 15)
->post("/api/servers/{$this->server->uuid}/files/compress",
[
'root' => $root ?? '/',
'files' => $files,
]
)->json();
}
/**
* Decompresses a given archive file.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function decompressFile(?string $root, string $file): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()
// Wait for up to 15 minutes for the decompress to be completed when calling this endpoint
// since it will likely take quite awhile for large directories.
->timeout((int) CarbonInterval::minutes(15)->totalSeconds)
->post(
sprintf('/api/servers/%s/files/decompress', $this->server->uuid),
[
'root' => $root ?? '/',
'file' => $file,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()
// Wait for up to 15 minutes for the archive to be completed when calling this endpoint
// since it will likely take quite awhile for large directories.
->timeout(60 * 15)
->post("/api/servers/{$this->server->uuid}/files/decompress",
[
'root' => $root ?? '/',
'file' => $file,
]
);
}
/**
* Chmods the given files.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function chmodFiles(?string $root, array $files): Response
{
Assert::isInstanceOf($this->server, Server::class);
try {
return $this->getHttpClient()->post(
sprintf('/api/servers/%s/files/chmod', $this->server->uuid),
[
'root' => $root ?? '/',
'files' => $files,
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()->post("/api/servers/{$this->server->uuid}/files/chmod",
[
'root' => $root ?? '/',
'files' => $files,
]
);
}
/**
* Pulls a file from the given URL and saves it to the disk.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function pull(string $url, ?string $directory, array $params = []): Response
{
Assert::isInstanceOf($this->server, Server::class);
$attributes = [
'url' => $url,
'root' => $directory ?? '/',
@@ -270,39 +188,25 @@ class DaemonFileRepository extends DaemonRepository
'foreground' => $params['foreground'] ?? null,
];
try {
return $this->getHttpClient()->post(
sprintf('/api/servers/%s/files/pull', $this->server->uuid),
array_filter($attributes, fn ($value) => !is_null($value))
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $this->getHttpClient()->post("/api/servers/{$this->server->uuid}/files/pull", array_filter($attributes, fn ($value) => !is_null($value)));
}
/**
* Searches all files in the directory (and its subdirectories) for the given search term.
*
* @throws \App\Exceptions\Http\Connection\DaemonConnectionException
* @throws ConnectionException
*/
public function search(string $searchTerm, ?string $directory): array
{
Assert::isInstanceOf($this->server, Server::class);
try {
$response = $this->getHttpClient()
->timeout(120)
->get(
sprintf('/api/servers/%s/files/search', $this->server->uuid),
[
'pattern' => $searchTerm,
'directory' => $directory ?? '/',
]
);
} catch (TransferException $exception) {
throw new DaemonConnectionException($exception);
}
return $response->json();
return $this->getHttpClient()
// Wait for up to 2 minutes for the search to be completed when calling this endpoint
// since it will likely take quite awhile for large directories.
->timeout(60 * 2)
->get("/api/servers/{$this->server->uuid}/files/search",
[
'pattern' => $searchTerm,
'directory' => $directory ?? '/',
]
)->json();
}
}