2022-11-14 19:19:42 +08:00
|
|
|
package service
|
|
|
|
|
|
|
|
import (
|
|
|
|
"bufio"
|
|
|
|
"encoding/json"
|
|
|
|
"io/ioutil"
|
|
|
|
"os"
|
2022-11-18 16:14:23 +08:00
|
|
|
"os/exec"
|
2022-11-14 19:19:42 +08:00
|
|
|
"strings"
|
|
|
|
|
|
|
|
"github.com/1Panel-dev/1Panel/backend/app/dto"
|
2022-11-18 16:14:23 +08:00
|
|
|
"github.com/1Panel-dev/1Panel/backend/constant"
|
|
|
|
"github.com/pkg/errors"
|
2022-11-14 19:19:42 +08:00
|
|
|
)
|
|
|
|
|
|
|
|
type DockerService struct{}
|
|
|
|
|
|
|
|
type IDockerService interface {
|
|
|
|
UpdateConf(req dto.DaemonJsonConf) error
|
|
|
|
UpdateConfByFile(info dto.DaemonJsonUpdateByFile) error
|
2022-12-07 17:28:14 +08:00
|
|
|
LoadDockerStatus() string
|
|
|
|
LoadDockerConf() *dto.DaemonJsonConf
|
|
|
|
OperateDocker(req dto.DockerOperation) error
|
2022-11-14 19:19:42 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
func NewIDockerService() IDockerService {
|
|
|
|
return &DockerService{}
|
|
|
|
}
|
|
|
|
|
|
|
|
type daemonJsonItem struct {
|
|
|
|
Status string `json:"status"`
|
|
|
|
Mirrors []string `json:"registry-mirrors"`
|
|
|
|
Registries []string `json:"insecure-registries"`
|
|
|
|
LiveRestore bool `json:"live-restore"`
|
|
|
|
ExecOpts []string `json:"exec-opts"`
|
|
|
|
}
|
|
|
|
|
2022-12-07 17:28:14 +08:00
|
|
|
func (u *DockerService) LoadDockerStatus() string {
|
|
|
|
status := constant.StatusRunning
|
2022-12-18 23:00:24 +08:00
|
|
|
// cmd := exec.Command("systemctl", "is-active", "docker")
|
|
|
|
// stdout, err := cmd.CombinedOutput()
|
|
|
|
// if string(stdout) != "active\n" || err != nil {
|
|
|
|
// status = constant.Stopped
|
|
|
|
// }
|
2022-12-08 11:56:07 +08:00
|
|
|
|
2022-12-07 17:28:14 +08:00
|
|
|
return status
|
|
|
|
}
|
|
|
|
|
|
|
|
func (u *DockerService) LoadDockerConf() *dto.DaemonJsonConf {
|
|
|
|
status := constant.StatusRunning
|
2022-12-08 11:56:07 +08:00
|
|
|
cmd := exec.Command("systemctl", "is-active", "docker")
|
|
|
|
stdout, err := cmd.CombinedOutput()
|
|
|
|
if string(stdout) != "active\n" || err != nil {
|
2022-12-07 17:28:14 +08:00
|
|
|
status = constant.Stopped
|
|
|
|
}
|
|
|
|
fileSetting, err := settingRepo.Get(settingRepo.WithByKey("DaemonJsonPath"))
|
2022-11-14 19:19:42 +08:00
|
|
|
if err != nil {
|
2022-12-07 17:28:14 +08:00
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
|
|
|
}
|
|
|
|
if len(fileSetting.Value) == 0 {
|
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
|
|
|
}
|
|
|
|
if _, err := os.Stat(fileSetting.Value); err != nil {
|
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
|
|
|
}
|
|
|
|
file, err := ioutil.ReadFile(fileSetting.Value)
|
|
|
|
if err != nil {
|
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
2022-11-14 19:19:42 +08:00
|
|
|
}
|
|
|
|
var conf daemonJsonItem
|
|
|
|
deamonMap := make(map[string]interface{})
|
|
|
|
if err := json.Unmarshal(file, &deamonMap); err != nil {
|
2022-12-07 17:28:14 +08:00
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
2022-11-14 19:19:42 +08:00
|
|
|
}
|
|
|
|
arr, err := json.Marshal(deamonMap)
|
|
|
|
if err != nil {
|
2022-12-07 17:28:14 +08:00
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
2022-11-14 19:19:42 +08:00
|
|
|
}
|
|
|
|
if err := json.Unmarshal(arr, &conf); err != nil {
|
2022-12-07 17:28:14 +08:00
|
|
|
return &dto.DaemonJsonConf{Status: status}
|
2022-11-14 19:19:42 +08:00
|
|
|
}
|
|
|
|
driver := "cgroupfs"
|
|
|
|
for _, opt := range conf.ExecOpts {
|
|
|
|
if strings.HasPrefix(opt, "native.cgroupdriver=") {
|
|
|
|
driver = strings.ReplaceAll(opt, "native.cgroupdriver=", "")
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
data := dto.DaemonJsonConf{
|
2022-12-07 17:28:14 +08:00
|
|
|
Status: status,
|
2022-11-14 19:19:42 +08:00
|
|
|
Mirrors: conf.Mirrors,
|
|
|
|
Registries: conf.Registries,
|
|
|
|
LiveRestore: conf.LiveRestore,
|
|
|
|
CgroupDriver: driver,
|
|
|
|
}
|
|
|
|
|
2022-12-07 17:28:14 +08:00
|
|
|
return &data
|
2022-11-14 19:19:42 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
func (u *DockerService) UpdateConf(req dto.DaemonJsonConf) error {
|
2022-12-07 17:28:14 +08:00
|
|
|
fileSetting, err := settingRepo.Get(settingRepo.WithByKey("DaemonJsonPath"))
|
2022-11-14 19:19:42 +08:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2022-12-07 17:28:14 +08:00
|
|
|
if len(fileSetting.Value) == 0 {
|
|
|
|
return errors.New("error daemon.json path in request")
|
|
|
|
}
|
|
|
|
if _, err := os.Stat(fileSetting.Value); err != nil && os.IsNotExist(err) {
|
|
|
|
if err = os.MkdirAll(fileSetting.Value, os.ModePerm); err != nil {
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
file, err := ioutil.ReadFile(fileSetting.Value)
|
|
|
|
if err != nil {
|
2022-11-14 19:19:42 +08:00
|
|
|
return err
|
|
|
|
}
|
2022-12-07 17:28:14 +08:00
|
|
|
deamonMap := make(map[string]interface{})
|
|
|
|
_ = json.Unmarshal(file, &deamonMap)
|
|
|
|
|
2022-12-02 14:10:01 +08:00
|
|
|
if len(req.Registries) == 0 {
|
|
|
|
delete(deamonMap, "insecure-registries")
|
|
|
|
} else {
|
|
|
|
deamonMap["insecure-registries"] = req.Registries
|
|
|
|
}
|
|
|
|
if len(req.Mirrors) == 0 {
|
2022-12-02 15:39:54 +08:00
|
|
|
delete(deamonMap, "registry-mirrors")
|
2022-12-02 14:10:01 +08:00
|
|
|
} else {
|
2022-12-02 15:39:54 +08:00
|
|
|
deamonMap["registry-mirrors"] = req.Mirrors
|
2022-12-02 14:10:01 +08:00
|
|
|
}
|
|
|
|
if !req.LiveRestore {
|
|
|
|
delete(deamonMap, "live-restore")
|
|
|
|
} else {
|
|
|
|
deamonMap["live-restore"] = req.LiveRestore
|
|
|
|
}
|
2022-11-14 19:19:42 +08:00
|
|
|
if opts, ok := deamonMap["exec-opts"]; ok {
|
|
|
|
if optsValue, isArray := opts.([]interface{}); isArray {
|
|
|
|
for i := 0; i < len(optsValue); i++ {
|
|
|
|
if opt, isStr := optsValue[i].(string); isStr {
|
|
|
|
if strings.HasPrefix(opt, "native.cgroupdriver=") {
|
|
|
|
optsValue[i] = "native.cgroupdriver=" + req.CgroupDriver
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if req.CgroupDriver == "systemd" {
|
|
|
|
deamonMap["exec-opts"] = []string{"native.cgroupdriver=systemd"}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
newJson, err := json.MarshalIndent(deamonMap, "", "\t")
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2022-12-07 17:28:14 +08:00
|
|
|
if err := ioutil.WriteFile(fileSetting.Value, newJson, 0640); err != nil {
|
2022-11-14 19:19:42 +08:00
|
|
|
return err
|
|
|
|
}
|
2022-11-18 16:14:23 +08:00
|
|
|
|
|
|
|
cmd := exec.Command("systemctl", "restart", "docker")
|
|
|
|
stdout, err := cmd.CombinedOutput()
|
|
|
|
if err != nil {
|
|
|
|
return errors.New(string(stdout))
|
|
|
|
}
|
2022-11-14 19:19:42 +08:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
func (u *DockerService) UpdateConfByFile(req dto.DaemonJsonUpdateByFile) error {
|
|
|
|
file, err := os.OpenFile(req.Path, os.O_WRONLY|os.O_TRUNC, 0640)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
defer file.Close()
|
|
|
|
write := bufio.NewWriter(file)
|
|
|
|
_, _ = write.WriteString(req.File)
|
|
|
|
write.Flush()
|
|
|
|
|
2022-11-18 16:14:23 +08:00
|
|
|
cmd := exec.Command("systemctl", "restart", "docker")
|
|
|
|
stdout, err := cmd.CombinedOutput()
|
|
|
|
if err != nil {
|
|
|
|
return errors.New(string(stdout))
|
|
|
|
}
|
2022-11-14 19:19:42 +08:00
|
|
|
return nil
|
|
|
|
}
|
2022-12-07 17:28:14 +08:00
|
|
|
|
|
|
|
func (u *DockerService) OperateDocker(req dto.DockerOperation) error {
|
|
|
|
cmd := exec.Command("systemctl", req.Operation, "docker")
|
|
|
|
stdout, err := cmd.CombinedOutput()
|
|
|
|
if err != nil {
|
|
|
|
return errors.New(string(stdout))
|
|
|
|
}
|
|
|
|
return nil
|
|
|
|
}
|