code: development,dbal,uploads (20 files)

This commit is contained in:
Richard Ward
2025-12-30 21:07:33 +00:00
parent c4f39092c0
commit a11dbab933
20 changed files with 20 additions and 20 deletions

View File

@@ -1,7 +1,7 @@
import { promises as fs } from 'fs'
import path from 'path'
import type { BlobListOptions, BlobListResult, BlobMetadata } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { FilesystemContext } from '../context'
import { buildFullPath } from '../paths'
import { readMetadata } from './metadata'

View File

@@ -1,7 +1,7 @@
import { promises as fs } from 'fs'
import path from 'path'
import type { BlobMetadata } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { FilesystemContext } from '../context'
import { buildFullPath, buildMetadataPath } from '../paths'
import { readMetadata } from './metadata'

View File

@@ -1,7 +1,7 @@
import { promises as fs } from 'fs'
import { createHash } from 'crypto'
import type { BlobMetadata } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { FilesystemContext } from '../context'
import { buildFullPath, buildMetadataPath } from '../paths'

View File

@@ -2,7 +2,7 @@ import { promises as fs, createWriteStream } from 'fs'
import path from 'path'
import { pipeline } from 'stream/promises'
import type { BlobMetadata, UploadOptions } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { FilesystemContext } from '../context'
import { buildFullPath, buildMetadataPath } from '../paths'
import { generateEtag, writeMetadata } from './metadata'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import type { DownloadOptions } from '../blob-storage'
import type { MemoryStore } from './store'
import { getBlobOrThrow, normalizeKey } from './utils'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import type { BlobListOptions, BlobListResult, BlobMetadata } from '../blob-storage'
import type { MemoryStore } from './store'
import { toBlobMetadata } from './serialization'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import type { UploadOptions } from '../blob-storage'
import type { MemoryStore } from './store'
import { collectStream, toBlobData, toBlobMetadata } from './serialization'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import type { BlobData, MemoryStore } from './store'
export const normalizeKey = (key: string): string => key.replace(/^\/+/, '').trim()

View File

@@ -7,7 +7,7 @@ import type {
BlobListOptions,
BlobStorageConfig,
} from '../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../core/foundation/errors'
import type { S3Context } from './client'
import { createS3Context } from './client'
import { downloadBuffer, downloadStream } from './operations/downloads'

View File

@@ -1,5 +1,5 @@
import type { DownloadOptions } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import { buildRangeHeader } from '../range'
import type { S3Context } from '../client'

View File

@@ -1,5 +1,5 @@
import type { BlobListOptions, BlobListResult, BlobMetadata } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { S3Context } from '../client'
export async function listBlobs(

View File

@@ -1,5 +1,5 @@
import type { BlobMetadata } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { S3Context } from '../client'
import { getMetadata } from './metadata'

View File

@@ -1,5 +1,5 @@
import type { BlobMetadata } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { S3Context } from '../client'
export async function getMetadata(

View File

@@ -1,5 +1,5 @@
import type { BlobMetadata, UploadOptions } from '../../../blob-storage'
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../../core/foundation/errors'
import type { S3Context } from '../client'
export async function uploadBuffer(

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import type { BlobMetadata } from '../blob-storage'
import { auditCopy, auditDeletion } from './audit-hooks'
import type { TenantAwareDeps } from './context'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import type { TenantContext } from '../../core/foundation/tenant-context'
import type { TenantAwareDeps } from './context'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../../core/foundation/errors'
import { auditUpload } from './audit-hooks'
import type { TenantAwareDeps } from './context'
import { scopeKey } from './context'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../core/foundation/errors'
import type { RPCMessage } from '../utils/rpc-types'
import type { BridgeState } from './state'
import type { MessageRouter } from './message-router'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../core/foundation/errors'
import type { RPCResponse } from '../utils/rpc-types'
import type { BridgeState } from './state'

View File

@@ -1,4 +1,4 @@
import { DBALError } from '@/core/foundation/errors'
import { DBALError } from '../../../core/foundation/errors'
import { generateRequestId } from '../utils/generate-request-id'
import type { RPCMessage } from '../utils/rpc-types'
import type { ConnectionManager } from './connection-manager'