Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
20 commits
Select commit Hold shift + click to select a range
4687b3f
feat(health,version): add health and version endpoints
DurgaPrasad-54 Feb 17, 2026
1c2468b
feat(health,version): add health and version endpoints without auth
DurgaPrasad-54 Feb 17, 2026
ffc0370
fix(health): remove unused private methods
DurgaPrasad-54 Feb 17, 2026
853cfa3
fix(health): fix exception issue
DurgaPrasad-54 Feb 17, 2026
6422265
fix(health): redact error details for unauthenticated health checks
DurgaPrasad-54 Feb 17, 2026
00e34b7
fix code quality issues and reduce cognitive complexity
DurgaPrasad-54 Feb 17, 2026
933e1cb
feat(health): add MySQL health endpoint
DurgaPrasad-54 Feb 19, 2026
d70184d
refactor(health): simplify MySQL health check and remove sensitive de…
DurgaPrasad-54 Feb 19, 2026
d130a85
fix(health): remove unused imports and variables
DurgaPrasad-54 Feb 19, 2026
3e755eb
refactor(health): address nitpicks (configurable ES scheme, log noise…
DurgaPrasad-54 Feb 19, 2026
d74ee26
fix(health): scope PROCESSLIST lock-wait check to application DB user
DurgaPrasad-54 Feb 21, 2026
79ce192
refactor(health): remove unused params and reuse response/error const…
DurgaPrasad-54 Feb 21, 2026
c24c710
fix(health): remove unused imports and methods
DurgaPrasad-54 Feb 21, 2026
baf29a1
chore(health): clean up unused imports, params, and dead helpers
DurgaPrasad-54 Feb 21, 2026
474c913
fix(health): avoid sharing JDBC connections across threads in advance…
DurgaPrasad-54 Feb 22, 2026
618a21b
refactor(health): reuse REDIS_COMPONENT constant and extract nested t…
DurgaPrasad-54 Feb 22, 2026
3e7f50e
fix(health): avoid blocking DB I/O under write lock and restore inter…
DurgaPrasad-54 Feb 22, 2026
b05cf7b
fix(health): cancel in-flight futures on generic failure
DurgaPrasad-54 Feb 22, 2026
824895e
feat(health,version): add index existance, read-only detection, canar…
DurgaPrasad-54 Feb 25, 2026
e9c7c33
refactor(health): reduce cognitive complexity, remove dead throws, an…
DurgaPrasad-54 Feb 25, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 19 additions & 15 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -245,6 +245,12 @@
<artifactId>h2</artifactId>
<scope>runtime</scope>
</dependency>
<!-- Elasticsearch client for health check -->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>8.10.0</version>
</dependency>
<!--END NEW DEPENDENCIES ADDED-->
</dependencies>
<profiles>
Expand Down Expand Up @@ -286,31 +292,29 @@
<version>3.3.0</version>
</plugin>
<plugin>
<groupId>pl.project13.maven</groupId>
<artifactId>git-commit-id-plugin</artifactId>
<version>4.9.10</version>
<groupId>io.github.git-commit-id</groupId>
<artifactId>git-commit-id-maven-plugin</artifactId>
<version>9.0.2</version>
<executions>
<execution>
<id>get-the-git-infos</id>
<goals>
<goal>revision</goal>
</goals>
<phase>initialize</phase>
</execution>
</executions>
<configuration>
<dotGitDirectory>${project.basedir}/.git</dotGitDirectory>
<prefix>git</prefix>
<verbose>false</verbose>
<generateGitPropertiesFile>true</generateGitPropertiesFile>
<generateGitPropertiesFilename>
${project.build.outputDirectory}/git.properties
</generateGitPropertiesFilename>
<format>json</format>
<gitDescribe>
<skip>false</skip>
<always>false</always>
<dirty>-dirty</dirty>
</gitDescribe>
<generateGitPropertiesFilename>${project.build.outputDirectory}/git.properties</generateGitPropertiesFilename>
<includeOnlyProperties>
<property>^git.branch$</property>
<property>^git.commit.id.abbrev$</property>
<property>^git.build.version$</property>
<property>^git.build.time$</property>
</includeOnlyProperties>
<failOnNoGitDirectory>false</failOnNoGitDirectory>
<failOnUnableToExtractRepoInfo>false</failOnUnableToExtractRepoInfo>
</configuration>
</plugin>

Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,90 @@
/*
* AMRIT – Accessible Medical Records via Integrated Technology
* Integrated EHR (Electronic Health Records) Solution
*
* Copyright (C) "Piramal Swasthya Management and Research Institute"
*
* This file is part of AMRIT.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see https://www.gnu.org/licenses/.
*/

package com.iemr.common.identity.controller.health;

import java.time.Instant;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import jakarta.servlet.http.Cookie;
import jakarta.servlet.http.HttpServletRequest;
import com.iemr.common.identity.service.health.HealthService;
import com.iemr.common.identity.utils.JwtAuthenticationUtil;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.responses.ApiResponse;
import io.swagger.v3.oas.annotations.responses.ApiResponses;
import io.swagger.v3.oas.annotations.tags.Tag;


@RestController
@RequestMapping("/health")
@Tag(name = "Health Check", description = "APIs for checking infrastructure health status")
public class HealthController {

private static final Logger logger = LoggerFactory.getLogger(HealthController.class);

private final HealthService healthService;
private final JwtAuthenticationUtil jwtAuthenticationUtil;

public HealthController(HealthService healthService, JwtAuthenticationUtil jwtAuthenticationUtil) {
this.healthService = healthService;
this.jwtAuthenticationUtil = jwtAuthenticationUtil;
}
@GetMapping
@Operation(summary = "Check infrastructure health",
description = "Returns the health status of MySQL, Redis, Elasticsearch, and other configured services")
@ApiResponses({
@ApiResponse(responseCode = "200", description = "Services are UP or DEGRADED (operational with warnings)"),
@ApiResponse(responseCode = "503", description = "One or more critical services are DOWN")
})
public ResponseEntity<Map<String, Object>> checkHealth() {
logger.info("Health check endpoint called");

try {
Map<String, Object> healthStatus = healthService.checkHealth();
String overallStatus = (String) healthStatus.get("status");

// Return 503 only if DOWN; 200 for both UP and DEGRADED (DEGRADED = operational with warnings)
HttpStatus httpStatus = "DOWN".equals(overallStatus) ? HttpStatus.SERVICE_UNAVAILABLE : HttpStatus.OK;

logger.debug("Health check completed with status: {}", overallStatus);
return new ResponseEntity<>(healthStatus, httpStatus);

} catch (Exception e) {
logger.error("Unexpected error during health check", e);

// Return sanitized error response
Map<String, Object> errorResponse = Map.of(
"status", "DOWN",
"timestamp", Instant.now().toString()
);

return new ResponseEntity<>(errorResponse, HttpStatus.SERVICE_UNAVAILABLE);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -21,54 +21,59 @@
*/
package com.iemr.common.identity.controller.version;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Properties;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import com.iemr.common.identity.utils.response.OutputResponse;

import io.swagger.v3.oas.annotations.Operation;

@RestController
public class VersionController {

private Logger logger = LoggerFactory.getLogger(this.getClass().getSimpleName());
private final Logger logger = LoggerFactory.getLogger(this.getClass().getSimpleName());

private static final String UNKNOWN_VALUE = "unknown";

@Operation(summary = "Get version information")
@GetMapping(value = "/version",consumes = "application/json", produces = "application/json")
public String versionInformation() {
OutputResponse output = new OutputResponse();
@GetMapping(value = "/version", produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<Map<String, String>> versionInformation() {
Map<String, String> response = new LinkedHashMap<>();
try {
logger.info("version Controller Start");
output.setResponse(readGitProperties());
} catch (Exception e) {
output.setError(e);
}

Properties gitProperties = loadGitProperties();
response.put("buildTimestamp", gitProperties.getProperty("git.build.time", UNKNOWN_VALUE));
response.put("version", gitProperties.getProperty("git.build.version", UNKNOWN_VALUE));
response.put("branch", gitProperties.getProperty("git.branch", UNKNOWN_VALUE));
response.put("commitHash", gitProperties.getProperty("git.commit.id.abbrev", UNKNOWN_VALUE));
} catch (Exception e) {
logger.error("Failed to load version information", e);
response.put("buildTimestamp", UNKNOWN_VALUE);
response.put("version", UNKNOWN_VALUE);
response.put("branch", UNKNOWN_VALUE);
response.put("commitHash", UNKNOWN_VALUE);
}
logger.info("version Controller End");
return output.toString();
return ResponseEntity.ok(response);
}
private String readGitProperties() throws Exception {
ClassLoader classLoader = getClass().getClassLoader();
InputStream inputStream = classLoader.getResourceAsStream("git.properties");

return readFromInputStream(inputStream);
}
private String readFromInputStream(InputStream inputStream)
throws IOException {
StringBuilder resultStringBuilder = new StringBuilder();
try (BufferedReader br = new BufferedReader(new InputStreamReader(inputStream))) {
String line;
while ((line = br.readLine()) != null) {
resultStringBuilder.append(line).append("\n");
}
}
return resultStringBuilder.toString();

private Properties loadGitProperties() throws IOException {
Properties properties = new Properties();
try (InputStream input = getClass().getClassLoader()
.getResourceAsStream("git.properties")) {
if (input != null) {
properties.load(input);
}
}
return properties;
}
}
Loading
Loading