style(reactive-rpc): 💄 run Prettier

Author: streamich

src/reactive-rpc/server/http1/Http1Server.ts

@@ -135,7 +135,19 @@ export class Http1Server implements Printable {
       const codecs = this.codecs;
       const ip = this.findIp(req);
       const token = this.findToken(req);
-      const ctx = new Http1ConnectionContext(req, res, path, query, ip, token, match.params, new NullObject(), codecs.value.json, codecs.value.json, codecs.messages.compact);
+      const ctx = new Http1ConnectionContext(
+        req,
+        res,
+        path,
+        query,
+        ip,
+        token,
+        match.params,
+        new NullObject(),
+        codecs.value.json,
+        codecs.value.json,
+        codecs.messages.compact,
+      );
       const headers = req.headers;
       const contentType = headers['content-type'];
       if (typeof contentType === 'string') ctx.setCodecs(contentType, codecs);
@@ -180,12 +192,7 @@ export class Http1Server implements Printable {
 
   public findIp(req: http.IncomingMessage): string {
     const headers = req.headers;
-    const ip = (
-      headers['x-forwarded-for'] ||
-      headers['x-real-ip'] ||
-      req.socket.remoteAddress ||
-      ''
-    );
+    const ip = headers['x-forwarded-for'] || headers['x-real-ip'] || req.socket.remoteAddress || '';
     return ip instanceof Array ? ip[0] : ip;
   }
 
@@ -236,9 +243,12 @@ export class Http1Server implements Printable {
   // ---------------------------------------------------------------- Printable
 
   public toString(tab: string = ''): string {
-    return `${this.constructor.name}` + printTree(tab, [
-      (tab) => `HTTP ${this.httpRouter.toString(tab)}`,
-      (tab) => `WebSocket ${this.wsRouter.toString(tab)}`,
-    ]);
+    return (
+      `${this.constructor.name}` +
+      printTree(tab, [
+        (tab) => `HTTP ${this.httpRouter.toString(tab)}`,
+        (tab) => `WebSocket ${this.wsRouter.toString(tab)}`,
+      ])
+    );
   }
 }

src/reactive-rpc/server/http1/RpcServer.ts

@@ -52,8 +52,8 @@ export class RpcServer implements Printable {
   public readonly http1: Http1Server;
   protected readonly batchProcessor: RpcMessageBatchProcessor<ConnectionContext>;
 
-  constructor (protected readonly opts: RpcServerOpts) {
-    const http1 = this.http1 = opts.http1;
+  constructor(protected readonly opts: RpcServerOpts) {
+    const http1 = (this.http1 = opts.http1);
     const onInternalError = http1.oninternalerror;
     http1.oninternalerror = (error, res, req) => {
       if (error instanceof RpcError) {
@@ -116,8 +116,6 @@ export class RpcServer implements Printable {
   // ---------------------------------------------------------------- Printable
 
   public toString(tab: string = ''): string {
-    return `${this.constructor.name}` + printTree(tab, [
-      (tab) => `HTTP/1.1 ${this.http1.toString(tab)}`,
-    ]);
+    return `${this.constructor.name}` + printTree(tab, [(tab) => `HTTP/1.1 ${this.http1.toString(tab)}`]);
   }
 }

src/reactive-rpc/server/ws/codec/WsFrameEncoder.ts

@@ -85,10 +85,10 @@ export class WsFrameEncoder<W extends IWriter & IWriterGrowable = IWriter & IWri
     const writer = this.writer;
     if (length < 126) {
       const octet2 = maskBit | length;
-      writer.u16((octet1 << 8) | octet2);  
+      writer.u16((octet1 << 8) | octet2);
     } else if (length < 0x10000) {
       const octet2 = maskBit | 126;
-      writer.u32((((octet1 << 8) | octet2) * 0x10000) + length);
+      writer.u32(((octet1 << 8) | octet2) * 0x10000 + length);
     } else {
       const octet2 = maskBit | 127;
       writer.u16((octet1 << 8) | octet2);

src/reactive-rpc/server/ws/codec/__tests__/encoder.spec.ts

@@ -90,7 +90,6 @@ describe('control frames', () => {
   });
 });
 
-
 describe('data frames', () => {
   test('can encode an empty BINARY data frame', () => {
     const encoder = new WsFrameEncoder();
@@ -139,7 +138,7 @@ describe('data frames', () => {
     const data2 = decoder.reader.buf(frame.length);
     expect(data2).toEqual(data);
   });
-  
+
   describe('can encode different message sizes', () => {
     const sizes = [0, 1, 2, 125, 126, 127, 128, 129, 255, 1234, 65535, 65536, 65537, 7777777, 2 ** 31 - 1];
     const encoder = new WsFrameEncoder();

src/reactive-rpc/server/ws/server/WsServerConnection.ts

@@ -23,11 +23,7 @@ export class WsServerConnection {
   public onpong: (data: Uint8Array | null) => void = () => {};
   public onclose: (code: number, reason: string) => void = () => {};
 
-  constructor(
-    protected readonly encoder: WsFrameEncoder,
-    public readonly socket: net.Socket,
-    head: Buffer,
-  ) {
+  constructor(protected readonly encoder: WsFrameEncoder, public readonly socket: net.Socket, head: Buffer) {
     const decoder = new WsFrameDecoder();
     if (head.length) decoder.push(head);
     let currentFrame: WsFrameHeader | null = null;
@@ -95,11 +91,14 @@ export class WsServerConnection {
   public upgrade(secWebSocketKey: string, secWebSocketProtocol: string, secWebSocketExtensions: string): void {
     const accept = secWebSocketKey + '258EAFA5-E914-47DA-95CA-C5AB0DC85B11';
     const acceptSha1 = crypto.createHash('sha1').update(accept).digest('base64');
-    this.socket.write('HTTP/1.1 101 Switching Protocols\r\n' +
-      'Upgrade: websocket\r\n' +
-      'Connection: Upgrade\r\n' +
-      'Sec-WebSocket-Accept: ' + acceptSha1 + '\r\n' +
-      '\r\n'
+    this.socket.write(
+      'HTTP/1.1 101 Switching Protocols\r\n' +
+        'Upgrade: websocket\r\n' +
+        'Connection: Upgrade\r\n' +
+        'Sec-WebSocket-Accept: ' +
+        acceptSha1 +
+        '\r\n' +
+        '\r\n',
     );
   }