From 0546cff708a024b7795dac32bcaa434903a2ce9a Mon Sep 17 00:00:00 2001 From: hailin Date: Tue, 9 Dec 2025 03:28:28 -0800 Subject: [PATCH] revert: restore Kafka session timeout to 5 minutes --- .claude/settings.local.json | 61 ++++++++++++++++++- .../messaging/kafka/event-consumer.service.ts | 6 +- 2 files changed, 62 insertions(+), 5 deletions(-) diff --git a/.claude/settings.local.json b/.claude/settings.local.json index 88d1a3ee..b69ecab7 100644 --- a/.claude/settings.local.json +++ b/.claude/settings.local.json @@ -1,8 +1,65 @@ { "permissions": { "allow": [ - "Bash(git -C \"c:\\Users\\dong\\Desktop\\rwadurian\" commit -m \"$(cat <<''EOF''\nfix(mobile-app): skip backup mnemonic page for MPC wallet mode\n\n- Fix mnemonic parsing: empty string \"\" now correctly becomes empty list\n- MPC mode (no mnemonic) skips backup page and navigates directly to home\n- Apply fix to both initial load and polling logic\n\n🤖 Generated with [Claude Code](https://claude.com/claude-code)\n\nCo-Authored-By: Claude \nEOF\n)\")", - "Bash(npx prisma:*)" + "Bash(__NEW_LINE__ echo \"=== Test /api/v1/referral/me (referral-service) ===\")", + "Bash(git -C \"c:\\Users\\dong\\Desktop\\rwadurian\" push)", + "Bash(__NEW_LINE__ echo \"=== Test /api/v1/authorizations/my (authorization-service on port 3002) ===\")", + "Bash(__NEW_LINE__ echo \"=== Test /api/v1/authorizations/my (authorization-service on port 3009) ===\")", + "Bash(backend/api-gateway/kong.yml )", + "Bash(frontend/mobile-app/lib/core/constants/api_endpoints.dart )", + "Bash(frontend/mobile-app/lib/core/di/injection_container.dart )", + "Bash(frontend/mobile-app/lib/core/services/referral_service.dart )", + "Bash(frontend/mobile-app/lib/core/services/authorization_service.dart )", + "Bash(frontend/mobile-app/lib/features/profile/presentation/pages/profile_page.dart )", + "Bash(backend/services/authorization-service/package.json )", + "Bash(backend/services/authorization-service/package-lock.json )", + "Bash(backend/services/authorization-service/src/shared/strategies/jwt.strategy.ts )", + "Bash(backend/services/authorization-service/src/infrastructure/persistence/repositories/system-account.repository.impl.ts)", + "Bash(DATABASE_URL=\"postgresql://rwauser:rwapass123@localhost:5432/rwa_authorization\" npx prisma migrate:*)", + "Bash(backend/services/authorization-service/.gitignore )", + "Bash(backend/services/authorization-service/prisma/migrations/00000000000000_init/migration.sql )", + "Bash(git fetch:*)", + "Bash(backend/services/blockchain-service/package.json )", + "Bash(backend/services/blockchain-service/package-lock.json )", + "Bash(backend/services/blockchain-service/src/api/api.module.ts )", + "Bash(backend/services/blockchain-service/src/api/controllers/index.ts )", + "Bash(backend/services/blockchain-service/src/api/controllers/deposit.controller.ts )", + "Bash(backend/services/blockchain-service/src/shared/index.ts )", + "Bash(backend/services/blockchain-service/src/shared/decorators/ )", + "Bash(backend/services/blockchain-service/src/shared/guards/ )", + "Bash(backend/services/blockchain-service/src/shared/strategies/ )", + "Bash(backend/services/wallet-service/src/api/api.module.ts )", + "Bash(backend/services/wallet-service/src/infrastructure/kafka/ )", + "Bash(backend/services/wallet-service/src/application/event-handlers/ )", + "Bash(backend/services/docker-compose.yml )", + "Bash(frontend/mobile-app/lib/core/services/deposit_service.dart)", + "Bash(backend/services/authorization-service/prisma/schema.prisma )", + "Bash(backend/services/authorization-service/src/application/services/ )", + "Bash(backend/services/authorization-service/src/domain/ )", + "Bash(backend/services/authorization-service/src/infrastructure/persistence/repositories/ )", + "Bash(backend/services/planting-service/src/application/services/planting-application.service.ts )", + "Bash(backend/services/planting-service/src/domain/services/fund-allocation.service.ts )", + "Bash(backend/services/planting-service/src/infrastructure/external/ )", + "Bash(backend/services/planting-service/src/infrastructure/infrastructure.module.ts )", + "Bash(backend/services/planting-service/src/infrastructure/persistence/prisma/prisma.service.ts )", + "Bash(backend/services/planting-service/src/infrastructure/persistence/unit-of-work.ts )", + "Bash(backend/services/referral-service/src/modules/api.module.ts )", + "Bash(backend/services/reward-service/src/infrastructure/external/authorization-service/authorization-service.client.ts )", + "Bash(backend/services/wallet-service/package.json )", + "Bash(backend/services/wallet-service/prisma/schema.prisma )", + "Bash(backend/services/wallet-service/src/)", + "Bash(git status:*)", + "Bash(git check-ignore:*)", + "Bash(docker inspect:*)", + "Bash(python -m json.tool:*)", + "Bash(docker logs:*)", + "Bash(curl:*)", + "Bash(git add:*)", + "Bash(git commit:*)", + "Bash(git push)", + "Bash(cat:*)", + "Bash(git revert:*)", + "Bash(git stash:*)" ], "deny": [], "ask": [] diff --git a/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts b/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts index 2df4dc67..6cb66004 100644 --- a/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts +++ b/backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts @@ -67,10 +67,10 @@ export class EventConsumerService implements OnModuleInit, OnModuleDestroy { this.consumer = this.kafka.consumer({ groupId, - sessionTimeout: 30000, // 30 seconds - enough for normal operations - heartbeatInterval: 3000, // 3 seconds + sessionTimeout: 300000, // 5 minutes - MPC keygen can take a while + heartbeatInterval: 10000, // 10 seconds maxWaitTimeInMs: 5000, - rebalanceTimeout: 60000, // 60 seconds - for MPC operations + rebalanceTimeout: 300000, // 5 minutes }); try {