Skip to content

Commit 47ef44c

Browse files
authored
Updated bhavcopy
Updated to return message when stream event is not available.
1 parent 6a0418b commit 47ef44c

File tree

1 file changed

+15
-7
lines changed

1 file changed

+15
-7
lines changed

public_api/bhavcopy.js

Lines changed: 15 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -172,16 +172,18 @@ class BhavCopy {
172172
if (fileName) {
173173
const parts = fileName.split("/");
174174
let originalFileName = parts.pop();
175+
176+
const fileDate = originalFileName
177+
.replace(".csv.zip", "")
178+
.replace("cm", "")
179+
.replace("fo", "")
180+
.replace("bhav", "");
181+
175182
return new Promise((resolve, reject) => {
176183
return this.__callNSEforFile(fileName)
177184
.then(streamObj => {
178185
if (streamObj && typeof streamObj === "object" && Object.keys(streamObj).length) {
179186
streamObj.on("response", response => {
180-
const fileDate = originalFileName
181-
.replace(".csv.zip", "")
182-
.replace("cm", "")
183-
.replace("fo", "")
184-
.replace("bhav", "");
185187
if (response.statusCode === 200) {
186188
//const unzip = require("unzip");
187189
const unzipper = require('unzipper');
@@ -236,6 +238,13 @@ class BhavCopy {
236238
return resolve({});
237239
}
238240
});
241+
242+
setTimeout(() => {
243+
return resolve({
244+
message: "Bhavcopy is not available for the date: " + fileDate
245+
});
246+
}, 5000);
247+
239248
} else {
240249
return reject({
241250
message: "Server is temporarily down. Please try after some time."
@@ -341,7 +350,6 @@ class BhavCopy {
341350

342351
if (Array.isArray(generateFileNamesArray) && generateFileNamesArray.length) {
343352
generateFileNamesArray.forEach((item, index) => promiseArray.push(this.__getBhavCopyFromNSE(item)));
344-
345353
}
346354

347355
return Promise.all(promiseArray)
@@ -360,4 +368,4 @@ class BhavCopy {
360368
}
361369
}
362370

363-
module.exports = BhavCopy;
371+
module.exports = BhavCopy;

0 commit comments

Comments
 (0)