server-demo.js

var port = process.argv[2] || 8888

var braid_text = require("./index.js")

// TODO: set a custom database folder
// (the default is ./braid-text-db)
//
// braid_text.db_folder = './custom_db_folder'

var server = require("http").createServer(async (req, res) => {
    console.log(`${req.method} ${req.url}`)

    // Free the CORS
    free_the_cors(req, res)
    if (req.method === 'OPTIONS') return


    if (req.url.endsWith("?editor")) {
        res.writeHead(200, { "Content-Type": "text/html", "Cache-Control": "no-cache" })
        require("fs").createReadStream("./editor.html").pipe(res)
        return
    }

    if (req.url.endsWith("?markdown-editor")) {
        res.writeHead(200, { "Content-Type": "text/html", "Cache-Control": "no-cache" })
        require("fs").createReadStream("./markdown-editor.html").pipe(res)
        return
    }

    if (req.url == '/simpleton-client.js') {
        res.writeHead(200, { "Content-Type": "text/javascript", "Cache-Control": "no-cache" })
        require("fs").createReadStream("./simpleton-client.js").pipe(res)
        return
    }

    if (req.url.startsWith('/test.html')) {
        let parts = req.url.split(/[\?&=]/g)

        if (parts[1] === 'check') {
            res.writeHead(200, { "Content-Type": "application/json", "Cache-Control": "no-cache" })
            return res.end(JSON.stringify({
                checking: parts[2],
                result: (await braid_text.get(parts[2])) != null
            }))
        } else if (parts[1] === 'dt_create_bytes_big_name') {
            try {
                braid_text.dt_create_bytes('x'.repeat(1000000) + '-0', [], 0, 0, 'hi')
                return res.end(JSON.stringify({ ok: true }))
            } catch (e) {
                return res.end(JSON.stringify({ ok: false, error: '' + e }))
            }
        } else if (parts[1] === 'dt_create_bytes_many_names') {
            try {
                braid_text.dt_create_bytes('hi-0', new Array(1000000).fill(0).map((x, i) => `x${i}-0`), 0, 0, 'hi')
                return res.end(JSON.stringify({ ok: true }))
            } catch (e) {
                return res.end(JSON.stringify({ ok: false, error: '' + e }))
            }
        }

        res.writeHead(200, { "Content-Type": "text/html", "Cache-Control": "no-cache" })
        require("fs").createReadStream("./test.html").pipe(res)
        return
    }

    // TODO: uncomment out the code below to add /pages endpoint,
    // which displays all the currently used keys
    // 
    // if (req.url === '/pages') {
    //     var pages = await braid_text.list()
    //     res.writeHead(200, {
    //         "Content-Type": "application/json",
    //         "Access-Control-Expose-Headers": "*"
    //     })
    //     res.end(JSON.stringify(pages))
    //     return
    // }

    // TODO: uncomment out the code below to add basic access control,
    // where a user logs in by openning the javascript console
    // and entering: document.cookie = 'fake_password'
    // 
    // var admin_pass = "fake_password"
    // 
    // if (req.method == "PUT" || req.method == "POST" || req.method == "PATCH") {
    //     if (!req.headers.cookie?.split(/;/).map(x => x.trim()).some(x => x === admin_pass)) {
    //         console.log("Blocked PUT:", { cookie: req.headers.cookie })
    //         res.statusCode = 401
    //         return res.end()
    //     }
    // }

    // Create some initial text for new documents
    if (!(await braid_text.get(req.url, {})).version.length) {
        await braid_text.put(req.url, {body: 'This is a fresh blank document, ready for you to edit.' })
    }

    // Now serve the collaborative text!
    braid_text.serve(req, res)
})

server.listen(port, () => {
    console.log(`server started on port ${port}`)
})


// Free the CORS!
function free_the_cors (req, res) {
    res.setHeader('Range-Request-Allow-Methods', 'PATCH, PUT')
    res.setHeader('Range-Request-Allow-Units', 'json')
    res.setHeader("Patches", "OK")
    var free_the_cors = {
        "Access-Control-Allow-Origin": "*",
        "Access-Control-Allow-Methods": "OPTIONS, HEAD, GET, PUT, UNSUBSCRIBE",
        "Access-Control-Allow-Headers": "subscribe, client, version, parents, merge-type, content-type, content-range, patches, cache-control, peer"
    }
    Object.entries(free_the_cors).forEach(x => res.setHeader(x[0], x[1]))
    if (req.method === 'OPTIONS') {
        res.writeHead(200)
        res.end()
    }
}