|
@@ -6416,7 +6416,11 @@
|
|
|
error: console.error,
|
|
|
infoAndReportMeasurement: function infoAndReportMeasurement() {}
|
|
|
};
|
|
|
- var FRAME_COMPOSE_LENGTH = 5;
|
|
|
+ var USER_ID = "987412365",
|
|
|
+ PAGE_SESSION = "aaabbbccc",
|
|
|
+ SERVER_SESSION = "cccbbbaaa",
|
|
|
+ COS_PREFIX = "error-bitstreams-auto-uploaded-from-application/",
|
|
|
+ FRAME_COMPOSE_LENGTH = 5;
|
|
|
|
|
|
var Workers = /*#__PURE__*/function () {
|
|
|
function Workers(e, t) {
|
|
@@ -6806,14 +6810,21 @@
|
|
|
key: "init",
|
|
|
value: function () {
|
|
|
var _init = _asyncToGenerator( /*#__PURE__*/regenerator.mark(function _callee() {
|
|
|
+ var _this5 = this;
|
|
|
|
|
|
- var r,
|
|
|
+ var e,
|
|
|
+ r,
|
|
|
n,
|
|
|
- t;
|
|
|
+ t,
|
|
|
+ _args = arguments;
|
|
|
return regenerator.wrap(function _callee$(_context) {
|
|
|
while (1) {
|
|
|
switch (_context.prev = _context.next) {
|
|
|
case 0:
|
|
|
+ e = _args.length > 0 && _args[0] !== undefined ? _args[0] : {
|
|
|
+ width: 1280,
|
|
|
+ height: 720
|
|
|
+ };
|
|
|
|
|
|
for (r = 0; r < FRAME_COMPOSE_LENGTH; r++) {
|
|
|
n = {
|
|
@@ -6829,13 +6840,108 @@
|
|
|
t = new Blob([decoder], {
|
|
|
type: "application/javascript"
|
|
|
});
|
|
|
- return _context.abrupt("return", (this.decoderWorker = new Worker(URL.createObjectURL(t)), this.decoderWorker.postMessage({
|
|
|
+ this.decoderWorker = new Worker(URL.createObjectURL(t));
|
|
|
+ this.decoderWorker.postMessage({
|
|
|
t: 9,
|
|
|
url: WASM_URLS[WASM_Version],
|
|
|
jitterLength: DECODER_PASSIVE_JITTER
|
|
|
- })));
|
|
|
+ });
|
|
|
+ this.decoderWorker.postMessage({
|
|
|
+ t: 1,
|
|
|
+ config: e
|
|
|
+ });
|
|
|
+ return _context.abrupt("return", new Promise(function (r) {
|
|
|
+ _this5.decoderWorker.onmessage = function (n) {
|
|
|
+ switch (n.data.t) {
|
|
|
+ case 0:
|
|
|
+ _this5.ReceiveDecodeMessage(n);
|
|
|
|
|
|
- case 5:
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 1:
|
|
|
+ _this5.UpdateStats(n);
|
|
|
+
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 2:
|
|
|
+ r();
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 3:
|
|
|
+ _this5.SendCacheFrameInfo(n);
|
|
|
+
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 4:
|
|
|
+ {
|
|
|
+ var o = new Date().toISOString(),
|
|
|
+ a = USER_ID + "-" + PAGE_SESSION + "-" + SERVER_SESSION + "-" + o + ".264";
|
|
|
+ uploadStream(COS_PREFIX + a, n.data.fileObj);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 5:
|
|
|
+ _this5.executeFunction("signal", {
|
|
|
+ signal: n.data.metadata,
|
|
|
+ pts: -1,
|
|
|
+ alreadyUpdateYUV: !1
|
|
|
+ });
|
|
|
+
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 6:
|
|
|
+ defaultLogger.infoAndReportMeasurement(n.data), defaultLogger.debug("WASM Ready Cost");
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 7:
|
|
|
+ _this5.ReceivePanoramaDecodeMessage(n);
|
|
|
+
|
|
|
+ break;
|
|
|
+
|
|
|
+ case 8:
|
|
|
+ {
|
|
|
+ var _o4 = {
|
|
|
+ MstType: 0
|
|
|
+ };
|
|
|
+ var _a3 = "";
|
|
|
+
|
|
|
+ try {
|
|
|
+ _a3 = JSON.stringify(_o4);
|
|
|
+ } catch (l) {
|
|
|
+ defaultLogger.error(l);
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ var s = "wasm:" + _a3;
|
|
|
+
|
|
|
+ _this5._rtcp.sendStringData(s);
|
|
|
+
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 9:
|
|
|
+ {
|
|
|
+ defaultLogger.info(n.data.printMsg);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ case 10:
|
|
|
+ {
|
|
|
+ defaultLogger.error(n.data.printMsg), _this5.executeFunction("error", {
|
|
|
+ code: n.data.code,
|
|
|
+ message: n.data.printMsg
|
|
|
+ });
|
|
|
+ break;
|
|
|
+ }
|
|
|
+
|
|
|
+ default:
|
|
|
+ defaultLogger.error("Receive unknown message event from decoder"), defaultLogger.debug(n.data);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ };
|
|
|
+ }));
|
|
|
+
|
|
|
+ case 7:
|
|
|
case "end":
|
|
|
return _context.stop();
|
|
|
}
|
|
@@ -14975,9 +15081,10 @@
|
|
|
return _context4.abrupt("return", Promise.reject(_context4.t0));
|
|
|
|
|
|
case 27:
|
|
|
- return _context4.abrupt("return", (this.beforeJoinRoomResolve(), this.receiveRtcData()));
|
|
|
+ this.beforeJoinRoomResolve();
|
|
|
+ return _context4.abrupt("return", this.receiveRtcData());
|
|
|
|
|
|
- case 28:
|
|
|
+ case 29:
|
|
|
case "end":
|
|
|
return _context4.stop();
|
|
|
}
|