1Panel/backend/app/service/app_install.go

702 lines
19 KiB
Go
Raw Normal View History

2022-11-18 14:27:40 +08:00
package service
import (
"context"
"encoding/json"
2022-11-18 14:27:40 +08:00
"fmt"
2023-03-08 11:04:22 +08:00
"math"
2022-11-18 16:14:23 +08:00
"os"
"path"
2022-11-22 22:47:38 +08:00
"reflect"
2022-11-18 16:14:23 +08:00
"strconv"
"strings"
"github.com/1Panel-dev/1Panel/backend/utils/env"
"github.com/1Panel-dev/1Panel/backend/utils/nginx"
"github.com/joho/godotenv"
2022-12-20 20:30:14 +08:00
"github.com/1Panel-dev/1Panel/backend/app/dto/request"
"github.com/1Panel-dev/1Panel/backend/app/dto/response"
2023-03-07 18:20:52 +08:00
"github.com/1Panel-dev/1Panel/backend/buserr"
2022-12-20 20:30:14 +08:00
2022-11-29 17:39:10 +08:00
"github.com/1Panel-dev/1Panel/backend/app/repo"
2022-11-18 14:27:40 +08:00
"github.com/1Panel-dev/1Panel/backend/app/dto"
"github.com/1Panel-dev/1Panel/backend/app/model"
"github.com/1Panel-dev/1Panel/backend/constant"
"github.com/1Panel-dev/1Panel/backend/global"
"github.com/1Panel-dev/1Panel/backend/utils/common"
"github.com/1Panel-dev/1Panel/backend/utils/compose"
"github.com/1Panel-dev/1Panel/backend/utils/docker"
"github.com/pkg/errors"
)
type AppInstallService struct {
}
type IAppInstallService interface {
Page(req request.AppInstalledSearch) (int64, []response.AppInstalledDTO, error)
CheckExist(key string) (*response.AppInstalledCheck, error)
LoadPort(key string) (int64, error)
LoadConnInfo(key string) (response.DatabaseConn, error)
SearchForWebsite(req request.AppInstalledSearch) ([]response.AppInstalledDTO, error)
Operate(req request.AppInstalledOperate) error
Update(req request.AppInstalledUpdate) error
SyncAll(systemInit bool) error
GetServices(key string) ([]response.AppService, error)
GetUpdateVersions(installId uint) ([]dto.AppVersion, error)
GetParams(id uint) ([]response.AppParam, error)
ChangeAppPort(req request.PortUpdate) error
GetDefaultConfigByKey(key string) (string, error)
DeleteCheck(installId uint) ([]dto.AppResource, error)
}
func NewIAppInstalledService() IAppInstallService {
return &AppInstallService{}
}
func (a *AppInstallService) Page(req request.AppInstalledSearch) (int64, []response.AppInstalledDTO, error) {
2022-11-28 13:50:53 +08:00
var opts []repo.DBOption
if req.Name != "" {
opts = append(opts, commonRepo.WithLikeName(req.Name))
}
2023-01-16 15:30:24 +08:00
if len(req.Tags) != 0 {
tags, err := tagRepo.GetByKeys(req.Tags)
if err != nil {
return 0, nil, err
}
var tagIds []uint
for _, t := range tags {
tagIds = append(tagIds, t.ID)
}
appTags, err := appTagRepo.GetByTagIds(tagIds)
if err != nil {
return 0, nil, err
}
var appIds []uint
for _, t := range appTags {
appIds = append(appIds, t.AppId)
}
opts = append(opts, appInstallRepo.WithAppIdsIn(appIds))
}
2022-11-28 13:50:53 +08:00
total, installs, err := appInstallRepo.Page(req.Page, req.PageSize, opts...)
2022-11-18 14:27:40 +08:00
if err != nil {
return 0, nil, err
}
2022-11-22 14:22:25 +08:00
2023-01-16 15:30:24 +08:00
installDTOs, err := handleInstalled(installs, req.Update)
2022-11-22 14:22:25 +08:00
if err != nil {
return 0, nil, err
2022-11-18 14:27:40 +08:00
}
return total, installDTOs, nil
}
func (a *AppInstallService) CheckExist(key string) (*response.AppInstalledCheck, error) {
2022-12-14 15:08:21 +08:00
res := &response.AppInstalledCheck{
2022-11-22 22:47:38 +08:00
IsExist: false,
}
2022-11-18 16:14:23 +08:00
app, err := appRepo.GetFirst(appRepo.WithKey(key))
if err != nil {
2022-11-22 22:47:38 +08:00
return res, nil
2022-11-18 16:14:23 +08:00
}
res.App = app.Name
2022-11-18 16:14:23 +08:00
appInstall, _ := appInstallRepo.GetFirst(appInstallRepo.WithAppId(app.ID))
2022-11-22 22:47:38 +08:00
if reflect.DeepEqual(appInstall, model.AppInstall{}) {
return res, nil
}
2022-12-04 17:45:54 +08:00
if err := syncById(appInstall.ID); err != nil {
return nil, err
}
appInstall, _ = appInstallRepo.GetFirst(commonRepo.WithByID(appInstall.ID))
2022-12-04 17:45:54 +08:00
2022-11-23 16:59:06 +08:00
res.ContainerName = appInstall.ContainerName
2022-11-22 22:47:38 +08:00
res.Name = appInstall.Name
res.Version = appInstall.Version
res.CreatedAt = appInstall.CreatedAt
res.Status = appInstall.Status
res.AppInstallID = appInstall.ID
res.IsExist = true
2022-12-22 10:39:26 +08:00
res.InstallPath = path.Join(constant.AppInstallDir, app.Key, appInstall.Name)
2022-11-22 22:47:38 +08:00
return res, nil
2022-11-18 16:14:23 +08:00
}
func (a *AppInstallService) LoadPort(key string) (int64, error) {
app, err := appInstallRepo.LoadBaseInfo(key, "")
if err != nil {
return int64(0), nil
}
return app.Port, nil
}
func (a *AppInstallService) LoadConnInfo(key string) (response.DatabaseConn, error) {
var data response.DatabaseConn
app, err := appInstallRepo.LoadBaseInfo(key, "")
2022-12-20 20:30:14 +08:00
if err != nil {
return data, nil
2022-12-20 20:30:14 +08:00
}
data.Password = app.Password
data.ServiceName = app.ServiceName
data.Port = app.Port
return data, nil
2022-12-20 20:30:14 +08:00
}
func (a *AppInstallService) SearchForWebsite(req request.AppInstalledSearch) ([]response.AppInstalledDTO, error) {
2023-01-16 15:30:24 +08:00
var (
installs []model.AppInstall
err error
opts []repo.DBOption
)
2022-11-18 14:27:40 +08:00
if req.Type != "" {
apps, err := appRepo.GetBy(appRepo.WithType(req.Type))
if err != nil {
return nil, err
}
var ids []uint
for _, app := range apps {
ids = append(ids, app.ID)
}
2023-01-16 15:30:24 +08:00
if req.Unused {
opts = append(opts, appInstallRepo.WithIdNotInWebsite())
}
opts = append(opts, appInstallRepo.WithAppIdsIn(ids))
2023-02-07 16:29:54 +08:00
installs, err = appInstallRepo.ListBy(opts...)
2022-11-18 14:27:40 +08:00
if err != nil {
return nil, err
}
} else {
2023-02-07 16:29:54 +08:00
installs, err = appInstallRepo.ListBy()
2022-11-18 14:27:40 +08:00
if err != nil {
return nil, err
}
}
2023-01-16 15:30:24 +08:00
return handleInstalled(installs, false)
2022-11-18 14:27:40 +08:00
}
func (a *AppInstallService) Operate(req request.AppInstalledOperate) error {
install, err := appInstallRepo.GetFirstByCtx(context.Background(), commonRepo.WithByID(req.InstallId))
2022-11-18 14:27:40 +08:00
if err != nil {
return err
}
dockerComposePath := install.GetComposePath()
switch req.Operate {
2023-03-01 11:51:49 +08:00
case constant.Rebuild:
2023-03-08 11:04:22 +08:00
return rebuildApp(install)
2023-03-01 11:51:49 +08:00
case constant.Start:
out, err := compose.Start(dockerComposePath)
2022-11-18 14:27:40 +08:00
if err != nil {
return handleErr(install, err, out)
}
return syncById(install.ID)
2023-03-01 11:51:49 +08:00
case constant.Stop:
2022-12-06 15:59:25 +08:00
out, err := compose.Stop(dockerComposePath)
2022-11-18 14:27:40 +08:00
if err != nil {
return handleErr(install, err, out)
}
return syncById(install.ID)
2022-12-14 15:08:21 +08:00
case constant.Restart:
2022-11-18 14:27:40 +08:00
out, err := compose.Restart(dockerComposePath)
if err != nil {
return handleErr(install, err, out)
}
return syncById(install.ID)
2022-12-14 15:08:21 +08:00
case constant.Delete:
if err := deleteAppInstall(install, req.DeleteBackup, req.ForceDelete, req.DeleteDB); err != nil && !req.ForceDelete {
2022-11-18 14:27:40 +08:00
return err
}
return nil
2022-12-14 15:08:21 +08:00
case constant.Sync:
2022-11-18 14:27:40 +08:00
return syncById(install.ID)
2023-03-08 11:04:22 +08:00
case constant.Upgrade:
return upgradeInstall(install.ID, req.DetailId)
2022-11-18 14:27:40 +08:00
default:
return errors.New("operate not support")
}
}
func (a *AppInstallService) Update(req request.AppInstalledUpdate) error {
2023-03-08 11:04:22 +08:00
installed, err := appInstallRepo.GetFirst(commonRepo.WithByID(req.InstallId))
if err != nil {
return err
}
changePort := false
var (
oldPorts []int
newPorts []int
)
2023-03-08 11:04:22 +08:00
port, ok := req.Params["PANEL_APP_PORT_HTTP"]
if ok {
portN := int(math.Ceil(port.(float64)))
if portN != installed.HttpPort {
oldPorts = append(oldPorts, installed.HttpPort)
changePort = true
2023-03-08 11:04:22 +08:00
httpPort, err := checkPort("PANEL_APP_PORT_HTTP", req.Params)
if err != nil {
return err
}
installed.HttpPort = httpPort
newPorts = append(newPorts, httpPort)
2023-03-08 11:04:22 +08:00
}
}
ports, ok := req.Params["PANEL_APP_PORT_HTTPS"]
if ok {
portN := int(math.Ceil(ports.(float64)))
if portN != installed.HttpsPort {
oldPorts = append(oldPorts, installed.HttpsPort)
2023-03-08 11:04:22 +08:00
httpsPort, err := checkPort("PANEL_APP_PORT_HTTPS", req.Params)
if err != nil {
return err
}
installed.HttpsPort = httpsPort
newPorts = append(newPorts, httpsPort)
2023-03-08 11:04:22 +08:00
}
}
envPath := path.Join(installed.GetPath(), ".env")
oldEnvMaps, err := godotenv.Read(envPath)
if err != nil {
return err
}
handleMap(req.Params, oldEnvMaps)
paramByte, err := json.Marshal(oldEnvMaps)
if err != nil {
return err
}
installed.Env = string(paramByte)
if err := env.Write(oldEnvMaps, envPath); err != nil {
2023-03-08 11:04:22 +08:00
return err
}
_ = appInstallRepo.Save(context.Background(), &installed)
if err := rebuildApp(installed); err != nil {
return err
}
website, _ := websiteRepo.GetFirst(websiteRepo.WithAppInstallId(installed.ID))
if changePort && website.ID != 0 && website.Status == constant.Running {
nginxInstall, err := getNginxFull(&website)
if err != nil {
return buserr.WithErr(constant.ErrUpdateBuWebsite, err)
}
config := nginxInstall.SiteConfig.Config
servers := config.FindServers()
if len(servers) == 0 {
return buserr.WithErr(constant.ErrUpdateBuWebsite, errors.New("nginx config is not valid"))
}
server := servers[0]
proxy := fmt.Sprintf("http://127.0.0.1:%d", installed.HttpPort)
server.UpdateRootProxy([]string{proxy})
if err := nginx.WriteConfig(config, nginx.IndentedStyle); err != nil {
return buserr.WithErr(constant.ErrUpdateBuWebsite, err)
}
if err := nginxCheckAndReload(nginxInstall.SiteConfig.OldContent, config.FilePath, nginxInstall.Install.ContainerName); err != nil {
return buserr.WithErr(constant.ErrUpdateBuWebsite, err)
}
}
if changePort {
go func() {
_ = OperateFirewallPort(oldPorts, newPorts)
}()
}
return nil
2023-03-08 11:04:22 +08:00
}
func (a *AppInstallService) SyncAll(systemInit bool) error {
2023-02-07 16:29:54 +08:00
allList, err := appInstallRepo.ListBy()
2022-11-18 14:27:40 +08:00
if err != nil {
return err
}
2023-03-14 14:03:51 +08:00
for _, i := range allList {
if i.Status == constant.Installing {
if systemInit {
i.Status = constant.Error
i.Message = "System restart causes application exception"
_ = appInstallRepo.Save(context.Background(), &i)
}
2023-03-14 14:03:51 +08:00
continue
2022-11-18 14:27:40 +08:00
}
2023-03-14 14:03:51 +08:00
if err := syncById(i.ID); err != nil {
global.LOG.Errorf("sync install app[%s] error,mgs: %s", i.Name, err.Error())
}
}
2022-11-18 14:27:40 +08:00
return nil
}
func (a *AppInstallService) GetServices(key string) ([]response.AppService, error) {
2022-11-18 14:27:40 +08:00
app, err := appRepo.GetFirst(appRepo.WithKey(key))
if err != nil {
return nil, err
}
2023-02-07 16:29:54 +08:00
installs, err := appInstallRepo.ListBy(appInstallRepo.WithAppId(app.ID), appInstallRepo.WithStatus(constant.Running))
2022-11-18 14:27:40 +08:00
if err != nil {
return nil, err
}
2022-12-14 15:08:21 +08:00
var res []response.AppService
2022-11-18 14:27:40 +08:00
for _, install := range installs {
paramMap := make(map[string]string)
if install.Param != "" {
_ = json.Unmarshal([]byte(install.Param), &paramMap)
}
2022-12-14 15:08:21 +08:00
res = append(res, response.AppService{
Label: install.Name,
Value: install.ServiceName,
Config: paramMap,
2022-11-18 14:27:40 +08:00
})
}
return res, nil
}
func (a *AppInstallService) GetUpdateVersions(installId uint) ([]dto.AppVersion, error) {
2022-11-18 14:27:40 +08:00
install, err := appInstallRepo.GetFirst(commonRepo.WithByID(installId))
var versions []dto.AppVersion
if err != nil {
return versions, err
}
app, err := appRepo.GetFirst(commonRepo.WithByID(install.AppId))
if err != nil {
return versions, err
}
details, err := appDetailRepo.GetBy(appDetailRepo.WithAppId(app.ID))
if err != nil {
return versions, err
}
for _, detail := range details {
if common.CompareVersion(detail.Version, install.Version) {
versions = append(versions, dto.AppVersion{
Version: detail.Version,
DetailId: detail.ID,
})
}
}
return versions, nil
}
func (a *AppInstallService) ChangeAppPort(req request.PortUpdate) error {
2023-03-07 18:20:52 +08:00
if common.ScanPort(int(req.Port)) {
return buserr.WithDetail(constant.ErrPortInUsed, req.Port, nil)
}
appInstall, err := appInstallRepo.LoadBaseInfo(req.Key, req.Name)
if err != nil {
return nil
}
if err := updateInstallInfoInDB(req.Key, "", "port", true, strconv.FormatInt(req.Port, 10)); err != nil {
return nil
}
appRess, _ := appInstallResourceRepo.GetBy(appInstallResourceRepo.WithLinkId(appInstall.ID))
for _, appRes := range appRess {
appInstall, err := appInstallRepo.GetFirst(commonRepo.WithByID(appRes.AppInstallId))
if err != nil {
return err
}
if _, err := compose.Restart(fmt.Sprintf("%s/%s/%s/docker-compose.yml", constant.AppInstallDir, appInstall.App.Key, appInstall.Name)); err != nil {
global.LOG.Errorf("docker-compose restart %s[%s] failed, err: %v", appInstall.App.Key, appInstall.Name, err)
}
}
2023-04-01 00:51:25 +08:00
if err := OperateFirewallPort([]int{int(appInstall.Port)}, []int{int(req.Port)}); err != nil {
global.LOG.Errorf("allow firewall failed, err: %v", err)
}
return nil
2022-11-18 14:27:40 +08:00
}
func (a *AppInstallService) DeleteCheck(installId uint) ([]dto.AppResource, error) {
2022-12-01 19:25:02 +08:00
var res []dto.AppResource
appInstall, err := appInstallRepo.GetFirst(commonRepo.WithByID(installId))
if err != nil {
return nil, err
}
app, err := appRepo.GetFirst(commonRepo.WithByID(appInstall.AppId))
if err != nil {
return nil, err
}
2023-04-06 16:38:16 +08:00
websites, _ := websiteRepo.GetBy(websiteRepo.WithAppInstallId(appInstall.ID))
for _, website := range websites {
res = append(res, dto.AppResource{
Type: "website",
Name: website.PrimaryDomain,
})
2022-12-01 19:25:02 +08:00
}
if app.Key == constant.AppOpenresty {
2022-12-01 19:25:02 +08:00
websites, _ := websiteRepo.GetBy()
for _, website := range websites {
res = append(res, dto.AppResource{
Type: "website",
Name: website.PrimaryDomain,
})
}
}
if app.Type == "runtime" {
resources, _ := appInstallResourceRepo.GetBy(appInstallResourceRepo.WithLinkId(appInstall.ID))
for _, resource := range resources {
linkInstall, _ := appInstallRepo.GetFirst(commonRepo.WithByID(resource.AppInstallId))
res = append(res, dto.AppResource{
Type: "app",
Name: linkInstall.Name,
})
}
}
return res, nil
}
func (a *AppInstallService) GetDefaultConfigByKey(key string) (string, error) {
2022-12-09 17:16:07 +08:00
appInstall, err := getAppInstallByKey(key)
if err != nil {
return "", err
}
filePath := path.Join(constant.AppResourceDir, appInstall.App.Key, "versions", appInstall.Version, "conf")
2022-12-13 20:03:54 +08:00
if key == constant.AppMysql {
2022-12-09 17:16:07 +08:00
filePath = path.Join(filePath, "my.cnf")
}
2022-12-13 20:03:54 +08:00
if key == constant.AppRedis {
2022-12-09 17:16:07 +08:00
filePath = path.Join(filePath, "redis.conf")
}
if key == constant.AppOpenresty {
2022-12-09 17:16:07 +08:00
filePath = path.Join(filePath, "nginx.conf")
}
contentByte, err := os.ReadFile(filePath)
if err != nil {
return "", err
}
return string(contentByte), nil
}
func (a *AppInstallService) GetParams(id uint) ([]response.AppParam, error) {
var (
res []response.AppParam
appForm dto.AppForm
envs = make(map[string]interface{})
)
install, err := appInstallRepo.GetFirst(commonRepo.WithByID(id))
if err != nil {
return nil, err
}
detail, err := appDetailRepo.GetFirst(commonRepo.WithByID(install.AppDetailId))
if err != nil {
return nil, err
}
if err := json.Unmarshal([]byte(detail.Params), &appForm); err != nil {
return nil, err
}
if err := json.Unmarshal([]byte(install.Env), &envs); err != nil {
return nil, err
}
for _, form := range appForm.FormFields {
if v, ok := envs[form.EnvKey]; ok {
2023-03-08 11:04:22 +08:00
appParam := response.AppParam{
Edit: false,
Key: form.EnvKey,
Rule: form.Rule,
Type: form.Type,
}
if form.Edit {
appParam.Edit = true
}
appParam.LabelZh = form.LabelZh
appParam.LabelEn = form.LabelEn
appParam.Value = v
if form.Type == "service" {
appInstall, _ := appInstallRepo.GetFirst(appInstallRepo.WithServiceName(v.(string)))
appParam.ShowValue = appInstall.Name
} else if form.Type == "select" {
for _, fv := range form.Values {
if fv.Value == v {
appParam.ShowValue = fv.Label
break
}
}
appParam.Values = form.Values
}
res = append(res, appParam)
}
}
return res, nil
}
2022-11-18 14:27:40 +08:00
func syncById(installId uint) error {
appInstall, err := appInstallRepo.GetFirst(commonRepo.WithByID(installId))
if err != nil {
return err
}
if appInstall.Status == constant.Installing {
return nil
}
2022-11-18 14:27:40 +08:00
containerNames, err := getContainerNames(appInstall)
if err != nil {
return err
}
cli, err := docker.NewClient()
if err != nil {
return err
}
containers, err := cli.ListContainersByName(containerNames)
if err != nil {
return err
}
var (
errorContainers []string
notFoundContainers []string
runningContainers []string
exitedContainers []string
2022-11-18 14:27:40 +08:00
)
for _, n := range containers {
switch n.State {
case "exited":
exitedContainers = append(exitedContainers, n.Names[0])
case "running":
2022-11-18 14:27:40 +08:00
runningContainers = append(runningContainers, n.Names[0])
default:
errorContainers = append(errorContainers, n.Names[0])
2022-11-18 14:27:40 +08:00
}
}
for _, old := range containerNames {
exist := false
for _, new := range containers {
if common.ExistWithStrArray(old, new.Names) {
exist = true
break
}
}
if !exist {
notFoundContainers = append(notFoundContainers, old)
}
}
containerCount := len(containers)
errCount := len(errorContainers)
notFoundCount := len(notFoundContainers)
existedCount := len(exitedContainers)
2022-11-18 14:27:40 +08:00
normalCount := len(containerNames)
runningCount := len(runningContainers)
if containerCount == 0 {
appInstall.Status = constant.Error
appInstall.Message = "container is not found"
return appInstallRepo.Save(context.Background(), &appInstall)
2022-11-18 14:27:40 +08:00
}
if errCount == 0 && existedCount == 0 {
2022-11-18 14:27:40 +08:00
appInstall.Status = constant.Running
return appInstallRepo.Save(context.Background(), &appInstall)
2022-11-18 14:27:40 +08:00
}
if existedCount == normalCount {
appInstall.Status = constant.Stopped
return appInstallRepo.Save(context.Background(), &appInstall)
}
2022-11-18 14:27:40 +08:00
if errCount == normalCount {
appInstall.Status = constant.Error
}
if runningCount < normalCount {
appInstall.Status = constant.UnHealthy
}
var errMsg strings.Builder
if errCount > 0 {
errMsg.Write([]byte(string(rune(errCount)) + " error containers:"))
for _, e := range errorContainers {
errMsg.Write([]byte(e))
}
errMsg.Write([]byte("\n"))
}
if notFoundCount > 0 {
errMsg.Write([]byte(string(rune(notFoundCount)) + " not found containers:"))
for _, e := range notFoundContainers {
errMsg.Write([]byte(e))
}
errMsg.Write([]byte("\n"))
}
appInstall.Message = errMsg.String()
return appInstallRepo.Save(context.Background(), &appInstall)
2022-11-18 14:27:40 +08:00
}
2022-12-08 16:00:59 +08:00
func updateInstallInfoInDB(appKey, appName, param string, isRestart bool, value interface{}) error {
if param != "password" && param != "port" && param != "user-password" {
return nil
2022-12-08 16:00:59 +08:00
}
appInstall, err := appInstallRepo.LoadBaseInfo(appKey, appName)
2022-12-12 14:06:39 +08:00
if err != nil {
return nil
2022-12-08 16:00:59 +08:00
}
2022-12-12 17:17:39 +08:00
envPath := fmt.Sprintf("%s/%s/%s/.env", constant.AppInstallDir, appKey, appInstall.Name)
lineBytes, err := os.ReadFile(envPath)
2022-12-12 17:17:39 +08:00
if err != nil {
return err
2022-12-12 17:17:39 +08:00
}
envKey := ""
switch param {
case "password":
envKey = "PANEL_DB_ROOT_PASSWORD="
case "port":
2022-12-12 17:17:39 +08:00
envKey = "PANEL_APP_PORT_HTTP="
case "user-password":
envKey = "PANEL_DB_USER_PASSWORD="
2022-12-12 17:17:39 +08:00
}
files := strings.Split(string(lineBytes), "\n")
var newFiles []string
for _, line := range files {
if strings.HasPrefix(line, envKey) {
newFiles = append(newFiles, fmt.Sprintf("%s%v", envKey, value))
} else {
newFiles = append(newFiles, line)
}
}
file, err := os.OpenFile(envPath, os.O_WRONLY|os.O_TRUNC, 0666)
if err != nil {
return err
2022-12-12 17:17:39 +08:00
}
defer file.Close()
_, err = file.WriteString(strings.Join(newFiles, "\n"))
if err != nil {
return err
2022-12-12 17:17:39 +08:00
}
2022-12-08 16:00:59 +08:00
oldVal, newVal := "", ""
if param == "password" {
oldVal = fmt.Sprintf("\"PANEL_DB_ROOT_PASSWORD\":\"%v\"", appInstall.Password)
newVal = fmt.Sprintf("\"PANEL_DB_ROOT_PASSWORD\":\"%v\"", value)
2022-12-12 14:06:39 +08:00
_ = appInstallRepo.BatchUpdateBy(map[string]interface{}{
"param": strings.ReplaceAll(appInstall.Param, oldVal, newVal),
"env": strings.ReplaceAll(appInstall.Env, oldVal, newVal),
}, commonRepo.WithByID(appInstall.ID))
2022-12-26 16:15:42 +08:00
}
if param == "user-password" {
oldVal = fmt.Sprintf("\"PANEL_DB_USER_PASSWORD\":\"%v\"", appInstall.UserPassword)
2022-12-26 16:15:42 +08:00
newVal = fmt.Sprintf("\"PANEL_DB_USER_PASSWORD\":\"%v\"", value)
_ = appInstallRepo.BatchUpdateBy(map[string]interface{}{
"param": strings.ReplaceAll(appInstall.Param, oldVal, newVal),
"env": strings.ReplaceAll(appInstall.Env, oldVal, newVal),
}, commonRepo.WithByID(appInstall.ID))
2022-12-08 16:00:59 +08:00
}
if param == "port" {
oldVal = fmt.Sprintf("\"PANEL_APP_PORT_HTTP\":%v", appInstall.Port)
newVal = fmt.Sprintf("\"PANEL_APP_PORT_HTTP\":%v", value)
2022-12-12 14:06:39 +08:00
_ = appInstallRepo.BatchUpdateBy(map[string]interface{}{
"param": strings.ReplaceAll(appInstall.Param, oldVal, newVal),
"env": strings.ReplaceAll(appInstall.Env, oldVal, newVal),
"http_port": value,
}, commonRepo.WithByID(appInstall.ID))
2022-12-08 16:00:59 +08:00
}
ComposeFile := fmt.Sprintf("%s/%s/%s/docker-compose.yml", constant.AppInstallDir, appKey, appInstall.Name)
stdout, err := compose.Down(ComposeFile)
if err != nil {
return errors.New(stdout)
}
stdout, err = compose.Up(ComposeFile)
if err != nil {
return errors.New(stdout)
}
return nil
2022-12-08 16:00:59 +08:00
}