hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

revert: restore Kafka session timeout to 5 minutes

This commit is contained in:
hailin 2025-12-09 03:28:28 -08:00
parent 429f8d5991
commit 0546cff708
2 changed files with 62 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
.claude/settings.local.json
View File

@ -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 <noreply@anthropic.com>\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": []

6
backend/services/mpc-service/src/infrastructure/messaging/kafka/event-consumer.service.ts
View File

@ -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 {