index.esm.js

function e(e, t, r, o) {
  return new (r || (r = Promise))(function (n, a) {
    function i(e) {
      try {
        s(o.next(e));
      } catch (e) {
        a(e);
      }
    }
    function u(e) {
      try {
        s(o.throw(e));
      } catch (e) {
        a(e);
      }
    }
    function s(e) {
      var t;
      e.done
        ? n(e.value)
        : ((t = e.value),
          t instanceof r
            ? t
            : new r(function (e) {
                e(t);
              })).then(i, u);
    }
    s((o = o.apply(e, t || [])).next());
  });
}
function t(e, t) {
  var r,
    o,
    n,
    a,
    i = {
      label: 0,
      sent: function () {
        if (1 & n[0]) throw n[1];
        return n[1];
      },
      trys: [],
      ops: [],
    };
  return (
    (a = { next: u(0), throw: u(1), return: u(2) }),
    'function' == typeof Symbol &&
      (a[Symbol.iterator] = function () {
        return this;
      }),
    a
  );
  function u(u) {
    return function (s) {
      return (function (u) {
        if (r) throw new TypeError('Generator is already executing.');
        for (; a && ((a = 0), u[0] && (i = 0)), i; )
          try {
            if (
              ((r = 1),
              o &&
                (n =
                  2 & u[0]
                    ? o.return
                    : u[0]
                    ? o.throw || ((n = o.return) && n.call(o), 0)
                    : o.next) &&
                !(n = n.call(o, u[1])).done)
            )
              return n;
            switch (((o = 0), n && (u = [2 & u[0], n.value]), u[0])) {
              case 0:
              case 1:
                n = u;
                break;
              case 4:
                return i.label++, { value: u[1], done: !1 };
              case 5:
                i.label++, (o = u[1]), (u = [0]);
                continue;
              case 7:
                (u = i.ops.pop()), i.trys.pop();
                continue;
              default:
                if (
                  !((n = i.trys),
                  (n = n.length > 0 && n[n.length - 1]) || (6 !== u[0] && 2 !== u[0]))
                ) {
                  i = 0;
                  continue;
                }
                if (3 === u[0] && (!n || (u[1] > n[0] && u[1] < n[3]))) {
                  i.label = u[1];
                  break;
                }
                if (6 === u[0] && i.label < n[1]) {
                  (i.label = n[1]), (n = u);
                  break;
                }
                if (n && i.label < n[2]) {
                  (i.label = n[2]), i.ops.push(u);
                  break;
                }
                n[2] && i.ops.pop(), i.trys.pop();
                continue;
            }
            u = t.call(e, i);
          } catch (e) {
            (u = [6, e]), (o = 0);
          } finally {
            r = n = 0;
          }
        if (5 & u[0]) throw u[1];
        return { value: u[0] ? u[1] : void 0, done: !0 };
      })([u, s]);
    };
  }
}
var r = !AudioWorkletNode;
function o() {
  var e;
  return (null === (e = navigator.mediaDevices) || void 0 === e ? void 0 : e.getUserMedia)
    ? navigator.mediaDevices.getUserMedia({ audio: !0, video: !1 })
    : navigator.getUserMedia
    ? new Promise(function (e, t) {
        navigator.getUserMedia(
          { audio: !0, video: !1 },
          function (t) {
            e(t);
          },
          function (e) {
            t(e);
          },
        );
      })
    : Promise.reject(new Error('不支持录音'));
}
function n(o, n) {
  return e(this, void 0, void 0, function () {
    return t(this, function (e) {
      switch (e.label) {
        case 0:
          return r ? [4, o.audioWorklet.addModule(''.concat(n, '/processor.worklet.js'))] : [3, 2];
        case 1:
          return e.sent(), [2, new AudioWorkletNode(o, 'processor-worklet')];
        case 2:
          let worker;
          if (/http/.test(n)) {
            const workerBlob = new Blob(
              ['importScripts(' + JSON.stringify(n + '/processor.worker.js') + ')'],
              { type: 'application/javascript' },
            );
            const blobUrl = window.URL.createObjectURL(workerBlob);
            worker = new Worker(blobUrl);
            worker.__blobUrl = blobUrl;
          } else {
            worker = new Worker(''.concat(n, '/processor.worker.js'));
          }
          return [4, worker];
        case 3:
          return [2, { port: e.sent() }];
      }
    });
  });
}
var a = (function () {
  function a(e) {
    (this.processorPath = e), (this.audioBuffers = []);
  }
  return (
    (a.prototype.start = function (a) {
      var i,
        u = a.sampleRate,
        s = a.frameSize,
        c = a.arrayBufferType;
      return e(this, void 0, void 0, function () {
        var e, a, d, l, f, p;
        return t(this, function (t) {
          switch (t.label) {
            case 0:
              return ((e = this).audioBuffers = []), [4, o()];
            case 1:
              return (
                (a = t.sent()),
                (this.audioTracks = a.getAudioTracks()),
                (d = (function (e, t) {
                  var r;
                  try {
                    (r = new (window.AudioContext || window.webkitAudioContext)({
                      sampleRate: t,
                    })).createMediaStreamSource(e);
                  } catch (t) {
                    (r = new (window.AudioContext ||
                      window.webkitAudioContext)()).createMediaStreamSource(e);
                  }
                  return r;
                })(a, u)),
                (this.audioContext = d),
                d.createMediaStreamSource(a),
                (l = d.createMediaStreamSource(a)),
                [4, n(d, this.processorPath)]
              );
            case 2:
              return (
                (f = t.sent()),
                (this.audioWorklet = f),
                f.port.postMessage({
                  type: 'init',
                  data: {
                    frameSize: s,
                    toSampleRate: u || d.sampleRate,
                    fromSampleRate: d.sampleRate,
                    arrayBufferType: c || 'short16',
                  },
                }),
                (f.port.onmessage = function (t) {
                  if (f.port.__blobUrl) {
                    window.URL.revokeObjectURL(f.port.__blobUrl);
                    f.port.__blobUrl = null;
                  }
                  s && e.onFrameRecorded && e.onFrameRecorded(t.data),
                    e.onStop &&
                      (t.data.frameBuffer && e.audioBuffers.push(t.data.frameBuffer),
                      t.data.isLastFrame && !r && (null == f ? void 0 : f.port).terminate(),
                      t.data.isLastFrame && e.onStop(e.audioBuffers));
                }),
                r
                  ? l.connect(f)
                  : (((p = d.createScriptProcessor(0, 1, 1)).onaudioprocess = function (e) {
                      f.port.postMessage({
                        type: 'message',
                        data: e.inputBuffer.getChannelData(0),
                      });
                    }),
                    l.connect(p),
                    p.connect(d.destination)),
                d.resume(),
                null === (i = this.onStart) || void 0 === i || i.call(this),
                [2]
              );
          }
        });
      });
    }),
    (a.prototype.stop = function () {
      var e, t, r;
      if (this.audioWorklet && this.audioWorklet.port && this.audioWorklet.port.__blobUrl) {
        window.URL.revokeObjectURL(this.audioWorklet.port.__blobUrl);
        this.audioWorklet.port.__blobUrl = null;
      }
      null === (e = this.audioWorklet) || void 0 === e || e.port.postMessage({ type: 'stop' }),
        null === (t = this.audioTracks) || void 0 === t || t[0].stop(),
        null === (r = this.audioContext) || void 0 === r || r.suspend();
    }),
    a
  );
})();
export { a as default };