This commit is contained in:
Sakurasan
2024-09-13 23:13:31 +08:00
parent 7fd82b43f4
commit 7979102880

View File

@@ -2,11 +2,14 @@ package store
import ( import (
"encoding/json" "encoding/json"
"errors"
"fmt" "fmt"
"log" "log"
"opencatd-open/pkg/vertexai" "opencatd-open/pkg/vertexai"
"os" "os"
"time" "time"
"gorm.io/gorm"
) )
func init() { func init() {
@@ -15,7 +18,7 @@ func init() {
vertex_auth := os.Getenv("Vertex") vertex_auth := os.Getenv("Vertex")
var Vertex vertexai.VertexSecretKey var Vertex vertexai.VertexSecretKey
if err := json.Unmarshal([]byte(vertex_auth), &Vertex); err != nil { if err := json.Unmarshal([]byte(vertex_auth), &Vertex); err != nil {
log.Fatalln(err) log.Fatalln(fmt.Errorf("import vertex_auth json error: %w", err))
return return
} }
key := Key{ key := Key{
@@ -24,8 +27,15 @@ func init() {
Key: vertex_auth, Key: vertex_auth,
ApiSecret: vertex_auth, ApiSecret: vertex_auth,
} }
if err := db.FirstOrCreate(&key).Error; err != nil { if err := db.Table("keys").Where("name = ?", Vertex.ProjectID).Find(&key).Error; err != nil {
log.Println(fmt.Errorf("create vertex key error: %v", err)) if errors.Is(err, gorm.ErrRecordNotFound) {
if err := db.Create(&key).Error; err != nil {
log.Fatalln(fmt.Errorf("import vertex_auth json error: %w", err))
}
} else {
log.Fatalln(fmt.Errorf("import vertex_auth json error: %w", err))
return
}
} }
} }
LoadKeysCache() LoadKeysCache()