Delete initialize

initialize/handlers.go

@@ -1,116 +0,0 @@
-package initialize
-
-import (
-	duckgoConvert "aurora/conversion/requests/duckgo"
-	"aurora/httpclient/bogdanfinn"
-	"aurora/internal/duckgo"
-	"aurora/internal/proxys"
-	officialtypes "aurora/typings/official"
-
-	"github.com/gin-gonic/gin"
-)
-
-type Handler struct {
-	proxy *proxys.IProxy
-}
-
-func NewHandle(proxy *proxys.IProxy) *Handler {
-	return &Handler{proxy: proxy}
-}
-
-func optionsHandler(c *gin.Context) {
-	// Set headers for CORS
-	c.Header("Access-Control-Allow-Origin", "*")
-	c.Header("Access-Control-Allow-Methods", "POST")
-	c.Header("Access-Control-Allow-Headers", "*")
-	c.JSON(200, gin.H{
-		"message": "pong",
-	})
-}
-
-func (h *Handler) duckduckgo(c *gin.Context) {
-	var original_request officialtypes.APIRequest
-	err := c.BindJSON(&original_request)
-	if err != nil {
-		c.JSON(400, gin.H{"error": gin.H{
-			"message": "Request must be proper JSON",
-			"type":    "invalid_request_error",
-			"param":   nil,
-			"code":    err.Error(),
-		}})
-		return
-	}
-	proxyUrl := h.proxy.GetProxyIP()
-	client := bogdanfinn.NewStdClient()
-	token, err := duckgo.InitXVQD(client, proxyUrl)
-	if err != nil {
-		c.JSON(500, gin.H{
-			"error": err.Error(),
-		})
-		return
-	}
-
-	translated_request := duckgoConvert.ConvertAPIRequest(original_request)
-	response, err := duckgo.POSTconversation(client, translated_request, token, proxyUrl)
-	if err != nil {
-		c.JSON(500, gin.H{
-			"error": "request conversion error",
-		})
-		return
-	}
-
-	defer response.Body.Close()
-	if duckgo.Handle_request_error(c, response) {
-		return
-	}
-	var response_part string
-	response_part = duckgo.Handler(c, response, translated_request, original_request.Stream)
-	if c.Writer.Status() != 200 {
-		return
-	}
-	if !original_request.Stream {
-		c.JSON(200, officialtypes.NewChatCompletionWithModel(response_part, translated_request.Model))
-	} else {
-		c.String(200, "data: [DONE]\n\n")
-	}
-}
-
-func (h *Handler) engines(c *gin.Context) {
-	type ResData struct {
-		ID      string `json:"id"`
-		Object  string `json:"object"`
-		Created int    `json:"created"`
-		OwnedBy string `json:"owned_by"`
-	}
-
-	type JSONData struct {
-		Object string    `json:"object"`
-		Data   []ResData `json:"data"`
-	}
-
-	modelS := JSONData{
-		Object: "list",
-	}
-	var resModelList []ResData
-
-	// Supported models
-	modelIDs := []string{
-		"gpt-4o-mini",
-		"o3-mini",
-		"claude-3-haiku-20240307",
-		"meta-llama/Llama-3.3-70B-Instruct-Turbo",
-		"mistralai/Mixtral-8x7B-Instruct-v0.1",
-	}
-
-	for _, modelID := range modelIDs {
-		resModelList = append(resModelList, ResData{
-			ID:      modelID,
-			Object:  "model",
-			Created: 1685474247,
-			OwnedBy: "duckduckgo",
-		})
-	}
-
-	modelS.Data = resModelList
-	c.JSON(200, modelS)
-}

initialize/proxy.go

@@ -1,48 +0,0 @@
-package initialize
-
-import (
-	"aurora/internal/proxys"
-	"bufio"
-	"log/slog"
-	"net/url"
-	"os"
-)
-
-func checkProxy() *proxys.IProxy {
-	var proxies []string
-	proxyUrl := os.Getenv("PROXY_URL")
-	if proxyUrl != "" {
-		proxies = append(proxies, proxyUrl)
-	}
-
-	if _, err := os.Stat("proxies.txt"); err == nil {
-		file, _ := os.Open("proxies.txt")
-		defer file.Close()
-		scanner := bufio.NewScanner(file)
-		for scanner.Scan() {
-			proxy := scanner.Text()
-			parsedURL, err := url.Parse(proxy)
-			if err != nil {
-				slog.Warn("proxy url is invalid", "url", proxy, "err", err)
-				continue
-			}
-
-			// 如果缺少端口信息，不是完整的代理链接
-			if parsedURL.Port() != "" {
-				proxies = append(proxies, proxy)
-			} else {
-				continue
-			}
-		}
-	}
-
-	if len(proxies) == 0 {
-		proxy := os.Getenv("http_proxy")
-		if proxy != "" {
-			proxies = append(proxies, proxy)
-		}
-	}
-
-	proxyIP := proxys.NewIProxyIP(proxies)
-	return &proxyIP
-}

initialize/router.go

@@ -1,66 +0,0 @@
-package initialize
-
-import (
-	"aurora/middlewares"
-	"net/http"
-	"os"
-
-	"github.com/gin-gonic/gin"
-)
-
-func RegisterRouter() *gin.Engine {
-	handler := NewHandle(
-		checkProxy(),
-	)
-
-	router := gin.Default()
-	router.Use(middlewares.Cors)
-	// // 访问根目录时，跳转到 /web
-	// router.GET("/", func(c *gin.Context) {
-	// 	c.JSON(200, gin.H{
-	// 		"message": "Hello, world!",
-	// 	})
-	// })
-	router.GET("/", func(c *gin.Context) {
-		c.Redirect(http.StatusFound, "/web")
-	})
-
-	router.GET("/ping", func(c *gin.Context) {
-		c.JSON(200, gin.H{
-			"message": "pong",
-		})
-	})
-
-	// 注册 prefixGroup 路由
-	prefixGroup := os.Getenv("PREFIX")
-	if prefixGroup != "" {
-		registerGroupRoutes(router.Group(prefixGroup), handler)
-	}
-	// 注册无前缀的路由
-	registerGroupRoutes(router.Group(""), handler)
-
-	return router
-}
-func registerGroupRoutes(group *gin.RouterGroup, handler *Handler) {
-	// OPTIONS 路由
-	group.OPTIONS("/v1/chat/completions", optionsHandler)
-	group.OPTIONS("/v1/chat/models", optionsHandler)
-	group.OPTIONS("/completions", optionsHandler)
-	group.OPTIONS("/models", optionsHandler)
-	group.OPTIONS("/api/v1/chat/completions", optionsHandler)
-	group.OPTIONS("/api/v1/models", optionsHandler)
-	group.OPTIONS("/hf/v1/chat/completions", optionsHandler)
-	group.OPTIONS("/hf/v1/models", optionsHandler)
-
-	// POST 路由
-	group.POST("/v1/chat/completions", middlewares.Authorization, handler.duckduckgo)
-	group.POST("/api/v1/chat/completions", middlewares.Authorization, handler.duckduckgo)
-	group.POST("/completions", middlewares.Authorization, handler.duckduckgo)
-	group.POST("/hf/v1/chat/completions", middlewares.Authorization, handler.duckduckgo)
-
-	// GET 路由
-	group.GET("/v1/models", middlewares.Authorization, handler.engines)
-	group.GET("/api/v1/models", middlewares.Authorization, handler.engines)
-	group.GET("/models", middlewares.Authorization, handler.engines)
-	group.GET("/hf/v1/models", middlewares.Authorization, handler.engines)
-}