content moderation restored

Author: nayan458

src/main/java/com/cadac/stone_inscription/moderation/client/N8nModerationClient.java

@@ -0,0 +1,94 @@
+package com.cadac.stone_inscription.moderation.client;
+
+import java.security.GeneralSecurityException;
+import java.security.SecureRandom;
+import java.time.Duration;
+import java.util.List;
+
+import javax.net.ssl.HostnameVerifier;
+import javax.net.ssl.HttpsURLConnection;
+import javax.net.ssl.SSLContext;
+import javax.net.ssl.SSLSession;
+import javax.net.ssl.TrustManager;
+import javax.net.ssl.X509TrustManager;
+
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.MediaType;
+import org.springframework.http.client.SimpleClientHttpRequestFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import com.cadac.stone_inscription.moderation.config.ContentModerationProperties;
+import com.cadac.stone_inscription.moderation.dto.ContentModerationRequestDto;
+
+@Component
+public class N8nModerationClient {
+
+    private final ContentModerationProperties properties;
+    private final RestTemplate restTemplate;
+
+    public N8nModerationClient(ContentModerationProperties properties) {
+        this.properties = properties;
+        this.restTemplate = buildRestTemplate(properties);
+    }
+
+    public String moderate(ContentModerationRequestDto request) {
+        HttpHeaders headers = new HttpHeaders();
+        headers.setContentType(MediaType.APPLICATION_JSON);
+
+        return restTemplate.exchange(
+                properties.getWebhookUrl(),
+                HttpMethod.POST,
+                new HttpEntity<>(request, headers),
+                new ParameterizedTypeReference<String>() {
+                }).getBody();
+    }
+
+    private RestTemplate buildRestTemplate(ContentModerationProperties properties) {
+        SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
+        requestFactory.setConnectTimeout(Duration.ofMillis(properties.getConnectTimeoutMs()));
+        requestFactory.setReadTimeout(Duration.ofMillis(properties.getReadTimeoutMs()));
+
+        if (Boolean.TRUE.equals(properties.getInsecureSsl())) {
+            configureInsecureSsl();
+        }
+
+        return new RestTemplate(requestFactory);
+    }
+
+    private void configureInsecureSsl() {
+        try {
+            TrustManager[] trustAllCerts = new TrustManager[] {
+                    new X509TrustManager() {
+                        @Override
+                        public java.security.cert.X509Certificate[] getAcceptedIssuers() {
+                            return new java.security.cert.X509Certificate[0];
+                        }
+
+                        @Override
+                        public void checkClientTrusted(java.security.cert.X509Certificate[] chain, String authType) {
+                        }
+
+                        @Override
+                        public void checkServerTrusted(java.security.cert.X509Certificate[] chain, String authType) {
+                        }
+                    }
+            };
+
+            SSLContext sslContext = SSLContext.getInstance("TLS");
+            sslContext.init(null, trustAllCerts, new SecureRandom());
+            HttpsURLConnection.setDefaultSSLSocketFactory(sslContext.getSocketFactory());
+            HttpsURLConnection.setDefaultHostnameVerifier(new HostnameVerifier() {
+                @Override
+                public boolean verify(String hostname, SSLSession session) {
+                    return true;
+                }
+            });
+        } catch (GeneralSecurityException ex) {
+            throw new IllegalStateException("Failed to configure insecure SSL for content moderation", ex);
+        }
+    }
+}

src/main/java/com/cadac/stone_inscription/moderation/config/ContentModerationProperties.java

@@ -0,0 +1,24 @@
+package com.cadac.stone_inscription.moderation.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+import lombok.Getter;
+import lombok.Setter;
+
+@Getter
+@Setter
+@Component
+@ConfigurationProperties(prefix = "content.moderation")
+public class ContentModerationProperties {
+
+    private String webhookUrl;
+
+    private Double safeThreshold = 0.7;
+
+    private Integer connectTimeoutMs = 5000;
+
+    private Integer readTimeoutMs = 10000;
+
+    private Boolean insecureSsl = false;
+}

src/main/java/com/cadac/stone_inscription/moderation/dto/ContentModerationRequestDto.java

@@ -0,0 +1,24 @@
+package com.cadac.stone_inscription.moderation.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ContentModerationRequestDto {
+
+    @JsonProperty("title")
+    private String title;
+
+    @JsonProperty("topic")
+    private String topic;
+
+    @JsonProperty("description")
+    private String description;
+}

src/main/java/com/cadac/stone_inscription/moderation/dto/ContentModerationResponseDto.java

@@ -0,0 +1,47 @@
+package com.cadac.stone_inscription.moderation.dto;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class ContentModerationResponseDto {
+
+    @JsonProperty("timestamp")
+    private String timestamp;
+
+    @JsonProperty("decision")
+    private String decision;
+
+    @JsonProperty("label")
+    private String label;
+
+    @JsonProperty("confidence")
+    private Double confidence;
+
+    @JsonProperty("reason")
+    private String reason;
+
+    @JsonProperty("status")
+    private String status;
+
+    @JsonProperty("description")
+    private String description;
+
+    @JsonProperty("id")
+    private Long id;
+
+    @JsonProperty("createdAt")
+    private String createdAt;
+
+    @JsonProperty("updatedAt")
+    private String updatedAt;
+}

src/main/java/com/cadac/stone_inscription/moderation/model/ContentModeration.java

@@ -0,0 +1,30 @@
+package com.cadac.stone_inscription.moderation.model;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ContentModeration {
+
+    @JsonProperty("label")
+    private String label;
+
+    @JsonProperty("confidence")
+    private Double confidence;
+
+    @JsonProperty("decision")
+    private String decision;
+
+    @JsonProperty("status")
+    private String status;
+
+    @JsonProperty("reason")
+    private String reason;
+}

src/main/java/com/cadac/stone_inscription/moderation/model/ContentModerationResult.java

@@ -0,0 +1,35 @@
+package com.cadac.stone_inscription.moderation.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class ContentModerationResult {
+
+    private boolean approved;
+
+    private String label;
+
+    private Double confidence;
+
+    private String decision;
+
+    private String status;
+
+    private String reason;
+
+    public ContentModeration toContentModeration() {
+        return ContentModeration.builder()
+                .label(label)
+                .confidence(confidence)
+                .decision(decision)
+                .status(status)
+                .reason(reason)
+                .build();
+    }
+}