downloader update

Author: chrisweb

audio_data_analyzer.js

@@ -6,10 +6,23 @@ var audioDataAnalyzer = new AudioDataAnalyzer();
 
 var trackDownloader = new TrackDownloader();
 
-trackDownloader.writeTrackToDisc(415208);
 
 
-
-var values = audioDataAnalyzer.getValues();
-
-console.log(values);
+var temporaryTracksDirecotry = './downloaded_tracks';
+var format = 'ogg';
+
+trackDownloader.writeTrackToDisc(415208, function writeTrackCallback(error) {
+    
+    if (!error) {
+    
+        var values = audioDataAnalyzer.getValues();
+
+        console.log(values);
+        
+    } else {
+        
+        console.log(error);
+        
+    }
+    
+}, temporaryTracksDirecotry, format);

bootstrap.js

@@ -0,0 +1,73 @@
+// nodejs fs
+var fs = require('fs');
+
+/**
+ * 
+ * @returns {directoryManagerConstructor}
+ */
+var directoryManager = function directoryManagerConstructor() {
+    
+};
+
+/**
+ * 
+ * @param {type} directory
+ * @param {type} callback
+ * @returns {undefined}
+ */
+directoryManager.prototype.exists = function directoryExistsFunction(directory, callback) {
+    
+    console.log('directoryExists: ' + directory);
+    
+    if (callback !== undefined) {
+    
+        // async exists
+        fs.exists(directory, function(exists) {
+
+            callback(false, exists);
+
+        });
+        
+    } else {
+        
+        fs.existsSync(directory);
+        
+    }
+    
+};
+
+/**
+ * 
+ * @param {type} directory
+ * @param {type} callback
+ * @returns {undefined}
+ */
+directoryManager.prototype.create = function createDirectoryFunction(directory, callback) {
+    
+    console.log('createDirectory: ' + directory);
+    
+    if (callback !== undefined) {
+    
+        fs.mkdir(directory, 0666, function(error) {
+
+            if (!error) {
+
+                callback(false);
+
+            } else {
+
+                callback(error);
+
+            }
+
+        });
+        
+    } else {
+        
+        fs.mkdirSync(directory, 0666);
+        
+    }
+    
+};
+
+module.exports.directoryManager = directoryManager;

library/directoryManager.js

@@ -1,3 +1,13 @@
+// nodejs fs
+var fs = require('fs');
+
+// nodejs http
+var http = require('http');
+
+var DirectoryManager = require('./directoryManager').directoryManager;
+
+var directoryManager = new DirectoryManager();
+
 /**
  * 
  * @returns {downloaderConstructor}
@@ -12,18 +22,59 @@ var downloader = function downloaderConstructor() {
  * on disc
  * 
  * @param {type} trackId
+ * @param {type} callback
  * @param {type} temporaryTracksDirecotry
  * @param {type} format
  * @returns {undefined}
  */
-downloader.prototype.writeTrackToDisc = function(trackId, temporaryTracksDirecotry, format) {
+downloader.prototype.writeTrackToDisc = function(trackId, callback, temporaryTracksDirecotry, format) {
 
     if (temporaryTracksDirecotry === undefined) {
 
-        temporaryTracksDirecotry = '';
+        temporaryTracksDirecotry = './downloaded_tracks';
 
     }
 
+    directoryManager.exists(temporaryTracksDirecotry, function directoryExistsCallback(error, exists) {
+        
+        if (!error) {
+        
+            if (!exists) {
+            
+                directoryManager.create(temporaryTracksDirecotry, createDirectoryCallback = function(error) {
+                
+                    if (!error) {
+                        
+                        downloadFile(trackId, callback, temporaryTracksDirecotry, format);
+                        
+                    } else {
+            
+                        callback(error);
+
+                    }
+                
+                });
+            
+            } else {
+                
+                downloadFile(trackId, callback, temporaryTracksDirecotry, format);
+                
+            }
+            
+        } else {            
+            
+            callback(error);
+            
+        }
+        
+    });
+    
+};
+    
+var downloadFile = function downloadFileFunction(trackId, callback, temporaryTracksDirecotry, format) {
+    
+    console.log('downloadFile: ' + trackId);
+    
     if (format === undefined) {
 
         format = 'ogg';
@@ -42,10 +93,12 @@ downloader.prototype.writeTrackToDisc = function(trackId, temporaryTracksDirecot
         default:
             throw 'unsupported track format';
     }
+    
+    var trackFileName = trackId + '.' + format;
 
-    var trackPath = temporaryTracksDirecotry + '/' + trackId + '.' + format;
+    var trackPath = temporaryTracksDirecotry + '/' + trackFileName;
 
-    // 
+    // request options
     var options = {
         hostname: 'storage-new.newjamendo.com',
         port: 80,
@@ -74,7 +127,7 @@ downloader.prototype.writeTrackToDisc = function(trackId, temporaryTracksDirecot
 
                 writeStream.end();
 
-                moveTrack();
+                callback(false);
 
             });
 
@@ -85,6 +138,8 @@ downloader.prototype.writeTrackToDisc = function(trackId, temporaryTracksDirecot
             console.log('writeTrackToDisc, http request error: ' + error.message);
 
             writeStream.end();
+            
+            callback(error);
 
         });
 
@@ -97,6 +152,8 @@ downloader.prototype.writeTrackToDisc = function(trackId, temporaryTracksDirecot
         console.log('writeTrackToDisc writeStream, error: ' + error);
 
         writeStream.end();
+        
+        callback(error);
 
     });