opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-08-31 01:35:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

keystone: endpoint list by service

Browse Source
This commit is contained in:
Zexi Li
2019-10-12 12:46:48 +08:00
parent 837e5a616e
commit 9ee245deed
1 changed files with 21 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/keystone/models/endpoints.go
+21
View File
@@ -324,6 +324,27 @@ func (manager *SEndpointManager) ValidateCreateData(ctx context.Context, userCre
return manager.SStandaloneResourceBaseManager.ValidateCreateData(ctx, userCred, ownerId, query, data)
}
func (manager *SEndpointManager) ListItemFilter(ctx context.Context, q *sqlchemy.SQuery, userCred mcclient.TokenCredential, query jsonutils.JSONObject) (*sqlchemy.SQuery, error) {
q, err := manager.SStandaloneResourceBaseManager.ListItemFilter(ctx, q, userCred, query)
if err != nil {
return nil, err
}
svcStr := jsonutils.GetAnyString(query, []string{"service", "service_id"})
if len(svcStr) > 0 {
svcObj, err := ServiceManager.FetchByIdOrName(userCred, svcStr)
if err != nil {
if err == sql.ErrNoRows {
return nil, httperrors.NewResourceNotFoundError2(ServiceManager.Keyword(), svcStr)
} else {
return nil, httperrors.NewGeneralError(err)
}
}
subq := ServiceManager.Query("id").Equals("id", svcObj.GetId())
q = q.Equals("service_id", subq.SubQuery())
}
return q, nil
}
func (endpoint *SEndpoint) PostCreate(ctx context.Context, userCred mcclient.TokenCredential, ownerId mcclient.IIdentityProvider, query jsonutils.JSONObject, data jsonutils.JSONObject) {
endpoint.SStandaloneResourceBase.PostCreate(ctx, userCred, ownerId, query, data)
logclient.AddActionLogWithContext(ctx, endpoint, logclient.ACT_CREATE, data, userCred, true)