Merge pull request #25 from smartprocure/feature/remove-try-catch

Remove `try/catch`

.gitignore

@@ -67,4 +67,6 @@ dist/
 
 src/syncPlayground.ts
 
-.idea/
+.idea/
+
+.env

CHANGELOG.md

@@ -1,244 +1,248 @@
+# 0.50.0
+
+- Remove try/catch and rely on retry logic in `mongochangestream`.
+
 # 0.49.0
 
--   Latest `mongochangestream` - Fix for downstream `processRecords` mutation.
+- Latest `mongochangestream` - Fix for downstream `processRecords` mutation.
 
 # 0.48.0
 
--   Latest `mongochangestream` - Add `lastFlush` to `stats` event.
+- Latest `mongochangestream` - Add `lastFlush` to `stats` event.
 
 # 0.47.0
 
--   **Breaking Change**: When there are multiple `overrides` that match the same
-    path (e.g. `*` and `foo.*` both match the path `foo.bar`), they will now be
-    applied in sequence, where the output of each override is passed as input to
-    the next.
--   Added a `mapSchema` option as an "escape hatch" to allow preprocessing each
-    node in the input object (using `map` from `obj-walker`) before converting
-    it to a Crate schema.
+- **Breaking Change**: When there are multiple `overrides` that match the same
+  path (e.g. `*` and `foo.*` both match the path `foo.bar`), they will now be
+  applied in sequence, where the output of each override is passed as input to
+  the next.
+- Added a `mapSchema` option as an "escape hatch" to allow preprocessing each
+  node in the input object (using `map` from `obj-walker`) before converting
+  it to a Crate schema.
 
 # 0.46.0
 
--   Bump `mongochangestream` to enable "pausable" feature.
--   Bumped deps.
+- Bump `mongochangestream` to enable "pausable" feature.
+- Bumped deps.
 
 # 0.45.0
 
--   Bump packages, including latest `prom-utils` which allows for throttling of items/sec and bytes/sec.
+- Bump packages, including latest `prom-utils` which allows for throttling of items/sec and bytes/sec.
 
 # 0.44.0
 
--   Updated `createIndexIgnoreMalformed` - dropped `body` field.
+- Updated `createIndexIgnoreMalformed` - dropped `body` field.
 
 # 0.43.0
 
--   Latest `mongochangestream` - Fixed omit bugs (not relevant to mongo2elastic).
--   Fixed: `processChangeStream` options should be optional.
--   Changed testing library from jest to vitest.
--   Bumped peer dependencies for `elasticsearch`, `ioredis`, and `mongodb`.
+- Latest `mongochangestream` - Fixed omit bugs (not relevant to mongo2elastic).
+- Fixed: `processChangeStream` options should be optional.
+- Changed testing library from jest to vitest.
+- Bumped peer dependencies for `elasticsearch`, `ioredis`, and `mongodb`.
 
 # 0.42.0
 
--   Latest `mongochangestream` - Support for parallel syncing of a collection.
+- Latest `mongochangestream` - Support for parallel syncing of a collection.
 
 # 0.41.0
 
--   Latest `mongochangestream` - Bug fixes.
+- Latest `mongochangestream` - Bug fixes.
 
 # 0.40.0
 
--   Remove `updateDescription` since it is not needed and may cause a `BSONObjectTooLarge` error.
+- Remove `updateDescription` since it is not needed and may cause a `BSONObjectTooLarge` error.
 
 # 0.39.1
 
--   Fix `passthrough` when set for an array field.
--   Better `passthrough` logic for `text` fields.
+- Fix `passthrough` when set for an array field.
+- Better `passthrough` logic for `text` fields.
 
 # 0.39.0
 
--   Removed `options.mapper` in favor of `options.rename` which takes an object of dotted path to renamed dotted path.
-    The `rename` option is available for syncing and converting a schema to a table.`_id` mapped to `_mongoId` by default.
+- Removed `options.mapper` in favor of `options.rename` which takes an object of dotted path to renamed dotted path.
+  The `rename` option is available for syncing and converting a schema to a table.`_id` mapped to `_mongoId` by default.
 
 # 0.38.0
 
--   Added `operationCounts` to the `process` event.
+- Added `operationCounts` to the `process` event.
 
 # 0.37.0
 
--   Latest `mongochangestream` - Change stream option `operationTypes` (`insert`, `update`, `delete`, ...).
+- Latest `mongochangestream` - Change stream option `operationTypes` (`insert`, `update`, `delete`, ...).
 
 # 0.36.0
 
--   `processChangeStream` now batches records. Default timeout before the queue is automatically
-    flushed is 30 seconds.
+- `processChangeStream` now batches records. Default timeout before the queue is automatically
+  flushed is 30 seconds.
 
 # 0.35.0
 
--   Latest `mongochangestream` - More robust error code handling for `missingOplogEntry`.
+- Latest `mongochangestream` - More robust error code handling for `missingOplogEntry`.
 
 # 0.34.0
 
--   Latest `mongochangestream` - Don't emit the `cursorError` event when stopping.
+- Latest `mongochangestream` - Don't emit the `cursorError` event when stopping.
 
 # 0.33.1
 
--   Latest `mongochangestream` - FSM bug fix.
+- Latest `mongochangestream` - FSM bug fix.
 
 # 0.33.0
 
--   Latest `mongochangestream` - Drop health check code in favor of `cursorError` event.
+- Latest `mongochangestream` - Drop health check code in favor of `cursorError` event.
 
 # 0.32.0
 
--   Latest `mongochangestream` - extend event types.
+- Latest `mongochangestream` - extend event types.
 
 # 0.31.0
 
--   Latest `mongochangestream` - `runInitialScan` pipeline.
+- Latest `mongochangestream` - `runInitialScan` pipeline.
 
 # 0.30.0
 
--   Emit errors that happened during initial bulk sync
+- Emit errors that happened during initial bulk sync
 
 # 0.29.0
 
--   Optionally pass `mapper` for an override.
+- Optionally pass `mapper` for an override.
 
 # 0.28.0
 
--   Glob expressions supported for overrides `path`.
--   Pass any key/value pair in `Override` object.
+- Glob expressions supported for overrides `path`.
+- Pass any key/value pair in `Override` object.
 
 # 0.27.0
 
--   Latest `mongochangestream` - Handle master failover scenario properly for initial scan.
+- Latest `mongochangestream` - Handle master failover scenario properly for initial scan.
 
 # 0.26.0
 
--   Latest `mongochangestream` - Longer `maxSyncDelay` default.
+- Latest `mongochangestream` - Longer `maxSyncDelay` default.
 
 # 0.25.0
 
--   Renamed `ignoreMalformed` to `createIndexIgnoreMalformed`.
--   More info when emitting.
+- Renamed `ignoreMalformed` to `createIndexIgnoreMalformed`.
+- More info when emitting.
 
 # 0.24.1
 
--   Export `detectResync`.
+- Export `detectResync`.
 
 # 0.24.0
 
--   Latest `mongochangestream` - More robust cursor consumption.
+- Latest `mongochangestream` - More robust cursor consumption.
 
 # 0.23.0
 
--   Latest `mongochangestream` - Bug fix.
+- Latest `mongochangestream` - Bug fix.
 
 # 0.22.0
 
--   Latest `mongochangestream` - generic emitter.
--   Use emitter from `mongochangestream` which now emits two events on its own.
+- Latest `mongochangestream` - generic emitter.
+- Use emitter from `mongochangestream` which now emits two events on its own.
 
 # 0.21.0
 
--   Latest `mongochangestream` - health checks.
+- Latest `mongochangestream` - health checks.
 
 # 0.20.0
 
--   Added `passthrough` option to allow for customization of field mappings.
--   Use `_.merge` instead of flattened key path.
+- Added `passthrough` option to allow for customization of field mappings.
+- Use `_.merge` instead of flattened key path.
 
 # 0.19.0
 
--   Use flattened key path for `ignore_malformed`.
+- Use flattened key path for `ignore_malformed`.
 
 # 0.18.0
 
--   Add optional settings that can be added to `ignoreMalformed`.
+- Add optional settings that can be added to `ignoreMalformed`.
 
 # 0.17.1
 
--   Unwrap first value of multi-valued BSON type. E.g., `['string', 'null']` => `'string'`.
+- Unwrap first value of multi-valued BSON type. E.g., `['string', 'null']` => `'string'`.
 
 # 0.17.0
 
--   Added options for `omit` and `overrides` to `convertSchema`.
--   Convert string enum to keyword.
+- Added options for `omit` and `overrides` to `convertSchema`.
+- Convert string enum to keyword.
 
 # 0.16.0
 
--   Added `createMappingFromSchema`.
--   `convertSchema` bug fixes.
+- Added `createMappingFromSchema`.
+- `convertSchema` bug fixes.
 
 # 0.15.0
 
--   Added `convertSchema` fn that converts a MongoDB JSON schema to an Elasticsearch mapping.
+- Added `convertSchema` fn that converts a MongoDB JSON schema to an Elasticsearch mapping.
 
 # 0.14.1
 
--   Forgot to bump `prom-utils` in this repo.
+- Forgot to bump `prom-utils` in this repo.
 
 # 0.14.0
 
--   Latest `mongochangestream` - `batchBytes` option.
+- Latest `mongochangestream` - `batchBytes` option.
 
 # 0.13.0
 
--   Return `emitter` with events: `process` and `error`.
--   Stats are no longer logged.
+- Return `emitter` with events: `process` and `error`.
+- Stats are no longer logged.
 
 # 0.12.0
 
--   Removed `clearCompletedOn`.
--   Latest `mongochangestream` - `JSONSchema` type.
+- Removed `clearCompletedOn`.
+- Latest `mongochangestream` - `JSONSchema` type.
 
 # 0.11.0
 
--   Latest `mongochangestream` - Option to strip metadata from a JSON schema for `detectSchemaChange`.
+- Latest `mongochangestream` - Option to strip metadata from a JSON schema for `detectSchemaChange`.
 
 # 0.10.0
 
--   Latest `mongochangestream` - Ensure that you can call `start` after calling `stop`.
+- Latest `mongochangestream` - Ensure that you can call `start` after calling `stop`.
 
 # 0.9.0
 
--   Fix `Document` type.
--   Bump `mongodb` peer dep.
--   Latest `mongochangestream`.
+- Fix `Document` type.
+- Bump `mongodb` peer dep.
+- Latest `mongochangestream`.
 
 # 0.8.2
 
--   Bug fix from `mongochangestream`.
+- Bug fix from `mongochangestream`.
 
 # 0.8.0
 
--   Latest `mongochangestream`.
+- Latest `mongochangestream`.
 
 # 0.7.0
 
--   Latest `mongochangestream`.
+- Latest `mongochangestream`.
 
 # 0.6.0
 
--   Pass along `reset` and other `mongochangestream` fns.
+- Pass along `reset` and other `mongochangestream` fns.
 
 # 0.5.0
 
--   Latest `mongochangestream`.
--   `detectSchemaChange`.
+- Latest `mongochangestream`.
+- `detectSchemaChange`.
 
 # 0.4.1
 
--   Lower required elasticsearch dep.
+- Lower required elasticsearch dep.
 
 # 0.3.0
 
--   Added peer dependencies.
--   Latest `mongochangestream`.
+- Added peer dependencies.
+- Latest `mongochangestream`.
 
 # 0.2.0
 
--   Latest `mongochangestream`.
+- Latest `mongochangestream`.
 
 # 0.1.0
 
--   Initial release.
+- Initial release.