diff --git a/.gitea/workflows/build-push.yaml b/.gitea/workflows/build-push.yaml
deleted file mode 100644
index 696d092..0000000
--- a/.gitea/workflows/build-push.yaml
+++ /dev/null
@@ -1,44 +0,0 @@
-name: Build and Push Docker Image
-
-on:
- push:
- branches:
- - main
-
-env:
- REGISTRY: git.savethenurse.com
- # CI/CD 파이프라인이 동작하는 Gitea 서버 자체의 레지스트리로 변경합니다.
- IMAGE_NAME: ${{ github.repository }}
-
-jobs:
- build-and-push:
- runs-on: ubuntu-latest
- steps:
- - name: Checkout repository
- uses: actions/checkout@v4
-
- - name: Set up Docker Buildx
- uses: docker/setup-buildx-action@v3
-
- - name: Log in to the Container registry
- uses: docker/login-action@v3
- with:
- registry: ${{ env.REGISTRY }}
- username: ${{ github.actor }}
- password: 18b8c375c76a07b9a6954bfdda794f5064dc6aa1
-
- - name: Extract metadata (tags, labels) for Docker
- id: meta
- uses: docker/metadata-action@v5
- with:
- images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
-
- - name: Build and push Docker image
- uses: docker/build-push-action@v5
- with:
- context: .
- push: true
- tags: ${{ steps.meta.outputs.tags }}
- labels: ${{ steps.meta.outputs.labels }}
- cache-from: type=gha
- cache-to: type=gha,mode=max
diff --git a/Dockerfile b/Dockerfile
deleted file mode 100644
index 3f43517..0000000
--- a/Dockerfile
+++ /dev/null
@@ -1,50 +0,0 @@
-# 1. Build Go Backend
-FROM golang:1.22-bookworm AS builder
-
-# Debian 기반 이미지는 빌드 도구가 이미 포함되어 있으므로 추가 설치 없이 진행합니다.
-
-WORKDIR /build
-
-# Cache go modules
-COPY backend/go.mod backend/go.sum ./
-RUN go mod download
-
-COPY backend/ ./
-# CGO_ENABLED=1 is required for sqlite3
-RUN CGO_ENABLED=1 go build -ldflags="-s -w" -o main main.go
-
-# 2. Final Minimal Image (Python + Go binary + Frontend)
-FROM python:3.10-slim
-
-# 파이썬 출력 버퍼링을 비활성화하여 도커 로그에 즉각 표시되도록 설정합니다.
-ENV PYTHONUNBUFFERED=1
-
-# Install system dependencies (ffmpeg is required for yt-dlp)
-RUN apt-get update && apt-get install -y \
- ffmpeg \
- ca-certificates \
- && rm -rf /var/lib/apt/lists/*
-
-WORKDIR /app
-
-# Install Python dependencies for worker
-COPY worker/requirements.txt ./worker/
-RUN pip install --no-cache-dir -r worker/requirements.txt
-
-# Copy Go binary from builder
-COPY --from=builder /build/main ./main
-
-# Copy worker script
-COPY worker/ ./worker/
-
-# Copy frontend
-COPY frontend/ ./frontend/
-
-# Ensure directories exist
-RUN mkdir -p db downloads
-
-# Expose Go server port
-EXPOSE 3000
-
-# Run the Go server command (which will also call the yt-dlp python script when needed)
-CMD ["./main"]
diff --git a/TODO.md b/TODO.md
deleted file mode 100644
index 4190ac4..0000000
--- a/TODO.md
+++ /dev/null
@@ -1,15 +0,0 @@
-# 전체 작업 진행 점검표
-
-- [x] 1. 프로젝트 폴더 구조 생성
-- [x] 2. Dockerfile 및 Unraid XML 템플릿 작성
-- [x] 3. Gitea Actions CI/CD 파일 작성 (.gitea/workflows/build-push.yaml)
-- [x] 4. SQLite DB 모델 및 초기화 로직 (backend/models)
-- [x] 5. Python yt-dlp 워커 스크립트 작성 (worker/downloader.py)
-- [x] 6. Go 백엔드 라우팅 및 파일 업로드(Zone B) 구현
-- [x] 7. Go - Python 연동 로직 (Zone C 다운로드 실행)
-- [x] 8. Google CSE 및 Gemini 2.5 Flash 연동 로직 (Zone A)
-- [x] 9. WebSocket 서버 및 진행률 방송 로직
-- [x] 10. 프론트엔드 메인 UI 구성 (Tailwind 3-Zone Layout)
-- [x] 11. 프론트엔드 JS 통신 로직 및 상태 바 렌더링 연동
-- [x] 12. 전체 기능 통합 테스트
-- [x] 13. Git Init 및 자동 Push (Gitea)
diff --git a/backend/go.mod b/backend/go.mod
deleted file mode 100644
index b212384..0000000
--- a/backend/go.mod
+++ /dev/null
@@ -1,29 +0,0 @@
-module github.com/savethenurse/ai-media-hub/backend
-
-go 1.22.2
-
-require (
- github.com/gofiber/fiber/v2 v2.52.12
- github.com/gofiber/websocket/v2 v2.2.1
- gorm.io/driver/sqlite v1.5.5
- gorm.io/gorm v1.25.10
-)
-
-require (
- github.com/andybalholm/brotli v1.1.0 // indirect
- github.com/fasthttp/websocket v1.5.3 // indirect
- github.com/google/uuid v1.6.0 // indirect
- github.com/jinzhu/inflection v1.0.0 // indirect
- github.com/jinzhu/now v1.1.5 // indirect
- github.com/klauspost/compress v1.17.9 // indirect
- github.com/mattn/go-colorable v0.1.13 // indirect
- github.com/mattn/go-isatty v0.0.20 // indirect
- github.com/mattn/go-runewidth v0.0.16 // indirect
- github.com/mattn/go-sqlite3 v1.14.17 // indirect
- github.com/rivo/uniseg v0.2.0 // indirect
- github.com/savsgio/gotils v0.0.0-20230208104028-c358bd845dee // indirect
- github.com/valyala/bytebufferpool v1.0.0 // indirect
- github.com/valyala/fasthttp v1.51.0 // indirect
- github.com/valyala/tcplisten v1.0.0 // indirect
- golang.org/x/sys v0.28.0 // indirect
-)
diff --git a/backend/go.sum b/backend/go.sum
deleted file mode 100644
index a78dc1b..0000000
--- a/backend/go.sum
+++ /dev/null
@@ -1,43 +0,0 @@
-github.com/andybalholm/brotli v1.1.0 h1:eLKJA0d02Lf0mVpIDgYnqXcUn0GqVmEFny3VuID1U3M=
-github.com/andybalholm/brotli v1.1.0/go.mod h1:sms7XGricyQI9K10gOSf56VKKWS4oLer58Q+mhRPtnY=
-github.com/fasthttp/websocket v1.5.3 h1:TPpQuLwJYfd4LJPXvHDYPMFWbLjsT91n3GpWtCQtdek=
-github.com/fasthttp/websocket v1.5.3/go.mod h1:46gg/UBmTU1kUaTcwQXpUxtRwG2PvIZYeA8oL6vF3Fs=
-github.com/gofiber/fiber/v2 v2.52.12 h1:0LdToKclcPOj8PktUdIKo9BUohjjwfnQl42Dhw8/WUw=
-github.com/gofiber/fiber/v2 v2.52.12/go.mod h1:YEcBbO/FB+5M1IZNBP9FO3J9281zgPAreiI1oqg8nDw=
-github.com/gofiber/websocket/v2 v2.2.1 h1:C9cjxvloojayOp9AovmpQrk8VqvVnT8Oao3+IUygH7w=
-github.com/gofiber/websocket/v2 v2.2.1/go.mod h1:Ao/+nyNnX5u/hIFPuHl28a+NIkrqK7PRimyKaj4JxVU=
-github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
-github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
-github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
-github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
-github.com/jinzhu/now v1.1.5/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
-github.com/klauspost/compress v1.17.9 h1:6KIumPrER1LHsvBVuDa0r5xaG0Es51mhhB9BQB2qeMA=
-github.com/klauspost/compress v1.17.9/go.mod h1:Di0epgTjJY877eYKx5yC51cX2A2Vl2ibi7bDH9ttBbw=
-github.com/mattn/go-colorable v0.1.13 h1:fFA4WZxdEF4tXPZVKMLwD8oUnCTTo08duU7wxecdEvA=
-github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovkB8vQcUbaXHg=
-github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
-github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
-github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
-github.com/mattn/go-runewidth v0.0.16 h1:E5ScNMtiwvlvB5paMFdw9p4kSQzbXFikJ5SQO6TULQc=
-github.com/mattn/go-runewidth v0.0.16/go.mod h1:Jdepj2loyihRzMpdS35Xk/zdY8IAYHsh153qUoGf23w=
-github.com/mattn/go-sqlite3 v1.14.17 h1:mCRHCLDUBXgpKAqIKsaAaAsrAlbkeomtRFKXh2L6YIM=
-github.com/mattn/go-sqlite3 v1.14.17/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
-github.com/rivo/uniseg v0.2.0 h1:S1pD9weZBuJdFmowNwbpi7BJ8TNftyUImj/0WQi72jY=
-github.com/rivo/uniseg v0.2.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc=
-github.com/savsgio/gotils v0.0.0-20230208104028-c358bd845dee h1:8Iv5m6xEo1NR1AvpV+7XmhI4r39LGNzwUL4YpMuL5vk=
-github.com/savsgio/gotils v0.0.0-20230208104028-c358bd845dee/go.mod h1:qwtSXrKuJh/zsFQ12yEE89xfCrGKK63Rr7ctU/uCo4g=
-github.com/valyala/bytebufferpool v1.0.0 h1:GqA5TC/0021Y/b9FG4Oi9Mr3q7XYx6KllzawFIhcdPw=
-github.com/valyala/bytebufferpool v1.0.0/go.mod h1:6bBcMArwyJ5K/AmCkWv1jt77kVWyCJ6HpOuEn7z0Csc=
-github.com/valyala/fasthttp v1.51.0 h1:8b30A5JlZ6C7AS81RsWjYMQmrZG6feChmgAolCl1SqA=
-github.com/valyala/fasthttp v1.51.0/go.mod h1:oI2XroL+lI7vdXyYoQk03bXBThfFl2cVdIA3Xl7cH8g=
-github.com/valyala/tcplisten v1.0.0 h1:rBHj/Xf+E1tRGZyWIWwJDiRY0zc1Js+CV5DqwacVSA8=
-github.com/valyala/tcplisten v1.0.0/go.mod h1:T0xQ8SeCZGxckz9qRXTfG43PvQ/mcWh7FwZEA7Ioqkc=
-golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.28.0 h1:Fksou7UEQUWlKvIdsqzJmUmCX3cZuD2+P3XyyzwMhlA=
-golang.org/x/sys v0.28.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
-gorm.io/driver/sqlite v1.5.5 h1:7MDMtUZhV065SilG62E0MquljeArQZNfJnjd9i9gx3E=
-gorm.io/driver/sqlite v1.5.5/go.mod h1:6NgQ7sQWAIFsPrJJl1lSNSu2TABh0ZZ/zm5fosATavE=
-gorm.io/gorm v1.25.10 h1:dQpO+33KalOA+aFYGlK+EfxcI5MbO7EP2yYygwh9h+s=
-gorm.io/gorm v1.25.10/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8=
diff --git a/backend/handlers/api.go b/backend/handlers/api.go
deleted file mode 100644
index 7f6b06f..0000000
--- a/backend/handlers/api.go
+++ /dev/null
@@ -1,140 +0,0 @@
-package handlers
-
-import (
- "encoding/json"
- "fmt"
- "os"
- "os/exec"
- "path/filepath"
-
- "github.com/gofiber/fiber/v2"
- "github.com/savethenurse/ai-media-hub/backend/models"
- "github.com/savethenurse/ai-media-hub/backend/services"
-)
-
-// SearchAndFilter handles Zone A logic
-func SearchAndFilter(c *fiber.Ctx) error {
- query := c.Query("q")
- if query == "" {
- return c.Status(400).JSON(fiber.Map{"error": "Query required"})
- }
-
- // 1. Send search query to CSE
- urls, err := services.PerformSearch(query)
- if err != nil {
- return c.Status(500).JSON(fiber.Map{"error": err.Error()})
- }
-
- if len(urls) == 0 {
- return c.JSON(fiber.Map{"recommended": []string{}})
- }
-
- // 2. Filter with Gemini
- result, err := services.FilterImagesWithGemini(query, urls)
- if err != nil {
- return c.Status(500).JSON(fiber.Map{"error": err.Error()})
- }
-
- return c.JSON(result)
-}
-
-// UploadMedia handles Zone B logic
-func UploadMedia(c *fiber.Ctx) error {
- file, err := c.FormFile("file")
- if err != nil {
- return c.Status(400).JSON(fiber.Map{"error": "File upload required"})
- }
-
- downloadsDir := os.Getenv("DOWNLOADS_DIR")
- if downloadsDir == "" {
- downloadsDir = "/app/downloads"
- }
-
- dest := filepath.Join(downloadsDir, file.Filename)
- if err := c.SaveFile(file, dest); err != nil {
- return c.Status(500).JSON(fiber.Map{"error": err.Error()})
- }
-
- // Logging to DB
- models.DB.Create(&models.MediaHistory{
- SourceURL: file.Filename, // Just to log it, though not a URL
- FilePath: dest,
- Status: "success",
- Type: "upload",
- })
-
- return c.JSON(fiber.Map{"status": "success", "filename": file.Filename})
-}
-
-// DownloadMedia handles Zone C logic
-func DownloadMedia(c *fiber.Ctx) error {
- type Request struct {
- URL string `json:"url"`
- Start string `json:"start"`
- End string `json:"end"`
- }
-
- var req Request
- if err := c.BodyParser(&req); err != nil {
- return c.Status(400).JSON(fiber.Map{"error": "Invalid JSON"})
- }
-
- // Check duplicates
- var hist models.MediaHistory
- res := models.DB.Where("source_url = ?", req.URL).First(&hist)
- if res.RowsAffected > 0 && c.Query("confirm") != "true" {
- return c.Status(statusConflict).JSON(fiber.Map{"error": "Duplicate", "need_confirm": true})
- }
-
- downloadsDir := os.Getenv("DOWNLOADS_DIR")
- if downloadsDir == "" {
- downloadsDir = "/app/downloads"
- }
-
- // Execute Python worker asynchronously or synchronously
- // For simplicity, we'll do it synchronously and broadcast progress via WS if we capture it.
- // But it's easier to just run the command and wait.
- BroadcastProgress("Downloading: " + req.URL)
-
- go func() {
- args := []string{"./worker/downloader.py", "--url", req.URL, "--outdir", downloadsDir}
- if req.Start != "" {
- args = append(args, "--start", req.Start)
- }
- if req.End != "" {
- args = append(args, "--end", req.End)
- }
-
- cmd := exec.Command("python", args...)
- fmt.Printf("[DEBUG Go Exec] Command: %v\n", cmd.String())
-
- output, err := cmd.CombinedOutput()
- fmt.Printf("[DEBUG Go Exec] Output:\n%s\n", string(output))
-
- if err != nil {
- fmt.Printf("[DEBUG Go Exec] Download error: %v\n", string(output))
- BroadcastProgress("Error: " + err.Error())
- models.DB.Create(&models.MediaHistory{
- SourceURL: req.URL,
- Status: "error",
- Type: "download",
- })
- return
- }
-
- var result map[string]interface{}
- json.Unmarshal(output, &result)
-
- BroadcastProgress(fmt.Sprintf("Download Success: %v", req.URL))
- models.DB.Create(&models.MediaHistory{
- SourceURL: req.URL,
- Status: "success",
- Type: "download",
- FilePath: fmt.Sprintf("%v", result["filepath"]),
- })
- }()
-
- return c.JSON(fiber.Map{"status": "started", "message": "Download process started"})
-}
-
-const statusConflict = 409
diff --git a/backend/handlers/ws.go b/backend/handlers/ws.go
deleted file mode 100644
index 77fc08f..0000000
--- a/backend/handlers/ws.go
+++ /dev/null
@@ -1,47 +0,0 @@
-package handlers
-
-import (
- "log"
- "sync"
-
- "github.com/gofiber/websocket/v2"
-)
-
-var clients = make(map[*websocket.Conn]bool)
-var clientsMutex sync.Mutex
-
-func WsHandler(c *websocket.Conn) {
- clientsMutex.Lock()
- clients[c] = true
- clientsMutex.Unlock()
-
- defer func() {
- clientsMutex.Lock()
- delete(clients, c)
- clientsMutex.Unlock()
- c.Close()
- }()
-
- for {
- // Just keep alive, ignore incoming messages
- _, _, err := c.ReadMessage()
- if err != nil {
- log.Println("ws error:", err)
- break
- }
- }
-}
-
-func BroadcastProgress(message string) {
- clientsMutex.Lock()
- defer clientsMutex.Unlock()
-
- for client := range clients {
- err := client.WriteMessage(websocket.TextMessage, []byte(message))
- if err != nil {
- log.Println("ws broadcast error:", err)
- client.Close()
- delete(clients, client)
- }
- }
-}
diff --git a/backend/main.go b/backend/main.go
deleted file mode 100644
index 5243c13..0000000
--- a/backend/main.go
+++ /dev/null
@@ -1,59 +0,0 @@
-package main
-
-import (
- "log"
- "os"
-
- "github.com/gofiber/fiber/v2"
- "github.com/gofiber/fiber/v2/middleware/cors"
- "github.com/gofiber/fiber/v2/middleware/logger"
- "github.com/gofiber/websocket/v2"
- "github.com/savethenurse/ai-media-hub/backend/handlers"
- "github.com/savethenurse/ai-media-hub/backend/models"
-)
-
-func main() {
- dbDir := os.Getenv("DB_DIR")
- if dbDir == "" {
- dbDir = "/app/db"
- }
- dbPath := dbDir + "/media_hub.db"
-
- // Ensure DB directory exists
- os.MkdirAll(dbDir, os.ModePerm)
-
- // Initialize Database
- models.InitDB(dbPath)
-
- app := fiber.New()
-
- app.Use(logger.New())
- app.Use(cors.New())
-
- // Static files (Frontend)
- app.Static("/", "./frontend")
-
- // API Routes
- api := app.Group("/api")
- api.Get("/search", handlers.SearchAndFilter)
- api.Post("/upload", handlers.UploadMedia)
- api.Post("/download", handlers.DownloadMedia)
-
- // WebSocket Route
- app.Use("/ws", func(c *fiber.Ctx) error {
- if websocket.IsWebSocketUpgrade(c) {
- c.Locals("allowed", true)
- return c.Next()
- }
- return fiber.ErrUpgradeRequired
- })
- app.Get("/ws", websocket.New(handlers.WsHandler))
-
- port := os.Getenv("PORT")
- if port == "" {
- port = "3000"
- }
-
- log.Printf("Starting Server on port %s", port)
- app.Listen(":" + port)
-}
diff --git a/backend/models/db.go b/backend/models/db.go
deleted file mode 100644
index 5953080..0000000
--- a/backend/models/db.go
+++ /dev/null
@@ -1,50 +0,0 @@
-package models
-
-import (
- "log"
- "os"
-
- "gorm.io/driver/sqlite"
- "gorm.io/gorm"
- "gorm.io/gorm/logger"
-)
-
-var DB *gorm.DB
-
-type MediaHistory struct {
- gorm.Model
- SourceURL string `gorm:"uniqueIndex"`
- FilePath string
- Status string
- Type string // ENUM: "download", "upload"
-}
-
-func InitDB(dbPath string) {
- var err error
-
- // 도커 로그 디버깅을 위해 SQL 쿼리를 디테일하게 출력하는 로거 설정
- newLogger := logger.New(
- log.New(os.Stdout, "\r\n", log.LstdFlags),
- logger.Config{
- LogLevel: logger.Info,
- Colorful: true,
- },
- )
-
- log.Println("Connecting to SQLite at:", dbPath)
- DB, err = gorm.Open(sqlite.Open(dbPath), &gorm.Config{
- Logger: newLogger,
- })
- if err != nil {
- log.Fatal("Failed to connect to database:", err)
- }
-
- // SQLite 동시성 최적화를 위해 WAL(Write-Ahead Logging) 모드를 활성화
- DB.Exec("PRAGMA journal_mode=WAL;")
-
- err = DB.AutoMigrate(&MediaHistory{})
- if err != nil {
- log.Println("Database migration error:", err)
- }
- log.Println("Database initialized and migrated.")
-}
diff --git a/backend/services/ai.go b/backend/services/ai.go
deleted file mode 100644
index cd81789..0000000
--- a/backend/services/ai.go
+++ /dev/null
@@ -1,94 +0,0 @@
-package services
-
-import (
- "bytes"
- "encoding/json"
- "fmt"
- "io/ioutil"
- "net/http"
- "os"
-)
-
-type RecommendResult struct {
- Recommended []struct {
- URL string `json:"url"`
- Reason string `json:"reason"`
- } `json:"recommended"`
-}
-
-// FilterImagesWithGemini asks Gemini 2.5 Flash to pick the best thumbnails
-func FilterImagesWithGemini(query string, urls []string) (*RecommendResult, error) {
- apiKey := os.Getenv("GEMINI_API_KEY")
- if apiKey == "" {
- return nil, fmt.Errorf("GEMINI_API_KEY not configured")
- }
-
- // Because Gemini multi-modal expects base64 or public URLs, since these are public URLs from Google search,
- // we can try providing instructions with URLs to be analyzed, or if direct URL access fails, we might need to download them.
- // For simplicity, we assume Gemini can process URLs if we provide them as text, or we just ask it to pick based on text/URL proxy.
- // Actually, the standard way is to download and attach as inline data. Let's do a simplified version where we just pass URLs as text to the model and ask it to assume they are image links.
- // Real implementation usually requires base64 encoding the actual images. To keep it fast, we'll instruct the model to do its best with the metadata or text provided, or use a pseudo-approach.
-
- prompt := fmt.Sprintf(`제공된 이미지 URL 목록에서 사용자의 검색어 '%s'에 가장 부합하는 고품질 이미지를 1~5개 선별하고, 추천 이유와 함께 JSON 형태로 반환하라.
-형식: {"recommended": [{"url": "url", "reason": "이유"}]}
-URL 목록: %v`, query, urls)
-
- payload := map[string]interface{}{
- "contents": []map[string]interface{}{
- {
- "parts": []map[string]interface{}{
- {"text": prompt},
- },
- },
- },
- "generationConfig": map[string]interface{}{
- "response_mime_type": "application/json",
- },
- }
-
- bodyBytes, _ := json.Marshal(payload)
- url := fmt.Sprintf("https://generativelanguage.googleapis.com/v1beta/models/gemini-2.5-flash:generateContent?key=%s", apiKey)
-
- req, _ := http.NewRequest("POST", url, bytes.NewBuffer(bodyBytes))
- req.Header.Set("Content-Type", "application/json")
-
- client := &http.Client{}
- resp, err := client.Do(req)
- if err != nil {
- return nil, err
- }
- defer resp.Body.Close()
-
- if resp.StatusCode != 200 {
- return nil, fmt.Errorf("Gemini API returned status: %d", resp.StatusCode)
- }
-
- respBody, _ := ioutil.ReadAll(resp.Body)
-
- // Parse Gemini Response
- var geminiResp struct {
- Candidates []struct {
- Content struct {
- Parts []struct {
- Text string `json:"text"`
- } `json:"parts"`
- } `json:"content"`
- } `json:"candidates"`
- }
-
- if err := json.Unmarshal(respBody, &geminiResp); err != nil {
- return nil, err
- }
-
- if len(geminiResp.Candidates) > 0 && len(geminiResp.Candidates[0].Content.Parts) > 0 {
- jsonStr := geminiResp.Candidates[0].Content.Parts[0].Text
- var res RecommendResult
- err := json.Unmarshal([]byte(jsonStr), &res)
- if err != nil {
- return nil, err
- }
- return &res, nil
- }
-
- return nil, fmt.Errorf("No valid response from Gemini")
-}
diff --git a/backend/services/search.go b/backend/services/search.go
deleted file mode 100644
index b74a419..0000000
--- a/backend/services/search.go
+++ /dev/null
@@ -1,64 +0,0 @@
-package services
-
-import (
- "encoding/json"
- "fmt"
- "io/ioutil"
- "net/http"
- "os"
-)
-
-type SearchResultItem struct {
- Title string `json:"title"`
- Link string `json:"link"`
- Pagemap struct {
- CseImage []struct {
- Src string `json:"src"`
- } `json:"cse_image"`
- CseThumbnail []struct {
- Src string `json:"src"`
- } `json:"cse_thumbnail"`
- } `json:"pagemap"`
-}
-
-type SearchResponse struct {
- Items []SearchResultItem `json:"items"`
-}
-
-// PerformSearch calls Google Custom Search API targeting YouTube, TikTok, Envato, Artgrid
-func PerformSearch(query string) ([]string, error) {
- apiKey := os.Getenv("GOOGLE_CSE_API_KEY")
- cx := os.Getenv("GOOGLE_CSE_ID")
-
- if apiKey == "" || cx == "" {
- return nil, fmt.Errorf("Google CSE credentials not configured")
- }
-
- // We append "site:youtube.com OR site:tiktok.com OR site:envato.com OR site:artgrid.io" to restrict
- // depending on CSE settings, but the easiest is doing it in query string
- fullQuery := fmt.Sprintf("%s site:youtube.com OR site:tiktok.com OR site:envato.com OR site:artgrid.io", query)
- url := fmt.Sprintf("https://www.googleapis.com/customsearch/v1?key=%s&cx=%s&q=%s&searchType=image&num=10", apiKey, cx, fullQuery)
-
- resp, err := http.Get(url)
- if err != nil {
- return nil, err
- }
- defer resp.Body.Close()
-
- if resp.StatusCode != 200 {
- return nil, fmt.Errorf("Google CSE API returned status: %d", resp.StatusCode)
- }
-
- body, _ := ioutil.ReadAll(resp.Body)
- var res SearchResponse
- if err := json.Unmarshal(body, &res); err != nil {
- return nil, err
- }
-
- var thumbnails []string
- for _, item := range res.Items {
- thumbnails = append(thumbnails, item.Link)
- }
-
- return thumbnails, nil
-}
diff --git a/frontend/app.js b/frontend/app.js
deleted file mode 100644
index bc82676..0000000
--- a/frontend/app.js
+++ /dev/null
@@ -1,198 +0,0 @@
-const statusText = document.getElementById('status-text');
-const wsIndicator = document.getElementById('ws-indicator');
-const searchBtn = document.getElementById('search-btn');
-const searchInput = document.getElementById('search-input');
-const resultsContainer = document.getElementById('discovery-results');
-
-const dropzone = document.getElementById('dropzone');
-const fileInput = document.getElementById('file-input');
-
-const dlBtn = document.getElementById('dl-btn');
-const dlUrl = document.getElementById('dl-url');
-const dlStart = document.getElementById('dl-start');
-const dlEnd = document.getElementById('dl-end');
-const confirmModal = document.getElementById('confirm-modal');
-const dlConfirmBtn = document.getElementById('dl-confirm-btn');
-const dlCancelBtn = document.getElementById('dl-cancel-btn');
-
-
-// --- WebSocket ---
-let ws;
-function connectWS() {
- const proto = window.location.protocol === 'https:' ? 'wss' : 'ws';
- const wsUrl = `${proto}://${window.location.host}/ws`;
- // For local dev without docker, port might be 3000
- const finalWsUrl = window.location.port === '' ? `${proto}://${window.location.hostname}:3000/ws` : wsUrl;
-
- ws = new WebSocket(finalWsUrl);
-
- ws.onopen = () => {
- wsIndicator.className = 'h-2 w-2 rounded-full bg-green-500';
- };
-
- ws.onmessage = (event) => {
- statusText.textContent = event.data;
- // flash text
- statusText.classList.add('text-blue-400');
- setTimeout(() => statusText.classList.remove('text-blue-400'), 500);
- };
-
- ws.onclose = () => {
- wsIndicator.className = 'h-2 w-2 rounded-full bg-red-500';
- setTimeout(connectWS, 2000); // Reconnect
- };
-}
-connectWS();
-
-// --- Zone A: Search ---
-searchBtn.addEventListener('click', async () => {
- const query = searchInput.value.trim();
- if (!query) return;
-
- searchBtn.disabled = true;
- searchBtn.textContent = '검색 중...';
- resultsContainer.innerHTML = '인공지능이 이미지를 탐색하고 선별 중입니다...
';
-
- try {
- const port = window.location.port ? `:${window.location.port}` : ':3000';
- const res = await fetch(`http://${window.location.hostname}${port}/api/search?q=${encodeURIComponent(query)}`);
- const data = await res.json();
-
- if (data.error) {
- resultsContainer.innerHTML = `Error: ${data.error}
`;
- } else if (data.recommended && data.recommended.length > 0) {
- resultsContainer.innerHTML = '';
- data.recommended.forEach((item, index) => {
- const delay = index * 100;
- resultsContainer.innerHTML += `
-
-
✨ AI Recommended
-
-
-
-
-
-
결과를 찾을 수 없습니다.
`;
- }
- } catch (err) {
- resultsContainer.innerHTML = `Exception: ${err.message}
`;
- } finally {
- searchBtn.disabled = false;
- searchBtn.textContent = '검색';
- }
-});
-
-
-// --- Zone B: Upload ---
-dropzone.addEventListener('dragover', (e) => {
- e.preventDefault();
- dropzone.classList.add('border-purple-500', 'bg-[#303030]');
-});
-
-dropzone.addEventListener('dragleave', () => {
- dropzone.classList.remove('border-purple-500', 'bg-[#303030]');
-});
-
-dropzone.addEventListener('drop', (e) => {
- e.preventDefault();
- dropzone.classList.remove('border-purple-500', 'bg-[#303030]');
-
- if (e.dataTransfer.files.length > 0) {
- uploadFile(e.dataTransfer.files[0]);
- }
-});
-
-dropzone.addEventListener('click', () => fileInput.click());
-fileInput.addEventListener('change', (e) => {
- if (e.target.files.length > 0) {
- uploadFile(e.target.files[0]);
- }
-});
-
-async function uploadFile(file) {
- const formData = new FormData();
- formData.append('file', file);
-
- statusText.textContent = `Uploading ${file.name}...`;
-
- try {
- const port = window.location.port ? `:${window.location.port}` : ':3000';
- const res = await fetch(`http://${window.location.hostname}${port}/api/upload`, {
- method: 'POST',
- body: formData
- });
- const data = await res.json();
-
- if (data.error) {
- statusText.textContent = `Upload Error: ${data.error}`;
- } else {
- statusText.textContent = `Upload Success: ${data.filename}`;
- }
- } catch (err) {
- statusText.textContent = `Upload Failed: ${err.message}`;
- }
-}
-
-
-// --- Zone C: Download ---
-async function requestDownload(confirm = false) {
- const url = dlUrl.value.trim();
- if (!url) return;
-
- dlBtn.disabled = true;
- dlBtn.textContent = '요청 중...';
-
- const payload = {
- url: url,
- start: dlStart.value.trim(),
- end: dlEnd.value.trim()
- };
-
- try {
- const port = window.location.port ? `:${window.location.port}` : ':3000';
- const res = await fetch(`http://${window.location.hostname}${port}/api/download${confirm ? '?confirm=true' : ''}`, {
- method: 'POST',
- headers: { 'Content-Type': 'application/json' },
- body: JSON.stringify(payload)
- });
-
- if (res.status === 409) {
- // Duplicate!
- confirmModal.classList.remove('hidden');
- confirmModal.classList.add('flex');
- dlBtn.disabled = false;
- dlBtn.textContent = '다운로드 시작';
- return;
- }
-
- const data = await res.json();
- if (data.error) {
- statusText.textContent = `Download Error: ${data.error}`;
- } else {
- // The WS will handle the progress
- dlUrl.value = '';
- dlStart.value = '';
- dlEnd.value = '';
- confirmModal.classList.add('hidden');
- confirmModal.classList.remove('flex');
- }
- } catch (err) {
- statusText.textContent = `Download Request Failed: ${err.message}`;
- } finally {
- dlBtn.disabled = false;
- dlBtn.textContent = '다운로드 시작';
- }
-}
-
-dlBtn.addEventListener('click', () => requestDownload(false));
-dlConfirmBtn.addEventListener('click', () => requestDownload(true));
-dlCancelBtn.addEventListener('click', () => {
- confirmModal.classList.add('hidden');
- confirmModal.classList.remove('flex');
-});
diff --git a/frontend/index.html b/frontend/index.html
deleted file mode 100644
index 152de87..0000000
--- a/frontend/index.html
+++ /dev/null
@@ -1,103 +0,0 @@
-
-
-
-
-
- AI Media Hub
-
-
-
-
-
-
-
-
-
-
-
- AI Media Hub Multimodal Ingest
-
-
-
-
-
-
-
-
-
- 🎯 Zone A: AI Smart Discovery
-
-
-
-
-
-
-
-
-
-
- 검색어를 입력하여 이미지를 탐색하세요
-
-
-
-
-
-
- 📥 Zone B: Smart Ingest
-
-
-
-
이곳에 미디어 파일을 드래그 & 드랍
-
-
-
-
-
-
- ✂️ Zone C: Direct Downloader
-
-
-
-
-
-
-
-
-
-
-
이미 다운로드 이력이 있는 URL입니다. 그래도 진행하시겠습니까?
-
-
-
-
-
-
-