Skip to content
This repository was archived by the owner on Nov 27, 2023. It is now read-only.

Commit 44a4f43

Browse files
committed
Remove spurious midleware funcs
1 parent c23cddf commit 44a4f43

File tree

1 file changed

+13
-40
lines changed

1 file changed

+13
-40
lines changed

src/lib/orbitdb-api.js

Lines changed: 13 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ const Http2 = require('http2');
66
class OrbitdbAPI {
77
constructor (dbm, server_opts) {
88
let comparisons, rawiterator, getraw, unpack_contents, listener;
9-
let dbMiddleware, ErrorHandler, asyncMiddleware;
9+
let dbMiddleware;
1010

1111
listener = Http2.createSecureServer(server_opts.http2_opts);
1212
this.server = new Hapi.Server({
@@ -31,16 +31,7 @@ class OrbitdbAPI {
3131
let db
3232
db = await dbm.get(request.params.dbname)
3333
return Promise.resolve((fn(db, request, h)))
34-
.catch((err) => ErrorHandler(err, h));
35-
};
36-
37-
asyncMiddleware = fn =>
38-
(request, h) => Promise.resolve(fn(request, h))
39-
.catch((err) => ErrorHandler(err, h));
40-
41-
ErrorHandler = (err, _h) => {
42-
console.error(err);
43-
return Boom.badImplementation();
34+
.catch((err) => {throw err});
4435
};
4536

4637
rawiterator = (db, request, _h) =>
@@ -67,56 +58,44 @@ class OrbitdbAPI {
6758
{
6859
method: 'GET',
6960
path: '/dbs',
70-
handler: (_request, h) => {
71-
try {
72-
return dbm.db_list();
73-
} catch(err) {
74-
return ErrorHandler(err, h);
75-
}
76-
}
61+
handler: (_request, h) => dbm.db_list()
7762
},
7863
{
7964
method: ['POST', 'PUT'],
8065
path: '/db',
81-
handler: asyncMiddleware( async (request, _h) => {
66+
handler: async (request, _h) => {
8267
let db, payload;
8368
payload = request.payload;
8469
db = await dbm.get(payload.dbname, payload);
8570
return dbm.db_info(db.dbname);
86-
})
71+
}
8772
},
8873
{
8974
method: ['POST', 'PUT'],
9075
path: '/db/{dbname}',
91-
handler: asyncMiddleware( async (request, _h) => {
76+
handler: async (request, _h) => {
9277
let db;
9378
db = await dbm.get(request.params.dbname, request.payload);
9479
return dbm.db_info(db.dbname);
95-
})
80+
}
9681
},
9782
{
9883
method: 'GET',
9984
path: '/db/{dbname}',
100-
handler: (request, h) => {
101-
try {
102-
return dbm.db_info(request.params.dbname);
103-
} catch(err) {
104-
return ErrorHandler(err, h);
105-
}
106-
}
85+
handler: (request, _h) => dbm.db_info(request.params.dbname)
10786
},
10887
{
10988
method: 'DELETE',
11089
path: '/db/{dbname}',
111-
handler: asyncMiddleware( async (request, _h) => {
90+
handler: async (request, _h) => {
11291
await dbm.db_list_remove(request.params.dbname);
11392
return {};
114-
})
93+
}
11594
},
11695
{
11796
method: 'DELETE',
11897
path: '/db/{dbname}/{item}',
119-
handler: dbMiddleware( async (db, request, _h) => {
98+
handler: async (db, request, _h) => {
12099
if (db.del) {
121100
return {hash: await db.del(request.params.item)};
122101
} else if (db.remove) {
@@ -128,7 +107,7 @@ class OrbitdbAPI {
128107
dbtype: db.type
129108
});
130109
}
131-
})
110+
}
132111
},
133112
{
134113
method: ['POST', 'PUT'],
@@ -241,13 +220,7 @@ class OrbitdbAPI {
241220
{
242221
method: 'GET',
243222
path: '/identity',
244-
handler: (_request, h) => {
245-
try {
246-
return dbm.identity()
247-
} catch(err) {
248-
return ErrorHandler(err, h);
249-
}
250-
}
223+
handler: (_request, _h) => dbm.identity()
251224
},
252225
{
253226
method: ['POST', 'PUT'],

0 commit comments

Comments
 (0)