add io and remove adapter

feat: add publish workflow

feat: 添加queryclient

fix: 修改路径

feat: 添加手动执行workflows

fix: 修改package.json

fix: fix publish

fix: publish test

fix

temp

.github/workflow/publish.yml

@@ -1,35 +0,0 @@
-name: Publish to npm
-on:
-  push:
-    tags:
-      - 'v*.*.*'   # 当推送带有版本号的 tag 时触发，例如 v1.0.0
-
-jobs:
-  publish:
-    runs-on: ubuntu-latest
-    steps:
-      # Step 1: Clone current Git repository
-      - name: Checkout this repository
-        uses: actions/checkout@v3
-      # Setop 2: list files in current directory
-      - name: List files in current directory
-        run: ls -al
-      # Step 3: Setup Node.js and install dependencies
-      - name: Setup Node.js
-        uses: actions/setup-node@v2
-        with:
-          node-version: '20.6'
-          registry-url: 'https://registry.npmjs.org/'
-      - name: npm whoami
-        run: |
-          npm whoami
-          echo "//registry.npmjs.org/:_authToken=${{ secrets.NPM_TOKEN }}" > .npmrc
-      # Step 4: Install dependencies
-      - name: Install dependencies
-        run: npm install
-      # Step 5: Publish to npm
-      - name: Publish package
-        run: npm publish
-        env:
-          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}  # 使用 GitHub Secrets 来安全存储 npm token
-          NPM_TOKEN: ${{ secrets.NPM_TOKEN }}  # 使用 GitHub Secrets 来安全存储 npm token

.github/workflows/publish.yml

@@ -0,0 +1,38 @@
+name: Publish to npm
+on:
+  push:
+    tags:
+      - 'v*.*.*'   # 当推送带有版本号的 tag 时触发，例如 v1.0.0
+  workflow_dispatch:   # 添加手动触发器
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    steps:
+      # Step 1: Clone current Git repository
+      - name: Checkout this repository
+        uses: actions/checkout@v3
+      # Step 3: Setup Node.js and install dependencies
+      - name: Setup Node.js
+        uses: actions/setup-node@v3
+        with:
+          node-version: '20.6'
+          registry-url: 'https://registry.npmjs.org/'
+          cache: 'npm'         # 启用 npm 缓存，提高安装速度
+      - name: Configure npm authentication
+        run: npm config set //registry.npmjs.org/:_authToken=${{ secrets.NPM_TOKEN }}
+      - name: Install dependencies
+        run: npm install
+      - name: Build project
+        run: npm run build
+      # Step 6: 发布到 npm
+      - name: Publish package
+        run: npm publish
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}
+      # Step 7: 发布成功后，更新版本标签
+      # - name: Create Git tag
+      #   run: |
+      #     TAG="v$(node -p -e "require('./package.json').version")"
+      #     git tag $TAG
+      #     git push origin $TAG

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@kevisual/query",
-  "version": "0.0.5",
+  "version": "0.0.7-alpha.1",
   "main": "dist/index.js",
   "module": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -14,8 +14,11 @@
   "files": [
     "dist"
   ],
-  "keywords": [],
-  "author": "",
+  "keywords": [
+    "kevisual",
+    "query"
+  ],
+  "author": "abearxiong",
   "license": "ISC",
   "description": "",
   "devDependencies": {
@@ -31,6 +34,10 @@
   "publishConfig": {
     "access": "public"
   },
+  "repository": {
+    "type": "git",
+    "url": "git+ssh://git@github.com/abearxiong/kevisual-query.git"
+  },
   "exports": {
     ".": {
       "import": "./dist/index.js",

rollup.config.js

@@ -18,23 +18,24 @@ export default [
       typescript({
         allowImportingTsExtensions: true,
         noEmit: true,
+        exclude: ['src/node-adapter.ts'],
       }), // 使用 @rollup/plugin-typescript 处理 TypeScript 文件
     ],
   },
-  {
-    input: 'src/node-adapter.ts', // TypeScript 入口文件
-    output: {
-      file: 'dist/node-adapter.js', // 输出文件
-      format: 'es', // 输出格式设置为 ES 模块
-    },
-    plugins: [
-      resolve(), // 使用 @rollup/plugin-node-resolve 解析 node_modules 中的模块
-      typescript({
-        allowImportingTsExtensions: true,
-        noEmit: true,
-      }), // 使用 @rollup/plugin-typescript 处理 TypeScript 文件
-    ],
-  },
+  // {
+  //   input: 'src/node-adapter.ts', // TypeScript 入口文件
+  //   output: {
+  //     file: 'dist/node-adapter.js', // 输出文件
+  //     format: 'es', // 输出格式设置为 ES 模块
+  //   },
+  //   plugins: [
+  //     resolve(), // 使用 @rollup/plugin-node-resolve 解析 node_modules 中的模块
+  //     typescript({
+  //       allowImportingTsExtensions: true,
+  //       noEmit: true,
+  //     }), // 使用 @rollup/plugin-typescript 处理 TypeScript 文件
+  //   ],
+  // },
   {
     input: 'src/ws.ts', // TypeScript 入口文件
     output: {
@@ -46,6 +47,7 @@ export default [
       typescript({
         allowImportingTsExtensions: true,
         noEmit: true,
+        declaration: false,
       }), // 使用 @rollup/plugin-typescript 处理 TypeScript 文件
     ],
   },

src/index.ts

@@ -1,6 +1,6 @@
 import { adapter } from './adapter.ts';
-import { QueryWs } from './ws.ts';
-export { QueryOpts };
+import { QueryWs, QueryWsOpts } from './ws.ts';
+export { QueryOpts, QueryWs };
 type Fn = (opts: {
   url?: string;
   headers?: Record<string, string>;
@@ -64,6 +64,7 @@ export class Query<U = any, V = any> {
     const headers = { ...this.headers, ...options?.headers };
     const adapter = options?.adapter || this.adapter;
     const beforeRequest = options?.beforeRequest || this.beforeRequest;
+    const afterResponse = options?.afterResponse || this.afterResponse;
     const timeout = options?.timeout || this.timeout;
     const req = {
       url: url,
@@ -76,8 +77,8 @@ export class Query<U = any, V = any> {
     }
     return adapter(req).then(async (res) => {
       res.success = res.code === 200;
-      if (options?.afterResponse) {
-        return await options.afterResponse(res);
+      if (afterResponse) {
+        return await afterResponse(res);
       }
       return res;
     });
@@ -97,7 +98,7 @@ export class QueryClient<U = any, V = any> extends Query<U, V> {
   storage: Storage;
   token: string;
   qws: QueryWs;
-  constructor(opts?: QueryOpts & { tokenName?: string; storage?: Storage }) {
+  constructor(opts?: QueryOpts & { tokenName?: string; storage?: Storage; io?: boolean }) {
     super(opts);
     this.tokenName = opts?.tokenName || 'token';
     this.storage = opts?.storage || localStorage;
@@ -111,7 +112,12 @@ export class QueryClient<U = any, V = any> extends Query<U, V> {
       }
       return opts;
     };
-    this.qws = new QueryWs({ url: opts?.url });
+    if (opts?.io) {
+      this.createWs();
+    }
+  }
+  createWs(opts?: QueryWsOpts) {
+    this.qws = new QueryWs({ url: this.url });
   }
   getToken() {
     return this.storage.getItem(this.tokenName);

src/ws.ts

@@ -9,7 +9,7 @@ type QueryWsStore = {
 };
 export type QuerySelectState = 'connecting' | 'connected' | 'disconnected';
 export type QueryWsStoreListener = (newState: QueryWsStore, oldState: QueryWsStore) => void;
-type QueryWsOpts = {
+export type QueryWsOpts = {
   url?: string;
   store?: StoreApi<QueryWsStore>;
   ws?: WebSocket;
@@ -45,22 +45,31 @@ export class QueryWs {
   /**
    * 连接 WebSocket
    */
-  connect() {
+  async connect(opts?: { timeout?: number }) {
     const store = this.store;
     const connected = store.getState().connected;
     if (connected) {
-      return;
+      return Promise.resolve(true);
     }
-    const ws = this.ws || new WebSocket(this.url);
-    ws.onopen = () => {
-      store.getState().setConnected(true);
-      store.getState().setStatus('connected');
-    };
-    ws.onclose = () => {
-      store.getState().setConnected(false);
-      store.getState().setStatus('disconnected');
-      this.ws = null;
-    };
+    return new Promise((resolve, reject) => {
+      const ws = this.ws || new WebSocket(this.url);
+      const timeout = opts?.timeout || 5 * 60 * 1000; // 默认 2 分钟
+      let timer = setTimeout(() => {
+        console.error('WebSocket 连接超时');
+        reject('timeout');
+      }, timeout);
+      ws.onopen = () => {
+        store.getState().setConnected(true);
+        store.getState().setStatus('connected');
+        resolve(true);
+        clearTimeout(timer);
+      };
+      ws.onclose = () => {
+        store.getState().setConnected(false);
+        store.getState().setStatus('disconnected');
+        this.ws = null;
+      };
+    });
   }
 
   listenConnect(callback: () => void) {
@@ -141,4 +150,10 @@ export class QueryWs {
       ws.send(data as string);
     }
   }
+  getOpen() {
+    if (!this.ws) {
+      return false;
+    }
+    return this.ws.readyState === WebSocket.OPEN;
+  }
 }