feat: add outbounds checks to diagnostics

fe-app-podkop/src/podkop/methods/shell/index.ts

@@ -29,15 +29,15 @@ export const PodkopShellMethods = {
       Podkop.AvailableClashAPIMethods.GET_PROXIES,
     ]),
   getClashApiProxyLatency: async (tag: string) =>
-    callBaseMethod<unknown>(Podkop.AvailableMethods.CLASH_API, [
-      Podkop.AvailableClashAPIMethods.GET_PROXY_LATENCY,
-      tag,
-    ]),
+    callBaseMethod<Podkop.GetClashApiProxyLatency>(
+      Podkop.AvailableMethods.CLASH_API,
+      [Podkop.AvailableClashAPIMethods.GET_PROXY_LATENCY, tag],
+    ),
   getClashApiGroupLatency: async (tag: string) =>
-    callBaseMethod<unknown>(Podkop.AvailableMethods.CLASH_API, [
-      Podkop.AvailableClashAPIMethods.GET_GROUP_LATENCY,
-      tag,
-    ]),
+    callBaseMethod<Podkop.GetClashApiGroupLatency>(
+      Podkop.AvailableMethods.CLASH_API,
+      [Podkop.AvailableClashAPIMethods.GET_GROUP_LATENCY, tag],
+    ),
   setClashApiGroupProxy: async (group: string, proxy: string) =>
     callBaseMethod<unknown>(Podkop.AvailableMethods.CLASH_API, [
       Podkop.AvailableClashAPIMethods.SET_GROUP_PROXY,

fe-app-podkop/src/podkop/tabs/diagnostic/checks/contstants.ts

@@ -5,6 +5,7 @@ export enum DIAGNOSTICS_CHECKS {
   SINGBOX = 'SINGBOX',
   NFT = 'NFT',
   FAKEIP = 'FAKEIP',
+  OUTBOUNDS = 'OUTBOUNDS',
 }
 
 export const DIAGNOSTICS_CHECKS_MAP: Record<
@@ -26,8 +27,13 @@ export const DIAGNOSTICS_CHECKS_MAP: Record<
     title: getCheckTitle('Nftables'),
     code: DIAGNOSTICS_CHECKS.NFT,
   },
-  [DIAGNOSTICS_CHECKS.FAKEIP]: {
+  [DIAGNOSTICS_CHECKS.OUTBOUNDS]: {
     order: 4,
+    title: getCheckTitle('Outbounds'),
+    code: DIAGNOSTICS_CHECKS.OUTBOUNDS,
+  },
+  [DIAGNOSTICS_CHECKS.FAKEIP]: {
+    order: 5,
     title: getCheckTitle('FakeIP'),
     code: DIAGNOSTICS_CHECKS.FAKEIP,
   },

fe-app-podkop/src/podkop/tabs/diagnostic/checks/runSectionsCheck.ts

@@ -0,0 +1,111 @@
+import { DIAGNOSTICS_CHECKS_MAP } from './contstants';
+import { PodkopShellMethods } from '../../../methods';
+import { updateCheckStore } from './updateCheckStore';
+import { getMeta } from '../helpers/getMeta';
+import { getDashboardSections } from '../../../methods/custom/getDashboardSections';
+import { IDiagnosticsChecksItem } from '../../../services';
+
+export async function runSectionsCheck() {
+  const { order, title, code } = DIAGNOSTICS_CHECKS_MAP.OUTBOUNDS;
+
+  updateCheckStore({
+    order,
+    code,
+    title,
+    description: _('Checking, please wait'),
+    state: 'loading',
+    items: [],
+  });
+
+  const sections = await getDashboardSections();
+
+  if (!sections.success) {
+    updateCheckStore({
+      order,
+      code,
+      title,
+      description: _('Cannot receive checks result'),
+      state: 'error',
+      items: [],
+    });
+
+    throw new Error('Sections checks failed');
+  }
+
+  const items = (await Promise.all(
+    sections.data.map(async (section) => {
+      async function getLatency() {
+        if (section.withTagSelect) {
+          const latencyGroup = await PodkopShellMethods.getClashApiGroupLatency(
+            section.code,
+          );
+          console.log('Latency group', latencyGroup);
+
+          const success = latencyGroup.success && !latencyGroup.data.message;
+
+          if (success) {
+            const latency = Object.values(latencyGroup.data)
+              .map((item) => (item ? `${item}ms` : 'n/a'))
+              .join(' / ');
+
+            return {
+              success: true,
+              latency,
+            };
+          }
+
+          return {
+            success: true,
+            latency: _('Not responding'),
+          };
+        }
+
+        const latencyProxy = await PodkopShellMethods.getClashApiProxyLatency(
+          section.code,
+        );
+        console.log('Latency proxy', latencyProxy);
+
+        const success = latencyProxy.success && !latencyProxy.data.message;
+
+        if (success) {
+          return {
+            success: true,
+            latency: `${latencyProxy.data.delay} ms`,
+          };
+        }
+
+        return {
+          success: false,
+          latency: _('Not responding'),
+        };
+      }
+
+      const { latency, success } = await getLatency();
+
+      return {
+        state: success ? 'success' : 'error',
+        key: section.displayName,
+        value: latency,
+      };
+    }),
+  )) as Array<IDiagnosticsChecksItem>;
+
+  const allGood = items.every((item) => item.state === 'success');
+
+  const atLeastOneGood = items.some((item) => item.state === 'success');
+
+  const { state, description } = getMeta({ atLeastOneGood, allGood });
+
+  updateCheckStore({
+    order,
+    code,
+    title,
+    description,
+    state,
+    items,
+  });
+
+  if (!atLeastOneGood) {
+    throw new Error('Sections checks failed');
+  }
+}

fe-app-podkop/src/podkop/tabs/diagnostic/diagnostic.store.ts

@@ -72,6 +72,14 @@ export const initialDiagnosticStore: Pick<
       items: [],
       state: 'skipped',
     },
+    {
+      code: DIAGNOSTICS_CHECKS.OUTBOUNDS,
+      title: DIAGNOSTICS_CHECKS_MAP.OUTBOUNDS.title,
+      order: DIAGNOSTICS_CHECKS_MAP.OUTBOUNDS.order,
+      description: _('Not running'),
+      items: [],
+      state: 'skipped',
+    },
     {
       code: DIAGNOSTICS_CHECKS.FAKEIP,
       title: DIAGNOSTICS_CHECKS_MAP.FAKEIP.title,
@@ -112,6 +120,14 @@ export const loadingDiagnosticsChecksStore: Pick<
       items: [],
       state: 'skipped',
     },
+    {
+      code: DIAGNOSTICS_CHECKS.OUTBOUNDS,
+      title: DIAGNOSTICS_CHECKS_MAP.OUTBOUNDS.title,
+      order: DIAGNOSTICS_CHECKS_MAP.OUTBOUNDS.order,
+      description: _('Pending'),
+      items: [],
+      state: 'skipped',
+    },
     {
       code: DIAGNOSTICS_CHECKS.FAKEIP,
       title: DIAGNOSTICS_CHECKS_MAP.FAKEIP.title,

fe-app-podkop/src/podkop/tabs/diagnostic/initController.ts

@@ -19,6 +19,7 @@ import { renderModal } from '../../../partials';
 import { PODKOP_LUCI_APP_VERSION } from '../../../constants';
 import { showToast } from '../../../helpers/showToast';
 import { renderWikiDisclaimer } from './partials/renderWikiDisclaimer';
+import { runSectionsCheck } from './checks/runSectionsCheck';
 
 async function fetchSystemInfo() {
   const systemInfo = await PodkopShellMethods.getSystemInfo();
@@ -518,6 +519,8 @@ async function runChecks() {
 
     await runNftCheck();
 
+    await runSectionsCheck();
+
     await runFakeIPCheck();
   } catch (e) {
     logger.error('[DIAGNOSTIC]', 'runChecks - e', e);

fe-app-podkop/src/podkop/types.ts

@@ -196,4 +196,11 @@ export namespace Podkop {
     openwrt_version: string;
     device_model: string;
   }
+
+  export interface GetClashApiProxyLatency {
+    delay: number;
+    message?: string;
+  }
+
+  export type GetClashApiGroupLatency = Record<string, number>;
 }