Commit 202c602
committed
merge: catch up with main (raw change streams PR #591)
Merges upstream main which includes PR #591 (raw change streams) and
PR #599 (direct BSON Buffer -> JSON conversion).
Auth fix conflicts (types.ts, config.test.ts) resolved — both sides
had the same fix, upstream also added database name decoding.
ChangeStream.ts has 11 unresolved conflicts — PR #591 replaced the
MongoDB driver ChangeStream with a custom RawChangeStream using raw
aggregate + getMore. Our Cosmos DB changes need to be re-applied to
the new code structure. Resolved in the next commit.File tree
2,891 files changed
+356085
-38196
lines changed- .changeset
- .github/workflows
- .jjconflict-base-0
- .changeset
- .github
- actions
- setup-node-build
- start-mongodb
- start-postgres-storage
- workflows
- .husky
- docs
- libs
- lib-mongodb
- src
- db
- locks
- types
- test
- src
- lib-postgres
- src
- db
- connection
- locks
- types
- utils
- test
- src
- lib-services
- src
- alerts
- codec
- errors
- ip
- locks
- logger
- migrations
- router
- schema
- json-schema
- validators
- signals
- probes
- system
- utils
- test
- __snapshots__
- src
- __mocks__
- __snapshots__
- fixtures
- schema
- __snapshots__
- modules
- module-core
- src
- types
- test
- src
- module-mongodb-storage
- src
- migrations
- db/migrations
- module
- storage
- implementation
- common
- v1
- v3
- types
- utils
- test
- src
- __snapshots__
- module-mongodb
- scripts
- src
- api
- common
- module
- replication
- types
- test
- src
- module-mssql
- ci
- dev
- src
- api
- common
- module
- replication
- types
- utils
- test
- src
- module-mysql
- dev
- config
- docker/mysql
- init-scripts
- src
- api
- common
- module
- replication
- zongji
- types
- utils
- test
- src
- module-postgres-storage
- src
- migrations
- scripts
- module
- storage
- batch
- checkpoints
- sync-rules
- types
- models
- utils
- test
- src
- __snapshots__
- module-postgres
- sql
- src
- api
- module
- replication
- types
- utils
- test
- src
- types
- packages
- jpgwire
- ca
- src
- test
- jsonbig
- src
- rsocket-router
- src
- router
- transport
- utils
- test
- src
- utils
- schema
- src
- scripts
- service-client
- src
- service-core-tests
- src
- test-utils
- tests
- service-core
- .probes
- src
- api
- auth
- entry
- commands
- events
- metrics
- open-telemetry
- migrations
- modules
- replication
- routes
- endpoints
- runner
- storage
- streams
- sync
- system
- util
- config
- collectors
- impl
- sync-rules
- impl
- test
- src
- routes
- sync
- util
- service-errors
- src
- test
- src
- sync-rules
- grammar
- docs
- scripts
- src
- compiler
- events
- schema-generators
- streams
- sync_plan
- engine
- evaluator
- types
- test
- src
- compiler
- __snapshots__
- grammar_parity
- fixtures
- sync_plan
- engine
- evaluator
- types
- types
- src
- config
- scripts
- service
- .probes
- local-dev
- src
- runners
- util
- test-client
- src
- load-testing
- .jjconflict-side-0
- .changeset
- .github
- actions
- setup-node-build
- start-mongodb
- start-postgres-storage
- workflows
- .husky
- docs
- libs
- lib-mongodb
- src
- db
- locks
- types
- test
- src
- lib-postgres
- src
- db
- connection
- locks
- types
- utils
- test
- src
- lib-services
- src
- alerts
- codec
- errors
- ip
- locks
- logger
- migrations
- router
- schema
- json-schema
- validators
- signals
- probes
- system
- utils
- test
- __snapshots__
- src
- __mocks__
- __snapshots__
- fixtures
- schema
- __snapshots__
- modules
- module-core
- src
- types
- test
- src
- module-mongodb-storage
- src
- migrations
- db/migrations
- module
- storage
- implementation
- common
- v1
- v3
- types
- utils
- test
- src
- __snapshots__
- module-mongodb
- scripts
- src
- api
- common
- module
- replication
- types
- test
- src
- module-mssql
- ci
- dev
- src
- api
- common
- module
- replication
- types
- utils
- test
- src
- module-mysql
- dev
- config
- docker/mysql
- init-scripts
- src
- api
- common
- module
- replication
- zongji
- types
- utils
- test
- src
- module-postgres-storage
- src
- migrations
- scripts
- module
- storage
- batch
- checkpoints
- sync-rules
- types
- models
- utils
- test
- src
- __snapshots__
- module-postgres
- sql
- src
- api
- module
- replication
- types
- utils
- test
- src
- types
- packages
- jpgwire
- ca
- src
- test
- jsonbig
- src
- rsocket-router
- src
- router
- transport
- utils
- test
- src
- utils
- schema
- src
- scripts
- service-client
- src
- service-core-tests
- src
- test-utils
- tests
- service-core
- .probes
- src
- api
- auth
- entry
- commands
- events
- metrics
- open-telemetry
- migrations
- modules
- replication
- routes
- endpoints
- runner
- storage
- streams
- sync
- system
- util
- config
- collectors
- impl
- sync-rules
- impl
- test
- src
- routes
- sync
- util
- service-errors
- src
- test
- src
- sync-rules
- grammar
- docs
- scripts
- src
- compiler
- events
- schema-generators
- streams
- sync_plan
- engine
- evaluator
- types
- test
- src
- compiler
- __snapshots__
- grammar_parity
- fixtures
- sync_plan
- engine
- evaluator
- types
- types
- src
- config
- scripts
- service
- .probes
- local-dev
- src
- runners
- util
- test-client
- src
- load-testing
- .jjconflict-side-1
- .changeset
- .github
- actions
- setup-node-build
- start-mongodb
- start-postgres-storage
- workflows
- .husky
- docs
- libs
- lib-mongodb
- src
- db
- locks
- types
- test
- src
- lib-postgres
- src
- db
- connection
- locks
- types
- utils
- test
- src
- lib-services
- src
- alerts
- codec
- errors
- ip
- locks
- logger
- migrations
- router
- schema
- json-schema
- validators
- signals
- probes
- system
- utils
- test
- __snapshots__
- src
- __mocks__
- __snapshots__
- fixtures
- schema
- __snapshots__
- modules
- module-core
- src
- types
- test
- src
- module-mongodb-storage
- src
- migrations
- db/migrations
- module
- storage
- implementation
- common
- v1
- v3
- types
- utils
- test
- src
- __snapshots__
- module-mongodb
- scripts
- src
- api
- common
- module
- replication
- types
- test
- src
- module-mssql
- ci
- dev
- src
- api
- common
- module
- replication
- types
- utils
- test
- src
- module-mysql
- dev
- config
- docker/mysql
- init-scripts
- src
- api
- common
- module
- replication
- zongji
- types
- utils
- test
- src
- module-postgres-storage
- src
- migrations
- scripts
- module
- storage
- batch
- checkpoints
- sync-rules
- types
- models
- utils
- test
- src
- __snapshots__
- module-postgres
- sql
- src
- api
- module
- replication
- types
- utils
- test
- src
- types
- packages
- jpgwire
- ca
- src
- test
- jsonbig
- src
- rsocket-router
- src
- router
- transport
- utils
- test
- src
- utils
- schema
- src
- scripts
- service-client
- src
- service-core-tests
- src
- test-utils
- tests
- service-core
- .probes
- src
- api
- auth
- entry
- commands
- events
- metrics
- open-telemetry
- migrations
- modules
- replication
- routes
- endpoints
- runner
- storage
- streams
- sync
- system
- util
- config
- collectors
- impl
- sync-rules
- impl
- test
- src
- routes
- sync
- util
- service-errors
- src
- test
- src
- sync-rules
- grammar
- docs
- scripts
- src
- compiler
- events
- schema-generators
- streams
- sync_plan
- engine
- evaluator
- types
- test
- src
- compiler
- __snapshots__
- grammar_parity
- fixtures
- sync_plan
- engine
- evaluator
- types
- types
- src
- config
- scripts
- service
- .probes
- local-dev
- src
- runners
- util
- test-client
- src
- load-testing
- libs
- lib-mongodb
- src
- db
- types
- test/src
- lib-postgres
- src/db/connection
- lib-services
- src/logger
- modules
- module-core
- module-mongodb-storage
- src
- storage
- implementation
- utils
- test/src
- module-mongodb
- src/replication
- test/src
- module-mssql
- ci
- module-mysql
- module-postgres-storage
- src/storage
- module-postgres
- src
- api
- replication
- test/src
- packages
- jpgwire
- rsocket-router
- schema
- service-client
- service-core-tests
- src
- test-utils
- tests
- service-core
- src
- api
- routes/endpoints
- storage
- sync
- test/src/sync
- service-errors
- src
- sync-rules
- src
- test/src
- types
- src
- service
- test-client
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,891 files changed
+356085
-38196
lines changedThis file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
This file was deleted.
File renamed without changes.
File renamed without changes.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
0 commit comments