added google drive storage to jio (tests to be done)

Gruntfile.js

@@ -182,6 +182,7 @@ module.exports = function (grunt) {
           'src/jio.storage/zipstorage.js',
           'src/jio.storage/dropboxstorage.js',
           'src/jio.storage/davstorage.js',
+          'src/jio.storage/gdrivestorage.js',
           'src/jio.storage/unionstorage.js',
           'src/jio.storage/erp5storage.js',
           'src/jio.storage/querystorage.js',

Makefile

@@ -43,6 +43,7 @@ zip:
 	@cp src/jio.storage/replicatestorage.js $(TMPDIR)/jio/storage/
 	@cp src/jio.storage/splitstorage.js     $(TMPDIR)/jio/storage/
 	@cp src/jio.storage/cryptstorage.js     $(TMPDIR)/jio/storage/
+	@cp src/jio.storage/gdrivestorage.js    $(TMPDIR)/jio/storage/
 	@cp src/jio.storage/revisionstorage.js  $(TMPDIR)/jio/storage/
 	@cp src/jio.storage/zipstorage.js       $(TMPDIR)/jio/storage/
 	@cp src/jio.storage/replicaterevisionstorage.js     $(TMPDIR)/jio/storage/
@@ -76,6 +77,7 @@ zip:
 	@$(UGLIFY) src/jio.storage/replicatestorage.js >$(TMPDIR)/jio/storage/replicatestorage.min.js 2>/dev/null
 	@$(UGLIFY) src/jio.storage/splitstorage.js     >$(TMPDIR)/jio/storage/splitstorage.min.js 2>/dev/null
 	@$(UGLIFY) src/jio.storage/cryptstorage.js     >$(TMPDIR)/jio/storage/cryptstorage.min.js 2>/dev/null
+	@$(UGLIFY) src/jio.storage/gdrivestorage.js    >$(TMPDIR)/jio/storage/gdrivestorage.min.js 2>/dev/null
 	@$(UGLIFY) src/jio.storage/revisionstorage.js     >$(TMPDIR)/jio/storage/revisionstorage.min.js 2>/dev/null
 	@$(UGLIFY) src/jio.storage/replicaterevisionstorage.js     >$(TMPDIR)/jio/storage/replicaterevisionstorage.min.js 2>/dev/null
 	@$(UGLIFY) src/jio.storage/zipstorage.js						 >$(TMPDIR)/jio/storage/zipstorage.min.js 2>/dev/null

src/jio.storage/gdrivestorage.js

+/*
+ * Copyright 2015, Nexedi SA
+ * Released under the LGPL license.
+ * http://www.gnu.org/licenses/lgpl.html
+ */
+/**
+ * JIO Google Drive Storage. Type = "gdrive".
+ * Google Drive "database" storage.
+ */
+/*global Blob, jIO, RSVP, UriTemplate, JSON*/
+/*jslint nomen: true*/
+
+(function (jIO, RSVP, Blob, UriTemplate) {
+  "use strict";
+
+  var UPLOAD_URL = "https://www.googleapis.com/upload/drive/v2/files{/id}" +
+      "?uploadType=multipart{&access_token}",
+    upload_template = UriTemplate.parse(UPLOAD_URL),
+    REMOVE_URL = "https://www.googleapis.com/drive/v2/" +
+      "files{/id,trash}{?access_token}",
+    remove_template = UriTemplate.parse(REMOVE_URL),
+    GET_URL = "https://www.googleapis.com/drive/v2/files{/id}?alt=media",
+    get_template = UriTemplate.parse(GET_URL),
+    LIST_URL = "https://www.googleapis.com/drive/v2/files" +
+      "?prettyPrint=false{&pageToken}&q=trashed=false" +
+      "&fields=nextPageToken,items(id,mimeType,title,parents(id,isRoot))" +
+      "{&access_token}",
+    list_template = UriTemplate.parse(LIST_URL),
+    FOLDER = "application/vnd.google-apps.folder";
+
+  function restrictDocumentId(id) {
+    if (id.indexOf("/") !== 0) {
+      throw new jIO.util.jIOError("id " + id + " is forbidden (no begin /)",
+                                  400);
+    }
+    if (id.lastIndexOf("/") !== (id.length - 1)) {
+      throw new jIO.util.jIOError("id " + id + " is forbidden (no end /)",
+                                  400);
+    }
+    return id;
+  }
+
+  function restrictAttachmentId(id) {
+    if (id.indexOf("/") !== -1) {
+      throw new jIO.util.jIOError("attachment " + id + " is forbidden",
+                                  400);
+    }
+  }
+
+  function listPage(result, token) {
+    var i,
+      obj;
+    return new RSVP.Queue()
+      .push(function () {
+        return jIO.util.ajax({
+          "type": "GET",
+          "url": list_template.expand({
+            pageToken : (result.nextPageToken || ""),
+            access_token: token
+          })
+        });
+      })
+      .push(function (data) {
+        obj = JSON.parse(data.target.response);
+        for (i = 0; i < obj.items.length; i += 1) {
+          result.push(obj.items[i]);
+        }
+        result.nextPageToken = obj.nextPageToken;
+        return result;
+      });
+  }
+
+  function listFiles(result, token) {
+    return new RSVP.Queue()
+      .push(function () {
+        return listPage(result, token);
+      })
+      .push(function () {
+        if (result.nextPageToken) {
+          return listFiles(result, token);
+        }
+        return result;
+      });
+  }
+
+  function splitpath(path) {
+    var name = path.split("/"),
+      it_name;
+
+    for (it_name = 0; it_name < name.length; it_name += 1) {
+      if (name[it_name] === "") {
+        name.splice(it_name, 1);
+        it_name -= 1;
+      }
+    }
+    return name;
+  }
+
+  function getFileId(path, token, list) {
+    var it_name,
+      itFi,
+      itPa,
+      parentId,
+      foundItem,
+      result = {},
+      name = splitpath(path);
+
+    if (!name.length) {return result; }
+    return new RSVP.Queue()
+      .push(function () {
+        return list || listFiles([], token);
+      })
+      .push(function (files) {
+        for (it_name = 0; it_name < name.length; it_name += 1) {
+          foundItem = false;
+          for (itFi = 0; itFi < files.length; itFi += 1) {
+            if (files[itFi].title  === name[it_name]) {
+              for (itPa = 0; itPa < files[itFi].parents.length;
+                   itPa += 1) {
+
+                if ((!it_name && files[itFi].parents[itPa].isRoot) ||
+                    (it_name &&
+                     files[itFi].parents[itPa].id === parentId)) {
+
+                  if (foundItem === true) {
+                    //if 2 files with same name in same folder.
+                    throw new jIO.util.jIOError("Method not implemented", 405);
+                  }
+                  foundItem = true;
+                  parentId = files[itFi].id;
+
+                  if (it_name === (name.length - 2) &&
+                      files[itFi].mimeType === FOLDER) {
+                    result.parent = parentId;
+                  }
+                  if (it_name === (name.length - 1)) {
+                    result.id = parentId;
+                    result.isDir = (files[itFi].mimeType === FOLDER)
+                      ? true : false;
+                  }
+                  break;
+                }
+
+              }
+            }
+          }
+          if (!foundItem) {break; }
+        }
+        return result;
+      });
+  }
+
+  /**
+   * The JIO Google Drive Storage extension
+   *
+   * @class GdriveStorage
+   * @constructor
+   */
+  function GdriveStorage(spec) {
+    if (spec === undefined || spec.access_token === undefined ||
+        typeof spec.access_token !== 'string') {
+      throw new TypeError("Access Token' must be a string " +
+                          "which contains more than one character.");
+    }
+    this._trashing = spec.trashing || true;
+    this._access_token = spec.access_token;
+    return;
+  }
+
+  function createPostRequest(title, parent, data, datatype) {
+    var str,
+      boundary = "-------314159265358979323846",
+      parentlist = parent ? '{id: "' + parent + '"}' : "",
+      type = data ? "" : '"mimeType" : "' + FOLDER + '",\n';
+
+    str = '--' + boundary +
+      '\nContent-Type: application/json; charset=UTF-8\n\n' +
+      '{\n"title": "' + title + '",\n' + type +
+      '"parents": [' + parentlist + ']\n}\n\n' +
+      '--' + boundary;
+
+    if (data) {
+      str += '\nContent-Type: ' + datatype + '\n' +
+        'Content-Transfer-Encoding: base64\n\n';
+      data = data.split(",").pop();
+      str += data;
+      str += '\n--' + boundary;
+    }
+    str += '--';
+
+    return str;
+  }
+
+  function putElement(id, data, token) {
+    var title = splitpath(id),
+      boundary = "-------314159265358979323846",
+      files;
+
+    return new RSVP.Queue()
+      .push(function () {
+        return getFileId(id, token);
+      })
+      .push(function (result) {
+        files = result;
+        if (title.length === 0 || (files.id && !data) ||
+            (!files.parent && title.length > 1)) {
+          throw new jIO.util.jIOError("Method Not Allowed", 405);
+        }
+      })
+      .push(function () {
+        if (data) { return jIO.util.readBlobAsDataURL(data); }
+        return;
+      })
+      .push(function (blob) {
+        var update = false;
+        if (blob) {blob = blob.currentTarget.result; }
+        if (blob && files.id) {update = true; }
+        return jIO.util.ajax({
+          "type": update ? "PUT" : "POST",
+          "url": upload_template.expand({
+            access_token: token,
+            id: update ? files.id : []
+          }),
+          headers: {
+            "Content-Type" : 'multipart/related; boundary="' + boundary + '"'
+          },
+          data : createPostRequest(title.pop(), files.parent, blob, data.type)
+        });
+      }, undefined);
+  }
+
+  GdriveStorage.prototype.put = function (id, param) {
+    id = restrictDocumentId(id);
+    if (Object.getOwnPropertyNames(param).length > 0) {
+      throw new jIO.util.jIOError("Can not store properties: " +
+                                  Object.getOwnPropertyNames(param), 400);
+    }
+    return putElement(id, false, this._access_token);
+  };
+
+  GdriveStorage.prototype.putAttachment = function (id, name, blob) {
+    id = restrictDocumentId(id);
+    restrictAttachmentId(name);
+    return putElement(id + name, blob, this._access_token);
+  };
+
+  function removeElement(id, deleteDir, token, trashing) {
+    var title = splitpath(id);
+
+    return new RSVP.Queue()
+      .push(function () {
+        return getFileId(id, token);
+      })
+      .push(function (result) {
+        if (!result.id) {
+          throw new jIO.util.jIOError("Not Found", 404);
+        }
+        if (title.length === 0 || result.isDir !== deleteDir) {
+          throw new jIO.util.jIOError("Method Not Allowed", 405);
+        }
+        return jIO.util.ajax({
+          type: trashing ? "POST" : "DELETE",
+          url: remove_template.expand({
+            id : result.id,
+            access_token : token,
+            trash : trashing ? "trash" : []
+          })
+        });
+      });
+  }
+
+  GdriveStorage.prototype.remove = function (id) {
+    id = restrictDocumentId(id);
+    return removeElement(id, true, this._access_token, this._trashing);
+  };
+
+  GdriveStorage.prototype.removeAttachment = function (id, name) {
+    id = restrictDocumentId(id);
+    restrictAttachmentId(name);
+    return removeElement(id + name, false, this._access_token, this._trashing);
+  };
+
+  GdriveStorage.prototype.get = function (id) {
+    var that = this;
+
+    id = restrictDocumentId(id);
+    if (!splitpath(id).length) {return {}; }
+
+    return new RSVP.Queue()
+      .push(function () {
+        return getFileId(id, that._access_token);
+      })
+      .push(function (result) {
+        if (result.isDir) {
+          return {};
+        }
+        throw new jIO.util.jIOError("Not a directory: " + id, 404);
+      }, function (error) {
+        if (error.target !== undefined && error.target.status === 404) {
+          throw new jIO.util.jIOError("Cannot find document: " + id, 404);
+        }
+        throw error;
+      });
+  };
+
+  GdriveStorage.prototype.allAttachments = function (id) {
+
+    var that = this,
+      files,
+      title = splitpath(id),
+      itFi,
+      itPa;
+
+    id = restrictDocumentId(id);
+    return new RSVP.Queue()
+      .push(function () {
+        files = listFiles([], that._access_token);
+        return files;
+      })
+      .push(function (list) {
+        var result;
+        result = title.length ? getFileId(id, that._access_token, list) : [];
+        return result;
+      })
+      .push(function (obj) {
+        var result = {};
+
+        files = files.fulfillmentValue;
+        if (title.length) {
+          if (!obj.id) {
+            throw new jIO.util.jIOError("Cannot find document: " + id, 404);
+          }
+          if (!obj.isDir) {
+            throw new jIO.util.jIOError("Not a directory: " + id, 404);
+          }
+        }
+        for (itFi = 0; itFi < files.length; itFi += 1) {
+          for (itPa = 0; itPa < files[itFi].parents.length; itPa += 1) {
+            if (files[itFi].mimeType !== FOLDER &&
+                ((!title.length && files[itFi].parents[itPa].isRoot) ||
+                 (title.length && files[itFi].parents[itPa].id === obj.id))) {
+              result[files[itFi].title] = {};
+              break;
+            }
+          }
+        }
+        return result;
+      }, undefined);
+  };
+
+  GdriveStorage.prototype.getAttachment = function (id, name) {
+    var that = this;
+
+    id = restrictDocumentId(id);
+    restrictAttachmentId(name);
+
+    return new RSVP.Queue()
+      .push(function () {
+        return getFileId(id + name, that._access_token);
+      })
+      .push(function (result) {
+        if (!result.id) {
+          throw new jIO.util.jIOError(
+            "Cannot find attachment: " + id + " , " + name,
+            404
+          );
+        }
+        if (result.isDir) {
+          throw new jIO.util.jIOError("Method not implemented", 405);
+        }
+        return jIO.util.ajax({
+          type: "GET",
+          dataType: "blob",
+          url: get_template.expand({
+            id: result.id,
+            access_token: that._access_token
+          }),
+          headers: {
+            "Authorization" : "Bearer " + that._access_token
+          }
+        });
+      })
+      .push(function (evt) {
+        return new Blob(
+          [evt.target.response || evt.target.responseText],
+          {"type": evt.target.getResponseHeader('Content-Type') ||
+            "application/octet-stream"}
+        );
+      });
+  };
+
+  jIO.addStorage('gdrive', GdriveStorage);
+
+}(jIO, RSVP, Blob, UriTemplate));