chore: format

Author: aminya

.github/workflows/bump_deps.yml

@@ -24,7 +24,6 @@ jobs:
           ncu -u --dep prod
           pnpm install
 
-
       - uses: tibdex/github-app-token@v1
         id: generate-token
         with:
@@ -38,7 +37,6 @@ jobs:
           labels: Dependencies
           branch: "Bump_Dependencies"
 
-
   Bump_devDependencies:
     runs-on: ubuntu-latest
     steps:

README.md

@@ -12,7 +12,7 @@ Python language support for [Atom-IDE](https://atom-ide-community.github.io), po
 
 ### Important
 
-Please note that `atom-ide-ui` is now deprecated, therefore, you must use the packages supplied from `atom-ide-community` as mentioned above. Links are also provided for more information.  
+Please note that `atom-ide-ui` is now deprecated, therefore, you must use the packages supplied from `atom-ide-community` as mentioned above. Links are also provided for more information.
 
 ## Feature Providers
 
@@ -62,12 +62,14 @@ apm install ide-python
 ```
 
 To use the debugger you need to install `atom-ide-debugger` and `atom-ide-console` as well:
+
 ```
 apm install atom-ide-debugger
 apm install atom-ide-console
 ```
 
 ### Debugger (experimental)
+
 After installation of the above packages:
 
 - Open the file you need to debug

lib/debugger/RemoteDebuggerCommandService.js

@@ -1,151 +1,147 @@
-import type {ConnectableObservable} from 'rxjs-compat/bundles/rxjs-compat.umd.min.js';
+import type { ConnectableObservable } from "rxjs-compat/bundles/rxjs-compat.umd.min.js"
 
-import http from 'http';
-import net from 'net';
-import {Observable, Subject} from 'rxjs-compat/bundles/rxjs-compat.umd.min.js';
-import {getLogger} from 'log4js';
-import {sleep} from '@atom-ide-community/nuclide-commons/promise';
+import http from "http"
+import net from "net"
+import { Observable, Subject } from "rxjs-compat/bundles/rxjs-compat.umd.min.js"
+import { getLogger } from "log4js"
+import { sleep } from "@atom-ide-community/nuclide-commons/promise"
 
-let isServerSetup = false;
+let isServerSetup = false
 
 export type RemoteDebugCommandRequest = {
-  type: 'python',
-  command: 'attach',
+  type: "python",
+  command: "attach",
   target: PythonDebuggerAttachTarget,
-};
+}
 
 export type PythonDebuggerAttachTarget = {
   port: number,
   localRoot: ?string,
   remoteRoot: ?string,
   debugOptions: ?Array<string>,
   id: ?string,
-};
+}
 
-const debugRequests: Subject<RemoteDebugCommandRequest> = new Subject();
-const attachReady: Map<number, PythonDebuggerAttachTarget> = new Map();
-const DEBUGGER_REGISTRY_PORT = 9615;
+const debugRequests: Subject<RemoteDebugCommandRequest> = new Subject()
+const attachReady: Map<number, PythonDebuggerAttachTarget> = new Map()
+const DEBUGGER_REGISTRY_PORT = 9615
 
-export function observeRemoteDebugCommands(): ConnectableObservable<
-  RemoteDebugCommandRequest,
-> {
-  let setupStep;
+export function observeRemoteDebugCommands(): ConnectableObservable<RemoteDebugCommandRequest> {
+  let setupStep
   if (!isServerSetup) {
-    setupStep = Observable.fromPromise(setupServer()).ignoreElements();
+    setupStep = Observable.fromPromise(setupServer()).ignoreElements()
   } else {
-    setupStep = Observable.empty();
+    setupStep = Observable.empty()
   }
-  return setupStep.concat(debugRequests).publish();
+  return setupStep.concat(debugRequests).publish()
 }
 
-export function observeAttachDebugTargets(): ConnectableObservable<
-  Array<PythonDebuggerAttachTarget>,
-> {
+export function observeAttachDebugTargets(): ConnectableObservable<Array<PythonDebuggerAttachTarget>> {
   // Validate attach-ready values with the processes with used ports (ready to attach).
   // Note: we can't use process ids because we could be debugging processes inside containers
   // where the process ids don't map to the host running this code.
   return Observable.interval(3000)
     .startWith(0)
     .switchMap(() =>
       Promise.all(
-        Array.from(attachReady.values()).map(async target => {
+        Array.from(attachReady.values()).map(async (target) => {
           if (!(await isPortUsed(target.port))) {
-            attachReady.delete(target.port);
+            attachReady.delete(target.port)
           }
-        }),
-      ),
+        })
+      )
     )
     .map(() => Array.from(attachReady.values()))
-    .publish();
+    .publish()
 }
 
 function isPortUsed(port: number): Promise<boolean> {
   const tryConnectPromise = new Promise((resolve, reject) => {
-    const client = new net.Socket();
+    const client = new net.Socket()
     client
-      .once('connect', () => {
-        cleanUp();
-        resolve(true);
+      .once("connect", () => {
+        cleanUp()
+        resolve(true)
+      })
+      .once("error", (err) => {
+        cleanUp()
+        resolve(err.code !== "ECONNREFUSED")
       })
-      .once('error', err => {
-        cleanUp();
-        resolve(err.code !== 'ECONNREFUSED');
-      });
 
     function cleanUp() {
-      client.removeAllListeners('connect');
-      client.removeAllListeners('error');
-      client.end();
-      client.destroy();
-      client.unref();
+      client.removeAllListeners("connect")
+      client.removeAllListeners("error")
+      client.end()
+      client.destroy()
+      client.unref()
     }
 
-    client.connect({port, host: '127.0.0.1'});
-  });
+    client.connect({ port, host: "127.0.0.1" })
+  })
   // Trying to connect can take multiple seconds, then times out (if the server is busy).
   // Hence, we need to fallback to `true`.
-  const connectTimeoutPromise = sleep(1000).then(() => true);
-  return Promise.race([tryConnectPromise, connectTimeoutPromise]);
+  const connectTimeoutPromise = sleep(1000).then(() => true)
+  return Promise.race([tryConnectPromise, connectTimeoutPromise])
 }
 
 function setupServer(): Promise<void> {
   return new Promise((resolve, reject) => {
     http
       .createServer((req, res) => {
-        if (req.method !== 'POST') {
-          res.writeHead(500, {'Content-Type': 'text/html'});
-          res.end('Invalid request');
+        if (req.method !== "POST") {
+          res.writeHead(500, { "Content-Type": "text/html" })
+          res.end("Invalid request")
         } else {
-          let body = '';
-          req.on('data', data => {
-            body += data;
-          });
-          req.on('end', () => {
-            handleJsonRequest(JSON.parse(body), res);
-          });
+          let body = ""
+          req.on("data", (data) => {
+            body += data
+          })
+          req.on("end", () => {
+            handleJsonRequest(JSON.parse(body), res)
+          })
         }
       })
-      .on('error', reject)
+      .on("error", reject)
       .listen((DEBUGGER_REGISTRY_PORT: any), () => {
-        isServerSetup = true;
-        resolve();
-      });
-  });
+        isServerSetup = true
+        resolve()
+      })
+  })
 }
 
 function handleJsonRequest(body, res) {
-  res.writeHead(200, {'Content-Type': 'application/json'});
-  const {domain, command, type} = body;
-  let success = false;
-  if (domain !== 'debug' || type !== 'python') {
-    res.end(JSON.stringify({success}));
-    return;
+  res.writeHead(200, { "Content-Type": "application/json" })
+  const { domain, command, type } = body
+  let success = false
+  if (domain !== "debug" || type !== "python") {
+    res.end(JSON.stringify({ success }))
+    return
   }
-  if (command === 'enable-attach') {
-    const port = Number(body.port);
-    const {options} = body;
+  if (command === "enable-attach") {
+    const port = Number(body.port)
+    const { options } = body
     const target = {
       port,
       id: options.id,
       localRoot: options.localRoot,
       remoteRoot: options.remoteRoot,
       debugOptions: options.debugOptions,
-    };
-    attachReady.set(port, target);
-    getLogger().info('Remote debug target is ready to attach', target);
-    success = true;
-  } else if (command === 'attach') {
-    const port = Number(body.port);
-    getLogger().info('Remote debug target attach request', body);
-    const target = attachReady.get(port);
+    }
+    attachReady.set(port, target)
+    getLogger().info("Remote debug target is ready to attach", target)
+    success = true
+  } else if (command === "attach") {
+    const port = Number(body.port)
+    getLogger().info("Remote debug target attach request", body)
+    const target = attachReady.get(port)
     if (target != null) {
       debugRequests.next({
         type,
         command,
         target,
-      });
-      success = true;
+      })
+      success = true
     }
   }
-  res.end(JSON.stringify({success}));
+  res.end(JSON.stringify({ success }))
 }