1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
|
import { uploadPublicMedia, MediaUploadError } from '../src/media-upload.js';
import { sha256 } from '@noble/hashes/sha256';
import { bytesToHex } from '@noble/hashes/utils';
let ok = true;
const check = (name, pass) => { console.log(`${pass ? '✓' : '✗'} ${name}`); if (!pass) ok = false; };
const bytes = new TextEncoder().encode('phone video bytes');
const file = new File([bytes], 'clip.mov', { type: 'video/quicktime' });
let signed = null;
const sign = async (event) => (signed = { ...event, id: '1'.repeat(64), pubkey: '2'.repeat(64), sig: '3'.repeat(128) });
const calls = [];
const fetcher = async (url, init) => {
if (init?.method === 'HEAD') return new Response('', { status: 200 }); // the reachability probe
calls.push({ url, init });
if (url.startsWith('https://first')) return new Response(JSON.stringify({ message: 'temporarily unavailable' }), { status: 503 });
return new Response(JSON.stringify({ url: 'https://cdn.example/clip.mov' }), { status: 201, headers: { 'content-type': 'application/json' } });
};
const url = await uploadPublicMedia(file, sign, { servers: ['https://first', 'https://second/'], fetcher, timeoutMs: 1000 });
check('falls back to a second independent media host', url === 'https://cdn.example/clip.mov' && calls.length === 2);
check('uploads the original video type and bytes', calls[1].init.method === 'PUT' && calls[1].init.body === file
&& calls[1].init.headers['content-type'] === 'video/quicktime');
check('hashes the file and binds the hash into Blossom auth', calls[1].init.headers['x-sha-256'] === bytesToHex(sha256(bytes))
&& signed.tags.some((tag) => tag[0] === 'x' && tag[1] === calls[1].init.headers['x-sha-256']));
check('sends signed Blossom authorization', calls[1].init.headers.authorization.startsWith('Nostr '));
// a host that never answers is skipped after the probe, not waited on
{
const puts = [];
const t0 = Date.now();
const u = await uploadPublicMedia(file, sign, {
servers: ['https://dead.example', 'https://alive.example'], timeoutMs: 60_000,
fetcher: async (url, init) => {
if (url.startsWith('https://dead')) return new Promise((_, reject) => init.signal.addEventListener('abort', () => reject(new Error('timeout'))));
if (init.method === 'HEAD') return new Response('', { status: 404 });
puts.push(url);
return new Response(JSON.stringify({ url: 'https://alive.example/x.mov' }), { status: 201 });
},
});
check('an unreachable host is skipped within seconds', u === 'https://alive.example/x.mov' && Date.now() - t0 < 7000 && puts.length === 1);
}
check('ditto is the first host', (await import('../src/media-upload.js')).PUBLIC_MEDIA_SERVERS[0] === 'https://blossom.ditto.pub');
const bareHashUrl = await uploadPublicMedia(file, sign, {
servers: ['https://media.example'], timeoutMs: 1000,
fetcher: async () => new Response(JSON.stringify({ url: '/' + 'a'.repeat(64) }), { status: 201 }),
});
check('adds the video extension when a Blossom server returns a bare hash URL', bareHashUrl.endsWith('.mov'));
try {
await uploadPublicMedia(file, sign, {
servers: ['https://one', 'https://two'], timeoutMs: 1000,
fetcher: async () => new Response('', { status: 413 }),
});
check('reports provider size rejection', false);
} catch (error) {
check('reports provider size rejection', error instanceof MediaUploadError && error.code === 'too-big');
}
console.log(ok ? '\n✅ public media upload works' : '\n❌ public media upload failed');
process.exit(ok ? 0 : 1);
|
