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,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.searchPublicRooms(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(43,{request:e,response:e,onrequest:e=>t.api.core.getRecentRooms(...e)}),o.register(44,{request:e,response:e,onrequest:e=>t.api.core.getLocalRoomMetadata(...e)}),o.register(45,{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(46,{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(47,{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(48,{request:e,response:e,onrequest:e=>t.api.core.setRoomUnread(...e)}),o.register(49,{request:e,response:e,onrequest:e=>t.api.core.bumpRoomPriority(...e)}),o.register(50,{request:e,response:e,onrequest:e=>t.api.core.snoozeRoom(...e)}),o.register(51,{request:e,response:e,onrequest:e=>t.api.core.addDevice(...e)}),o.register(52,{request:e,response:e,onrequest:e=>t.api.core.removeDevice(...e)}),o.register(53,{request:e,response:e,onrequest:e=>t.api.core.getDevice(...e)}),o.register(54,{request:e,response:e,onrequest:e=>t.api.core.getDevices(...e)}),o.register(55,{request:e,response:e,onrequest:e=>t.api.core.getDevicesByMemberId(...e)}),o.register(56,{request:e,response:e,onrequest:e=>t.api.core.getCurrentDeviceId(...e)}),o.register(57,{request:e,response:e,onrequest:e=>t.api.core.moveIndexer(...e)}),o.register(58,{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(59,{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(60,{request:e,response:e,onrequest:e=>t.api.core.createIdentityInvitation(...e)}),o.register(61,{request:e,response:e,onrequest:e=>t.api.core.createInvitation(...e)}),o.register(62,{request:e,response:e,onrequest:e=>t.api.core.updateMember(...e)}),o.register(63,{request:e,response:e,onrequest:e=>t.api.core.isMemberMuted(...e)}),o.register(64,{request:e,response:e,onrequest:e=>t.api.core.getMember(...e)}),o.register(65,{request:e,response:e,onrequest:e=>t.api.core.removeMember(...e)}),o.register(66,{request:e,response:e,onrequest:e=>t.api.core.getMembers(...e)}),o.register(67,{request:e,response:e,onrequest:e=>t.api.core.getActiveMembers(...e)}),o.register(68,{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(69,{request:e,response:e,onrequest:e=>t.api.core.getModerators(...e)}),o.register(70,{request:e,response:e,onrequest:e=>t.api.core.getMemberCount(...e)}),o.register(71,{request:e,response:e,onrequest:e=>t.api.core.getMemberForDevice(...e)}),o.register(72,{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(73,{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(74,{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(75,{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(76,{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(77,{request:e,response:e,onrequest:e=>t.api.core.changeMemberRole(...e)}),o.register(78,{request:e,response:e,onrequest:e=>t.api.core.muteMember(...e)}),o.register(79,{request:e,response:e,onrequest:e=>t.api.core.unmuteMember(...e)}),o.register(80,{request:e,response:e,onrequest:e=>t.api.core.getSearchMembers(...e)}),o.register(81,{request:e,response:e,onrequest:e=>t.api.core.getPushNotificationMembers(...e)}),o.register(82,{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(83,{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(84,{request:e,response:e,onrequest:e=>t.api.core.addContact(...e)}),o.register(85,{request:e,response:e,onrequest:e=>t.api.core.setContactAlias(...e)}),o.register(86,{request:e,response:e,onrequest:e=>t.api.core.removeContact(...e)}),o.register(87,{request:e,response:e,onrequest:e=>t.api.core.getActiveContacts(...e)}),o.register(88,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.subscribeActiveContacts(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(89,{request:e,response:e,onrequest:e=>t.api.core.getContactInfo(...e)}),o.register(90,{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(91,{request:e,response:e,onrequest:e=>t.api.core.getSelfContactInfo(...e)}),o.register(92,{request:e,response:e,onrequest:e=>t.api.core.blockMember(...e)}),o.register(93,{request:e,response:e,onrequest:e=>t.api.core.unblockMember(...e)}),o.register(94,{request:e,response:e,onrequest:e=>t.api.core.getBlockedMembers(...e)}),o.register(95,{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(96,{request:e,response:e,onrequest:e=>t.api.core.getConnectedMembers(...e)}),o.register(97,{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(98,{request:e,response:e,onrequest:e=>t.api.core.updateConfig(...e)}),o.register(99,{request:e,response:e,onrequest:e=>t.api.core.getConfig(...e)}),o.register(100,{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(101,{request:e,response:e,onrequest:e=>t.api.core.updateRoomSettings(...e)}),o.register(102,{request:e,response:e,onrequest:e=>t.api.core.disableMembershipEvents(...e)}),o.register(103,{request:e,response:e,onrequest:e=>t.api.core.enableMembershipEvents(...e)}),o.register(104,{request:e,response:e,onrequest:e=>t.api.core.addChatMessage(...e)}),o.register(105,{request:e,response:e,onrequest:e=>t.api.core.updateChatMessage(...e)}),o.register(106,{request:e,response:e,onrequest:e=>t.api.core.addFilePreview(...e)}),o.register(107,{request:e,response:e,onrequest:e=>t.api.core.removeFilePreview(...e)}),o.register(108,{request:e,response:e,onrequest:e=>t.api.core.addLinkPreview(...e)}),o.register(109,{request:e,response:e,onrequest:e=>t.api.core.removeLinkPreview(...e)}),o.register(110,{request:e,response:e,onrequest:e=>t.api.core.removeChatMessage(...e)}),o.register(111,{request:e,response:e,onrequest:e=>t.api.core.forwardChatMessage(...e)}),o.register(112,{request:e,response:e,onrequest:e=>t.api.core.pinChatMessage(...e)}),o.register(113,{request:e,response:e,onrequest:e=>t.api.core.unpinChatMessage(...e)}),o.register(114,{request:e,response:e,onrequest:e=>t.api.core.startCall(...e)}),o.register(115,{request:e,response:e,onrequest:e=>t.api.core.joinCall(...e)}),o.register(116,{request:e,response:e,onrequest:e=>t.api.core.leaveCall(...e)}),o.register(117,{request:e,response:e,onrequest:e=>t.api.core.endCall(...e)}),o.register(118,{request:e,response:e,onrequest:e=>t.api.core.addCallStream(...e)}),o.register(119,{request:e,response:e,onrequest:e=>t.api.core.removeCallStream(...e)}),o.register(120,{request:e,response:e,onrequest:e=>t.api.core.updateCallStream(...e)}),o.register(121,{request:e,response:e,onrequest:e=>t.api.core.startCallRecording(...e)}),o.register(122,{request:e,response:e,onrequest:e=>t.api.core.stopCallRecording(...e)}),o.register(123,{request:e,response:e,onrequest:e=>t.api.core.getActiveCalls(...e)}),o.register(124,{request:e,response:e,onrequest:e=>t.api.core.getAllActiveCalls(...e)}),o.register(125,{request:e,response:e,onrequest:e=>t.api.core.getCalls(...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.subscribeActiveCalls(...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.subscribeAllActiveCalls(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(128,{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(129,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.subscribeCallProxy(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(130,{request:e,response:e,onrequest:e=>t.api.core.signalCallPeer(...e)}),o.register(131,{request:e,response:e,onrequest:e=>t.api.core.addCallStartedEvent(...e)}),o.register(132,{request:e,response:e,onrequest:e=>t.api.core.addCallHangupEvent(...e)}),o.register(133,{request:e,response:e,onrequest:e=>t.api.core.addCallMissedEvent(...e)}),o.register(134,{request:e,response:e,onrequest:e=>t.api.core.addLocationSharedEvent(...e)}),o.register(135,{request:e,response:e,onrequest:e=>t.api.core.addRoomAvatarChangedEvent(...e)}),o.register(136,{request:e,response:e,onrequest:e=>t.api.core.addEvent(...e)}),o.register(137,{request:e,response:e,onrequest:e=>t.api.core.removeEvent(...e)}),o.register(138,{request:e,response:e,onrequest:e=>t.api.core.getChatMessage(...e)}),o.register(139,{request:e,response:e,onrequest:e=>t.api.core.getChatMessageById(...e)}),o.register(140,{request:e,response:e,onrequest:e=>t.api.core.getChatMessages(...e)}),o.register(141,{request:e,response:e,onrequest:e=>t.api.core.getPinnedChatMessages(...e)}),o.register(142,{request:e,response:e,onrequest:e=>t.api.core.getChatLength(...e)}),o.register(143,{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(144,{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(145,{request:e,response:e,onrequest:e=>t.api.core.searchChatMessages(...e)}),o.register(146,{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(147,{request:e,response:e,onrequest:e=>t.api.core.sendDMFromContact(...e)}),o.register(148,{request:e,response:e,onrequest:e=>t.api.core.sendDMRequest(...e)}),o.register(149,{request:e,response:e,onrequest:e=>t.api.core.sendInvitations(...e)}),o.register(150,{request:e,response:e,onrequest:e=>t.api.core.updatePrivateMailboxRecord(...e)}),o.register(151,{request:e,response:e,onrequest:e=>t.api.core.getPrivateMailboxRecords(...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.subscribePrivateMailbox(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(153,{request:e,response:e,onrequest:e=>t.api.core.getSentPrivateMailboxRecords(...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.subscribeSentPrivateMailbox(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(155,{request:e,response:e,onrequest:e=>t.api.core.getDmByMemberId(...e)}),o.register(156,{request:e,response:e,onrequest:e=>t.api.core.getDmRequestsByStatus(...e)}),o.register(157,{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(158,{request:e,response:e,onrequest:e=>t.api.core.acceptDmRequest(...e)}),o.register(159,{request:e,response:e,onrequest:e=>t.api.core.rejectDmRequest(...e)}),o.register(160,{request:e,response:e,onrequest:e=>t.api.core.addReaction(...e)}),o.register(161,{request:e,response:e,onrequest:e=>t.api.core.removeReaction(...e)}),o.register(162,{request:e,response:e,onrequest:e=>t.api.core.getLatestReactions(...e)}),o.register(163,{request:e,response:e,onrequest:e=>t.api.core.getReactions(...e)}),o.register(164,{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(165,{request:e,response:e,onrequest:e=>t.api.core.addChatReport(...e)}),o.register(166,{request:e,response:e,onrequest:e=>t.api.core.removeChatReport(...e)}),o.register(167,{request:e,response:e,onrequest:e=>t.api.core.dismissChatReports(...e)}),o.register(168,{request:e,response:e,onrequest:e=>t.api.core.reportMember(...e)}),o.register(169,{request:e,response:e,onrequest:e=>t.api.core.getReportedMembers(...e)}),o.register(170,{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(171,{request:e,response:e,onrequest:e=>t.api.core.getReportedMessages(...e)}),o.register(172,{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(173,{request:e,response:e,onrequest:e=>t.api.core.addFileBlob(...e)}),o.register(174,{request:e,response:e,onrequest:e=>t.api.core.addFile(...e)}),o.register(175,{request:e,response:e,onrequest:e=>t.api.core.saveFileBlob(...e)}),o.register(176,{request:e,response:e,onrequest:e=>t.api.core.saveFile(...e)}),o.register(177,{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(178,{request:e,response:e,onrequest:e=>t.api.core.sendFile(...e)}),o.register(179,{request:e,response:e,onrequest:e=>t.api.core.removeFile(...e)}),o.register(180,{request:e,response:e,onrequest:e=>t.api.core.refreshFileLinks(...e)}),o.register(181,{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(182,{request:e,response:e,onrequest:e=>t.api.core.clearAllFiles(...e)}),o.register(183,{request:e,response:e,onrequest:e=>t.api.core.getFileEntry(...e)}),o.register(184,{request:e,response:e,onrequest:e=>t.api.core.getLocalFiles(...e)}),o.register(185,{request:e,response:e,onrequest:e=>t.api.core.getFiles(...e)}),o.register(186,{request:e,response:e,onrequest:e=>t.api.core.startDownload(...e)}),o.register(187,{request:e,response:e,onrequest:e=>t.api.core.cancelDownload(...e)}),o.register(188,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.readFileStream(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(189,{request:e,response:e,onrequest:e=>t.api.core.saveToDisk(...e)}),o.register(190,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.subscribeSaveToDisk(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(191,{request:e,response:e,onrequest:e=>t.api.core.clearFile(...e)}),o.register(192,{request:e,response:e,onrequest:e=>t.api.core.unclearFile(...e)}),o.register(193,{request:e,response:e,onrequest:e=>t.api.core.getFileCleared(...e)}),o.register(194,{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(195,{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(196,{request:e,response:e,onrequest:e=>t.api.core.getStats(...e)}),o.register(197,{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(198,{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(199,{request:e,response:e,onrequest:e=>t.api.core.lookupUsername(...e)}),o.register(200,{request:e,response:e,onrequest:e=>t.api.core.lookupUserByMemberId(...e)}),o.register(201,{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(202,{request:e,response:e,onrequest:e=>t.api.core.registerUsername(...e)}),o.register(203,{request:e,response:e,onrequest:e=>t.api.core.updateUsername(...e)}),o.register(204,{request:e,response:e,onrequest:e=>t.api.core.searchUsername(...e)}),o.register(205,{request:e,response:e,onrequest:e=>t.api.core.getReservationsByKey(...e)}),o.register(206,{request:e,response:e,onrequest:e=>t.api.core.checkUsername(...e)}),o.register(207,{request:e,response:e,onrequest:e=>t.api.core.updateRoomPreferences(...e)}),o.register(208,{request:e,response:e,onrequest:e=>t.api.core.getRoomPreferences(...e)}),o.register(209,{request:e,response:e,onrequest:e=>t.api.core.audit(...e)}),o.register(210,{request:e,response:e,onrequest:e=>t.api.core.autobeeLogs(...e)}),o.register(211,{request:e,response:e,onrequest:e=>t.api.core.close(...e)}),o.register(212,{request:e,response:e,onrequest:e=>t.api.core.suspend(...e)}),o.register(213,{request:e,response:e,onrequest:e=>t.api.core.resume(...e)}),o.register(214,{request:e,response:e,onrequest:e=>t.api.core.getDebugFlags(...e)}),o.register(215,{request:e,response:e,onrequest:e=>t.api.core.updateDebugFlag(...e)}),o.register(216,{request:e,response:e,onrequest:e=>t.api.core.repair(...e)}),o.register(217,{request:e,response:e,onrequest:e=>t.api.core.rotateWriter(...e)}),o.register(218,{request:e,response:e,onrequest:e=>t.api.core.getRoomStats(...e)}),o.register(219,{request:e,response:e,onrequest:e=>t.api.core.compact(...e)}),o.register(220,{request:e,response:e,onrequest:e=>t.api.core.setUnread(...e)}),o.register(221,{request:e,response:e,onrequest:e=>t.api.core.getUnread(...e)}),o.register(222,{request:e,response:e,onrequest:e=>t.api.core.getUnreadAnchor(...e)}),o.register(223,{request:e,response:e,onrequest:e=>t.api.core.setUnreadAnchor(...e)}),o.register(224,{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(225,{request:e,response:e,onrequest:e=>t.api.core.getUnreadRooms(...e)}),o.register(226,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.subscribeUnreadRooms(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(227,{request:e,response:e,onrequest:e=>t.api.core.updateTypingIndicator(...e)}),o.register(228,{request:e,response:e,onrequest:e=>t.api.core.getTypingIndicator(...e)}),o.register(229,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.core.subscribeTypingIndicator(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(230,{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(231,{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(232,{request:e,response:e,onrequest:e=>t.api.core.boot(...e)}),o.register(233,{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(234,{request:e,response:e,onrequest:e=>t.api.core.setCallRingingId(...e)}),o.register(235,{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(236,{request:e,response:e,onrequest:e=>t.api.core.getDHTSettings(...e)}),o.register(237,{request:e,response:e,onrequest:e=>t.api.core.updateDHTSettings(...e)}),o.register(238,{request:e,response:e,onrequest:e=>t.api.core.getSwarmSettings(...e)}),o.register(239,{request:e,response:e,onrequest:e=>t.api.core.updateSwarmSettings(...e)}),o.register(240,{request:e,response:e,onrequest:e=>t.api.core.setRoomFavorite(...e)}),o.register(241,{request:e,response:e,onrequest:e=>t.api.core.clearOldFiles(...e)}),o.register(242,{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(243,{request:e,response:e,onrequest:e=>t.api.preferences.update(...e)}),o.register(244,{request:e,response:e,onrequest:e=>t.api.preferences.query(...e)}),o.register(245,{request:e,response:e,onrequest:e=>t.api.call.authorize(...e)}),o.register(246,{request:e,response:e,onrequest:e=>t.api.call.deauthorize(...e)}),o.register(247,{request:e,response:e,onrequest:e=>t.api.call.joinPeer(...e)}),o.register(248,{request:e,response:e,onrequest:e=>t.api.call.leavePeer(...e)}),o.register(249,{request:e,response:e,onrequest:e=>t.api.call.requestTrack(...e)}),o.register(250,{request:e,response:e,onrequest:e=>t.api.call.unrequestTrack(...e)}),o.register(251,{request:e,response:e,onrequest:e=>t.api.call.signalMedia(...e)}),o.register(252,{request:e,response:e,onrequest:e=>t.api.call.getRequestedTracks(...e)}),o.register(253,{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(254,{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(255,{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(256,{request:e,response:e,onrequest:e=>t.api.call.shareTrack(...e)}),o.register(257,{request:e,response:e,onrequest:e=>t.api.call.unshareTrack(...e)}),o.register(258,{request:e,response:e,onrequest:e=>t.api.call.relayTrack(...e)}),o.register(259,{request:e,response:e,onrequest:e=>t.api.call.unrelayTrack(...e)}),o.register(260,{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(261,{request:e,response:e,onrequest:e=>t.api.call.getAvailableTracks(...e)}),o.register(262,{request:e,response:e,onrequest:e=>t.api.call.setPresent(...e)}),o.register(263,{request:e,response:e,onrequest:e=>t.api.call.setNotPresent(...e)}),o.register(264,{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(265,{request:e,response:e,onrequest:e=>t.api.call.getPresence(...e)}),o.register(266,{request:e,response:e,onrequest:e=>t.api.tracing.start(...e)}),o.register(267,{request:e,response:e,onrequest:e=>t.api.tracing.addFrontendTrace(...e)}),o.register(268,{request:e,response:e,onrequest:e=>t.api.console.log(...e)}),o.register(269,{request:e,response:e,onrequest:e=>t.api.console.warn(...e)}),o.register(270,{request:e,response:e,onrequest:e=>t.api.console.error(...e)}),o.register(271,{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(272,{request:e,response:e,onrequest:e=>t.api.network.query(...e)}),o.register(273,{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(274,{request:e,response:e,onrequest:e=>t.api.network.debug(...e)}),o.register(275,{request:e,response:e,onrequest:e=>t.api.network.setBluetoothEnabled(...e)}),o.register(276,{request:e,response:e,onrequest:e=>t.api.network.setNearbyContactInfo(...e)}),o.register(277,{request:e,response:e,onrequest:e=>t.api.network.clearNearbyContactInfo(...e)}),o.register(278,{request:e,response:e,onrequest:e=>t.api.network.getNearbyContactInfos(...e)}),o.register(279,{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(280,{request:e,response:e,onrequest:e=>t.api.debug.getCurrentRoomStats(...e)}),o.register(281,{request:e,response:e,onrequest:e=>t.api.debug.enableInspector(...e)}),o.register(282,{request:e,response:e,onrequest:e=>t.api.debug.disableInspector(...e)}),o.register(283,{request:e,response:e,onrequest:e=>t.api.debug.getInspectorKey(...e)}),o.register(284,{request:e,response:e,onrequest:e=>t.api.debug.processTop(...e)}),o.register(285,{request:e,response:e,onrequest:e=>t.api.debug.heapSnapshot(...e)}),o.register(286,{request:e,response:e,onrequest:e=>t.api.debug.hash(...e)}),o.register(287,{request:e,response:e,onrequest:e=>t.api.debug.generateSyntheticError(...e)}),o.register(288,{request:e,response:e,onrequest:e=>t.api.debug.resetUnreads(...e)}),o.register(289,{request:e,response:e,onrequest:e=>t.api.debug.getAccumulatedBytes(...e)}),o.register(290,{request:e,response:e,onrequest:e=>t.api.pear.teardown(...e)}),o.register(291,{request:e,response:e,onrequest:e=>t.api.pear.selfDestruct(...e)}),o.register(292,{request:e,response:e,onrequest:e=>t.api.feedback.send(...e)}),o.register(293,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.callNetwork.subscribe(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(294,{request:e,response:e,onrequest:e=>t.api.callNetwork.query(...e)}),o.register(295,{request:e,response:e,dedup:!0,onstream:async e=>{try{for await(const o of e){const n=t.api.callNetwork.subscribeDebug(...o);r(n,e).on("error",s)}}catch(r){e.destroy(r)}}}),o.register(296,{request:e,response:e,onrequest:e=>t.api.callNetwork.debug(...e)})};