1 Commits

Author SHA1 Message Date
Sebastian fd64fdeff1 chore(deps): update dependency vue-tsc to v3.3.10
JS Unit Tests / test (pull_request) Successful in 50s
Build Test / test (pull_request) Successful in 54s
PHP Integration Tests / Integration Tests (pull_request) Failing after 1m24s
PHP Unit Tests / test (pull_request) Successful in 1m37s
2026-08-16 03:02:02 +00:00
9 changed files with 36 additions and 146 deletions
+2 -35
View File
@@ -23,8 +23,8 @@ use KTXF\Resource\Identifier\EntityIdentifier;
use KTXF\Resource\Identifier\ResourceIdentifier;
use KTXF\Resource\Identifier\ResourceIdentifiers;
use KTXF\Resource\Identifier\ServiceIdentifier;
use KTXF\Mail\Provider\ProviderBaseInterface;
use KTXF\Resource\Provider\ResourceServiceLocationInterface;
use KTXF\Resource\SystemIdentity;
use KTXF\Routing\Attributes\AuthenticatedRoute;
use KTXM\MailManager\Manager;
use Psr\Log\LoggerInterface;
@@ -86,7 +86,7 @@ class DefaultController extends ControllerAbstract {
// acting-user override: only the reserved system context is permitted,
// gated on the system mail management permission
if ($user !== null && $user !== $userId) {
if ($user !== SystemIdentity::USER || !$this->identityContext->hasPermission('mail_manager.system')) {
if ($user !== ProviderBaseInterface::USER_SYSTEM || !$this->identityContext->hasPermission('mail_manager.system')) {
return new JsonResponse([
'version' => $version,
'transaction' => $transaction,
@@ -180,7 +180,6 @@ class DefaultController extends ControllerAbstract {
'entity.copy' => throw new InvalidArgumentException('Operation not implemented: ' . $operation),
'entity.submit' => $this->entitySubmit($tenantId, $userId, $data),
'entity.download' => $this->entityDownload($tenantId, $userId, $data),
'entity.preview' => $this->entityPreview($tenantId, $userId, $data),
'entity.blobs' => $this->entityBlobs($tenantId, $userId, $data),
default => throw new InvalidArgumentException(self::ERR_INVALID_OPERATION . $operation)
@@ -969,36 +968,4 @@ class DefaultController extends ControllerAbstract {
return $results;
}
private function entityPreview(string $tenantId, string $userId, array $data): Response {
if (!isset($data['target']) || !is_string($data['target'])) {
throw new InvalidArgumentException(self::ERR_MISSING_TARGET);
}
if (!isset($data['part']) || !is_array($data['part'])) {
throw new InvalidArgumentException('Attachment preview requires a part');
}
$target = ResourceIdentifier::fromString($data['target']);
if (!$target instanceof EntityIdentifier) {
throw new InvalidArgumentException(self::ERR_INVALID_IDENTIFIER);
}
$preview = $this->manager->entityPreview(
$tenantId,
$userId,
$target,
$data['part'],
isset($data['variant']) && is_string($data['variant']) ? $data['variant'] : 'inline',
);
if ($preview === null) {
return new Response('', Response::HTTP_NO_CONTENT);
}
return new StreamedResponse($preview->resource->stream(), Response::HTTP_OK, [
'Content-Type' => $preview->resource->mimeType(),
'Content-Length' => (string) $preview->size,
'ETag' => '"' . trim($preview->etag, '"') . '"',
'Cache-Control' => 'private, max-age=3600',
'X-Content-Type-Options' => 'nosniff',
]);
}
}
+7 -50
View File
@@ -5,10 +5,7 @@ declare(strict_types=1);
namespace KTXM\MailManager;
use InvalidArgumentException;
use KTXC\Preview\Preview;
use KTXC\Preview\PreviewManager;
use KTXC\Resource\ProviderManager;
use KTXF\Preview\PreviewSource;
use KTXF\Mail\Collection\CollectionBaseInterface;
use KTXF\Mail\Collection\CollectionPropertiesMutableInterface;
use KTXF\Mail\Collection\ICollectionBase;
@@ -50,7 +47,6 @@ class Manager {
public function __construct(
private LoggerInterface $logger,
private ProviderManager $providerManager,
private PreviewManager $previewManager,
) { }
/**
@@ -938,6 +934,13 @@ class Manager {
}
}
public function entityDownload(string $tenantId, string $userId, EntityIdentifier $targetEntity, array|null $targetPart): BinaryResource {
// retrieve service
$service = $this->serviceFetch($tenantId, $userId, $targetEntity->provider(), $targetEntity->service());
// download entity
return $service->entityDownload($targetEntity, $targetPart);
}
/**
* Check if messages exist
*
@@ -1349,50 +1352,4 @@ class Manager {
return $service->entitySubmit($sender, $source, $message);
}
public function entityDownload(string $tenantId, string $userId, EntityIdentifier $targetEntity, array|null $targetPart): BinaryResource {
// retrieve service
$service = $this->serviceFetch($tenantId, $userId, $targetEntity->provider(), $targetEntity->service());
// download entity
return $service->entityDownload($targetEntity, $targetPart);
}
/**
* Resolve an authorized attachment and lazily generate or retrieve its preview.
*/
public function entityPreview(string $tenantId, string $userId, EntityIdentifier $targetEntity, array $part, string $variant = 'inline'): ?Preview {
$mimeType = $part['type'] ?? null;
$size = $part['size'] ?? null;
if (!is_string($mimeType) || ($size !== null && !is_int($size))) {
throw new InvalidArgumentException('Attachment preview requires a MIME type and optional integer size');
}
$selector = array_filter([
'blobId' => $part['blobId'] ?? null,
'partId' => $part['partId'] ?? null,
'cid' => $part['cid'] ?? null,
], static fn(mixed $value): bool => is_string($value) && $value !== '');
if ($selector === []) {
throw new InvalidArgumentException('Attachment preview requires a blob, part, or content identifier');
}
$attachmentIdentity = hash('sha256', json_encode($selector, JSON_THROW_ON_ERROR));
return $this->previewManager->fetch($tenantId, new PreviewSource(
sourceType: 'mail-attachment',
identity: (string) $targetEntity . ':' . $attachmentIdentity,
// Attachments are immutable once delivered, so there is no revision to track;
// existence and access are enforced by entityDownload() (via serviceFetch) below,
// which only runs on a cache miss.
signature: 'immutable',
mimeType: $mimeType,
size: $size,
resourceFactory: fn(): BinaryResource => $this->entityDownload(
$tenantId,
$userId,
$targetEntity,
$selector,
),
), $variant);
}
}
+12 -8
View File
@@ -2,8 +2,7 @@
namespace KTXM\MailManager;
use KTXF\Module\Configuration\BrowserModuleContextInterface;
use KTXF\Module\Configuration\ModuleContextInterface;
use KTXF\Module\ModuleBrowserInterface;
use KTXF\Module\ModuleInstanceAbstract;
/**
@@ -12,7 +11,7 @@ use KTXF\Module\ModuleInstanceAbstract;
* Provides unified mail sending and management across multiple providers
* with context-aware service discovery and queued delivery.
*/
class Module extends ModuleInstanceAbstract
class Module extends ModuleInstanceAbstract implements ModuleBrowserInterface
{
public function __construct()
@@ -59,10 +58,15 @@ class Module extends ModuleInstanceAbstract
];
}
public function configure(ModuleContextInterface $context): void
{
if ($context instanceof BrowserModuleContextInterface) {
$context->registerModule($this, 'MailManager', 'static/module.mjs');
}
public function registerBI(): array {
return [
'handle' => $this->handle(),
'namespace' => 'MailManager',
'version' => $this->version(),
'label' => $this->label(),
'author' => $this->author(),
'description' => $this->description(),
'boot' => 'static/module.mjs',
];
}
}
+7 -7
View File
@@ -1041,9 +1041,9 @@
"license": "MIT"
},
"node_modules/@vue/language-core": {
"version": "3.3.11",
"resolved": "https://registry.npmjs.org/@vue/language-core/-/language-core-3.3.11.tgz",
"integrity": "sha512-QJmpliwAVpC/OxubIByPAhNzsQPRc8/gxlN2qnVzVfIMjMDz/9RnXRFoetjz5yEgXVXyp4LqhXq3V53PjmNzFw==",
"version": "3.3.10",
"resolved": "https://registry.npmjs.org/@vue/language-core/-/language-core-3.3.10.tgz",
"integrity": "sha512-CR7ByBbgPHqhxrioKPOcZBqttaozzLNwtkCzXQ+uF8gLPHnUe03srPnGpdtHD3zp+bq5iyVkZ1WNx7W564RPwg==",
"dev": true,
"license": "MIT",
"dependencies": {
@@ -2992,14 +2992,14 @@
}
},
"node_modules/vue-tsc": {
"version": "3.3.11",
"resolved": "https://registry.npmjs.org/vue-tsc/-/vue-tsc-3.3.11.tgz",
"integrity": "sha512-gOb0B9rtU2+f1dszwPqSH5kAieIF9ReeLhD3kSRNHv5WZZUQz/JdVXW0RTdqhNTMlQkqKzrTTviqKr/4FYZraQ==",
"version": "3.3.10",
"resolved": "https://registry.npmjs.org/vue-tsc/-/vue-tsc-3.3.10.tgz",
"integrity": "sha512-YaDVxcW+CGtaOt3pZahMG5jYPx0hsUTxyEoPOTSMebcGUXP9lIBabQ14vfKMORb2CqqK5CxsNo/d1d+4IQwiKg==",
"dev": true,
"license": "MIT",
"dependencies": {
"@volar/typescript": "2.4.28",
"@vue/language-core": "3.3.11"
"@vue/language-core": "3.3.10"
},
"bin": {
"vue-tsc": "bin/vue-tsc.js"
+1 -6
View File
@@ -2,7 +2,7 @@
* Entity management service
*/
import { transceivePost, transceiveStream, transceiveDownload, transceiveBlob } from './transceive';
import { transceivePost, transceiveStream, transceiveDownload } from './transceive';
import type {
EntityFetchRequest,
EntityFetchResponse,
@@ -28,7 +28,6 @@ import type {
EntityPatchResponse,
EntityPatchRequest,
EntityDownloadRequest,
EntityPreviewRequest,
EntityBlobsRequest,
EntityBlobsResponse,
EntityBlobsWireResponse,
@@ -232,10 +231,6 @@ export const entityService = {
return transceiveDownload<EntityDownloadRequest>('entity.download', request);
},
async preview(request: EntityPreviewRequest): Promise<Blob> {
return await transceiveBlob<EntityPreviewRequest>('entity.preview', request);
},
/**
* Fetch one or more message parts (attachments) inline for rendering.
*
+6 -5
View File
@@ -8,8 +8,9 @@ export { serviceService } from './serviceService';
export { collectionService } from './collectionService';
export { entityService } from './entityService';
export * from '../types/common';
export * from '../types/provider';
export * from '../types/service';
export * from '../types/collection';
export * from '../types/entity';
// Type exports
export type * from '../types/common';
export type * from '../types/provider';
export type * from '../types/service';
export type * from '../types/collection';
export type * from '../types/entity';
-22
View File
@@ -188,28 +188,6 @@ export function transceiveDownload<TRequest>(
return { transaction: request.transaction };
}
export async function transceiveBlob<TRequest>(operation: string, data: TRequest): Promise<Blob> {
const request: ApiRequest<TRequest> = {
version: API_VERSION,
transaction: generateTransactionId(),
operation,
data,
};
let blob: Blob | null = null;
await fetchWrapper.post(API_URL, request, {
headers: { 'Accept': '*/*' },
onStream: async (response: Response) => {
if (response.status === 204) {
throw new Error(`[${operation}] Preview unavailable`);
}
blob = await response.blob();
},
});
if (blob === null) throw new Error(`[${operation}] Empty preview response`);
return blob;
}
function appendHiddenField(form: HTMLFormElement, name: string, value: string): void {
const input = document.createElement('input');
input.type = 'hidden';
-6
View File
@@ -10,7 +10,6 @@ import type {
EntityBlobSelector,
EntityBlobsResponse,
EntityDownloadRequest,
EntityPreviewRequest,
EntityTransmitRequest,
EntityTransmitResponse,
} from '../types/entity'
@@ -519,10 +518,6 @@ export const useEntitiesStore = defineStore('mailEntitiesStore', () => {
}
}
async function preview(request: EntityPreviewRequest): Promise<Blob> {
return await entityService.preview(request)
}
// Return public API
return {
// State (readonly)
@@ -545,7 +540,6 @@ export const useEntitiesStore = defineStore('mailEntitiesStore', () => {
move,
transmit,
download,
preview,
blobs,
}
})
+1 -7
View File
@@ -227,12 +227,6 @@ export interface EntityDownloadRequest {
filename?: string | null;
}
export interface EntityPreviewRequest {
target: EntityIdentifier;
part: EntityBlobSelector & { type: string; size?: number | null };
variant?: string;
}
export interface EntityBlobsRequest {
target: EntityIdentifier;
parts: EntityBlobSelector[];
@@ -252,4 +246,4 @@ export interface EntityBlobsResult extends Omit<EntityBlobsWireResult, 'bytes'>
blob: Blob;
}
export interface EntityBlobsResponse extends Array<EntityBlobsResult> {}
export interface EntityBlobsResponse extends Array<EntityBlobsResult> {}