opensource/panel
3
0
Fork 0
mirror of https://github.com/tnb-labs/panel.git synced 2026-08-29 02:10:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: lint

Browse Source
This commit is contained in:
耗子
2026-02-14 05:23:50 +08:00
parent 3ab58fc817
commit 47d945710b
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/queuejob/process_task.go
+1 -1
View File
@@ -51,6 +51,6 @@ func (r *ProcessTask) Handle(args ...any) error {
}
func (r *ProcessTask) ErrHandle(err error) {
r.log.Warn("[ProcessTask] background task failed", slog.Any("task_id", r.taskID), slog.Any("err", err))
r.log.Warn("background task failed", slog.Any("task_id", r.taskID), slog.Any("err", err))
_ = r.taskRepo.UpdateStatus(r.taskID, biz.TaskStatusFailed)
}
internal/service/toolbox_migration.go
+2 -2
View File
@@ -338,7 +338,7 @@ func (s *ToolboxMigrationService) Progress(w http.ResponseWriter, r *http.Reques
ws, err := websocket.Accept(w, r, opts)
if err != nil {
s.log.Warn("[Migration] websocket upgrade error", slog.Any("err", err))
s.log.Warn("websocket upgrade error", slog.Any("err", err))
return
}
defer func() { _ = ws.CloseNow() }()
@@ -1055,7 +1055,7 @@ func (s *ToolboxMigrationService) addLog(msg string) {
s.state.mu.Lock()
s.state.Logs = append(s.state.Logs, fmt.Sprintf("[%s] %s", time.Now().Format("15:04:05"), msg))
s.state.mu.Unlock()
s.log.Info("[Migration] " + msg)
s.log.Info(msg)
}
// addResult 添加迁移结果
internal/service/ws.go
+7 -7
View File
@@ -41,7 +41,7 @@ func NewWsService(t *gotext.Locale, conf *config.Config, log *slog.Logger, ssh b
func (s *WsService) Exec(w http.ResponseWriter, r *http.Request) {
ws, err := s.upgrade(w, r)
if err != nil {
s.log.Warn("[Websocket] upgrade exec ws error", slog.Any("err", err))
s.log.Warn("upgrade exec ws error", slog.Any("err", err))
return
}
defer func(ws *websocket.Conn) { _ = ws.CloseNow() }(ws)
@@ -81,7 +81,7 @@ func (s *WsService) Exec(w http.ResponseWriter, r *http.Request) {
func (s *WsService) PTY(w http.ResponseWriter, r *http.Request) {
ws, err := s.upgrade(w, r)
if err != nil {
s.log.Warn("[Websocket] upgrade pty ws error", slog.Any("err", err))
s.log.Warn("upgrade pty ws error", slog.Any("err", err))
return
}
defer func(ws *websocket.Conn) { _ = ws.CloseNow() }(ws)
@@ -131,7 +131,7 @@ func (s *WsService) Session(w http.ResponseWriter, r *http.Request) {
ws, err := s.upgrade(w, r)
if err != nil {
s.log.Warn("[Websocket] upgrade session ws error", slog.Any("err", err))
s.log.Warn("upgrade session ws error", slog.Any("err", err))
return
}
defer func(ws *websocket.Conn) { _ = ws.CloseNow() }(ws)
@@ -170,7 +170,7 @@ func (s *WsService) ContainerTerminal(w http.ResponseWriter, r *http.Request) {
ws, err := s.upgrade(w, r)
if err != nil {
s.log.Warn("[Websocket] upgrade container terminal ws error", slog.Any("err", err))
s.log.Warn("upgrade container terminal ws error", slog.Any("err", err))
return
}
defer func(ws *websocket.Conn) { _ = ws.CloseNow() }(ws)
@@ -200,7 +200,7 @@ func (s *WsService) ContainerTerminal(w http.ResponseWriter, r *http.Request) {
func (s *WsService) ContainerImagePull(w http.ResponseWriter, r *http.Request) {
ws, err := s.upgrade(w, r)
if err != nil {
s.log.Warn("[Websocket] upgrade image pull ws error", slog.Any("err", err))
s.log.Warn("upgrade image pull ws error", slog.Any("err", err))
return
}
defer func(ws *websocket.Conn) { _ = ws.CloseNow() }(ws)
@@ -252,7 +252,7 @@ func (s *WsService) ContainerImagePull(w http.ResponseWriter, r *http.Request) {
// 迭代进度
for msg, err := range resp.JSONMessages(ctx) {
if err != nil {
s.log.Warn("[Websocket] image pull error", slog.Any("err", err))
s.log.Warn("image pull error", slog.Any("err", err))
errorMsg, _ := json.Marshal(map[string]any{
"status": "error",
"error": err.Error(),
@@ -274,7 +274,7 @@ func (s *WsService) ContainerImagePull(w http.ResponseWriter, r *http.Request) {
// 转发进度信息
progressMsg, _ := json.Marshal(msg)
if err = ws.Write(ctx, websocket.MessageText, progressMsg); err != nil {
s.log.Warn("[Websocket] write image pull progress error", slog.Any("err", err))
s.log.Warn("write image pull progress error", slog.Any("err", err))
return
}
}