[Update] 修改url

.gitignore

@@ -16,4 +16,7 @@ log/
 vendor/
 config.yml
 host_key
-cmd/coco
+cmd/koko
+cmd/logs
+cmd/kokodir
+build

pkg/handler/session.go

@@ -101,7 +101,7 @@ func (h *interactiveHandler) loadAssetsFromCache() {
 		go h.firstLoadAssetAndNodes()
 	} else {
 		h.assets = make([]model.Asset, 0)
-		h.firstLoadAssetAndNodes()
+		go h.firstLoadAssetAndNodes()
 	}
 }
 
@@ -159,7 +159,7 @@ func (h *interactiveHandler) Dispatch(ctx cctx.Context) {
 
 		if err != nil {
 			if err != io.EOF {
-				logger.Debug("user disconnected")
+				logger.Debug("User disconnected")
 			} else {
 				logger.Error("Read from user err: ", err)
 			}

pkg/service/assets.go

@@ -57,7 +57,7 @@ func GetSystemUserFilterRules(systemUserID string) (rules []model.SystemUserFilt
 	        "filter": "de7693ca-75d5-4639-986b-44ed390260a0"
 	    }
 	]`*/
-	Url := fmt.Sprintf(SystemUserCmdFilterRules, systemUserID)
+	Url := fmt.Sprintf(SystemUserCmdFilterRulesListURL, systemUserID)
 
 	err = authClient.Get(Url, &rules)
 	if err != nil {
@@ -94,7 +94,7 @@ func GetDomainWithGateway(gID string) (domain model.Domain) {
 }
 
 func GetTokenAsset(token string) (tokenUser model.TokenUser) {
-	Url := fmt.Sprintf(TokenAssetUrl, token)
+	Url := fmt.Sprintf(TokenAssetURL, token)
 	err := authClient.Get(Url, &tokenUser)
 	if err != nil {
 		logger.Error("Get Token Asset info failed: ", err)

pkg/service/terminal.go

@@ -102,7 +102,7 @@ func PushSessionCommand(commands []*model.Command) (err error) {
 }
 
 func PushFTPLog(data *model.FTPLog) (err error) {
-	err = authClient.Post(FTPLogList, data, nil)
+	err = authClient.Post(FTPLogListURL, data, nil)
 	if err != nil {
 		logger.Error(err)
 	}

pkg/service/urls.go

@@ -3,13 +3,13 @@ package service
 const (
 	UserAuthURL    = "/api/authentication/v1/auth/"                      // post 验证用户登陆
 	UserProfileURL = "/api/users/v1/profile/"                            // 获取当前用户的基本信息
-	UserListUrl    = "/api/users/v1/users/"                              // 用户列表地址
+	UserListURL    = "/api/users/v1/users/"                              // 用户列表地址
 	UserDetailURL  = "/api/users/v1/users/%s/"                           // 获取用户信息
 	UserAuthOTPURL = "/api/authentication/v1/otp/auth/"                  // 验证OTP
-	TokenAssetUrl  = "/api/authentication/v1/connection-token/?token=%s" // Token name
+	TokenAssetURL  = "/api/authentication/v1/connection-token/?token=%s" // Token name
 
 	SystemUserAssetAuthURL          = "/api/assets/v1/system-user/%s/asset/%s/auth-info/" // 该系统用户对某资产的授权
-	SystemUserCmdFilterRules = "/api/assets/v1/system-user/%s/cmd-filter-rules/"   // 过滤规则url
+	SystemUserCmdFilterRulesListURL = "/api/assets/v1/system-user/%s/cmd-filter-rules/"   // 过滤规则url
 	SystemUserDetailURL             = "/api/assets/v1/system-user/%s/"                    // 某个系统用户的信息
 	AssetDetailURL                  = "/api/assets/v1/assets/%s/"                         // 某一个资产信息
 	DomainDetailURL                 = "/api/assets/v1/domain/%s/?gateway=1"
@@ -22,11 +22,11 @@ const (
 	SessionDetailURL  = "/api/terminal/v1/sessions/%s/"        // finish session的时候发送
 	SessionReplayURL  = "/api/terminal/v1/sessions/%s/replay/" //上传录像
 	SessionCommandURL = "/api/terminal/v1/command/"            //上传批量命令
-	FTPLogList        = "/api/audits/v1/ftp-log/"              // 上传 ftp日志
-
 	FinishTaskURL     = "/api/terminal/v1/tasks/%s/"
 
-	UserAssetsURL                  = "/api/perms/v1/user/%s/assets/"                 //获取用户授权的所有资产
-	UserNodesAssetsURL             = "/api/perms/v1/user/%s/nodes-assets/"           // 获取用户授权的所有节点信息 节点分组
-	ValidateUserAssetPermissionURL = "/api/perms/v1/asset-permission/user/validate/" //0不使用缓存 1 使用缓存 2 刷新缓存
+	FTPLogListURL = "/api/audits/v1/ftp-log/" // 上传 ftp日志
+
+	UserAssetsURL                  = "/api/perms/v1/users/%s/assets/"                 //获取用户授权的所有资产
+	UserNodesAssetsURL             = "/api/perms/v1/users/%s/nodes-assets/"           // 获取用户授权的所有节点信息 节点分组
+	ValidateUserAssetPermissionURL = "/api/perms/v1/asset-permissions/user/validate/" //0不使用缓存 1 使用缓存 2 刷新缓存
 )

pkg/service/users.go

@@ -44,7 +44,7 @@ func GetProfile() (user *model.User, err error) {
 func GetUserByUsername(username string) (user *model.User, err error) {
 	var users []*model.User
 	payload := map[string]string{"username": username}
-	err = authClient.Get(UserListUrl, &users, payload)
+	err = authClient.Get(UserListURL, &users, payload)
 	if err != nil {
 		return
 	}