eigen
/
pos-be
12
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 295 Wiki Activity

fix(couch) perbaikan sync data couch
continuous-integration/drone/tag Build is passing Details

pull/6/head^2 devel_10.5.2
Aswin Ashar Abdullah 2024-07-01 08:50:42 +07:00
parent 0b1cdabea4
commit 8db2256852
1 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/modules/configuration/couch/data/services/couch.service.ts
View File

@ -30,26 +30,32 @@ export class CouchService {
} }
public async createDoc(data, database) { public async createDoc(data, database) {
const nano = require('nano')('http://root:password@172.10.10.2:5970'); try {
const db = nano.use(database); const nano = require('nano')('http://root:password@172.10.10.2:5970');
return await db.insert(data); const db = nano.use(database);
return await db.insert(data);
} catch (error) {}
} }
public async deleteDoc(data, database) { public async deleteDoc(data, database) {
const nano = require('nano')('http://root:password@172.10.10.2:5970'); try {
const db = nano.use(database); const nano = require('nano')('http://root:password@172.10.10.2:5970');
const result = await db.get(data.id); const db = nano.use(database);
await db.destroy(data.id, result._rev); const result = await db.get(data.id);
await db.destroy(data.id, result._rev);
} catch (error) {}
} }
public async updateDoc(data, database) { public async updateDoc(data, database) {
const nano = require('nano')('http://root:password@172.10.10.2:5970'); try {
const db = nano.use(database); const nano = require('nano')('http://root:password@172.10.10.2:5970');
const result = await db.get(data.id); const db = nano.use(database);
console.log(result, 'dsa'); const result = await db.get(data.id);
await db.insert({ console.log(result, 'dsa');
...data, await db.insert({
_rev: result._rev, ...data,
}); _rev: result._rev,
});
} catch (error) {}
} }
} }