|
@@ -208,11 +208,11 @@ SearchClient.prototype.addAllPages = function()
|
|
|
var self = this;
|
|
var self = this;
|
|
|
var offset = 0;
|
|
var offset = 0;
|
|
|
var Page = this.crowi.model('Page');
|
|
var Page = this.crowi.model('Page');
|
|
|
- var stream = Page.getStreamOfFindAll();
|
|
|
|
|
|
|
+ var cursor = Page.getStreamOfFindAll();
|
|
|
var body = [];
|
|
var body = [];
|
|
|
|
|
|
|
|
return new Promise(function(resolve, reject) {
|
|
return new Promise(function(resolve, reject) {
|
|
|
- stream.on('data', function (doc) {
|
|
|
|
|
|
|
+ cursor.on('data', function (doc) {
|
|
|
if (!doc.creator || !doc.revision || !self.shouldIndexed(doc)) {
|
|
if (!doc.creator || !doc.revision || !self.shouldIndexed(doc)) {
|
|
|
debug('Skipped', doc.path);
|
|
debug('Skipped', doc.path);
|
|
|
return ;
|
|
return ;
|
|
@@ -221,7 +221,7 @@ SearchClient.prototype.addAllPages = function()
|
|
|
self.prepareBodyForCreate(body, doc);
|
|
self.prepareBodyForCreate(body, doc);
|
|
|
}).on('error', function (err) {
|
|
}).on('error', function (err) {
|
|
|
// TODO: handle err
|
|
// TODO: handle err
|
|
|
- debug('Error stream:', err);
|
|
|
|
|
|
|
+ debug('Error cursor:', err);
|
|
|
}).on('close', function () {
|
|
}).on('close', function () {
|
|
|
// all done
|
|
// all done
|
|
|
|
|
|