mirror of
https://github.com/lowdefy/lowdefy.git
synced 2025-03-19 15:01:06 +08:00
Merge branch 'develop' into fix-tests
This commit is contained in:
Gerrie van Wyk
GitHub
commit
6759833b88
94
.pnp.cjs
generated
94
.pnp.cjs
generated
@ -3192,7 +3192,7 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["@swc/core", "npm:1.2.135"],
|
||||
["@swc/jest", "virtual:babee6e81435a5d101529cd67f2c6b175f4db37a4ab0b58df15adf73dd11be8917ac14caf44ab4e6882a92c61661055072365b349016e85173e049f006fc2305#npm:0.2.17"],
|
||||
["jest", "virtual:babee6e81435a5d101529cd67f2c6b175f4db37a4ab0b58df15adf73dd11be8917ac14caf44ab4e6882a92c61661055072365b349016e85173e049f006fc2305#npm:27.5.1"],
|
||||
["mongodb", "virtual:8892fd55020404ef7b68cfff5e095a43035d4129ed154e1c28837e4f2c038ceb7761f36556ed437d5a606142082cb5505d80f52744c412cdeaaaf5d9c72e693c#npm:3.7.3"],
|
||||
["mongodb", "npm:4.4.0"],
|
||||
["saslprep", "npm:1.0.3"]
|
||||
],
|
||||
"linkType": "SOFT",
|
||||
@ -4221,7 +4221,7 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["@shelf/jest-mongodb", "virtual:8892fd55020404ef7b68cfff5e095a43035d4129ed154e1c28837e4f2c038ceb7761f36556ed437d5a606142082cb5505d80f52744c412cdeaaaf5d9c72e693c#npm:2.2.0"],
|
||||
["@types/mongodb", null],
|
||||
["debug", "virtual:46bd44738c648c1105842f65adfc896e3dbcb5f8631b32158dc40c0a1a21460f1708014b7896430af62fa59b995d372f1841b2205de80ebc306769451a14cbdd#npm:4.3.2"],
|
||||
["mongodb", "virtual:8892fd55020404ef7b68cfff5e095a43035d4129ed154e1c28837e4f2c038ceb7761f36556ed437d5a606142082cb5505d80f52744c412cdeaaaf5d9c72e693c#npm:3.7.3"],
|
||||
["mongodb", "npm:4.4.0"],
|
||||
["mongodb-memory-server", "npm:7.3.6"],
|
||||
["uuid", "npm:8.3.2"]
|
||||
],
|
||||
@ -4896,6 +4896,26 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["@types/webidl-conversions", [
|
||||
["npm:6.1.1", {
|
||||
"packageLocation": "./.yarn/cache/@types-webidl-conversions-npm-6.1.1-ce4d057614-bd0faad4df.zip/node_modules/@types/webidl-conversions/",
|
||||
"packageDependencies": [
|
||||
["@types/webidl-conversions", "npm:6.1.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["@types/whatwg-url", [
|
||||
["npm:8.2.1", {
|
||||
"packageLocation": "./.yarn/cache/@types-whatwg-url-npm-8.2.1-718fa51acd-975987a9ca.zip/node_modules/@types/whatwg-url/",
|
||||
"packageDependencies": [
|
||||
["@types/whatwg-url", "npm:8.2.1"],
|
||||
["@types/node", "npm:17.0.14"],
|
||||
["@types/webidl-conversions", "npm:6.1.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["@types/yargs", [
|
||||
["npm:16.0.4", {
|
||||
"packageLocation": "./.yarn/cache/@types-yargs-npm-16.0.4-7aaef7d6c8-caa21d2c95.zip/node_modules/@types/yargs/",
|
||||
@ -6055,6 +6075,14 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["bson", "npm:1.1.6"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}],
|
||||
["npm:4.6.1", {
|
||||
"packageLocation": "./.yarn/cache/bson-npm-4.6.1-4e698544f6-32c38400b0.zip/node_modules/bson/",
|
||||
"packageDependencies": [
|
||||
["bson", "npm:4.6.1"],
|
||||
["buffer", "npm:5.7.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["buffer", [
|
||||
@ -7520,6 +7548,13 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["denque", "npm:1.5.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}],
|
||||
["npm:2.0.1", {
|
||||
"packageLocation": "./.yarn/cache/denque-npm-2.0.1-4ba00e404b-ec398d1e3c.zip/node_modules/denque/",
|
||||
"packageDependencies": [
|
||||
["denque", "npm:2.0.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["depd", [
|
||||
@ -12993,10 +13028,22 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
],
|
||||
"linkType": "SOFT",
|
||||
}],
|
||||
["virtual:8892fd55020404ef7b68cfff5e095a43035d4129ed154e1c28837e4f2c038ceb7761f36556ed437d5a606142082cb5505d80f52744c412cdeaaaf5d9c72e693c#npm:3.7.3", {
|
||||
"packageLocation": "./.yarn/__virtual__/mongodb-virtual-40cb457e1d/0/cache/mongodb-npm-3.7.3-c479129d1e-ef7690fe6e.zip/node_modules/mongodb/",
|
||||
["npm:4.4.0", {
|
||||
"packageLocation": "./.yarn/cache/mongodb-npm-4.4.0-cc5718bafa-e485927d1d.zip/node_modules/mongodb/",
|
||||
"packageDependencies": [
|
||||
["mongodb", "virtual:8892fd55020404ef7b68cfff5e095a43035d4129ed154e1c28837e4f2c038ceb7761f36556ed437d5a606142082cb5505d80f52744c412cdeaaaf5d9c72e693c#npm:3.7.3"],
|
||||
["mongodb", "npm:4.4.0"],
|
||||
["bson", "npm:4.6.1"],
|
||||
["denque", "npm:2.0.1"],
|
||||
["mongodb-connection-string-url", "npm:2.4.2"],
|
||||
["saslprep", "npm:1.0.3"],
|
||||
["socks", "npm:2.6.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}],
|
||||
["virtual:0a51e320dc5b109e637e794bce5af2be0a1eef05b47f4f7a5da449544562a38b8e690909d1d419a9018331638b1b33914a9007effc9c013b31e98b84170bb801#npm:3.7.3", {
|
||||
"packageLocation": "./.yarn/__virtual__/mongodb-virtual-e918975556/0/cache/mongodb-npm-3.7.3-c479129d1e-ef7690fe6e.zip/node_modules/mongodb/",
|
||||
"packageDependencies": [
|
||||
["mongodb", "virtual:0a51e320dc5b109e637e794bce5af2be0a1eef05b47f4f7a5da449544562a38b8e690909d1d419a9018331638b1b33914a9007effc9c013b31e98b84170bb801#npm:3.7.3"],
|
||||
["@types/aws4", null],
|
||||
["@types/bson-ext", null],
|
||||
["@types/kerberos", null],
|
||||
@ -13033,6 +13080,17 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["mongodb-connection-string-url", [
|
||||
["npm:2.4.2", {
|
||||
"packageLocation": "./.yarn/cache/mongodb-connection-string-url-npm-2.4.2-dfd1085b7c-aed2718840.zip/node_modules/mongodb-connection-string-url/",
|
||||
"packageDependencies": [
|
||||
["mongodb-connection-string-url", "npm:2.4.2"],
|
||||
["@types/whatwg-url", "npm:8.2.1"],
|
||||
["whatwg-url", "npm:11.0.0"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["mongodb-memory-server", [
|
||||
["npm:7.3.6", {
|
||||
"packageLocation": "./.yarn/unplugged/mongodb-memory-server-npm-7.3.6-1008c38beb/node_modules/mongodb-memory-server/",
|
||||
@ -13058,7 +13116,7 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["https-proxy-agent", "npm:5.0.0"],
|
||||
["md5-file", "npm:5.0.0"],
|
||||
["mkdirp", "npm:1.0.4"],
|
||||
["mongodb", "virtual:8892fd55020404ef7b68cfff5e095a43035d4129ed154e1c28837e4f2c038ceb7761f36556ed437d5a606142082cb5505d80f52744c412cdeaaaf5d9c72e693c#npm:3.7.3"],
|
||||
["mongodb", "virtual:0a51e320dc5b109e637e794bce5af2be0a1eef05b47f4f7a5da449544562a38b8e690909d1d419a9018331638b1b33914a9007effc9c013b31e98b84170bb801#npm:3.7.3"],
|
||||
["new-find-package-json", "npm:1.1.0"],
|
||||
["semver", "npm:7.3.5"],
|
||||
["tar-stream", "npm:2.2.0"],
|
||||
@ -18237,6 +18295,14 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["punycode", "npm:2.1.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}],
|
||||
["npm:3.0.0", {
|
||||
"packageLocation": "./.yarn/cache/tr46-npm-3.0.0-e1ae1ea7c9-44c3cc6767.zip/node_modules/tr46/",
|
||||
"packageDependencies": [
|
||||
["tr46", "npm:3.0.0"],
|
||||
["punycode", "npm:2.1.1"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["treeify", [
|
||||
@ -18936,6 +19002,13 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
["webidl-conversions", "npm:6.1.0"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}],
|
||||
["npm:7.0.0", {
|
||||
"packageLocation": "./.yarn/cache/webidl-conversions-npm-7.0.0-e8c8e30c68-f05588567a.zip/node_modules/webidl-conversions/",
|
||||
"packageDependencies": [
|
||||
["webidl-conversions", "npm:7.0.0"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}]
|
||||
]],
|
||||
["whatwg-encoding", [
|
||||
@ -18958,6 +19031,15 @@ function $$SETUP_STATE(hydrateRuntimeState, basePath) {
|
||||
}]
|
||||
]],
|
||||
["whatwg-url", [
|
||||
["npm:11.0.0", {
|
||||
"packageLocation": "./.yarn/cache/whatwg-url-npm-11.0.0-073529d93a-ed4826aaa5.zip/node_modules/whatwg-url/",
|
||||
"packageDependencies": [
|
||||
["whatwg-url", "npm:11.0.0"],
|
||||
["tr46", "npm:3.0.0"],
|
||||
["webidl-conversions", "npm:7.0.0"]
|
||||
],
|
||||
"linkType": "HARD",
|
||||
}],
|
||||
["npm:5.0.0", {
|
||||
"packageLocation": "./.yarn/cache/whatwg-url-npm-5.0.0-374fb45e60-b8daed4ad3.zip/node_modules/whatwg-url/",
|
||||
"packageDependencies": [
|
||||
|
||||
BIN
.yarn/cache/@types-webidl-conversions-npm-6.1.1-ce4d057614-bd0faad4df.zip
vendored
Normal file
BIN
.yarn/cache/@types-webidl-conversions-npm-6.1.1-ce4d057614-bd0faad4df.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/@types-whatwg-url-npm-8.2.1-718fa51acd-975987a9ca.zip
vendored
Normal file
BIN
.yarn/cache/@types-whatwg-url-npm-8.2.1-718fa51acd-975987a9ca.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/bson-npm-4.6.1-4e698544f6-32c38400b0.zip
vendored
Normal file
BIN
.yarn/cache/bson-npm-4.6.1-4e698544f6-32c38400b0.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/denque-npm-2.0.1-4ba00e404b-ec398d1e3c.zip
vendored
Normal file
BIN
.yarn/cache/denque-npm-2.0.1-4ba00e404b-ec398d1e3c.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/mongodb-connection-string-url-npm-2.4.2-dfd1085b7c-aed2718840.zip
vendored
Normal file
BIN
.yarn/cache/mongodb-connection-string-url-npm-2.4.2-dfd1085b7c-aed2718840.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/mongodb-npm-4.4.0-cc5718bafa-e485927d1d.zip
vendored
Normal file
BIN
.yarn/cache/mongodb-npm-4.4.0-cc5718bafa-e485927d1d.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/tr46-npm-3.0.0-e1ae1ea7c9-44c3cc6767.zip
vendored
Normal file
BIN
.yarn/cache/tr46-npm-3.0.0-e1ae1ea7c9-44c3cc6767.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/webidl-conversions-npm-7.0.0-e8c8e30c68-f05588567a.zip
vendored
Normal file
BIN
.yarn/cache/webidl-conversions-npm-7.0.0-e8c8e30c68-f05588567a.zip
vendored
Normal file
Binary file not shown.
BIN
.yarn/cache/whatwg-url-npm-11.0.0-073529d93a-ed4826aaa5.zip
vendored
Normal file
BIN
.yarn/cache/whatwg-url-npm-11.0.0-073529d93a-ed4826aaa5.zip
vendored
Normal file
Binary file not shown.
@ -106,14 +106,30 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `pipeline: object[]`: __Required__ - Array containing all the aggregation framework commands for the execution.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#aggregate) for more information. Supported settings are:
|
||||
- `readPreference: string | object`: The read preference.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#aggregate) for more information. Supported settings are:
|
||||
- `allowDiskUse: boolean`: Default: `false` - Allow disk use on the MongoDB server to store temporary results for the aggregation.
|
||||
- `maxTimeMS: number`: Specifies a cumulative time limit in milliseconds for processing operations on the cursor.
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `batchSize: number`: The number of documents to return per batch.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `bypassDocumentValidation: boolean`: Default: `false` - Allow driver to bypass schema validation in MongoDB 3.2 or higher.
|
||||
- `checkKeys: boolean`: The serializer will check if keys are valid.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `comment: string`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the aggregation. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: boolean`: Specifies to return the information on the processing of the pipeline.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `hint: string | object`: Add an index selection hint to an aggregation command.
|
||||
- `ignoreUndefined: boolean`: Default: `true` - Serialize will not emit undefined fields.
|
||||
- `let: object`: Specifies an object with a list of variables. This allows you to improve command readability by separating the variables from the query text.
|
||||
- `maxAwaitTimeMS: number`: The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query.
|
||||
- `maxTimeMS: number`: Specifies a cumulative time limit in milliseconds for processing operations on the cursor.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `readConcern: object`: Specifies the level of isolation for read operations.
|
||||
- `readPreference: string | object`: The read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern to use with the $out or $merge stage.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -143,14 +159,27 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `filter: object`: __Required__ - The filter used to select the document to update.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#updateOne) for more information. Supported settings are:
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#deletemany) for more information. Supported settings are:
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `checkKeys: boolean`: Default: `false` - If true, will throw if bson documents start with $ or include a . in any key value.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `hint: object`: An optional hint for query optimization.
|
||||
- `comment: string`: A user-provided comment to attach to this command.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: boolean`: Specifies the verbosity mode for the explain output.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `hint: string | object`: An optional hint for query optimization.
|
||||
- `ignoreUndefined: boolean`: Default: `false` - Specify if the BSON serializer should ignore undefined fields.
|
||||
- `j: boolean`: Specify a journal write concern.
|
||||
- `w: number | string`: The write concern
|
||||
- `wtimeout: number`: The write concern timeout.
|
||||
- `let: object`: Map of parameter names and values that can be accessed using `$$var` (requires MongoDB 5.0).
|
||||
- `maxTimeMS: number`: Specifies a cumulative time limit in milliseconds for processing operations on the cursor.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `ordered: boolean`: If true, when an insert fails, don't execute the remaining writes. If false, continue with remaining inserts when one fails.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: string | object`: The read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -173,14 +202,27 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `filter: object`: __Required__ - The filter used to select the document to update.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#updateOne) for more information. Supported settings are:
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#deleteone) for more information. Supported settings are:
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `checkKeys: boolean`: Default: `false` - If true, will throw if bson documents start with $ or include a . in any key value.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `hint: object`: An optional hint for query optimization.
|
||||
- `comment: string`: A user-provided comment to attach to this command.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: boolean`: Specifies the verbosity mode for the explain output.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `hint: string | object`: An optional hint for query optimization.
|
||||
- `ignoreUndefined: boolean`: Default: `false` - Specify if the BSON serializer should ignore undefined fields.
|
||||
- `j: boolean`: Specify a journal write concern.
|
||||
- `w: number | string`: The write concern
|
||||
- `wtimeout: number`: The write concern timeout.
|
||||
- `let: object`: Map of parameter names and values that can be accessed using `$$var` (requires MongoDB 5.0).
|
||||
- `maxTimeMS: number`: Specifies a cumulative time limit in milliseconds for processing operations on the cursor.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `ordered: boolean`: If true, when an insert fails, don't execute the remaining writes. If false, continue with remaining inserts when one fails.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: string | object`: The read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -204,16 +246,43 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `query: object`: __Required__ - A MongoDB query object.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#find) for more information. Supported settings are:
|
||||
- `limit: number`: Sets the limit of documents returned in the query.
|
||||
- `sort array | object`: Set to sort the documents coming back from the query.
|
||||
- `projection: object`: The fields to return in the query. Object of fields to either include or exclude (one of, not both), `{'a':1, 'b': 1}` or `{'a': 0, 'b': 0}`.
|
||||
- `skip: number`: Set to skip N documents ahead in your query (useful for pagination).
|
||||
- `hint: object`: Tell the query to use specific indexes in the query. Object of indexes to use, `{'_id':1}`.
|
||||
- `comment: string`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the query. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `readPreference: string | object`: The preferred read preference.
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the query.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#find) for more information. Supported settings are:
|
||||
- `allowDiskUse: boolean`: Allows disk use for blocking sort operations exceeding 100MB memory. (MongoDB 3.2 or higher)
|
||||
- `allowPartialResults: boolean`: For queries against a sharded collection, allows the command (or subsequent getMore commands) to return partial results, rather than an error, if one or more queried shards are available.
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `awaitData: boolean`: Specify if the cursor is a tailable-await cursor. Requires `tailable` to be true.
|
||||
- `batchSize: number`: Set the batchSize for the getMoreCommand when iterating over the query results.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `checkKeys: boolean`: The serializer will check if keys are valid.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `comment: string | object`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the query. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: boolean`: Specifies the verbosity mode for the explain output.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `hint: string | object`: Tell the query to use specific indexes in the query. Object of indexes to use, `{'_id':1}`.
|
||||
- `ignoreUndefined: boolean`: Default: `true` - Serialize will not emit undefined fields.
|
||||
- `let: object`: Map of parameter names and values that can be accessed using `$$var` (requires MongoDB 5.0).
|
||||
- `limit: number`: Sets the limit of documents returned in the query.
|
||||
- `max: object`: The exclusive upper bound for a specific index.
|
||||
- `maxAwaitTimeMS: number`: The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query. Requires `tailable` and `awaitData` to be true.
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the command.
|
||||
- `min: object`: The inclusive lower bound for a specific index.
|
||||
- `noCursorTimeout: boolean`: The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to prevent that.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `projection: object`: The fields to return in the query. Object of fields to either include or exclude (one of, not both), `{'a':1, 'b': 1}` or `{'a': 0, 'b': 0}`.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: string | object`: The preferred read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `returnKey: boolean`: If true, returns only the index keys in the resulting documents.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `showRecordId: boolean`: Determine whether to return the record identifier for each document. If true, adds a field $recordId to the returned documents.
|
||||
- `singleBatch: boolean`: Default: `false` - Determines whether to close the cursor after the first batch.
|
||||
- `skip: number`: Set to skip N documents ahead in your query (useful for pagination).
|
||||
- `sort: array | object`: Set to sort the documents coming back from the query.
|
||||
- `tailable: boolean`: Specify if the cursor is tailable.
|
||||
- `timeout: boolean`: Specify if the cursor can timeout.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -245,16 +314,43 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `query: object`: __Required__ - A MongoDB query object.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#find) for more information. Supported settings are:
|
||||
- `limit: number`: Sets the limit of documents returned in the query.
|
||||
- `sort: array | object`: Set to sort the documents coming back from the query.
|
||||
- `projection: object`: The fields to return in the query. Object of fields to either include or exclude (one of, not both), `{'a':1, 'b': 1}` or `{'a': 0, 'b': 0}`.
|
||||
- `skip: number`: Set to skip N documents ahead in your query (useful for pagination).
|
||||
- `hint: object`: Tell the query to use specific indexes in the query. Object of indexes to use, `{'_id':1}`.
|
||||
- `comment: string`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the query. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `readPreference: string | object`: The preferred read preference.
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the query.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#findone) for more information. Supported settings are:
|
||||
- `allowDiskUse: boolean`: Allows disk use for blocking sort operations exceeding 100MB memory. (MongoDB 3.2 or higher)
|
||||
- `allowPartialResults: boolean`: For queries against a sharded collection, allows the command (or subsequent getMore commands) to return partial results, rather than an error, if one or more queried shards are available.
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `awaitData: boolean`: Specify if the cursor is a tailable-await cursor. Requires `tailable` to be true.
|
||||
- `batchSize: number`: Set the batchSize for the getMoreCommand when iterating over the query results.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `checkKeys: boolean`: The serializer will check if keys are valid.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `comment: string | object`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the query. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: boolean`: Specifies the verbosity mode for the explain output.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `hint: string | object`: Tell the query to use specific indexes in the query. Object of indexes to use, `{'_id':1}`.
|
||||
- `ignoreUndefined: boolean`: Default: `true` - Serialize will not emit undefined fields.
|
||||
- `let: object`: Map of parameter names and values that can be accessed using `$$var` (requires MongoDB 5.0).
|
||||
- `limit: number`: Sets the limit of documents returned in the query.
|
||||
- `max: object`: The exclusive upper bound for a specific index.
|
||||
- `maxAwaitTimeMS: number`: The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query. Requires `tailable` and `awaitData` to be true.
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the command.
|
||||
- `min: object`: The inclusive lower bound for a specific index.
|
||||
- `noCursorTimeout: boolean`: The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to prevent that.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `projection: object`: The fields to return in the query. Object of fields to either include or exclude (one of, not both), `{'a':1, 'b': 1}` or `{'a': 0, 'b': 0}`.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: string | object`: The preferred read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `returnKey: boolean`: If true, returns only the index keys in the resulting documents.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `showRecordId: boolean`: Determine whether to return the record identifier for each document. If true, adds a field $recordId to the returned documents.
|
||||
- `singleBatch: boolean`: Default: `false` - Determines whether to close the cursor after the first batch.
|
||||
- `skip: number`: Set to skip N documents ahead in your query (useful for pagination).
|
||||
- `sort: array | object`: Set to sort the documents coming back from the query.
|
||||
- `tailable: boolean`: Specify if the cursor is tailable.
|
||||
- `timeout: boolean`: Specify if the cursor can timeout.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -276,15 +372,27 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `docs: object[]`: __Required__ - The array of documents to be inserted.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#insertMany) for more information. Supported settings are:
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#insertmany) for more information. Supported settings are:
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `bypassDocumentValidation: boolean`: Default: `false` - Allow driver to bypass schema validation in MongoDB 3.2 or higher
|
||||
- `checkKeys: boolean`: Default: `true` - If true, will throw if bson documents start with $ or include a . in any key value.
|
||||
- `forceServerObjectId: boolean`: Default: `false` - Force server to assign _id values instead of driver.
|
||||
- `j: boolean`: Default: `false` - Specify a journal write concern.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `comment: string | object`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the query. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: object`: Specifies the verbosity mode for the explain output.
|
||||
- `forcesServerObjectId: boolean`: Default: `false` - Force server to assign _id values instead of driver.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `ignoreUndefined: boolean`: Default: `false` - Specify if the BSON serializer should ignore undefined fields.
|
||||
- `w: number | string`: The write concern.
|
||||
- `wtimeout: number`: The write concern timeout.
|
||||
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the command.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `ordered: boolean`: If true, when an insert fails, don't execute the remaining writes. If false, continue with remaining inserts when one fails.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: object`: The preferred read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -311,14 +419,26 @@ _ref:
|
||||
|
||||
#### Properties
|
||||
- `doc: object`: __Required__ - The document to be inserted.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#insertOne) for more information. Supported settings are:
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#insertone) for more information. Supported settings are:
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `bypassDocumentValidation: boolean`: Default: `false` - Allow driver to bypass schema validation in MongoDB 3.2 or higher
|
||||
- `checkKeys: boolean`: Default: `true` - If true, will throw if bson documents start with $ or include a . in any key value.
|
||||
- `forceServerObjectId: boolean`: Default: `false` - Force server to assign _id values instead of driver.
|
||||
- `j: boolean`: Default: `false` - Specify a journal write concern.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `comment: string | object`: Add a [comment](https://docs.mongodb.com/manual/reference/operator/query/comment/index.html) to the query. These comments are visible in the MongoDB profile log, making them easier to interpret.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: object`: Specifies the verbosity mode for the explain output.
|
||||
- `forcesServerObjectId: boolean`: Default: `false` - Force server to assign _id values instead of driver.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `ignoreUndefined: boolean`: Default: `false` - Specify if the BSON serializer should ignore undefined fields.
|
||||
- `w: number | string`: The write concern.
|
||||
- `wtimeout: number`: The write concern timeout.
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the command.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: object`: The preferred read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
@ -382,7 +502,6 @@ _ref:
|
||||
requests:
|
||||
- id: set_resolved
|
||||
type: MongoDBUpdateMany
|
||||
connectionId: my_mongodb_collection_id
|
||||
properties:
|
||||
filter:
|
||||
score:
|
||||
@ -399,19 +518,29 @@ _ref:
|
||||
#### Properties
|
||||
- `filter: object`: __Required__ - The filter used to select the document to update.
|
||||
- `update: object | object[]`: __Required__ - The update operations to be applied to the document.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/3.3/api/Collection.html#updateOne) for more information. Supported settings are:
|
||||
- `arrayFilters: string[]`: _Array_ - Array filters for the [`$[<identifier>]`](https://docs.mongodb.com/manual/reference/operator/update/positional-filtered/) array update operator.
|
||||
- `options: object`: Optional settings. See the [driver docs](https://mongodb.github.io/node-mongodb-native/4.0/classes/collection.html#updateone) for more information. Supported settings are:
|
||||
- `arrayFilters: object[]`: _Array_ - Array filters for the [`$[<identifier>]`](https://docs.mongodb.com/manual/reference/operator/update/positional-filtered/) array update operator.
|
||||
- `authdb: string`: Specifies the authentication information to be used.
|
||||
- `bsonRegExp: boolean`: Return the BSON regular expressions as BSONRegExp instances.
|
||||
- `bypassDocumentValidation: boolean`: Default: `false` - Allow driver to bypass schema validation in MongoDB 3.2 or higher.
|
||||
- `checkKeys: boolean`: Default: `false` - If true, will throw if bson documents start with $ or include a . in any key value.
|
||||
- `collation: object`: Specify collation (MongoDB 3.4 or higher) settings for update operation.
|
||||
- `forceServerObjectId: boolean`: Force server to assign _id values instead of driver.
|
||||
- `hint: object`: An optional hint for query optimization.
|
||||
- `comment: string | object`: A user-provided comment to attach to this command.
|
||||
- `dbName: string`: The database name.
|
||||
- `explain: object`: Specifies the verbosity mode for the explain output.
|
||||
- `fullResponse: boolean`: Return the full server response for the command.
|
||||
- `hint: string | object`: An optional hint for query optimization.
|
||||
- `ignoreUndefined: boolean`: Default: `false` - Specify if the BSON serializer should ignore undefined fields.
|
||||
- `j: boolean`: Specify a journal write concern.
|
||||
- `let: object`: Map of parameter names and values that can be accessed using `$$var` (requires MongoDB 5.0).
|
||||
- `maxTimeMS: number`: Number of milliseconds to wait before aborting the command.
|
||||
- `noResponse: boolean`: Admin command option.
|
||||
- `readConcern: object`: Specify a read concern and level for the collection. (only MongoDB 3.2 or higher supported).
|
||||
- `readPreference: object`: The preferred read preference.
|
||||
- `retryWrites: boolean`: Should retry failed writes.
|
||||
- `serializeFunctions: boolean`: Default: `false` - Serialize the javascript functions.
|
||||
- `upsert: boolean`: Default: `false` - Insert document if no match is found.
|
||||
- `w: integer | string`: The write concern
|
||||
- `wtimeout: integer`: The write concern timeout.
|
||||
|
||||
- `willRetryWrites: boolean`: Option whether to retry writes.
|
||||
- `writeConcern: object`: An object that expresses the write concern.
|
||||
|
||||
#### Examples
|
||||
|
||||
|
||||
@ -43,7 +43,7 @@
|
||||
},
|
||||
"dependencies": {
|
||||
"@lowdefy/helpers": "4.0.0-alpha.6",
|
||||
"mongodb": "3.7.3",
|
||||
"mongodb": "4.4.0",
|
||||
"saslprep": "1.0.3"
|
||||
},
|
||||
"devDependencies": {
|
||||
|
||||
@ -69,7 +69,7 @@ test('aggregation connection error', async () => {
|
||||
read: true,
|
||||
};
|
||||
await expect(MongoDBAggregation({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
|
||||
@ -30,8 +30,8 @@ async function MongodbDeleteMany({ request, connection }) {
|
||||
throw error;
|
||||
}
|
||||
await client.close();
|
||||
const { deletedCount } = serialize(res);
|
||||
return { deletedCount };
|
||||
const { acknowledged, deletedCount } = serialize(res);
|
||||
return { acknowledged, deletedCount };
|
||||
}
|
||||
|
||||
MongodbDeleteMany.schema = schema;
|
||||
|
||||
@ -50,6 +50,7 @@ test('deleteMany - Single Document', async () => {
|
||||
};
|
||||
const res = await MongoDBDeleteMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: true,
|
||||
deletedCount: 1,
|
||||
});
|
||||
});
|
||||
@ -66,6 +67,7 @@ test('deleteMany - Multiple Documents', async () => {
|
||||
};
|
||||
const res = await MongoDBDeleteMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: true,
|
||||
deletedCount: 3,
|
||||
});
|
||||
});
|
||||
@ -82,6 +84,7 @@ test('deleteMany - Multiple Documents one field', async () => {
|
||||
};
|
||||
const res = await MongoDBDeleteMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: true,
|
||||
deletedCount: 3,
|
||||
});
|
||||
});
|
||||
@ -97,7 +100,7 @@ test('deleteMany connection error', async () => {
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBDeleteMany({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
@ -112,9 +115,11 @@ test('deleteMany mongodb error', async () => {
|
||||
collection,
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBDeleteMany({ request, connection })).rejects.toThrow(
|
||||
'w has to be a number or a string'
|
||||
);
|
||||
const res = await MongoDBDeleteMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: false,
|
||||
deletedCount: undefined,
|
||||
});
|
||||
});
|
||||
|
||||
test('checkRead should be false', async () => {
|
||||
|
||||
@ -30,8 +30,8 @@ async function MongodbDeleteOne({ request, connection }) {
|
||||
throw error;
|
||||
}
|
||||
await client.close();
|
||||
const { deletedCount } = serialize(res);
|
||||
return { deletedCount };
|
||||
const { acknowledged, deletedCount } = serialize(res);
|
||||
return { acknowledged, deletedCount };
|
||||
}
|
||||
|
||||
MongodbDeleteOne.schema = schema;
|
||||
|
||||
@ -42,6 +42,7 @@ test('deleteOne', async () => {
|
||||
};
|
||||
const res = await MongoDBDeleteOne({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: true,
|
||||
deletedCount: 1,
|
||||
});
|
||||
});
|
||||
@ -57,7 +58,7 @@ test('deleteOne connection error', async () => {
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBDeleteOne({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
@ -80,9 +81,11 @@ test('deleteOne catch invalid options', async () => {
|
||||
collection,
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBDeleteOne({ request, connection })).rejects.toThrow(
|
||||
'w has to be a number or a string'
|
||||
);
|
||||
const res = await MongoDBDeleteOne({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: false,
|
||||
deletedCount: undefined,
|
||||
});
|
||||
});
|
||||
|
||||
test('request not an object', async () => {
|
||||
|
||||
@ -86,7 +86,7 @@ test('findOne connection error', async () => {
|
||||
read: true,
|
||||
};
|
||||
await expect(MongoDBFindOne({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
|
||||
@ -30,8 +30,8 @@ async function MongodbInsertMany({ request, connection }) {
|
||||
throw error;
|
||||
}
|
||||
await client.close();
|
||||
const { insertedCount, ops } = serialize(res);
|
||||
return { insertedCount, ops };
|
||||
const { acknowledged, insertedCount } = serialize(res);
|
||||
return { acknowledged, insertedCount };
|
||||
}
|
||||
|
||||
MongodbInsertMany.schema = schema;
|
||||
|
||||
@ -41,18 +41,8 @@ test('insertMany', async () => {
|
||||
};
|
||||
const res = await MongoDBInsertMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: true,
|
||||
insertedCount: 3,
|
||||
ops: [
|
||||
{
|
||||
_id: 'insertMany1-1',
|
||||
},
|
||||
{
|
||||
_id: 'insertMany1-2',
|
||||
},
|
||||
{
|
||||
_id: 'insertMany1-3',
|
||||
},
|
||||
],
|
||||
});
|
||||
});
|
||||
|
||||
@ -69,15 +59,8 @@ test('insertMany options', async () => {
|
||||
};
|
||||
const res = await MongoDBInsertMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
acknowledged: true,
|
||||
insertedCount: 2,
|
||||
ops: [
|
||||
{
|
||||
_id: 'insertMany2-1',
|
||||
},
|
||||
{
|
||||
_id: 'insertMany2-2',
|
||||
},
|
||||
],
|
||||
});
|
||||
});
|
||||
|
||||
@ -90,7 +73,7 @@ test('insertMany connection error', async () => {
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBInsertMany({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
|
||||
@ -30,8 +30,8 @@ async function MongodbInsertOne({ request, connection }) {
|
||||
throw error;
|
||||
}
|
||||
await client.close();
|
||||
const { insertedCount, insertedId, ops } = serialize(res);
|
||||
return { insertedCount, insertedId, ops };
|
||||
const { acknowledged, insertedId } = serialize(res);
|
||||
return { acknowledged, insertedId };
|
||||
}
|
||||
|
||||
MongodbInsertOne.schema = schema;
|
||||
|
||||
@ -40,13 +40,8 @@ test('insertOne', async () => {
|
||||
};
|
||||
const res = await MongoDBInsertOne({ request, connection });
|
||||
expect(res).toEqual({
|
||||
insertedCount: 1,
|
||||
acknowledged: true,
|
||||
insertedId: 'insertOne',
|
||||
ops: [
|
||||
{
|
||||
_id: 'insertOne',
|
||||
},
|
||||
],
|
||||
});
|
||||
});
|
||||
|
||||
@ -63,13 +58,8 @@ test('insertOne options', async () => {
|
||||
};
|
||||
const res = await MongoDBInsertOne({ request, connection });
|
||||
expect(res).toEqual({
|
||||
insertedCount: 1,
|
||||
acknowledged: true,
|
||||
insertedId: 'insertOne_options',
|
||||
ops: [
|
||||
{
|
||||
_id: 'insertOne_options',
|
||||
},
|
||||
],
|
||||
});
|
||||
});
|
||||
|
||||
@ -82,7 +72,7 @@ test('insertOne connection error', async () => {
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBInsertOne({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
@ -123,16 +113,8 @@ test('insertOne insert a date', async () => {
|
||||
};
|
||||
const res = await MongoDBInsertOne({ request, connection });
|
||||
expect(res).toEqual({
|
||||
insertedCount: 1,
|
||||
acknowledged: true,
|
||||
insertedId: 'insertOneDate',
|
||||
ops: [
|
||||
{
|
||||
_id: 'insertOneDate',
|
||||
date: {
|
||||
_date: 1577836800000,
|
||||
},
|
||||
},
|
||||
],
|
||||
});
|
||||
let client;
|
||||
let inserted;
|
||||
|
||||
@ -113,10 +113,7 @@ test('updateMany upsert', async () => {
|
||||
const res = await MongoDBUpdateMany({ request, connection });
|
||||
expect(res).toEqual({
|
||||
modifiedCount: 0,
|
||||
upsertedId: {
|
||||
_id: 'updateMany_upsert',
|
||||
index: 0,
|
||||
},
|
||||
upsertedId: 'updateMany_upsert',
|
||||
upsertedCount: 1,
|
||||
matchedCount: 0,
|
||||
});
|
||||
@ -175,7 +172,7 @@ test('updateMany connection error', async () => {
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBUpdateMany({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
|
||||
@ -65,10 +65,7 @@ test('updateOne upsert', async () => {
|
||||
const res = await MongoDBUpdateOne({ request, connection });
|
||||
expect(res).toEqual({
|
||||
modifiedCount: 0,
|
||||
upsertedId: {
|
||||
_id: 'updateOne_upsert',
|
||||
index: 0,
|
||||
},
|
||||
upsertedId: 'updateOne_upsert',
|
||||
upsertedCount: 1,
|
||||
matchedCount: 0,
|
||||
});
|
||||
@ -127,7 +124,7 @@ test('updateOne connection error', async () => {
|
||||
write: true,
|
||||
};
|
||||
await expect(MongoDBUpdateOne({ request, connection })).rejects.toThrow(
|
||||
'Invalid connection string'
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
|
||||
@ -14,8 +14,7 @@
|
||||
limitations under the License.
|
||||
*/
|
||||
|
||||
import Mongo from 'mongodb';
|
||||
const { MongoClient } = Mongo;
|
||||
import { MongoClient } from 'mongodb';
|
||||
|
||||
async function getCollection({ connection }) {
|
||||
let client;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
See the License for the specific language governing permissions and
|
||||
limitations under the License.
|
||||
*/
|
||||
import { MongoClient } from 'mongodb';
|
||||
import { MongoClient, Collection } from 'mongodb';
|
||||
|
||||
import getCollection from './getCollection.js';
|
||||
|
||||
@ -27,7 +27,7 @@ test('get collection', async () => {
|
||||
};
|
||||
const res = await getCollection({ connection });
|
||||
expect(res.client).toBeInstanceOf(MongoClient);
|
||||
expect(res.collection).toBeInstanceOf(MongoClient.connect.Collection);
|
||||
expect(res.collection).toBeInstanceOf(Collection);
|
||||
await res.client.close();
|
||||
});
|
||||
|
||||
@ -38,7 +38,7 @@ test('get collection, no databaseName, uses databaseUri', async () => {
|
||||
};
|
||||
const res = await getCollection({ connection });
|
||||
expect(res.client).toBeInstanceOf(MongoClient);
|
||||
expect(res.collection).toBeInstanceOf(MongoClient.connect.Collection);
|
||||
expect(res.collection).toBeInstanceOf(Collection);
|
||||
await res.client.close();
|
||||
});
|
||||
|
||||
@ -48,7 +48,9 @@ test('invalid databaseUri', async () => {
|
||||
databaseName: 'test',
|
||||
collection: 'getCollection',
|
||||
};
|
||||
await expect(() => getCollection({ connection })).rejects.toThrow('Invalid connection string');
|
||||
await expect(() => getCollection({ connection })).rejects.toThrow(
|
||||
'Invalid scheme, expected connection string to start with "mongodb://" or "mongodb+srv://"'
|
||||
);
|
||||
});
|
||||
|
||||
test('invalid databaseName', async () => {
|
||||
@ -58,7 +60,7 @@ test('invalid databaseName', async () => {
|
||||
collection: 'getCollection',
|
||||
};
|
||||
await expect(() => getCollection({ connection })).rejects.toThrow(
|
||||
'database name must be a string'
|
||||
'Database name must be a string'
|
||||
);
|
||||
});
|
||||
|
||||
@ -69,6 +71,6 @@ test('invalid collection', async () => {
|
||||
collection: {},
|
||||
};
|
||||
await expect(() => getCollection({ connection })).rejects.toThrow(
|
||||
'collection name must be a String'
|
||||
'Collection name must be a String'
|
||||
);
|
||||
});
|
||||
|
||||
@ -14,11 +14,9 @@
|
||||
limitations under the License.
|
||||
*/
|
||||
|
||||
import Mongo from 'mongodb';
|
||||
import { ObjectId } from 'mongodb';
|
||||
import { type } from '@lowdefy/helpers';
|
||||
|
||||
const { ObjectId } = Mongo;
|
||||
|
||||
function replacer(_, value) {
|
||||
if (type.isObject(value)) {
|
||||
Object.keys(value).forEach((key) => {
|
||||
|
||||
@ -14,7 +14,7 @@
|
||||
limitations under the License.
|
||||
*/
|
||||
|
||||
import { ObjectID } from 'mongodb';
|
||||
import { ObjectId } from 'mongodb';
|
||||
import { serialize, deserialize } from './serialize.js';
|
||||
|
||||
test('serialize dates', () => {
|
||||
@ -52,8 +52,8 @@ test('deserialize does not turn dates to strings', () => {
|
||||
|
||||
test('serialize mongodb object id', () => {
|
||||
const object = {
|
||||
objectid: ObjectID.createFromHexString('5e53d8403108c4b9fa51765d'),
|
||||
array: [ObjectID.createFromHexString('5e53d8403108c4b9fa51765d')],
|
||||
objectid: ObjectId.createFromHexString('5e53d8403108c4b9fa51765d'),
|
||||
array: [ObjectId.createFromHexString('5e53d8403108c4b9fa51765d')],
|
||||
};
|
||||
expect(serialize(object)).toEqual({
|
||||
objectid: { _oid: '5e53d8403108c4b9fa51765d' },
|
||||
@ -67,8 +67,8 @@ test('deserialize mongodb object id', () => {
|
||||
array: [{ _oid: '5e53d8403108c4b9fa51765d' }],
|
||||
};
|
||||
expect(deserialize(object)).toEqual({
|
||||
objectid: ObjectID.createFromHexString('5e53d8403108c4b9fa51765d'),
|
||||
array: [ObjectID.createFromHexString('5e53d8403108c4b9fa51765d')],
|
||||
objectid: ObjectId.createFromHexString('5e53d8403108c4b9fa51765d'),
|
||||
array: [ObjectId.createFromHexString('5e53d8403108c4b9fa51765d')],
|
||||
});
|
||||
});
|
||||
|
||||
|
||||
93
yarn.lock
93
yarn.lock
@ -2327,7 +2327,7 @@ __metadata:
|
||||
"@swc/core": 1.2.135
|
||||
"@swc/jest": 0.2.17
|
||||
jest: 27.5.1
|
||||
mongodb: 3.7.3
|
||||
mongodb: 4.4.0
|
||||
saslprep: 1.0.3
|
||||
languageName: unknown
|
||||
linkType: soft
|
||||
@ -3703,6 +3703,23 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"@types/webidl-conversions@npm:*":
|
||||
version: 6.1.1
|
||||
resolution: "@types/webidl-conversions@npm:6.1.1"
|
||||
checksum: bd0faad4dfec232010d96a42fbd7b5ac4df557899050a6676a75d30ced8553f19e5a3c747fd2b4317f2810d4cf5d2d6dd47ad22ecfb9e6b21119aba678b8897f
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"@types/whatwg-url@npm:^8.2.1":
|
||||
version: 8.2.1
|
||||
resolution: "@types/whatwg-url@npm:8.2.1"
|
||||
dependencies:
|
||||
"@types/node": "*"
|
||||
"@types/webidl-conversions": "*"
|
||||
checksum: 975987a9ca14a8d5a883523acb4fa0df7760cd8ca8dee56cd57753821e56060bfbead94df84f4504fe0b4270776d81cbb40fcd1f8643dab86da3a9abe926fb5c
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"@types/yargs-parser@npm:*":
|
||||
version: 20.2.1
|
||||
resolution: "@types/yargs-parser@npm:20.2.1"
|
||||
@ -4677,6 +4694,15 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"bson@npm:^4.6.1":
|
||||
version: 4.6.1
|
||||
resolution: "bson@npm:4.6.1"
|
||||
dependencies:
|
||||
buffer: ^5.6.0
|
||||
checksum: 32c38400b0c5f85cf22c28b9f9bbc63b3c090c23a749a8c159db975f225161a7fe776f8a18ed1da3f58a9e7496ce2b7935753e9471f17c614bf02ebab145e052
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"buffer-alloc-unsafe@npm:^1.1.0":
|
||||
version: 1.1.0
|
||||
resolution: "buffer-alloc-unsafe@npm:1.1.0"
|
||||
@ -4740,7 +4766,7 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"buffer@npm:^5.2.1, buffer@npm:^5.5.0":
|
||||
"buffer@npm:^5.2.1, buffer@npm:^5.5.0, buffer@npm:^5.6.0":
|
||||
version: 5.7.1
|
||||
resolution: "buffer@npm:5.7.1"
|
||||
dependencies:
|
||||
@ -5927,6 +5953,13 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"denque@npm:^2.0.1":
|
||||
version: 2.0.1
|
||||
resolution: "denque@npm:2.0.1"
|
||||
checksum: ec398d1e3c6c8d4f5213dcf9ad74d7faa3b461e29a0019c9742b49a97ac5e16aa7134db45fa9d841e318e7722dd1ba670a474fde9a5b0d870b3a5fc6fe914c30
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"depd@npm:^1.1.2":
|
||||
version: 1.1.2
|
||||
resolution: "depd@npm:1.1.2"
|
||||
@ -10746,6 +10779,16 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"mongodb-connection-string-url@npm:^2.4.1":
|
||||
version: 2.4.2
|
||||
resolution: "mongodb-connection-string-url@npm:2.4.2"
|
||||
dependencies:
|
||||
"@types/whatwg-url": ^8.2.1
|
||||
whatwg-url: ^11.0.0
|
||||
checksum: aed2718840c79f8d6be35309e308bf4466a009256da6b02e6212abeef39ae27bf6101273580696e246e51ee4f7471e2d938c44e8f8a5194982092f692b37c571
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"mongodb-memory-server-core@npm:7.3.6":
|
||||
version: 7.3.6
|
||||
resolution: "mongodb-memory-server-core@npm:7.3.6"
|
||||
@ -10781,7 +10824,23 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"mongodb@npm:3.7.3, mongodb@npm:^3.6.9":
|
||||
"mongodb@npm:4.4.0":
|
||||
version: 4.4.0
|
||||
resolution: "mongodb@npm:4.4.0"
|
||||
dependencies:
|
||||
bson: ^4.6.1
|
||||
denque: ^2.0.1
|
||||
mongodb-connection-string-url: ^2.4.1
|
||||
saslprep: ^1.0.3
|
||||
socks: ^2.6.1
|
||||
dependenciesMeta:
|
||||
saslprep:
|
||||
optional: true
|
||||
checksum: e485927d1def94f28564bdcb98d82144914bf23854e8bd15437fcef0d9a36f36997f7e97e0aad730ebf299c6a919430669198e02b5e2f4410f74a4002409b182
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"mongodb@npm:^3.6.9":
|
||||
version: 3.7.3
|
||||
resolution: "mongodb@npm:3.7.3"
|
||||
dependencies:
|
||||
@ -13857,7 +13916,7 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"saslprep@npm:1.0.3, saslprep@npm:^1.0.0":
|
||||
"saslprep@npm:1.0.3, saslprep@npm:^1.0.0, saslprep@npm:^1.0.3":
|
||||
version: 1.0.3
|
||||
resolution: "saslprep@npm:1.0.3"
|
||||
dependencies:
|
||||
@ -14958,6 +15017,15 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"tr46@npm:^3.0.0":
|
||||
version: 3.0.0
|
||||
resolution: "tr46@npm:3.0.0"
|
||||
dependencies:
|
||||
punycode: ^2.1.1
|
||||
checksum: 44c3cc6767fb800490e6e9fd64fd49041aa4e49e1f6a012b34a75de739cc9ed3a6405296072c1df8b6389ae139c5e7c6496f659cfe13a04a4bff3a1422981270
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"tr46@npm:~0.0.3":
|
||||
version: 0.0.3
|
||||
resolution: "tr46@npm:0.0.3"
|
||||
@ -15584,6 +15652,13 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"webidl-conversions@npm:^7.0.0":
|
||||
version: 7.0.0
|
||||
resolution: "webidl-conversions@npm:7.0.0"
|
||||
checksum: f05588567a2a76428515333eff87200fae6c83c3948a7482ebb109562971e77ef6dc49749afa58abb993391227c5697b3ecca52018793e0cb4620a48f10bd21b
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"whatwg-encoding@npm:^1.0.5":
|
||||
version: 1.0.5
|
||||
resolution: "whatwg-encoding@npm:1.0.5"
|
||||
@ -15600,6 +15675,16 @@ __metadata:
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"whatwg-url@npm:^11.0.0":
|
||||
version: 11.0.0
|
||||
resolution: "whatwg-url@npm:11.0.0"
|
||||
dependencies:
|
||||
tr46: ^3.0.0
|
||||
webidl-conversions: ^7.0.0
|
||||
checksum: ed4826aaa57e66bb3488a4b25c9cd476c46ba96052747388b5801f137dd740b73fde91ad207d96baf9f17fbcc80fc1a477ad65181b5eb5fa718d27c69501d7af
|
||||
languageName: node
|
||||
linkType: hard
|
||||
|
||||
"whatwg-url@npm:^5.0.0":
|
||||
version: 5.0.0
|
||||
resolution: "whatwg-url@npm:5.0.0"
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user