import pl.edu.icm.synat.api.services.store.StatelessStore
import pl.edu.icm.synat.api.services.store.model.RecordConditions
import pl.edu.icm.synat.api.services.store.model.batch.operations.BatchOperations
import pl.edu.icm.synat.api.services.store.model.batch.operations.RemoveRecord

store = serviceUtils.getService('Store', StatelessStore.class)

conditions = new RecordConditions()
conditions.withTags("dataset:IEEE")
//conditions.withTags("import:5813")

results = store.listRecords(conditions, null, 1000)
token = results.getNextToken();
remove(store, results)
iter = 1;
deleted = results.getItems().size()
println "deleted "+ deleted

while (token!=null) {
    iter++
    results = store.listRecords(conditions, token, 1000)
    token = results.getNextToken();
    remove(store, results)
    deleted+=results.getItems().size()
    println "deleted "+ deleted
}

def remove(store, results){
    def operationsToExecute = new BatchOperations();
    for(result in results.getItems()){
        operationsToExecute.getOperations().add(new RemoveRecord(result));
    }
    store.executeBatch(operationsToExecute)
}