github/meteor
1
1
Fork 0
mirror of https://github.com/meteor/meteor.git synced 2026-05-02 03:01:46 -04:00
Code Issues Packages Projects Releases Wiki Activity

- fix test: 'mongo-livedata - transform sets _id if not present, MONGO | STRING'

Browse Source
This commit is contained in:
denihs
2023-02-15 09:29:37 -04:00
parent 7f0257abae
commit aaa0b15ec6
1 changed files with 34 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

60
packages/mongo/mongo_livedata_tests.js
View File

@@ -1796,33 +1796,41 @@ _.each( ['STRING', 'MONGO'], function(idGeneration) {
]
);
testAsyncMulti('mongo-livedata - transform sets _id if not present, ' + idGeneration, [
function (test, expect) {
var self = this;
var justId = function (doc) {
return _.omit(doc, '_id');
};
TRANSFORMS["justId"] = justId;
var collectionOptions = {
idGeneration: idGeneration,
transform: justId,
transformName: "justId"
};
this.collectionName = Random.id();
if (Meteor.isClient) {
Meteor.call('createInsecureCollection', this.collectionName, collectionOptions);
Meteor.subscribe('c-' + this.collectionName, expect());
}
}, function (test, expect) {
var self = this;
self.coll = new Mongo.Collection(this.collectionName, collectionOptions);
self.coll.insert({}, expect(function (err, id) {
test.isFalse(err);
testAsyncMulti(
'mongo-livedata - transform sets _id if not present, ' + idGeneration,
[
function(test, expect) {
var justId = function(doc) {
return _.omit(doc, '_id');
};
TRANSFORMS['justId'] = justId;
var collectionOptions = {
idGeneration: idGeneration,
transform: justId,
transformName: 'justId',
};
this.collectionName = Random.id();
if (Meteor.isClient) {
Meteor.call(
'createInsecureCollection',
this.collectionName,
collectionOptions
);
Meteor.subscribe('c-' + this.collectionName, expect());
}
},
async function(test, expect) {
var self = this;
self.coll = new Mongo.Collection(
this.collectionName,
collectionOptions
);
const id = await self.coll.insertAsync({});
test.isTrue(id);
test.equal(self.coll.findOne()._id, id);
}));
}
]);
test.equal((await self.coll.findOneAsync())._id, id);
},
]
);
var bin = Base64.decode(
"TWFuIGlzIGRpc3Rpbmd1aXNoZWQsIG5vdCBvbmx5IGJ5IGhpcyBy" +