-
Notifications
You must be signed in to change notification settings - Fork 5
/
Copy pathtest.js
69 lines (61 loc) · 2.05 KB
/
test.js
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
var HAPI = require("@hapi/hapi")
var HAPICo = require("./hapi-plugin-co")
var Request = require("request-promise")
var server = HAPI.server({
host: "127.0.0.1",
port: 12345,
debug: { request: [ "error" ] }
})
;(async () => {
await server.register(HAPICo)
/* provider */
server.route({
method: "GET",
path: "/foo",
handler: function * (request, h) { /* THE CO-ROUTINE */
var value = yield new Promise(function (resolve, reject) {
setTimeout(function () {
resolve(42)
}, 1000)
})
return { value: value }
}
})
server.route({
method: "GET",
path: "/bar",
handler: async (request, h) => {
var value = await new Promise(function (resolve, reject) {
setTimeout(function () {
resolve(42)
}, 1000)
})
return { value: value }
}
})
await server.start()
/* consumer */
let p1 = server.inject({ method: "GET", url: "/foo" }).then(function (response) {
if (response.result.value === 42)
console.log("-- internal request: /foo: OK")
else
console.log("-- internal request: /foo: ERROR: invalid response: ", response.result.value)
}).catch(function (error) {
console.log("-- internal request: /foo: ERROR: ", error)
})
let p2 = Request({ uri: "http://127.0.0.1:12345/foo", json: true }).then(function (response) {
if (response.value === 42)
console.log("-- external request: /foo: OK")
else
console.log("-- external request: /foo: ERROR: invalid response: ", response.value)
}).catch(function (error) {
console.log("-- external request: /foo: ERROR: ", error)
})
Promise.all([ p1, p2 ]).then(function () {
server.stop({ timeout: 1000 }, function (error) {
if (error)
console.log("ERROR", error)
process.exit(0)
})
})
})()