Add connectivity check before init-app (#104)

* add conn check

* (add) conncheck on info

update ci

update ci

temporarily mute macos test

Author: chh7872

.github/workflows/test.yml

@@ -40,13 +40,13 @@ jobs:
           args: zip -qq -r ./eup.zip lib scripts vscode package.json
 
       - name: Upload tarball
-        uses: actions/upload-artifact@v3
+        uses: actions/upload-artifact@v4
         with:
           name: ${{ steps.build.outputs.tarball }}
           path: ${{ steps.build.outputs.tarball }}
 
       - name: Upload EUP package
-        uses: actions/upload-artifact@v3
+        uses: actions/upload-artifact@v4
         with:
           name: eup.zip
           path: eup.zip
@@ -60,7 +60,7 @@ jobs:
 
     strategy:
       matrix:
-        os: [windows-latest, ubuntu-latest, macos-latest]
+        os: [windows-latest, ubuntu-latest]
         node: ['16']
 
     steps:
@@ -81,7 +81,7 @@ jobs:
         run: yarn --ignore-scripts --registry=https://registry-lpm.listenai.com
 
       - name: Download tarball
-        uses: actions/download-artifact@v3
+        uses: actions/download-artifact@v4
         with:
           name: ${{ needs.build.outputs.tarball }}
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@lisa-plugin/zephyr",
-  "version": "2.0.0",
+  "version": "2.1.0-beta.1",
   "description": "LISA plugin for Zephyr",
   "main": "./lib/main.js",
   "engines": {

src/main.ts

@@ -15,6 +15,7 @@ import AppProject from "./models/appProject";
 import { resolve, dirname } from "path";
 import * as Sentry from "@sentry/node";
 import { join } from "path";
+import { connCheck } from "./utils/connCheck";
 Sentry.init({
   dsn: "http://[email protected]/106",
   tracesSampleRate: 1.0,
@@ -70,6 +71,15 @@ export async function env(): Promise<Record<string, string>> {
     });
   }
 
+  try {
+    await connCheck();
+  } catch (e) {
+    const errmsg = (e as Error).message;
+    Object.assign(variables, {
+      res: redChar(errmsg)
+    });
+  }
+
   return {
     env: envShow,
     west: westShow,

src/tasks/project.ts

@@ -23,6 +23,7 @@ import {
 import {flashRun, IFlashOpts} from "../utils/flash";
 import {IImage} from "@tool/lpk/lib/manifest";
 import {toNumber} from "lodash";
+import { connCheck } from "../utils/connCheck";
 
 async function getAppFlashAddr(buildDir: string): Promise<number> {
   const hasLoadOffset = await getKconfig(buildDir, 'CONFIG_HAS_FLASH_LOAD_OFFSET');
@@ -106,6 +107,8 @@ export default ({ application, cmd, cli }: LisaType) => {
   job("init-app", {
     title: "初始化项目",
     async task(ctx, task) {
+      await connCheck(task);
+
       task.title = "";
       const targetDir = workspace() || process.cwd();
       const app = new AppProject(targetDir, task);
@@ -117,6 +120,8 @@ export default ({ application, cmd, cli }: LisaType) => {
   job("update", {
     title: "更新提货单projects",
     async task(ctx, task) {
+      await connCheck(task);
+
       task.title = "";
       const targetDir = workspace() || process.cwd();
       const app = new AppProject(targetDir, task);

src/utils/connCheck.ts

@@ -0,0 +1,60 @@
+import got, { Response } from 'got';
+
+interface ConnCheckRawResult {
+  url: string;
+  ok: boolean;
+}
+
+export async function connCheck(task?: any): Promise<void> {
+  // set proxy?
+  if (task) {
+    task.title = "正在检查网络状况...";
+  }
+
+  const urlBase: Record<string, string> = {
+    "https://cdn.iflyos.cn/public/cskTools/conntest.txt": "聆思资源服务",
+    "https://pypi.tuna.tsinghua.edu.cn/simple/numpy": "PyPI 软件仓库（TUNA 镜像站）",
+    "https://registry.npmmirror.com": "NPMMirror 镜像站"
+  };
+
+  const urls = Object.keys(urlBase);
+  const checkResult = await parallelHttpsCheck(urls);
+  const failedUrls = checkResult.filter(result => !result.ok);
+  if (failedUrls.length > 0) {
+    const failedItems = failedUrls.map(result => urlBase[result.url]).join(', ');
+    throw new Error(`资源访问失败，请检查网络连接是否正常。item = ${failedItems}`);
+  }
+}
+
+async function parallelHttpsCheck(urls: string[]): Promise<ConnCheckRawResult[]> {
+  const results = await Promise.allSettled(
+    urls.map(url =>
+      got(url, {
+        timeout: 3000,
+        headers: {
+          'User-Agent': 'Mozilla/5.0 (LISA zephyr plugin/2.1.0)'
+        },
+        throwHttpErrors: true
+      }).then((response: Response) => {
+        const status = response.statusCode;
+        return {
+          url,
+          ok: (status >= 200 && status < 310) || status === 401,
+        };
+      }).catch(() => ({
+        url,
+        ok: false
+      }))
+    )
+  );
+
+  return results.map(result => {
+    if (result.status === 'fulfilled') {
+      return result.value;
+    }
+    return {
+      url: urls[results.indexOf(result)],
+      ok: false,
+    };
+  });
+}