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