1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
// mongofiles_get.js; ensure that get command works as expected
var testName = 'mongofiles_get';
(function() {
jsTest.log('Testing mongofiles get command');
load('jstests/files/util/mongofiles_common.js');
load('jstests/libs/extended_assert.js');
var assert = extendedAssert;
var runTests = function(topology, passthrough) {
var t = topology.init(passthrough);
var conn = t.connection();
var db = conn.getDB('test');
var getFile = testName + (Math.random() + 1).toString(36).substring(7);
jsTest.log('Putting file with ' + passthrough.name + ' passthrough');
// ensure tool runs without error
assert.eq(runMongoProgram.apply(this, ['mongofiles',
'--port', conn.port,
'put', filesToInsert[0]]
.concat(passthrough.args)),
0, 'put 1 failed');
// ensure the file was inserted
assert.eq(1, db.fs.files.count(), 'unexpected fs.files count 1');
var fileId = db.fs.files.findOne()._id;
jsTest.log('Getting file with ' + passthrough.name + ' passthrough');
// ensure tool runs without error
assert.eq(runMongoProgram.apply(this, ['mongofiles',
'--port', conn.port,
'--local', getFile,
'get', filesToInsert[0]]
.concat(passthrough.args)),
0, 'get failed');
// ensure the retrieved file is exactly the same as that inserted
var actual = md5sumFile(filesToInsert[0]);
var expected = md5sumFile(getFile);
assert.eq(actual, expected, 'mismatched md5 sum - expected ' + expected + ' got ' + actual);
// ensure tool runs get_id without error
var idAsJSON = fileId.tojson();
if (_isWindows()) {
idAsJSON = '"' + idAsJSON.replace(/"/g, '\\"') + '"';
}
assert.eq(runMongoProgram.apply(this, ['mongofiles',
'--port', conn.port,
'--local', getFile,
'get_id', idAsJSON]
.concat(passthrough.args)),
0, 'get_id failed');
expected = md5sumFile(getFile);
assert.eq(actual, expected, 'mismatched md5 sum on _id - expected ' + expected + ' got ' + actual);
// clear the output buffer
clearRawMongoProgramOutput();
// test getting to stdout
assert.eq(runMongoProgram.apply(this, ['mongofiles',
'--port', conn.port,
'--local', '-',
'get', filesToInsert[0]]
.concat(passthrough.args)),
0, 'get stdout failed');
var expectedContent = "this is a text file";
assert.strContains.soon(expectedContent, rawMongoProgramOutput,
"stdout get didn't match expected file content");
t.stop();
};
// run with plain and auth passthroughs
passthroughs.forEach(function(passthrough) {
runTests(standaloneTopology, passthrough);
runTests(replicaSetTopology, passthrough);
runTests(shardedClusterTopology, passthrough);
});
}());
|
