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/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.3",
+  "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": [],
+  "keywords": [
-  "author": "",
+    "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 入口文件
+  //   input: 'src/node-adapter.ts', // TypeScript 入口文件
-    output: {
+  //   output: {
-      file: 'dist/node-adapter.js', // 输出文件
+  //     file: 'dist/node-adapter.js', // 输出文件
-      format: 'es', // 输出格式设置为 ES 模块
+  //     format: 'es', // 输出格式设置为 ES 模块
-    },
+  //   },
-    plugins: [
+  //   plugins: [
-      resolve(), // 使用 @rollup/plugin-node-resolve 解析 node_modules 中的模块
+  //     resolve(), // 使用 @rollup/plugin-node-resolve 解析 node_modules 中的模块
-      typescript({
+  //     typescript({
-        allowImportingTsExtensions: true,
+  //       allowImportingTsExtensions: true,
-        noEmit: true,
+  //       noEmit: true,
-      }), // 使用 @rollup/plugin-typescript 处理 TypeScript 文件
+  //     }), // 使用 @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,5 +1,6 @@
 import { adapter } from './adapter.ts';
-export {QueryWs} from './ws.ts'
+import { QueryWs, QueryWsOpts } from './ws.ts';
+export { QueryOpts, QueryWs };
 type Fn = (opts: {
   url?: string;
   headers?: Record<string, string>;
@@ -37,8 +38,10 @@ type DataOpts = Partial<QueryOpts> & {
  *   path: 'demo',
  *   key: '1',
  *  });
+ *
+ * U是参数 V是返回值
  */
-export class Query {
+export class Query<U = any, V = any> {
   adapter: typeof adapter;
   url: string;
   beforeRequest?: Fn;
@@ -53,14 +56,15 @@ export class Query {
     };
     this.timeout = opts?.timeout || 60000; // 默认超时时间为 60s
   }
-  async get<T, S>(params: Record<string, any> & Data & T, options?: DataOpts): Promise<Result<S>> {
+  async get<T = any, S = any>(params: Record<string, any> & Data & U & T, options?: DataOpts): Promise<Result<V & S>> {
     return this.post(params, options);
   }
-  async post<T, S>(body: Record<string, any> & Data & T, options?: DataOpts): Promise<Result<S>> {
+  async post<T = any, S = any>(body: Record<string, any> & Data & T, options?: DataOpts): Promise<Result<S>> {
     const url = options?.url || this.url;
     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,
@@ -73,8 +77,8 @@ export class Query {
     }
     return adapter(req).then(async (res) => {
       res.success = res.code === 200;
-      if (options?.afterResponse) {
+      if (afterResponse) {
-        return await options.afterResponse(res);
+        return await afterResponse(res);
       }
       return res;
     });
@@ -86,5 +90,44 @@ export class Query {
     this.afterResponse = fn;
   }
 }
+/**
+ * 前端调用后端QueryRouter
+ */
+export class QueryClient<U = any, V = any> extends Query<U, V> {
+  tokenName: string;
+  storage: Storage;
+  token: string;
+  qws: QueryWs;
+  constructor(opts?: QueryOpts & { tokenName?: string; storage?: Storage; io?: boolean }) {
+    super(opts);
+    this.tokenName = opts?.tokenName || 'token';
+    this.storage = opts?.storage || localStorage;
+    this.beforeRequest = async (opts) => {
+      const token = this.token || this.getToken();
+      if (token) {
+        opts.headers = {
+          ...opts.headers,
+          Authorization: `Bearer ${token}`,
+        };
+      }
+      return opts;
+    };
+    if (opts?.io) {
+      this.createWs();
+    }
+  }
+  createWs(opts?: QueryWsOpts) {
+    this.qws = new QueryWs({ url: this.url });
+  }
+  getToken() {
+    return this.storage.getItem(this.tokenName);
+  }
+  saveToken(token: string) {
+    this.storage.setItem(this.tokenName, token);
+  }
+  removeToken() {
+    this.storage.removeItem(this.tokenName);
+  }
+}
 
 export { adapter };

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,21 +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);
+    return new Promise((resolve, reject) => {
-    ws.onopen = () => {
+      const ws = this.ws || new WebSocket(this.url);
-      store.getState().setConnected(true);
+      const timeout = opts?.timeout || 5 * 60 * 1000; // 默认 2 分钟
-      store.getState().setStatus('connected');
+      let timer = setTimeout(() => {
-    };
+        console.error('WebSocket 连接超时');
-    ws.onclose = () => {
+        reject('timeout');
-      store.getState().setConnected(false);
+      }, timeout);
-      this.ws = null;
+      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) {
@@ -140,4 +150,10 @@ export class QueryWs {
       ws.send(data as string);
     }
   }
+  getOpen() {
+    if (!this.ws) {
+      return false;
+    }
+    return this.ws.readyState === WebSocket.OPEN;
+  }
 }