routetableresource.go 2.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. // Copyright 2019 Yunion
  2. //
  3. // Licensed under the Apache License, Version 2.0 (the "License");
  4. // you may not use this file except in compliance with the License.
  5. // You may obtain a copy of the License at
  6. //
  7. // http://www.apache.org/licenses/LICENSE-2.0
  8. //
  9. // Unless required by applicable law or agreed to in writing, software
  10. // distributed under the License is distributed on an "AS IS" BASIS,
  11. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. // See the License for the specific language governing permissions and
  13. // limitations under the License.
  14. package models
  15. import (
  16. "context"
  17. "database/sql"
  18. "yunion.io/x/pkg/errors"
  19. "yunion.io/x/sqlchemy"
  20. api "yunion.io/x/onecloud/pkg/apis/compute"
  21. "yunion.io/x/onecloud/pkg/httperrors"
  22. "yunion.io/x/onecloud/pkg/mcclient"
  23. )
  24. type SRouteTableResourceBase struct {
  25. RouteTableId string `width:"36" charset:"ascii" nullable:"false" list:"user" create:"required" json:"route_table_id"`
  26. }
  27. type SRouteTableResourceBaseManager struct {
  28. SVpcResourceBaseManager
  29. }
  30. func (manager *SRouteTableResourceBaseManager) ListItemFilter(
  31. ctx context.Context,
  32. q *sqlchemy.SQuery,
  33. userCred mcclient.TokenCredential,
  34. query api.RouteTableFilterList,
  35. ) (*sqlchemy.SQuery, error) {
  36. if len(query.RouteTableId) > 0 {
  37. routeTable, err := RouteTableManager.FetchByIdOrName(ctx, userCred, query.RouteTableId)
  38. if err != nil {
  39. if errors.Cause(err) == sql.ErrNoRows {
  40. return nil, httperrors.NewResourceNotFoundError2("route_table", query.RouteTableId)
  41. }
  42. return nil, httperrors.NewGeneralError(err)
  43. }
  44. q = q.Equals("route_table_id", routeTable.GetId())
  45. }
  46. subq := RouteTableManager.Query("id").Snapshot()
  47. subq, err := manager.SVpcResourceBaseManager.ListItemFilter(ctx, subq, userCred, query.VpcFilterListInput)
  48. if err != nil {
  49. return nil, errors.Wrap(err, "SVpcResourceBaseManager.ListItemFilter")
  50. }
  51. if subq.IsAltered() {
  52. q = q.Filter(sqlchemy.In(q.Field("route_table_id"), subq.SubQuery()))
  53. }
  54. return q, nil
  55. }