feat: Adaptors

Author: leeyeh

package-lock.json

@@ -26,13 +26,16 @@
     "debug": "^3.1.0",
     "es6-promise": "4.2.3",
     "eventemitter3": "^2.0.3",
-    "leancloud-realtime": "^5.0.0-beta.0",
+    "isomorphic-ws": "^4.0.1",
+    "leancloud-realtime": "^5.0.0-beta.3",
     "leancloud-realtime-plugin-live-query": "^1.2.0",
     "localstorage-memory": "^1.0.1",
     "md5": "^2.0.0",
+    "promise-timeout": "^1.3.0",
     "superagent": "^3.3.1",
     "underscore": "^1.8.3",
-    "uuid": "^3.3.2"
+    "uuid": "^3.3.2",
+    "ws": "^7.2.1"
   },
   "devDependencies": {
     "@pollyjs/adapter-node-http": "^2.6.2",
@@ -62,7 +65,7 @@
     "prettier": "^1.11.1",
     "pretty-quick": "^1.4.1",
     "should": "^11.1.0",
-    "typescript": "^3.0.3",
+    "typescript": "^3.8.3",
     "weapp-polyfill": "^3.1.2",
     "webpack": "^3.11.0",
     "webpack-strip-block": "^0.2.0"

package.json

@@ -0,0 +1,21 @@
+const adaptors = {};
+
+const getAdaptor = name => {
+  const adaptor = adaptors[name];
+  if (adaptor === undefined) {
+    throw new Error(`${name} adaptor is not configured`);
+  }
+  return adaptor;
+};
+const setAdaptor = (name, adaptor) => {
+  adaptors[name] = adaptor;
+};
+const setAdaptors = newAdaptors => {
+  Object.assign(adaptors, newAdaptors);
+};
+
+module.exports = {
+  getAdaptor,
+  setAdaptor,
+  setAdaptors,
+};

src/adaptor.js

@@ -4,6 +4,7 @@ const debug = require('debug');
 const userAgent = require('./ua');
 const { inherits, parseDate } = require('./utils');
 const Promise = require('./promise');
+const { setAdaptor, setAdaptors } = require('./adaptor');
 
 const AV = global.AV || {};
 
@@ -372,4 +373,7 @@ AV.debug = {
   disable: debug.disable,
 };
 
+AV.setAdaptors = setAdaptors;
+AV.setAdaptor = setAdaptor;
+
 module.exports = AV;

src/av.js

@@ -0,0 +1,58 @@
+const superagent = require('superagent');
+const storage = require('./utils/localstorage');
+
+function request(url, { method, data, headers, onprogress }) {
+  const req = superagent(method, url);
+  if (headers) {
+    req.set(headers);
+  }
+  if (onprogress) {
+    req.on('progress', onprogress);
+  }
+
+  return req
+    .send(data)
+    .catch(error => {
+      if (error.response) {
+        return error.response;
+      }
+      throw error;
+    })
+    .then(({ status, ok, header, body }) => ({
+      status,
+      ok,
+      headers: header,
+      data: body,
+    }));
+}
+
+function upload(url, file, { headers, data, onprogress } = {}) {
+  const req = superagent('POST', url)
+    .attach(file.field, file.data, file.name)
+    .field(data);
+  if (headers) {
+    req.set(headers);
+  }
+  if (onprogress) {
+    req.on('progress', onprogress);
+  }
+  return req
+    .catch(error => {
+      if (error.response) {
+        return error.response;
+      }
+      throw error;
+    })
+    .then(({ status, ok, header, body }) => ({
+      status,
+      ok,
+      headers: header,
+      data: body,
+    }));
+}
+
+module.exports = {
+  request,
+  upload,
+  storage,
+};

src/builtin-adaptors.js

@@ -1,8 +1,26 @@
 const AV = require('./index');
 
-const { Realtime } = require('leancloud-realtime/core');
+const {
+  Realtime,
+  setAdaptor: setRTMAdaptor,
+  setAdaptors: setRTMAdaptors,
+} = require('leancloud-realtime/core');
 const { LiveQueryPlugin } = require('leancloud-realtime-plugin-live-query');
 Realtime.__preRegisteredPlugins = [LiveQueryPlugin];
 AV._sharedConfig.liveQueryRealtime = Realtime;
 
+const { setAdaptor, setAdaptors } = AV;
+AV.setAdaptor = (name, adaptor) => {
+  setAdaptor(name, adaptor);
+  setRTMAdaptor(name, adaptor);
+};
+AV.setAdaptors = adaptors => {
+  setAdaptors(adaptors);
+  setRTMAdaptors(adaptors);
+};
+const adaptors = require('./builtin-adaptors');
+AV.setAdaptors(adaptors);
+const WebSocket = require('isomorphic-ws');
+AV.setAdaptors({ WebSocket });
+
 module.exports = AV;

src/index-live-query.js

@@ -10,6 +10,9 @@ const _ = require('underscore');
 
 const AV = require('./av');
 
+const adaptors = require('./builtin-adaptors');
+AV.setAdaptors(adaptors);
+
 AV._ = _;
 AV.version = require('./version');
 AV.Promise = require('./promise');