Commit f1da5e13 authored by Eric's avatar Eric

[update] modify service assets part

parent 117e5199
package service package service
import ( import (
"encoding/json"
"fmt" "fmt"
"cocogo/pkg/logger" "cocogo/pkg/logger"
...@@ -9,11 +8,16 @@ import ( ...@@ -9,11 +8,16 @@ import (
) )
func GetSystemUserAssetAuthInfo(systemUserID, assetID string) (info model.SystemUserAuthInfo) { func GetSystemUserAssetAuthInfo(systemUserID, assetID string) (info model.SystemUserAuthInfo) {
Url := authClient.ParseUrlQuery(fmt.Sprintf(SystemUserAssetAuthURL, systemUserID, assetID), nil)
err := authClient.Get(Url, &info)
if err != nil {
logger.Error("Get system user Asset auth info failed")
}
return return
} }
func GetSystemUserAuthInfo(systemUserID string) (info model.SystemUserAuthInfo) { func GetSystemUserAuthInfo(systemUserID string) (info model.SystemUserAuthInfo) {
Url := fmt.Sprintf(SystemUserAuthInfoURL, systemUserID) Url := authClient.ParseUrlQuery(fmt.Sprintf(SystemUserAuthInfoURL, systemUserID), nil)
err := authClient.Get(Url, &info) err := authClient.Get(Url, &info)
if err != nil { if err != nil {
...@@ -22,47 +26,52 @@ func GetSystemUserAuthInfo(systemUserID string) (info model.SystemUserAuthInfo) ...@@ -22,47 +26,52 @@ func GetSystemUserAuthInfo(systemUserID string) (info model.SystemUserAuthInfo)
return return
} }
func GetSystemUserFilterRules(systemUsrId string) (rules []model.SystemUserFilterRule, err error) { func GetSystemUserFilterRules(systemUserID string) (rules []model.SystemUserFilterRule, err error) {
var resp = `[ /*[
{ {
"id": "12ae03a4-81b7-43d9-b356-2db4d5d63927", "id": "12ae03a4-81b7-43d9-b356-2db4d5d63927",
"org_id": "", "org_id": "",
"type": { "type": {
"value": "command", "value": "command",
"display": "命令" "display": "命令"
}, },
"priority": 50, "priority": 50,
"content": "reboot\r\nrm", "content": "reboot\r\nrm",
"action": { "action": {
"value": 0, "value": 0,
"display": "拒绝" "display": "拒绝"
}, },
"comment": "", "comment": "",
"date_created": "2019-04-29 11:32:12 +0800", "date_created": "2019-04-29 11:32:12 +0800",
"date_updated": "2019-04-29 11:32:12 +0800", "date_updated": "2019-04-29 11:32:12 +0800",
"created_by": "Administrator", "created_by": "Administrator",
"filter": "de7693ca-75d5-4639-986b-44ed390260a0" "filter": "de7693ca-75d5-4639-986b-44ed390260a0"
}, },
{ {
"id": "c1fe1ebf-8fdc-4477-b2cf-dd9bc12de832", "id": "c1fe1ebf-8fdc-4477-b2cf-dd9bc12de832",
"org_id": "", "org_id": "",
"type": { "type": {
"value": "regex", "value": "regex",
"display": "正则表达式" "display": "正则表达式"
}, },
"priority": 49, "priority": 49,
"content": "shutdown|echo|df", "content": "shutdown|echo|df",
"action": { "action": {
"value": 1, "value": 1,
"display": "允许" "display": "允许"
}, },
"comment": "", "comment": "",
"date_created": "2019-04-29 11:32:39 +0800", "date_created": "2019-04-29 11:32:39 +0800",
"date_updated": "2019-04-29 11:32:50 +0800", "date_updated": "2019-04-29 11:32:50 +0800",
"created_by": "Administrator", "created_by": "Administrator",
"filter": "de7693ca-75d5-4639-986b-44ed390260a0" "filter": "de7693ca-75d5-4639-986b-44ed390260a0"
} }
]` ]`*/
err = json.Unmarshal([]byte(resp), &rules) Url := authClient.ParseUrlQuery(fmt.Sprintf(SystemUserCmdFilterRules, systemUserID), nil)
err = authClient.Get(Url, &rules)
if err != nil {
logger.Error("Get system user auth info failed")
}
return return
} }
...@@ -5,8 +5,9 @@ const ( ...@@ -5,8 +5,9 @@ const (
UserProfileURL = "/api/users/v1/profile/" // 获取当前用户的基本信息 UserProfileURL = "/api/users/v1/profile/" // 获取当前用户的基本信息
UserUserURL = "/api/users/v1/users/%s/" // 获取用户信息 UserUserURL = "/api/users/v1/users/%s/" // 获取用户信息
SystemUserAssetAuthURL = "/api/assets/v1/system-user/%s/asset/%s/auth-info/" // 该系统用户对某资产的授权 SystemUserAssetAuthURL = "/api/assets/v1/system-user/%s/asset/%s/auth-info/" // 该系统用户对某资产的授权
SystemUserAuthInfoURL = "/api/assets/v1/system-user/%s/auth-info/" // 该系统用户的授权 SystemUserAuthInfoURL = "/api/assets/v1/system-user/%s/auth-info/" // 该系统用户的授权
SystemUserCmdFilterRules = "/api/assets/v1/system-user/%s/cmd-filter-rules/" // 过滤规则url
TerminalRegisterURL = "/api/terminal/v2/terminal-registrations/" // 注册当前coco TerminalRegisterURL = "/api/terminal/v2/terminal-registrations/" // 注册当前coco
TerminalConfigURL = "/api/terminal/v1/terminal/config/" // 从jumpserver获取coco的配置 TerminalConfigURL = "/api/terminal/v1/terminal/config/" // 从jumpserver获取coco的配置
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment