123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
import log from './log.ts'import type { ServerRequest } from './std.ts'import type { APIRequest, APIRequestURL, APIResponse, RouterURL } from './types.ts'
export class AlephAPIRequest implements APIRequest {    #req: ServerRequest    #url: APIRequestURL    #cookies: ReadonlyMap<string, string>
    constructor(req: ServerRequest, url: RouterURL) {        this.#req = req
        const paramsMap = new Map<string, string>()        for (const key in url.params) {            paramsMap.set(key, url.params[key])        }        this.#url = {            pathname: url.pathname,            params: paramsMap,            query: url.query,        }        this.#cookies = new Map() // todo: parse cookies    }
    get url(): APIRequestURL {        return this.#url    }
    get cookies(): ReadonlyMap<string, string> {        return this.#cookies    }
    get method(): string {        return this.#req.method    }
    get proto(): string {        return this.#req.proto    }
    get protoMinor(): number {        return this.#req.protoMinor    }
    get protoMajor(): number {        return this.#req.protoMajor    }
    get headers(): Headers {        return this.#req.headers    }}
export class AlephAPIResponse implements APIResponse {    #req: ServerRequest    #headers: Headers    #status: number
    constructor(req: ServerRequest) {        this.#req = req        this.#headers = new Headers()        this.#status = 200    }
    status(code: number): this {        this.#status = code        return this    }
    addHeader(key: string, value: string): this {        this.#headers.append(key, value)        return this    }
    setHeader(key: string, value: string): this {        this.#headers.set(key, value)        return this    }
    removeHeader(key: string): this {        this.#headers.delete(key)        return this    }
    async send(data: string | Uint8Array | ArrayBuffer) {        let body: string | Uint8Array        if (data instanceof ArrayBuffer) {            body = new Uint8Array(data)        } else {            body = data        }        return this.#req.respond({            status: this.#status,            headers: this.#headers,            body        }).catch(err => log.warn('ServerRequest.respond:', err.message))    }
    async json(data: any) {        this.#headers.set('Content-Type', 'application/json')        return this.#req.respond({            status: this.#status,            headers: this.#headers,            body: JSON.stringify(data)        }).catch(err => log.warn('ServerRequest.respond:', err.message))    }}