chore: Remove some unused code

ssongliu · ssongliu · commit 6d387b53a02e · 2025-11-27T16:22:10.000+08:00
diff --git a/core/app/api/v2/auth.go b/core/app/api/v2/auth.go
@@ -118,15 +118,6 @@ func (b *BaseApi) Captcha(c *gin.Context) {
 	helper.SuccessWithData(c, captcha)
 }
 
-func (b *BaseApi) GetResponsePage(c *gin.Context) {
-	pageCode, err := authService.GetResponsePage()
-	if err != nil {
-		helper.InternalServer(c, err)
-		return
-	}
-	helper.SuccessWithData(c, pageCode)
-}
-
 func (b *BaseApi) GetWelcomePage(c *gin.Context) {
 	count, _, _ := logService.PageLoginLog(c, dto.SearchLgLogWithPage{PageInfo: dto.PageInfo{Page: 1, PageSize: 10}})
 	if count != 1 {
diff --git a/core/app/api/v2/helper/helper.go b/core/app/api/v2/helper/helper.go
@@ -1,11 +1,10 @@
 package helper
 
 import (
-	"errors"
 	"fmt"
-	"github.com/1Panel-dev/1Panel/core/cmd/server/res"
 	"net/http"
-	"strconv"
+
+	"github.com/1Panel-dev/1Panel/core/cmd/server/res"
 
 	"github.com/1Panel-dev/1Panel/core/app/dto"
 	"github.com/1Panel-dev/1Panel/core/global"
@@ -91,12 +90,3 @@ func ErrWithHtml(ctx *gin.Context, code int, scope string) {
 	ctx.Data(code, "text/html; charset=utf-8", data)
 	ctx.Abort()
 }
-
-func GetParamID(c *gin.Context) (uint, error) {
-	idParam, ok := c.Params.Get("id")
-	if !ok {
-		return 0, errors.New("error id in path")
-	}
-	intNum, _ := strconv.Atoi(idParam)
-	return uint(intNum), nil
-}
diff --git a/core/app/api/v2/upgrade.go b/core/app/api/v2/upgrade.go
@@ -79,25 +79,3 @@ func (b *BaseApi) Upgrade(c *gin.Context) {
 	}
 	helper.Success(c)
 }
-
-// @Tags System Setting
-// @Summary Upgrade
-// @Accept json
-// @Param request body dto.OperateByID true "request"
-// @Success 200
-// @Security ApiKeyAuth
-// @Security Timestamp
-// @Router /core/settings/rollback [post]
-// @x-panel-log {"bodyKeys":["id"],"paramKeys":[],"BeforeFunctions":[{"input_column":"id","input_value":"id","isList":false,"db":"upgrade_logs","output_column":"old_version","output_value":"version"}],"formatZH":"回滚系统 => [version]","formatEN":"rollback system => [version]"}
-func (b *BaseApi) Rollback(c *gin.Context) {
-	var req dto.OperateByID
-	if err := helper.CheckBindAndValidate(&req, c); err != nil {
-		return
-	}
-
-	if err := upgradeService.Rollback(req); err != nil {
-		helper.InternalServer(c, err)
-		return
-	}
-	helper.Success(c)
-}
diff --git a/core/app/repo/common.go b/core/app/repo/common.go
@@ -29,11 +29,6 @@ func WithByName(name string) global.DBOption {
 		return g.Where("`name` = ?", name)
 	}
 }
-func WithoutByName(name string) global.DBOption {
-	return func(g *gorm.DB) *gorm.DB {
-		return g.Where("`name` != ?", name)
-	}
-}
 
 func WithByType(ty string) global.DBOption {
 	return func(g *gorm.DB) *gorm.DB {
@@ -60,11 +55,6 @@ func WithByNode(node string) global.DBOption {
 		return g.Where("node = ?", node)
 	}
 }
-func WithByGroupBelong(group string) global.DBOption {
-	return func(g *gorm.DB) *gorm.DB {
-		return g.Where("group_belong = ?", group)
-	}
-}
 
 func WithOrderBy(orderStr string) global.DBOption {
 	if orderStr == "createdAt" {
diff --git a/core/app/repo/host.go b/core/app/repo/host.go
@@ -20,7 +20,6 @@ type IHostRepo interface {
 	WithByInfo(info string) global.DBOption
 	WithByPort(port uint) global.DBOption
 	WithByUser(user string) global.DBOption
-	WithByAddr(addr string) global.DBOption
 }
 
 func NewIHostRepo() IHostRepo {
@@ -79,11 +78,6 @@ func (h *HostRepo) WithByUser(user string) global.DBOption {
 		return g.Where("user = ?", user)
 	}
 }
-func (h *HostRepo) WithByAddr(addr string) global.DBOption {
-	return func(g *gorm.DB) *gorm.DB {
-		return g.Where("addr = ?", addr)
-	}
-}
 
 func (h *HostRepo) Create(host *model.Host) error {
 	return global.DB.Create(host).Error
diff --git a/core/app/service/host.go b/core/app/service/host.go
@@ -50,7 +50,7 @@ func (u *HostService) TestByInfo(req dto.HostConnTest) bool {
 		req.PrivateKey = string(privateKey)
 	}
 	if len(req.Password) == 0 && len(req.PrivateKey) == 0 {
-		host, err := hostRepo.Get(hostRepo.WithByAddr(req.Addr), hostRepo.WithByPort(req.Port))
+		host, err := hostRepo.Get(repo.WithByAddr(req.Addr), hostRepo.WithByPort(req.Port))
 		if err != nil {
 			return false
 		}
@@ -235,7 +235,7 @@ func (u *HostService) GetHostByID(id uint) (*dto.HostInfo, error) {
 }
 
 func (u *HostService) Create(req dto.HostOperate) (*dto.HostInfo, error) {
-	hostItem, _ := hostRepo.Get(hostRepo.WithByAddr(req.Addr), hostRepo.WithByUser(req.User), hostRepo.WithByPort(req.Port))
+	hostItem, _ := hostRepo.Get(repo.WithByAddr(req.Addr), hostRepo.WithByUser(req.User), hostRepo.WithByPort(req.Port))
 	if hostItem.ID != 0 {
 		return nil, buserr.New("ErrRecordExist")
 	}
diff --git a/core/utils/cloud_storage/client/helper/webdav/auth.go b/core/utils/cloud_storage/client/helper/webdav/auth.go
@@ -72,16 +72,6 @@ func NewAutoAuth(login string, secret string) Authorizer {
 	return az
 }
 
-func NewEmptyAuth() Authorizer {
-	fmap := make([]authfactory, 0)
-	az := &authorizer{factories: fmap, defAuthMux: sync.Mutex{}, defAuth: &nullAuth{}}
-	return az
-}
-
-func NewPreemptiveAuth(auth Authenticator) Authorizer {
-	return &preemptiveAuthorizer{auth: auth}
-}
-
 func (a *authorizer) NewAuthenticator(body io.Reader) (Authenticator, io.Reader) {
 	var retryBuf io.Reader = body
 	if body != nil {
@@ -296,11 +286,3 @@ func (n *nullAuth) Clone() Authenticator {
 func (n *nullAuth) String() string {
 	return "NullAuth"
 }
-
-func (b *preemptiveAuthorizer) NewAuthenticator(body io.Reader) (Authenticator, io.Reader) {
-	return b.auth.Clone(), body
-}
-
-func (b *preemptiveAuthorizer) AddAuthenticator(key string, fn AuthFactory) {
-	panic("You're funny! A preemptive authorizer may only have a single authentication method")
-}
diff --git a/core/utils/cloud_storage/client/helper/webdav/utils.go b/core/utils/cloud_storage/client/helper/webdav/utils.go
@@ -1,7 +1,6 @@
 package webdav
 
 import (
-	"bytes"
 	"encoding/xml"
 	"io"
 	"net/url"
@@ -63,13 +62,6 @@ func Join(path0 string, path1 string) string {
 	return strings.TrimSuffix(path0, "/") + "/" + strings.TrimPrefix(path1, "/")
 }
 
-func String(r io.Reader) string {
-	buf := new(bytes.Buffer)
-	// TODO - make String return an error as well
-	_, _ = buf.ReadFrom(r)
-	return buf.String()
-}
-
 func parseInt64(s *string) int64 {
 	if n, e := strconv.ParseInt(*s, 10, 64); e == nil {
 		return n
diff --git a/core/utils/cmd/cmd.go b/core/utils/cmd/cmd.go
@@ -1,9 +1,6 @@
 package cmd
 
 import (
-	"bufio"
-	"fmt"
-	"io"
 	"os/exec"
 	"strings"
 )
@@ -23,36 +20,3 @@ func Which(name string) bool {
 	}
 	return true
 }
-
-func ExecWithStreamOutput(command string, outputCallback func(string)) error {
-	cmd := exec.Command("bash", "-c", command)
-
-	stdout, err := cmd.StdoutPipe()
-	if err != nil {
-		return fmt.Errorf("failed to get stdout: %w", err)
-	}
-
-	stderr, err := cmd.StderrPipe()
-	if err != nil {
-		return fmt.Errorf("failed to get stderr: %w", err)
-	}
-
-	if err := cmd.Start(); err != nil {
-		return fmt.Errorf("failed to start command: %w", err)
-	}
-
-	go streamReader(stdout, outputCallback)
-	go streamReader(stderr, outputCallback)
-
-	if err := cmd.Wait(); err != nil {
-		return fmt.Errorf("command finished with error: %w", err)
-	}
-	return nil
-}
-
-func streamReader(reader io.ReadCloser, callback func(string)) {
-	scanner := bufio.NewScanner(reader)
-	for scanner.Scan() {
-		callback(scanner.Text())
-	}
-}
diff --git a/core/utils/common/common.go b/core/utils/common/common.go
@@ -72,19 +72,6 @@ func ScanPort(port int) bool {
 	return false
 }
 
-func CheckPort(host string, port string, timeout time.Duration) bool {
-	target := net.JoinHostPort(host, port)
-	conn, err := net.DialTimeout("tcp", target, timeout)
-	if err != nil {
-		if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
-			return false
-		}
-		return strings.Contains(err.Error(), "connection refused")
-	}
-	defer conn.Close()
-	return true
-}
-
 func ComparePanelVersion(version1, version2 string) bool {
 	if version1 == version2 {
 		return false
diff --git a/core/utils/common/sqlite.go b/core/utils/common/sqlite.go
@@ -31,25 +31,6 @@ func LoadDBConnByPath(fullPath, dbName string) *gorm.DB {
 	return db
 }
 
-func LoadDBConnByPathWithErr(fullPath, dbName string) (*gorm.DB, error) {
-	if _, err := CreateDirWhenNotExist(true, path.Dir(fullPath)); err != nil {
-		return nil, fmt.Errorf("init db dir failed, err: %v", err)
-	}
-	if _, err := os.Stat(fullPath); err != nil {
-		f, err := os.Create(fullPath)
-		if err != nil {
-			return nil, fmt.Errorf("init %s db file failed, err: %v", dbName, err)
-		}
-		_ = f.Close()
-	}
-
-	db, err := GetDBWithPath(fullPath)
-	if err != nil {
-		return nil, fmt.Errorf("init %s db failed, err: %v", dbName, err)
-	}
-	return db, nil
-}
-
 func CloseDB(db *gorm.DB) {
 	sqlDB, err := db.DB()
 	if err != nil {
diff --git a/core/utils/files/files.go b/core/utils/files/files.go
@@ -2,8 +2,6 @@ package files
 
 import (
 	"bytes"
-	"crypto/md5"
-	"encoding/hex"
 	"errors"
 	"fmt"
 	"io"
@@ -196,17 +194,3 @@ func Stat(path string) bool {
 	}
 	return true
 }
-
-func GetFileMD5(filePath string) (string, error) {
-	file, err := os.Open(filePath)
-	if err != nil {
-		return "", err
-	}
-	defer file.Close()
-	hash := md5.New()
-
-	if _, err = io.Copy(hash, file); err != nil {
-		return "", err
-	}
-	return hex.EncodeToString(hash.Sum(nil)), nil
-}

Original file line number	Diff line number	Diff line change
`@@ -29,11 +29,6 @@ func WithByName(name string) global.DBOption {`
`29`	`29`	return g.Where("`name` = ?", name)
`30`	`30`	`}`
`31`	`31`	`}`
`32`		`-func WithoutByName(name string) global.DBOption {`
`33`		`- return func(g gorm.DB) gorm.DB {`
`34`		- return g.Where("`name` != ?", name)
`35`		`- }`
`36`		`-}`
`37`	`32`
`38`	`33`	`func WithByType(ty string) global.DBOption {`
`39`	`34`	`return func(g gorm.DB) gorm.DB {`
`@@ -60,11 +55,6 @@ func WithByNode(node string) global.DBOption {`
`60`	`55`	`return g.Where("node = ?", node)`
`61`	`56`	`}`
`62`	`57`	`}`
`63`		`-func WithByGroupBelong(group string) global.DBOption {`
`64`		`- return func(g gorm.DB) gorm.DB {`
`65`		`- return g.Where("group_belong = ?", group)`
`66`		`- }`
`67`		`-}`
`68`	`58`
`69`	`59`	`func WithOrderBy(orderStr string) global.DBOption {`
`70`	`60`	`if orderStr == "createdAt" {`
Original file line number	Diff line number	Diff line change
`@@ -20,7 +20,6 @@ type IHostRepo interface {`
`20`	`20`	`WithByInfo(info string) global.DBOption`
`21`	`21`	`WithByPort(port uint) global.DBOption`
`22`	`22`	`WithByUser(user string) global.DBOption`
`23`		`- WithByAddr(addr string) global.DBOption`
`24`	`23`	`}`
`25`	`24`
`26`	`25`	`func NewIHostRepo() IHostRepo {`
`@@ -79,11 +78,6 @@ func (h *HostRepo) WithByUser(user string) global.DBOption {`
`79`	`78`	`return g.Where("user = ?", user)`
`80`	`79`	`}`
`81`	`80`	`}`
`82`		`-func (h *HostRepo) WithByAddr(addr string) global.DBOption {`
`83`		`- return func(g gorm.DB) gorm.DB {`
`84`		`- return g.Where("addr = ?", addr)`
`85`		`- }`
`86`		`-}`
`87`	`81`
`88`	`82`	`func (h HostRepo) Create(host model.Host) error {`
`89`	`83`	`return global.DB.Create(host).Error`
Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ func (u *HostService) TestByInfo(req dto.HostConnTest) bool {`
`50`	`50`	`req.PrivateKey = string(privateKey)`
`51`	`51`	`}`
`52`	`52`	`if len(req.Password) == 0 && len(req.PrivateKey) == 0 {`
`53`		`- host, err := hostRepo.Get(hostRepo.WithByAddr(req.Addr), hostRepo.WithByPort(req.Port))`
	`53`	`+ host, err := hostRepo.Get(repo.WithByAddr(req.Addr), hostRepo.WithByPort(req.Port))`
`54`	`54`	`if err != nil {`
`55`	`55`	`return false`
`56`	`56`	`}`
`@@ -235,7 +235,7 @@ func (u HostService) GetHostByID(id uint) (dto.HostInfo, error) {`
`235`	`235`	`}`
`236`	`236`
`237`	`237`	`func (u HostService) Create(req dto.HostOperate) (dto.HostInfo, error) {`
`238`		`- hostItem, _ := hostRepo.Get(hostRepo.WithByAddr(req.Addr), hostRepo.WithByUser(req.User), hostRepo.WithByPort(req.Port))`
	`238`	`+ hostItem, _ := hostRepo.Get(repo.WithByAddr(req.Addr), hostRepo.WithByUser(req.User), hostRepo.WithByPort(req.Port))`
`239`	`239`	`if hostItem.ID != 0 {`
`240`	`240`	`return nil, buserr.New("ErrRecordExist")`
`241`	`241`	`}`