微调

README.md

@@ -1,23 +1,40 @@
 # autodop
-autodop 是一个 DevOps 自动化系统。
+autodop 是一个 DevOps 自动化系统，分为 dmaster 和 dagent 两个应用。
 
 DevOps 自动化：
 - 构建部署
 - 运行监控
 - 备份还原
 
-autodop 模块：
+## autodop-dmaster
+autodop-dmaster 功能模块
+- 主机集群
+> 管理已部署 dagent 应用的主机(物理主机和虚拟主机)
+- 虚拟主机
+> 管理物理主机上的虚拟主机
 - 应用
 > 自主开发需要构建部署的程序
 - 第三方应用
 > 类似 MySQL 之类提供服务的程序
-- 主机
-> 已部署 dagent 应用的主机(物理主机和虚拟主机)
-- 虚拟主机
-> 物理主机上的虚拟主机管理
-- 系统
-> autodop 系统管理
+- 系统管理
+> 管理 autodop 系统
+
+### 主机集群
+- 主机管理
+
+### 虚拟主机
+- 虚拟主机管理
+
+### 应用
+- 构建部署
+
+### 第三方应用
+- 备份还原
+
+### 系统管理
 
-## 第三方应用
-- 添加第三方应用
-> 添加备份还原配置
+## autodop-dagent
+autodop-dagent 功能模块
+- 系统监控
+- 应用部署
+- 执行脚本

dagent/src/main/java/cn/reghao/autodop/dagent/node/agent/DagentNotifier.java

@@ -6,7 +6,7 @@ import cn.reghao.autodop.common.mq.MsgType;
 import cn.reghao.autodop.common.utils.HostAddress;
 import cn.reghao.autodop.common.utils.NetworkUtil;
 import cn.reghao.autodop.common.utils.text.TextFile;
-import cn.reghao.autodop.dagent.config.DmasterProperties;
+import cn.reghao.autodop.dagent.utils.config.DmasterProperties;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 

dagent/src/main/java/cn/reghao/autodop/dagent/config/DmasterProperties.java → dagent/src/main/java/cn/reghao/autodop/dagent/utils/config/DmasterProperties.java

@@ -1,4 +1,4 @@
-package cn.reghao.autodop.dagent.config;
+package cn.reghao.autodop.dagent.utils.config;
 
 import lombok.Data;
 import org.springframework.beans.factory.annotation.Value;

dagent/src/main/java/cn/reghao/autodop/dagent/mq/RabbitConfig.java → dagent/src/main/java/cn/reghao/autodop/dagent/utils/mq/RabbitConfig.java

@@ -1,4 +1,4 @@
-package cn.reghao.autodop.dagent.mq;
+package cn.reghao.autodop.dagent.utils.mq;
 
 import cn.reghao.autodop.common.utils.NetworkUtil;
 import org.springframework.amqp.core.Queue;

dagent/src/main/java/cn/reghao/autodop/dagent/mq/RemoteCallDispatcher.java → dagent/src/main/java/cn/reghao/autodop/dagent/utils/mq/RemoteCallDispatcher.java

@@ -1,7 +1,7 @@
-package cn.reghao.autodop.dagent.mq;
+package cn.reghao.autodop.dagent.utils.mq;
 
 import cn.reghao.autodop.common.deploy.DeployConfig;
-import cn.reghao.autodop.common.mq.*;
+import cn.reghao.autodop.common.mq.MsgType;
 import cn.reghao.autodop.common.result.RpcResult;
 import cn.reghao.autodop.dagent.app.deploy.AppDeployService;
 import com.google.gson.Gson;

dmaster/src/main/java/cn/reghao/autodop/dmaster/app/service/build/tools/updater/GitImpl.java

@@ -107,17 +107,26 @@ public class GitImpl implements CodeUpdater {
     }
 
     private CommitLog clone(String remote, String branch, String local) throws Exception {
-        CloneCommand gitClone = Git.cloneRepository()
-                .setURI(remote)
-                .setBranch(branch)
-                .setDirectory(new File(local))
-                .setTransportConfigCallback(new TransportConfigCallback() {
-                    @Override
-                    public void configure(Transport transport) {
-                        SshTransport sshTransport = (SshTransport) transport;
-                        sshTransport.setSshSessionFactory(sshSessionFactory);
-                    }
-                });
+        CloneCommand gitClone;
+        if (sshSessionFactory != null) {
+            gitClone = Git.cloneRepository()
+                    .setURI(remote)
+                    .setBranch(branch)
+                    .setDirectory(new File(local))
+                    .setTransportConfigCallback(new TransportConfigCallback() {
+                        @Override
+                        public void configure(Transport transport) {
+                            SshTransport sshTransport = (SshTransport) transport;
+                            sshTransport.setSshSessionFactory(sshSessionFactory);
+                        }
+                    });
+        } else {
+            gitClone = Git.cloneRepository()
+                    .setURI(remote)
+                    .setBranch(branch)
+                    .setDirectory(new File(local))
+                    .setCredentialsProvider(credentials);
+        }
 
         try (Git git = gitClone.call()) {
             Repository repo = git.getRepository();

dmaster/src/main/java/cn/reghao/autodop/dmaster/host/agent/AgentStatus.java → dmaster/src/main/java/cn/reghao/autodop/dmaster/cluster/agent/AgentStatus.java

@@ -1,4 +1,4 @@
-package cn.reghao.autodop.dmaster.host.agent;
+package cn.reghao.autodop.dmaster.cluster.agent;
 
 /**
  * @author reghao

dmaster/src/main/java/cn/reghao/autodop/dmaster/host/controller/NodeController.java → dmaster/src/main/java/cn/reghao/autodop/dmaster/cluster/controller/NodeController.java

@@ -1,4 +1,4 @@
-package cn.reghao.autodop.dmaster.host.controller;
+package cn.reghao.autodop.dmaster.cluster.controller;
 
 import cn.reghao.autodop.common.result.WebResult;
 import io.swagger.annotations.Api;

dmaster/src/main/java/cn/reghao/autodop/dmaster/host/service/NodeService.java → dmaster/src/main/java/cn/reghao/autodop/dmaster/cluster/service/NodeService.java

@@ -1,4 +1,4 @@
-package cn.reghao.autodop.dmaster.host.service;
+package cn.reghao.autodop.dmaster.cluster.service;
 
 import org.springframework.stereotype.Service;