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

Create new abort controller

Browse Source 
Signed-off-by: Hung-Han (Henry) Chen <chenhungh@gmail.com>
This commit is contained in:
Hung-Han (Henry) Chen 2021-11-22 17:20:27 +02:00
parent 183ab0ea46
commit b7e982c5b2
No known key found for this signature in database
GPG Key ID: 54B44603D251B788
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/common/k8s-api/kube-api.ts
View File

@ -587,20 +587,37 @@ export class KubeApi<T extends KubeObject> {
}
electron.powerMonitor.once("suspend", () => {
logger.info(`[KUBE-API] system suspended, abort watching of ${watchUrl}...`);
try {
if (opts.abortController) {
opts.abortController.abort?.();
} else {
abort?.();
}
} catch (error) {
logger.error(`[KUBE-API] error aborting watch (${watchId})`, error);
}
electron.powerMonitor.once("resume", () => {
const url = "k8slens.dev"; // url to check if domain names are resolvable.
this.whenCanResolveDomainName(url, { retries: 50, maxTimeout: 3000 }).then(() => {
logger.info(`[KUBE-API] domain name can be resolved, checking networkOnline:${this.networkOnline.toString?.()}`);
let abortController = opts.abortController;
if (opts.abortController.signal.aborted) {
abortController = new AbortController();
}
if (this.networkOnline) {
logger.info(`[KUBE-API] system resumed, resume watching of ${watchUrl}...`);
this.watch({ ...opts, namespace, callback, watchId, retry: true });
this.watch({ ...opts, abortController, namespace, callback, watchId, retry: true });
} else {
logger.info(`[KUBE-API] system resumed but network appears to be offline, resume watching when online.`);
electron.ipcMain.once("network:online", () => {
logger.info(`[KUBE-API] network on line, resume watching of ${watchUrl}...`);
this.watch({ ...opts, namespace, callback, watchId, retry: true });
this.watch({ ...opts, abortController, namespace, callback, watchId, retry: true });
});
}
}).catch((error) => {