Add podcast generation and refactor summary services

Introduced podcast generation via a new `PodcastServiceImpl` using AI clients to generate scripts based on book summaries. Refactored models, configurations, and service classes to improve consistency, maintainability, and alignment with new features. Enhanced JSON handling and adjusted application properties to support updated AI configurations.

Author: maxiplux

docs/desing.vsdx

@@ -4,13 +4,9 @@
 import org.springframework.ai.anthropic.AnthropicChatModel;
 import org.springframework.ai.chat.client.ChatClient;
 import org.springframework.ai.openai.OpenAiChatModel;
-import org.springframework.ai.openai.OpenAiChatOptions;
-import org.springframework.ai.openai.api.OpenAiApi;
 import org.springframework.ai.vertexai.gemini.VertexAiGeminiChatModel;
-import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.context.annotation.Primary;
 
 /**
  * Configuration class for AI chat clients.
@@ -28,7 +24,9 @@ public class AiConfig {
      */
     //@Primary
     @Bean
-    ChatClient openAiChatClient(OpenAiChatModel chatModel) {        return ChatClient.create(chatModel);    }
+    ChatClient openAiChatClient(OpenAiChatModel chatModel) {
+        return ChatClient.create(chatModel);
+    }
 
 
     @Bean
@@ -43,5 +41,4 @@ ChatClient anthropicChatClient(AnthropicChatModel chatModel) {
     }
 
 
-
 }

src/main/java/app/quantun/summary/config/ai/AiConfig.java

@@ -1,7 +1,6 @@
 package app.quantun.summary.config.ai;
 
 import lombok.Data;
-import org.springframework.boot.context.properties.ConfigurationProperties;
 
 // Configuration Properties Class
 //@ConfigurationProperties(prefix = "spring.ai.perplexity")

src/main/java/app/quantun/summary/config/ai/PerplexityProperties.java

@@ -2,12 +2,11 @@
 
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;
-
 import com.fasterxml.jackson.databind.module.SimpleModule;
 import com.google.protobuf.Message;
+import com.google.protobuf.UnknownFieldSet;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-import com.google.protobuf.UnknownFieldSet;
 
 @Configuration
 public class JacksonConfig {

src/main/java/app/quantun/summary/config/serializer/JacksonConfig.java

@@ -1,7 +1,6 @@
 package app.quantun.summary.controller;
 
 import app.quantun.summary.model.contract.dto.TableIndexContent;
-import app.quantun.summary.model.contract.request.Answer;
 import app.quantun.summary.service.PdfServices;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.media.Content;
@@ -55,13 +54,10 @@ public ResponseEntity<String> handleFileUpload(@RequestParam("file") MultipartFi
         return ResponseEntity.ok("File uploaded successfully: " + fileName);
     }
 
-        @PostMapping("/get-table-of-content")
+    @PostMapping("/get-table-of-content")
     public TableIndexContent getTableOfContent(String message) {
         return this.pdfServices.getBookTableOfContentPages(message);
     }
 
 
-
-
-
 }

src/main/java/app/quantun/summary/controller/PdfController.java

@@ -1,11 +1,10 @@
 package app.quantun.summary.message.consumer;
 
-import app.quantun.summary.message.producer.SummaryBookProducerService;
 import app.quantun.summary.model.contract.message.BookFilePayload;
 import app.quantun.summary.model.entity.Book;
 import app.quantun.summary.repository.BookRepository;
-
-import app.quantun.summary.service.impl.SummaryServicesImpl;
+import app.quantun.summary.service.PodcastService;
+import app.quantun.summary.service.SummaryServices;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import lombok.val;
@@ -28,7 +27,9 @@ public class SummaryBookConsumerImpl implements SummaryBookConsumer {
 
     private final BookRepository summaryBookRepository;
 
-    private final SummaryServicesImpl summaryServices;
+    private final SummaryServices summaryServices;
+
+    private final PodcastService podCastService;
 
 
     @KafkaListener(
@@ -73,7 +74,6 @@ public void processMessages(List<BookFilePayload> messages) {
                         log.info("Book with id {} already exists in the database", message.id());
 
                         this.makeSummary(book);
-                        this.makeScript(book);
                         this.makePodcast(book);
                         this.saveChanges(book);
 
@@ -96,23 +96,21 @@ private void saveChanges(Book book) {
             log.info("Saving changes for book with id: {}", book.getId());
             this.summaryBookRepository.save(book);
             log.info("Successfully saved changes for book with id: {}", book.getId());
-        } catch (Exception e)
-        {
+        } catch (Exception e) {
             log.error("Failed to save changes for book with id: {}. Error: {}", book.getId(), e.getMessage());
 
         }
     }
 
-    private void makePodcast(Book book) {
 
-    }
-
-    private void makeScript(Book book) {
+    private void makePodcast(Book book) {
+        val podCast = this.podCastService.createScript(book);
+        book.setPodCast(podCast);
 
     }
 
     private void makeSummary(Book book) {
-        val summary=summaryServices.summarizeBook(book);
+        val summary = summaryServices.summarizeBook(book);
         book.setTextSummary(summary);
 
     }

src/main/java/app/quantun/summary/message/consumer/SummaryBookConsumerImpl.java

@@ -1,9 +1,13 @@
 package app.quantun.summary.model.contract.dto;
 
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
-import lombok.*;
-import java.util.List;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
 import java.util.ArrayList;
+import java.util.List;
 
 @Data
 @Builder
@@ -12,11 +16,15 @@
 @JsonIgnoreProperties(ignoreUnknown = true)
 public class BookSummary {
     private Metadata metadata = new Metadata();
-     private IntroductionBlueprint introduction = new IntroductionBlueprint();
-    @Builder.Default private CoreElementsBreakdown coreElements = new CoreElementsBreakdown();
-    @Builder.Default private List<Chapter> chapterDigest = new ArrayList<>();
-    @Builder.Default private CriticalAnalysisFramework analysis = new CriticalAnalysisFramework();
-    @Builder.Default private ActionableTakeawaySystem takeaways = new ActionableTakeawaySystem();
+    private IntroductionBlueprint introduction = new IntroductionBlueprint();
+    @Builder.Default
+    private CoreElementsBreakdown coreElements = new CoreElementsBreakdown();
+    @Builder.Default
+    private List<Chapter> chapterDigest = new ArrayList<>();
+    @Builder.Default
+    private CriticalAnalysisFramework analysis = new CriticalAnalysisFramework();
+    @Builder.Default
+    private ActionableTakeawaySystem takeaways = new ActionableTakeawaySystem();
 
     @Data
     @Builder
@@ -49,18 +57,23 @@ public static class IntroductionBlueprint {
     @AllArgsConstructor
     @JsonIgnoreProperties(ignoreUnknown = true)
     public static class CoreElementsBreakdown {
-        @Builder.Default private PlotArchitecture plot = new PlotArchitecture();
-        @Builder.Default private List<CharacterEntry> characters = new ArrayList<>();
-        @Builder.Default private ThemeNetwork themes = new ThemeNetwork();
-        @Builder.Default private StyleAnalysis style = new StyleAnalysis();
+        @Builder.Default
+        private PlotArchitecture plot = new PlotArchitecture();
+        @Builder.Default
+        private List<CharacterEntry> characters = new ArrayList<>();
+        @Builder.Default
+        private ThemeNetwork themes = new ThemeNetwork();
+        @Builder.Default
+        private StyleAnalysis style = new StyleAnalysis();
 
         @Data
         @Builder
         @NoArgsConstructor
         @AllArgsConstructor
         public static class PlotArchitecture {
             private String centralConflict;
-            @Builder.Default private List<String> narrativeArc = new ArrayList<>();
+            @Builder.Default
+            private List<String> narrativeArc = new ArrayList<>();
         }
 
         @Data
@@ -82,8 +95,10 @@ public static class CharacterEntry {
         @JsonIgnoreProperties(ignoreUnknown = true)
         public static class ThemeNetwork {
             private String primaryTheme;
-            @Builder.Default private List<String> supportingThemes = new ArrayList<>();
-            @Builder.Default private List<String> recurringMotifs = new ArrayList<>();
+            @Builder.Default
+            private List<String> supportingThemes = new ArrayList<>();
+            @Builder.Default
+            private List<String> recurringMotifs = new ArrayList<>();
         }
 
         @Data
@@ -129,9 +144,12 @@ public static class CriticalAnalysisFramework {
     @AllArgsConstructor
     @JsonIgnoreProperties(ignoreUnknown = true)
     public static class ActionableTakeawaySystem {
-        @Builder.Default private List<String> practicalApplications = new ArrayList<>();
-        @Builder.Default private List<String> discussionPrompts = new ArrayList<>();
-        @Builder.Default private List<String> furtherExploration = new ArrayList<>();
+        @Builder.Default
+        private List<String> practicalApplications = new ArrayList<>();
+        @Builder.Default
+        private List<String> discussionPrompts = new ArrayList<>();
+        @Builder.Default
+        private List<String> furtherExploration = new ArrayList<>();
     }
 }
 

src/main/java/app/quantun/summary/model/contract/dto/BookSummary.java

@@ -0,0 +1,28 @@
+package app.quantun.summary.model.contract.dto;
+
+
+import app.quantun.summary.model.entity.Script;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.TreeSet;
+
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class PodCast {
+
+
+    private String title;
+    private Long duration;
+
+
+    private TreeSet<Script> scripts;
+
+
+}

src/main/java/app/quantun/summary/model/contract/dto/PodCast.java

@@ -4,6 +4,7 @@
 import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
 
 import java.util.List;
+
 @JsonIgnoreProperties(ignoreUnknown = true)
 
 public record TableIndexContent(List<IndexContent> indexContents) {

src/main/java/app/quantun/summary/model/contract/dto/TableIndexContent.java

@@ -1,6 +1,7 @@
 package app.quantun.summary.model.entity;
 
 import app.quantun.summary.model.contract.dto.BookSummary;
+import app.quantun.summary.model.contract.dto.PodCast;
 import jakarta.persistence.*;
 import lombok.*;
 import org.hibernate.annotations.Type;
@@ -29,7 +30,8 @@ public class Book {
     @Column(columnDefinition = "jsonb")
     private BookSummary textSummary;
 
-    @ManyToOne(fetch = FetchType.LAZY)
+    @Type(io.hypersistence.utils.hibernate.type.json.JsonType.class)
+    @Column(columnDefinition = "jsonb")
     private PodCast podCast;