diff --git a/src/service.ts b/src/service.ts index e8dd5424913eef4066d4414765d3a75ef38ee24b..388af3ad9bf560f87cf32c5c24e24936315207ec 100644 --- a/src/service.ts +++ b/src/service.ts @@ -230,33 +230,32 @@ function updateObject(dbName: string, docName: string, document: string) { .use(dbName) .get(docName) .then((body) => { - const CRDT = crdtlib.crdt.DeltaCRDT.Companion.fromJson(document); - const bodyCRDT = crdtlib.crdt.DeltaCRDT.Companion.fromJson( - JSON.stringify(body) - ); - bodyCRDT.merge(CRDT); - const newDocument = JSON.parse(bodyCRDT.toJson()); - newDocument._rev = body._rev; - client.db - .use(dbName) - .insert(newDocument, docName) - .catch((error) => { - console.error( - `[SERVER][ERROR] Failed updating document '${docName}' in database '${dbName}'` - ); - console.error(error); - }); + try { + const CRDT = crdtlib.crdt.DeltaCRDT.Companion.fromJson(document); + const bodyCRDT = crdtlib.crdt.DeltaCRDT.Companion.fromJson( + JSON.stringify(body) + ); + bodyCRDT.merge(CRDT); + const newDocument = JSON.parse(bodyCRDT.toJson()); + newDocument._rev = body._rev; + client.db.use(dbName).insert(newDocument, docName); + } catch (error) { + console.error( + `[SERVER][ERROR] Failed updating document '${docName}' in database '${dbName}'` + ); + console.error(error); + } }) .catch((error) => { - client.db - .use(dbName) - .insert(JSON.parse(document), docName) - .catch((error) => { - console.error( - `[SERVER][ERROR] Failed updating document '${docName}' in database '${dbName}'` - ); - console.error(error); - }); + try { + const CRDT = crdtlib.crdt.DeltaCRDT.Companion.fromJson(document); + client.db.use(dbName).insert(JSON.parse(document), docName); + } catch (error) { + console.error( + `[SERVER][ERROR] Failed updating document '${docName}' in database '${dbName}'` + ); + console.error(error); + } }); }) .catch((error) => {