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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
"use strict";
Components.utils.import("resource://gre/modules/osfile.jsm");
Components.utils.import("resource://gre/modules/FileUtils.jsm");
Components.utils.import("resource://gre/modules/NetUtil.jsm");
Components.utils.import("resource://gre/modules/Services.jsm");
Components.utils.import("resource://gre/modules/Promise.jsm");
Components.utils.import("resource://gre/modules/Task.jsm");
function run_test() {
do_test_pending();
run_next_test();
}
/**
* A file that we know exists and that can be used for reading.
*/
var EXISTING_FILE = "test_osfile_async_copy.js";
/**
* Fetch asynchronously the contents of a file using xpcom.
*
* Used for comparing xpcom-based results to os.file-based results.
*
* @param {string} path The _absolute_ path to the file.
* @return {promise}
* @resolves {string} The contents of the file.
*/
var reference_fetch_file = function reference_fetch_file(path) {
let promise = Promise.defer();
let file = new FileUtils.File(path);
NetUtil.asyncFetch({
uri: NetUtil.newURI(file),
loadUsingSystemPrincipal: true
}, function(stream, status) {
if (!Components.isSuccessCode(status)) {
promise.reject(status);
return;
}
let result, reject;
try {
result = NetUtil.readInputStreamToString(stream, stream.available());
} catch (x) {
reject = x;
}
stream.close();
if (reject) {
promise.reject(reject);
} else {
promise.resolve(result);
}
});
return promise.promise;
};
/**
* Compare asynchronously the contents two files using xpcom.
*
* Used for comparing xpcom-based results to os.file-based results.
*
* @param {string} a The _absolute_ path to the first file.
* @param {string} b The _absolute_ path to the second file.
*
* @resolves {null}
*/
var reference_compare_files = function reference_compare_files(a, b) {
let a_contents = yield reference_fetch_file(a);
let b_contents = yield reference_fetch_file(b);
// Not using do_check_eq to avoid dumping the whole file to the log.
// It is OK to === compare here, as both variables contain a string.
do_check_true(a_contents === b_contents);
};
/**
* Test to ensure that OS.File.copy works.
*/
function test_copymove(options = {}) {
let source = OS.Path.join((yield OS.File.getCurrentDirectory()),
EXISTING_FILE);
let dest = OS.Path.join(OS.Constants.Path.tmpDir,
"test_osfile_async_copy_dest.tmp");
let dest2 = OS.Path.join(OS.Constants.Path.tmpDir,
"test_osfile_async_copy_dest2.tmp");
try {
// 1. Test copy.
yield OS.File.copy(source, dest, options);
yield reference_compare_files(source, dest);
// 2. Test subsequent move.
yield OS.File.move(dest, dest2);
yield reference_compare_files(source, dest2);
// 3. Check that the moved file was really moved.
do_check_eq((yield OS.File.exists(dest)), false);
} finally {
try {
yield OS.File.remove(dest);
} catch (ex if ex.becauseNoSuchFile) {
// ignore
}
try {
yield OS.File.remove(dest2);
} catch (ex if ex.becauseNoSuchFile) {
// ignore
}
}
}
// Regular copy test.
add_task(test_copymove);
// Userland copy test.
add_task(test_copymove.bind(null, {unixUserland: true}));
add_task(do_test_finished);
|
