mirror of
				https://github.com/songquanpeng/one-api.git
				synced 2025-10-25 19:03:43 +08:00 
			
		
		
		
	Compare commits
	
		
			34 Commits
		
	
	
		
			v0.1.6-alp
			...
			v0.2.4-alp
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
|  | dc4a6cb711 | ||
|  | 5798fdac50 | ||
|  | 3710688efd | ||
|  | 83e86b9f8a | ||
|  | 74c1ba7cbc | ||
|  | 73aa53f536 | ||
|  | da9ccb528d | ||
|  | 44729da277 | ||
|  | 7a3378b4b7 | ||
|  | fd19d7d246 | ||
|  | 5c694a1503 | ||
|  | 9edc54ca69 | ||
|  | e6af636fa0 | ||
|  | 6e1ef75009 | ||
|  | d9db16e999 | ||
|  | 241ade2fae | ||
|  | 80065de8a3 | ||
|  | 16f53b5afb | ||
|  | 3071300c0c | ||
|  | 8b056bf408 | ||
|  | e5640857b1 | ||
|  | 331177d97e | ||
|  | 4fed003f1a | ||
|  | a1ea1bf696 | ||
|  | 7c66fc6c21 | ||
|  | d93cb8f645 | ||
|  | b08cd7e104 | ||
|  | aea6c859e7 | ||
|  | 480e789cd8 | ||
|  | 23ec541ba6 | ||
|  | 053bb85a1c | ||
|  | 601fa5cea8 | ||
|  | 7a5057f02d | ||
|  | c76027a210 | 
							
								
								
									
										1
									
								
								.github/FUNDING.yml
									
									
									
									
										vendored
									
									
										Normal file
									
								
							
							
						
						
									
										1
									
								
								.github/FUNDING.yml
									
									
									
									
										vendored
									
									
										Normal file
									
								
							| @@ -0,0 +1 @@ | ||||
| custom: ['https://iamazing.cn/page/reward'] | ||||
| @@ -42,14 +42,14 @@ _✨ All in one 的 OpenAI 接口,整合各种 API 访问方式,开箱即用 | ||||
|  | ||||
| ## 功能 | ||||
| 1. 支持多种 API 访问渠道,欢迎 PR 或提 issue 添加更多渠道: | ||||
|    + [x] One API 服务端中继 | ||||
|    + [x] OpenAI 官方通道 | ||||
|    + [x] [API2D](https://api2d.com/r/197971) | ||||
|    + [ ] Azure OpenAI API | ||||
|    + [x] Azure OpenAI API | ||||
|    + [x] [CloseAI](https://console.openai-asia.com) | ||||
|    + [x] [OpenAI-SB](https://openai-sb.com) | ||||
|    + [x] [OpenAI Max](https://openaimax.com) | ||||
|    + [x] [OhMyGPT](https://www.ohmygpt.com) | ||||
|    + [x] 自定义渠道 | ||||
|    + [x] 自定义渠道:例如使用自行搭建的 OpenAI 代理 | ||||
| 2. 支持通过负载均衡的方式访问多个渠道。 | ||||
| 3. 支持单个访问渠道设置多个 API Key,利用起来你的多个 API Key。 | ||||
| 4. 支持 HTTP SSE,可以通过流式传输实现打字机效果。 | ||||
|   | ||||
| @@ -34,6 +34,7 @@ var TurnstileCheckEnabled = false | ||||
| var RegisterEnabled = true | ||||
|  | ||||
| var SMTPServer = "" | ||||
| var SMTPPort = 587 | ||||
| var SMTPAccount = "" | ||||
| var SMTPToken = "" | ||||
|  | ||||
|   | ||||
| @@ -1,14 +1,20 @@ | ||||
| package common | ||||
|  | ||||
| import "gopkg.in/gomail.v2" | ||||
| import ( | ||||
| 	"fmt" | ||||
| 	"net/smtp" | ||||
| 	"strings" | ||||
| ) | ||||
|  | ||||
| func SendEmail(subject string, receiver string, content string) error { | ||||
| 	m := gomail.NewMessage() | ||||
| 	m.SetHeader("From", SMTPAccount) | ||||
| 	m.SetHeader("To", receiver) | ||||
| 	m.SetHeader("Subject", subject) | ||||
| 	m.SetBody("text/html", content) | ||||
| 	d := gomail.NewDialer(SMTPServer, 587, SMTPAccount, SMTPToken) | ||||
| 	err := d.DialAndSend(m) | ||||
| 	mail := []byte(fmt.Sprintf("To: %s\r\n"+ | ||||
| 		"From: %s<%s>\r\n"+ | ||||
| 		"Subject: %s\r\n"+ | ||||
| 		"Content-Type: text/html; charset=UTF-8\r\n\r\n%s\r\n", | ||||
| 		receiver, SystemName, SMTPAccount, subject, content)) | ||||
| 	auth := smtp.PlainAuth("", SMTPAccount, SMTPToken, SMTPServer) | ||||
| 	addr := fmt.Sprintf("%s:%d", SMTPServer, SMTPPort) | ||||
| 	to := strings.Split(receiver, ";") | ||||
| 	err := smtp.SendMail(addr, auth, SMTPAccount, to, mail) | ||||
| 	return err | ||||
| } | ||||
|   | ||||
							
								
								
									
										52
									
								
								common/model-ratio.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										52
									
								
								common/model-ratio.go
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,52 @@ | ||||
| package common | ||||
|  | ||||
| import "encoding/json" | ||||
|  | ||||
| // https://platform.openai.com/docs/models/model-endpoint-compatibility | ||||
| // https://openai.com/pricing | ||||
| // TODO: when a new api is enabled, check the pricing here | ||||
| var ModelRatio = map[string]float64{ | ||||
| 	"gpt-4":                   15, | ||||
| 	"gpt-4-0314":              15, | ||||
| 	"gpt-4-32k":               30, | ||||
| 	"gpt-4-32k-0314":          30, | ||||
| 	"gpt-3.5-turbo":           1, | ||||
| 	"gpt-3.5-turbo-0301":      1, | ||||
| 	"text-ada-001":            0.2, | ||||
| 	"text-babbage-001":        0.25, | ||||
| 	"text-curie-001":          1, | ||||
| 	"text-davinci-002":        10, | ||||
| 	"text-davinci-003":        10, | ||||
| 	"text-davinci-edit-001":   10, | ||||
| 	"code-davinci-edit-001":   10, | ||||
| 	"whisper-1":               10, | ||||
| 	"davinci":                 10, | ||||
| 	"curie":                   10, | ||||
| 	"babbage":                 10, | ||||
| 	"ada":                     10, | ||||
| 	"text-embedding-ada-002":  0.2, | ||||
| 	"text-search-ada-doc-001": 10, | ||||
| 	"text-moderation-stable":  10, | ||||
| 	"text-moderation-latest":  10, | ||||
| } | ||||
|  | ||||
| func ModelRatio2JSONString() string { | ||||
| 	jsonBytes, err := json.Marshal(ModelRatio) | ||||
| 	if err != nil { | ||||
| 		SysError("Error marshalling model ratio: " + err.Error()) | ||||
| 	} | ||||
| 	return string(jsonBytes) | ||||
| } | ||||
|  | ||||
| func UpdateModelRatioByJSONString(jsonStr string) error { | ||||
| 	return json.Unmarshal([]byte(jsonStr), &ModelRatio) | ||||
| } | ||||
|  | ||||
| func GetModelRatio(name string) float64 { | ||||
| 	ratio, ok := ModelRatio[name] | ||||
| 	if !ok { | ||||
| 		SysError("Model ratio not found: " + name) | ||||
| 		return 1 | ||||
| 	} | ||||
| 	return ratio | ||||
| } | ||||
| @@ -6,6 +6,7 @@ import ( | ||||
| 	"one-api/common" | ||||
| 	"one-api/model" | ||||
| 	"strconv" | ||||
| 	"strings" | ||||
| ) | ||||
|  | ||||
| func GetAllChannels(c *gin.Context) { | ||||
| @@ -84,7 +85,17 @@ func AddChannel(c *gin.Context) { | ||||
| 	} | ||||
| 	channel.CreatedTime = common.GetTimestamp() | ||||
| 	channel.AccessedTime = common.GetTimestamp() | ||||
| 	err = channel.Insert() | ||||
| 	keys := strings.Split(channel.Key, "\n") | ||||
| 	channels := make([]model.Channel, 0) | ||||
| 	for _, key := range keys { | ||||
| 		if key == "" { | ||||
| 			continue | ||||
| 		} | ||||
| 		localChannel := channel | ||||
| 		localChannel.Key = key | ||||
| 		channels = append(channels, localChannel) | ||||
| 	} | ||||
| 	err = model.BatchInsertChannels(channels) | ||||
| 	if err != nil { | ||||
| 		c.JSON(http.StatusOK, gin.H{ | ||||
| 			"success": false, | ||||
|   | ||||
| @@ -2,8 +2,11 @@ package controller | ||||
|  | ||||
| import ( | ||||
| 	"bufio" | ||||
| 	"bytes" | ||||
| 	"encoding/json" | ||||
| 	"fmt" | ||||
| 	"github.com/gin-gonic/gin" | ||||
| 	"github.com/pkoukk/tiktoken-go" | ||||
| 	"io" | ||||
| 	"net/http" | ||||
| 	"one-api/common" | ||||
| @@ -11,16 +14,46 @@ import ( | ||||
| 	"strings" | ||||
| ) | ||||
|  | ||||
| type Message struct { | ||||
| 	Role    string `json:"role"` | ||||
| 	Content string `json:"content"` | ||||
| } | ||||
|  | ||||
| type TextRequest struct { | ||||
| 	Model    string    `json:"model"` | ||||
| 	Messages []Message `json:"messages"` | ||||
| 	Prompt   string    `json:"prompt"` | ||||
| 	//Stream   bool      `json:"stream"` | ||||
| } | ||||
|  | ||||
| type Usage struct { | ||||
| 	PromptTokens     int `json:"prompt_tokens"` | ||||
| 	CompletionTokens int `json:"completion_tokens"` | ||||
| 	TotalTokens      int `json:"total_tokens"` | ||||
| } | ||||
|  | ||||
| type TextResponse struct { | ||||
| 	Usage `json:"usage"` | ||||
| } | ||||
|  | ||||
| type StreamResponse struct { | ||||
| 	Choices []struct { | ||||
| 		Delta struct { | ||||
| 			Content string `json:"content"` | ||||
| 		} `json:"delta"` | ||||
| 		FinishReason string `json:"finish_reason"` | ||||
| 	} `json:"choices"` | ||||
| } | ||||
|  | ||||
| var tokenEncoder, _ = tiktoken.GetEncoding("cl100k_base") | ||||
|  | ||||
| func countToken(text string) int { | ||||
| 	token := tokenEncoder.Encode(text, nil, nil) | ||||
| 	return len(token) | ||||
| } | ||||
|  | ||||
| func Relay(c *gin.Context) { | ||||
| 	channelType := c.GetInt("channel") | ||||
| 	tokenId := c.GetInt("token_id") | ||||
| 	isUnlimitedTimes := c.GetBool("unlimited_times") | ||||
| 	baseURL := common.ChannelBaseURLs[channelType] | ||||
| 	if channelType == common.ChannelTypeCustom { | ||||
| 		baseURL = c.GetString("base_url") | ||||
| 	} | ||||
| 	requestURL := c.Request.URL.String() | ||||
| 	req, err := http.NewRequest(c.Request.Method, fmt.Sprintf("%s%s", baseURL, requestURL), c.Request.Body) | ||||
| 	err := relayHelper(c) | ||||
| 	if err != nil { | ||||
| 		c.JSON(http.StatusOK, gin.H{ | ||||
| 			"error": gin.H{ | ||||
| @@ -28,42 +61,107 @@ func Relay(c *gin.Context) { | ||||
| 				"type":    "one_api_error", | ||||
| 			}, | ||||
| 		}) | ||||
| 		return | ||||
| 	} | ||||
| 	//req.Header = c.Request.Header.Clone() | ||||
| 	// Fix HTTP Decompression failed | ||||
| 	// https://github.com/stoplightio/prism/issues/1064#issuecomment-824682360 | ||||
| 	//req.Header.Del("Accept-Encoding") | ||||
| 	req.Header.Set("Authorization", c.Request.Header.Get("Authorization")) | ||||
| } | ||||
|  | ||||
| func relayHelper(c *gin.Context) error { | ||||
| 	channelType := c.GetInt("channel") | ||||
| 	tokenId := c.GetInt("token_id") | ||||
| 	consumeQuota := c.GetBool("consume_quota") | ||||
| 	var textRequest TextRequest | ||||
| 	if consumeQuota || channelType == common.ChannelTypeAzure { | ||||
| 		requestBody, err := io.ReadAll(c.Request.Body) | ||||
| 		if err != nil { | ||||
| 			return err | ||||
| 		} | ||||
| 		err = c.Request.Body.Close() | ||||
| 		if err != nil { | ||||
| 			return err | ||||
| 		} | ||||
| 		err = json.Unmarshal(requestBody, &textRequest) | ||||
| 		if err != nil { | ||||
| 			return err | ||||
| 		} | ||||
| 		// Reset request body | ||||
| 		c.Request.Body = io.NopCloser(bytes.NewBuffer(requestBody)) | ||||
| 	} | ||||
| 	baseURL := common.ChannelBaseURLs[channelType] | ||||
| 	requestURL := c.Request.URL.String() | ||||
| 	if channelType == common.ChannelTypeCustom { | ||||
| 		baseURL = c.GetString("base_url") | ||||
| 	} | ||||
| 	fullRequestURL := fmt.Sprintf("%s%s", baseURL, requestURL) | ||||
| 	if channelType == common.ChannelTypeAzure { | ||||
| 		// https://learn.microsoft.com/en-us/azure/cognitive-services/openai/chatgpt-quickstart?pivots=rest-api&tabs=command-line#rest-api | ||||
| 		query := c.Request.URL.Query() | ||||
| 		if query.Get("api-version") == "" { | ||||
| 			apiVersion := c.GetString("api_version") | ||||
| 			requestURL = fmt.Sprintf("%s?api-version=%s", requestURL, apiVersion) | ||||
| 		} | ||||
| 		baseURL = c.GetString("base_url") | ||||
| 		task := strings.TrimPrefix(requestURL, "/v1/") | ||||
| 		model_ := textRequest.Model | ||||
| 		model_ = strings.Replace(model_, ".", "", -1) | ||||
| 		fullRequestURL = fmt.Sprintf("%s/openai/deployments/%s/%s", baseURL, model_, task) | ||||
| 	} | ||||
| 	req, err := http.NewRequest(c.Request.Method, fullRequestURL, c.Request.Body) | ||||
| 	if err != nil { | ||||
| 		return err | ||||
| 	} | ||||
| 	if channelType == common.ChannelTypeAzure { | ||||
| 		key := c.Request.Header.Get("Authorization") | ||||
| 		key = strings.TrimPrefix(key, "Bearer ") | ||||
| 		req.Header.Set("api-key", key) | ||||
| 	} else { | ||||
| 		req.Header.Set("Authorization", c.Request.Header.Get("Authorization")) | ||||
| 	} | ||||
| 	req.Header.Set("Content-Type", c.Request.Header.Get("Content-Type")) | ||||
| 	req.Header.Set("Accept", c.Request.Header.Get("Accept")) | ||||
| 	req.Header.Set("Connection", c.Request.Header.Get("Connection")) | ||||
| 	client := &http.Client{} | ||||
|  | ||||
| 	resp, err := client.Do(req) | ||||
| 	if err != nil { | ||||
| 		c.JSON(http.StatusOK, gin.H{ | ||||
| 			"error": gin.H{ | ||||
| 				"message": err.Error(), | ||||
| 				"type":    "one_api_error", | ||||
| 			}, | ||||
| 		}) | ||||
| 		return | ||||
| 		return err | ||||
| 	} | ||||
| 	err = req.Body.Close() | ||||
| 	if err != nil { | ||||
| 		return err | ||||
| 	} | ||||
| 	err = c.Request.Body.Close() | ||||
| 	if err != nil { | ||||
| 		return err | ||||
| 	} | ||||
| 	var textResponse TextResponse | ||||
| 	isStream := resp.Header.Get("Content-Type") == "text/event-stream" | ||||
| 	var streamResponseText string | ||||
|  | ||||
| 	defer func() { | ||||
| 		err := req.Body.Close() | ||||
| 		if err != nil { | ||||
| 			common.SysError("Error closing request body: " + err.Error()) | ||||
| 		} | ||||
| 		if !isUnlimitedTimes && requestURL == "/v1/chat/completions" { | ||||
| 			err := model.DecreaseTokenRemainTimesById(tokenId) | ||||
| 		if consumeQuota { | ||||
| 			quota := 0 | ||||
| 			usingGPT4 := strings.HasPrefix(textRequest.Model, "gpt-4") | ||||
| 			completionRatio := 1 | ||||
| 			if usingGPT4 { | ||||
| 				completionRatio = 2 | ||||
| 			} | ||||
| 			if isStream { | ||||
| 				var promptText string | ||||
| 				for _, message := range textRequest.Messages { | ||||
| 					promptText += fmt.Sprintf("%s: %s\n", message.Role, message.Content) | ||||
| 				} | ||||
| 				completionText := fmt.Sprintf("%s: %s\n", "assistant", streamResponseText) | ||||
| 				quota = countToken(promptText) + countToken(completionText)*completionRatio + 3 | ||||
| 			} else { | ||||
| 				quota = textResponse.Usage.PromptTokens + textResponse.Usage.CompletionTokens*completionRatio | ||||
| 			} | ||||
| 			ratio := common.GetModelRatio(textRequest.Model) | ||||
| 			quota = int(float64(quota) * ratio) | ||||
| 			err := model.DecreaseTokenQuota(tokenId, quota) | ||||
| 			if err != nil { | ||||
| 				common.SysError("Error decreasing token remain times: " + err.Error()) | ||||
| 				common.SysError("Error consuming token remain quota: " + err.Error()) | ||||
| 			} | ||||
| 		} | ||||
| 	}() | ||||
| 	isStream := resp.Header.Get("Content-Type") == "text/event-stream" | ||||
|  | ||||
| 	if isStream { | ||||
| 		scanner := bufio.NewScanner(resp.Body) | ||||
| 		scanner.Split(func(data []byte, atEOF bool) (advance int, token []byte, err error) { | ||||
| @@ -87,6 +185,18 @@ func Relay(c *gin.Context) { | ||||
| 			for scanner.Scan() { | ||||
| 				data := scanner.Text() | ||||
| 				dataChan <- data | ||||
| 				data = data[6:] | ||||
| 				if data != "[DONE]" { | ||||
| 					var streamResponse StreamResponse | ||||
| 					err = json.Unmarshal([]byte(data), &streamResponse) | ||||
| 					if err != nil { | ||||
| 						common.SysError("Error unmarshalling stream response: " + err.Error()) | ||||
| 						return | ||||
| 					} | ||||
| 					for _, choice := range streamResponse.Choices { | ||||
| 						streamResponseText += choice.Delta.Content | ||||
| 					} | ||||
| 				} | ||||
| 			} | ||||
| 			stopChan <- true | ||||
| 		}() | ||||
| @@ -103,20 +213,48 @@ func Relay(c *gin.Context) { | ||||
| 				return false | ||||
| 			} | ||||
| 		}) | ||||
| 		return | ||||
| 		err = resp.Body.Close() | ||||
| 		if err != nil { | ||||
| 			return err | ||||
| 		} | ||||
| 		return nil | ||||
| 	} else { | ||||
| 		for k, v := range resp.Header { | ||||
| 			c.Writer.Header().Set(k, v[0]) | ||||
| 		} | ||||
| 		if consumeQuota { | ||||
| 			responseBody, err := io.ReadAll(resp.Body) | ||||
| 			if err != nil { | ||||
| 				return err | ||||
| 			} | ||||
| 			err = resp.Body.Close() | ||||
| 			if err != nil { | ||||
| 				return err | ||||
| 			} | ||||
| 			err = json.Unmarshal(responseBody, &textResponse) | ||||
| 			if err != nil { | ||||
| 				return err | ||||
| 			} | ||||
| 			// Reset response body | ||||
| 			resp.Body = io.NopCloser(bytes.NewBuffer(responseBody)) | ||||
| 		} | ||||
| 		_, err = io.Copy(c.Writer, resp.Body) | ||||
| 		if err != nil { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"error": gin.H{ | ||||
| 					"message": err.Error(), | ||||
| 					"type":    "one_api_error", | ||||
| 				}, | ||||
| 			}) | ||||
| 			return | ||||
| 			return err | ||||
| 		} | ||||
| 		err = resp.Body.Close() | ||||
| 		if err != nil { | ||||
| 			return err | ||||
| 		} | ||||
| 		return nil | ||||
| 	} | ||||
| } | ||||
|  | ||||
| func RelayNotImplemented(c *gin.Context) { | ||||
| 	c.JSON(http.StatusOK, gin.H{ | ||||
| 		"error": gin.H{ | ||||
| 			"message": "Not Implemented", | ||||
| 			"type":    "one_api_error", | ||||
| 		}, | ||||
| 	}) | ||||
| } | ||||
|   | ||||
| @@ -75,6 +75,30 @@ func GetToken(c *gin.Context) { | ||||
| 	return | ||||
| } | ||||
|  | ||||
| func GetTokenStatus(c *gin.Context) { | ||||
| 	tokenId := c.GetInt("token_id") | ||||
| 	userId := c.GetInt("id") | ||||
| 	token, err := model.GetTokenByIds(tokenId, userId) | ||||
| 	if err != nil { | ||||
| 		c.JSON(http.StatusOK, gin.H{ | ||||
| 			"success": false, | ||||
| 			"message": err.Error(), | ||||
| 		}) | ||||
| 		return | ||||
| 	} | ||||
| 	expiredAt := token.ExpiredTime | ||||
| 	if expiredAt == -1 { | ||||
| 		expiredAt = 0 | ||||
| 	} | ||||
| 	c.JSON(http.StatusOK, gin.H{ | ||||
| 		"object":          "credit_summary", | ||||
| 		"total_granted":   token.RemainQuota, | ||||
| 		"total_used":      0, // not supported currently | ||||
| 		"total_available": token.RemainQuota, | ||||
| 		"expires_at":      expiredAt * 1000, | ||||
| 	}) | ||||
| } | ||||
|  | ||||
| func AddToken(c *gin.Context) { | ||||
| 	isAdmin := c.GetInt("role") >= common.RoleAdminUser | ||||
| 	token := model.Token{} | ||||
| @@ -102,8 +126,8 @@ func AddToken(c *gin.Context) { | ||||
| 		ExpiredTime:  token.ExpiredTime, | ||||
| 	} | ||||
| 	if isAdmin { | ||||
| 		cleanToken.RemainTimes = token.RemainTimes | ||||
| 		cleanToken.UnlimitedTimes = token.UnlimitedTimes | ||||
| 		cleanToken.RemainQuota = token.RemainQuota | ||||
| 		cleanToken.UnlimitedQuota = token.UnlimitedQuota | ||||
| 	} else { | ||||
| 		userId := c.GetInt("id") | ||||
| 		quota, err := model.GetUserQuota(userId) | ||||
| @@ -114,9 +138,7 @@ func AddToken(c *gin.Context) { | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		if quota > 0 { | ||||
| 			cleanToken.RemainTimes = quota | ||||
| 		} | ||||
| 		cleanToken.RemainQuota = quota | ||||
| 	} | ||||
| 	err = cleanToken.Insert() | ||||
| 	if err != nil { | ||||
| @@ -128,7 +150,7 @@ func AddToken(c *gin.Context) { | ||||
| 	} | ||||
| 	if !isAdmin { | ||||
| 		// update user quota | ||||
| 		err = model.DecreaseUserQuota(c.GetInt("id"), cleanToken.RemainTimes) | ||||
| 		err = model.DecreaseUserQuota(c.GetInt("id"), cleanToken.RemainQuota) | ||||
| 	} | ||||
| 	c.JSON(http.StatusOK, gin.H{ | ||||
| 		"success": true, | ||||
| @@ -184,7 +206,7 @@ func UpdateToken(c *gin.Context) { | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		if cleanToken.Status == common.TokenStatusExhausted && cleanToken.RemainTimes <= 0 && !cleanToken.UnlimitedTimes { | ||||
| 		if cleanToken.Status == common.TokenStatusExhausted && cleanToken.RemainQuota <= 0 && !cleanToken.UnlimitedQuota { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"success": false, | ||||
| 				"message": "令牌可用次数已用尽,无法启用,请先修改令牌剩余次数,或者设置为无限次数", | ||||
| @@ -199,8 +221,8 @@ func UpdateToken(c *gin.Context) { | ||||
| 		cleanToken.Name = token.Name | ||||
| 		cleanToken.ExpiredTime = token.ExpiredTime | ||||
| 		if isAdmin { | ||||
| 			cleanToken.RemainTimes = token.RemainTimes | ||||
| 			cleanToken.UnlimitedTimes = token.UnlimitedTimes | ||||
| 			cleanToken.RemainQuota = token.RemainQuota | ||||
| 			cleanToken.UnlimitedQuota = token.UnlimitedQuota | ||||
| 		} | ||||
| 	} | ||||
| 	err = cleanToken.Update() | ||||
|   | ||||
| @@ -539,9 +539,23 @@ func ManageUser(c *gin.Context) { | ||||
| 	switch req.Action { | ||||
| 	case "disable": | ||||
| 		user.Status = common.UserStatusDisabled | ||||
| 		if user.Role == common.RoleRootUser { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"success": false, | ||||
| 				"message": "无法禁用超级管理员用户", | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 	case "enable": | ||||
| 		user.Status = common.UserStatusEnabled | ||||
| 	case "delete": | ||||
| 		if user.Role == common.RoleRootUser { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"success": false, | ||||
| 				"message": "无法删除超级管理员用户", | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		if err := user.Delete(); err != nil { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"success": false, | ||||
| @@ -557,6 +571,13 @@ func ManageUser(c *gin.Context) { | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		if user.Role >= common.RoleAdminUser { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"success": false, | ||||
| 				"message": "该用户已经是管理员", | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		user.Role = common.RoleAdminUser | ||||
| 	case "demote": | ||||
| 		if user.Role == common.RoleRootUser { | ||||
| @@ -566,6 +587,13 @@ func ManageUser(c *gin.Context) { | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		if user.Role == common.RoleCommonUser { | ||||
| 			c.JSON(http.StatusOK, gin.H{ | ||||
| 				"success": false, | ||||
| 				"message": "该用户已经是普通用户", | ||||
| 			}) | ||||
| 			return | ||||
| 		} | ||||
| 		user.Role = common.RoleCommonUser | ||||
| 	} | ||||
|  | ||||
|   | ||||
							
								
								
									
										22
									
								
								docker-compose.yml
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										22
									
								
								docker-compose.yml
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,22 @@ | ||||
| version: '3.4' | ||||
|  | ||||
| services: | ||||
|   one-api: | ||||
|     image: ghcr.io/songquanpeng/one-api:latest | ||||
|     container_name: one-api | ||||
|     restart: always | ||||
|     command: --log-dir /app/logs | ||||
|     ports: | ||||
|       - "3000:3000" | ||||
|     volumes: | ||||
|       - /home/ubuntu/data/one-api:/data | ||||
|       - /home/ubuntu/data/one-api/logs:/app/logs | ||||
|     # environment: | ||||
|     #   REDIS_CONN_STRING: redis://default:redispw@localhost:49153 | ||||
|     #   SESSION_SECRET: random_string | ||||
|     #   SQL_DSN: root:123456@tcp(localhost:3306)/one-api | ||||
|     healthcheck: | ||||
|       test: ["CMD-SHELL", "curl -s http://localhost:3000/api/status | grep -o '\"success\":\\s*true' | awk '{print $2}' | grep 'true'"] | ||||
|       interval: 30s | ||||
|       timeout: 10s | ||||
|       retries: 3 | ||||
							
								
								
									
										5
									
								
								go.mod
									
									
									
									
									
								
							
							
						
						
									
										5
									
								
								go.mod
									
									
									
									
									
								
							| @@ -12,8 +12,8 @@ require ( | ||||
| 	github.com/go-playground/validator/v10 v10.12.0 | ||||
| 	github.com/go-redis/redis/v8 v8.11.5 | ||||
| 	github.com/google/uuid v1.3.0 | ||||
| 	github.com/pkoukk/tiktoken-go v0.1.1 | ||||
| 	golang.org/x/crypto v0.8.0 | ||||
| 	gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df | ||||
| 	gorm.io/driver/mysql v1.4.3 | ||||
| 	gorm.io/driver/sqlite v1.4.3 | ||||
| 	gorm.io/gorm v1.24.0 | ||||
| @@ -25,6 +25,7 @@ require ( | ||||
| 	github.com/cespare/xxhash/v2 v2.1.2 // indirect | ||||
| 	github.com/chenzhuoyu/base64x v0.0.0-20221115062448-fe3a3abad311 // indirect | ||||
| 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect | ||||
| 	github.com/dlclark/regexp2 v1.8.1 // indirect | ||||
| 	github.com/gin-contrib/sse v0.1.0 // indirect | ||||
| 	github.com/go-playground/locales v0.14.1 // indirect | ||||
| 	github.com/go-playground/universal-translator v0.18.1 // indirect | ||||
| @@ -51,7 +52,5 @@ require ( | ||||
| 	golang.org/x/sys v0.7.0 // indirect | ||||
| 	golang.org/x/text v0.9.0 // indirect | ||||
| 	google.golang.org/protobuf v1.30.0 // indirect | ||||
| 	gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc // indirect | ||||
| 	gopkg.in/yaml.v2 v2.4.0 // indirect | ||||
| 	gopkg.in/yaml.v3 v3.0.1 // indirect | ||||
| ) | ||||
|   | ||||
							
								
								
									
										35
									
								
								go.sum
									
									
									
									
									
								
							
							
						
						
									
										35
									
								
								go.sum
									
									
									
									
									
								
							| @@ -14,6 +14,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c | ||||
| github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= | ||||
| github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78= | ||||
| github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc= | ||||
| github.com/dlclark/regexp2 v1.8.1 h1:6Lcdwya6GjPUNsBct8Lg/yRPwMhABj269AAzdGSiR+0= | ||||
| github.com/dlclark/regexp2 v1.8.1/go.mod h1:DHkYz0B9wPfa6wondMfaivmHpzrQ3v9q8cnmRbL6yW8= | ||||
| github.com/fsnotify/fsnotify v1.4.9 h1:hsms1Qyu0jgnwNXIxa+/V/PDsU6CfLf6CNO8H7IWoS4= | ||||
| github.com/gin-contrib/cors v1.4.0 h1:oJ6gwtUl3lqV0WEIwM/LxPF1QZ5qe2lGWdY2+bz7y0g= | ||||
| github.com/gin-contrib/cors v1.4.0/go.mod h1:bs9pNM0x/UsmHPBWT2xZz9ROh8xYjYkiURUfmBoMlcs= | ||||
| @@ -26,33 +28,27 @@ github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm | ||||
| github.com/gin-contrib/static v0.0.1 h1:JVxuvHPuUfkoul12N7dtQw7KRn/pSMq7Ue1Va9Swm1U= | ||||
| github.com/gin-contrib/static v0.0.1/go.mod h1:CSxeF+wep05e0kCOsqWdAWbSszmc31zTIbD8TvWl7Hs= | ||||
| github.com/gin-gonic/gin v1.6.3/go.mod h1:75u5sXoLsGZoRN5Sgbi1eraJ4GU3++wFwWzhwvtwp4M= | ||||
| github.com/gin-gonic/gin v1.8.1 h1:4+fr/el88TOO3ewCmQr8cx/CtZ/umlIRIs5M4NTNjf8= | ||||
| github.com/gin-gonic/gin v1.8.1/go.mod h1:ji8BvRH1azfM+SYow9zQ6SZMvR8qOMZHmsCuWR9tTTk= | ||||
| github.com/gin-gonic/gin v1.9.0 h1:OjyFBKICoexlu99ctXNR2gg+c5pKrKMuyjgARg9qeY8= | ||||
| github.com/gin-gonic/gin v1.9.0/go.mod h1:W1Me9+hsUSyj3CePGrd1/QrKJMSJ1Tu/0hFEH89961k= | ||||
| github.com/go-playground/assert/v2 v2.0.1 h1:MsBgLAaY856+nPRTKrp3/OZK38U/wa0CcBYNjji3q3A= | ||||
| github.com/go-playground/assert/v2 v2.0.1/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4= | ||||
| github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s= | ||||
| github.com/go-playground/locales v0.13.0/go.mod h1:taPMhCMXrRLJO55olJkUXHZBHCxTMfnGwq/HNwmWNS8= | ||||
| github.com/go-playground/locales v0.14.0 h1:u50s323jtVGugKlcYeyzC0etD1HifMjqmJqb8WugfUU= | ||||
| github.com/go-playground/locales v0.14.0/go.mod h1:sawfccIbzZTqEDETgFXqTho0QybSa7l++s0DH+LDiLs= | ||||
| github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA= | ||||
| github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY= | ||||
| github.com/go-playground/universal-translator v0.17.0/go.mod h1:UkSxE5sNxxRwHyU+Scu5vgOQjsIJAF8j9muTVoKLVtA= | ||||
| github.com/go-playground/universal-translator v0.18.0 h1:82dyy6p4OuJq4/CByFNOn/jYrnRPArHwAcmLoJZxyho= | ||||
| github.com/go-playground/universal-translator v0.18.0/go.mod h1:UvRDBj+xPUEGrFYl+lu/H90nyDXpg0fqeB/AQUGNTVA= | ||||
| github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY= | ||||
| github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY= | ||||
| github.com/go-playground/validator/v10 v10.2.0/go.mod h1:uOYAAleCW8F/7oMFd6aG0GOhaH6EGOAJShg8Id5JGkI= | ||||
| github.com/go-playground/validator/v10 v10.10.0/go.mod h1:74x4gJWsvQexRdW8Pn3dXSGrTK4nAUsbPlLADvpJkos= | ||||
| github.com/go-playground/validator/v10 v10.11.1 h1:prmOlTVv+YjZjmRmNSF3VmspqJIxJWXmqUsHwfTRRkQ= | ||||
| github.com/go-playground/validator/v10 v10.11.1/go.mod h1:i+3WkQ1FvaUjjxh1kSvIA4dMGDBiPU55YFDl0WbKdWU= | ||||
| github.com/go-playground/validator/v10 v10.12.0 h1:E4gtWgxWxp8YSxExrQFv5BpCahla0PVF2oTTEYaWQGI= | ||||
| github.com/go-playground/validator/v10 v10.12.0/go.mod h1:hCAPuzYvKdP33pxWa+2+6AIKXEKqjIUyqsNCtbsSJrA= | ||||
| github.com/go-redis/redis/v8 v8.11.5 h1:AcZZR7igkdvfVmQTPnu9WE37LRrO/YrBH5zWyjDC0oI= | ||||
| github.com/go-redis/redis/v8 v8.11.5/go.mod h1:gREzHqY1hg6oD9ngVRbLStwAWKhA0FEgq8Jd4h5lpwo= | ||||
| github.com/go-sql-driver/mysql v1.6.0 h1:BCTh4TKNUYmOmMUcQ3IipzF5prigylS7XXjEkfCHuOE= | ||||
| github.com/go-sql-driver/mysql v1.6.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg= | ||||
| github.com/goccy/go-json v0.9.7 h1:IcB+Aqpx/iMHu5Yooh7jEzJk1JZ7Pjtmys2ukPr7EeM= | ||||
| github.com/goccy/go-json v0.9.7/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= | ||||
| github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= | ||||
| github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= | ||||
| @@ -92,19 +88,16 @@ github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= | ||||
| github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= | ||||
| github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= | ||||
| github.com/leodido/go-urn v1.2.0/go.mod h1:+8+nEpDfqqsY+g338gtMEUOtuK+4dEMhiQEgxpxOKII= | ||||
| github.com/leodido/go-urn v1.2.1 h1:BqpAaACuzVSgi/VLzGZIobT2z4v53pjosyNd9Yv6n/w= | ||||
| github.com/leodido/go-urn v1.2.1/go.mod h1:zt4jvISO2HfUBqxjfIshjdMTYS56ZS/qv49ictyFfxY= | ||||
| github.com/leodido/go-urn v1.2.3 h1:6BE2vPT0lqoz3fmOesHZiaiFh7889ssCo2GMvLCfiuA= | ||||
| github.com/leodido/go-urn v1.2.3/go.mod h1:7ZrI8mTSeBSHl/UaRyKQW1qZeMgak41ANeCNaVckg+4= | ||||
| github.com/mattn/go-isatty v0.0.12/go.mod h1:cbi8OIDigv2wuxKPP5vlRcQ1OAZbq2CE4Kysco4FUpU= | ||||
| github.com/mattn/go-isatty v0.0.14 h1:yVuAays6BHfxijgZPzw+3Zlu5yQgKGP2/hcQbHb7S9Y= | ||||
| github.com/mattn/go-isatty v0.0.14/go.mod h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27kJ6hsGG94= | ||||
| github.com/mattn/go-isatty v0.0.18 h1:DOKFKCQ7FNG2L1rbrmstDN4QVRdS89Nkh85u68Uwp98= | ||||
| github.com/mattn/go-isatty v0.0.18/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= | ||||
| github.com/mattn/go-sqlite3 v1.14.15/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg= | ||||
| github.com/mattn/go-sqlite3 v2.0.3+incompatible h1:gXHsfypPkaMZrKbD5209QV9jbUTJKjyR5WD3HYQSd+U= | ||||
| github.com/mattn/go-sqlite3 v2.0.3+incompatible/go.mod h1:FPy6KqzDD04eiIsT53CuJW3U88zkxoIYsOqkbpncsNc= | ||||
| github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 h1:ZqeYNhU3OHLH3mGKHDcjJRFFRrJa6eAM5H+CtDdOsPc= | ||||
| github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= | ||||
| github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= | ||||
| github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= | ||||
| @@ -114,11 +107,12 @@ github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjY | ||||
| github.com/nxadm/tail v1.4.8 h1:nPr65rt6Y5JFSKQO7qToXr7pePgD6Gwiw05lkbyAQTE= | ||||
| github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE= | ||||
| github.com/onsi/gomega v1.18.1 h1:M1GfJqGRrBrrGGsbxzV5dqM2U2ApXefZCQpkukxYRLE= | ||||
| github.com/pelletier/go-toml/v2 v2.0.1 h1:8e3L2cCQzLFi2CR4g7vGFuFxX7Jl1kKX8gW+iV0GUKU= | ||||
| github.com/pelletier/go-toml/v2 v2.0.1/go.mod h1:r9LEWfGN8R5k0VXJ+0BkIe7MYkRdwZOjgMj2KwnJFUo= | ||||
| github.com/pelletier/go-toml/v2 v2.0.7 h1:muncTPStnKRos5dpVKULv2FVd4bMOhNePj9CjgDb8Us= | ||||
| github.com/pelletier/go-toml/v2 v2.0.7/go.mod h1:eumQOmlWiOPt5WriQQqoM5y18pDHwha2N+QD+EUNTek= | ||||
| github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= | ||||
| github.com/pkoukk/tiktoken-go v0.1.1 h1:jtkYlIECjyM9OW1w4rjPmTohK4arORP9V25y6TM6nXo= | ||||
| github.com/pkoukk/tiktoken-go v0.1.1/go.mod h1:boMWvk9pQCOTx11pgu0DrIdrAKgQzzJKUP6vLXaz7Rw= | ||||
| github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= | ||||
| github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= | ||||
| github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= | ||||
| @@ -132,7 +126,6 @@ github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81P | ||||
| github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= | ||||
| github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= | ||||
| github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= | ||||
| github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk= | ||||
| github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= | ||||
| github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= | ||||
| github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8= | ||||
| @@ -142,7 +135,6 @@ github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2 | ||||
| github.com/ugorji/go v1.1.7/go.mod h1:kZn38zHttfInRq0xu/PH0az30d+z6vm202qpg1oXVMw= | ||||
| github.com/ugorji/go v1.2.7/go.mod h1:nF9osbDWLy6bDVv/Rtoh6QgnvNDpmCalQV5urGCCS6M= | ||||
| github.com/ugorji/go/codec v1.1.7/go.mod h1:Ax+UKWsSmolVDwsd+7N3ZtXu+yMGCf907BLYF3GoBXY= | ||||
| github.com/ugorji/go/codec v1.2.7 h1:YPXUKf7fYbp/y8xloBqZOw2qaVggbfwMlI8WM3wZUJ0= | ||||
| github.com/ugorji/go/codec v1.2.7/go.mod h1:WGN1fab3R1fzQlVQTkfxVtIBhWDRqOviHU95kRgeqEY= | ||||
| github.com/ugorji/go/codec v1.2.11 h1:BMaWp1Bb6fHwEtbplGBGJ498wD+LKlNSl25MjdZY4dU= | ||||
| github.com/ugorji/go/codec v1.2.11/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg= | ||||
| @@ -150,26 +142,17 @@ golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUu | ||||
| golang.org/x/arch v0.3.0 h1:02VY4/ZcO/gBOH6PUaoiptASxtXU10jazRCP865E97k= | ||||
| golang.org/x/arch v0.3.0/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8= | ||||
| golang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= | ||||
| golang.org/x/crypto v0.0.0-20211215153901-e495a2d5b3d3/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4= | ||||
| golang.org/x/crypto v0.1.0 h1:MDRAIl0xIo9Io2xV565hzXHw3zVseKrJKodhohM5CjU= | ||||
| golang.org/x/crypto v0.1.0/go.mod h1:RecgLatLF4+eUMCP1PoPZQb+cVrJcOPbHkTkbkB9sbw= | ||||
| golang.org/x/crypto v0.8.0 h1:pd9TJtTueMTVQXzk8E2XESSMQDj/U7OUu0PqJqPXQjQ= | ||||
| golang.org/x/crypto v0.8.0/go.mod h1:mRqEX+O9/h5TFCrQhkgjo2yKi0yYA+9ecGkdQoHrywE= | ||||
| golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= | ||||
| golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= | ||||
| golang.org/x/net v0.7.0 h1:rJrUqqhjsgNp7KqAIc25s9pZnjU7TUcSY7HcVZjdn1g= | ||||
| golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= | ||||
| golang.org/x/net v0.9.0 h1:aWJ/m6xSmxWBx+V0XRHTlrYrPG56jKsLdTFmsSsCzOM= | ||||
| golang.org/x/net v0.9.0/go.mod h1:d48xBJpPfHeWQsugry2m+kC02ZBRGRgulfHnEXEuWns= | ||||
| golang.org/x/sys v0.0.0-20200116001909-b77594299b42/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= | ||||
| golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= | ||||
| golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= | ||||
| golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| golang.org/x/sys v0.0.0-20210806184541-e5e7981a1069/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| golang.org/x/sys v0.0.0-20220704084225-05e143d24a9e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| golang.org/x/sys v0.5.0 h1:MUK/U/4lj1t1oPg0HfuXDN/Z1wv31ZJ/YcPiGccS4DU= | ||||
| golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| golang.org/x/sys v0.7.0 h1:3jlCCIQZPdOYu1h8BkNvLz8Kgwtae2cagcG/VamtZRU= | ||||
| golang.org/x/sys v0.7.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= | ||||
| @@ -177,28 +160,20 @@ golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9sn | ||||
| golang.org/x/text v0.3.2/go.mod h1:bEr9sfX3Q8Zfm5fL9x+3itogRgK3+ptLWKqgva+5dAk= | ||||
| golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= | ||||
| golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= | ||||
| golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= | ||||
| golang.org/x/text v0.7.0 h1:4BRB4x83lYWy72KwLD/qYDuTu7q9PjSagHvijDw7cLo= | ||||
| golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= | ||||
| golang.org/x/text v0.9.0 h1:2sjJmO8cDvYveuX97RDLsxlyUxLl+GHoLxBiRdHllBE= | ||||
| golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8= | ||||
| golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= | ||||
| golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4= | ||||
| golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= | ||||
| google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw= | ||||
| google.golang.org/protobuf v1.28.0 h1:w43yiav+6bVFTBQFZX0r7ipe9JQ1QsbMgHwbBziscLw= | ||||
| google.golang.org/protobuf v1.28.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= | ||||
| google.golang.org/protobuf v1.30.0 h1:kPPoIgf3TsEvrm0PFe15JQ+570QVxYzEvvHqChK+cng= | ||||
| google.golang.org/protobuf v1.30.0/go.mod h1:HV8QOd/L58Z+nl8r43ehVNZIU/HEI6OcFqwMG9pJV4I= | ||||
| gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc h1:2gGKlE2+asNV9m7xrywl36YYNnBG5ZQ0r/BOOxqPpmk= | ||||
| gopkg.in/alexcesaro/quotedprintable.v3 v3.0.0-20150716171945-2caba252f4dc/go.mod h1:m7x9LTH6d71AHyAX77c9yqWCCa3UKHcVEj9y7hAtKDk= | ||||
| gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= | ||||
| gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= | ||||
| gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= | ||||
| gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= | ||||
| gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= | ||||
| gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df h1:n7WqCuqOuCbNr617RXOY0AWRXxgwEyPp2z+p0+hgMuE= | ||||
| gopkg.in/gomail.v2 v2.0.0-20160411212932-81ebce5c23df/go.mod h1:LRQQ+SO6ZHR7tOkpBDuZnXENFzX8qRjMDMyPD6BRkCw= | ||||
| gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 h1:uRGJdciOHaEIrze2W8Q3AKkepLTh2hOroT7a+7czfdQ= | ||||
| gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= | ||||
| gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI= | ||||
|   | ||||
| @@ -110,7 +110,17 @@ func TokenAuth() func(c *gin.Context) { | ||||
| 		} | ||||
| 		c.Set("id", token.UserId) | ||||
| 		c.Set("token_id", token.Id) | ||||
| 		c.Set("unlimited_times", token.UnlimitedTimes) | ||||
| 		requestURL := c.Request.URL.String() | ||||
| 		consumeQuota := false | ||||
| 		switch requestURL { | ||||
| 		case "/v1/chat/completions": | ||||
| 			consumeQuota = !token.UnlimitedQuota | ||||
| 		case "/v1/completions": | ||||
| 			consumeQuota = !token.UnlimitedQuota | ||||
| 		case "/v1/edits": | ||||
| 			consumeQuota = !token.UnlimitedQuota | ||||
| 		} | ||||
| 		c.Set("consume_quota", consumeQuota) | ||||
| 		if len(parts) > 1 { | ||||
| 			if model.IsAdmin(token.UserId) { | ||||
| 				c.Set("channelId", parts[1]) | ||||
|   | ||||
| @@ -63,8 +63,11 @@ func Distribute() func(c *gin.Context) { | ||||
| 		} | ||||
| 		c.Set("channel", channel.Type) | ||||
| 		c.Request.Header.Set("Authorization", fmt.Sprintf("Bearer %s", channel.Key)) | ||||
| 		if channel.Type == common.ChannelTypeCustom { | ||||
| 		if channel.Type == common.ChannelTypeCustom || channel.Type == common.ChannelTypeAzure { | ||||
| 			c.Set("base_url", channel.BaseURL) | ||||
| 			if channel.Type == common.ChannelTypeAzure { | ||||
| 				c.Set("api_version", channel.Other) | ||||
| 			} | ||||
| 		} | ||||
| 		c.Next() | ||||
| 	} | ||||
|   | ||||
| @@ -15,6 +15,7 @@ type Channel struct { | ||||
| 	CreatedTime  int64  `json:"created_time" gorm:"bigint"` | ||||
| 	AccessedTime int64  `json:"accessed_time" gorm:"bigint"` | ||||
| 	BaseURL      string `json:"base_url" gorm:"column:base_url"` | ||||
| 	Other        string `json:"other"` | ||||
| } | ||||
|  | ||||
| func GetAllChannels(startIdx int, num int) ([]*Channel, error) { | ||||
| @@ -52,6 +53,12 @@ func GetRandomChannel() (*Channel, error) { | ||||
| 	return &channel, err | ||||
| } | ||||
|  | ||||
| func BatchInsertChannels(channels []Channel) error { | ||||
| 	var err error | ||||
| 	err = DB.Create(&channels).Error | ||||
| 	return err | ||||
| } | ||||
|  | ||||
| func (channel *Channel) Insert() error { | ||||
| 	var err error | ||||
| 	err = DB.Create(channel).Error | ||||
|   | ||||
| @@ -33,6 +33,7 @@ func InitOptionMap() { | ||||
| 	common.OptionMap["TurnstileCheckEnabled"] = strconv.FormatBool(common.TurnstileCheckEnabled) | ||||
| 	common.OptionMap["RegisterEnabled"] = strconv.FormatBool(common.RegisterEnabled) | ||||
| 	common.OptionMap["SMTPServer"] = "" | ||||
| 	common.OptionMap["SMTPPort"] = strconv.Itoa(common.SMTPPort) | ||||
| 	common.OptionMap["SMTPAccount"] = "" | ||||
| 	common.OptionMap["SMTPToken"] = "" | ||||
| 	common.OptionMap["Notice"] = "" | ||||
| @@ -47,11 +48,15 @@ func InitOptionMap() { | ||||
| 	common.OptionMap["TurnstileSiteKey"] = "" | ||||
| 	common.OptionMap["TurnstileSecretKey"] = "" | ||||
| 	common.OptionMap["QuotaForNewUser"] = strconv.Itoa(common.QuotaForNewUser) | ||||
| 	common.OptionMap["ModelRatio"] = common.ModelRatio2JSONString() | ||||
| 	common.OptionMap["TopUpLink"] = common.TopUpLink | ||||
| 	common.OptionMapRWMutex.Unlock() | ||||
| 	options, _ := AllOption() | ||||
| 	for _, option := range options { | ||||
| 		updateOptionMap(option.Key, option.Value) | ||||
| 		err := updateOptionMap(option.Key, option.Value) | ||||
| 		if err != nil { | ||||
| 			common.SysError("Failed to update option map: " + err.Error()) | ||||
| 		} | ||||
| 	} | ||||
| } | ||||
|  | ||||
| @@ -68,11 +73,10 @@ func UpdateOption(key string, value string) error { | ||||
| 	// otherwise it will execute Update (with all fields). | ||||
| 	DB.Save(&option) | ||||
| 	// Update OptionMap | ||||
| 	updateOptionMap(key, value) | ||||
| 	return nil | ||||
| 	return updateOptionMap(key, value) | ||||
| } | ||||
|  | ||||
| func updateOptionMap(key string, value string) { | ||||
| func updateOptionMap(key string, value string) (err error) { | ||||
| 	common.OptionMapRWMutex.Lock() | ||||
| 	defer common.OptionMapRWMutex.Unlock() | ||||
| 	common.OptionMap[key] = value | ||||
| @@ -111,6 +115,9 @@ func updateOptionMap(key string, value string) { | ||||
| 	switch key { | ||||
| 	case "SMTPServer": | ||||
| 		common.SMTPServer = value | ||||
| 	case "SMTPPort": | ||||
| 		intValue, _ := strconv.Atoi(value) | ||||
| 		common.SMTPPort = intValue | ||||
| 	case "SMTPAccount": | ||||
| 		common.SMTPAccount = value | ||||
| 	case "SMTPToken": | ||||
| @@ -135,7 +142,10 @@ func updateOptionMap(key string, value string) { | ||||
| 		common.TurnstileSecretKey = value | ||||
| 	case "QuotaForNewUser": | ||||
| 		common.QuotaForNewUser, _ = strconv.Atoi(value) | ||||
| 	case "ModelRatio": | ||||
| 		err = common.UpdateModelRatioByJSONString(value) | ||||
| 	case "TopUpLink": | ||||
| 		common.TopUpLink = value | ||||
| 	} | ||||
| 	return err | ||||
| } | ||||
|   | ||||
| @@ -55,7 +55,7 @@ func Redeem(key string, tokenId int) (quota int, err error) { | ||||
| 	if redemption.Status != common.RedemptionCodeStatusEnabled { | ||||
| 		return 0, errors.New("该兑换码已被使用") | ||||
| 	} | ||||
| 	err = TopUpToken(tokenId, redemption.Quota) | ||||
| 	err = IncreaseTokenQuota(tokenId, redemption.Quota) | ||||
| 	if err != nil { | ||||
| 		return 0, err | ||||
| 	} | ||||
|   | ||||
| @@ -17,8 +17,8 @@ type Token struct { | ||||
| 	CreatedTime    int64  `json:"created_time" gorm:"bigint"` | ||||
| 	AccessedTime   int64  `json:"accessed_time" gorm:"bigint"` | ||||
| 	ExpiredTime    int64  `json:"expired_time" gorm:"bigint;default:-1"` // -1 means never expired | ||||
| 	RemainTimes    int    `json:"remain_times" gorm:"default:0"` | ||||
| 	UnlimitedTimes bool   `json:"unlimited_times" gorm:"default:false"` | ||||
| 	RemainQuota    int    `json:"remain_quota" gorm:"default:0"` | ||||
| 	UnlimitedQuota bool   `json:"unlimited_quota" gorm:"default:false"` | ||||
| } | ||||
|  | ||||
| func GetAllUserTokens(userId int, startIdx int, num int) ([]*Token, error) { | ||||
| @@ -52,13 +52,13 @@ func ValidateUserToken(key string) (token *Token, err error) { | ||||
| 			} | ||||
| 			return nil, errors.New("该 token 已过期") | ||||
| 		} | ||||
| 		if !token.UnlimitedTimes && token.RemainTimes <= 0 { | ||||
| 		if !token.UnlimitedQuota && token.RemainQuota <= 0 { | ||||
| 			token.Status = common.TokenStatusExhausted | ||||
| 			err := token.SelectUpdate() | ||||
| 			if err != nil { | ||||
| 				common.SysError("更新 token 状态失败:" + err.Error()) | ||||
| 			} | ||||
| 			return nil, errors.New("该 token 可用次数已用尽") | ||||
| 			return nil, errors.New("该 token 额度已用尽") | ||||
| 		} | ||||
| 		go func() { | ||||
| 			token.AccessedTime = common.GetTimestamp() | ||||
| @@ -91,7 +91,7 @@ func (token *Token) Insert() error { | ||||
| // Update Make sure your token's fields is completed, because this will update non-zero values | ||||
| func (token *Token) Update() error { | ||||
| 	var err error | ||||
| 	err = DB.Model(token).Select("name", "status", "expired_time", "remain_times", "unlimited_times").Updates(token).Error | ||||
| 	err = DB.Model(token).Select("name", "status", "expired_time", "remain_quota", "unlimited_quota").Updates(token).Error | ||||
| 	return err | ||||
| } | ||||
|  | ||||
| @@ -116,15 +116,26 @@ func DeleteTokenById(id int, userId int) (err error) { | ||||
| 	if err != nil { | ||||
| 		return err | ||||
| 	} | ||||
| 	quota := token.RemainQuota | ||||
| 	if quota != 0 { | ||||
| 		if quota > 0 { | ||||
| 			err = IncreaseUserQuota(userId, quota) | ||||
| 		} else { | ||||
| 			err = DecreaseUserQuota(userId, -quota) | ||||
| 		} | ||||
| 	} | ||||
| 	if err != nil { | ||||
| 		return err | ||||
| 	} | ||||
| 	return token.Delete() | ||||
| } | ||||
|  | ||||
| func DecreaseTokenRemainTimesById(id int) (err error) { | ||||
| 	err = DB.Model(&Token{}).Where("id = ?", id).Update("remain_times", gorm.Expr("remain_times - ?", 1)).Error | ||||
| func IncreaseTokenQuota(id int, quota int) (err error) { | ||||
| 	err = DB.Model(&Token{}).Where("id = ?", id).Update("remain_quota", gorm.Expr("remain_quota + ?", quota)).Error | ||||
| 	return err | ||||
| } | ||||
|  | ||||
| func TopUpToken(id int, times int) (err error) { | ||||
| 	err = DB.Model(&Token{}).Where("id = ?", id).Update("remain_times", gorm.Expr("remain_times + ?", times)).Error | ||||
| func DecreaseTokenQuota(id int, quota int) (err error) { | ||||
| 	err = DB.Model(&Token{}).Where("id = ?", id).Update("remain_quota", gorm.Expr("remain_quota - ?", quota)).Error | ||||
| 	return err | ||||
| } | ||||
|   | ||||
| @@ -225,6 +225,11 @@ func GetUserQuota(id int) (quota int, err error) { | ||||
| 	return quota, err | ||||
| } | ||||
|  | ||||
| func IncreaseUserQuota(id int, quota int) (err error) { | ||||
| 	err = DB.Model(&User{}).Where("id = ?", id).Update("quota", gorm.Expr("quota + ?", quota)).Error | ||||
| 	return err | ||||
| } | ||||
|  | ||||
| func DecreaseUserQuota(id int, quota int) (err error) { | ||||
| 	err = DB.Model(&User{}).Where("id = ?", id).Update("quota", gorm.Expr("quota - ?", quota)).Error | ||||
| 	return err | ||||
|   | ||||
							
								
								
									
										13
									
								
								one-api.service
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										13
									
								
								one-api.service
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,13 @@ | ||||
| [Unit] | ||||
| Description=One API Service | ||||
| After=network.target | ||||
|  | ||||
| [Service] | ||||
| User=yourusername                  # 守护进程用户名 | ||||
| WorkingDirectory=/path/to/One-API  # One API运行路径 | ||||
| ExecStart=/path/to/One-API/one-api --port 3000 --log-dir /path/to/One-API/logs  # 端口 | ||||
| Restart=always | ||||
| RestartSec=5 | ||||
|  | ||||
| [Install] | ||||
| WantedBy=multi-user.target | ||||
							
								
								
									
										18
									
								
								router/dashboard.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										18
									
								
								router/dashboard.go
									
									
									
									
									
										Normal file
									
								
							| @@ -0,0 +1,18 @@ | ||||
| package router | ||||
|  | ||||
| import ( | ||||
| 	"github.com/gin-contrib/gzip" | ||||
| 	"github.com/gin-gonic/gin" | ||||
| 	"one-api/controller" | ||||
| 	"one-api/middleware" | ||||
| ) | ||||
|  | ||||
| func SetDashboardRouter(router *gin.Engine) { | ||||
| 	apiRouter := router.Group("/dashboard") | ||||
| 	apiRouter.Use(gzip.Gzip(gzip.DefaultCompression)) | ||||
| 	apiRouter.Use(middleware.GlobalAPIRateLimit()) | ||||
| 	apiRouter.Use(middleware.TokenAuth()) | ||||
| 	{ | ||||
| 		apiRouter.GET("/billing/credit_grants", controller.GetTokenStatus) | ||||
| 	} | ||||
| } | ||||
| @@ -7,6 +7,7 @@ import ( | ||||
|  | ||||
| func SetRouter(router *gin.Engine, buildFS embed.FS, indexPage []byte) { | ||||
| 	SetApiRouter(router) | ||||
| 	SetDashboardRouter(router) | ||||
| 	SetRelayRouter(router) | ||||
| 	setWebRouter(router, buildFS, indexPage) | ||||
| } | ||||
|   | ||||
| @@ -7,14 +7,32 @@ import ( | ||||
| ) | ||||
|  | ||||
| func SetRelayRouter(router *gin.Engine) { | ||||
| 	// https://platform.openai.com/docs/api-reference/introduction | ||||
| 	relayV1Router := router.Group("/v1") | ||||
| 	relayV1Router.Use(middleware.TokenAuth(), middleware.Distribute()) | ||||
| 	{ | ||||
| 		relayV1Router.Any("/*path", controller.Relay) | ||||
| 	} | ||||
| 	relayDashboardRouter := router.Group("/dashboard") | ||||
| 	relayDashboardRouter.Use(middleware.TokenAuth(), middleware.Distribute()) | ||||
| 	{ | ||||
| 		relayDashboardRouter.Any("/*path", controller.Relay) | ||||
| 		relayV1Router.GET("/models", controller.Relay) | ||||
| 		relayV1Router.GET("/models/:model", controller.Relay) | ||||
| 		relayV1Router.POST("/completions", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/chat/completions", controller.Relay) | ||||
| 		relayV1Router.POST("/edits", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/images/generations", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/images/edits", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/images/variations", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/embeddings", controller.Relay) | ||||
| 		relayV1Router.POST("/audio/transcriptions", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/audio/translations", controller.RelayNotImplemented) | ||||
| 		relayV1Router.GET("/files", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/files", controller.RelayNotImplemented) | ||||
| 		relayV1Router.DELETE("/files/:id", controller.RelayNotImplemented) | ||||
| 		relayV1Router.GET("/files/:id", controller.RelayNotImplemented) | ||||
| 		relayV1Router.GET("/files/:id/content", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/fine-tunes", controller.RelayNotImplemented) | ||||
| 		relayV1Router.GET("/fine-tunes", controller.RelayNotImplemented) | ||||
| 		relayV1Router.GET("/fine-tunes/:id", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/fine-tunes/:id/cancel", controller.RelayNotImplemented) | ||||
| 		relayV1Router.GET("/fine-tunes/:id/events", controller.RelayNotImplemented) | ||||
| 		relayV1Router.DELETE("/models/:model", controller.RelayNotImplemented) | ||||
| 		relayV1Router.POST("/moderations", controller.RelayNotImplemented) | ||||
| 	} | ||||
| } | ||||
|   | ||||
| @@ -19,7 +19,6 @@ import Channel from './pages/Channel'; | ||||
| import Token from './pages/Token'; | ||||
| import EditToken from './pages/Token/EditToken'; | ||||
| import EditChannel from './pages/Channel/EditChannel'; | ||||
| import AddChannel from './pages/Channel/AddChannel'; | ||||
| import Redemption from './pages/Redemption'; | ||||
| import EditRedemption from './pages/Redemption/EditRedemption'; | ||||
|  | ||||
| @@ -93,7 +92,7 @@ function App() { | ||||
|         path='/channel/add' | ||||
|         element={ | ||||
|           <Suspense fallback={<Loading></Loading>}> | ||||
|             <AddChannel /> | ||||
|             <EditChannel /> | ||||
|           </Suspense> | ||||
|         } | ||||
|       /> | ||||
|   | ||||
| @@ -1,6 +1,6 @@ | ||||
| import React, { useEffect, useState } from 'react'; | ||||
| import { Divider, Form, Grid, Header, Message } from 'semantic-ui-react'; | ||||
| import { API, removeTrailingSlash, showError } from '../helpers'; | ||||
| import { API, removeTrailingSlash, showError, verifyJSON } from '../helpers'; | ||||
|  | ||||
| const SystemSetting = () => { | ||||
|   let [inputs, setInputs] = useState({ | ||||
| @@ -12,6 +12,7 @@ const SystemSetting = () => { | ||||
|     GitHubClientSecret: '', | ||||
|     Notice: '', | ||||
|     SMTPServer: '', | ||||
|     SMTPPort: '', | ||||
|     SMTPAccount: '', | ||||
|     SMTPToken: '', | ||||
|     ServerAddress: '', | ||||
| @@ -25,6 +26,7 @@ const SystemSetting = () => { | ||||
|     TurnstileSecretKey: '', | ||||
|     RegisterEnabled: '', | ||||
|     QuotaForNewUser: 0, | ||||
|     ModelRatio: '', | ||||
|     TopUpLink: '' | ||||
|   }); | ||||
|   let originInputs = {}; | ||||
| @@ -90,6 +92,7 @@ const SystemSetting = () => { | ||||
|       name === 'TurnstileSiteKey' || | ||||
|       name === 'TurnstileSecretKey' || | ||||
|       name === 'QuotaForNewUser' || | ||||
|       name === 'ModelRatio' || | ||||
|       name === 'TopUpLink' | ||||
|     ) { | ||||
|       setInputs((inputs) => ({ ...inputs, [name]: value })); | ||||
| @@ -107,10 +110,17 @@ const SystemSetting = () => { | ||||
|     if (originInputs['QuotaForNewUser'] !== inputs.QuotaForNewUser) { | ||||
|       await updateOption('QuotaForNewUser', inputs.QuotaForNewUser); | ||||
|     } | ||||
|     if (originInputs['ModelRatio'] !== inputs.ModelRatio) { | ||||
|       if (!verifyJSON(inputs.ModelRatio)) { | ||||
|         showError('模型倍率不是合法的 JSON 字符串'); | ||||
|         return; | ||||
|       } | ||||
|       await updateOption('ModelRatio', inputs.ModelRatio); | ||||
|     } | ||||
|     if (originInputs['TopUpLink'] !== inputs.TopUpLink) { | ||||
|       await updateOption('TopUpLink', inputs.TopUpLink); | ||||
|     } | ||||
|   } | ||||
|   }; | ||||
|  | ||||
|   const submitSMTP = async () => { | ||||
|     if (originInputs['SMTPServer'] !== inputs.SMTPServer) { | ||||
| @@ -119,6 +129,12 @@ const SystemSetting = () => { | ||||
|     if (originInputs['SMTPAccount'] !== inputs.SMTPAccount) { | ||||
|       await updateOption('SMTPAccount', inputs.SMTPAccount); | ||||
|     } | ||||
|     if ( | ||||
|       originInputs['SMTPPort'] !== inputs.SMTPPort && | ||||
|       inputs.SMTPPort !== '' | ||||
|     ) { | ||||
|       await updateOption('SMTPPort', inputs.SMTPPort); | ||||
|     } | ||||
|     if ( | ||||
|       originInputs['SMTPToken'] !== inputs.SMTPToken && | ||||
|       inputs.SMTPToken !== '' | ||||
| @@ -249,7 +265,7 @@ const SystemSetting = () => { | ||||
|               label='新用户初始配额' | ||||
|               name='QuotaForNewUser' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.QuotaForNewUser} | ||||
|               type='number' | ||||
|               min='0' | ||||
| @@ -259,32 +275,51 @@ const SystemSetting = () => { | ||||
|               label='充值链接' | ||||
|               name='TopUpLink' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.TopUpLink} | ||||
|               type='link' | ||||
|               placeholder='例如发卡网站的购买链接' | ||||
|             /> | ||||
|           </Form.Group> | ||||
|           <Form.Group widths='equal'> | ||||
|             <Form.TextArea | ||||
|               label='模型倍率' | ||||
|               name='ModelRatio' | ||||
|               onChange={handleInputChange} | ||||
|               style={{ minHeight: 250, fontFamily: 'JetBrains Mono, Consolas' }} | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.ModelRatio} | ||||
|               placeholder='为一个 JSON 文本,键为模型名称,值为倍率' | ||||
|             /> | ||||
|           </Form.Group> | ||||
|           <Form.Button onClick={submitOperationConfig}>保存运营设置</Form.Button> | ||||
|           <Divider /> | ||||
|           <Header as='h3'> | ||||
|             配置 SMTP | ||||
|             <Header.Subheader>用以支持系统的邮件发送</Header.Subheader> | ||||
|           </Header> | ||||
|           <Form.Group widths={3}> | ||||
|           <Form.Group widths={4}> | ||||
|             <Form.Input | ||||
|               label='SMTP 服务器地址' | ||||
|               name='SMTPServer' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.SMTPServer} | ||||
|               placeholder='例如:smtp.qq.com' | ||||
|             /> | ||||
|             <Form.Input | ||||
|               label='SMTP 端口' | ||||
|               name='SMTPPort' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.SMTPPort} | ||||
|               placeholder='默认: 587' | ||||
|             /> | ||||
|             <Form.Input | ||||
|               label='SMTP 账户' | ||||
|               name='SMTPAccount' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.SMTPAccount} | ||||
|               placeholder='通常是邮箱地址' | ||||
|             /> | ||||
| @@ -293,7 +328,7 @@ const SystemSetting = () => { | ||||
|               name='SMTPToken' | ||||
|               onChange={handleInputChange} | ||||
|               type='password' | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.SMTPToken} | ||||
|               placeholder='敏感信息不会发送到前端显示' | ||||
|             /> | ||||
| @@ -320,7 +355,7 @@ const SystemSetting = () => { | ||||
|               label='GitHub Client ID' | ||||
|               name='GitHubClientId' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.GitHubClientId} | ||||
|               placeholder='输入你注册的 GitHub OAuth APP 的 ID' | ||||
|             /> | ||||
| @@ -329,7 +364,7 @@ const SystemSetting = () => { | ||||
|               name='GitHubClientSecret' | ||||
|               onChange={handleInputChange} | ||||
|               type='password' | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.GitHubClientSecret} | ||||
|               placeholder='敏感信息不会发送到前端显示' | ||||
|             /> | ||||
| @@ -357,7 +392,7 @@ const SystemSetting = () => { | ||||
|               name='WeChatServerAddress' | ||||
|               placeholder='例如:https://yourdomain.com' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.WeChatServerAddress} | ||||
|             /> | ||||
|             <Form.Input | ||||
| @@ -365,7 +400,7 @@ const SystemSetting = () => { | ||||
|               name='WeChatServerToken' | ||||
|               type='password' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.WeChatServerToken} | ||||
|               placeholder='敏感信息不会发送到前端显示' | ||||
|             /> | ||||
| @@ -373,7 +408,7 @@ const SystemSetting = () => { | ||||
|               label='微信公众号二维码图片链接' | ||||
|               name='WeChatAccountQRCodeImageURL' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.WeChatAccountQRCodeImageURL} | ||||
|               placeholder='输入一个图片链接' | ||||
|             /> | ||||
| @@ -397,7 +432,7 @@ const SystemSetting = () => { | ||||
|               label='Turnstile Site Key' | ||||
|               name='TurnstileSiteKey' | ||||
|               onChange={handleInputChange} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.TurnstileSiteKey} | ||||
|               placeholder='输入你注册的 Turnstile Site Key' | ||||
|             /> | ||||
| @@ -406,7 +441,7 @@ const SystemSetting = () => { | ||||
|               name='TurnstileSecretKey' | ||||
|               onChange={handleInputChange} | ||||
|               type='password' | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               value={inputs.TurnstileSecretKey} | ||||
|               placeholder='敏感信息不会发送到前端显示' | ||||
|             /> | ||||
|   | ||||
| @@ -164,7 +164,7 @@ const TokensTable = () => { | ||||
|       showSuccess('充值成功!'); | ||||
|       let newTokens = [...tokens]; | ||||
|       let realIdx = (activePage - 1) * ITEMS_PER_PAGE + targetTokenIdx; | ||||
|       newTokens[realIdx].remain_times += data; | ||||
|       newTokens[realIdx].remain_quota += data; | ||||
|       setTokens(newTokens); | ||||
|       setRedemptionCode(''); | ||||
|       setShowTopUpModal(false); | ||||
| @@ -217,10 +217,10 @@ const TokensTable = () => { | ||||
|             <Table.HeaderCell | ||||
|               style={{ cursor: 'pointer' }} | ||||
|               onClick={() => { | ||||
|                 sortToken('remain_times'); | ||||
|                 sortToken('remain_quota'); | ||||
|               }} | ||||
|             > | ||||
|               剩余次数 | ||||
|               额度 | ||||
|             </Table.HeaderCell> | ||||
|             <Table.HeaderCell | ||||
|               style={{ cursor: 'pointer' }} | ||||
| @@ -255,7 +255,7 @@ const TokensTable = () => { | ||||
|                   <Table.Cell>{token.id}</Table.Cell> | ||||
|                   <Table.Cell>{token.name ? token.name : '无'}</Table.Cell> | ||||
|                   <Table.Cell>{renderStatus(token.status)}</Table.Cell> | ||||
|                   <Table.Cell>{token.unlimited_times ? '无限制' : token.remain_times}</Table.Cell> | ||||
|                   <Table.Cell>{token.unlimited_quota ? '无限制' : token.remain_quota}</Table.Cell> | ||||
|                   <Table.Cell>{renderTimestamp(token.created_time)}</Table.Cell> | ||||
|                   <Table.Cell>{token.expired_time === -1 ? '永不过期' : renderTimestamp(token.expired_time)}</Table.Cell> | ||||
|                   <Table.Cell> | ||||
|   | ||||
| @@ -1,5 +1,5 @@ | ||||
| import React, { useEffect, useState } from 'react'; | ||||
| import { Button, Form, Label, Pagination, Table } from 'semantic-ui-react'; | ||||
| import { Button, Form, Label, Pagination, Popup, Table } from 'semantic-ui-react'; | ||||
| import { Link } from 'react-router-dom'; | ||||
| import { API, showError, showSuccess } from '../helpers'; | ||||
|  | ||||
| @@ -237,15 +237,25 @@ const UsersTable = () => { | ||||
|                       > | ||||
|                         降级 | ||||
|                       </Button> | ||||
|                       <Button | ||||
|                         size={'small'} | ||||
|                         negative | ||||
|                         onClick={() => { | ||||
|                           manageUser(user.username, 'delete', idx); | ||||
|                         }} | ||||
|                       <Popup | ||||
|                         trigger={ | ||||
|                           <Button size='small' negative> | ||||
|                             删除 | ||||
|                           </Button> | ||||
|                         } | ||||
|                         on='click' | ||||
|                         flowing | ||||
|                         hoverable | ||||
|                       > | ||||
|                         删除 | ||||
|                       </Button> | ||||
|                         <Button | ||||
|                           negative | ||||
|                           onClick={() => { | ||||
|                             manageUser(user.username, 'delete', idx); | ||||
|                           }} | ||||
|                         > | ||||
|                           删除用户 {user.username} | ||||
|                         </Button> | ||||
|                       </Popup> | ||||
|                       <Button | ||||
|                         size={'small'} | ||||
|                         onClick={() => { | ||||
|   | ||||
| @@ -152,4 +152,13 @@ export function downloadTextAsFile(text, filename) { | ||||
|   a.href = url; | ||||
|   a.download = filename; | ||||
|   a.click(); | ||||
| } | ||||
| } | ||||
|  | ||||
| export const verifyJSON = (str) => { | ||||
|   try { | ||||
|     JSON.parse(str); | ||||
|   } catch (e) { | ||||
|     return false; | ||||
|   } | ||||
|   return true; | ||||
| }; | ||||
| @@ -1,95 +0,0 @@ | ||||
| import React, { useState } from 'react'; | ||||
| import { Button, Form, Header, Segment } from 'semantic-ui-react'; | ||||
| import { API, showError, showSuccess } from '../../helpers'; | ||||
| import { CHANNEL_OPTIONS } from '../../constants'; | ||||
|  | ||||
| const AddChannel = () => { | ||||
|   const originInputs = { | ||||
|     name: '', | ||||
|     type: 1, | ||||
|     key: '', | ||||
|     base_url: '', | ||||
|   }; | ||||
|   const [inputs, setInputs] = useState(originInputs); | ||||
|   const { name, type, key } = inputs; | ||||
|  | ||||
|   const handleInputChange = (e, { name, value }) => { | ||||
|     setInputs((inputs) => ({ ...inputs, [name]: value })); | ||||
|   }; | ||||
|  | ||||
|   const submit = async () => { | ||||
|     if (inputs.name === '' || inputs.key === '') return; | ||||
|     if (inputs.base_url.endsWith('/')) { | ||||
|       inputs.base_url = inputs.base_url.slice(0, inputs.base_url.length - 1); | ||||
|     } | ||||
|     const res = await API.post(`/api/channel/`, inputs); | ||||
|     const { success, message } = res.data; | ||||
|     if (success) { | ||||
|       showSuccess('渠道创建成功!'); | ||||
|       setInputs(originInputs); | ||||
|     } else { | ||||
|       showError(message); | ||||
|     } | ||||
|   }; | ||||
|  | ||||
|   return ( | ||||
|     <> | ||||
|       <Segment> | ||||
|         <Header as='h3'>创建新的渠道</Header> | ||||
|         <Form autoComplete='off'> | ||||
|           <Form.Field> | ||||
|             <Form.Select | ||||
|               label='类型' | ||||
|               name='type' | ||||
|               options={CHANNEL_OPTIONS} | ||||
|               value={inputs.type} | ||||
|               onChange={handleInputChange} | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           { | ||||
|             type === 8 && ( | ||||
|               <Form.Field> | ||||
|                 <Form.Input | ||||
|                   label='Base URL' | ||||
|                   name='base_url' | ||||
|                   placeholder={'请输入自定义渠道的 Base URL'} | ||||
|                   onChange={handleInputChange} | ||||
|                   value={inputs.base_url} | ||||
|                   autoComplete='off' | ||||
|                 /> | ||||
|               </Form.Field> | ||||
|             ) | ||||
|           } | ||||
|           <Form.Field> | ||||
|             <Form.Input | ||||
|               label='名称' | ||||
|               name='name' | ||||
|               placeholder={'请输入名称'} | ||||
|               onChange={handleInputChange} | ||||
|               value={name} | ||||
|               autoComplete='off' | ||||
|               required | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           <Form.Field> | ||||
|             <Form.Input | ||||
|               label='密钥' | ||||
|               name='key' | ||||
|               placeholder={'请输入密钥'} | ||||
|               onChange={handleInputChange} | ||||
|               value={key} | ||||
|               // type='password' | ||||
|               autoComplete='off' | ||||
|               required | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           <Button type={'submit'} onClick={submit}> | ||||
|             提交 | ||||
|           </Button> | ||||
|         </Form> | ||||
|       </Segment> | ||||
|     </> | ||||
|   ); | ||||
| }; | ||||
|  | ||||
| export default AddChannel; | ||||
| @@ -1,5 +1,5 @@ | ||||
| import React, { useEffect, useState } from 'react'; | ||||
| import { Button, Form, Header, Segment } from 'semantic-ui-react'; | ||||
| import { Button, Form, Header, Message, Segment } from 'semantic-ui-react'; | ||||
| import { useParams } from 'react-router-dom'; | ||||
| import { API, showError, showSuccess } from '../../helpers'; | ||||
| import { CHANNEL_OPTIONS } from '../../constants'; | ||||
| @@ -7,14 +7,19 @@ import { CHANNEL_OPTIONS } from '../../constants'; | ||||
| const EditChannel = () => { | ||||
|   const params = useParams(); | ||||
|   const channelId = params.id; | ||||
|   const [loading, setLoading] = useState(true); | ||||
|   const [inputs, setInputs] = useState({ | ||||
|   const isEdit = channelId !== undefined; | ||||
|   const [loading, setLoading] = useState(isEdit); | ||||
|   const originInputs = { | ||||
|     name: '', | ||||
|     key: '', | ||||
|     type: 1, | ||||
|     key: '', | ||||
|     base_url: '', | ||||
|   }); | ||||
|     other: '' | ||||
|   }; | ||||
|   const [batch, setBatch] = useState(false); | ||||
|   const [inputs, setInputs] = useState(originInputs); | ||||
|   const handleInputChange = (e, { name, value }) => { | ||||
|     console.log(name, value); | ||||
|     setInputs((inputs) => ({ ...inputs, [name]: value })); | ||||
|   }; | ||||
|  | ||||
| @@ -30,17 +35,31 @@ const EditChannel = () => { | ||||
|     setLoading(false); | ||||
|   }; | ||||
|   useEffect(() => { | ||||
|     loadChannel().then(); | ||||
|     if (isEdit) { | ||||
|       loadChannel().then(); | ||||
|     } | ||||
|   }, []); | ||||
|  | ||||
|   const submit = async () => { | ||||
|     if (inputs.base_url.endsWith('/')) { | ||||
|       inputs.base_url = inputs.base_url.slice(0, inputs.base_url.length - 1); | ||||
|     if (!isEdit && (inputs.name === '' || inputs.key === '')) return; | ||||
|     let localInputs = inputs; | ||||
|     if (localInputs.base_url.endsWith('/')) { | ||||
|       localInputs.base_url = localInputs.base_url.slice(0, localInputs.base_url.length - 1); | ||||
|     } | ||||
|     let res; | ||||
|     if (isEdit) { | ||||
|       res = await API.put(`/api/channel/`, { ...localInputs, id: parseInt(channelId) }); | ||||
|     } else { | ||||
|       res = await API.post(`/api/channel/`, localInputs); | ||||
|     } | ||||
|     let res = await API.put(`/api/channel/`, { ...inputs, id: parseInt(channelId) }); | ||||
|     const { success, message } = res.data; | ||||
|     if (success) { | ||||
|       showSuccess('渠道更新成功!'); | ||||
|       if (isEdit) { | ||||
|         showSuccess('渠道更新成功!'); | ||||
|       } else { | ||||
|         showSuccess('渠道创建成功!'); | ||||
|         setInputs(originInputs); | ||||
|       } | ||||
|     } else { | ||||
|       showError(message); | ||||
|     } | ||||
| @@ -49,8 +68,8 @@ const EditChannel = () => { | ||||
|   return ( | ||||
|     <> | ||||
|       <Segment loading={loading}> | ||||
|         <Header as='h3'>更新渠道信息</Header> | ||||
|         <Form autoComplete='off'> | ||||
|         <Header as='h3'>{isEdit ? '更新渠道信息' : '创建新的渠道'}</Header> | ||||
|         <Form autoComplete='new-password'> | ||||
|           <Form.Field> | ||||
|             <Form.Select | ||||
|               label='类型' | ||||
| @@ -60,16 +79,45 @@ const EditChannel = () => { | ||||
|               onChange={handleInputChange} | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           { | ||||
|             inputs.type === 3 && ( | ||||
|               <> | ||||
|                 <Message> | ||||
|                   注意,<strong>模型部署名称必须和模型名称保持一致</strong>,因为 One API 会把请求体中的 model 参数替换为你的部署名称(模型名称中的点会被剔除)。 | ||||
|                 </Message> | ||||
|                 <Form.Field> | ||||
|                   <Form.Input | ||||
|                     label='AZURE_OPENAI_ENDPOINT' | ||||
|                     name='base_url' | ||||
|                     placeholder={'请输入 AZURE_OPENAI_ENDPOINT,例如:https://docs-test-001.openai.azure.com'} | ||||
|                     onChange={handleInputChange} | ||||
|                     value={inputs.base_url} | ||||
|                     autoComplete='new-password' | ||||
|                   /> | ||||
|                 </Form.Field> | ||||
|                 <Form.Field> | ||||
|                   <Form.Input | ||||
|                     label='默认 API 版本' | ||||
|                     name='other' | ||||
|                     placeholder={'请输入默认 API 版本,例如:2023-03-15-preview,该配置可以被实际的请求查询参数所覆盖'} | ||||
|                     onChange={handleInputChange} | ||||
|                     value={inputs.other} | ||||
|                     autoComplete='new-password' | ||||
|                   /> | ||||
|                 </Form.Field> | ||||
|               </> | ||||
|             ) | ||||
|           } | ||||
|           { | ||||
|             inputs.type === 8 && ( | ||||
|               <Form.Field> | ||||
|                 <Form.Input | ||||
|                   label='Base URL' | ||||
|                   name='base_url' | ||||
|                   placeholder={'请输入新的自定义渠道的 Base URL'} | ||||
|                   placeholder={'请输入自定义渠道的 Base URL,例如:https://openai.justsong.cn'} | ||||
|                   onChange={handleInputChange} | ||||
|                   value={inputs.base_url} | ||||
|                   autoComplete='off' | ||||
|                   autoComplete='new-password' | ||||
|                 /> | ||||
|               </Form.Field> | ||||
|             ) | ||||
| @@ -78,23 +126,44 @@ const EditChannel = () => { | ||||
|             <Form.Input | ||||
|               label='名称' | ||||
|               name='name' | ||||
|               placeholder={'请输入新的名称'} | ||||
|               placeholder={'请输入名称'} | ||||
|               onChange={handleInputChange} | ||||
|               value={inputs.name} | ||||
|               autoComplete='off' | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           <Form.Field> | ||||
|             <Form.Input | ||||
|               label='密钥' | ||||
|               name='key' | ||||
|               placeholder={'请输入新的密钥'} | ||||
|               onChange={handleInputChange} | ||||
|               value={inputs.key} | ||||
|               // type='password' | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           { | ||||
|             batch ? <Form.Field> | ||||
|               <Form.TextArea | ||||
|                 label='密钥' | ||||
|                 name='key' | ||||
|                 placeholder={'请输入密钥,一行一个'} | ||||
|                 onChange={handleInputChange} | ||||
|                 value={inputs.key} | ||||
|                 style={{ minHeight: 150, fontFamily: 'JetBrains Mono, Consolas' }} | ||||
|                 autoComplete='new-password' | ||||
|               /> | ||||
|             </Form.Field> : <Form.Field> | ||||
|               <Form.Input | ||||
|                 label='密钥' | ||||
|                 name='key' | ||||
|                 placeholder={'请输入密钥'} | ||||
|                 onChange={handleInputChange} | ||||
|                 value={inputs.key} | ||||
|                 autoComplete='new-password' | ||||
|                 /> | ||||
|             </Form.Field> | ||||
|           } | ||||
|           { | ||||
|             !isEdit && ( | ||||
|               <Form.Checkbox | ||||
|                 checked={batch} | ||||
|                 label='批量创建' | ||||
|                 name='batch' | ||||
|                 onChange={() => setBatch(!batch)} | ||||
|               /> | ||||
|             ) | ||||
|           } | ||||
|           <Button onClick={submit}>提交</Button> | ||||
|         </Form> | ||||
|       </Segment> | ||||
|   | ||||
| @@ -73,7 +73,7 @@ const EditRedemption = () => { | ||||
|     <> | ||||
|       <Segment loading={loading}> | ||||
|         <Header as='h3'>{isEdit ? '更新兑换码信息' : '创建新的兑换码'}</Header> | ||||
|         <Form autoComplete='off'> | ||||
|         <Form autoComplete='new-password'> | ||||
|           <Form.Field> | ||||
|             <Form.Input | ||||
|               label='名称' | ||||
| @@ -81,7 +81,7 @@ const EditRedemption = () => { | ||||
|               placeholder={'请输入名称'} | ||||
|               onChange={handleInputChange} | ||||
|               value={name} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               required={!isEdit} | ||||
|             /> | ||||
|           </Form.Field> | ||||
| @@ -92,7 +92,7 @@ const EditRedemption = () => { | ||||
|               placeholder={'请输入单个兑换码中包含的额度'} | ||||
|               onChange={handleInputChange} | ||||
|               value={quota} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               type='number' | ||||
|             /> | ||||
|           </Form.Field> | ||||
| @@ -105,7 +105,7 @@ const EditRedemption = () => { | ||||
|                   placeholder={'请输入生成数量'} | ||||
|                   onChange={handleInputChange} | ||||
|                   value={count} | ||||
|                   autoComplete='off' | ||||
|                   autoComplete='new-password' | ||||
|                   type='number' | ||||
|                 /> | ||||
|               </Form.Field> | ||||
|   | ||||
| @@ -10,13 +10,13 @@ const EditToken = () => { | ||||
|   const [loading, setLoading] = useState(isEdit); | ||||
|   const originInputs = { | ||||
|     name: '', | ||||
|     remain_times: 0, | ||||
|     remain_quota: 0, | ||||
|     expired_time: -1, | ||||
|     unlimited_times: false | ||||
|     unlimited_quota: false | ||||
|   }; | ||||
|   const isAdminUser = isAdmin(); | ||||
|   const [inputs, setInputs] = useState(originInputs); | ||||
|   const { name, remain_times, expired_time, unlimited_times } = inputs; | ||||
|   const { name, remain_quota, expired_time, unlimited_quota } = inputs; | ||||
|  | ||||
|   const handleInputChange = (e, { name, value }) => { | ||||
|     setInputs((inputs) => ({ ...inputs, [name]: value })); | ||||
| @@ -37,8 +37,8 @@ const EditToken = () => { | ||||
|     } | ||||
|   }; | ||||
|  | ||||
|   const setUnlimitedTimes = () => { | ||||
|     setInputs({ ...inputs, unlimited_times: !unlimited_times }); | ||||
|   const setUnlimitedQuota = () => { | ||||
|     setInputs({ ...inputs, unlimited_quota: !unlimited_quota }); | ||||
|   }; | ||||
|  | ||||
|   const loadToken = async () => { | ||||
| @@ -63,7 +63,7 @@ const EditToken = () => { | ||||
|   const submit = async () => { | ||||
|     if (!isEdit && inputs.name === '') return; | ||||
|     let localInputs = inputs; | ||||
|     localInputs.remain_times = parseInt(localInputs.remain_times); | ||||
|     localInputs.remain_quota = parseInt(localInputs.remain_quota); | ||||
|     if (localInputs.expired_time !== -1) { | ||||
|       let time = Date.parse(localInputs.expired_time); | ||||
|       if (isNaN(time)) { | ||||
| @@ -95,7 +95,7 @@ const EditToken = () => { | ||||
|     <> | ||||
|       <Segment loading={loading}> | ||||
|         <Header as='h3'>{isEdit ? '更新令牌信息' : '创建新的令牌'}</Header> | ||||
|         <Form autoComplete='off'> | ||||
|         <Form autoComplete='new-password'> | ||||
|           <Form.Field> | ||||
|             <Form.Input | ||||
|               label='名称' | ||||
| @@ -103,7 +103,7 @@ const EditToken = () => { | ||||
|               placeholder={'请输入名称'} | ||||
|               onChange={handleInputChange} | ||||
|               value={name} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               required={!isEdit} | ||||
|             /> | ||||
|           </Form.Field> | ||||
| @@ -111,19 +111,19 @@ const EditToken = () => { | ||||
|             isAdminUser && <> | ||||
|               <Form.Field> | ||||
|                 <Form.Input | ||||
|                   label='剩余次数' | ||||
|                   name='remain_times' | ||||
|                   placeholder={'请输入剩余次数'} | ||||
|                   label='额度' | ||||
|                   name='remain_quota' | ||||
|                   placeholder={'请输入额度'} | ||||
|                   onChange={handleInputChange} | ||||
|                   value={remain_times} | ||||
|                   autoComplete='off' | ||||
|                   value={remain_quota} | ||||
|                   autoComplete='new-password' | ||||
|                   type='number' | ||||
|                   disabled={unlimited_times} | ||||
|                   disabled={unlimited_quota} | ||||
|                 /> | ||||
|               </Form.Field> | ||||
|               <Button type={'button'} onClick={() => { | ||||
|                 setUnlimitedTimes(); | ||||
|               }}>{unlimited_times ? '取消无限次' : '设置为无限次'}</Button> | ||||
|               <Button type={'button'} style={{marginBottom: '14px'}} onClick={() => { | ||||
|                 setUnlimitedQuota(); | ||||
|               }}>{unlimited_quota ? '取消无限额度' : '设置为无限额度'}</Button> | ||||
|             </> | ||||
|           } | ||||
|           <Form.Field> | ||||
| @@ -133,7 +133,7 @@ const EditToken = () => { | ||||
|               placeholder={'请输入过期时间,格式为 yyyy-MM-dd HH:mm:ss,-1 表示无限制'} | ||||
|               onChange={handleInputChange} | ||||
|               value={expired_time} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               type='datetime-local' | ||||
|             /> | ||||
|           </Form.Field> | ||||
|   | ||||
| @@ -60,7 +60,7 @@ const EditUser = () => { | ||||
|     <> | ||||
|       <Segment loading={loading}> | ||||
|         <Header as='h3'>更新用户信息</Header> | ||||
|         <Form autoComplete='off'> | ||||
|         <Form autoComplete='new-password'> | ||||
|           <Form.Field> | ||||
|             <Form.Input | ||||
|               label='用户名' | ||||
| @@ -68,7 +68,7 @@ const EditUser = () => { | ||||
|               placeholder={'请输入新的用户名'} | ||||
|               onChange={handleInputChange} | ||||
|               value={username} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           <Form.Field> | ||||
| @@ -79,7 +79,7 @@ const EditUser = () => { | ||||
|               placeholder={'请输入新的密码'} | ||||
|               onChange={handleInputChange} | ||||
|               value={password} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           <Form.Field> | ||||
| @@ -89,7 +89,7 @@ const EditUser = () => { | ||||
|               placeholder={'请输入新的显示名称'} | ||||
|               onChange={handleInputChange} | ||||
|               value={display_name} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|             /> | ||||
|           </Form.Field> | ||||
|           <Form.Field> | ||||
| @@ -97,7 +97,7 @@ const EditUser = () => { | ||||
|               label='已绑定的 GitHub 账户' | ||||
|               name='github_id' | ||||
|               value={github_id} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               placeholder='此项只读,需要用户通过个人设置页面的相关绑定按钮进行绑定,不可直接修改' | ||||
|               readOnly | ||||
|             /> | ||||
| @@ -107,7 +107,7 @@ const EditUser = () => { | ||||
|               label='已绑定的微信账户' | ||||
|               name='wechat_id' | ||||
|               value={wechat_id} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               placeholder='此项只读,需要用户通过个人设置页面的相关绑定按钮进行绑定,不可直接修改' | ||||
|               readOnly | ||||
|             /> | ||||
| @@ -117,7 +117,7 @@ const EditUser = () => { | ||||
|               label='已绑定的邮箱账户' | ||||
|               name='email' | ||||
|               value={email} | ||||
|               autoComplete='off' | ||||
|               autoComplete='new-password' | ||||
|               placeholder='此项只读,需要用户通过个人设置页面的相关绑定按钮进行绑定,不可直接修改' | ||||
|               readOnly | ||||
|             /> | ||||
|   | ||||
		Reference in New Issue
	
	Block a user