Consolidate LensProxy related stuff to directory

Co-authored-by: Mikko Aspiala <mikko.aspiala@gmail.com>

Signed-off-by: Janne Savolainen <janne.savolainen@live.fi>

src/main/__test__/lens-proxy.test.ts

@@ -3,7 +3,7 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 
-import { isLongRunningRequest } from "../lens-proxy";
+import { isLongRunningRequest } from "../lens-proxy/lens-proxy";
 
 describe("isLongRunningRequest", () => {
   it("returns true on watches", () => {

src/main/k8s-request.injectable.ts

@@ -7,7 +7,7 @@ import request from "request-promise-native";
 import { apiKubePrefix } from "../common/vars";
 import type { Cluster } from "../common/cluster/cluster";
 import { getInjectable } from "@ogre-tools/injectable";
-import lensProxyPortInjectable from "./lens-proxy-port.injectable";
+import lensProxyPortInjectable from "./lens-proxy/lens-proxy-port.injectable";
 
 export type K8sRequest = (cluster: Cluster, path: string, options?: RequestPromiseOptions) => Promise<any>;
 

src/main/kubeconfig-manager/create-kubeconfig-manager.injectable.ts

@@ -6,7 +6,7 @@ import { getInjectable } from "@ogre-tools/injectable";
 import type { Cluster } from "../../common/cluster/cluster";
 import directoryForTempInjectable from "../../common/app-paths/directory-for-temp/directory-for-temp.injectable";
 import { KubeconfigManager } from "./kubeconfig-manager";
-import lensProxyPortInjectable from "../lens-proxy-port.injectable";
+import lensProxyPortInjectable from "../lens-proxy/lens-proxy-port.injectable";
 
 export interface KubeConfigManagerInstantiationParameter {
   cluster: Cluster;

src/main/lens-proxy/lens-proxy.injectable.ts

@@ -5,9 +5,9 @@
 import { getInjectable } from "@ogre-tools/injectable";
 import { LensProxy } from "./lens-proxy";
 import { kubeApiUpgradeRequest } from "./proxy-functions";
-import routerInjectable from "./router/router.injectable";
+import routerInjectable from "../router/router.injectable";
 import httpProxy from "http-proxy";
-import clusterManagerInjectable from "./cluster-manager.injectable";
+import clusterManagerInjectable from "../cluster-manager.injectable";
 import shellApiRequestInjectable from "./proxy-functions/shell-api-request/shell-api-request.injectable";
 import lensProxyPortInjectable from "./lens-proxy-port.injectable";
 

src/main/lens-proxy/lens-proxy.ts

@@ -7,14 +7,14 @@ import net from "net";
 import type http from "http";
 import spdy from "spdy";
 import type httpProxy from "http-proxy";
-import { apiPrefix, apiKubePrefix } from "../common/vars";
-import type { Router } from "./router/router";
-import type { ContextHandler } from "./context-handler/context-handler";
-import logger from "./logger";
-import type { Cluster } from "../common/cluster/cluster";
+import { apiPrefix, apiKubePrefix } from "../../common/vars";
+import type { Router } from "../router/router";
+import type { ContextHandler } from "../context-handler/context-handler";
+import logger from "../logger";
+import type { Cluster } from "../../common/cluster/cluster";
 import type { ProxyApiRequestArgs } from "./proxy-functions";
-import { appEventBus } from "../common/app-event-bus/event-bus";
-import { getBoolean } from "./utils/parse-query";
+import { appEventBus } from "../../common/app-event-bus/event-bus";
+import { getBoolean } from "../utils/parse-query";
 
 type GetClusterForRequest = (req: http.IncomingMessage) => Cluster | null;
 

src/main/lens-proxy/proxy-functions/kube-api-upgrade-request.ts

@@ -6,7 +6,7 @@
 import { chunk } from "lodash";
 import tls from "tls";
 import url from "url";
-import { apiKubePrefix } from "../../common/vars";
+import { apiKubePrefix } from "../../../common/vars";
 import type { ProxyApiRequestArgs } from "./types";
 
 const skipRawHeaders = new Set(["Host", "Authorization"]);
@@ -16,8 +16,8 @@ export async function kubeApiUpgradeRequest({ req, socket, head, cluster }: Prox
   const proxyCa = await cluster.contextHandler.resolveAuthProxyCa();
   const apiUrl = url.parse(cluster.apiUrl);
   const pUrl = url.parse(proxyUrl);
-  const connectOpts = { 
-    port: parseInt(pUrl.port), 
+  const connectOpts = {
+    port: parseInt(pUrl.port),
     host: pUrl.hostname,
     ca: proxyCa,
   };

src/main/lens-proxy/proxy-functions/shell-api-request/shell-api-request.injectable.ts

@@ -4,9 +4,9 @@
  */
 import { getInjectable } from "@ogre-tools/injectable";
 import { shellApiRequest } from "./shell-api-request";
-import createShellSessionInjectable from "../../shell-session/create-shell-session.injectable";
+import createShellSessionInjectable from "../../../shell-session/create-shell-session.injectable";
 import shellRequestAuthenticatorInjectable from "./shell-request-authenticator/shell-request-authenticator.injectable";
-import clusterManagerInjectable from "../../cluster-manager.injectable";
+import clusterManagerInjectable from "../../../cluster-manager.injectable";
 
 const shellApiRequestInjectable = getInjectable({
   id: "shell-api-request",

src/main/lens-proxy/proxy-functions/shell-api-request/shell-api-request.ts

@@ -3,14 +3,14 @@
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
 
-import logger from "../../logger";
+import logger from "../../../logger";
 import type WebSocket from "ws";
 import { Server as WebSocketServer } from "ws";
 import type { ProxyApiRequestArgs } from "../types";
-import type { ClusterManager } from "../../cluster-manager";
+import type { ClusterManager } from "../../../cluster-manager";
 import URLParse from "url-parse";
-import type { Cluster } from "../../../common/cluster/cluster";
-import type { ClusterId } from "../../../common/cluster-types";
+import type { Cluster } from "../../../../common/cluster/cluster";
+import type { ClusterId } from "../../../../common/cluster-types";
 
 interface Dependencies {
   authenticateRequest: (clusterId: ClusterId, tabId: string, shellToken: string) => boolean;

src/main/lens-proxy/proxy-functions/shell-api-request/shell-request-authenticator/shell-request-authenticator.ts

@@ -2,9 +2,9 @@
  * Copyright (c) OpenLens Authors. All rights reserved.
  * Licensed under MIT License. See LICENSE in root directory for more information.
  */
-import { getOrInsertMap } from "../../../../common/utils";
-import type { ClusterId } from "../../../../common/cluster-types";
-import { ipcMainHandle } from "../../../../common/ipc";
+import { getOrInsertMap } from "../../../../../common/utils";
+import type { ClusterId } from "../../../../../common/cluster-types";
+import { ipcMainHandle } from "../../../../../common/ipc";
 import crypto from "crypto";
 import { promisify } from "util";
 

src/main/lens-proxy/proxy-functions/types.ts

@@ -5,7 +5,7 @@
 
 import type http from "http";
 import type net from "net";
-import type { Cluster } from "../../common/cluster/cluster";
+import type { Cluster } from "../../../common/cluster/cluster";
 
 export interface ProxyApiRequestArgs {
   req: http.IncomingMessage;

src/main/start-main-application/lens-window/application-window/application-window.injectable.ts

@@ -5,7 +5,7 @@
 import { getInjectable } from "@ogre-tools/injectable";
 import { lensWindowInjectionToken } from "./lens-window-injection-token";
 import createLensWindowInjectable from "./create-lens-window.injectable";
-import lensProxyPortInjectable from "../../../lens-proxy-port.injectable";
+import lensProxyPortInjectable from "../../../lens-proxy/lens-proxy-port.injectable";
 import isMacInjectable from "../../../../common/vars/is-mac.injectable";
 import appNameInjectable from "../../../app-paths/app-name/app-name.injectable";
 import appEventBusInjectable from "../../../../common/app-event-bus/app-event-bus.injectable";

src/main/start-main-application/runnables/setup-lens-proxy.injectable.ts

@@ -5,9 +5,9 @@
 import { getInjectable } from "@ogre-tools/injectable";
 import { getAppVersion, getAppVersionFromProxyServer } from "../../../common/utils";
 import exitAppInjectable from "../../electron-app/features/exit-app.injectable";
-import lensProxyInjectable from "../../lens-proxy.injectable";
+import lensProxyInjectable from "../../lens-proxy/lens-proxy.injectable";
 import loggerInjectable from "../../../common/logger.injectable";
-import lensProxyPortInjectable from "../../lens-proxy-port.injectable";
+import lensProxyPortInjectable from "../../lens-proxy/lens-proxy-port.injectable";
 import isWindowsInjectable from "../../../common/vars/is-windows.injectable";
 import showErrorPopupInjectable from "../../electron-app/features/show-error-popup.injectable";
 import { beforeApplicationIsLoadingInjectionToken } from "../runnable-tokens/before-application-is-loading-injection-token";