optimizely / agent

86%

master: 86%

LAST BUILD ON BRANCH mpirnovar-redisstreams-to-cmab-fssdk-12072

branch: mpirnovar-redisstreams-to-cmab-fssdk-12072

CHANGE BRANCH

x

Reset

• mpirnovar-redisstreams-to-cmab-fssdk-12072
• Mat001-patch-1
• Mat001-patch-1-temp
• Mat001-patch-2
• Mat001-patch-3
• dependabot/go_modules/github.com/golang-jwt/jwt/v4-4.5.2
• dependabot/go_modules/golang.org/x/crypto-0.31.0
• junaed/fssdk-11071-dependabot-full-sdk-review
• master
• mpirnovar-agent-dependabot-fssdk-11471
• mpirnovar-agent-release-4.2.0
• mpirnovar-cmab-config-fssdk-11587
• mpirnovar-cmab-redis-cache-fssdk-11990
• mpirnovar-crypto-prisma-fix-fssdk-11339
• mpirnovar-experid-variationid-fssdk-11452
• mpirnovar-fix-client-cmabconfig-fssdk-11980
• mpirnovar-fssdk-11338
• redis-streams-notifications
• refs/tags/v3.0.0
• refs/tags/v3.0.1
• refs/tags/v4.0.0
• refs/tags/v4.0.0-beta
• refs/tags/v4.1.0
• refs/tags/v4.2.0
• refs/tags/v4.2.2
• refs/tags/v4.3.0-beta.1
• release/v4.2.1
• v2.0.0
• v2.0.0-beta
• v2.0.0-beta1
• v2.0.0-beta2
• v2.0.0-beta3
• v2.0.1
• v2.1.0
• v2.2.0
• v2.3.0
• v2.3.1
• v2.4.0
• v2.5.0
• v2.6.0
• v2.7.0
• v2.7.1

Build # 19249451979

Build Type

Pull #448

github

Committed by Mat001

Commit Message

Integrate Redis Streams and enhance CMAB with flexible authentication

This commit integrates Redis Streams for persistent notification delivery
from v4.3.0-beta.1 with the existing CMAB Redis cache support in master.

Features Added:
- Redis Streams implementation for notification synchronization with
  persistent message delivery, automatic retries, consumer groups, and
  configurable batching
- Flexible Redis authentication utility supporting auth_token, redis_secret,
  and password fields with environment variable fallback
- Applied flexible auth pattern to all Redis clients: ODP cache, UPS,
  CMAB cache, and synchronization pubsub
- Configurable CMAB prediction endpoint via config or environment variable

Changes:
- Added pkg/syncer/pubsub/redis_streams.go and comprehensive tests
- Added pkg/utils/redisauth for flexible password authentication
- Updated all Redis clients (ODP, UPS, CMAB) with UnmarshalJSON for auth
- Updated config.yaml with Redis Streams parameters and auth_token field
- Updated CHANGELOG.md with [Unreleased] section documenting new features
- Updated CI workflow to use Redis 6 and added Redis to test-coverage job
- Added docs/redis-streams.md with complete Redis Streams documentation

Configuration:
- CMAB configuration remains under client.cmab section
- Redis Streams enabled via synchronization.notification.default
- All Redis clients support auth_token, redis_secret, password fields
- Environment variables: REDIS_PASSWORD, REDIS_ODP_PASSWORD,
  REDIS_UPS_PASSWORD, REDIS_CMAB_PASSWORD

Testing:
- All existing tests pass
- Added 5 new auth tests for CMAB Redis cache
- Redis Streams includes 18 comprehensive tests
- redisauth utility includes 14 tests covering all scenarios

Both features coexist without conflicts - Redis Streams uses STREAM data
type for messaging while CMAB cache uses STRING type for key-value storage.

Pull Request Pull Request #448: [FSSDK-12072] Integrate Redis Streams into agent

Run Details

457 of 542 new or added lines in 8 files covered. (84.32%)

3405 of 3941 relevant lines covered (86.4%)

2975.3 hits per line