Compare commits
2 Commits
developmen
...
test/delim
Author | SHA1 | Date |
---|---|---|
philipyoo | 15064a5cb0 | |
philipyoo | e7bc6c1fb2 |
|
@ -51,6 +51,7 @@ class DelimiterMaster extends Delimiter {
|
||||||
if ((this.prefix && !key.startsWith(this.prefix))
|
if ((this.prefix && !key.startsWith(this.prefix))
|
||||||
|| (typeof this[this.nextContinueMarker] === 'string' &&
|
|| (typeof this[this.nextContinueMarker] === 'string' &&
|
||||||
key <= this[this.nextContinueMarker])) {
|
key <= this[this.nextContinueMarker])) {
|
||||||
|
console.log('skip 1')
|
||||||
return FILTER_SKIP;
|
return FILTER_SKIP;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -75,8 +76,9 @@ class DelimiterMaster extends Delimiter {
|
||||||
* */
|
* */
|
||||||
if (key === this.prvKey || key === this[this.nextContinueMarker] ||
|
if (key === this.prvKey || key === this[this.nextContinueMarker] ||
|
||||||
(this.delimiter &&
|
(this.delimiter &&
|
||||||
key.startsWith(this[this.nextContinueMarker]))) {
|
key.startsWith(`${this[this.nextContinueMarker]}${this.delimiter}`))) {
|
||||||
/* master version already filtered */
|
/* master version already filtered */
|
||||||
|
console.log('skip 2')
|
||||||
return FILTER_SKIP;
|
return FILTER_SKIP;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -89,6 +91,7 @@ class DelimiterMaster extends Delimiter {
|
||||||
* MongoClient). */
|
* MongoClient). */
|
||||||
this.prvKey = undefined;
|
this.prvKey = undefined;
|
||||||
this.prvPHDKey = key;
|
this.prvPHDKey = key;
|
||||||
|
console.log('accept 1')
|
||||||
return FILTER_ACCEPT;
|
return FILTER_ACCEPT;
|
||||||
}
|
}
|
||||||
if (Version.isDeleteMarker(value)) {
|
if (Version.isDeleteMarker(value)) {
|
||||||
|
@ -102,9 +105,11 @@ class DelimiterMaster extends Delimiter {
|
||||||
* follow. */
|
* follow. */
|
||||||
if (key === this.prvPHDKey) {
|
if (key === this.prvPHDKey) {
|
||||||
this.prvKey = undefined;
|
this.prvKey = undefined;
|
||||||
|
console.log('accept 2')
|
||||||
return FILTER_ACCEPT;
|
return FILTER_ACCEPT;
|
||||||
}
|
}
|
||||||
this.prvKey = key;
|
this.prvKey = key;
|
||||||
|
console.log('skip 3')
|
||||||
return FILTER_SKIP;
|
return FILTER_SKIP;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -131,8 +136,10 @@ class DelimiterMaster extends Delimiter {
|
||||||
if (index === this[this.nextContinueMarker].length - 1) {
|
if (index === this[this.nextContinueMarker].length - 1) {
|
||||||
return this[this.nextContinueMarker];
|
return this[this.nextContinueMarker];
|
||||||
}
|
}
|
||||||
|
console.log(`skipping: ${this[this.nextContinueMarker] + VID_SEP}`)
|
||||||
return this[this.nextContinueMarker] + VID_SEP;
|
return this[this.nextContinueMarker] + VID_SEP;
|
||||||
}
|
}
|
||||||
|
console.log('skipping: none')
|
||||||
return SKIP_NONE;
|
return SKIP_NONE;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -919,6 +919,7 @@ class MongoClientInterface {
|
||||||
|
|
||||||
stream
|
stream
|
||||||
.on('data', e => {
|
.on('data', e => {
|
||||||
|
console.log(JSON.stringify(e));
|
||||||
skip.filter(e);
|
skip.filter(e);
|
||||||
})
|
})
|
||||||
.on('error', err => {
|
.on('error', err => {
|
||||||
|
|
Loading…
Reference in New Issue