package stirling.software.SPDF.EE; import java.net.URI; import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.posthog.java.shaded.org.json.JSONObject; import lombok.extern.slf4j.Slf4j; import stirling.software.SPDF.model.ApplicationProperties; import stirling.software.SPDF.utils.GeneralUtils; @Service @Slf4j public class KeygenLicenseVerifier { private static final String ACCOUNT_ID = "e5430f69-e834-4ae4-befd-b602aae5f372"; private static final String BASE_URL = "https://api.keygen.sh/v1/accounts"; private static final ObjectMapper objectMapper = new ObjectMapper(); private final ApplicationProperties applicationProperties; @Autowired public KeygenLicenseVerifier(ApplicationProperties applicationProperties) { this.applicationProperties = applicationProperties; } public boolean verifyLicense(String licenseKey) { try { log.info("Checking license key"); String machineFingerprint = generateMachineFingerprint(); // First, try to validate the license JsonNode validationResponse = validateLicense(licenseKey, machineFingerprint); if (validationResponse != null) { boolean isValid = validationResponse.path("meta").path("valid").asBoolean(); String licenseId = validationResponse.path("data").path("id").asText(); if (!isValid) { String code = validationResponse.path("meta").path("code").asText(); log.debug(code); if ("NO_MACHINE".equals(code) || "NO_MACHINES".equals(code) || "FINGERPRINT_SCOPE_MISMATCH".equals(code)) { log.info( "License not activated for this machine. Attempting to activate..."); boolean activated = activateMachine(licenseKey, licenseId, machineFingerprint); if (activated) { // Revalidate after activation validationResponse = validateLicense(licenseKey, machineFingerprint); isValid = validationResponse != null && validationResponse .path("meta") .path("valid") .asBoolean(); } } } return isValid; } return false; } catch (Exception e) { log.error("Error verifying license: " + e.getMessage()); return false; } } private JsonNode validateLicense(String licenseKey, String machineFingerprint) throws Exception { HttpClient client = HttpClient.newHttpClient(); String requestBody = String.format( "{\"meta\":{\"key\":\"%s\",\"scope\":{\"fingerprint\":\"%s\"}}}", licenseKey, machineFingerprint); HttpRequest request = HttpRequest.newBuilder() .uri( URI.create( BASE_URL + "/" + ACCOUNT_ID + "/licenses/actions/validate-key")) .header("Content-Type", "application/vnd.api+json") .header("Accept", "application/vnd.api+json") // .header("Authorization", "License " + licenseKey) .POST(HttpRequest.BodyPublishers.ofString(requestBody)) .build(); HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString()); log.debug(" validateLicenseResponse body: " + response.body()); JsonNode jsonResponse = objectMapper.readTree(response.body()); if (response.statusCode() == 200) { JsonNode metaNode = jsonResponse.path("meta"); boolean isValid = metaNode.path("valid").asBoolean(); String detail = metaNode.path("detail").asText(); String code = metaNode.path("code").asText(); log.debug("License validity: " + isValid); log.debug("Validation detail: " + detail); log.debug("Validation code: " + code); int users = jsonResponse .path("data") .path("attributes") .path("metadata") .path("users") .asInt(0); applicationProperties.getEnterpriseEdition().setMaxUsers(users); log.info(applicationProperties.toString()); } else { log.error("Error validating license. Status code: " + response.statusCode()); } return jsonResponse; } private boolean activateMachine(String licenseKey, String licenseId, String machineFingerprint) throws Exception { HttpClient client = HttpClient.newHttpClient(); String hostname; try { hostname = java.net.InetAddress.getLocalHost().getHostName(); } catch (Exception e) { hostname = "Unknown"; } JSONObject body = new JSONObject() .put( "data", new JSONObject() .put("type", "machines") .put( "attributes", new JSONObject() .put("fingerprint", machineFingerprint) .put( "platform", System.getProperty( "os.name")) // Added // platform // parameter .put( "name", hostname)) // Added name parameter .put( "relationships", new JSONObject() .put( "license", new JSONObject() .put( "data", new JSONObject() .put( "type", "licenses") .put( "id", licenseId))))); HttpRequest request = HttpRequest.newBuilder() .uri(URI.create(BASE_URL + "/" + ACCOUNT_ID + "/machines")) .header("Content-Type", "application/vnd.api+json") .header("Accept", "application/vnd.api+json") .header( "Authorization", "License " + licenseKey) // Keep the license key authentication .POST( HttpRequest.BodyPublishers.ofString( body.toString())) // Send the JSON body .build(); HttpResponse response = client.send(request, HttpResponse.BodyHandlers.ofString()); log.debug("activateMachine Response body: " + response.body()); if (response.statusCode() == 201) { log.info("Machine activated successfully"); return true; } else { log.error( "Error activating machine. Status code: {}, error: {}", response.statusCode(), response.body()); return false; } } private String generateMachineFingerprint() { return GeneralUtils.generateMachineFingerprint(); } }