mirror of
https://github.com/honojs/hono.git
synced 2024-11-29 17:46:30 +01:00
5cbd89c3ae
* wip * fix(validator): cache `arrayBuffer` to use after validation * denoify * refactor * denoify * make it `bufferToFormData()` in utils/buffer.ts
209 lines
5.2 KiB
TypeScript
209 lines
5.2 KiB
TypeScript
/* eslint-disable @typescript-eslint/no-explicit-any */
|
|
/* eslint-disable @typescript-eslint/no-non-null-assertion */
|
|
import type {
|
|
Input,
|
|
InputToDataByTarget,
|
|
ParamKeys,
|
|
ParamKeyToRecord,
|
|
RemoveQuestion,
|
|
UndefinedIfHavingQuestion,
|
|
ValidationTargets,
|
|
} from './types.ts'
|
|
import { parseBody } from './utils/body.ts'
|
|
import type { BodyData } from './utils/body.ts'
|
|
import type { Cookie } from './utils/cookie.ts'
|
|
import { parse } from './utils/cookie.ts'
|
|
import type { UnionToIntersection } from './utils/types.ts'
|
|
import { getQueryParam, getQueryParams, decodeURIComponent_ } from './utils/url.ts'
|
|
|
|
type Body = {
|
|
json: any
|
|
text: string
|
|
arrayBuffer: ArrayBuffer
|
|
blob: Blob
|
|
formData: FormData
|
|
}
|
|
type BodyCache = Partial<Body & { parsedBody: BodyData }>
|
|
|
|
export class HonoRequest<P extends string = '/', I extends Input['out'] = {}> {
|
|
raw: Request
|
|
|
|
private paramData: Record<string, string> | undefined
|
|
private vData: { [K in keyof ValidationTargets]?: {} } // Short name of validatedData
|
|
path: string
|
|
bodyCache: BodyCache = {}
|
|
|
|
constructor(
|
|
request: Request,
|
|
path: string = '/',
|
|
paramData?: Record<string, string> | undefined
|
|
) {
|
|
this.raw = request
|
|
this.path = path
|
|
this.paramData = paramData
|
|
this.vData = {}
|
|
}
|
|
|
|
param<P2 extends string = P>(
|
|
key: RemoveQuestion<ParamKeys<P2>>
|
|
): UndefinedIfHavingQuestion<ParamKeys<P2>>
|
|
param<P2 extends string = P>(): UnionToIntersection<ParamKeyToRecord<ParamKeys<P2>>>
|
|
param(key?: string): unknown {
|
|
if (this.paramData) {
|
|
if (key) {
|
|
const param = this.paramData[key]
|
|
return param ? (/\%/.test(param) ? decodeURIComponent_(param) : param) : undefined
|
|
} else {
|
|
const decoded: Record<string, string> = {}
|
|
|
|
for (const [key, value] of Object.entries(this.paramData)) {
|
|
if (value && typeof value === 'string') {
|
|
decoded[key] = /\%/.test(value) ? decodeURIComponent_(value) : value
|
|
}
|
|
}
|
|
|
|
return decoded
|
|
}
|
|
}
|
|
return null
|
|
}
|
|
|
|
query(key: string): string | undefined
|
|
query(): Record<string, string>
|
|
query(key?: string) {
|
|
return getQueryParam(this.url, key)
|
|
}
|
|
|
|
queries(key: string): string[] | undefined
|
|
queries(): Record<string, string[]>
|
|
queries(key?: string) {
|
|
return getQueryParams(this.url, key)
|
|
}
|
|
|
|
header(name: string): string | undefined
|
|
header(): Record<string, string>
|
|
header(name?: string) {
|
|
if (name) return this.raw.headers.get(name.toLowerCase()) ?? undefined
|
|
|
|
const headerData: Record<string, string | undefined> = {}
|
|
this.raw.headers.forEach((value, key) => {
|
|
headerData[key] = value
|
|
})
|
|
return headerData
|
|
}
|
|
|
|
/** @deprecated
|
|
* Use Cookie Middleware instead of `c.req.cookie()`. The `c.req.cookie()` will be removed in v4.
|
|
*
|
|
* @example
|
|
*
|
|
* import { getCookie } from 'hono/cookie'
|
|
* // ...
|
|
* app.get('/', (c) => c.text(getCookie(c, 'cookie-name')))
|
|
*/
|
|
cookie(key: string): string | undefined
|
|
|
|
/** @deprecated
|
|
* Use Cookie Middleware instead of `c.req.cookie()`. The `c.req.cookie()` will be removed in v4.
|
|
*
|
|
* @example
|
|
*
|
|
* import { getCookie } from 'hono/cookie'
|
|
* // ...
|
|
* app.get('/', (c) => c.json(getCookie(c)))
|
|
*/
|
|
cookie(): Cookie
|
|
|
|
cookie(key?: string) {
|
|
const cookie = this.raw.headers.get('Cookie')
|
|
if (!cookie) return
|
|
const obj = parse(cookie)
|
|
if (key) {
|
|
const value = obj[key]
|
|
return value
|
|
} else {
|
|
return obj
|
|
}
|
|
}
|
|
|
|
async parseBody<T extends BodyData = BodyData>(): Promise<T> {
|
|
if (this.bodyCache.parsedBody) return this.bodyCache.parsedBody as T
|
|
const parsedBody = await parseBody<T>(this)
|
|
this.bodyCache.parsedBody = parsedBody
|
|
return parsedBody
|
|
}
|
|
|
|
private cachedBody = (key: keyof Body) => {
|
|
const { bodyCache, raw } = this
|
|
const cachedBody = bodyCache[key]
|
|
if (cachedBody) return cachedBody
|
|
/**
|
|
* If an arrayBuffer cache is exist,
|
|
* use it for creating a text, json, and others.
|
|
*/
|
|
if (bodyCache.arrayBuffer) {
|
|
return (async () => {
|
|
return await new Response(bodyCache.arrayBuffer)[key]()
|
|
})()
|
|
}
|
|
return (bodyCache[key] = raw[key]())
|
|
}
|
|
|
|
json<T = any>(): Promise<T> {
|
|
return this.cachedBody('json')
|
|
}
|
|
|
|
text(): Promise<string> {
|
|
return this.cachedBody('text')
|
|
}
|
|
|
|
arrayBuffer(): Promise<ArrayBuffer> {
|
|
return this.cachedBody('arrayBuffer')
|
|
}
|
|
|
|
blob(): Promise<Blob> {
|
|
return this.cachedBody('blob')
|
|
}
|
|
|
|
formData(): Promise<FormData> {
|
|
return this.cachedBody('formData')
|
|
}
|
|
|
|
addValidatedData(target: keyof ValidationTargets, data: {}) {
|
|
this.vData[target] = data
|
|
}
|
|
|
|
valid<T extends keyof I & keyof ValidationTargets>(target: T): InputToDataByTarget<I, T>
|
|
valid(target: keyof ValidationTargets) {
|
|
return this.vData[target] as unknown
|
|
}
|
|
|
|
get url() {
|
|
return this.raw.url
|
|
}
|
|
get method() {
|
|
return this.raw.method
|
|
}
|
|
get headers() {
|
|
return this.raw.headers
|
|
}
|
|
get body() {
|
|
return this.raw.body
|
|
}
|
|
get bodyUsed() {
|
|
return this.raw.bodyUsed
|
|
}
|
|
get integrity() {
|
|
return this.raw.integrity
|
|
}
|
|
get keepalive() {
|
|
return this.raw.keepalive
|
|
}
|
|
get referrer() {
|
|
return this.raw.referrer
|
|
}
|
|
get signal() {
|
|
return this.raw.signal
|
|
}
|
|
}
|