revise and add editing; using a new npm pkg, still WIP, needs cleanup and docs

Author: aldeed

google-spreadsheets.js

@@ -1,2 +1,3 @@
 GoogleClientLogin = Npm.require("googleclientlogin").GoogleClientLogin;
-GoogleSpreadsheets = Npm.require("google-spreadsheets");
+GoogleSpreadsheets = Npm.require("google-spreadsheets");
+EditGoogleSpreadsheet = Npm.require("edit-google-spreadsheet");

package.js

@@ -6,7 +6,8 @@ Package.describe({
 
 Npm.depends({
   "google-spreadsheets": "0.3.0",
-  "googleclientlogin": "0.2.8"
+  "googleclientlogin": "0.2.8",
+  "edit-google-spreadsheet": "0.2.6"
 });
 
 Package.on_use(function (api) {

server/methods.js

@@ -1,28 +1,99 @@
+var path = Npm.require('path');
+var Future = Npm.require(path.join('fibers', 'future'));
+var fs = Npm.require('fs');
+var pemFile;
+if (__meteor_bootstrap__ && __meteor_bootstrap__.serverDir) {
+  pemFile = path.join(__meteor_bootstrap__.serverDir, 'assets/app/google-key.pem');
+}
+
 Meteor.methods({
   // Fetches from a google spreadsheet
   // key = key from googe spreadsheet publish
-  // worksheet = numerical index or string
+  // worksheet = 0-based index of worksheet
   // range = "R1C1:R5C5"
-  'spreadsheet/fetch': function (key, worksheet, range, rowOneHeader) {
+  // headerRow = 1-based index of row containing header, if there is a header
+  'spreadsheet/fetch': function (key, worksheet, range, headerRow) {
     if (!worksheet) worksheet = 0;
-    if (!rowOneHeader) rowOneHeader = true;
-    return GoogleSpreadsheets({
+    var fut = new Future(); //don't return until we're done importing
+    GoogleSpreadsheets({
         key: key
-    }, Meteor.bindEnvironment( function(err, spreadsheet) {
+    }, Meteor.bindEnvironment( function(error, spreadsheet) {
+        if (error) {
+          console.log("Error getting Google sheet with key " + key + ":", error);
+          fut.return(false);
+          return;
+        }
         spreadsheet.worksheets[worksheet].cells({
             range: range
         }, Meteor.bindEnvironment( function(err, cells) {
+          var header, data;
           //console.log("Upserting spreadsheet: ",spreadsheet.title)
-          header = cells.cells[1];
-          if (rowOneHeader == true) delete cells.cells[1];
+          if (headerRow) {
+            header = cells.cells[headerRow];
+            delete cells.cells[headerRow];
+          }
           data = cells.cells;
-          record = GASpreadsheet.upsert({spreadsheet: spreadsheet.title},{$set:{spreadsheet: spreadsheet.title, header: header, cells: data}})
+          var result = GASpreadsheet.upsert({spreadsheet: spreadsheet.title}, {$set:{header: header, cells: data}});
+          fut.return(GASpreadsheet.findOne({spreadsheet: spreadsheet.title}, {fields: {_id: 1}})._id);
         }));
     }));
+    return fut.wait();
   },
-  'spreadsheet/update': function (key, worksheet, rowOneHeader) {
-    if (!worksheet) worksheet = 0;
-    if (!rowOneHeader) rowOneHeader = true;
-    //TODO update spreadsheet with collection updates
+  'spreadsheet/fetch2': function (spreadsheetName, worksheetId, options) {
+    var fut = new Future(); //don't return until we're done exporting
+
+    EditGoogleSpreadsheet.load({
+      //debug: true,
+      spreadsheetName: spreadsheetName,
+      worksheetId: worksheetId,
+      oauth : {
+        email: options.email,
+        keyFile: pemFile
+      }
+    }, function sheetReady(err, spreadsheet) {
+      if (err) {
+        console.log(err);
+        fut.return(false);
+        return;
+      }
+      spreadsheet.receive(function(err, rows, info) {
+        if (err) {
+          console.log(err);
+          fut.return(false);
+        } else {
+          fut.return({rows: rows, info: info});
+        }
+      });
+    });
+    return fut.wait();
+  },
+  'spreadsheet/update': function (spreadsheetName, worksheetId, updateObject, options) {
+    var fut = new Future(); //don't return until we're done exporting
+
+    EditGoogleSpreadsheet.load({
+      //debug: true,
+      spreadsheetName: spreadsheetName,
+      worksheetId: worksheetId,
+      oauth : {
+        email: options.email,
+        keyFile: pemFile
+      }
+    }, function sheetReady(err, spreadsheet) {
+      if (err) {
+        console.log(err);
+        fut.return(false);
+        return;
+      }
+      spreadsheet.add(updateObject);
+      spreadsheet.send(function(err) {
+        if (err) {
+          console.log(err);
+          fut.return(false);
+        } else {
+          fut.return(true);
+        }
+      });
+    });
+    return fut.wait();
   }
 });