keet-deobfuscated / @holepunchto / keet-core / lib / api / v2 / index.js

const e = require("ready-resource"),
  o = require("safety-catch"),
  s = require("../../client/index.js"),
  {
    api: { hrpc: t },
  } = require("../../../schema/spec"),
  { KeetMethod: i } = require("./base"),
  n = require("./core"),
  h = require("./call"),
  r = require("./debug"),
  a = require("./error"),
  c = require("./network")
class d extends i {
  _run() {
    return this.backend.coreAPI.boot()
  }
}
class u extends i {
  async _run() {}
}
module.exports = class extends e {
  constructor(e, i, n = {}) {
    if (
      (super(),
      (this.keet = e),
      (this.stream = i),
      (this.opts = n),
      (this.view = new s.View()),
      (this.rpc = new t(i)),
      (this._apis = null),
      this.rpc.onBoot(this.onBoot.bind(this)),
      this.rpc.onSelfDestruct(this.onSelfDestruct.bind(this)),
      this.stream.on("close", this.close.bind(this)),
      !this.keet.opened)
    )
      throw new Error("Keet must be opened before starting RPC")
    this.ready().catch(n.onerror || o)
  }
  async _open() {
    ;((this.coreAPI = new n(this)),
      (this.callAPI = new h(this)),
      (this.debugAPI = new r(this)),
      (this.errorAPI = new a(this)),
      (this.networkAPI = new c(this)),
      (this.apis = [this.coreAPI, this.callAPI, this.debugAPI, this.errorAPI, this.networkAPI]),
      this.keet.on("v2:room-changed", this._onRoomChanged.bind(this)),
      this.keet.on("v2:room-chat-changed", this._onRoomChatChanged.bind(this)),
      this.keet.on("v2:room-stats-changed", this._onRoomStatsChanged.bind(this)),
      this.keet.on("v2:room-digest-changed", this._onRoomDigestChanged.bind(this)),
      this.keet.on("v2:room-member-changed", this._onRoomMemberChanged.bind(this)),
      this.keet.on("v2:room-device-changed", this._onRoomDeviceChanged.bind(this)),
      this.keet.on("v2:room-config-changed", this._onRoomConfigChanged.bind(this)),
      this.keet.on("v2:room-reactions-changed", this._onRoomReactionsChanged.bind(this)),
      this.keet.on("v2:room-join-requests-changed", this._onRoomJoinRequestsChanged.bind(this)),
      this.view.members.on("update", this._pushMember.bind(this)),
      this.view.devices.on("update", this._pushDevice.bind(this)),
      this.view.lobby.on("reset", this._pushLobby.bind(this)),
      this.view.identity.on("reset", this._pushIdentity.bind(this)),
      this.view.roomInfo.on("update:reset", this._pushRoomInfo.bind(this)),
      this.view.roomInfo.on("update:role", this._pushRoomInfoRole.bind(this)),
      this.view.roomInfo.on("update:digest", this._pushRoomInfoDigest.bind(this)),
      this.view.roomInfo.on("update:config", this._pushRoomInfoConfig.bind(this)),
      this.view.roomInfo.on("update:message", this._pushRoomInfoMessage.bind(this)),
      this.view.chat.on("reset", this._pushChat.bind(this)),
      this.view.messageInfo.on("update:reset", this._pushMessageInfo.bind(this)),
      this.view.messageInfo.on("update:role", this._pushMessageInfoRole.bind(this)),
      this.view.messageInfo.on("update:member", this._pushMessageInfoMember.bind(this)),
      this.view.messageInfo.on("update:chat", this._pushMessageInfoChat.bind(this)),
      this.view.messageInfo.on("update:reactions", this._pushMessageInfoReactions.bind(this)),
      await Promise.all(this.apis.map((e) => e.ready())))
  }
  async _close() {
    this.apis && (await Promise.all(this.apis.map((e) => e.close())))
  }
  _onPairingChanged(e) {
    this.coreAPI.onPairingChanged(e)
  }
  _onRoomChanged(e) {
    this.coreAPI.onRoomChanged(e)
  }
  _onRoomStatsChanged(e) {
    this.coreAPI.onRoomStatsChanged(e)
  }
  _onRoomChatChanged(e) {
    this.coreAPI.onRoomChatChanged(e)
  }
  _onRoomDigestChanged(e) {
    this.coreAPI.onRoomDigestChanged(e)
  }
  _onRoomMemberChanged(e) {
    this.coreAPI.onRoomMemberChanged(e)
  }
  _onRoomDeviceChanged(e) {
    this.coreAPI.onRoomDeviceChanged(e)
  }
  _onRoomConfigChanged(e) {
    this.coreAPI.onRoomConfigChanged(e)
  }
  _onRoomReactionsChanged(e) {
    this.coreAPI.onRoomReactionsChanged(e)
  }
  _onRoomJoinRequestsChanged(e) {
    this.coreAPI.onRoomJoinRequestsChanged(e)
  }
  _pushMember(e, o) {
    return this.rpc.coreMember(o)
  }
  _pushDevice(e, o) {
    return this.rpc.coreDevice(o)
  }
  _pushMessage(e, o) {
    return this.rpc.coreMessage(o)
  }
  _pushIdentity() {
    return this.rpc.coreIdentityReset(this.view.identity)
  }
  _pushLobby() {
    return this.rpc.coreLobbyReset(this.view.lobby)
  }
  _pushRoomInfoMessage(e) {
    return this.rpc.coreRoomInfoLastMessage({ id: e.id, lastMessage: e.messageId })
  }
  _pushRoomInfoDigest(e) {
    return this.rpc.coreRoomInfoDigest(e)
  }
  _pushRoomInfoConfig(e) {
    return this.rpc.coreRoomInfoConfig(e)
  }
  _pushRoomInfoRole(e) {
    return this.rpc.coreRoomInfoRole(e)
  }
  _pushRoomInfo(e) {
    return this.rpc.coreRoomInfo(e)
  }
  _pushChat() {
    return this.rpc.coreChatReset(this.view.chat)
  }
  _pushMessageInfo(e) {
    return this.rpc.coreMessageInfo(e)
  }
  _pushMessageInfoChat(e) {
    return this.rpc.coreMessageInfoChat(e)
  }
  _pushMessageInfoMember(e) {
    return this.rpc.coreMessageInfoMember(e)
  }
  _pushMessageInfoRole(e) {
    return this.rpc.coreMessageInfoRole(e)
  }
  _pushMessageInfoReactions(e) {
    return this.rpc.coreMessageInfoReactions(e)
  }
  onBoot() {
    return d.run(this)
  }
  onSelfDestruct() {
    return u.run(this)
  }
}