1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
|
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)
|