style(reactive-rpc): 💄 run Prettier

Author: streamich

src/__tests__/reactive-rpc/uws/ws/rx-rpc/RpcPersistentClient.spec.ts

@@ -59,8 +59,7 @@ if (process.env.TEST_E2E) {
         channel: {
           newChannel: () =>
             new WebSocketChannel({
-              newSocket: () =>
-                new WebSocket(url, [protocolSpecifier]) as any,
+              newSocket: () => new WebSocket(url, [protocolSpecifier]) as any,
             }),
         },
       });

src/reactive-rpc/common/rpc/RpcMessageStreamProcessor.ts

@@ -242,7 +242,7 @@ export class RpcMessageStreamProcessor<Ctx = unknown> {
   public onNotificationMessage(message: msg.NotificationMessage, ctx: Ctx): void {
     const {method, value} = message;
     if (!method || method.length > 128) throw RpcError.fromCode(RpcErrorCodes.INVALID_METHOD);
-    const request = value && (typeof value === 'object') ? value?.data : undefined;
+    const request = value && typeof value === 'object' ? value?.data : undefined;
     this.caller.notification(method, request, ctx).catch((error: unknown) => {});
   }
 }

src/reactive-rpc/server/context.ts

@@ -13,9 +13,11 @@ const CODECS_REGEX = /rpc.(\w{0,32})\.(\w{0,32})\.(\w{0,32})(?:\-(\w{0,32}))?/;
 
 export class ConnectionContext<Meta = Record<string, unknown>> {
   private static findIp(req: HttpRequest, res: HttpResponse): string {
-    return req.getHeader('x-forwarded-for') ||
+    return (
+      req.getHeader('x-forwarded-for') ||
       req.getHeader('x-real-ip') ||
-      Buffer.from(res.getRemoteAddressAsText()).toString();
+      Buffer.from(res.getRemoteAddressAsText()).toString()
+    );
   }
 
   private static findToken(req: HttpRequest, params: string[] | null): string {