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
|
context("HttpClient")
test_that("HttpClient works", {
skip_on_cran()
expect_is(HttpClient, "R6ClassGenerator")
aa <- HttpClient$new(url = hb())
expect_is(aa, "HttpClient")
expect_null(aa$handle)
expect_length(aa$opts, 0)
expect_is(aa$url, "character")
expect_is(aa$.__enclos_env__$private$make_request, "function")
expect_is(aa$post, "function")
expect_is(aa$get, "function")
})
test_that("HttpClient fails well", {
skip_on_cran()
expect_error(HttpClient$new(), "need one of url or handle")
})
test_that("HttpClient print method", {
skip_on_cran()
aa <- HttpClient$new(url = hb(),
opts = list(verbose = TRUE),
headers = list(foo = "bar"),
auth = auth(user = "foo", pwd = "bar", auth = "basic"),
proxies = proxy("http://97.77.104.22:3128")
)
expect_is(aa$print, "function")
expect_output(aa$print(), "crul connection")
expect_output(aa$print(), "verbose: TRUE")
expect_output(aa$print(), "auth: FALSE")
expect_output(aa$print(), "- foo:bar")
expect_output(aa$print(), "type: 1")
expect_output(aa$print(), "foo: bar")
expect_output(aa$print(), "progress: FALSE")
})
context("HttpClient - disk")
test_that("HttpClient works", {
skip_on_cran()
aa <- HttpClient$new(url = hb())
f <- tempfile()
res <- aa$get("get", disk = f)
lns <- readLines(res$content, n = 10)
expect_is(aa, "HttpClient")
expect_is(res$content, "character")
expect_gt(length(lns), 0)
unlink(f)
})
test_that("HttpClient disk fails well", {
skip_on_cran()
aa <- HttpClient$new(url = hb())
expect_error(aa$get("get", disk = 5), "invalid 'path' argument")
})
context("HttpClient - stream")
test_that("stream works", {
skip_on_cran()
aa <- HttpClient$new(url = hb())
expect_output(
res <- aa$get('stream/50', stream = function(x) cat(rawToChar(x))),
"headers"
)
expect_is(res, "HttpResponse")
expect_null(res$content)
})
test_that("stream fails well", {
skip_on_cran()
aa <- HttpClient$new(url = hb())
expect_error(aa$get("get", stream = 5), "could not find function \"fun\"")
})
context("HttpClient - failure behavior")
test_that("HttpClient - failure behavior", {
skip_on_cran()
# url doesn't exist - could not resolve host
conn <- HttpClient$new("http://stuffthings.gvb")
expect_error(conn$get(), "resolve host")
})
test_that("parse() works with disk usage", {
skip_on_cran()
f <- tempfile(fileext = ".json")
out <- crul::HttpClient$new("https://httpbin.org/get")$get(disk = f)
expect_is(out$parse(), "character")
expect_match(out$parse(), "headers")
})
test_that("parse() works with stream usage", {
skip_on_cran()
lst <- list()
fun <- function(x) lst <<- append(lst, list(x))
out <- crul::HttpClient$new("https://httpbin.org/get")$get(stream = fun)
expect_equal(out$parse(), raw(0))
})
|
