Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

HCX-353 : Add notification trigger for signing cert expiry #16

Merged
merged 1 commit into from
Aug 18, 2023
Merged

HCX-353 : Add notification trigger for signing cert expiry #16

Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
18 changes: 12 additions & 6 deletions ...b/src/main/java/org/swasth/commonscheduler/schedulers/ParticipantValidationScheduler.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -41,26 +41,32 @@ public class ParticipantValidationScheduler extends BaseScheduler {
private int notificationExpiry;
@Value("${certificate.expiry-days}")
private List<Integer> beforeExpiryDaysList;


@Scheduled(fixedDelayString = "${fixedDelay.in.milliseconds.participantVerify}")
public void process() throws Exception {
logger.info("Participant validation scheduler started");
certExpiry(Constants.ENCRYPTION_CERT_EXPIRY);
certExpiry(Constants.SIGNING_CERT_PATH_EXPIRY);
}

public void certExpiry(String participantCert) throws Exception {
String expiryMessage = "";
String beforeExpiryMessage = "";
List<Map<String, Object>> participants = new ArrayList<>();
List<String> expiredParticipantCodes = new ArrayList<>();
List<String> aboutToExpireParticipantCodes = new ArrayList<>();
List<Map<String, Object>> participants = new ArrayList<>();
for (int beforeExpiryDay : beforeExpiryDaysList) {
long expiryTime = System.currentTimeMillis() + (1 + beforeExpiryDay) * 24L * 60 * 60 * 1000;
participants = registryService.getDetails("{ \"filters\": { \"encryption_cert_expiry\": { \"<\": " + expiryTime + " } } }");
participants = registryService.getDetails("{ \"filters\": { " + participantCert + ": { \"<\": " + expiryTime + " } } }");
for (Map<String, Object> participant : participants) {
long certExpiry = (long) participant.get(Constants.ENCRYPTION_CERT_EXPIRY);
long certExpiry = (long) participant.get(participantCert);
String participantCode = (String) participant.get(Constants.PARTICIPANT_CODE);
long earlierDayTime = expiryTime - (24L * 60 * 60 * 1000) ;
long earlierDayTime = expiryTime - (24L * 60 * 60 * 1000);
if (certExpiry <= System.currentTimeMillis()) {
expiredParticipantCodes.add(participantCode);
expiryMessage = getTemplateMessage(expiryTopicCode);
} else if (certExpiry > earlierDayTime && certExpiry < expiryTime){
} else if (certExpiry > earlierDayTime && certExpiry < expiryTime) {
aboutToExpireParticipantCodes.add(participantCode);
beforeExpiryMessage = getTemplateMessage(beforeExpiryTopicCode).replace("${days}", String.valueOf(beforeExpiryDay));
}
Expand All @@ -71,7 +77,6 @@ public void process() throws Exception {
generateEvent(expiredParticipantCodes, expiryMessage, expiryTopicCode);
logger.info("Total number of participants with expired or expiring encryption certificate in {}", participants.size());
logger.info("Participant validation scheduler ended");

}

private void generateEvent(List<String> participantCodes, String message, String topiCode) throws Exception {
Expand All @@ -81,6 +86,7 @@ private void generateEvent(List<String> participantCodes, String message, String
kafkaClient.send(notifyTopic, Constants.NOTIFICATION, event);
logger.info("Notify event is pushed to kafka: {}", event);
}

private String getTemplateMessage(String topicCode) throws Exception {
return (String) JSONUtils.deserialize((String) (NotificationUtils.getNotification(topicCode).get(Constants.TEMPLATE)), Map.class).get(Constants.MESSAGE);
}
Expand Down
Loading