const e = require("tiny-buffer-rpc/any"),
{ pipeline: r } = require("streamx")
function s() {}
module.exports = function (t, o) {
;(o.register(0, { request: e, response: e, onrequest: (e) => t.api.swarm.ready(...e) }),
o.register(1, { request: e, response: e, onrequest: (e) => t.api.core.getVersion(...e) }),
o.register(2, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeRoomVersion(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(3, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeForceUpdates(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(4, { request: e, response: e, onrequest: (e) => t.api.core.upgradeRoom(...e) }),
o.register(5, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateUserSettings(...e),
}),
o.register(6, { request: e, response: e, onrequest: (e) => t.api.core.getIdentity(...e) }),
o.register(7, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeIdentity(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(8, { request: e, response: e, onrequest: (e) => t.api.core.generateIdentity(...e) }),
o.register(9, { request: e, response: e, onrequest: (e) => t.api.core.restoreIdentity(...e) }),
o.register(10, {
request: e,
response: e,
onrequest: (e) => t.api.core.getRecoveryPhrase(...e),
}),
o.register(11, {
request: e,
response: e,
onrequest: (e) => t.api.core.getEncryptedRecoveryPhrase(...e),
}),
o.register(12, {
request: e,
response: e,
onrequest: (e) => t.api.core.decryptEncryptedRecoveryPhrase(...e),
}),
o.register(13, {
request: e,
response: e,
onrequest: (e) => t.api.core.freeRecoveryPhrase(...e),
}),
o.register(14, {
request: e,
response: e,
onrequest: (e) => t.api.core.confirmRecoveryPhrase(...e),
}),
o.register(15, {
request: e,
response: e,
onrequest: (e) => t.api.core.storeRecoveryPhrase(...e),
}),
o.register(16, { request: e, response: e, onrequest: (e) => t.api.core.confirmIdentity(...e) }),
o.register(17, {
request: e,
response: e,
onrequest: (e) => t.api.core.confirmPairingRequest(...e),
}),
o.register(18, {
request: e,
response: e,
dedup: !1,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeIdentityPairingRequests(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(19, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateIdentityProfile(...e),
}),
o.register(20, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateIdentityDevice(...e),
}),
o.register(21, {
request: e,
response: e,
onrequest: (e) => t.api.core.removeIdentityDevice(...e),
}),
o.register(22, { request: e, response: e, onrequest: (e) => t.api.core.getLinkInfo(...e) }),
o.register(23, {
request: e,
response: e,
onrequest: (e) => t.api.core.startPairingIdentity(...e),
}),
o.register(24, { request: e, response: e, onrequest: (e) => t.api.core.pairIdentity(...e) }),
o.register(25, { request: e, response: e, onrequest: (e) => t.api.core.createRoom(...e) }),
o.register(26, { request: e, response: e, onrequest: (e) => t.api.core.pairRoom(...e) }),
o.register(27, { request: e, response: e, onrequest: (e) => t.api.core.leaveRoom(...e) }),
o.register(28, {
request: e,
response: e,
onrequest: (e) => t.api.core.startPairingRoom(...e),
}),
o.register(29, { request: e, response: e, onrequest: (e) => t.api.core.stopPairingRoom(...e) }),
o.register(30, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribePendingRooms(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(31, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribePushNotificationChanges(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(32, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeActivateRoom(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(33, { request: e, response: e, onrequest: (e) => t.api.core.getRoomKeys(...e) }),
o.register(34, {
request: e,
response: e,
onrequest: (e) => t.api.core.resyncPrivateProfile(...e),
}),
o.register(35, { request: e, response: e, onrequest: (e) => t.api.core.getTipSize(...e) }),
o.register(36, { request: e, response: e, onrequest: (e) => t.api.core.bookmark(...e) }),
o.register(37, { request: e, response: e, onrequest: (e) => t.api.core.unbookmark(...e) }),
o.register(38, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeBookmarks(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(39, { request: e, response: e, onrequest: (e) => t.api.core.getRoomInfo(...e) }),
o.register(40, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeRoomInfo(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(41, { request: e, response: e, onrequest: (e) => t.api.core.searchRooms(...e) }),
o.register(42, { request: e, response: e, onrequest: (e) => t.api.core.getRecentRooms(...e) }),
o.register(43, {
request: e,
response: e,
onrequest: (e) => t.api.core.getLocalRoomMetadata(...e),
}),
o.register(44, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeRecentRooms(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(45, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeFavoriteRooms(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(46, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeUnreadActivity(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(47, { request: e, response: e, onrequest: (e) => t.api.core.setRoomUnread(...e) }),
o.register(48, {
request: e,
response: e,
onrequest: (e) => t.api.core.bumpRoomPriority(...e),
}),
o.register(49, { request: e, response: e, onrequest: (e) => t.api.core.addDevice(...e) }),
o.register(50, { request: e, response: e, onrequest: (e) => t.api.core.removeDevice(...e) }),
o.register(51, { request: e, response: e, onrequest: (e) => t.api.core.getDevice(...e) }),
o.register(52, { request: e, response: e, onrequest: (e) => t.api.core.getDevices(...e) }),
o.register(53, {
request: e,
response: e,
onrequest: (e) => t.api.core.getDevicesByMemberId(...e),
}),
o.register(54, {
request: e,
response: e,
onrequest: (e) => t.api.core.getCurrentDeviceId(...e),
}),
o.register(55, { request: e, response: e, onrequest: (e) => t.api.core.moveIndexer(...e) }),
o.register(56, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeDevice(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(57, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeDevices(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(58, {
request: e,
response: e,
onrequest: (e) => t.api.core.createIdentityInvitation(...e),
}),
o.register(59, {
request: e,
response: e,
onrequest: (e) => t.api.core.createInvitation(...e),
}),
o.register(60, { request: e, response: e, onrequest: (e) => t.api.core.updateMember(...e) }),
o.register(61, { request: e, response: e, onrequest: (e) => t.api.core.isMemberMuted(...e) }),
o.register(62, { request: e, response: e, onrequest: (e) => t.api.core.getMember(...e) }),
o.register(63, { request: e, response: e, onrequest: (e) => t.api.core.removeMember(...e) }),
o.register(64, { request: e, response: e, onrequest: (e) => t.api.core.getMembers(...e) }),
o.register(65, {
request: e,
response: e,
onrequest: (e) => t.api.core.getActiveMembers(...e),
}),
o.register(66, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeActiveMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(67, { request: e, response: e, onrequest: (e) => t.api.core.getModerators(...e) }),
o.register(68, { request: e, response: e, onrequest: (e) => t.api.core.getMemberCount(...e) }),
o.register(69, { request: e, response: e, onrequest: (e) => t.api.core.waitUntilJoined(...e) }),
o.register(70, {
request: e,
response: e,
onrequest: (e) => t.api.core.getMemberForDevice(...e),
}),
o.register(71, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeMemberCount(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(72, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeMember(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(73, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(74, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeModerators(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(75, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeMemberForDevice(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(76, {
request: e,
response: e,
onrequest: (e) => t.api.core.changeMemberRole(...e),
}),
o.register(77, { request: e, response: e, onrequest: (e) => t.api.core.muteMember(...e) }),
o.register(78, { request: e, response: e, onrequest: (e) => t.api.core.unmuteMember(...e) }),
o.register(79, {
request: e,
response: e,
onrequest: (e) => t.api.core.getSearchMembers(...e),
}),
o.register(80, {
request: e,
response: e,
onrequest: (e) => t.api.core.getPushNotificationMembers(...e),
}),
o.register(81, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeSearchMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(82, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribePushNotificationMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(83, { request: e, response: e, onrequest: (e) => t.api.core.getContactInfo(...e) }),
o.register(84, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeContactInfo(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(85, {
request: e,
response: e,
onrequest: (e) => t.api.core.getSelfContactInfo(...e),
}),
o.register(86, { request: e, response: e, onrequest: (e) => t.api.core.blockMember(...e) }),
o.register(87, { request: e, response: e, onrequest: (e) => t.api.core.unblockMember(...e) }),
o.register(88, {
request: e,
response: e,
onrequest: (e) => t.api.core.getBlockedMembers(...e),
}),
o.register(89, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeBlockedMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(90, {
request: e,
response: e,
onrequest: (e) => t.api.core.getConnectedMembers(...e),
}),
o.register(91, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeConnectedMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(92, { request: e, response: e, onrequest: (e) => t.api.core.updateConfig(...e) }),
o.register(93, { request: e, response: e, onrequest: (e) => t.api.core.getConfig(...e) }),
o.register(94, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeConfig(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(95, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateRoomSettings(...e),
}),
o.register(96, {
request: e,
response: e,
onrequest: (e) => t.api.core.disableMembershipEvents(...e),
}),
o.register(97, {
request: e,
response: e,
onrequest: (e) => t.api.core.enableMembershipEvents(...e),
}),
o.register(98, { request: e, response: e, onrequest: (e) => t.api.core.addChatMessage(...e) }),
o.register(99, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateChatMessage(...e),
}),
o.register(100, {
request: e,
response: e,
onrequest: (e) => t.api.core.removeChatMessage(...e),
}),
o.register(101, {
request: e,
response: e,
onrequest: (e) => t.api.core.forwardChatMessage(...e),
}),
o.register(102, { request: e, response: e, onrequest: (e) => t.api.core.pinChatMessage(...e) }),
o.register(103, {
request: e,
response: e,
onrequest: (e) => t.api.core.unpinChatMessage(...e),
}),
o.register(104, { request: e, response: e, onrequest: (e) => t.api.core.startCall(...e) }),
o.register(105, { request: e, response: e, onrequest: (e) => t.api.core.joinCall(...e) }),
o.register(106, { request: e, response: e, onrequest: (e) => t.api.core.leaveCall(...e) }),
o.register(107, { request: e, response: e, onrequest: (e) => t.api.core.endCall(...e) }),
o.register(108, { request: e, response: e, onrequest: (e) => t.api.core.addCallStream(...e) }),
o.register(109, {
request: e,
response: e,
onrequest: (e) => t.api.core.removeCallStream(...e),
}),
o.register(110, { request: e, response: e, onrequest: (e) => t.api.core.getActiveCalls(...e) }),
o.register(111, { request: e, response: e, onrequest: (e) => t.api.core.getCalls(...e) }),
o.register(112, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeActiveCalls(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(113, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeCalls(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(114, {
request: e,
response: e,
onrequest: (e) => t.api.core.addCallStartedEvent(...e),
}),
o.register(115, {
request: e,
response: e,
onrequest: (e) => t.api.core.addCallHangupEvent(...e),
}),
o.register(116, {
request: e,
response: e,
onrequest: (e) => t.api.core.addCallMissedEvent(...e),
}),
o.register(117, {
request: e,
response: e,
onrequest: (e) => t.api.core.addLocationSharedEvent(...e),
}),
o.register(118, {
request: e,
response: e,
onrequest: (e) => t.api.core.addRoomAvatarChangedEvent(...e),
}),
o.register(119, { request: e, response: e, onrequest: (e) => t.api.core.addEvent(...e) }),
o.register(120, { request: e, response: e, onrequest: (e) => t.api.core.removeEvent(...e) }),
o.register(121, { request: e, response: e, onrequest: (e) => t.api.core.getChatMessage(...e) }),
o.register(122, {
request: e,
response: e,
onrequest: (e) => t.api.core.getChatMessageById(...e),
}),
o.register(123, {
request: e,
response: e,
onrequest: (e) => t.api.core.getChatMessages(...e),
}),
o.register(124, {
request: e,
response: e,
onrequest: (e) => t.api.core.getPinnedChatMessages(...e),
}),
o.register(125, { request: e, response: e, onrequest: (e) => t.api.core.getChatLength(...e) }),
o.register(126, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeChatMessages(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(127, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeChatLength(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(128, {
request: e,
response: e,
onrequest: (e) => t.api.core.searchChatMessages(...e),
}),
o.register(129, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.createChatSearchStream(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(130, {
request: e,
response: e,
onrequest: (e) => t.api.core.sendDMFromContact(...e),
}),
o.register(131, { request: e, response: e, onrequest: (e) => t.api.core.sendDMRequest(...e) }),
o.register(132, {
request: e,
response: e,
onrequest: (e) => t.api.core.sendInvitations(...e),
}),
o.register(133, {
request: e,
response: e,
onrequest: (e) => t.api.core.updatePrivateMailboxRecord(...e),
}),
o.register(134, {
request: e,
response: e,
onrequest: (e) => t.api.core.getPrivateMailboxRecords(...e),
}),
o.register(135, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribePrivateMailbox(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(136, {
request: e,
response: e,
onrequest: (e) => t.api.core.getSentPrivateMailboxRecords(...e),
}),
o.register(137, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeSentPrivateMailbox(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(138, {
request: e,
response: e,
onrequest: (e) => t.api.core.getDmByMemberId(...e),
}),
o.register(139, {
request: e,
response: e,
onrequest: (e) => t.api.core.getDmRequestsByStatus(...e),
}),
o.register(140, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeDmRequestsByStatus(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(141, {
request: e,
response: e,
onrequest: (e) => t.api.core.acceptDmRequest(...e),
}),
o.register(142, {
request: e,
response: e,
onrequest: (e) => t.api.core.rejectDmRequest(...e),
}),
o.register(143, { request: e, response: e, onrequest: (e) => t.api.core.addReaction(...e) }),
o.register(144, { request: e, response: e, onrequest: (e) => t.api.core.removeReaction(...e) }),
o.register(145, {
request: e,
response: e,
onrequest: (e) => t.api.core.getLatestReactions(...e),
}),
o.register(146, { request: e, response: e, onrequest: (e) => t.api.core.getReactions(...e) }),
o.register(147, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeReactions(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(148, { request: e, response: e, onrequest: (e) => t.api.core.addChatReport(...e) }),
o.register(149, {
request: e,
response: e,
onrequest: (e) => t.api.core.removeChatReport(...e),
}),
o.register(150, { request: e, response: e, onrequest: (e) => t.api.core.reportMember(...e) }),
o.register(151, {
request: e,
response: e,
onrequest: (e) => t.api.core.getReportedMembers(...e),
}),
o.register(152, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeReportedMembers(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(153, {
request: e,
response: e,
onrequest: (e) => t.api.core.getReportedMessages(...e),
}),
o.register(154, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeReportedMessages(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(155, { request: e, response: e, onrequest: (e) => t.api.core.addFileBlob(...e) }),
o.register(156, { request: e, response: e, onrequest: (e) => t.api.core.addFile(...e) }),
o.register(157, { request: e, response: e, onrequest: (e) => t.api.core.saveFileBlob(...e) }),
o.register(158, { request: e, response: e, onrequest: (e) => t.api.core.saveFile(...e) }),
o.register(159, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeAddFile(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(160, { request: e, response: e, onrequest: (e) => t.api.core.sendFile(...e) }),
o.register(161, { request: e, response: e, onrequest: (e) => t.api.core.removeFile(...e) }),
o.register(162, {
request: e,
response: e,
onrequest: (e) => t.api.core.refreshFileLinks(...e),
}),
o.register(163, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeFileInfo(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(164, { request: e, response: e, onrequest: (e) => t.api.core.clearAllFiles(...e) }),
o.register(165, { request: e, response: e, onrequest: (e) => t.api.core.getFileEntry(...e) }),
o.register(166, { request: e, response: e, onrequest: (e) => t.api.core.getLocalFiles(...e) }),
o.register(167, { request: e, response: e, onrequest: (e) => t.api.core.getFiles(...e) }),
o.register(168, { request: e, response: e, onrequest: (e) => t.api.core.startDownload(...e) }),
o.register(169, { request: e, response: e, onrequest: (e) => t.api.core.cancelDownload(...e) }),
o.register(170, { request: e, response: e, onrequest: (e) => t.api.core.clearFile(...e) }),
o.register(171, { request: e, response: e, onrequest: (e) => t.api.core.unclearFile(...e) }),
o.register(172, { request: e, response: e, onrequest: (e) => t.api.core.getFileCleared(...e) }),
o.register(173, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeFileCleared(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(174, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeFiles(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(175, { request: e, response: e, onrequest: (e) => t.api.core.getStats(...e) }),
o.register(176, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeProgress(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(177, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeSystemUpdateRequest(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(178, { request: e, response: e, onrequest: (e) => t.api.core.lookupUsername(...e) }),
o.register(179, {
request: e,
response: e,
onrequest: (e) => t.api.core.lookupUserByMemberId(...e),
}),
o.register(180, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeUsername(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(181, {
request: e,
response: e,
onrequest: (e) => t.api.core.registerUsername(...e),
}),
o.register(182, { request: e, response: e, onrequest: (e) => t.api.core.updateUsername(...e) }),
o.register(183, { request: e, response: e, onrequest: (e) => t.api.core.searchUsername(...e) }),
o.register(184, {
request: e,
response: e,
onrequest: (e) => t.api.core.getReservationsByKey(...e),
}),
o.register(185, { request: e, response: e, onrequest: (e) => t.api.core.checkUsername(...e) }),
o.register(186, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateRoomPreferences(...e),
}),
o.register(187, {
request: e,
response: e,
onrequest: (e) => t.api.core.getRoomPreferences(...e),
}),
o.register(188, { request: e, response: e, onrequest: (e) => t.api.core.audit(...e) }),
o.register(189, { request: e, response: e, onrequest: (e) => t.api.core.close(...e) }),
o.register(190, { request: e, response: e, onrequest: (e) => t.api.core.suspend(...e) }),
o.register(191, { request: e, response: e, onrequest: (e) => t.api.core.resume(...e) }),
o.register(192, { request: e, response: e, onrequest: (e) => t.api.core.getDebugFlags(...e) }),
o.register(193, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateDebugFlag(...e),
}),
o.register(194, { request: e, response: e, onrequest: (e) => t.api.core.repair(...e) }),
o.register(195, { request: e, response: e, onrequest: (e) => t.api.core.rotateWriter(...e) }),
o.register(196, { request: e, response: e, onrequest: (e) => t.api.core.getRoomStats(...e) }),
o.register(197, { request: e, response: e, onrequest: (e) => t.api.core.compact(...e) }),
o.register(198, { request: e, response: e, onrequest: (e) => t.api.core.setUnread(...e) }),
o.register(199, { request: e, response: e, onrequest: (e) => t.api.core.getUnread(...e) }),
o.register(200, {
request: e,
response: e,
onrequest: (e) => t.api.core.getUnreadAnchor(...e),
}),
o.register(201, {
request: e,
response: e,
onrequest: (e) => t.api.core.setUnreadAnchor(...e),
}),
o.register(202, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeUnreadAnchor(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(203, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeSentLength(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(204, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.createErrorStream(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(205, { request: e, response: e, onrequest: (e) => t.api.core.boot(...e) }),
o.register(206, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeErrors(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(207, {
request: e,
response: e,
onrequest: (e) => t.api.core.setCallRingingId(...e),
}),
o.register(208, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.core.subscribeNotifications(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(209, { request: e, response: e, onrequest: (e) => t.api.core.getDHTSettings(...e) }),
o.register(210, {
request: e,
response: e,
onrequest: (e) => t.api.core.updateDHTSettings(...e),
}),
o.register(211, {
request: e,
response: e,
onrequest: (e) => t.api.core.setRoomFavorite(...e),
}),
o.register(212, { request: e, response: e, onrequest: (e) => t.api.core.clearOldFiles(...e) }),
o.register(213, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.preferences.subscribe(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(214, { request: e, response: e, onrequest: (e) => t.api.preferences.update(...e) }),
o.register(215, { request: e, response: e, onrequest: (e) => t.api.preferences.query(...e) }),
o.register(216, { request: e, response: e, onrequest: (e) => t.api.call.authorize(...e) }),
o.register(217, { request: e, response: e, onrequest: (e) => t.api.call.deauthorize(...e) }),
o.register(218, { request: e, response: e, onrequest: (e) => t.api.call.joinPeer(...e) }),
o.register(219, { request: e, response: e, onrequest: (e) => t.api.call.leavePeer(...e) }),
o.register(220, { request: e, response: e, onrequest: (e) => t.api.call.requestTrack(...e) }),
o.register(221, { request: e, response: e, onrequest: (e) => t.api.call.unrequestTrack(...e) }),
o.register(222, { request: e, response: e, onrequest: (e) => t.api.call.signalMedia(...e) }),
o.register(223, {
request: e,
response: e,
onrequest: (e) => t.api.call.getRequestedTracks(...e),
}),
o.register(224, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.call.subscribeRequestedTracks(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(225, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.call.subscribeMediaSignals(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(226, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.call.subscribeProxyUpdates(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(227, { request: e, response: e, onrequest: (e) => t.api.call.shareTrack(...e) }),
o.register(228, { request: e, response: e, onrequest: (e) => t.api.call.unshareTrack(...e) }),
o.register(229, { request: e, response: e, onrequest: (e) => t.api.call.relayTrack(...e) }),
o.register(230, { request: e, response: e, onrequest: (e) => t.api.call.unrelayTrack(...e) }),
o.register(231, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.call.subscribeAvailableTracks(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(232, {
request: e,
response: e,
onrequest: (e) => t.api.call.getAvailableTracks(...e),
}),
o.register(233, { request: e, response: e, onrequest: (e) => t.api.call.setPresent(...e) }),
o.register(234, { request: e, response: e, onrequest: (e) => t.api.call.setNotPresent(...e) }),
o.register(235, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.call.subscribePresence(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(236, { request: e, response: e, onrequest: (e) => t.api.call.getPresence(...e) }),
o.register(237, { request: e, response: e, onrequest: (e) => t.api.tracing.start(...e) }),
o.register(238, {
request: e,
response: e,
onrequest: (e) => t.api.tracing.addFrontendTrace(...e),
}),
o.register(239, { request: e, response: e, onrequest: (e) => t.api.console.log(...e) }),
o.register(240, { request: e, response: e, onrequest: (e) => t.api.console.warn(...e) }),
o.register(241, { request: e, response: e, onrequest: (e) => t.api.console.error(...e) }),
o.register(242, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.network.subscribe(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(243, { request: e, response: e, onrequest: (e) => t.api.network.query(...e) }),
o.register(244, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.network.subscribeDebug(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(245, { request: e, response: e, onrequest: (e) => t.api.network.debug(...e) }),
o.register(246, {
request: e,
response: e,
dedup: !0,
onstream: async (e) => {
try {
for await (const o of e) {
const n = t.api.error.subscribe(...o)
r(n, e).on("error", s)
}
} catch (r) {
e.destroy(r)
}
},
}),
o.register(247, {
request: e,
response: e,
onrequest: (e) => t.api.debug.getCurrentRoomStats(...e),
}),
o.register(248, {
request: e,
response: e,
onrequest: (e) => t.api.debug.enableInspector(...e),
}),
o.register(249, {
request: e,
response: e,
onrequest: (e) => t.api.debug.disableInspector(...e),
}),
o.register(250, {
request: e,
response: e,
onrequest: (e) => t.api.debug.getInspectorKey(...e),
}),
o.register(251, { request: e, response: e, onrequest: (e) => t.api.debug.processTop(...e) }),
o.register(252, { request: e, response: e, onrequest: (e) => t.api.debug.heapSnapshot(...e) }),
o.register(253, { request: e, response: e, onrequest: (e) => t.api.debug.hash(...e) }),
o.register(254, {
request: e,
response: e,
onrequest: (e) => t.api.debug.generateSyntheticError(...e),
}),
o.register(255, { request: e, response: e, onrequest: (e) => t.api.debug.resetUnreads(...e) }),
o.register(256, { request: e, response: e, onrequest: (e) => t.api.pear.teardown(...e) }),
o.register(257, { request: e, response: e, onrequest: (e) => t.api.pear.selfDestruct(...e) }),
o.register(258, { request: e, response: e, onrequest: (e) => t.api.feedback.send(...e) }))
}