Merge pull request #68 from linkedconnections/development

v2.0.5

lib/GtfsIndex.js

@@ -48,12 +48,17 @@ class GtfsIndex {
     }
 
     async download(url, headers) {
-        const res = await request(url, { method: 'GET', headers });
+        try {
+            const res = await request(url, { method: 'GET', headers });
 
-        if (res.statusCode === 200) {
-            await this.unzip(await res.body);
-        } else {
-            throw new Error(`Error on HTTP request: ${url}, Message: ${await res.body.text()}`);
+            if (res.statusCode === 200) {
+                await this.unzip(await res.body);
+            } else {
+                throw new Error(`Error on HTTP request: ${url}, Message: ${await res.body.text()}`);
+            }
+        } catch (err) {
+            await this.cleanUp();
+            throw err;
         }
     }
 
@@ -295,7 +300,7 @@ class GtfsIndex {
 
     async cleanUp() {
         // We don't want to delete sources that are probably been reused
-        if(this.auxPath !== this.path) {
+        if (this.auxPath !== this.path) {
             await del([this.auxPath], { force: true });
         }
     }

lib/Utils.js

@@ -9,7 +9,6 @@ function unzipStream(stream, outPath) {
         }
         stream.pipe(unzip.Extract({ path: outPath }))
             .on('error', async err => {
-                await this.cleanUp();
                 reject(err);
             })
             .on('close', () => {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "gtfsrt2lc",
-  "version": "2.0.4",
+  "version": "2.0.5",
   "description": "Converts the GTFS-RT to Linked Connections",
   "main": "./Gtfsrt2LC.js",
   "bin": {

test/gtfsrt2lc.test.js

@@ -583,6 +583,10 @@ test('Cover GtfsIndex functions', async () => {
     try {
         await gti.getIndexes();
     } catch (err) { }
+
+    try {
+        await gti.download('http://google.com');
+    } catch (err) { }
 });
 
 test('Cover Utils functions', async () => {