Iris: Answer questions about lecture slides

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisCourseSettings.java

@@ -28,6 +28,10 @@ public class IrisCourseSettings extends IrisSettings {
     @JoinColumn(name = "iris_chat_settings_id")
     private IrisChatSubSettings irisChatSettings;
 
+    @OneToOne(cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.EAGER)
+    @JoinColumn(name = "iris_lecture_ingestion_settings_id")
+    private IrisLectureIngestionSubSettings irisLectureIngestionSettings;
+
     @OneToOne(cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.EAGER)
     @JoinColumn(name = "iris_hestia_settings_id")
     private IrisHestiaSubSettings irisHestiaSettings;
@@ -49,6 +53,16 @@ public void setCourse(Course course) {
         this.course = course;
     }
 
+    @Override
+    public IrisLectureIngestionSubSettings getIrisLectureIngestionSettings() {
+        return irisLectureIngestionSettings;
+    }
+
+    @Override
+    public void setIrisLectureIngestionSettings(IrisLectureIngestionSubSettings irisLectureIngestionSettings) {
+        this.irisLectureIngestionSettings = irisLectureIngestionSettings;
+    }
+
     @Override
     public IrisChatSubSettings getIrisChatSettings() {
         return irisChatSettings;

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisExerciseSettings.java

@@ -41,6 +41,15 @@ public void setExercise(Exercise exercise) {
         this.exercise = exercise;
     }
 
+    @Override
+    public IrisLectureIngestionSubSettings getIrisLectureIngestionSettings() {
+        return null;
+    }
+
+    @Override
+    public void setIrisLectureIngestionSettings(IrisLectureIngestionSubSettings irisLectureIngestionSettings) {
+    }
+
     @Override
     public IrisChatSubSettings getIrisChatSettings() {
         return irisChatSettings;

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisGlobalSettings.java

@@ -31,13 +31,20 @@ public class IrisGlobalSettings extends IrisSettings {
     @Column(name = "enable_auto_update_hestia")
     private boolean enableAutoUpdateHestia;
 
+    @Column(name = "enable_auto_update_lecture_ingestion")
+    private boolean enableAutoUpdateLectureIngestion;
+
     @Column(name = "enable_auto_update_competency_generation")
     private boolean enableAutoUpdateCompetencyGeneration;
 
     @OneToOne(cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.EAGER, optional = false)
     @JoinColumn(name = "iris_chat_settings_id")
     private IrisChatSubSettings irisChatSettings;
 
+    @OneToOne(cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.EAGER, optional = false)
+    @JoinColumn(name = "iris_lecture_ingestion_settings_id")
+    private IrisLectureIngestionSubSettings irisLectureIngestionSettings;
+
     @OneToOne(cascade = CascadeType.ALL, orphanRemoval = true, fetch = FetchType.EAGER, optional = false)
     @JoinColumn(name = "iris_hestia_settings_id")
     private IrisHestiaSubSettings irisHestiaSettings;
@@ -74,6 +81,14 @@ public void setEnableAutoUpdateChat(boolean enableAutoUpdateChat) {
         this.enableAutoUpdateChat = enableAutoUpdateChat;
     }
 
+    public boolean isEnableAutoUpdateLectureIngestion() {
+        return enableAutoUpdateLectureIngestion;
+    }
+
+    public void setEnableAutoUpdateLectureIngestion(boolean enableAutoUpdateLectureIngestion) {
+        this.enableAutoUpdateLectureIngestion = enableAutoUpdateLectureIngestion;
+    }
+
     public boolean isEnableAutoUpdateHestia() {
         return enableAutoUpdateHestia;
     }
@@ -90,6 +105,16 @@ public void setEnableAutoUpdateCompetencyGeneration(boolean enableAutoUpdateComp
         this.enableAutoUpdateCompetencyGeneration = enableAutoUpdateCompetencyGeneration;
     }
 
+    @Override
+    public IrisLectureIngestionSubSettings getIrisLectureIngestionSettings() {
+        return irisLectureIngestionSettings;
+    }
+
+    @Override
+    public void setIrisLectureIngestionSettings(IrisLectureIngestionSubSettings irisLectureIngestionSettings) {
+        this.irisLectureIngestionSettings = irisLectureIngestionSettings;
+    }
+
     @Override
     public IrisChatSubSettings getIrisChatSettings() {
         return irisChatSettings;

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisLectureIngestionSubSettings.java

@@ -0,0 +1,29 @@
+package de.tum.in.www1.artemis.domain.iris.settings;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.DiscriminatorValue;
+import jakarta.persistence.Entity;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+
+/**
+ * Represents the specific ingestion sub-settings of lectures for Iris.
+ * This class extends {@link IrisSubSettings} to provide settings required for lecture data ingestion.
+ */
+@Entity
+@DiscriminatorValue("LECTURE_INGESTION")
+@JsonInclude(JsonInclude.Include.NON_EMPTY)
+public class IrisLectureIngestionSubSettings extends IrisSubSettings {
+
+    @Column(name = "auto_ingest_on_lecture_attachment_upload")
+    private boolean autoIngestOnLectureAttachmentUpload;
+
+    public boolean getAutoIngestOnLectureAttachmentUpload() {
+        return autoIngestOnLectureAttachmentUpload;
+    }
+
+    public void setAutoIngestOnLectureAttachmentUpload(boolean autoIngestOnLectureAttachmentUpload) {
+        this.autoIngestOnLectureAttachmentUpload = autoIngestOnLectureAttachmentUpload;
+    }
+
+}

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisSettings.java

@@ -45,6 +45,10 @@ public abstract class IrisSettings extends DomainObject {
 
     public abstract void setIrisChatSettings(IrisChatSubSettings irisChatSettings);
 
+    public abstract IrisLectureIngestionSubSettings getIrisLectureIngestionSettings();
+
+    public abstract void setIrisLectureIngestionSettings(IrisLectureIngestionSubSettings irisLectureIngestionSettings);
+
     public abstract IrisHestiaSubSettings getIrisHestiaSettings();
 
     public abstract void setIrisHestiaSettings(IrisHestiaSubSettings irisHestiaSettings);

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisSubSettings.java

@@ -40,6 +40,7 @@
 // @formatter:off
 @JsonSubTypes({
     @JsonSubTypes.Type(value = IrisChatSubSettings.class, name = "chat"),
+    @JsonSubTypes.Type(value = IrisLectureIngestionSubSettings.class, name = "lecture-ingestion"),
     @JsonSubTypes.Type(value = IrisHestiaSubSettings.class, name = "hestia"),
     @JsonSubTypes.Type(value = IrisCompetencyGenerationSubSettings.class, name = "competency-generation")
 })

src/main/java/de/tum/in/www1/artemis/domain/iris/settings/IrisSubSettingsType.java

@@ -1,5 +1,5 @@
 package de.tum.in.www1.artemis.domain.iris.settings;
 
 public enum IrisSubSettingsType {
-    CHAT, HESTIA, COMPETENCY_GENERATION
+    CHAT, HESTIA, COMPETENCY_GENERATION, LECTURE_INGESTION
 }

src/main/java/de/tum/in/www1/artemis/repository/iris/IrisSettingsRepository.java

@@ -23,6 +23,7 @@ public interface IrisSettingsRepository extends ArtemisJpaRepository<IrisSetting
             SELECT irisSettings
             FROM IrisGlobalSettings irisSettings
                 LEFT JOIN FETCH irisSettings.irisChatSettings
+                LEFT JOIN FETCH irisSettings.irisLectureIngestionSettings
                 LEFT JOIN FETCH irisSettings.irisHestiaSettings
                 LEFT JOIN FETCH irisSettings.irisCompetencyGenerationSettings
             """)
@@ -36,6 +37,7 @@ default IrisGlobalSettings findGlobalSettingsElseThrow() {
             SELECT irisSettings
             FROM IrisCourseSettings irisSettings
                 LEFT JOIN FETCH irisSettings.irisChatSettings
+                LEFT JOIN FETCH irisSettings.irisLectureIngestionSettings
                 LEFT JOIN FETCH irisSettings.irisHestiaSettings
                 LEFT JOIN FETCH irisSettings.irisCompetencyGenerationSettings
             WHERE irisSettings.course.id = :courseId

src/main/java/de/tum/in/www1/artemis/service/AttachmentUnitService.java

@@ -7,6 +7,7 @@
 import java.time.ZonedDateTime;
 import java.util.List;
 import java.util.Objects;
+import java.util.Optional;
 
 import org.apache.commons.io.FilenameUtils;
 import org.springframework.context.annotation.Profile;
@@ -20,6 +21,8 @@
 import de.tum.in.www1.artemis.repository.AttachmentRepository;
 import de.tum.in.www1.artemis.repository.AttachmentUnitRepository;
 import de.tum.in.www1.artemis.repository.SlideRepository;
+import de.tum.in.www1.artemis.repository.iris.IrisSettingsRepository;
+import de.tum.in.www1.artemis.service.connectors.pyris.PyrisWebhookService;
 import de.tum.in.www1.artemis.web.rest.errors.BadRequestAlertException;
 
 @Profile(PROFILE_CORE)
@@ -36,13 +39,20 @@ public class AttachmentUnitService {
 
     private final SlideRepository slideRepository;
 
+    private final Optional<PyrisWebhookService> pyrisWebhookService;
+
+    private final Optional<IrisSettingsRepository> irisSettingsRepository;
+
     public AttachmentUnitService(SlideRepository slideRepository, SlideSplitterService slideSplitterService, AttachmentUnitRepository attachmentUnitRepository,
-            AttachmentRepository attachmentRepository, FileService fileService) {
+            AttachmentRepository attachmentRepository, FileService fileService, Optional<PyrisWebhookService> pyrisWebhookService,
+            Optional<IrisSettingsRepository> irisSettingsRepository) {
         this.attachmentUnitRepository = attachmentUnitRepository;
         this.attachmentRepository = attachmentRepository;
         this.fileService = fileService;
         this.slideSplitterService = slideSplitterService;
         this.slideRepository = slideRepository;
+        this.pyrisWebhookService = pyrisWebhookService;
+        this.irisSettingsRepository = irisSettingsRepository;
     }
 
     /**
@@ -70,7 +80,9 @@ public AttachmentUnit createAttachmentUnit(AttachmentUnit attachmentUnit, Attach
         Attachment savedAttachment = attachmentRepository.saveAndFlush(attachment);
         savedAttachmentUnit.setAttachment(savedAttachment);
         evictCache(file, savedAttachmentUnit);
-
+        if (pyrisWebhookService.isPresent() && irisSettingsRepository.isPresent()) {
+            pyrisWebhookService.get().autoUpdateAttachmentUnitsInPyris(lecture.getCourse().getId(), List.of(savedAttachmentUnit));
+        }
         return savedAttachmentUnit;
     }
 
@@ -118,8 +130,10 @@ public AttachmentUnit updateAttachmentUnit(AttachmentUnit existingAttachmentUnit
             if (Objects.equals(FilenameUtils.getExtension(updateFile.getOriginalFilename()), "pdf")) {
                 slideSplitterService.splitAttachmentUnitIntoSingleSlides(savedAttachmentUnit);
             }
+            if (pyrisWebhookService.isPresent() && irisSettingsRepository.isPresent()) {
+                pyrisWebhookService.get().autoUpdateAttachmentUnitsInPyris(savedAttachmentUnit.getLecture().getCourse().getId(), List.of(savedAttachmentUnit));
+            }
         }
-
         return savedAttachmentUnit;
     }
 

src/main/java/de/tum/in/www1/artemis/service/LectureImportService.java

@@ -9,6 +9,7 @@
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Optional;
 import java.util.Set;
 
 import org.apache.commons.io.FileUtils;
@@ -30,6 +31,8 @@
 import de.tum.in.www1.artemis.repository.AttachmentRepository;
 import de.tum.in.www1.artemis.repository.LectureRepository;
 import de.tum.in.www1.artemis.repository.LectureUnitRepository;
+import de.tum.in.www1.artemis.repository.iris.IrisSettingsRepository;
+import de.tum.in.www1.artemis.service.connectors.pyris.PyrisWebhookService;
 
 @Profile(PROFILE_CORE)
 @Service
@@ -43,10 +46,17 @@ public class LectureImportService {
 
     private final AttachmentRepository attachmentRepository;
 
-    public LectureImportService(LectureRepository lectureRepository, LectureUnitRepository lectureUnitRepository, AttachmentRepository attachmentRepository) {
+    private final Optional<PyrisWebhookService> pyrisWebhookService;
+
+    private final Optional<IrisSettingsRepository> irisSettingsRepository;
+
+    public LectureImportService(LectureRepository lectureRepository, LectureUnitRepository lectureUnitRepository, AttachmentRepository attachmentRepository,
+            Optional<PyrisWebhookService> pyrisWebhookService, Optional<IrisSettingsRepository> irisSettingsRepository) {
         this.lectureRepository = lectureRepository;
         this.lectureUnitRepository = lectureUnitRepository;
         this.attachmentRepository = attachmentRepository;
+        this.pyrisWebhookService = pyrisWebhookService;
+        this.irisSettingsRepository = irisSettingsRepository;
     }
 
     /**
@@ -92,7 +102,11 @@ public Lecture importLecture(final Lecture importedLecture, final Course course)
         }
         lecture.setAttachments(attachments);
         attachmentRepository.saveAll(attachments);
-
+        // Send lectures to pyris
+        if (pyrisWebhookService.isPresent() && irisSettingsRepository.isPresent()) {
+            pyrisWebhookService.get().autoUpdateAttachmentUnitsInPyris(lecture.getCourse().getId(),
+                    lectureUnits.stream().filter(lectureUnit -> lectureUnit instanceof AttachmentUnit).map(lectureUnit -> (AttachmentUnit) lectureUnit).toList());
+        }
         // Save again to establish the ordered list relationship
         return lectureRepository.save(lecture);
     }
@@ -133,7 +147,6 @@ else if (importedLectureUnit instanceof AttachmentUnit importedAttachmentUnit) {
             attachment.setAttachmentUnit(attachmentUnit);
             attachmentRepository.save(attachment);
             attachmentUnit.setAttachment(attachment);
-
             return attachmentUnit;
         }
         else if (importedLectureUnit instanceof OnlineUnit importedOnlineUnit) {

src/main/java/de/tum/in/www1/artemis/service/LectureService.java

@@ -6,6 +6,7 @@
 import java.util.ArrayList;
 import java.util.HashSet;
 import java.util.List;
+import java.util.Optional;
 import java.util.Set;
 
 import org.springframework.context.annotation.Profile;
@@ -21,6 +22,7 @@
 import de.tum.in.www1.artemis.domain.metis.conversation.Channel;
 import de.tum.in.www1.artemis.repository.LectureRepository;
 import de.tum.in.www1.artemis.repository.metis.conversation.ChannelRepository;
+import de.tum.in.www1.artemis.service.connectors.pyris.PyrisWebhookService;
 import de.tum.in.www1.artemis.service.metis.conversation.ChannelService;
 import de.tum.in.www1.artemis.web.rest.dto.SearchResultPageDTO;
 import de.tum.in.www1.artemis.web.rest.dto.pageablesearch.SearchTermPageableSearchDTO;
@@ -38,11 +40,15 @@ public class LectureService {
 
     private final ChannelService channelService;
 
-    public LectureService(LectureRepository lectureRepository, AuthorizationCheckService authCheckService, ChannelRepository channelRepository, ChannelService channelService) {
+    private final Optional<PyrisWebhookService> pyrisWebhookService;
+
+    public LectureService(LectureRepository lectureRepository, AuthorizationCheckService authCheckService, ChannelRepository channelRepository, ChannelService channelService,
+            Optional<PyrisWebhookService> pyrisWebhookService) {
         this.lectureRepository = lectureRepository;
         this.authCheckService = authCheckService;
         this.channelRepository = channelRepository;
         this.channelService = channelService;
+        this.pyrisWebhookService = pyrisWebhookService;
     }
 
     /**
@@ -133,9 +139,33 @@ public SearchResultPageDTO<Lecture> getAllOnPageWithSize(final SearchTermPageabl
      * @param lecture the lecture to be deleted
      */
     public void delete(Lecture lecture) {
+        if (pyrisWebhookService.isPresent()) {
+            Lecture lectureWithAttachmentUnits = lectureRepository.findByIdWithLectureUnitsAndAttachmentsElseThrow(lecture.getId());
+            List<AttachmentUnit> attachmentUnitList = lectureWithAttachmentUnits.getLectureUnits().stream().filter(lectureUnit -> lectureUnit instanceof AttachmentUnit)
+                    .map(lectureUnit -> (AttachmentUnit) lectureUnit).toList();
+            if (!attachmentUnitList.isEmpty()) {
+                pyrisWebhookService.get().deleteLectureFromPyrisDB(attachmentUnitList);
+            }
+        }
         Channel lectureChannel = channelRepository.findChannelByLectureId(lecture.getId());
         channelService.deleteChannel(lectureChannel);
         lectureRepository.deleteById(lecture.getId());
     }
 
+    /**
+     * Ingest the lectures when triggered by the ingest lectures button
+     *
+     * @param lectures set of lectures to be ingested
+     * @return returns the job token if the operation is successful else it returns null
+     */
+    public boolean ingestLecturesInPyris(Set<Lecture> lectures) {
+        if (pyrisWebhookService.isPresent()) {
+            List<AttachmentUnit> attachmentUnitList = lectures.stream().flatMap(lec -> lec.getLectureUnits().stream()).filter(unit -> unit instanceof AttachmentUnit)
+                    .map(unit -> (AttachmentUnit) unit).toList();
+            if (!attachmentUnitList.isEmpty()) {
+                return pyrisWebhookService.get().addLectureUnitsToPyrisDB(attachmentUnitList) != null;
+            }
+        }
+        return false;
+    }
 }

src/main/java/de/tum/in/www1/artemis/service/LectureUnitService.java

@@ -36,6 +36,7 @@
 import de.tum.in.www1.artemis.repository.LectureUnitCompletionRepository;
 import de.tum.in.www1.artemis.repository.LectureUnitRepository;
 import de.tum.in.www1.artemis.repository.SlideRepository;
+import de.tum.in.www1.artemis.service.connectors.pyris.PyrisWebhookService;
 
 @Profile(PROFILE_CORE)
 @Service
@@ -55,15 +56,19 @@ public class LectureUnitService {
 
     private final ExerciseRepository exerciseRepository;
 
+    private final Optional<PyrisWebhookService> pyrisWebhookService;
+
     public LectureUnitService(LectureUnitRepository lectureUnitRepository, LectureRepository lectureRepository, CompetencyRepository competencyRepository,
-            LectureUnitCompletionRepository lectureUnitCompletionRepository, FileService fileService, SlideRepository slideRepository, ExerciseRepository exerciseRepository) {
+            LectureUnitCompletionRepository lectureUnitCompletionRepository, FileService fileService, SlideRepository slideRepository, ExerciseRepository exerciseRepository,
+            Optional<PyrisWebhookService> pyrisWebhookService) {
         this.lectureUnitRepository = lectureUnitRepository;
         this.lectureRepository = lectureRepository;
         this.competencyRepository = competencyRepository;
         this.lectureUnitCompletionRepository = lectureUnitCompletionRepository;
         this.fileService = fileService;
         this.slideRepository = slideRepository;
         this.exerciseRepository = exerciseRepository;
+        this.pyrisWebhookService = pyrisWebhookService;
     }
 
     /**
@@ -162,6 +167,7 @@ public void removeLectureUnit(@NotNull LectureUnit lectureUnit) {
                 for (Slide slide : slides) {
                     fileService.schedulePathForDeletion(FilePathService.actualPathForPublicPathOrThrow(URI.create(slide.getSlideImagePath())), 5);
                 }
+                pyrisWebhookService.ifPresent(service -> service.deleteLectureFromPyrisDB(List.of(attachmentUnit)));
                 slideRepository.deleteAll(slides);
             }
         }