feat(model): model yükleme sürecinde timeout süresi eklendi; model verileri doğrulama ve düzeltme işlemleri güncellendi

Author: omerada

user-service/src/main/java/com/craftpilot/userservice/command/ModelDataLoaderCommand.java

@@ -6,12 +6,8 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.core.io.ClassPathResource;
 import org.springframework.stereotype.Component;
 
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.Paths;
 import java.time.Duration;
 
 @Component
@@ -24,50 +20,27 @@ public class ModelDataLoaderCommand implements CommandLineRunner {
 
     @Value("${spring.models.file:newmodels.json}")
     private String modelsFile;
+    
+    @Value("${spring.models.timeout:300}")
+    private int loadTimeoutSeconds;
 
     @Override
     public void run(String... args) {
-        log.info("AI modelleri yükleme işlemi başlıyor...");
+        log.info("Başlangıçta model yükleme etkin. '{}' dosyasından modeller yükleniyor", modelsFile);
 
         // Dosya yolunu belirle
         String jsonFilePath = args.length > 0 && args[0] != null && !args[0].isEmpty() ? 
                               args[0] : modelsFile;
 
-        // Önce classpath resource olarak kontrol et
-        org.springframework.core.io.Resource resource = 
-            new ClassPathResource(jsonFilePath.replace("classpath:", ""));
-            
-        if (resource.exists()) {
-            log.info("'{}' classpath kaynağından modeller yükleniyor", jsonFilePath);
-            modelDataLoader.loadModelsFromJson(jsonFilePath)
-                .timeout(Duration.ofMinutes(5))
-                .doOnSuccess(count -> {
-                    log.info("AI model yükleme işlemi tamamlandı: {} model yüklendi", count);
-                })
-                .doOnError(error -> {
-                    log.error("AI model yükleme sırasında hata: {}", error.getMessage(), error);
-                })
-                .subscribe();
-            return;
-        }
-        
-        // Resource olarak bulunamazsa, dosya sistemi olarak kontrol et
-        Path path = Paths.get(jsonFilePath);
-        if (!Files.exists(path)) {
-            log.error("Model dosyası bulunamadı: {}", path.toAbsolutePath());
-            return;
-        }
-        
-        log.info("'{}' dosyasından modeller yükleniyor", jsonFilePath);
-        
+        // Modelleri yükle ve işlem tamamlanana kadar bekle
         modelDataLoader.loadModelsFromJson(jsonFilePath)
-            .timeout(Duration.ofMinutes(5))
+            .timeout(Duration.ofSeconds(loadTimeoutSeconds))
             .doOnSuccess(count -> {
                 log.info("AI model yükleme işlemi tamamlandı: {} model yüklendi", count);
             })
             .doOnError(error -> {
                 log.error("AI model yükleme sırasında hata: {}", error.getMessage(), error);
             })
-            .subscribe();
+            .block(Duration.ofSeconds(loadTimeoutSeconds + 10)); // Bloke etme süresi timeout + 10 saniye
     }
 }

user-service/src/main/java/com/craftpilot/userservice/model/ai/AIModel.java

@@ -5,6 +5,7 @@
 import lombok.Data;
 import lombok.NoArgsConstructor;
 import org.springframework.data.annotation.Id;
+import org.springframework.data.mongodb.core.index.Indexed;
 import org.springframework.data.mongodb.core.mapping.Document;
 
 @Data
@@ -14,6 +15,9 @@
 @Document(collection = "ai_models")
 public class AIModel {
     @Id
+    private String id;
+    
+    @Indexed(unique = true)
     private String modelId;  
     private String modelName;
     private String provider;
@@ -23,12 +27,5 @@ public class AIModel {
     private String creditType;
     private String category;
     private Integer contextLength;
-    private Double defaultTemperature;
-    private String icon;
-    private String description;
-    private Double fee;
-    private Boolean featured;
-    private Integer maxTokens;
-    private Boolean multimodal;
-    private Boolean active;
+    private Boolean isActive;
 }

user-service/src/main/java/com/craftpilot/userservice/repository/ProviderRepository.java

@@ -4,8 +4,10 @@
 import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
 import org.springframework.stereotype.Repository;
 import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
 
 @Repository
 public interface ProviderRepository extends ReactiveMongoRepository<Provider, String> {
     // Provider'ları bulmak için ek metotlar buraya eklenebilir
+    Mono<Provider> findByName(String name);
 }