import pl.edu.icm.synat.api.services.collections.events.CollectionEvent
import pl.edu.icm.synat.api.services.index.fulltext.FulltextIndexService
import pl.edu.icm.synat.events.EventBus
import pl.edu.icm.synat.logic.services.collection.CollectionService

eventBus = serviceUtils.getService('collection.recordEvent', EventBus.class,"jms")

collectionIndex = serviceUtils.getService('CollectionIndex', FulltextIndexService.class)
collectionService = serviceUtils.getService('collection-service', CollectionService.class)

skip = 0
results = collectionService.listAllCollections(skip,100)
iter =1;
check(results)

while (results.size()>0) {
    skip +=results.size()
    results = collectionService.listAllCollections(skip,100)
    check(results)
    
}

def check(results){
    for(result in results){
        println result.getId()
        Date timestamp = new Date();
        CollectionEvent event = new CollectionEvent(timestamp, 'collection-service', result.getId(), null, null, false, "destinationFlow:collectionFlow");

        eventBus.reportEvent(event);
    }
    print iter++ +" "
}