-
Notifications
You must be signed in to change notification settings - Fork 2
/
Copy pathkonecty-server.js
125 lines (112 loc) · 3.34 KB
/
konecty-server.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
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
const api = require('./api');
module.exports = function(RED) {
function KonectyServerNode(n) {
RED.nodes.createNode(this, n);
this.host = RED.util.evaluateNodeProperty(n.host, n.hostType ?? "str", this, {});
this.key = RED.util.evaluateNodeProperty(n.key, n.keyType ?? "str", this, {});
this.name = n.name;
}
RED.nodes.registerType('konecty-server', KonectyServerNode);
RED.httpAdmin.get('/konecty-server/:id/menu', RED.auth.needsPermission('konecty-server.read'), async function(req, res) {
const { id } = req.params;
const node = RED.nodes.getNode(id);
if (node != null) {
try {
const { host, key } = node;
const apiInstance = api({ host, key });
const result = await apiInstance.getMenu();
res.json(result);
} catch (err) {
res.sendStatus(500);
node.error(`Konecty Server Failed: ${err.toString()}`);
}
} else {
res.sendStatus(404);
}
});
RED.httpAdmin.get('/konecty-server/:id/documents', RED.auth.needsPermission('konecty-server.read'), async function(req, res) {
const { id } = req.params;
const node = RED.nodes.getNode(id);
if (node != null) {
try {
const { host, key } = node;
const apiInstance = api({ host, key });
const documents = await apiInstance.getDocuments();
res.json(documents);
} catch (err) {
res.sendStatus(500);
node.error(`Konecty Server Failed: ${err.toString()}`);
}
} else {
res.sendStatus(404);
}
});
RED.httpAdmin.get('/konecty-server/:id/documents/:document', RED.auth.needsPermission('konecty-server.read'), async function(
req,
res
) {
const { id, document } = req.params;
const node = RED.nodes.getNode(id);
if (node != null) {
try {
const { host, key } = node;
const apiInstance = api({ host, key });
const result = await apiInstance.getDocument(document);
res.json(result);
} catch (err) {
res.sendStatus(500);
node.error(`Konecty Server Failed: ${err.toString()}`);
}
} else {
res.sendStatus(404);
}
});
RED.httpAdmin.get(
'/konecty-server/:id/lookup/:document/:field/:search',
RED.auth.needsPermission('konecty-server.read'),
async function(req, res) {
const { id, document, field, search } = req.params;
const node = RED.nodes.getNode(id);
if (node != null) {
try {
const { host, key } = node;
const apiInstance = api({ host, key });
const result = await apiInstance.getSuggestions(document, field, search);
if (result.success) {
return res.json(result.data);
}
return [];
} catch (err) {
res.sendStatus(500);
node.error(`Konecty Server Failed: ${err.toString()}`);
}
} else {
res.sendStatus(404);
}
}
);
RED.httpAdmin.get(
'/konecty-server/:id/lookupDocument/:document/:field/:search',
RED.auth.needsPermission('konecty-server.read'),
async function(req, res) {
const { id, document, field, search } = req.params;
const node = RED.nodes.getNode(id);
if (node != null) {
try {
const { host, key } = node;
const apiInstance = api({ host, key });
const result = await apiInstance.getSuggestionsForDocument(document, field, search);
if (result.success) {
return res.json(result.data);
}
return [];
} catch (err) {
res.sendStatus(500);
node.error(`Konecty Server Failed: ${err.toString()}`);
}
} else {
res.sendStatus(404);
}
}
);
};