import options
import streams
import tables
import bindings/quickjs
import types/url
import js/javascript
import utils/twtstr
type
HttpMethod* = enum
HTTP_CONNECT = "CONNECT"
HTTP_DELETE = "DELETE"
HTTP_GET = "GET"
HTTP_HEAD = "HEAD"
HTTP_OPTIONS = "OPTIONS"
HTTP_PATCH = "PATCH"
HTTP_POST = "POST"
HTTP_PUT = "PUT"
HTTP_TRACE = "TRACE"
RequestMode* = enum
NO_CORS, SAME_ORIGIN, CORS, NAVIGATE, WEBSOCKET
RequestDestination* = enum
NO_DESTINATION, AUDIO, AUDIOWORKLET, DOCUMENT, EMBED, FONT, FRAME, IFRAME,
IMAGE, MANIFEST, OBJECT, PAINTWORKLET, REPORT, SCRIPT, SERVICEWORKER,
SHAREDWORKER, STYLE, TRACK, WORKER, XSLT
CredentialsMode* = enum
SAME_ORIGIN, OMIT, INCLUDE
CORSAttribute* = enum
NO_CORS, ANONYMOUS, USE_CREDENTIALS
type
Request* = ref RequestObj
RequestObj* = object
httpmethod*: HttpMethod
url*: Url
headers*: HeaderList
body*: Option[string]
multipart*: Option[MimeData]
referer*: URL
mode*: RequestMode
destination*: RequestDestination
credentialsMode*: CredentialsMode
proxy*: URL #TODO: this should definitely be a different API.
Response* = ref object
body*: Stream
bodyUsed* {.jsget.}: bool
res* {.jsget.}: int
contenttype* {.jsget.}: string
status* {.jsget.}: int
headers* {.jsget.}: HeaderList
redirect*: Request
url*: URL #TODO should be urllist?
unregisterFun*: proc()
ReadableStream* = ref object of Stream
isource*: Stream
buf: string
isend: bool
HeaderList* = ref object
table* {.jsget.}: Table[string, seq[string]]
# Originally from the stdlib
MimePart* = object
name*, content*: string
case isFile*: bool
of true:
filename*, contentType*: string
fileSize*: int64
isStream*: bool
else: discard
MimeData* = object
content*: seq[MimePart]
iterator pairs*(headers: HeaderList): (string, string) =
for k, vs in headers.table:
for v in vs:
yield (k, v)
proc rsReadData(s: Stream, buffer: pointer, bufLen: int): int =
var s = ReadableStream(s)
if s.atEnd:
return 0
while s.buf.len < bufLen:
var len: int
s.isource.read(len)
if len == 0:
result = s.buf.len
copyMem(buffer, addr(s.buf[0]), result)
s.buf = s.buf.substr(result)
s.isend = true
return
var nbuf: string
s.isource.readStr(len, nbuf)
s.buf &= nbuf
assert s.buf.len >= bufLen
result = bufLen
copyMem(buffer, addr(s.buf[0]), result)
s.buf = s.buf.substr(result)
if s.buf.len == 0:
var len: int
s.isource.read(len)
if len == 0:
s.isend = true
else:
s.isource.readStr(len, s.buf)
proc rsAtEnd(s: Stream): bool =
ReadableStream(s).isend
proc rsClose(s: Stream) = {.cast(tags: [WriteIOEffect]).}: #TODO TODO TODO ew.
var s = ReadableStream(s)
if s.isend: return
s.buf = ""
while true:
var len: int
s.isource.read(len)
if len == 0:
s.isend = true
break
s.isource.setPosition(s.isource.getPosition() + len)
proc newReadableStream*(isource: Stream): ReadableStream =
new(result)
result.isource = isource
result.readDataImpl = rsReadData
result.atEndImpl = rsAtEnd
result.closeImpl = rsClose
var len: int
result.isource.read(len)
if len == 0:
result.isend = true
else:
result.isource.readStr(len, result.buf)
func newHeaderList*(): HeaderList =
new(result)
func newHeaderList*(table: Table[string, string]): HeaderList =
new(result)
for k, v in table:
let k = k.toHeaderCase()
if k in result.table:
result.table[k].add(v)
else:
result.table[k] = @[v]
func newRequest*(url: URL, httpmethod = HTTP_GET, headers = newHeaderList(),
body = none(string), # multipart = none(MimeData),
mode = RequestMode.NO_CORS,
credentialsMode = CredentialsMode.SAME_ORIGIN,
destination = RequestDestination.NO_DESTINATION,
proxy: URL = nil): Request =
return Request(
url: url,
httpmethod: httpmethod,
headers: headers,
body: body,
#multipart: multipart,
mode: mode,
credentialsMode: credentialsMode,
destination: destination,
proxy: proxy
)
func newRequest*(url: URL, httpmethod = HTTP_GET, headers: seq[(string, string)] = @[],
body = none(string), # multipart = none(MimeData), TODO TODO TODO multipart
mode = RequestMode.NO_CORS, proxy: URL = nil): Request {.jsctor.} =
let hl = newHeaderList()
for pair in headers:
let (k, v) = pair
hl.table[k] = @[v]
return newRequest(url, httpmethod, hl, body, mode, proxy = proxy)
func createPotentialCORSRequest*(url: URL, destination: RequestDestination, cors: CORSAttribute, fallbackFlag = false): Request =
var mode = if cors == NO_CORS:
RequestMode.NO_CORS
else:
RequestMode.CORS
if fallbackFlag and mode == NO_CORS:
mode = SAME_ORIGIN
let credentialsMode = if cors == ANONYMOUS:
CredentialsMode.SAME_ORIGIN
else: CredentialsMode.INCLUDE
return newRequest(url, destination = destination, mode = mode, credentialsMode = credentialsMode)
proc `[]=`*(multipart: var MimeData, k, v: string) =
multipart.content.add(MimePart(name: k, content: v))
proc add*(headers: var HeaderList, k, v: string) =
let k = k.toHeaderCase()
if k notin headers.table:
headers.table[k] = @[v]
else:
headers.table[k].add(v)
proc `[]=`*(headers: var HeaderList, k, v: string) =
headers.table[k.toHeaderCase()] = @[v]
func getOrDefault*(headers: HeaderList, k: string, default = ""): string =
let k = k.toHeaderCase()
if k in headers.table:
headers.table[k][0]
else:
default
#TODO: this should be a property of body
proc close*(response: Response) {.jsfunc.} =
response.bodyUsed = true
if response.unregisterFun != nil:
response.unregisterFun()
if response.body != nil:
response.body.close()
proc text*(response: Response): string {.jsfunc.} =
if response.body == nil:
return ""
result = response.body.readAll()
response.close()
#TODO: get rid of this
proc readAll*(response: Response): string {.jsfunc.} =
return response.text()
proc Response_json*(ctx: JSContext, this: JSValue, argc: cint, argv: ptr JSValue): JSValue {.cdecl.} =
let op = getOpaque0(this)
if unlikely(not ctx.isInstanceOf(this, "Response") or op == nil):
return JS_ThrowTypeError(ctx, "Value is not an instance of %s", "Response")
let response = cast[Response](op)
var s = response.text()
return JS_ParseJSON(ctx, addr s[0], cast[csize_t](s.len), cstring"<input>")
func credentialsMode*(attribute: CORSAttribute): CredentialsMode =
case attribute
of NO_CORS, ANONYMOUS:
return SAME_ORIGIN
of USE_CREDENTIALS:
return INCLUDE
proc addRequestModule*(ctx: JSContext) =
ctx.registerType(Request)
ctx.registerType(Response, extra_funcs = [TabFunc(name: "json", fun: Response_json)])
ctx.registerType(HeaderList)