Merge branch 'moduledecoupled' into 'develop'
Remove unused code files and update dependencies See merge request olympus_ai/apollo!5
This commit is contained in:
@@ -5,16 +5,18 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|||||||
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
||||||
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
|
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
|
||||||
import org.springframework.cloud.openfeign.EnableFeignClients;
|
import org.springframework.cloud.openfeign.EnableFeignClients;
|
||||||
|
import org.springframework.context.annotation.ComponentScan;
|
||||||
import org.springframework.context.annotation.Configuration;
|
import org.springframework.context.annotation.Configuration;
|
||||||
import org.springframework.scheduling.annotation.EnableAsync;
|
import org.springframework.scheduling.annotation.EnableAsync;
|
||||||
|
|
||||||
import com.olympus.apollo.properties.StorageProperties;
|
import com.olympus.apollo.properties.StorageProperties;
|
||||||
|
|
||||||
@SpringBootApplication(scanBasePackages = {"com.olympus.apollo", "com.olympus.feign"})
|
@SpringBootApplication
|
||||||
@EnableConfigurationProperties(StorageProperties.class)
|
@EnableConfigurationProperties(StorageProperties.class)
|
||||||
@EnableAsync
|
@EnableAsync
|
||||||
@Configuration
|
@Configuration
|
||||||
@EnableDiscoveryClient
|
@EnableDiscoveryClient
|
||||||
|
@ComponentScan(basePackages = {"com.olympus.apollo", "com.olympus.feign", "com.olympus.dto","com.olympus.model"})
|
||||||
@EnableFeignClients(basePackages = "com.olympus.feign")
|
@EnableFeignClients(basePackages = "com.olympus.feign")
|
||||||
public class ApolloApplication {
|
public class ApolloApplication {
|
||||||
|
|
||||||
|
|||||||
@@ -1,31 +1,25 @@
|
|||||||
package com.olympus.apollo.controllers.FeApi;
|
package com.olympus.apollo.controllers.FeApi;
|
||||||
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.text.SimpleDateFormat;
|
import java.text.SimpleDateFormat;
|
||||||
import java.util.Date;
|
import java.util.Date;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.concurrent.CompletableFuture;
|
|
||||||
|
|
||||||
import com.olympus.apollo.dto.*;
|
import com.olympus.apollo.dto.*;
|
||||||
import com.olympus.apollo.exception.GitCloneException;
|
import com.olympus.apollo.exception.GitCloneException;
|
||||||
import com.olympus.apollo.services.GitService;
|
import com.olympus.apollo.services.GitService;
|
||||||
import com.olympus.apollo.utils.GitUtils;
|
import com.olympus.apollo.utils.GitUtils;
|
||||||
import org.eclipse.jgit.api.errors.GitAPIException;
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.beans.factory.annotation.Value;
|
||||||
import org.springframework.http.HttpStatus;
|
|
||||||
import org.springframework.http.HttpStatusCode;
|
|
||||||
import org.springframework.http.ResponseEntity;
|
import org.springframework.http.ResponseEntity;
|
||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
import com.olympus.apollo.models.KSGitIngestionInfo;
|
import com.olympus.model.apollo.KSGitIngestionInfo;
|
||||||
import com.olympus.apollo.repository.KSGitInfoRepository;
|
import com.olympus.apollo.repository.KSGitInfoRepository;
|
||||||
import com.olympus.apollo.repository.KSGitIngestionInfoRepository;
|
import com.olympus.apollo.repository.KSGitIngestionInfoRepository;
|
||||||
import com.olympus.apollo.services.KSGitInfoService;
|
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
@RequestMapping("/fe-api/ks_git_repos")
|
@RequestMapping("/fe-api/ks_git_repos")
|
||||||
|
|||||||
@@ -1,12 +1,11 @@
|
|||||||
package com.olympus.apollo.controllers.FeApi;
|
package com.olympus.apollo.controllers.FeApi;
|
||||||
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSDocument;
|
import com.olympus.model.apollo.KSDocument;
|
||||||
import com.olympus.apollo.repository.KSDocumentRepository;
|
import com.olympus.apollo.repository.KSDocumentRepository;
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ package com.olympus.apollo.controllers.FeApi;
|
|||||||
import com.olympus.apollo.dto.DeleteGitRepoDetailsRequest;
|
import com.olympus.apollo.dto.DeleteGitRepoDetailsRequest;
|
||||||
import com.olympus.apollo.dto.DeletionRequest;
|
import com.olympus.apollo.dto.DeletionRequest;
|
||||||
import com.olympus.apollo.dto.VectorStoreDetails;
|
import com.olympus.apollo.dto.VectorStoreDetails;
|
||||||
import com.olympus.apollo.models.VectorStore;
|
import com.olympus.model.apollo.VectorStore;
|
||||||
import com.olympus.apollo.repository.VectorStoreRepository;
|
import com.olympus.apollo.repository.VectorStoreRepository;
|
||||||
import com.olympus.apollo.services.DeletionService;
|
import com.olympus.apollo.services.DeletionService;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
|
|||||||
@@ -6,11 +6,8 @@ import java.text.SimpleDateFormat;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
import com.olympus.apollo.dto.DeletionRequest;
|
|
||||||
import com.olympus.apollo.dto.ExternalFileIngestionDTO;
|
import com.olympus.apollo.dto.ExternalFileIngestionDTO;
|
||||||
import com.olympus.apollo.dto.IngestionOutput;
|
import com.olympus.model.apollo.KSTexts;
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
|
||||||
import com.olympus.apollo.models.KSTexts;
|
|
||||||
import com.olympus.apollo.repository.KSTextsRepository;
|
import com.olympus.apollo.repository.KSTextsRepository;
|
||||||
import com.olympus.apollo.services.DeletionService;
|
import com.olympus.apollo.services.DeletionService;
|
||||||
import com.olympus.apollo.services.KSIngestor;
|
import com.olympus.apollo.services.KSIngestor;
|
||||||
@@ -19,16 +16,14 @@ import org.springframework.http.ResponseEntity;
|
|||||||
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.bind.annotation.*;
|
||||||
import org.springframework.web.multipart.MultipartFile;
|
import org.springframework.web.multipart.MultipartFile;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSDocument;
|
import com.olympus.model.apollo.KSDocument;
|
||||||
import com.olympus.apollo.models.KSIngestionInfo;
|
import com.olympus.model.apollo.KSIngestionInfo;
|
||||||
import com.olympus.apollo.repository.KSDocumentRepository;
|
import com.olympus.apollo.repository.KSDocumentRepository;
|
||||||
import com.olympus.apollo.repository.KSIngestionInfoRepository;
|
import com.olympus.apollo.repository.KSIngestionInfoRepository;
|
||||||
import com.olympus.apollo.exception.StorageFileNotFoundException;
|
import com.olympus.apollo.exception.StorageFileNotFoundException;
|
||||||
import com.olympus.apollo.services.StorageService;
|
import com.olympus.apollo.services.StorageService;
|
||||||
import com.olympus.apollo.dto.FileUploadDTO;
|
import com.olympus.apollo.dto.FileUploadDTO;
|
||||||
|
|
||||||
import javax.swing.text.html.Option;
|
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
public class KSFileController {
|
public class KSFileController {
|
||||||
@Autowired
|
@Autowired
|
||||||
|
|||||||
@@ -4,7 +4,6 @@ import java.util.List;
|
|||||||
|
|
||||||
import com.olympus.apollo.dto.ResultDTO;
|
import com.olympus.apollo.dto.ResultDTO;
|
||||||
import com.olympus.apollo.feign.services.ParserModuleService;
|
import com.olympus.apollo.feign.services.ParserModuleService;
|
||||||
import com.olympus.apollo.models.ParseProcess;
|
|
||||||
import com.olympus.apollo.services.GitService;
|
import com.olympus.apollo.services.GitService;
|
||||||
import com.olympus.dto.JavaParseRequest;
|
import com.olympus.dto.JavaParseRequest;
|
||||||
import com.olympus.dto.ParseRequest;
|
import com.olympus.dto.ParseRequest;
|
||||||
|
|||||||
@@ -1,8 +1,6 @@
|
|||||||
package com.olympus.apollo.dto;
|
package com.olympus.apollo.dto;
|
||||||
|
|
||||||
import com.olympus.apollo.models.CodeTypes;
|
import com.olympus.model.apollo.CodeTypes;
|
||||||
import com.olympus.apollo.models.ParseStatuses;
|
|
||||||
import com.olympus.apollo.models.RevEngineeringStatuses;
|
|
||||||
import lombok.Getter;
|
import lombok.Getter;
|
||||||
import lombok.Setter;
|
import lombok.Setter;
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
package com.olympus.apollo.feign.services;
|
package com.olympus.apollo.feign.services;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
import com.olympus.apollo.repository.KSGitInfoRepository;
|
import com.olympus.apollo.repository.KSGitInfoRepository;
|
||||||
import com.olympus.dto.ParseRequest;
|
import com.olympus.dto.ParseRequest;
|
||||||
import com.olympus.feign.JavaParserModule;
|
import com.olympus.feign.JavaParserModule;
|
||||||
|
|||||||
@@ -1,11 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Getter @Setter
|
|
||||||
public class CodeTypes {
|
|
||||||
private String type;
|
|
||||||
private String re_scenario;
|
|
||||||
private String[] base_source;
|
|
||||||
}
|
|
||||||
@@ -1,34 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Document(collection = "ksdocuments")
|
|
||||||
@Getter @Setter
|
|
||||||
public class KSDocument {
|
|
||||||
|
|
||||||
|
|
||||||
private @Id String id;
|
|
||||||
|
|
||||||
private String name;
|
|
||||||
private String description;
|
|
||||||
|
|
||||||
private String filePath;
|
|
||||||
private String fileName;
|
|
||||||
|
|
||||||
|
|
||||||
private String ingestionStatus;
|
|
||||||
//private String ingestionMessage;
|
|
||||||
private Date ingestionDate;
|
|
||||||
private String ingestionDateFormat;
|
|
||||||
|
|
||||||
private KSIngestionInfo ingestionInfo;
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -1,39 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Document(collection = "ksgit_info")
|
|
||||||
@Getter
|
|
||||||
@Setter
|
|
||||||
public class KSGitInfo {
|
|
||||||
@Id
|
|
||||||
private String id;
|
|
||||||
|
|
||||||
private String repoName;
|
|
||||||
private String branch;
|
|
||||||
private String commitId;
|
|
||||||
private String repoPath;
|
|
||||||
private KSGitIngestionInfo ksGitIngestionInfo;
|
|
||||||
private HashMap<String, String> gitModifiedFiles;
|
|
||||||
private String cloneStatus;
|
|
||||||
private String ingestionStatus;
|
|
||||||
private Date ingestionDate;
|
|
||||||
private String ingestionDateFormat;
|
|
||||||
|
|
||||||
private boolean codeParsingToBeDone;
|
|
||||||
//private String parseStatus;
|
|
||||||
//private String reverseEngineeringStatus;
|
|
||||||
//private String codeType;
|
|
||||||
//private String parseId;
|
|
||||||
private List<CodeTypes> codeTypes;
|
|
||||||
private List<ParseStatuses> parseStatuses;
|
|
||||||
private List<RevEngineeringStatuses> revEngineeringStatuses;
|
|
||||||
}
|
|
||||||
@@ -1,21 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import java.util.HashMap;
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Document(collection = "ksgit_ingestioninfo")
|
|
||||||
@Getter @Setter
|
|
||||||
public class KSGitIngestionInfo {
|
|
||||||
@Id
|
|
||||||
private String id;
|
|
||||||
|
|
||||||
private String type;
|
|
||||||
private HashMap<String, String> metadata;
|
|
||||||
private int minChunkSizeToEmbed;
|
|
||||||
private int maxNumberOfChunks;
|
|
||||||
private int minChunkSize;
|
|
||||||
private int defaultChunkSize;
|
|
||||||
}
|
|
||||||
@@ -1,30 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
|
|
||||||
import java.util.HashMap;
|
|
||||||
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
|
|
||||||
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Document(collection = "ksingestioninfo")
|
|
||||||
@Getter @Setter
|
|
||||||
public class KSIngestionInfo {
|
|
||||||
|
|
||||||
private @Id String id;
|
|
||||||
|
|
||||||
|
|
||||||
private String type;
|
|
||||||
|
|
||||||
private HashMap<String,String> metadata;
|
|
||||||
|
|
||||||
private int minChunkSizeToEmbed;
|
|
||||||
private int maxNumberOfChunks;
|
|
||||||
private int minChunkSize;
|
|
||||||
private int defaultChunkSize;
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -1,34 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
import java.util.HashMap;
|
|
||||||
|
|
||||||
@Document(collection = "ksinternal")
|
|
||||||
@Getter @Setter
|
|
||||||
public class KSTexts {
|
|
||||||
private @Id String id;
|
|
||||||
private String textToEmbed;
|
|
||||||
private String name;
|
|
||||||
private String description;
|
|
||||||
|
|
||||||
private String ingestionStatus;
|
|
||||||
//private String ingestionMessage;
|
|
||||||
private Date ingestionDate;
|
|
||||||
private String ingestionDateFormat;
|
|
||||||
|
|
||||||
//private KSIngestionInfo ingestionInfo;
|
|
||||||
private String type;
|
|
||||||
private HashMap IngestionInfo;
|
|
||||||
private HashMap<String,String> metadata;
|
|
||||||
|
|
||||||
private int minChunkSizeToEmbed;
|
|
||||||
private int maxNumberOfChunks;
|
|
||||||
private int minChunkSize;
|
|
||||||
private int defaultChunkSize;
|
|
||||||
private HashMap additionalMetadata;
|
|
||||||
}
|
|
||||||
@@ -1,42 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
|
|
||||||
import java.util.Date;
|
|
||||||
|
|
||||||
@Document(collection = "parse_process")
|
|
||||||
@Getter
|
|
||||||
@Setter
|
|
||||||
public class ParseProcess {
|
|
||||||
|
|
||||||
public ParseProcess(String applicationName) {
|
|
||||||
this.applicationName = applicationName;
|
|
||||||
this.status = "IN_PROGRESS";
|
|
||||||
this.parsedFiles = 0;
|
|
||||||
this.startDate = new Date();
|
|
||||||
}
|
|
||||||
|
|
||||||
@Id
|
|
||||||
private String id;
|
|
||||||
|
|
||||||
private String repositoryId;
|
|
||||||
|
|
||||||
private String applicationName;
|
|
||||||
|
|
||||||
private Integer totalFiles;
|
|
||||||
|
|
||||||
private Integer parsedFiles;
|
|
||||||
|
|
||||||
private String currentFile;
|
|
||||||
|
|
||||||
private Date startDate;
|
|
||||||
|
|
||||||
private Date endDate;
|
|
||||||
|
|
||||||
private String status;
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -1,13 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Getter @Setter
|
|
||||||
@AllArgsConstructor
|
|
||||||
public class ParseStatuses {
|
|
||||||
private String type;
|
|
||||||
private String Status;
|
|
||||||
private String parseProcessId;
|
|
||||||
}
|
|
||||||
@@ -1,13 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import lombok.AllArgsConstructor;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.Setter;
|
|
||||||
|
|
||||||
@Getter @Setter
|
|
||||||
@AllArgsConstructor
|
|
||||||
public class RevEngineeringStatuses {
|
|
||||||
private String type;
|
|
||||||
private String status;
|
|
||||||
private String revProcessId;
|
|
||||||
}
|
|
||||||
@@ -1,20 +0,0 @@
|
|||||||
package com.olympus.apollo.models;
|
|
||||||
|
|
||||||
import lombok.Getter;
|
|
||||||
import org.springframework.data.annotation.Id;
|
|
||||||
import org.springframework.data.mongodb.core.mapping.Document;
|
|
||||||
|
|
||||||
import java.util.HashMap;
|
|
||||||
|
|
||||||
@Document(collection = "vector_store")
|
|
||||||
@Getter
|
|
||||||
public class VectorStore {
|
|
||||||
private @Id String id;
|
|
||||||
|
|
||||||
private HashMap<String, String> metadata;
|
|
||||||
private String content;
|
|
||||||
private String media;
|
|
||||||
private String embedding;
|
|
||||||
private HashMap<String, String> contentFormatter;
|
|
||||||
|
|
||||||
}
|
|
||||||
@@ -6,7 +6,7 @@ import org.springframework.data.repository.query.Param;
|
|||||||
import org.springframework.data.rest.core.annotation.RepositoryRestResource;
|
import org.springframework.data.rest.core.annotation.RepositoryRestResource;
|
||||||
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSDocument;
|
import com.olympus.model.apollo.KSDocument;
|
||||||
|
|
||||||
@RepositoryRestResource(collectionResourceRel = "ksdocuments", path = "ksdocuments")
|
@RepositoryRestResource(collectionResourceRel = "ksdocuments", path = "ksdocuments")
|
||||||
@CrossOrigin
|
@CrossOrigin
|
||||||
|
|||||||
@@ -1,16 +1,12 @@
|
|||||||
package com.olympus.apollo.repository;
|
package com.olympus.apollo.repository;
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
import com.olympus.apollo.models.VectorStore;
|
|
||||||
import org.springframework.data.mongodb.repository.MongoRepository;
|
import org.springframework.data.mongodb.repository.MongoRepository;
|
||||||
import org.springframework.data.mongodb.repository.Query;
|
import org.springframework.data.mongodb.repository.Query;
|
||||||
import org.springframework.data.rest.core.annotation.RepositoryRestResource;
|
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
import org.springframework.web.bind.annotation.CrossOrigin;
|
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
|
|
||||||
@Repository
|
@Repository
|
||||||
public interface KSGitInfoRepository extends MongoRepository<KSGitInfo, String> {
|
public interface KSGitInfoRepository extends MongoRepository<KSGitInfo, String> {
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ package com.olympus.apollo.repository;
|
|||||||
import org.springframework.data.mongodb.repository.MongoRepository;
|
import org.springframework.data.mongodb.repository.MongoRepository;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSGitIngestionInfo;
|
import com.olympus.model.apollo.KSGitIngestionInfo;
|
||||||
|
|
||||||
@Repository
|
@Repository
|
||||||
public interface KSGitIngestionInfoRepository extends MongoRepository<KSGitIngestionInfo, String> {
|
public interface KSGitIngestionInfoRepository extends MongoRepository<KSGitIngestionInfo, String> {
|
||||||
|
|||||||
@@ -3,10 +3,9 @@ package com.olympus.apollo.repository;
|
|||||||
import org.springframework.data.repository.CrudRepository;
|
import org.springframework.data.repository.CrudRepository;
|
||||||
import org.springframework.stereotype.Repository;
|
import org.springframework.stereotype.Repository;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSIngestionInfo;
|
import com.olympus.model.apollo.KSIngestionInfo;
|
||||||
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
||||||
|
|
||||||
@CrossOrigin
|
|
||||||
@Repository
|
@Repository
|
||||||
public interface KSIngestionInfoRepository extends CrudRepository<KSIngestionInfo, String> {
|
public interface KSIngestionInfoRepository extends CrudRepository<KSIngestionInfo, String> {
|
||||||
|
|
||||||
|
|||||||
@@ -1,18 +1,14 @@
|
|||||||
package com.olympus.apollo.repository;
|
package com.olympus.apollo.repository;
|
||||||
|
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSDocument;
|
import com.olympus.model.apollo.KSTexts;
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
|
||||||
import com.olympus.apollo.models.KSTexts;
|
|
||||||
import org.springframework.data.mongodb.repository.MongoRepository;
|
import org.springframework.data.mongodb.repository.MongoRepository;
|
||||||
import org.springframework.data.mongodb.repository.Query;
|
import org.springframework.data.mongodb.repository.Query;
|
||||||
import org.springframework.data.rest.core.annotation.RepositoryRestResource;
|
import org.springframework.data.rest.core.annotation.RepositoryRestResource;
|
||||||
import org.springframework.web.bind.annotation.CrossOrigin;
|
|
||||||
|
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
|
|
||||||
@RepositoryRestResource(collectionResourceRel = "ksinternal", path = "ksinternal")
|
@RepositoryRestResource(collectionResourceRel = "ksinternal", path = "ksinternal")
|
||||||
@CrossOrigin
|
|
||||||
public interface KSTextsRepository extends MongoRepository<KSTexts, String> {
|
public interface KSTextsRepository extends MongoRepository<KSTexts, String> {
|
||||||
|
|
||||||
@Query("{'name': ?0}")
|
@Query("{'name': ?0}")
|
||||||
|
|||||||
@@ -1,7 +1,8 @@
|
|||||||
package com.olympus.apollo.repository;
|
package com.olympus.apollo.repository;
|
||||||
|
|
||||||
|
|
||||||
import com.olympus.apollo.dto.VectorStoreDetails;
|
import com.olympus.apollo.dto.VectorStoreDetails;
|
||||||
import com.olympus.apollo.models.VectorStore;
|
import com.olympus.model.apollo.VectorStore;
|
||||||
import org.springframework.data.mongodb.repository.Aggregation;
|
import org.springframework.data.mongodb.repository.Aggregation;
|
||||||
import org.springframework.data.mongodb.repository.MongoRepository;
|
import org.springframework.data.mongodb.repository.MongoRepository;
|
||||||
import org.springframework.data.mongodb.repository.Query;
|
import org.springframework.data.mongodb.repository.Query;
|
||||||
|
|||||||
@@ -3,23 +3,18 @@ package com.olympus.apollo.services;
|
|||||||
import com.olympus.apollo.dto.DeleteGitRepoDetailsRequest;
|
import com.olympus.apollo.dto.DeleteGitRepoDetailsRequest;
|
||||||
import com.olympus.apollo.dto.ResultDTO;
|
import com.olympus.apollo.dto.ResultDTO;
|
||||||
import com.olympus.apollo.exception.vectorStoreMetaDetailsEmptyException;
|
import com.olympus.apollo.exception.vectorStoreMetaDetailsEmptyException;
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
|
||||||
import com.olympus.apollo.models.KSGitIngestionInfo;
|
|
||||||
import com.olympus.apollo.models.KSIngestionInfo;
|
|
||||||
import com.olympus.apollo.repository.*;
|
import com.olympus.apollo.repository.*;
|
||||||
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import com.olympus.apollo.dto.DeletionRequest;
|
import com.olympus.apollo.dto.DeletionRequest;
|
||||||
import com.olympus.apollo.dto.VectorStoreMetadataDetails;
|
import com.olympus.model.apollo.VectorStore;
|
||||||
import com.olympus.apollo.models.VectorStore;
|
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.messaging.simp.SimpMessagingTemplate;
|
import org.springframework.messaging.simp.SimpMessagingTemplate;
|
||||||
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Async;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import java.util.Collection;
|
|
||||||
import java.util.Collections;
|
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Optional;
|
import java.util.Optional;
|
||||||
import java.util.concurrent.CompletableFuture;
|
import java.util.concurrent.CompletableFuture;
|
||||||
|
|||||||
@@ -13,10 +13,8 @@ import java.util.concurrent.CompletableFuture;
|
|||||||
import java.util.regex.Matcher;
|
import java.util.regex.Matcher;
|
||||||
import java.util.regex.Pattern;
|
import java.util.regex.Pattern;
|
||||||
|
|
||||||
import com.olympus.apollo.dto.GitCloneOutput;
|
|
||||||
import com.olympus.apollo.dto.ResultDTO;
|
import com.olympus.apollo.dto.ResultDTO;
|
||||||
import com.olympus.apollo.exception.BranchCheckoutException;
|
import com.olympus.apollo.exception.BranchCheckoutException;
|
||||||
import com.olympus.apollo.exception.GitCloneException;
|
|
||||||
import com.olympus.apollo.repository.VectorStoreRepository;
|
import com.olympus.apollo.repository.VectorStoreRepository;
|
||||||
import org.eclipse.jgit.api.Git;
|
import org.eclipse.jgit.api.Git;
|
||||||
import org.eclipse.jgit.api.errors.GitAPIException;
|
import org.eclipse.jgit.api.errors.GitAPIException;
|
||||||
@@ -30,14 +28,13 @@ import org.springframework.ai.transformer.splitter.TokenTextSplitter;
|
|||||||
import org.springframework.ai.vectorstore.VectorStore;
|
import org.springframework.ai.vectorstore.VectorStore;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.beans.factory.annotation.Value;
|
||||||
import org.springframework.http.ResponseEntity;
|
|
||||||
import org.springframework.messaging.simp.SimpMessagingTemplate;
|
import org.springframework.messaging.simp.SimpMessagingTemplate;
|
||||||
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Async;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import com.olympus.apollo.dto.IngestionOutput;
|
import com.olympus.apollo.dto.IngestionOutput;
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
import com.olympus.apollo.models.KSGitIngestionInfo;
|
import com.olympus.model.apollo.KSGitIngestionInfo;
|
||||||
import com.olympus.apollo.repository.KSGitInfoRepository;
|
import com.olympus.apollo.repository.KSGitInfoRepository;
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
@@ -246,7 +243,7 @@ public class GitRepositoryIngestor {
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
for (String fileToDelete : filePathsToDelete) {
|
for (String fileToDelete : filePathsToDelete) {
|
||||||
Optional<com.olympus.apollo.models.VectorStore> optionalDocument = vectorStoreRepository.findByKsapplicationNameKsBranchFilePath(repoName,branchName,fileToDelete);
|
Optional<com.olympus.model.apollo.VectorStore> optionalDocument = vectorStoreRepository.findByKsapplicationNameKsBranchFilePath(repoName,branchName,fileToDelete);
|
||||||
if (optionalDocument.isPresent()) {
|
if (optionalDocument.isPresent()) {
|
||||||
String vectorStoreId = optionalDocument.get().getId();
|
String vectorStoreId = optionalDocument.get().getId();
|
||||||
vectorStoreRepository.deleteById(vectorStoreId);
|
vectorStoreRepository.deleteById(vectorStoreId);
|
||||||
|
|||||||
@@ -1,11 +1,10 @@
|
|||||||
package com.olympus.apollo.services;
|
package com.olympus.apollo.services;
|
||||||
|
|
||||||
import com.olympus.apollo.dto.GitCloneOutput;
|
|
||||||
import com.olympus.apollo.dto.GitPullOutput;
|
import com.olympus.apollo.dto.GitPullOutput;
|
||||||
import com.olympus.apollo.dto.ResultDTO;
|
import com.olympus.apollo.dto.ResultDTO;
|
||||||
import com.olympus.apollo.exception.BranchCheckoutException;
|
import com.olympus.apollo.exception.BranchCheckoutException;
|
||||||
import com.olympus.apollo.exception.GitCloneException;
|
import com.olympus.apollo.exception.GitCloneException;
|
||||||
import com.olympus.apollo.models.KSGitInfo;
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
import com.olympus.apollo.repository.KSGitInfoRepository;
|
import com.olympus.apollo.repository.KSGitInfoRepository;
|
||||||
import com.olympus.apollo.utils.GitUrlUtils;
|
import com.olympus.apollo.utils.GitUrlUtils;
|
||||||
import com.olympus.apollo.utils.GitUtils;
|
import com.olympus.apollo.utils.GitUtils;
|
||||||
|
|||||||
@@ -4,10 +4,9 @@ import java.util.*;
|
|||||||
import java.text.SimpleDateFormat;
|
import java.text.SimpleDateFormat;
|
||||||
|
|
||||||
import com.olympus.apollo.dto.IngestionOutput;
|
import com.olympus.apollo.dto.IngestionOutput;
|
||||||
import com.olympus.apollo.models.KSDocument;
|
import com.olympus.model.apollo.KSDocument;
|
||||||
import com.olympus.apollo.models.KSTexts;
|
import com.olympus.model.apollo.KSTexts;
|
||||||
import com.olympus.apollo.repository.KSTextsRepository;
|
import com.olympus.apollo.repository.KSTextsRepository;
|
||||||
import org.codelibs.jhighlight.fastutil.Hash;
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.ai.document.Document;
|
import org.springframework.ai.document.Document;
|
||||||
@@ -19,7 +18,7 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|||||||
import org.springframework.core.io.Resource;
|
import org.springframework.core.io.Resource;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import com.olympus.apollo.models.KSIngestionInfo;
|
import com.olympus.model.apollo.KSIngestionInfo;
|
||||||
import com.olympus.apollo.repository.KSDocumentRepository;
|
import com.olympus.apollo.repository.KSDocumentRepository;
|
||||||
import com.olympus.apollo.repository.KSIngestionInfoRepository;
|
import com.olympus.apollo.repository.KSIngestionInfoRepository;
|
||||||
|
|
||||||
|
|||||||
@@ -1,7 +1,11 @@
|
|||||||
package com.olympus.apollo.utils;
|
package com.olympus.apollo.utils;
|
||||||
|
|
||||||
|
|
||||||
import com.olympus.apollo.dto.GitCloneInput;
|
import com.olympus.apollo.dto.GitCloneInput;
|
||||||
import com.olympus.apollo.models.*;
|
import com.olympus.model.apollo.KSGitInfo;
|
||||||
|
import com.olympus.model.apollo.KSGitIngestionInfo;
|
||||||
|
import com.olympus.model.apollo.ParseStatuses;
|
||||||
|
import com.olympus.model.apollo.RevEngineeringStatuses;
|
||||||
import org.eclipse.jgit.lib.Ref;
|
import org.eclipse.jgit.lib.Ref;
|
||||||
import org.eclipse.jgit.lib.Repository;
|
import org.eclipse.jgit.lib.Repository;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
@@ -19,7 +23,7 @@ public class GitUtils {
|
|||||||
|
|
||||||
private static final Logger logger = LoggerFactory.getLogger(GitUtils.class);
|
private static final Logger logger = LoggerFactory.getLogger(GitUtils.class);
|
||||||
|
|
||||||
public static KSGitInfo createKSGitInfo(GitCloneInput gitCloneInput,String basePath){
|
public static KSGitInfo createKSGitInfo(GitCloneInput gitCloneInput, String basePath){
|
||||||
logger.debug("Creating KSGitInfo with repoName: {}, branch: {}",gitCloneInput.getRepoName(),gitCloneInput.getBranch());
|
logger.debug("Creating KSGitInfo with repoName: {}, branch: {}",gitCloneInput.getRepoName(),gitCloneInput.getBranch());
|
||||||
|
|
||||||
KSGitInfo info = new KSGitInfo();
|
KSGitInfo info = new KSGitInfo();
|
||||||
|
|||||||
Reference in New Issue
Block a user