export async function handler()

in src/shardMigrationCheck.ts [4:20]

• 15 lines of code
• 3 McCabe index (conditional complexity)

export async function handler(event: TargetAndNewNodeResponse): Promise<TargetAndNewNodeResponse> {
    const elasticsearchClient = new Elasticsearch(event.targetElasticSearchNode.ec2Instance.id)

    return Promise.all([
        elasticsearchClient.getClusterHealth(),
        elasticsearchClient.getDocuments(event.targetElasticSearchNode)
    ]).then(([clusterStatus, documents]) => {
        const hasDocuments = documents.count > 0;
        const clusterIsUnhealthy = !(clusterStatus.status === "green");

        if (clusterIsUnhealthy || hasDocuments) {
            const error = `Check failed: hasDocuments=${hasDocuments} (${event.targetElasticSearchNode.ec2Instance.id} still has ${documents.count} docs) clusterIsUnhealthy=${clusterIsUnhealthy} (status is currently ${clusterStatus.status})`;
            console.log(error);
            throw new Error(error);
        } else return event;
    });
}