-
Notifications
You must be signed in to change notification settings - Fork 0
/
url.brs
230 lines (195 loc) · 7.83 KB
/
url.brs
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
'*
'* URL Code
'*
'* Copyright (C) 2012, Jon Gettler
'* http://www.mvpmc.org/
'*
'* This program is free software; you can redistribute it and/or modify
'* it under the terms of the GNU General Public License as published by
'* the Free Software Foundation; either version 2 of the License, or
'* (at your option) any later version.
'*
'* This program is distributed in the hope that it will be useful,
'* but WITHOUT ANY WARRANTY; without even the implied warranty of
'* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
'* GNU General Public License for more details.
'*
'* You should have received a copy of the GNU General Public License
'* along with this program; if not, write to the Free Software
'* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
'*
REM ******************************************************
REM Constucts a URL Transfer object
REM ******************************************************
Function CreateURLTransferObject(url As String) as Object
obj = CreateObject("roUrlTransfer")
obj.SetPort(CreateObject("roMessagePort"))
obj.SetUrl(url)
obj.AddHeader("Content-Type", "application/x-www-form-urlencoded")
obj.EnableEncodings(true)
return obj
End Function
REM ******************************************************
REM Url Query builder
REM so this is a quick and dirty name/value encoder/accumulator
REM ******************************************************
Function NewHttp(url As String) as Object
obj = CreateObject("roAssociativeArray")
obj.Http = CreateURLTransferObject(url)
obj.FirstParam = true
obj.AddParam = http_add_param
obj.AddRawQuery = http_add_raw_query
obj.GetToStringWithRetry = http_get_to_string_with_retry
obj.PrepareUrlForQuery = http_prepare_url_for_query
obj.GetToStringWithTimeout = http_get_to_string_with_timeout
obj.PostFromStringWithTimeout = http_post_from_string_with_timeout
if Instr(1, url, "?") > 0 then obj.FirstParam = false
return obj
End Function
REM ******************************************************
REM Constucts a URL Transfer object 2
REM ******************************************************
Function CreateURLTransferObject2(url As String, contentHeader As String) as Object
obj = CreateObject("roUrlTransfer")
obj.SetPort(CreateObject("roMessagePort"))
obj.SetUrl(url)
obj.AddHeader("Content-Type", contentHeader)
obj.EnableEncodings(true)
return obj
End Function
REM ******************************************************
REM Url Query builder 2
REM so this is a quick and dirty name/value encoder/accumulator
REM ******************************************************
Function NewHttp2(url As String, contentHeader As String) as Object
obj = CreateObject("roAssociativeArray")
obj.Http = CreateURLTransferObject2(url, contentHeader)
obj.FirstParam = true
obj.AddParam = http_add_param
obj.AddRawQuery = http_add_raw_query
obj.GetToStringWithRetry = http_get_to_string_with_retry
obj.PrepareUrlForQuery = http_prepare_url_for_query
obj.GetToStringWithTimeout = http_get_to_string_with_timeout
obj.PostFromStringWithTimeout = http_post_from_string_with_timeout
if Instr(1, url, "?") > 0 then obj.FirstParam = false
return obj
End Function
REM ******************************************************
REM HttpEncode - just encode a string
REM ******************************************************
Function HttpEncode(str As String) As String
o = CreateObject("roUrlTransfer")
return o.Escape(str)
End Function
REM ******************************************************
REM Prepare the current url for adding query parameters
REM Automatically add a '?' or '&' as necessary
REM ******************************************************
Function http_prepare_url_for_query() As String
url = m.Http.GetUrl()
if m.FirstParam then
url = url + "?"
m.FirstParam = false
else
url = url + "&"
endif
m.Http.SetUrl(url)
return url
End Function
REM ******************************************************
REM Percent encode a name/value parameter pair and add the
REM the query portion of the current url
REM Automatically add a '?' or '&' as necessary
REM Prevent duplicate parameters
REM ******************************************************
Function http_add_param(name As String, val As String) as Void
q = m.Http.Escape(name)
q = q + "="
url = m.Http.GetUrl()
if Instr(1, url, q) > 0 return 'Parameter already present
q = q + m.Http.Escape(val)
m.AddRawQuery(q)
End Function
REM ******************************************************
REM Tack a raw query string onto the end of the current url
REM Automatically add a '?' or '&' as necessary
REM ******************************************************
Function http_add_raw_query(query As String) as Void
url = m.PrepareUrlForQuery()
url = url + query
m.Http.SetUrl(url)
End Function
REM ******************************************************
REM Performs Http.AsyncGetToString() in a retry loop
REM with exponential backoff. To the outside
REM world this appears as a synchronous API.
REM ******************************************************
Function http_get_to_string_with_retry() as String
timeout% = 1500
num_retries% = 5
str = ""
while num_retries% > 0
' print "httpget try " + itostr(num_retries%)
if (m.Http.AsyncGetToString())
event = wait(timeout%, m.Http.GetPort())
if type(event) = "roUrlEvent"
str = event.GetString()
exit while
elseif event = invalid
m.Http.AsyncCancel()
REM reset the connection on timeouts
m.Http = CreateURLTransferObject(m.Http.GetUrl())
timeout% = 2 * timeout%
else
print "roUrlTransfer::AsyncGetToString(): unknown event"
endif
endif
num_retries% = num_retries% - 1
end while
return str
End Function
REM ******************************************************
REM Performs Http.AsyncGetToString() with a single timeout in seconds
REM To the outside world this appears as a synchronous API.
REM ******************************************************
Function http_get_to_string_with_timeout(seconds as Integer) as String
timeout% = 1000 * seconds
str = ""
m.Http.EnableFreshConnection(true) 'Don't reuse existing connections
if (m.Http.AsyncGetToString())
event = wait(timeout%, m.Http.GetPort())
if type(event) = "roUrlEvent"
str = event.GetString()
elseif event = invalid
Dbg("AsyncGetToString timeout")
m.Http.AsyncCancel()
else
Dbg("AsyncGetToString unknown event", event)
endif
endif
return str
End Function
REM ******************************************************
REM Performs Http.AsyncPostFromString() with a single timeout in seconds
REM To the outside world this appears as a synchronous API.
REM ******************************************************
Function http_post_from_string_with_timeout(val As String, seconds as Integer) as String
timeout% = 1000 * seconds
str = ""
' m.Http.EnableFreshConnection(true) 'Don't reuse existing connections
if (m.Http.AsyncPostFromString(val))
event = wait(timeout%, m.Http.GetPort())
if type(event) = "roUrlEvent"
print "1"
str = event.GetString()
elseif event = invalid
print "2"
Dbg("AsyncPostFromString timeout")
m.Http.AsyncCancel()
else
print "3"
Dbg("AsyncPostFromString unknown event", event)
endif
endif
return str
End Function