Merge pull request bytedance#229 from yqjiang/refactor-live-loaderbuffer

Refactor live loaderbuffer

.eslintrc.js

@@ -2,7 +2,7 @@ module.exports = {
     "parser": "babel-eslint",
     "extends": "standard",
     "rules": {
-        "semi": 2
+        "semi": 0
     },
     "overrides": [
         {

packages/xgplayer-buffer/package.json

@@ -1,6 +1,14 @@
 {
   "name": "xgplayer-buffer",
   "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "devDependencies": {},
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
   "dependencies": {
     "@babel/cli": "^7.6.0",
     "@babel/core": "^7.6.0"

packages/xgplayer-flv-live/src/index.js

@@ -1,4 +1,5 @@
-import Context from 'xgplayer-utils'
+import FetchLoader from "xgplayer-loader-fetch";
+import XgBuffer from "xgplayer-buffer";
 import FlvDemuxer from 'xgplayer-flv/demux'
 import FetchLoader from 'xgplayer-loader-fetch'
 
@@ -13,6 +14,28 @@ class FlvLiveController {
     this._context.registry('FLV_DEMUXER', FlvDemuxer)
     this._context.registry('FETCH_LOADER', FetchLoader)
   }
+
+  _init() {
+    this._registry();
+  }
+
+  _registry() {
+    this._context.registry("LOADER", FetchLoader);
+    this._context.registry("LOADER_BUBBER", XgBuffer);
+    // TODO: this._context.registry("DEMUXER", FLVDE)
+
+  }
+
+  _initInstances() {
+    this._context.initInstance("LOADER", {buffer: "LOADER_BUFFER"});
+    this._context.initInstance("LOADER_BUBBER");
+  }
+
+  load(url, opts) {
+    let loader = this._context.getInstance("LOADER");
+    loader.load(url, opts);
+  }
 }
 
-export default FlvLiveController
+export default FlvLiveController;
+

packages/xgplayer-hls-live/package.json

@@ -0,0 +1,15 @@
+{
+  "name": "xgplayer-hls-live",
+  "version": "1.0.0",
+  "description": "",
+  "main": "webpack.config.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "xgplayer-remux": "1.0.0",
+    "xgplayer-utils": "1.1.6-alpha.0"
+  }
+}

packages/xgplayer-hls-live/src/demuxer/m3u8parser.js

@@ -0,0 +1,67 @@
+/**
+ * Reference: https://tools.ietf.org/html/rfc8216#section-4.3
+ */
+
+// TODO: Support More
+class M3U8Parser {
+  static parse (text, baseurl = '') {
+    let ret = {
+      duration: 0
+    };
+    let refs = text.split(/\r|\n/);
+    let ref = refs.shift()
+    if (!ref.match('#EXTM3U')) {
+      // TODO:M3U格式错误。
+      return null;
+    }
+    ref = refs.shift()
+    while (ref !== undefined) {
+      let refm = ref.match(/#(.*):(.*)/);
+      if (refm && refm.length > 2) {
+        switch (refm[1]) {
+          case 'EXT-X-VERSION':
+            ret.version = parseInt(refm[2]);
+            break;
+          case 'EXT-X-MEDIA-SEQUENCE':
+            ret.sequence = parseInt(refm[2]);
+            break;
+          case 'EXT-X-TARGETDURATION':
+            ret.targetduration = parseFloat(refm[2]);
+            break;
+          case 'EXTINF':
+            if (!ret.frags) {
+              ret.frags = []
+            }
+            let freg = {
+              start: ret.duration,
+              duration: parseFloat(refm[2]) * 1000
+            }
+            ret.duration += freg.duration;
+            freg.url = baseurl + refs.shift();
+            ret.frags.push(freg);
+            break;
+          default:
+            break;
+        }
+      }
+      ref = refs.shift()
+    }
+    return ret;
+  }
+
+  static parseURL (url) {
+    let baseurl = '';
+    let urls = url.match(/(.*\/).*\.m3u8$/);
+    if (urls && urls.length > 0) {
+      for (let i = 0; i < urls.length; i++) {
+        if (urls[i].match(/.*\/$/g) && urls[i].length > baseurl.length) {
+          baseurl = urls[i];
+        }
+      }
+    }
+
+    return baseurl;
+  }
+}
+
+export default M3U8Parser;