Added reading the data back from the File-Collection

Author: brucejo75

.meteor/packages

@@ -11,6 +11,8 @@ blaze-html-templates    # Compile .html files into Meteor Blaze views
 reactive-var            # Reactive variable for tracker
 jquery                  # Helpful client-side library
 tracker                 # Meteor's client-side reactive programming library
+audit-argument-checks
+check
 
 standard-minifier-css   # CSS minifier run for production mode
 standard-minifier-js    # JS minifier run for production mode
@@ -25,4 +27,6 @@ benjaminrh:jquery-cookie
 numeral:numeral
 twbs:bootstrap
 session
+aldeed:simple-schema
+mdg:validated-method
 vsivsi:file-collection

.meteor/versions

@@ -2,7 +2,9 @@ accounts-base@1.2.7
 accounts-password@1.1.8
 accounts-ui@1.1.9
 accounts-ui-unstyled@1.1.12
+aldeed:simple-schema@1.5.3
 allow-deny@1.0.4
+audit-argument-checks@1.0.7
 autoupdate@1.2.9
 babel-compiler@6.6.4
 babel-runtime@0.1.8
@@ -43,6 +45,8 @@ less@2.6.0
 livedata@1.0.18
 localstorage@1.0.9
 logging@1.0.12
+mdg:validated-method@1.1.0
+mdg:validation-error@0.2.0
 meteor@1.1.14
 meteor-base@1.0.4
 minifier-css@1.1.11

client/colltest.html

@@ -4,6 +4,7 @@ <h3>file-collection JS Test App</h3>
     <ul>
       <li>Upload files by clicking <button type="button" class="btn btn-primary">Upload</button> or drag your files onto the grid.</li>
       <li>Once uploaded you can download the files from the collection by clicking the link in the name column.</li>
+      <li>Output the first 10K of data to the <b>File Data</b> panel below by pressing <button type="button" aria-hidden="true" class="btn btn-success btn-itsy">D</button>.</li>
       <li>Delete files from the collection by clicking the <button type="button" aria-hidden="true" class="btn btn-danger btn-itsy"><span class="glyphicon glyphicon-remove"></span></button> button in the name column.<br>
       Note: this deletion will remove all data of any aborted upload and cannot be restarted after deleting.</li>
     </ul>
@@ -38,6 +39,7 @@ <h3>file-collection JS Test App</h3>
           <td>
           <button type="button" aria-hidden="true" class="btn btn-danger btn-itsy del-file"><span class="glyphicon glyphicon-remove"></span></button>
           {{#if length}}
+            <button type="button" aria-hidden="true" class="btn btn-success btn-itsy dump-file">D</button>
             <a href="{{link}}?download=true">{{shortFilename 56}}</a>
           {{else}}
             {{shortFilename 56}}
@@ -81,5 +83,10 @@ <h3>file-collection JS Test App</h3>
         </tr>
       </tbody>
     </table>
+    <br><br>
+    <h4>File Data:</h4>
+    <div class="panel panel-info">
+          <div class="panel-body wrap">{{fileData}}</div>
+    </div>
   </div>
 </template>

client/colltest.js

@@ -9,6 +9,9 @@ Template.collTest.onCreated(function onCreated() {
       'path': '/'
     });
   });
+  template.autorun(function subFileData() {
+    Meteor.subscribe('fileData');
+  });
 });
 
 Template.collTest.onRendered(function onRendered() {
@@ -30,7 +33,7 @@ function shorten(name, width) {
     retVal = name;
   }
   return retVal;
-};
+}
 
 Template.collTest.events({
   'click .del-file': function cancelFile() {
@@ -47,9 +50,12 @@ Template.collTest.events({
     Uploads.resumable.pause();
     t.pause.set(true);
   },
-  'click .fileResume': function pauseFiles(e, t) {
+  'click .fileResume': function resumeFiles(e, t) {
     Uploads.resumable.upload();
     t.pause.set(false);
+  },
+  'click .dump-file': function dumpFile() {
+    dumpData.call({'filename': this.filename});
   }
 });
 
@@ -75,14 +81,16 @@ Template.collTest.helpers({
     }
     return cursor;
   },
+  'fileData': function dataEntries() {
+    let doc = fileData.findOne({});
+    let data = doc && doc.data;
+    return data;
+  },
   'owner': function owner() {
     let ref = this.metadata;
     let FOwner = ref && ref._auth && ref._auth.owner;
     return FOwner;
   },
-  // 'id': function id() {
-  //   return '' + this._id;
-  // },
   'link': function getLink() {
     return Uploads.baseURL + '/md5/' + this.md5;
   },

lib/upload-collection.js renamed to lib/collections.js

@@ -13,3 +13,17 @@ Uploads = FileCollection({
     }
   ]
 });
+
+fileData = new Mongo.Collection('fileData');
+
+fileData.allow({
+  'insert': () => false,
+  'update': () => false,
+  'remove': () => true
+});
+
+fileData.deny({
+  'insert': () => true,
+  'update': () => true,
+  'remove': () => true
+});

lib/methods.js

@@ -0,0 +1,28 @@
+dumpData = new ValidatedMethod({
+  'name': 'dumpData',
+  'validate': new SimpleSchema({
+    'filename': { 'type': String }
+  }).validator(),
+  run({filename}) {
+    if(!this.isSimulation) {
+      let buffer = '';
+      // because the stream is calling back in another context, need to bind
+      // the callbacks to this context (e.g. so we can use the buffer variable)
+      let bndStreamEnd = Meteor.bindEnvironment(function streamEnd() {
+        fileData.upsert({'data': {'$exists': true}}, {'data': buffer});
+        console.log(buffer);
+      });
+      let bndStreamData = Meteor.bindEnvironment(function streamData(buf) {
+        // handle up to 10K
+        if(buffer.length < 10000) {
+          buffer = buffer + buf;
+        }
+      });
+      // get the file stream
+      let fStream = Uploads.findOneStream({'filename': filename});
+      // handle the stream
+      fStream.on('data', bndStreamData);
+      fStream.on('end', bndStreamEnd);
+    }
+  }
+});

sample.css

@@ -22,3 +22,11 @@
     font-size: 6px;
     line-height: 7px;
 }
+
+.wrap { 
+  white-space: pre-wrap;
+  white-space: -moz-pre-wrap; /* Firefox */    
+  white-space: -pre-wrap;     /* Opera <7 */   
+  white-space: -o-pre-wrap;   /* Opera 7 */    
+  word-wrap: break-word;      /* IE */
+}

server/sample.js

@@ -1,5 +1,6 @@
 Meteor.startup(function serverStartup() {
   Meteor.publish('allData', function allData(clientUserId) {
+    check(clientUserId, null);
     let retVal = [];
     if(this.userId === clientUserId) {
       retVal = Uploads.find({
@@ -12,32 +13,10 @@ Meteor.startup(function serverStartup() {
     return retVal;
   });
 
-  // Meteor.users.deny({
-  //   'update': function update() {
-  //     return true;
-  //   }
-  // });
-
-  Uploads.allow({
-    'insert': function insert(userId, file) {
-      file.metadata = file.metadata || {};
-      file.metadata._auth = {'owner': userId};
-      return true;
-    },
-    'remove': function remove(userId, file) {
-      return file.metadata && file.metadata._auth &&
-        file.metadata._auth.owner === userId;
-    },
-    'read': function read(userId, file) {
-      return file.metadata && file.metadata._auth &&
-        file.metadata._auth.owner === userId;
-    },
-    'write': function write(userId, file) {
-      return file.metadata && file.metadata._auth &&
-        file.metadata._auth.owner === userId;
-    }
+  Meteor.publish('fileData', function pubFileData() {
+    return fileData.find({});
   });
-debugger;
+
   let query = Uploads.find({'metadata._Resumable': {'$exists': false}});
   query.observe({
     removed: function cleanUpIncompleteFiles(rmFile) {
@@ -47,3 +26,23 @@ debugger;
     }
   });
 });
+
+Uploads.allow({
+  'insert': function insert(userId, file) {
+    file.metadata = file.metadata || {};
+    file.metadata._auth = {'owner': userId};
+    return true;
+  },
+  'remove': function remove(userId, file) {
+    return file.metadata && file.metadata._auth &&
+      file.metadata._auth.owner === userId;
+  },
+  'read': function read(userId, file) {
+    return file.metadata && file.metadata._auth &&
+      file.metadata._auth.owner === userId;
+  },
+  'write': function write(userId, file) {
+    return file.metadata && file.metadata._auth &&
+      file.metadata._auth.owner === userId;
+  }
+});