initial commit

Author: sunnylqm

.babelrc

@@ -0,0 +1,14 @@
+{
+  "plugins": [
+    "syntax-object-rest-spread",
+    "syntax-async-functions",
+    "transform-es2015-arrow-functions",
+    "transform-async-to-generator",
+    "transform-es2015-modules-commonjs",
+    "transform-es2015-destructuring",
+    "transform-es2015-spread",
+    "transform-object-rest-spread",
+    "transform-es2015-parameters",
+    "transform-strict-mode"
+  ]
+}

.prettierrc.js

@@ -0,0 +1,4 @@
+module.exports = {
+  trailingComma: 'all',
+  singleQuote: true,
+};

cli.json

@@ -0,0 +1,162 @@
+{
+  "useCommand": true,
+  "defaultCommand": "help",
+  "commands": {
+    "help": {
+    },
+
+    "login":{
+    },
+    "logout": {
+    },
+    "me": {
+    },
+
+    "createApp": {
+      "options": {
+        "name": {
+          "hasValue": true
+        },
+        "platform": {
+          "hasValue": true
+        }
+      }
+    },
+    "apps": {
+      "options": {
+        "platform": {
+          "hasValue": true
+        }
+      }
+    },
+    "deleteApp": {
+    },
+    "selectApp": {
+      "options": {
+        "platform": {
+          "hasValue": true
+        }
+      }
+    },
+
+    "uploadIpa": {
+    },
+    "uploadApk": {
+    },
+    "packages": {
+      "options": {
+        "platform": {
+          "hasValue": true
+        }
+      }
+    },
+
+    "publish": {
+      "options": {
+        "platform": {
+          "hasValue": true
+        },
+        "name": {
+          "hasValue": true
+        },
+        "description": {
+          "hasValue": true
+        },
+        "metaInfo": {
+          "hasValue": true
+        }
+      }
+    },
+    "versions": {
+      "options": {
+        "platform": {
+          "hasValue": true
+        }
+      }
+    },
+
+    "update": {
+      "options": {
+        "platform": {
+          "hasValue": true
+        },
+        "versionId": {
+          "hasValue": true
+        },
+        "packageId": {
+          "hasValue": true
+        }
+      }
+    },
+
+    "build": {
+      "description": "Bundle javascript and copy assets."
+    },
+    "bundle": {
+      "description": "Bundle javascript code only.",
+      "options": {
+        "dev": {
+          "default": "false",
+          "hasValue": true
+        },
+        "platform": {
+          "hasValue": true
+        },
+        "bundleName":{
+          "default": "index.bundlejs",
+          "hasValue": true
+        },
+        "entryFile": {
+          "default": "index.js",
+          "hasValue": true
+        },
+        "intermediaDir": {
+          "default": "build/intermedia/${platform}",
+          "hasValue": true
+        },
+        "output": {
+          "default": "build/output/${platform}.${time}.ppk",
+          "hasValue": true
+        },
+        "verbose": {
+
+        }
+      }
+    },
+    "release": {
+      "description": "Push builded file to server."
+    },
+    "diff": {
+      "description": "Create diff patch",
+      "options": {
+        "output": {
+          "default": "build/output/diff",
+          "hasValue": true
+        }
+      }
+    },
+    "diffFromApk": {
+      "description": "Create diff patch from a Android package(.apk)",
+      "options": {
+        "output": {
+          "default": "build/output/diff-${time}.apk-patch",
+          "hasValue": true
+        }
+      }
+    },
+    "diffFromIpa": {
+      "description": "Create diff patch from a iOS package(.ipa)",
+      "options": {
+        "output": {
+          "default": "build/output/diff-${time}.ipa-patch",
+          "hasValue": true
+        }
+      }
+    }
+  },
+  "globalOptions":{
+    "no-interactive": {
+      "default": false
+    }
+  }
+}

index.js

@@ -0,0 +1,4 @@
+/**
+ * Created by tdzl2003 on 2/22/16.
+ */
+module.exports = require('./lib');

lib/api.js

@@ -0,0 +1,158 @@
+'use strict';
+
+let query = function () {
+  var _ref2 = _asyncToGenerator(function* (url, options) {
+    const resp = yield fetch(url, options);
+    const json = yield resp.json();
+    if (resp.status !== 200) {
+      throw Object.assign(new Error(json.message || json.error), { status: resp.status });
+    }
+    return json;
+  });
+
+  return function query(_x, _x2) {
+    return _ref2.apply(this, arguments);
+  };
+}();
+
+let uploadFile = function () {
+  var _ref3 = _asyncToGenerator(function* (fn) {
+    var _ref4 = yield exports.post('/upload', {});
+
+    const url = _ref4.url,
+          fieldName = _ref4.fieldName,
+          formData = _ref4.formData;
+
+    let realUrl = url;
+
+    if (!/^https?\:\/\//.test(url)) {
+      realUrl = host + url;
+    }
+
+    const fileSize = fs.statSync(fn).size;
+
+    const bar = new _progress2.default('  Uploading [:bar] :percent :etas', {
+      complete: '=',
+      incomplete: ' ',
+      total: fileSize
+    });
+
+    const info = yield new Promise(function (resolve, reject) {
+      formData.file = fs.createReadStream(fn);
+
+      formData.file.on('data', function (data) {
+        bar.tick(data.length);
+      });
+      _request2.default.post(realUrl, {
+        formData
+      }, function (err, resp, body) {
+        if (err) {
+          return reject(err);
+        }
+        if (resp.statusCode > 299) {
+          return reject(Object.assign(new Error(body), { status: resp.statusCode }));
+        }
+        resolve(JSON.parse(body));
+      });
+    });
+    return info;
+  });
+
+  return function uploadFile(_x3) {
+    return _ref3.apply(this, arguments);
+  };
+}();
+
+var _request = require('request');
+
+var _request2 = _interopRequireDefault(_request);
+
+var _progress = require('progress');
+
+var _progress2 = _interopRequireDefault(_progress);
+
+function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
+
+function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { return Promise.resolve(value).then(function (value) { step("next", value); }, function (err) { step("throw", err); }); } } return step("next"); }); }; }
+
+/**
+ * Created by tdzl2003 on 2/13/16.
+ */
+
+const fetch = require('isomorphic-fetch');
+let host = process.env.PUSHY_REGISTRY || 'https://update.reactnative.cn/api';
+const fs = require('fs-extra');
+
+
+let session = undefined;
+let savedSession = undefined;
+
+exports.loadSession = _asyncToGenerator(function* () {
+  if (fs.existsSync('.update')) {
+    try {
+      exports.replaceSession(JSON.parse(fs.readFileSync('.update', 'utf8')));
+      savedSession = session;
+    } catch (e) {
+      console.error('Failed to parse file `.update`. Try to remove it manually.');
+      throw e;
+    }
+  }
+});
+
+exports.getSession = function () {
+  return session;
+};
+
+exports.replaceSession = function (newSession) {
+  session = newSession;
+};
+
+exports.saveSession = function () {
+  // Only save on change.
+  if (session !== savedSession) {
+    const current = session;
+    const data = JSON.stringify(current, null, 4);
+    fs.writeFileSync('.update', data, 'utf8');
+    savedSession = current;
+  }
+};
+
+exports.closeSession = function () {
+  if (fs.existsSync('.update')) {
+    fs.unlinkSync('.update');
+    savedSession = undefined;
+  }
+  session = undefined;
+  host = process.env.PUSHY_REGISTRY || 'https://update.reactnative.cn';
+};
+
+function queryWithoutBody(method) {
+  return function (api) {
+    return query(host + api, {
+      method,
+      headers: {
+        'X-AccessToken': session ? session.token : ''
+      }
+    });
+  };
+}
+
+function queryWithBody(method) {
+  return function (api, body) {
+    return query(host + api, {
+      method,
+      headers: {
+        'Content-Type': 'application/json',
+        'X-AccessToken': session ? session.token : ''
+      },
+      body: JSON.stringify(body)
+    });
+  };
+}
+
+exports.get = queryWithoutBody('GET');
+exports.post = queryWithBody('POST');
+exports.put = queryWithBody('PUT');
+exports.doDelete = queryWithBody('DELETE');
+
+exports.uploadFile = uploadFile;