@@ -6,7 +6,7 @@ const Http2 = require('http2');
66class 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