hendrik/lens
1
0
Fork 0
mirror of https://github.com/lensapp/lens.git synced 2025-05-20 05:10:56 +00:00
Code Issues Projects Releases Wiki Activity

pass clusterId query as param

Browse Source 
Signed-off-by: Jim Ehrismann <jehrismann@mirantis.com>
This commit is contained in:
Jim Ehrismann 2021-11-29 11:00:38 -05:00
parent 536e9bbd31
commit f49d3aeb6d
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/renderer/port-forward/port-forward.store.ts
View File

@ -112,7 +112,7 @@ export async function addPortForward(portForward: ForwardedPort): Promise<number
} }
} catch (error) { } catch (error) {
logger.warn("[PORT-FORWARD-STORE] Error adding port-forward:", error, portForward); logger.warn("[PORT-FORWARD-STORE] Error adding port-forward:", error, portForward);
throw(error); throw (error);
} }
portForwardStore.reset(); portForwardStore.reset();
@ -134,7 +134,7 @@ export async function getPortForward(portForward: ForwardedPort): Promise<number
response = await apiBase.get<PortForwardResult>(`/pods/port-forward/${portForward.namespace}/${portForward.kind}/${portForward.name}?port=${portForward.port}&forwardPort=${portForward.forwardPort}${getProtocolQuery(portForward.protocol)}`); response = await apiBase.get<PortForwardResult>(`/pods/port-forward/${portForward.namespace}/${portForward.kind}/${portForward.name}?port=${portForward.port}&forwardPort=${portForward.forwardPort}${getProtocolQuery(portForward.protocol)}`);
} catch (error) { } catch (error) {
logger.warn("[PORT-FORWARD-STORE] Error getting port-forward:", error, portForward); logger.warn("[PORT-FORWARD-STORE] Error getting port-forward:", error, portForward);
throw(error); throw (error);
} }
return response?.port; return response?.port;
@ -142,7 +142,7 @@ export async function getPortForward(portForward: ForwardedPort): Promise<number
export async function modifyPortForward(portForward: ForwardedPort, desiredPort: number): Promise<number> { export async function modifyPortForward(portForward: ForwardedPort, desiredPort: number): Promise<number> {
let port = 0; let port = 0;
await removePortForward(portForward); await removePortForward(portForward);
portForward.forwardPort = desiredPort; portForward.forwardPort = desiredPort;
port = await addPortForward(portForward); port = await addPortForward(portForward);
@ -159,20 +159,19 @@ export async function removePortForward(portForward: ForwardedPort) {
await waitUntilFree(+portForward.forwardPort, 200, 1000); await waitUntilFree(+portForward.forwardPort, 200, 1000);
} catch (error) { } catch (error) {
logger.warn("[PORT-FORWARD-STORE] Error removing port-forward:", error, portForward); logger.warn("[PORT-FORWARD-STORE] Error removing port-forward:", error, portForward);
throw(error); throw (error);
} }
portForwardStore.reset(); portForwardStore.reset();
} }
export async function getPortForwards(clusterId?: string): Promise<ForwardedPort[]> { export async function getPortForwards(clusterId?: string): Promise<ForwardedPort[]> {
try { try {
const query = clusterId ? `?clusterId=${clusterId}` : ""; const response = await apiBase.get<PortForwardsResult>("/pods/port-forwards", { query: { clusterId }});
const response = await apiBase.get<PortForwardsResult>(`/pods/port-forwards${query}`);
return response.portForwards; return response.portForwards;
} catch (error) { } catch (error) {
logger.warn("[PORT-FORWARD-STORE] Error getting all port-forwards:", error); logger.warn("[PORT-FORWARD-STORE] Error getting all port-forwards:", error);
return []; return [];
} }
} }