opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-10-29 17:58:36 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(notify): add capability for notify config (#19568)

Browse Source
This commit is contained in:
屈轩
2024-02-28 17:51:32 +08:00
committed by GitHub
parent bb7a05c63d
commit 8d254bcc80
3 changed files with 42 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/notify/models/config.go
+30
View File
@@ -103,6 +103,36 @@ func (cm *SConfigManager) ValidateCreateData(ctx context.Context, userCred mccli
return input, nil
}
func (manager *SConfigManager) GetPropertyCapability(ctx context.Context, userCred mcclient.TokenCredential, query jsonutils.JSONObject) (jsonutils.JSONObject, error) {
q := manager.Query()
configs := []SConfig{}
err := db.FetchModelObjects(manager, q, &configs)
if err != nil {
return nil, err
}
ret := struct {
System []string `json:"system,allowempty"`
Domain map[string][]string `json:"domain,allowempty"`
}{
System: []string{},
Domain: map[string][]string{},
}
for _, config := range configs {
switch config.Attribution {
case api.CONFIG_ATTRIBUTION_SYSTEM:
ret.System = append(ret.System, config.Type)
case api.CONFIG_ATTRIBUTION_DOMAIN:
_, ok := ret.Domain[config.DomainId]
if !ok {
ret.Domain[config.DomainId] = []string{}
}
ret.Domain[config.DomainId] = append(ret.Domain[config.DomainId], config.Type)
}
}
return jsonutils.Marshal(ret), nil
}
func (c *SConfig) PostCreate(ctx context.Context, userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, data jsonutils.JSONObject) {
c.SDomainLevelResourceBase.PostCreate(ctx, userCred, ownerId, query, data)
err := c.StartRepullSubcontactTask(ctx, userCred, false)