forked from ezpaarse-project/ezpaarse-middlewares
-
Notifications
You must be signed in to change notification settings - Fork 0
/
mock.js
93 lines (80 loc) · 1.76 KB
/
mock.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
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
'use strict';
exports.contextify = function (middleware, contextModifier) {
const report = {};
let ctx = {
request: {
headers: {},
header (name) { return ctx.request.headers[name.toLowerCase()]; }
},
response: {
header () {}
},
logger: {
silly () {},
info () {},
verbose () {},
warn () {},
error () {},
},
job: {
outputFields: {
added: [],
removed: []
},
filters: {
robots: false
}
},
report: {
getJson() {
return report;
},
set(group, entry, value) {
if (!report[group]) { report[group] = {}; }
report[group][entry] = value;
},
get(group, entry) {
return report[group] && report[group][entry];
},
inc(group, entry) {
if (!report[group]) { report[group] = {}; }
var count = report[group][entry];
report[group][entry] = (typeof count === 'number') ? count + 1 : 1;
},
},
saturate () {},
drain () {},
};
if (typeof contextModifier === 'function') {
contextModifier(ctx);
}
return middleware.call(ctx);
};
function cache(collectionName) {
const items = new Map();
const cacheObject = {
collection: null
};
cacheObject.checkIndexes = function (ttl, callback) {
callback();
};
cacheObject.set = function (id, doc, callback) {
items.set(id, {
date: new Date(),
id: id,
data: doc
});
callback();
};
cacheObject.get = function (id, callback) {
const item = items.get(id);
callback(null, item && item.data);
};
return cacheObject;
}
global.ezpaarse = {};
global.ezpaarse.config = {};
const libs = { cache };
global.ezpaarse.lib = function (name) {
return libs[name];
};