Remove database file

Reviewed-on: sfja.skp/maotube#3

.gitignore

@@ -2,3 +2,5 @@ node_modules/
 videos/*
 !videos/.gitkeep
 tmp/
+database.sqlite3
+

index.js

@@ -6,11 +6,48 @@ import path from "path";
 import childProcess from "child_process";
 import levenshtein from "js-levenshtein";
 import cookieParser from "cookie-parser";
-import { fileURLToPath } from 'url';
+import { fileURLToPath } from "url";
+import sqlite3 from "sqlite3";
+import fs from "fs/promises";
+
+const PORT = 8000;
 
-const users = [];
 let sessions = [];
-const videos = [];
+let videoQueue = [];
+
+const db = new sqlite3.Database("database.sqlite3");
+
+function dbGet(query, ...parameters) {
+    return new Promise((resolve, reject) => db.get(query, parameters, (err, data) => err ? reject(err) : resolve(data)));
+}
+
+function dbAll(query, ...parameters) {
+    return new Promise((resolve, reject) => db.all(query, parameters, (err, data) => err ? reject(err) : resolve(data)));
+}
+
+function dbRun(query, ...parameters) {
+    return new Promise((resolve, reject) => db.run(query, parameters, (err, data) => err ? reject(err) : resolve(data)));
+}
+
+function runCommand(cmd, args) {
+    return new Promise(resolve => {
+        const process = childProcess.spawn(cmd, args);
+
+        let data = "";
+        let error = false;
+        process.stdout.on("data", chunk => data += chunk);
+        process.stderr.on("data", chunk => {
+            error = true;
+            data += chunk;
+        });
+
+        process.on("close", () => resolve({ error, data }));
+    });
+}
+
+function videoPath(id) {
+    return `videos/${id}.webm`;
+}
 
 function randomString(length) {
     const chars = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ123456789";
@@ -25,77 +62,8 @@ function dirname() {
     return path.dirname(fileURLToPath(import.meta.url));
 }
 
-const app = express();
-app.use(cors());
-app.use(express.json());
-app.use(cookieParser());
-app.use(express.urlencoded({ extended: true }));
-
-app.use("/", express.static("public/"));
-app.use("/videos", express.static("videos/"));
-
-app.post("/api/register", async (req, res) => {
-    const { username, password } = req.body;
-    if (typeof username !== "string" || typeof password !== "string") {
-        return res.status(400).json({ ok: false, error: "bad request" });
-    }
-    const existingUser = users.find(user => user.username === username);
-    if (existingUser !== undefined) {
-        return res.status(400).json({ ok: false, error: "username taken" });
-    }
-    const passwordHash = await bcrypt.hash(password, 10);
-    const id = users.length;
-    const user = { id, username, passwordHash };
-    users.push(user);
-    return res.status(200).json({ ok: true, user });
-});
-
-app.post("/api/login", async (req, res) => {
-    const { username, password } = req.body;
-    if (typeof username !== "string" || typeof password !== "string") {
-        return res.status(400).json({ ok: false, error: "bad request" });
-    }
-    const user = users.find(user => user.username === username);
-    if (user === undefined) {
-        return res.status(400).json({ ok: false, error: "wrong username/password" });
-    }
-    if (!await bcrypt.compare(password, user.passwordHash)) {
-        return res.status(400).json({ ok: false, error: "wrong username/password" });
-    }
-    sessions = sessions.filter(session => session.userId !== user.id);
-    const token = randomString(64);
-    const session = { userId: user.id, token };
-    sessions.push(session);
-    res.clearCookie("token");
-    res.cookie("token", token);
-    return res.status(200).json({ ok: true, session });
-});
-
-
-app.get("/api/search", async (req, res) => {
-    const page = +req.query.page || 0;
-    const search = req.query.query;
-    if (!search) {
-        return res.status(400).json({ ok: false, error: "bad request" });
-    }
-    const [start, end] = [20 * page, 20 * (page + 1)];
-    const withDistance = videos
-        .map(video => ({ dist: levenshtein(search, video.title), ...video }));
-    withDistance.sort((a, b) => a.dist - b.dist);
-    const returnedVideos = withDistance
-        .slice(start, end)
-        .map(video => {
-            const user = users.find(user => user.id === video.userId);
-            if (!user) {
-                return { ...video, author: "[Liberal]" };
-            }
-            return { ...video, author: user.username };
-        });
-    return res.status(200).json({ ok: true, videos: returnedVideos, total: videos.length });
-});
-
 function authorized() {
-    return (req, res, next) => {
+    return async (req, res, next) => {
         const token = (() => {
             if (req.cookies && "token" in req.cookies) {
                 return req.cookies["token"];
@@ -114,7 +82,7 @@ function authorized() {
         if (session === undefined) {
             return res.status(400).json({ ok: false, error: "unauthorized" });
         }
-        const user = users.find(user => user.id === session.userId);
+        const user = await dbGet("SELECT * FROM users WHERE id = ?", session.userId);
         if (user === undefined) {
             throw new Error("error: session with invalid userId");
         }
@@ -123,53 +91,225 @@ function authorized() {
     }
 }
 
+const app = express();
+app.use(cors());
+app.use(express.json());
+app.use(cookieParser());
+app.use(express.urlencoded({ extended: true }));
+
+app.use("/", express.static("public/"));
+app.use("/videos", express.static("videos/"));
+
+app.post("/api/register", async (req, res) => {
+    const { username, password } = req.body;
+
+    if (typeof username !== "string" || typeof password !== "string") {
+        return res.status(400).json({ ok: false, error: "bad request" });
+    }
+
+    const existingUser = await dbGet("SELECT * FROM users WHERE username = ?", username);
+
+    if (existingUser !== undefined) {
+        return res.status(400).json({ ok: false, error: "username taken" });
+    }
+
+    const passwordHash = await bcrypt.hash(password, 10);
+
+    await dbGet("INSERT INTO users (username, password) VALUES (?, ?)", username, passwordHash);
+
+    return res.status(200).json({ ok: true });
+});
+
+app.post("/api/login", async (req, res) => {
+    const { username, password } = req.body;
+
+    if (typeof username !== "string" || typeof password !== "string") {
+        return res.status(400).json({ ok: false, error: "bad request" });
+    }
+
+    const user = await dbGet("SELECT * FROM users WHERE username = ?", username);
+
+    if (user === undefined) {
+        return res.status(400).json({ ok: false, error: "wrong username/password" });
+    }
+
+    if (!await bcrypt.compare(password, user.password)) {
+        return res.status(400).json({ ok: false, error: "wrong username/password" });
+    }
+
+    sessions = sessions.filter(session => session.userId !== user.id);
+
+    const token = randomString(64);
+    const session = { userId: user.id, token };
+
+    sessions.push(session);
+
+    res.clearCookie("token");
+    res.cookie("token", token);
+
+    return res.status(200).json({ ok: true, session });
+});
+
+
+app.get("/api/search", async (req, res) => {
+    const page = +req.query.page || 0;
+    const search = req.query.query;
+
+    if (!search) {
+        return res.status(400).json({ ok: false, error: "bad request" });
+    }
+
+    const [start, end] = [20 * page, 20];
+    const videos = await dbAll(`
+        SELECT videos.*, users.username AS author
+        FROM videos
+        JOIN users ON users.id = videos.user_id
+        WHERE title LIKE CONCAT('%', ?, '%')
+        LIMIT ?
+        OFFSET ?
+    `, search, end, start);
+
+    const { total } = await dbGet("SELECT COUNT(*) AS total FROM videos");
+
+    return res.status(200).json({ ok: true, videos, total });
+});
+
 app.get("/api/logout", authorized(), (req, res) => {
     sessions = sessions.filter(session => session.userId !== req.user.id);
     return res.status(200).json({ ok: true });
 });
 
-app.post("/api/upload_video", authorized(), fileUpload({ limits: { fileSize: 2 ** 26 }, useTempFiles: true }), async (req, res) => {
-    const { title } = req.body;
+app.post("/api/upload-video", authorized(), fileUpload({ limits: { fileSize: 2 ** 26 }, useTempFiles: true }), async (req, res) => {
+    const { title, description } = req.body;
+    if (!title) {
+        return res.status(400).json({ ok: false, error: "bad request" });
+    }
+
     if (!req.files || !req.files.video) {
         return res.status(400).json({ ok: false, error: "bad request" });
     }
+
     if (req.files.video.mimetype !== "video/mp4") {
-        return res.status(400).json({ ok: false, error: "bad mimetype" });
+        return res.status(415).json({ ok: false, error: "bad mimetype" });
     }
+
     const userId = req.user.id;
     const id = randomString(4);
     const tempPath = req.files.video.tempFilePath;
-    const newPath = path.join(dirname(), "videos", `${id}.mp4`);
-    console.log(newPath);
+    const newPath = path.join(dirname(), videoPath(id));
+    const thumbnailPath = path.join(dirname(), "videos", `${id}.png`);
 
-    const exitCode = await new Promise((resolve, _reject) => {
-        const process = childProcess.spawn("HandBrakeCLI", ["-i", tempPath, "-o", newPath, "-Z", "Social 25 MB 5 Minutes 360p60"]);
-        process.stderr.on("data", (data) => {
-            console.error(data.toString());
-        });
-        process.on("close", (code) => {
-            resolve(code);
-        })
-    })
-    if (exitCode !== 0) {
-        throw new Error("handbrake failed");
+    const durationResult = await runCommand("ffprobe", ["-i", tempPath, "-show_format", "-loglevel", "error"]);
+    if (durationResult.error) {
+        return res.status(400).json({ ok: false, error: "invalid video file" });
     }
 
-    const video = {
-        id,
+    const duration = parseFloat(durationResult.data.match(/duration=([.\d]+)/)[1]) * 1_000_000;;
+
+    const queueItem = {
+        videoId: id,
         userId,
         title,
-        path: newPath,
+        errors: [],
+        progress: 0,
+        duration,
     };
-    videos.push(video);
+
+    videoQueue.push(queueItem);
+
+    const progressPath = path.join(dirname(), "tmp", "progress", `${id}.txt`)
+    const uploadProcess = childProcess.spawn("ffmpeg", ["-i", tempPath, "-b:v", "1M", "-b:a", "192k", "-progress", progressPath, "-loglevel", "error", newPath]);
+    const thumbnailProcess = childProcess.spawn("ffmpeg", ["-i", tempPath, "-ss", "00:00:01.000", "-vframes", "1", "-loglevel", "error", thumbnailPath]);
+
+    uploadProcess.stderr.on("data", data => queueItem.errors.push(data.toString()));
+    thumbnailProcess.stderr.on("data", data => queueItem.errors.push(data.toString()));
+
+    uploadProcess.on("close", () => {
+        if (queueItem.errors.length) {
+            return;
+        }
+
+        dbRun(
+            "INSERT INTO videos (id, user_id, title, description, created_at) VALUES (?, ?, ?, ?, ?)",
+            id, userId, title, description ?? "", new Date().toISOString()
+        );
+
+        const index = videoQueue.indexOf(item => item.videoId === queueItem.videoId)
+        videoQueue.splice(index, 1);
+    });
+
+    return res.status(200).json({ ok: true });
+});
+
+app.get("/api/video-queue", authorized(), (req, res) => {
+    const userId = req.user.id;
+
+    const queue = videoQueue.filter(item => item.userId === userId);
+
+    return res.status(200).json({ ok: true, queue });
+});
+
+app.get("/api/video-info", async (req, res) => {
+    const id = req.query["id"];
+
+    const video = await dbGet(`
+        SELECT videos.id, videos.title, videos.description, videos.created_at, users.username AS author
+        FROM videos
+        JOIN users ON users.id = videos.user_id
+        WHERE videos.id = ?
+        LIMIT 1
+    `, id);
+
+    if (!video) {
+        return res.status(404).json({ ok: false, error: "video not found" });
+    }
+
+    video.path = path.join("/", videoPath(id));
+
     return res.status(200).json({ ok: true, video });
-})
+});
 
 app.use((err, req, res, next) => {
     console.error(err);
     res.status(500).json({ ok: false, error: "server error" })
 });
 
-app.listen(8000, () => {
+async function main() {
+    (async () => {
+        const progressPath = path.join(dirname(), "tmp", "progress");
+
+        await fs.mkdir(progressPath, { recursive: true });
+
+        const watch = fs.watch(progressPath, { recursive: true });
+
+        for await (const event of watch) {
+            const videoId = event.filename.replace(".txt", "");
+            const queueItem = videoQueue.find(item => item.videoId === videoId);
+
+            if (!queueItem) {
+                continue;
+            }
+
+            fs.readFile(path.join(progressPath, event.filename), "utf-8")
+                .then(string => {
+                    const index = string.lastIndexOf("out_time_ms=");
+                    if (index === -1) return;
+
+                    const length = parseInt(string.slice(index).match(/out_time_ms=(\d+)/)[1]);
+
+                    for (const i in videoQueue) {
+                        if (videoQueue[i].videoId !== videoId) continue;
+
+                        videoQueue[i].progress = length;
+                    }
+                });
+        }
+    })();
+
+    app.listen(PORT, () => {
         console.log("app at http://localhost:8000/");
-})
+    });
+}
+
+main();
+

migration.sql

@@ -0,0 +1,15 @@
+CREATE TABLE users (
+    id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL,
+    username TEXT NOT NULL,
+    password TEXT NOT NULL
+);
+
+CREATE TABLE videos (
+    id TEXT PRIMARY KEY NOT NULL,
+    user_id INTEGER,
+    title TEXT NOT NULL,
+    description TEXT NOT NULL,
+    created_at TEXT NOT NULL,
+    FOREIGN KEY(user_id) REFERENCES users(id)
+);
+

package.json

@@ -16,6 +16,7 @@
     "cors": "^2.8.5",
     "express": "^4.18.2",
     "express-fileupload": "^1.4.3",
-    "js-levenshtein": "^1.1.6"
+    "js-levenshtein": "^1.1.6",
+    "sqlite3": "^5.1.7"
   }
 }

public/header.js

@@ -3,39 +3,42 @@ function displayHeader() {
         {
             href: "/",
             name: "Home",
+            accessKey: "h",
         },
         {
             href: "/register/",
             name: "Register",
+            accessKey: "r",
         },
         {
             href: "/login/",
             name: "Login",
+            accessKey: "l",
         },
         {
             href: "/upload/",
             name: "Upload",
+            accessKey: "u",
         },
-    ].map(({name, href}) => {
+    ].map(({name, href, accessKey}) => {
         if (href === window.location.pathname) {
-            return `<a href="${href}"><b>${name}</b></a>`
+            return `<a href="${href}" accesskey="${accessKey}"><b>${name}</b></a>`
         } else {
-            return `<a href="${href}">${name}</a>`
+            return `<a href="${href}" accesskey="${accessKey}">${name}</a>`
         }
     }).join(" - ");
 
     document.querySelector("h1").outerHTML = `
         <header>
-            <a href="/">
             <h1 id="app-name">MaoTube</h1>
-            </a>
             <nav>
                 ${links}
-            </nav>
-            <form method="GET" target="_self" action="/search">
-                <input type="text" id="search" name="query" placeholder="Search">
+                -
+                <form id="search-form" method="GET" target="_self" action="/search">
+                    <input type="text" id="search" name="query" placeholder="Search" accesskey="s">
                     <input type="submit" value="Search">
                 </form>
+            </nav>
         </header>
     `
 }

public/helpers.js

@@ -0,0 +1,8 @@
+function error(message) {
+    const errorContainer = document.getElementById("mao-error");
+    const errorElement = document.getElementById("mao-error-message");
+
+    errorElement.innerText = message || "unknown error";
+    errorContainer.classList.remove("hidden");
+}
+

public/login/index.html

@@ -9,7 +9,7 @@
         <h1>MaoTube</h1>
         <div>
             <label for="username"><p>Username</p></label>
-            <input type="text" name="username" id="username">
+            <input type="text" name="username" id="username" autofocus>
             <label for="password"><p>Password</p></label>
             <input type="password" name="password" id="password">
             <br>

public/queue/index.html

@@ -0,0 +1,31 @@
+<!DOCTYPE html>
+<html lang="en">
+    <head>
+        <meta charset="utf-8">
+        <title>MaoTube</title>
+        <link rel="stylesheet" href="/style.css">
+        <script defer src="/helpers.js"></script>
+        <script defer src="script.js"></script>
+        <script defer src="/header.js"></script>
+    </head>
+    <body>
+        <h1>MaoTube</h1>
+        <div>
+            <h1>Uploading videos</h1>
+        </div>
+        <br>
+        <div id="result">
+            <noscript>
+                <div class="mao-error">
+                    <p>javascript not enabled</p>
+                    <p>bottom text</p>
+                </div>
+            </noscript>
+            <div id="mao-error" class="mao-error hidden">
+                <p id="mao-error-message"></p>
+                <p>bottom text</p>
+            </div>
+        </div>
+    </body>
+</html>
+

public/queue/script.js

@@ -0,0 +1,57 @@
+function readableMicroseconds(us) {
+    const min = parseInt(us / 60_000_000);
+    const sec = parseInt((us % 60_000_000) / 1_000_000);
+
+    if (!min) {
+        return `${sec}s`;
+    }
+
+    return `${min}m ${sec}s`;
+}
+
+async function main() {
+    const response = await fetch(`/api/video-queue`);
+    if (!response.ok) {
+        error("something went wrong");
+        return;
+    }
+
+    const json = await response.json();
+    if (!json.ok) {
+        error(json.error);
+    }
+
+    const queue = json.queue;
+
+    document.getElementById("result").innerHTML =
+        `<p>Currently processing ${queue.length} video(s)</p>`
+        + `<ul id="video-list">`
+        + queue
+            .map(vid => {
+                const percentage = parseInt(vid.progress / vid.duration * 100);
+                const uploadedTime = readableMicroseconds(vid.progress);
+                const totalTime = readableMicroseconds(vid.duration);
+
+                return `
+                    <li>
+                        <div class="video-item">
+                            <div class="video-image">
+                                <img class="shadow" src="/videos/${vid.videoId}.png" alt="">
+                                <img class="non-shadow" src="/videos/${vid.videoId}.png" alt="">
+                            </div>
+                            <span class="video-info">
+                                <b>${vid.title}</b>
+                                <br>
+                                <p>Uploaded ${uploadedTime} of ${totalTime} (${percentage}%)</p>
+                                <progress max="${vid.duration}" value="${vid.progress}">${percentage}%</progress>
+                            </span>
+                        </div>
+                    </li>
+                `;
+            })
+            .join("")
+        + "</ul>";
+}
+
+main();
+

public/register/index.html

@@ -9,7 +9,7 @@
         <h1>MaoTube</h1>
         <div>
             <label for="username"><p>Username</p></label>
-            <input type="text" name="username" id="username">
+            <input type="text" name="username" id="username" autofocus>
             <label for="password"><p>Password</p></label>
             <input type="password" name="password" id="password">
             <br>

public/search/script.js

@@ -17,12 +17,28 @@ function displayResponse(response) {
         error("search returned no results");
         return;
     }
+    console.log(videos);
     const resultElement = document.getElementById("result");
     resultElement.innerHTML = `<p>Showing ${videos.length}/${total} results.</p>`
         + "<ul id='video-list'>"
         + videos
             .map(v => {
-                return `<li><p><a href="/watch?id=${v.id}">${v.title}</a> - ${v.author}</p></li>`
+                console.log(v);
+                return `
+					<li>
+						<div class="video-item">
+							<div class="video-image">
+								<img class="shadow" src="/videos/${v.id}.png" alt="">
+								<img class="non-shadow" src="/videos/${v.id}.png" alt="">
+							</div>
+							<span class="video-info">
+								<a href="/watch?id=${v.id}">${v.title}</a>
+								<br>
+								by ${v.author}
+							</span>
+						</div>
+					</li>
+				`;
             })
             .join("")
         + "</ul>";

public/style.css

@@ -1,26 +1,49 @@
+:root {
+    color-scheme: light dark;
+
+    --red: #c51e0e;
+}
+
+@media (prefers-color-scheme: dark) {
+    :root {
+        --red: #F4511E;
+    }
+}
 
 *, *::before, *::after {
     box-sizing: border-box;
+    appearance: none;
 }
 
-:root {
-    color-scheme: light dark;
+*:focus {
+    outline: 2px solid var(--red);
 }
 
 body {
     margin: 0 auto;
     padding: 0;
     text-align: center;
-    font-family: system-ui, sans-serif;
-    background-color: #dff3f1;
-    color: #211;
 }
 
-@media (prefers-color-scheme: dark) {
-  body {
-    background: #211;
-    color: #dff3f1;
-  }
+a {
+    color: var(--red);
+}
+
+textarea, input {
+    font-family: sans-serif;
+    font-size: 0.8em;
+}
+
+nav {
+    margin-bottom: 20px;
+}
+
+input::file-selector-button {
+    appearance: none;
+}
+
+#search-form {
+    display: inline-block;
 }
 
 .mao-error {
@@ -38,7 +61,7 @@ body {
 }
 
 .mao-error p {
-  color: #fff;
+  color: white;
   text-transform: uppercase;
   font-weight: bold;
   font-family: "Impact", "Bebas", "League Gothic", "Oswald", "Coluna", "Ubuntu Condensed", system-ui, sans-serif;
@@ -59,50 +82,75 @@ body {
     margin-top: auto;
 }
 
-ul#video-list {
+#video-list {
     padding: 0;
     list-style: none;
+    width: 100%;
+    max-width: 800px;
+    margin: auto;
 }
 
 #video-player {
-    max-height: 80vh;
+    height: 60vh;
+    width: 100%;
+    background-color: black;
 }
 
-header {
+#video-result {
+    width: 106vh;
+    display: none;
+    text-align: left;
+    margin: auto;
+}
+
+.video-item {
+    padding: 0.5rem;
     display: flex;
-    align-items: center;
-    gap: 30px;
-    background-image: linear-gradient(to bottom, #c51e0e, #FF5722);
-    padding: 20px;
-    box-shadow: 0 15px 15px rgba(0, 0, 0, 0.2);
-    color: #fcf4c8;
+    flex-direction: row;
+    align-items: flex-start;
+    gap: 2rem;
+    text-align: left;
+    background-color: rgba(255, 255, 255, 0.3);
+    border: 1px solid black;
 }
 
-#app-name {
-    padding-right: 20px;
-    margin: 0;
-}
-
-a {
-    color: #fcf4c8;
-    text-decoration: none;
-}
-
-#search {
-    border: none;
-    outline: none;
-    padding: 10px;
-    background-color: rgba(0, 0, 0, 0.2);
-    transition-duration: 100ms;
-    color: white;
-}
-
-#search:hover {
+@media (prefers-color-scheme: dark) {
+    .video-item {
         background-color: rgba(0, 0, 0, 0.3);
+    }
 }
 
-#search:focus {
-    background-color: white;
-    color: black;
+.video-item .video-image {
+    position: relative;
+    width: 200px;
+    height: 113px;
+    overflow: hidden;
+    background-color: black;
+}
+
+
+.video-item .video-image img {
+    position: absolute;
+    inset: 0;
+    width: 100%;
+    height: 100%;
+}
+
+.video-item .shadow {
+    object-fit: cover;
+    filter: blur(0.25rem) brightness(50%);
+}
+
+.video-item .non-shadow {
+    object-fit: contain;
+}
+
+.video-item .video-info {
+    padding-block: 0.5em;
+}
+
+.video-item a {
+    font-size: 1.4em;
+    font-weight: bold;
 }
 

public/upload/index.html

@@ -4,19 +4,36 @@
         <meta charset="utf-8">
         <title>MaoTube</title>
         <link rel="stylesheet" href="/style.css">
+        <script defer src="/header.js"></script>
+        <script defer src="/helpers.js"></script>
+        <script defer src="script.js"></script>
     </head>
     <body>
         <h1>MaoTube</h1>
-        <form action="/api/upload_video" method="POST" enctype="multipart/form-data">
-            <label for="username"><p>Title</p></label>
-            <input type="text" name="title">
-            <label for="password"><p>Video</p></label>
-            <input type="file" name="video">
-            <br>
-            <br>
+        <form id="upload-form" method="POST" action="/api/upload-video" enctype="multipart/form-data">
+            <label for="title"><p>Title</p></label>
+            <input type="text" name="title" id="title" required autofocus>
+            <label for="description"><p>Description</p></label>
+            <textarea name="description" id="description"></textarea>
+            <label for="video"><p>Video</p></label>
+            <input type="file" name="video" id="video" required>
+            <br><br>
             <input type="submit" id="submit" value="Upload">
+            <br><br>
+            <a href="/queue">View upload queue</a>
         </form>
-        <script src="/header.js"></script>
+
+        <noscript>
+            <div class="mao-error">
+                <p>javascript not enabled</p>
+                <p>bottom text</p>
+            </div>
+        </noscript>
+
+        <div id="mao-error" class="mao-error hidden">
+            <p id="mao-error-message"></p>
+            <p>bottom text</p>
+        </div>
     </body>
 </html>
 

public/upload/script.js

@@ -0,0 +1,22 @@
+document.getElementById("upload-form").addEventListener("submit", event => {
+    event.preventDefault();
+
+    const data = new FormData(event.target);
+
+    fetch("/api/upload-video", {
+        method: "POST",
+        body: data,
+    })
+    .then(response => response.json())
+    .then(response => {
+        if (!response.ok) {
+            error(response.error);
+            return;
+        }
+
+        location.href = "/queue";
+    })
+    .catch(err => {
+        error("failed to upload video");
+    });
+});

public/watch/index.html

@@ -4,29 +4,35 @@
         <meta charset="utf-8">
         <title>MaoTube</title>
         <link rel="stylesheet" href="/style.css">
+        <script defer src="script.js"></script>
+        <script defer src="/header.js"></script>
     </head>
     <body>
         <h1>MaoTube</h1>
-        <form method="GET" target="_self" action="/search">
-            <label for="query"><p>Search</p></label>
-            <input type="text" id="query" name="query" placeholder="...">
-            <input type="submit" value="Search">
-        </form>
         <br>
         <div id="result">
+            <div id="video-result">
+                <video id="video-player"></video>
+                <h1 id="video-title"></h1>
+                <p id="video-author"></p>
+                <br>
+                <hr>
+                <br>
+                <p id="video-description"></p>
+            </div>
+
             <noscript>
                 <div class="mao-error">
                     <p>javascript not enabled</p>
                     <p>bottom text</p>
                 </div>
             </noscript>
+
             <div id="mao-error" class="mao-error hidden">
                 <p id="mao-error-message"></p>
                 <p>bottom text</p>
             </div>
         </div>
-        <script src="script.js"></script>
-        <script src="/header.js"></script>
     </body>
 </html>
 

public/watch/script.js

@@ -1,13 +1,14 @@
-
 function error(message) {
     const errorContainer = document.getElementById("mao-error");
     const errorElement = document.getElementById("mao-error-message");
 
-    errorElement.innerText = message;
+    document.getElementById("video-result").style.display = "none";
+
+    errorElement.innerText = message || "unknown error";
     errorContainer.classList.remove("hidden");
 }
 
-function main() {
+async function main() {
     const params = new URLSearchParams(window.location.search);
     const id = params.get("id");
     if (!id) {
@@ -15,17 +16,36 @@ function main() {
         return;
     }
 
-    const result = document.getElementById("result");
-
-    const video = document.createElement("video");
-    video.controls = true;
-    video.id = "video-player";
-    video.src = `/videos/${id}.mp4`;
-    result.appendChild(video);
-    video.onerror = () => {
-        video.remove();
-        error("invalid id parameter");
+    const info = await fetch(`/api/video-info?id=${id}`);
+    if (!info.ok) {
+        error("error fetching video info");
+        return;
     }
+
+    const json = await info.json();
+    if (!json.ok) {
+        error(json.error);
+        return;
+    }
+
+    const video = json.video;
+
+    const player = document.getElementById("video-player");
+    player.controls = true;
+    player.src = video.path;
+    player.onerror = () => {
+        error("unable to play video");
+    }
+    player.onload = () => {
+        player.style.height = player.clientWidth / 16 * 9 + "px";
+    }
+
+    document.getElementById("video-title").innerText = video.title;
+    document.getElementById("video-author").innerText = "by " + video.author + " - published " + new Date(video.created_at).toLocaleDateString();
+    document.getElementById("video-description").innerText = video.description;
+
+    document.getElementById("video-result").style.display = "block";
 }
 
 main();
+