fix: 优化 c++ bindings 的析构函数和生命周期管理 (#2)

* refactor: 项目重构为 ts, 优化 js 侧状态管理,新增队列对实例状态更新进行处理, 优化 build 脚本

* fix: build.sh 支持 macos

* fix: 单测优化

* cd: Bump version from 1.0.5 to 1.1.0

* feat: 单测重构为ts, 使用 vitest, 解决队列中的竞态问题

* fix: filename typo

* fix: 优化 c++ bindings 的析构函数和生命周期管理

* style: add ESLint and Prettier configuration files

- Add .eslintrc.js with TypeScript support and comprehensive linting rules
- Configure ESLint to enforce code style including indentation, quotes, and semicolons
- Add .prettierrc with formatting standards for consistent code formatting
- Set print width to 120 characters and use 2-space indentation
- Establish consistent code style across the TypeScript project to improve code quality and maintainability

* chore: bump version from 1.1.0 to 1.1.1

- Update package.json version to 1.1.1
- Prepare release with bug fixes and improvements from recent commits

* fix: exmaple

* fix: 解决潜在死锁风险

* chore: eslint 配置更新

* fix: 抽象 common_utils, 修复了线程安全问题以及内存泄漏风险

* fix: 解决 producer send 的潜在内存泄露问题

* fix: ProducerSendCallback 构造函数内存泄漏问题，ConsumerMessageListener 内存管理

* fix: C++ bindings 新增 utils，抽象日志等公共处理, ts 状态处理与 C++ 保持一致

Author: JimmyDaddy

.prettierrc

@@ -0,0 +1,11 @@
+{
+  "semi": true,
+  "trailingComma": "none",
+  "singleQuote": true,
+  "printWidth": 120,
+  "tabWidth": 2,
+  "useTabs": false,
+  "bracketSpacing": true,
+  "arrowParens": "avoid",
+  "endOfLine": "lf"
+}

AGENTS.md

@@ -0,0 +1,84 @@
+# AI 编码助手项目指令
+
+> **语言要求**: 始终使用中文回复
+
+---
+
+## 🔴 强制规则 (MUST)
+
+以下规则必须严格遵守，违反任何一条都是不可接受的：
+
+
+### 代码质量检查
+编码任务完成前，**必须按顺序执行以下检查**：
+1. TypeScript 检查必须通过
+2. Lint 检查必须通过
+3. 单元测试必须全部通过
+4. Code Review 必须完成
+
+### 单元测试要求
+- **服务端代码必须编写单测**
+- **单测覆盖率必须达到 100%**
+- **禁止 skip 任何测试用例**
+- **必须使用终端工具实际运行单测** - 不能假装运行
+
+---
+
+## 📋 命令参考
+
+### TypeScript 检查
+
+## TIPS
+- ts check
+```shell
+npm run build:ts
+```
+
+### Lint 检查
+```shell
+# TypeScript/JavaScript 文件
+npm run lint
+
+```
+
+### 单元测试
+```shell
+## 可以有选择执行，对 lib 下的  C++ 文件进行编译
+./build.sh local
+## 然后执行
+npm run test <文件路径>
+```
+
+
+## ⚡ 执行流程
+
+完成编码任务的标准流程：
+
+```
+1. 理解需求
+   ↓
+2. 编写/修改代码
+   ↓
+3. 运行 TypeScript 检查
+   ↓
+4. 运行 Lint 检查
+   ↓
+5. 编写单测 (如需要)
+   ↓
+6. 运行单测并等待完成
+   ↓
+7. Code Review
+   ↓
+8. 如有问题，返回步骤 2 修复
+   ↓
+9. 完成
+```
+
+---
+
+## ⏳ 单测执行注意事项
+
+- 单测启动和执行需要较长时间，**耐心等待**
+- 如支持后台进程读取，可使用 Background process 异步等待
+- **绝对禁止使用 sleep 命令等待**
+

eslint.config.js

@@ -0,0 +1,73 @@
+const js = require('@eslint/js');
+const tseslint = require('@typescript-eslint/eslint-plugin');
+const tsparser = require('@typescript-eslint/parser');
+
+module.exports = [
+  // Base configuration for all files
+  js.configs.recommended,
+  
+  // TypeScript files configuration
+  {
+    files: ['**/*.ts', '**/*.tsx'],
+    languageOptions: {
+      parser: tsparser,
+      parserOptions: {
+        ecmaVersion: 2020,
+        sourceType: 'module',
+      },
+      globals: {
+        console: 'readonly',
+        process: 'readonly',
+        Buffer: 'readonly',
+        __dirname: 'readonly',
+        __filename: 'readonly',
+        module: 'readonly',
+        require: 'readonly',
+        exports: 'readonly',
+        global: 'readonly',
+        setTimeout: 'readonly',
+        setInterval: 'readonly',
+        clearTimeout: 'readonly',
+        clearInterval: 'readonly',
+        NodeJS: 'readonly',
+      },
+    },
+    plugins: {
+      '@typescript-eslint': tseslint,
+    },
+    rules: {
+      // Disable problematic rules for this project
+      '@typescript-eslint/no-unused-vars': 'off',
+      '@typescript-eslint/no-explicit-any': 'off',
+      '@typescript-eslint/explicit-function-return-type': 'off',
+      '@typescript-eslint/explicit-module-boundary-types': 'off',
+      '@typescript-eslint/no-non-null-assertion': 'off',
+      'no-unused-vars': 'off',
+      'no-undef': 'off',
+      'no-redeclare': 'off',
+      'no-constant-condition': 'off',
+      
+      // Keep essential rules
+      'no-console': 'off',
+      'prefer-const': 'error',
+      'no-var': 'error',
+      'semi': ['error', 'always'],
+      'quotes': ['error', 'single'],
+      'eol-last': 'error',
+    },
+  },
+  
+  // Ignore patterns
+  {
+    ignores: [
+      'dist/',
+      'build/',
+      'node_modules/',
+      'deps/',
+      'Release/',
+      'coverage/',
+      '*.js',
+      'test/',
+    ],
+  },
+];

example/common.js

@@ -0,0 +1,5 @@
+export const config = {
+  nameServer: '127.0.0.1:9876'
+  // nameServer: 'onsaddr.cn-hangzhou.mq.aliyuncs.com:80'
+  // nameServer: 'v0-default-<instanceId>.mq.cloudrun.local:9515'
+};

example/common.ts

@@ -0,0 +1,58 @@
+import * as readline from 'readline';
+import { config } from './common';
+import { Producer } from '../src';
+
+if (typeof (Promise as any).withResolvers === 'undefined') {
+  (Promise as any).withResolvers = function () {
+    let resolve: ((value?: any) => void) | null = null;
+    let reject: ((reason?: any) => void) | null = null;
+    const promise = new Promise((res, rej) => {
+      resolve = res;
+      reject = rej;
+    });
+    return { promise, resolve, reject };
+  };
+}
+
+const rl = readline.createInterface({
+  input: process.stdin,
+  output: process.stdout
+});
+
+void async function () {
+  const producer = new Producer('GID_GROUP', {
+    nameServer: config.nameServer
+  });
+
+  // producer.setSessionCredentials('accessKey', 'secretKey', 'ALIYUN')
+
+  await producer.start();
+
+  while(1) {
+    const { promise, resolve, reject } = (Promise as any).withResolvers();
+    rl.question('Enter input: ', async (input: string) => {
+      await producer.send('TP_TOPIC', input).catch(reject);
+      resolve();
+    });
+    await promise;
+  }
+
+  // producer.start(async function() {
+  //     console.log('producer started');
+  //     while(1) {
+  //         const { promise, resolve, reject } = Promise.withResolvers()
+  //         rl.question('Enter input: ', input => {
+  //             producer.send('TP_TOPIC', input, function(err, ret) {
+  //                 if (err) {
+  //                     console.error(err);
+  //                     reject(err)
+  //                 }
+  //                 console.log(ret);
+  //                 resolve(ret)
+  //             });
+  //         });
+  //         await promise.catch(console.error);
+  //     }
+  // });
+
+}();

example/producer.js

@@ -0,0 +1,20 @@
+import { config } from './common';
+import { PushConsumer, Message, ConsumerAck } from '../src';
+
+void function () {
+  const consumer = new PushConsumer('GID_GROUP', {
+    nameServer: config.nameServer
+  });
+
+  // consumer.setSessionCredentials('accessKey', 'secretKey', 'ALIYUN');
+
+  consumer.subscribe('TP_TOPIC', '*');
+  consumer.on('message', function(msg: Message, ack: ConsumerAck) {
+    console.log(msg);
+    ack.done(true);
+  });
+
+  consumer.start(function() {
+    console.log('consumer started');
+  });
+}();