Skip to content
This repository has been archived by the owner on May 29, 2023. It is now read-only.

Commit

Permalink
chore: fix syntax annotation warnings (#62)
Browse files Browse the repository at this point in the history
  • Loading branch information
0xJuancito authored Jun 2, 2022
1 parent 64a9c28 commit 7e2d570
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/controllers/rpc/comms.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import { RpcServerModule } from '@dcl/rpc/dist/codegen'
import { RpcContext, Subscription } from '../../types'
import { RpcContext } from '../../types'
import { CommsServiceDefinition } from '../bff-proto/comms-service'

export const topicRegex = /^[^\.]+(\.[^\.]+)*$/
Expand Down Expand Up @@ -86,7 +86,7 @@ export const commsModule: RpcServerModule<CommsServiceDefinition, RpcContext> =

return { subscriptionId }
},
async *getPeerMessages({ subscriptionId }, { components, peer }) {
async *getPeerMessages({ subscriptionId }, { peer }) {
if (!peer) {
throw new Error('Trying to get messages for a peer that has not been registered')
}
Expand All @@ -102,7 +102,7 @@ export const commsModule: RpcServerModule<CommsServiceDefinition, RpcContext> =
yield { payload: message.data, topic, sender }
}
},
async *getSystemMessages({ subscriptionId }, { components, peer }) {
async *getSystemMessages({ subscriptionId }, { peer }) {
if (!peer) {
throw new Error('Trying to get messages for a peer that has not been registered')
}
Expand All @@ -116,7 +116,7 @@ export const commsModule: RpcServerModule<CommsServiceDefinition, RpcContext> =
yield { payload: message.data, topic }
}
},
async unsubscribeToPeerMessages({ subscriptionId }, { components, peer }) {
async unsubscribeToPeerMessages({ subscriptionId }, { peer }) {
if (!peer) {
throw new Error('Trying to unsubscribe from a peer that has not been registered')
}
Expand All @@ -128,7 +128,7 @@ export const commsModule: RpcServerModule<CommsServiceDefinition, RpcContext> =

return { ok: true }
},
async unsubscribeToSystemMessages({ subscriptionId }, { components, peer }) {
async unsubscribeToSystemMessages({ subscriptionId }, { peer }) {
if (!peer) {
throw new Error('Trying to unsubscribe from a peer that has not been registered')
}
Expand Down

0 comments on commit 7e2d570

Please sign in to comment.