import { createReadStream } from "fs"
import { stat } from "fs/promises"
import { Readable } from "stream"

import { Hono } from "hono"

const app = new Hono()

function nodeToWebStream(nodeStream: Readable) {
    return new ReadableStream({
        start(controller) {
            // 处理数据块
            nodeStream.on("data", chunk => controller.enqueue(chunk))

            // 处理流结束
            nodeStream.on("end", () => controller.close())

            // 处理错误
            nodeStream.on("error", error => controller.error(error))
        },
        cancel() {
            nodeStream.destroy()
        },
    })
}

app.get("/video", async c => {
    const filename = "demo.mp4"
    const { size } = await stat(filename)
    const headers = new Headers()
    headers.set("Content-Type", "video/mp4")
    const range = c.req.header("Range")

    if (!range) {
        headers.set("Content-Length", String(size))
        return c.newResponse(nodeToWebStream(createReadStream("demo.mp4")), {
            status: 200,
            headers,
        })
    }

    const parts = range.replace(/bytes=/, "").split("-")
    const start = parseInt(parts[0])
    const end = parts[1] ? parseInt(parts[1]) : size - 1
    const chunksize = end - start + 1
    headers.set("Content-Range", `bytes ${start}-${end}/${size}`)
    headers.set("Accept-Ranges", "bytes")
    headers.set("Content-Length", String(chunksize))
    return c.newResponse(nodeToWebStream(createReadStream(filename, { start, end })), { status: 206, headers })
})

export default {
    port: 4567,
    fetch: app.fetch,
}

className.replace(/([\[\]\(\):])/g, "\\$1")

const controller = new AbortController()
const signal = controller.signal

fetch(url, { signal })
    .then(response => response.json())
    .then(data => console.log(data))
    .catch(error => console.error(error))

// 取消请求
controller.abort()

useEffect(() => {
    const controller = new AbortController()
    const signal = controller.signal
    window.addEventListener("click", () => console.log("click"), { signal })
    return () => {
        controller.abort()
    }
}, [])

const signal = AbortSignal.timeout(1000)

const controller = new AbortController()
const signal = controller.signal
setTimeout(() => controller.abort(), 1000)

const controller = new AbortController()
const controller2 = new AbortController()
const signal = AbortSignal.any([controller.signal, controller2.signal])

input.value = "123456"

const changeEvent = new Event("change", { bubbles: true })
const inputEvent = new Event("input", { bubbles: true })

input.dispatchEvent(changeEvent)
input.dispatchEvent(inputEvent)

const set = Object.getOwnPropertyDescriptor(HTMLInputElement.prototype, "value")?.set

set?.call(input, "123456")

const inputEvent = new Event("input", { bubbles: true })

input.dispatchEvent(inputEvent)

element.addEventListener("click", function (event) {
    event.stopPropagation()
    console.log("Button clicked")
})

element.addEventListener("click", function (event) {
    event.stopImmediatePropagation()
    console.log("Button clicked")
})

element.addEventListener("click", function (event) {
    console.log("This will not be logged")
})

function foo() {}

// 打印 "foo"
console.log(foo.name)

const foo = (() => function () {})()

// 打印 ""
console.log(foo.name)

const foo = function () {}

// 打印 "foo"
console.log(foo.name)

const bar = () => 0

// 打印 "bar"
console.log(bar.name)

const obj = {
    foo: function () {},
    bar: () => 0,
}

// 打印 "foo"
console.log(obj.foo.name)

// 打印 "bar"
console.log(obj.bar.name)

const obj = {}

obj.foo = function () {}

// 打印 ""
console.log(obj.foo.name)

const name = "bar"
obj[name] = () => 0

// 打印 ""
console.log(obj.bar.name)

const name = "foo"

const obj = {
    [name]: function () {},
}

// 打印 "foo"
console.log(obj[name].name)

const foo = function () {}
Object.defineProperty(foo, "name", { value: "bar" })

// 打印 "bar"
console.log(foo.name)