Merge pull request #8 from hienao/dev

Support scrape submission over HTTP

Author: hienao

frontend/src/lib/idempotency-key.test.ts

@@ -0,0 +1,20 @@
+import { createIdempotencyKey } from './idempotency-key'
+
+describe('createIdempotencyKey', () => {
+  it('uses randomUUID when it is available', () => {
+    const randomUUID = vi.fn(() => 'd9428888-122b-4c26-a04f-efc2b3e153a7')
+    const getRandomValues = vi.fn((bytes: Uint8Array) => bytes)
+
+    expect(createIdempotencyKey({ randomUUID, getRandomValues })).toBe('d9428888-122b-4c26-a04f-efc2b3e153a7')
+    expect(getRandomValues).not.toHaveBeenCalled()
+  })
+
+  it('creates a version 4 UUID with getRandomValues when randomUUID is unavailable', () => {
+    const getRandomValues = vi.fn((bytes: Uint8Array) => {
+      bytes.set(Array.from({ length: 16 }, (_, index) => index))
+      return bytes
+    })
+
+    expect(createIdempotencyKey({ getRandomValues })).toBe('00010203-0405-4607-8809-0a0b0c0d0e0f')
+  })
+})

frontend/src/lib/idempotency-key.ts

@@ -0,0 +1,15 @@
+interface CryptoSource {
+  randomUUID?: () => string
+  getRandomValues: (array: Uint8Array) => Uint8Array
+}
+
+export function createIdempotencyKey(cryptoSource: CryptoSource = globalThis.crypto) {
+  if (typeof cryptoSource.randomUUID === 'function') return cryptoSource.randomUUID()
+
+  const bytes = cryptoSource.getRandomValues(new Uint8Array(16))
+  bytes[6] = (bytes[6] & 0x0f) | 0x40
+  bytes[8] = (bytes[8] & 0x3f) | 0x80
+
+  const hex = Array.from(bytes, (byte) => byte.toString(16).padStart(2, '0')).join('')
+  return `${hex.slice(0, 8)}-${hex.slice(8, 12)}-${hex.slice(12, 16)}-${hex.slice(16, 20)}-${hex.slice(20)}`
+}

frontend/src/pages/targets-page.tsx

@@ -16,6 +16,7 @@ import { FormField } from '@/components/common/form-field'
 import { Message } from '@/components/common/message'
 import { Panel } from '@/components/common/panel'
 import { errorMessage } from '@/lib/error-message'
+import { createIdempotencyKey } from '@/lib/idempotency-key'
 
 const emptyForm: TargetInput = { source_type: 'openlist', connection_id: 0, name: '', root_path: '/', library_type: 'movie', rename_enabled: false, enabled: true }
 
@@ -95,7 +96,7 @@ export function TargetsPage() {
     onError: (error) => setMatchError(errorMessage(error, t('targets.previewError'))),
   })
   const executeJob = useMutation({
-    mutationFn: (value: ScrapePreview) => jobApi.submit(value.target_id, { preview_id: value.id, rename_media: value.plan.proposed_directory_creates.length + value.plan.proposed_directory_renames.length + value.plan.proposed_file_renames.length > 0, confirm_directory_fingerprint: value.fingerprint }, crypto.randomUUID()),
+    mutationFn: (value: ScrapePreview) => jobApi.submit(value.target_id, { preview_id: value.id, rename_media: value.plan.proposed_directory_creates.length + value.plan.proposed_directory_renames.length + value.plan.proposed_file_renames.length > 0, confirm_directory_fingerprint: value.fingerprint }, createIdempotencyKey()),
     onSuccess: () => { setMatchCandidate(null); void navigate('/jobs') },
     onError: (error) => setMatchError(errorMessage(error, t('targets.executeError'))),
   })