1
+ const logger = require ( './logger' ) ;
2
+
1
3
/*
2
4
* Copyright (c) 2018 TopCoder, Inc. All rights reserved.
3
5
*/
@@ -17,6 +19,7 @@ async function getById(model, id) {
17
19
return await new Promise ( ( resolve , reject ) => {
18
20
model . query ( 'id' ) . eq ( id ) . exec ( ( err , result ) => {
19
21
if ( err ) {
22
+ logger . error ( `DynamoDB getById error ${ err } ` ) ;
20
23
reject ( err ) ;
21
24
}
22
25
@@ -35,6 +38,7 @@ async function scan(model, scanParams) {
35
38
return await new Promise ( ( resolve , reject ) => {
36
39
model . scan ( scanParams ) . exec ( ( err , result ) => {
37
40
if ( err ) {
41
+ logger . error ( `DynamoDB scan error ${ err } ` ) ;
38
42
reject ( err ) ;
39
43
}
40
44
@@ -53,6 +57,7 @@ async function scanOne(model, scanParams) {
53
57
return await new Promise ( ( resolve , reject ) => {
54
58
model . scan ( scanParams ) . exec ( ( err , result ) => {
55
59
if ( err ) {
60
+ logger . error ( `DynamoDB scanOne error ${ err } ` ) ;
56
61
reject ( err ) ;
57
62
}
58
63
@@ -72,6 +77,7 @@ async function create(Model, data) {
72
77
const dbItem = new Model ( data ) ;
73
78
dbItem . save ( ( err ) => {
74
79
if ( err ) {
80
+ logger . error ( `DynamoDB create error ${ err } ` ) ;
75
81
reject ( err ) ;
76
82
}
77
83
@@ -95,6 +101,7 @@ async function update(Model, id, data) {
95
101
return await new Promise ( ( resolve , reject ) => {
96
102
dbItem . save ( ( err ) => {
97
103
if ( err ) {
104
+ logger . error ( `DynamoDB update error ${ err } ` ) ;
98
105
reject ( err ) ;
99
106
}
100
107
@@ -113,6 +120,7 @@ async function remove(Model, queryParams) {
113
120
await new Promise ( ( resolve , reject ) => {
114
121
dbItem . delete ( ( err ) => {
115
122
if ( err ) {
123
+ logger . error ( `DynamoDB remove error ${ err } ` ) ;
116
124
reject ( err ) ;
117
125
}
118
126
0 commit comments