forked from HowProgrammingWorks/ConcurrentQueue
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathtest-pipe-server2.js
More file actions
112 lines (101 loc) · 2.57 KB
/
test-pipe-server2.js
File metadata and controls
112 lines (101 loc) · 2.57 KB
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
'use strict';
const http = require('http');
const ConcurrentQueue = require('../6-thenable');
const request = require('./client');
const fn = async (params) => {
const { url } = params;
const response = {
data: `request:${url}`,
statusCode: 200
}
return response;
};
const job = async (element, callback) => {
const { task, thenable } = element;
const { fn, request } = task;
const result = await fn(request);
if (request.url === '/pipe-err2') {
const err = new Error('error /pipe-err2')
callback(err, { result, thenable });
} else {
callback(null, { result, thenable });
}
};
const q2 = new ConcurrentQueue(5)
.process((element, callback) => {
const { task, thenable } = element;
//Test on success
const { result } = task;
if (result.data === 'request:/pipe') {
const result = { data: 'piped', statusCode: 200 }
callback(null, { result, thenable });
} else {
//Test on error
const result = { data: 'not found', statusCode: 404 }
const err = new Error('not found');
callback(err, { result, thenable });
}
})
.success(data => {
const { thenable, result } = data;
setTimeout(() => {
thenable.resolve(result);
}, 0)
})
.failure((err, data) => {
const { thenable, result } = data;
setTimeout(() => {
thenable.reject(result);
}, 0)
});
const q1 = new ConcurrentQueue(2)
.process(job)
.wait(500)
.pipe(q2)
.success(data => {
const { thenable, result } = data;
thenable.resolve(result);
})
.failure((err, data) => {
const { thenable } = data;
setTimeout(() => {
thenable.reject({
err: err,
data: 'error processing page',
statusCode: 503
});
}, 0);
});
const server = http.createServer((req, res) => {
const request = { url: req.url };
q1.add({ request, fn })
.then(result => {
const { data, statusCode } = result;
res.statusCode = statusCode;
res.end(data);
if (req.url === '/pipe') {
if(data === 'piped') {
console.log('Test passed', { data });
} else {
console.log('Test failed, data must be \'piped\'');
console.log({ data });
}
} else if (req.url === '/pipe-err'){
console.log({ data });
}
}, err => {
const { data, statusCode } = err;
res.statusCode = statusCode;
res.end(data);
});
});
server.listen(8080, 'localhost');
setTimeout(() => {
request('/pipe');
}, 500);
setTimeout(() => {
request('/pipe-err');
}, 600);
setTimeout(() => {
request('/pipe-err2');
}, 100);