desirae.js/lib/browser-adapters.js

/*jshint -W054 */
;(function (exports) {
  'use strict';

  function create(Desi) {
    // Chrome, Firefox, and even MSIE11+ all support crypto
    var crypto = window.crypto || window.msCrypto
      , PromiseA = window.Promise
      , algos
      ;

    // convenience mappings for common digest algorithms
    algos = {
      'sha1': 'SHA-1'
    , 'sha256': 'SHA-256'
    , 'sha512': 'SHA-512'
    };

    // The function to generate a sha1sum is the same as generating any digest
    // but here's a shortcut function anyway
    function sha1sum(str) {
      return hashsum('sha1', str);
    }

    // a more general convenience function
    function hashsum(hash, str) {
        // you have to convert from string to array buffer
      var ab
        // you have to represent the algorithm as an object 
        , algo = { name: algos[hash] }
        ;

      if ('string' === typeof str) {
        ab = str2ab(str);
      } else {
        ab = str;
      }

      // All crypto digest methods return a promise
      return crypto.subtle.digest(algo, ab).then(function (digest) {
        // you have to convert the ArrayBuffer to a DataView and then to a hex String
        return ab2hex(digest);
      }).catch(function (e) {
        // if you specify an unsupported digest algorithm or non-ArrayBuffer, you'll get an error
        console.error('sha1sum ERROR');
        console.error(e);
        throw e;
      });
    }

    // convert from arraybuffer to hex
    function ab2hex(ab) {
      var dv = new DataView(ab)
        , i
        , len
        , hex = ''
        , c
        ;

      for (i = 0, len = dv.byteLength; i < len; i += 1) {
        c = dv.getUint8(i).toString(16);

        if (c.length < 2) {
          c = '0' + c;
        }

        hex += c;
      }

      return hex;
    }

    // convert from string to arraybuffer
    function str2ab(stringToEncode, insertBom) {
      stringToEncode = stringToEncode.replace(/\r\n/g,"\n");

      var utftext = []
        , n
        , c
        ;

      if (true === insertBom)  {
        utftext[0] =  0xef;
        utftext[1] =  0xbb;
        utftext[2] =  0xbf;
      }

      for (n = 0; n < stringToEncode.length; n += 1) {

        c = stringToEncode.charCodeAt(n);

        if (c < 128) {
            utftext[utftext.length]= c;
        }
        else if((c > 127) && (c < 2048)) {
            utftext[utftext.length] = (c >> 6) | 192;
            utftext[utftext.length] = (c & 63) | 128;
        }
        else {
            utftext[utftext.length] = (c >> 12) | 224;
            utftext[utftext.length] = ((c >> 6) & 63) | 128;
            utftext[utftext.length] = (c & 63) | 128;
        }

      }
      return new Uint8Array(utftext).buffer;
    }

    exports.hashsum = hashsum;
    exports.sha1sum = sha1sum;

    //
    // FSAPI
    //
    var fsapi
      ;

    function request() {
    }
    request.get = function (url/*, query*/) {
      // Return a new promise.
      return new PromiseA(function(resolve, reject) {
        // Do the usual XHR stuff
        var req = new XMLHttpRequest()
          ;

        req.onload = function() {
          // This is called even on 404 etc
          // so check the status
          if (200 === req.status) {
            // Resolve the promise with the response text
            resolve(req.response);
          }
          else {
            // Otherwise reject with the status text
            // which will hopefully be a meaningful error
            reject(Error(req.statusText));
          }
        };

        // Handle network errors
        req.onerror = function() {
          reject(Error("Network Error"));
        };

        // Make the request
        req.open('GET', url);
        req.send();
      });
    };
    request.post = function (url/*, query*/, body) {
      // Return a new promise.
      return new PromiseA(function(resolve, reject) {
        // Do the usual XHR stuff
        var req = new XMLHttpRequest()
          ;

        req.onload = function() {
          // This is called even on 404 etc
          // so check the status
          if (200 === req.status) {
            // Resolve the promise with the response text
            resolve(req.response);
          }
          else {
            // Otherwise reject with the status text
            // which will hopefully be a meaningful error
            reject(Error(req.statusText));
          }
        };

        // Handle network errors
        req.onerror = function() {
          reject(Error("Network Error"));
        };

        req.open('POST', url);
        req.setRequestHeader("Content-Type", "application/json;charset=UTF-8");
        // Make the request
        if ('string' !== typeof body) {
          body = JSON.stringify(body);
        }
        req.send(body);
      });
    };

    Desi.fsapi = fsapi = Desi.fsapi || {};
    fsapi.getMeta = function (collections, opts) {
      opts = opts || {};

      var extensions = ''
        , dotfiles = ''
        , contents = ''
        , sha1sum = ''
        ;

      if (Array.isArray(opts.extensions)) {
        extensions = '&extensions=' + opts.extensions.join(','); // md,markdown,jade,htm,html
      }
      if (opts.dotfiles) {
        dotfiles = '&dotfiles=true';
      }
      if (opts.contents) {
        contents = '&contents=true';
      }
      if (false === opts.sha1sum) {
        sha1sum = '&sha1sum=false';
      }

      return request.post('/api/fs/walk?_method=GET' + dotfiles + extensions + contents + sha1sum, {
        dirs: collections
      }).then(function (resp) {
        return JSON.parse(resp);
      }).catch(function (e) {
        throw e;
      });
    };

    fsapi.getContents = function (filepaths) {
      return request.post('/api/fs/files?_method=GET', {
        paths: filepaths
      }).then(function (resp) {
        return JSON.parse(resp);
      });
    };

    fsapi.getCache = function () {
      return request.get('/api/fs/static/cache.json').then(function (resp) {
        return JSON.parse(resp);
      }).catch(function (/*e*/) {
        return {};
      }).then(function (obj) {
        return obj;
      });
    };

    fsapi.copy = function (files) {
      var body = { files: files };
      body = JSON.stringify(body); // this is more or less instant for a few MiB of posts
      return request.post('/api/fs/copy', body).then(function (resp) {
        var response = JSON.parse(resp)
          ;

        // not accurate for utf8/unicode, but close enough
        response.size = body.length;
        return response;
      });

    };

    fsapi.putFiles = function (files) {
      var body = { files: files }
        ;

      files.forEach(function (file) {
        if (!file.contents || 'string' === typeof file.contents) {
          return;
        }
        if (/\.json$/i.test(file.path)) {
          file.contents = JSON.stringify(file.contents);
        }
        else if (/\.ya?ml$/i.test(file.path)) {
          file.contents = exports.jsyaml.dump(file.contents); 
        }
      });

      body = JSON.stringify(body); // this is more or less instant for a few MiB of posts
      return request.post('/api/fs/files', body).then(function (resp) {
        var response = JSON.parse(resp)
          ;

        // not accurate for utf8/unicode, but close enough
        response.size = body.length;
        return response;
      });
    };
  }

  if (exports.Desirae) {
    create(exports.Desirae);
  } else {
    exports.create = create;
  }
}('undefined' !== typeof exports && exports || window));