package com.gentics.mesh.context;

import java.util.concurrent.atomic.AtomicLong;

import com.gentics.mesh.core.data.search.SearchQueueBatch;
import com.syncleus.ferma.tx.Tx;

import io.vertx.core.logging.Logger;
import io.vertx.core.logging.LoggerFactory;

/**
 * Context which tracks recursive and bulk actions.
 * 
 * Some operations may affect a lot of elements and thus it is needed to commit the transaction at specific safe points in order to reduce the memory footprint.
 */
public class BulkActionContext {

	private static final Logger log = LoggerFactory.getLogger(BulkActionContext.class);

	private static final int DEFAULT_BATCH_SIZE = 100;

	private final AtomicLong counter = new AtomicLong(0);

	private SearchQueueBatch batch;

	public BulkActionContext(SearchQueueBatch batch) {
		this.batch = batch;
	}

	/**
	 * Increment the counter which tracks deleted elements.
	 * 
	 * @return
	 */
	public long inc() {
		return counter.incrementAndGet();
	}

	/**
	 * Process the deletion by processing the batch and committing the transaction.
	 */
	public void process() {
		process(false);
	}

	/**
	 * Process the actions by processing the batch and committing the transaction. The method will also automatically increase the counter.
	 * 
	 * @param force
	 *            Force the commit / process even if the batch is not yet full
	 */
	public void process(boolean force) {
		if (counter.incrementAndGet() >= DEFAULT_BATCH_SIZE || force) {
			log.info("Processing transaction. I counted {" + counter.get() + "} elements.");
			Tx.getActive().getGraph().commit();
			batch.processSync();
			// Reset the counter back to zero
			counter.set(0);
		}
	}

	public void dropIndex(String composeIndexName) {
		batch.dropIndex(composeIndexName);
	}

	public SearchQueueBatch batch() {
		return batch;
	}

}

@@ -1533,16 +1533,40 @@
 nts.%22);%0A
+%09%09%09batch.processSync();%0A
 %09%09%09Tx.ge
@@ -1600,32 +1600,8 @@
 ();%0A
-%09%09%09batch.processSync();%0A
 %09%09%09/

Switch task order to prevent errors during batch processing