MatrixChat: Add more detailed logging to the event crawler.
This commit is contained in:
parent
3f53691834
commit
1b63886a6b
1 changed files with 5 additions and 0 deletions
|
@ -2101,7 +2101,10 @@ export default createReactClass({
|
||||||
// here.
|
// here.
|
||||||
await sleep(3000);
|
await sleep(3000);
|
||||||
|
|
||||||
|
console.log("Seshat: Running the crawler loop.");
|
||||||
|
|
||||||
if (cancelled) {
|
if (cancelled) {
|
||||||
|
console.log("Seshat: Cancelling the crawler.");
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -2124,6 +2127,7 @@ export default createReactClass({
|
||||||
checkpoint.token, 100, checkpoint.direction);
|
checkpoint.token, 100, checkpoint.direction);
|
||||||
|
|
||||||
if (res.chunk.length === 0) {
|
if (res.chunk.length === 0) {
|
||||||
|
console.log("Seshat: Done with the checkpoint", checkpoint)
|
||||||
// We got to the start/end of our timeline, lets just
|
// We got to the start/end of our timeline, lets just
|
||||||
// delete our checkpoint and go back to sleep.
|
// delete our checkpoint and go back to sleep.
|
||||||
await platform.removeCrawlerCheckpoint(checkpoint);
|
await platform.removeCrawlerCheckpoint(checkpoint);
|
||||||
|
@ -2223,6 +2227,7 @@ export default createReactClass({
|
||||||
// Let us delete the checkpoint in that case, otherwise push
|
// Let us delete the checkpoint in that case, otherwise push
|
||||||
// the new checkpoint to be used by the crawler.
|
// the new checkpoint to be used by the crawler.
|
||||||
if (eventsAlreadyAdded === true && newCheckpoint.fullCrawl !== true) {
|
if (eventsAlreadyAdded === true && newCheckpoint.fullCrawl !== true) {
|
||||||
|
console.log("Seshat: Checkpoint had already all events added, stopping the crawl", checkpoint);
|
||||||
await platform.removeCrawlerCheckpoint(newCheckpoint);
|
await platform.removeCrawlerCheckpoint(newCheckpoint);
|
||||||
} else {
|
} else {
|
||||||
this.crawlerChekpoints.push(newCheckpoint);
|
this.crawlerChekpoints.push(newCheckpoint);
|
||||||
|
|
Loading…
Reference in a new issue