From 86bf3e5dba9f3b2dd89d04dbad0f3c0e9ab23b0c Mon Sep 17 00:00:00 2001
From: Afrisal Yodi Purnama <afrisalyp@gmail.com>
Date: Sun, 24 Nov 2019 06:26:51 +0700
Subject: [PATCH] DB query consistent.

---
 models/index.js    | 2 ++
 utils/db-helper.js | 6 +++---
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/models/index.js b/models/index.js
index 6d8247a..f7ba593 100644
--- a/models/index.js
+++ b/models/index.js
@@ -14,6 +14,8 @@ const config = require('config');
 const dynamoose = require('dynamoose');
 
 dynamoose.AWS.config.update({
+  accessKeyId: config.DYNAMODB.AWS_ACCESS_KEY_ID,
+  secretAccessKey: config.DYNAMODB.AWS_SECRET_ACCESS_KEY,
   region: config.DYNAMODB.AWS_REGION
 });
 
diff --git a/utils/db-helper.js b/utils/db-helper.js
index a8dc61b..1d4db26 100644
--- a/utils/db-helper.js
+++ b/utils/db-helper.js
@@ -18,7 +18,7 @@ const logger = require('./logger');
  */
 async function getById(model, id) {
   return await new Promise((resolve, reject) => {
-    model.query('id').eq(id).exec((err, result) => {
+    model.query('id').eq(id).consistent().exec((err, result) => {
       if (err) {
         return reject(err);
       }
@@ -36,7 +36,7 @@ async function getById(model, id) {
  */
 async function scan(model, scanParams) {
   return await new Promise((resolve, reject) => {
-    model.scan(scanParams).exec((err, result) => {
+    model.scan(scanParams).consistent().exec((err, result) => {
       if (err) {
         return reject(err);
       }
@@ -56,7 +56,7 @@ async function scanOne(model, scanParams) {
   logger.debug('Enter scanOne.');
 
   return await new Promise((resolve, reject) => {
-    model.scan(scanParams).exec((err, result) => {
+    model.scan(scanParams).consistent().exec((err, result) => {
       if (err) {
         logger.debug(`scanOne. Error. ${err}`);
         return reject(err);