forked from Keyang/node-csvtojson
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy patherrorHandle.js
More file actions
80 lines (77 loc) · 2.29 KB
/
errorHandle.js
File metadata and controls
80 lines (77 loc) · 2.29 KB
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
var Converter = require("../libs/core/Converter.js");
var assert = require("assert");
var fs = require("fs");
describe("Converter error handling", function() {
it("should handle quote not closed", function(done) {
var rs = fs.createReadStream(__dirname + "/data/dataWithUnclosedQuotes");
var conv = new Converter({});
conv.on("error", function(err) {
assert(err.err === "unclosed_quote");
done();
});
rs.pipe(conv);
});
// it("should handle quote not closed in a forked process", function(done) {
// var rs = fs.createReadStream(__dirname + "/data/dataWithUnclosedQuotes");
// var conv = new Converter({
// fork: true
// });
// conv.on("error", function(err) {
// assert(err.err === "unclosed_quote");
// done();
// });
// rs.pipe(conv);
// });
// it("should handle max row exceed error", function(done) {
// var rs = fs.createReadStream(__dirname + "/data/dataWithUnclosedQuotes");
// var conv = new Converter({
// maxRowLength: 64
// });
// var tested = false;
// conv.on("error", function(err) {
// if (tested === false) {
// assert(err === "row_exceed");
// tested = true;
// done();
// }
// });
// rs.pipe(conv);
// });
// it("should handle max row exceed error in a forked process", function(done) {
// var rs = fs.createReadStream(__dirname + "/data/dataWithUnclosedQuotes");
// var conv = new Converter({
// maxRowLength: 64,
// fork:true
// });
// var tested = false;
// conv.on("error", function(err) {
// if (tested === false) {
// assert(err === "row_exceed");
// tested = true;
// done();
// }
// });
// rs.pipe(conv);
// });
it ("should handle column number mismatched error", function(done) {
var rs = fs.createReadStream(__dirname + "/data/dataWithMismatchedColumn");
var conv = new Converter({
checkColumn:true,
workerNum:1
});
var tested = false;
conv.on("error", function(err) {
if (tested === false) {
assert(err.err === "column_mismatched");
tested = true;
// done();
}
});
conv.on("json",function() {});
conv.on('done',function() {
assert(tested);
done();
});
rs.pipe(conv);
});
});