suresk

{
  "name": "Debug with mocha",
  "type": "node",
  "request": "launch",
  "program": "${workspaceRoot}/node_modules/mocha/bin/_mocha",
  "stopOnEntry": false,
  "args": ["--no-timeouts", "${relativeFile}"],
  "cwd": "${workspaceRoot}"
}

suresk

{
  "name": "Debug with mocha",
  "type": "node",
  "request": "launch",
  "program": "${workspaceRoot}/node_modules/mocha/bin/_mocha",
  "stopOnEntry": false,
  "args": ["--no-timeouts", "--opts", "${workspaceRoot}/test/mocha-debug.opts", "${relativeFile}"],
  "cwd": "${workspaceRoot}"
}

suresk

// Add/rename alias
if(currentIndex > -1)
{
	renameAlias(aliasName, buildIndexName(aliasName, currentIndex), indexName);
}
else
{
	elasticClient.admin().indices().prepareAliases().addAlias(indexName, aliasName).execute();
}

suresk

private void releaseLock(String aliasName)
{
	synchronized (aliasName)
	{
		DeleteRequest deleteRequest = new DeleteRequest().index(LOCK_DIRECTORY).type(LOCK_TYPE).id(aliasName);
		elasticClient.delete(deleteRequest);
	}
}

suresk

// Do the indexing
T res = job.rebuildIndex(indexName);

....

public interface IndexRebuildJob<T>
{
    public T rebuildIndex(String indexName);
}

suresk

String mapping = getMapFile(aliasName);

if(mapping != null)
{
	elasticClient.admin().indices().putMapping(new PutMappingRequest(indexName).source(getMapFile(aliasName)));
}

...

private String getMapFile(String aliasName)

suresk

// Create the index
Settings.Builder settingsBuilder = Settings.builder();

for(Map.Entry<String, Integer> setting : config.getIndexSettings().entrySet())
{
	settingsBuilder.put(setting.getKey(), setting.getValue());
}

elasticClient.admin().indices().create(new CreateIndexRequest(indexName, settingsBuilder.build()));

suresk

// Delete it, if it already exists

if(elasticClient.admin().indices().exists(new IndicesExistsRequest(indexName)).actionGet().isExists())
{
  elasticClient.admin().indices().delete(new DeleteIndexRequest(indexName));
}

suresk

private int findCurrentIndex(String aliasName, int indexCount)
{
	Map<String, AliasOrIndex> allAliases = elasticClient
		.admin()
		.cluster()
		.state(Requests.clusterStateRequest())
		.actionGet()
		.getState()
		.getMetaData()
		.getAliasAndIndexLookup();

suresk

private boolean getLock(String aliasName)
{
	synchronized (aliasName)
	{
		IndexRequestBuilder indexRequest = elasticClient.prepareIndex(LOCK_DIRECTORY, LOCK_TYPE, aliasName).setSource("{}").setOpType(OpType.CREATE);
		boolean successful = false;
		
		try
		{
			IndexResponse response = indexRequest.get();