Upload videos from your app

import { openAsBlob } from 'node:fs';
import { basename } from 'node:path';
import { SlubyClient } from '@sluby/sdk';

const { SLUBY_URL, SLUBY_API_KEY } = process.env;
if (!SLUBY_URL || !SLUBY_API_KEY) throw new Error('Set SLUBY_URL and SLUBY_API_KEY.');
const client = new SlubyClient({ baseUrl: SLUBY_URL, apiKey: SLUBY_API_KEY });

const path = process.argv[2];
if (!path) throw new Error('usage: node upload.mjs <file>');

// Ctrl+C cancels the upload and discards the asset it created
const controller = new AbortController();
process.once('SIGINT', () => controller.abort());

const upload = client.uploads.upload(await openAsBlob(path), {
  title: basename(path),
  description: 'Uploaded from my server',
  accessTier: 'private',
  signal: controller.signal,
  onProgress: (percent, sent, total) => console.log(`${percent}% (${sent} of ${total} bytes)`),
});

console.log(`asset ${await upload.assetId}, upload ${await upload.uploadId}`);
await upload;
console.log('all bytes received, processing starts');

const upload = client.uploads.upload(file, { title: 'Long recording' });

await upload.pause(); // stops sending; the bytes received so far stay on the server
console.log(upload.isPaused); // true
upload.resume(); // continues from the last byte the server has

await upload.abort(); // ends the upload and deletes the asset it created
await upload.catch((err) => console.log(err.name)); // AbortError

import { AbortError, PermissionError, SlubyError } from '@sluby/sdk';

const upload = client.uploads.upload(file, { title: 'Demo' });
try {
  await upload;
} catch (err) {
  if (err instanceof AbortError) console.log('cancelled');
  else if (err instanceof PermissionError) console.log('the key has no upload scope');
  else if (err instanceof SlubyError)
    console.log(`upload failed (${err.statusCode}): ${err.message}`);
  else throw err;
}

export async function sendVideo(file: File): Promise<string> {
  const res = await fetch(`/videos?title=${encodeURIComponent(file.name)}`, {
    method: 'POST',
    body: file,
  });
  if (!res.ok) throw new Error(`Upload failed with status ${res.status}`);
  const { assetId } = (await res.json()) as { assetId: string };
  return assetId;
}

import { createServer } from 'node:http';
import { createWriteStream, openAsBlob } from 'node:fs';
import { rm } from 'node:fs/promises';
import { randomUUID } from 'node:crypto';
import { tmpdir } from 'node:os';
import { join } from 'node:path';
import { pipeline } from 'node:stream/promises';
import { SlubyClient } from '@sluby/sdk';

const { SLUBY_URL, SLUBY_API_KEY } = process.env;
if (!SLUBY_URL || !SLUBY_API_KEY) throw new Error('Set SLUBY_URL and SLUBY_API_KEY.');
const client = new SlubyClient({ baseUrl: SLUBY_URL, apiKey: SLUBY_API_KEY });

createServer(async (req, res) => {
  const url = new URL(req.url ?? '/', 'http://localhost');
  if (req.method !== 'POST' || url.pathname !== '/videos') {
    res.writeHead(404).end();
    return;
  }
  // check your own user's session here before you accept the file

  const path = join(tmpdir(), randomUUID());
  try {
    await pipeline(req, createWriteStream(path));
    const upload = client.uploads.upload(await openAsBlob(path), {
      title: url.searchParams.get('title') || 'Untitled',
    });
    const assetId = await upload.assetId;
    await upload;
    res.writeHead(201, { 'Content-Type': 'application/json' });
    res.end(JSON.stringify({ assetId }));
  } catch (err) {
    console.error(err);
    res.writeHead(502, { 'Content-Type': 'application/json' });
    res.end(JSON.stringify({ error: 'Upload failed' }));
  } finally {
    await rm(path, { force: true });
  }
}).listen(3000);

import { readFile } from 'node:fs/promises';
import * as tus from 'tus-js-client';

const { SLUBY_URL, SLUBY_API_KEY } = process.env;
if (!SLUBY_URL || !SLUBY_API_KEY) throw new Error('Set SLUBY_URL and SLUBY_API_KEY.');

const file = await readFile('./video.mp4');

const upload = new tus.Upload(file, {
  endpoint: `${SLUBY_URL}/api/v1/uploads`,
  headers: { Authorization: `Bearer ${SLUBY_API_KEY}` },
  chunkSize: 10 * 1024 * 1024,
  metadata: {
    filename: 'video.mp4',
    filetype: 'video/mp4',
    title: 'Uploaded with tus-js-client',
    description: '',
    accessTier: 'public',
  },
  onError: (err) => console.error('upload failed', err),
  onSuccess: async () => {
    // the upload id is the last path segment of the upload URL
    const uploadId = String(upload.url).split('/').pop();
    const res = await fetch(`${SLUBY_URL}/api/v1/uploads/${uploadId}`, {
      headers: { Authorization: `Bearer ${SLUBY_API_KEY}` },
    });
    const session = await res.json();
    console.log(`asset ${session.video_asset_id}`);
  },
});
upload.start();