// Licensed to the Apache Software Foundation (ASF) under one

// or more contributor license agreements. See the NOTICE file

// distributed with this work for additional information

// regarding copyright ownership. The ASF licenses this file

// to you under the Apache License, Version 2.0 (the

// "License"); you may not use this file except in compliance

// with the License. You may obtain a copy of the License at

//

// http://www.apache.org/licenses/LICENSE-2.0

//

// Unless required by applicable law or agreed to in writing,

// software distributed under the License is distributed on an

// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

// KIND, either express or implied. See the License for the

// specific language governing permissions and limitations

// under the License.

package com.cloud.api;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.EnumSet;

import java.util.HashMap;

import java.util.List;

import java.util.ListIterator;

import java.util.Map;

import java.util.Set;

import java.util.function.Function;

import java.util.stream.Collectors;

import javax.annotation.PostConstruct;

import javax.inject.Inject;

import com.cloud.cpu.CPU;

import org.apache.cloudstack.acl.Role;

import org.apache.cloudstack.acl.RoleService;

import org.apache.cloudstack.affinity.AffinityGroup;

import org.apache.cloudstack.affinity.AffinityGroupResponse;

import org.apache.cloudstack.affinity.dao.AffinityGroupDao;

import org.apache.cloudstack.api.ApiCommandResourceType;

import org.apache.cloudstack.api.ApiConstants;

import org.apache.cloudstack.api.ApiConstants.DomainDetails;

import org.apache.cloudstack.api.ApiConstants.HostDetails;

import org.apache.cloudstack.api.ApiConstants.VMDetails;

import org.apache.cloudstack.api.ResponseObject.ResponseView;

import org.apache.cloudstack.api.response.AccountResponse;

import org.apache.cloudstack.api.response.AsyncJobResponse;

import org.apache.cloudstack.api.response.BackupOfferingResponse;

import org.apache.cloudstack.api.response.BackupScheduleResponse;

import org.apache.cloudstack.api.response.DiskOfferingResponse;

import org.apache.cloudstack.api.response.DomainResponse;

import org.apache.cloudstack.api.response.DomainRouterResponse;

import org.apache.cloudstack.api.response.EventResponse;

import org.apache.cloudstack.api.response.SharedFSResponse;

import org.apache.cloudstack.api.response.HostForMigrationResponse;

import org.apache.cloudstack.api.response.HostResponse;

import org.apache.cloudstack.api.response.HostTagResponse;

import org.apache.cloudstack.api.response.ImageStoreResponse;

import org.apache.cloudstack.api.response.InstanceGroupResponse;

import org.apache.cloudstack.api.response.NetworkOfferingResponse;

import org.apache.cloudstack.api.response.ObjectStoreResponse;

import org.apache.cloudstack.api.response.ProjectAccountResponse;

import org.apache.cloudstack.api.response.ProjectInvitationResponse;

import org.apache.cloudstack.api.response.ProjectResponse;

import org.apache.cloudstack.api.response.ResourceIconResponse;

import org.apache.cloudstack.api.response.ResourceTagResponse;

import org.apache.cloudstack.api.response.SecurityGroupResponse;

import org.apache.cloudstack.api.response.ServiceOfferingResponse;

import org.apache.cloudstack.api.response.SnapshotResponse;

import org.apache.cloudstack.api.response.StoragePoolResponse;

import org.apache.cloudstack.api.response.StorageTagResponse;

import org.apache.cloudstack.api.response.TemplateResponse;

import org.apache.cloudstack.api.response.UserResponse;

import org.apache.cloudstack.api.response.UserVmResponse;

import org.apache.cloudstack.api.response.VolumeResponse;

import org.apache.cloudstack.api.response.VpcOfferingResponse;

import org.apache.cloudstack.api.response.ZoneResponse;

import org.apache.cloudstack.backup.BackupOffering;

import org.apache.cloudstack.backup.BackupSchedule;

import org.apache.cloudstack.backup.dao.BackupDao;

import org.apache.cloudstack.backup.dao.BackupOfferingDao;

import org.apache.cloudstack.backup.dao.BackupScheduleDao;

import org.apache.cloudstack.context.CallContext;

import org.apache.cloudstack.engine.orchestration.service.NetworkOrchestrationService;

import org.apache.cloudstack.engine.orchestration.service.VolumeOrchestrationService;

import org.apache.cloudstack.framework.config.dao.ConfigurationDao;

import org.apache.cloudstack.framework.jobs.AsyncJob;

import org.apache.cloudstack.framework.jobs.AsyncJobManager;

import org.apache.cloudstack.framework.jobs.dao.AsyncJobDao;

import org.apache.cloudstack.resourcedetail.SnapshotPolicyDetailVO;

import org.apache.cloudstack.resourcedetail.dao.DiskOfferingDetailsDao;

import org.apache.cloudstack.resourcedetail.dao.SnapshotPolicyDetailsDao;

import org.apache.cloudstack.storage.datastore.db.ObjectStoreDao;

import org.apache.cloudstack.storage.datastore.db.ObjectStoreVO;

import org.apache.cloudstack.storage.datastore.db.PrimaryDataStoreDao;

import org.apache.cloudstack.storage.datastore.db.StoragePoolVO;

import org.apache.cloudstack.storage.sharedfs.SharedFS;

import org.apache.cloudstack.storage.sharedfs.query.dao.SharedFSJoinDao;

import org.apache.cloudstack.storage.sharedfs.query.vo.SharedFSJoinVO;

import com.cloud.agent.api.VgpuTypesInfo;

import com.cloud.api.query.dao.AccountJoinDao;

import com.cloud.api.query.dao.AffinityGroupJoinDao;

import com.cloud.api.query.dao.AsyncJobJoinDao;

import com.cloud.api.query.dao.DataCenterJoinDao;

import com.cloud.api.query.dao.DiskOfferingJoinDao;

import com.cloud.api.query.dao.DomainJoinDao;

import com.cloud.api.query.dao.DomainRouterJoinDao;

import com.cloud.api.query.dao.HostJoinDao;

import com.cloud.api.query.dao.ImageStoreJoinDao;

import com.cloud.api.query.dao.InstanceGroupJoinDao;

import com.cloud.api.query.dao.NetworkOfferingJoinDao;

import com.cloud.api.query.dao.ProjectAccountJoinDao;

import com.cloud.api.query.dao.ProjectInvitationJoinDao;

import com.cloud.api.query.dao.ProjectJoinDao;

import com.cloud.api.query.dao.ResourceTagJoinDao;

import com.cloud.api.query.dao.SecurityGroupJoinDao;

import com.cloud.api.query.dao.ServiceOfferingJoinDao;

import com.cloud.api.query.dao.SnapshotJoinDao;

import com.cloud.api.query.dao.StoragePoolJoinDao;

import com.cloud.api.query.dao.TemplateJoinDao;

import com.cloud.api.query.dao.UserAccountJoinDao;

import com.cloud.api.query.dao.UserVmJoinDao;

import com.cloud.api.query.dao.VolumeJoinDao;

import com.cloud.api.query.dao.VpcOfferingJoinDao;

import com.cloud.api.query.vo.AccountJoinVO;

import com.cloud.api.query.vo.AffinityGroupJoinVO;

import com.cloud.api.query.vo.AsyncJobJoinVO;

import com.cloud.api.query.vo.DataCenterJoinVO;

import com.cloud.api.query.vo.DiskOfferingJoinVO;

import com.cloud.api.query.vo.DomainJoinVO;

import com.cloud.api.query.vo.DomainRouterJoinVO;

import com.cloud.api.query.vo.EventJoinVO;

import com.cloud.api.query.vo.HostJoinVO;

import com.cloud.api.query.vo.ImageStoreJoinVO;

import com.cloud.api.query.vo.InstanceGroupJoinVO;

import com.cloud.api.query.vo.NetworkOfferingJoinVO;

import com.cloud.api.query.vo.ProjectAccountJoinVO;

import com.cloud.api.query.vo.ProjectInvitationJoinVO;

import com.cloud.api.query.vo.ProjectJoinVO;

import com.cloud.api.query.vo.ResourceTagJoinVO;

import com.cloud.api.query.vo.SecurityGroupJoinVO;

import com.cloud.api.query.vo.ServiceOfferingJoinVO;

import com.cloud.api.query.vo.SnapshotJoinVO;

import com.cloud.api.query.vo.StoragePoolJoinVO;

import com.cloud.api.query.vo.TemplateJoinVO;

import com.cloud.api.query.vo.UserAccountJoinVO;

import com.cloud.api.query.vo.UserVmJoinVO;

import com.cloud.api.query.vo.VolumeJoinVO;

import com.cloud.api.query.vo.VpcOfferingJoinVO;

import com.cloud.capacity.CapacityManager;

import com.cloud.capacity.CapacityVO;

import com.cloud.capacity.dao.CapacityDao;

import com.cloud.capacity.dao.CapacityDaoImpl.SummedCapacity;

import com.cloud.configuration.Config;

import com.cloud.configuration.ConfigurationManager;

import com.cloud.configuration.ConfigurationService;

import com.cloud.configuration.Resource;

import com.cloud.configuration.Resource.ResourceType;

import com.cloud.dc.AccountVlanMapVO;

import com.cloud.dc.ClusterDetailsDao;

import com.cloud.dc.ClusterDetailsVO;

import com.cloud.dc.ClusterVO;

import com.cloud.dc.DataCenter;

import com.cloud.dc.DataCenterVO;

import com.cloud.dc.HostPodVO;

import com.cloud.dc.Vlan;

import com.cloud.dc.VlanVO;

import com.cloud.dc.dao.AccountVlanMapDao;

import com.cloud.dc.dao.ClusterDao;

import com.cloud.dc.dao.DataCenterDao;

import com.cloud.dc.dao.HostPodDao;

import com.cloud.dc.dao.VlanDao;

import com.cloud.domain.Domain;

import com.cloud.domain.DomainVO;

import com.cloud.domain.dao.DomainDao;

import com.cloud.domain.dao.DomainDetailsDao;

import com.cloud.event.Event;

import com.cloud.event.dao.EventJoinDao;

import com.cloud.exception.InvalidParameterValueException;

import com.cloud.gpu.HostGpuGroupsVO;

import com.cloud.gpu.VGPUTypesVO;

import com.cloud.gpu.dao.HostGpuGroupsDao;

import com.cloud.gpu.dao.VGPUTypesDao;

import com.cloud.ha.HighAvailabilityManager;

import com.cloud.host.Host;

import com.cloud.host.HostStats;

import com.cloud.host.HostTagVO;

import com.cloud.host.HostVO;

import com.cloud.host.dao.HostDao;

import com.cloud.host.dao.HostDetailsDao;

import com.cloud.host.dao.HostTagsDao;

import com.cloud.hypervisor.Hypervisor.HypervisorType;

import com.cloud.network.IpAddress;

import com.cloud.network.Network;

import com.cloud.network.Network.Capability;

import com.cloud.network.Network.Provider;

import com.cloud.network.Network.Service;

import com.cloud.network.NetworkModel;

import com.cloud.network.NetworkProfile;

import com.cloud.network.Networks.TrafficType;

import com.cloud.network.PhysicalNetworkServiceProvider;

import com.cloud.network.as.AutoScalePolicy;

import com.cloud.network.as.AutoScalePolicyConditionMapVO;

import com.cloud.network.as.AutoScalePolicyVO;

import com.cloud.network.as.AutoScaleVmGroupPolicyMapVO;

import com.cloud.network.as.AutoScaleVmGroupVO;

import com.cloud.network.as.AutoScaleVmProfileVO;

import com.cloud.network.as.ConditionVO;

import com.cloud.network.as.CounterVO;

import com.cloud.network.as.dao.AutoScalePolicyConditionMapDao;

import com.cloud.network.as.dao.AutoScalePolicyDao;

import com.cloud.network.as.dao.AutoScaleVmGroupDao;

import com.cloud.network.as.dao.AutoScaleVmGroupPolicyMapDao;

import com.cloud.network.as.dao.AutoScaleVmGroupVmMapDao;

import com.cloud.network.as.dao.AutoScaleVmProfileDao;

import com.cloud.network.as.dao.ConditionDao;

import com.cloud.network.as.dao.CounterDao;

import com.cloud.network.dao.AccountGuestVlanMapDao;

import com.cloud.network.dao.AccountGuestVlanMapVO;

import com.cloud.network.dao.FirewallRulesCidrsDao;

import com.cloud.network.dao.FirewallRulesDao;

import com.cloud.network.dao.FirewallRulesDcidrsDao;

import com.cloud.network.dao.IPAddressDao;

import com.cloud.network.dao.IPAddressVO;

import com.cloud.network.dao.LoadBalancerDao;

import com.cloud.network.dao.LoadBalancerVO;

import com.cloud.network.dao.NetworkDao;

import com.cloud.network.dao.NetworkDomainDao;

import com.cloud.network.dao.NetworkDomainVO;

import com.cloud.network.dao.NetworkRuleConfigDao;

import com.cloud.network.dao.NetworkRuleConfigVO;

import com.cloud.network.dao.NetworkVO;

import com.cloud.network.dao.PhysicalNetworkDao;

import com.cloud.network.dao.PhysicalNetworkServiceProviderDao;

import com.cloud.network.dao.PhysicalNetworkServiceProviderVO;

import com.cloud.network.dao.PhysicalNetworkTrafficTypeDao;

import com.cloud.network.dao.PhysicalNetworkTrafficTypeVO;

import com.cloud.network.dao.PhysicalNetworkVO;

import com.cloud.network.dao.Site2SiteCustomerGatewayDao;

import com.cloud.network.dao.Site2SiteCustomerGatewayVO;

import com.cloud.network.dao.Site2SiteVpnGatewayDao;

import com.cloud.network.dao.Site2SiteVpnGatewayVO;

import com.cloud.network.router.VirtualRouter;

import com.cloud.network.rules.FirewallRuleVO;

import com.cloud.network.rules.LoadBalancer;

import com.cloud.network.security.SecurityGroup;

import com.cloud.network.security.SecurityGroupManager;

import com.cloud.network.security.SecurityGroupVO;

import com.cloud.network.security.dao.SecurityGroupDao;

import com.cloud.network.vpc.NetworkACL;

import com.cloud.network.vpc.StaticRouteVO;

import com.cloud.network.vpc.VpcGatewayVO;

import com.cloud.network.vpc.VpcManager;

import com.cloud.network.vpc.VpcOffering;

import com.cloud.network.vpc.VpcProvisioningService;

import com.cloud.network.vpc.VpcVO;

import com.cloud.network.vpc.dao.NetworkACLDao;

import com.cloud.network.vpc.dao.StaticRouteDao;

import com.cloud.network.vpc.dao.VpcDao;

import com.cloud.network.vpc.dao.VpcGatewayDao;

import com.cloud.network.vpc.dao.VpcOfferingDao;

import com.cloud.offering.DiskOffering;

import com.cloud.offering.NetworkOffering;

import com.cloud.offering.ServiceOffering;

import com.cloud.offerings.NetworkOfferingVO;

import com.cloud.offerings.dao.NetworkOfferingDao;

import com.cloud.projects.Project;

import com.cloud.projects.ProjectAccount;

import com.cloud.projects.ProjectInvitation;

import com.cloud.projects.ProjectService;

import com.cloud.region.ha.GlobalLoadBalancingRulesService;

import com.cloud.resource.ResourceManager;

import com.cloud.resource.icon.ResourceIconVO;

import com.cloud.resource.icon.dao.ResourceIconDao;

import com.cloud.server.ManagementServer;

import com.cloud.server.ManagementServerHostStats;

import com.cloud.server.ResourceIcon;

import com.cloud.server.ResourceManagerUtil;

import com.cloud.server.ResourceMetaDataService;

import com.cloud.server.ResourceTag;

import com.cloud.server.ResourceTag.ResourceObjectType;

import com.cloud.server.StatsCollector;

import com.cloud.server.TaggedResourceService;

import com.cloud.service.ServiceOfferingDetailsVO;

import com.cloud.service.ServiceOfferingVO;

import com.cloud.service.dao.ServiceOfferingDao;

import com.cloud.service.dao.ServiceOfferingDetailsDao;

import com.cloud.storage.DiskOfferingVO;

import com.cloud.storage.GuestOS;

import com.cloud.storage.GuestOSCategoryVO;

import com.cloud.storage.ImageStore;

import com.cloud.storage.Snapshot;

import com.cloud.storage.SnapshotVO;

import com.cloud.storage.Storage.ImageFormat;

import com.cloud.storage.Storage.StoragePoolType;

import com.cloud.storage.StorageManager;

import com.cloud.storage.StoragePool;

import com.cloud.storage.StoragePoolTagVO;

import com.cloud.storage.StorageStats;

import com.cloud.storage.UploadVO;

import com.cloud.storage.VMTemplateVO;

import com.cloud.storage.Volume;

import com.cloud.storage.Volume.Type;

import com.cloud.storage.VolumeStats;

import com.cloud.storage.VolumeVO;

import com.cloud.storage.dao.BucketDao;

import com.cloud.storage.dao.DiskOfferingDao;

import com.cloud.storage.dao.GuestOSCategoryDao;

import com.cloud.storage.dao.GuestOSDao;

import com.cloud.storage.dao.SnapshotDao;

import com.cloud.storage.dao.SnapshotPolicyDao;

import com.cloud.storage.dao.StoragePoolTagsDao;

import com.cloud.storage.dao.UploadDao;

import com.cloud.storage.dao.VMTemplateDao;

import com.cloud.storage.dao.VMTemplateDetailsDao;

import com.cloud.storage.dao.VolumeDao;

import com.cloud.storage.snapshot.SnapshotPolicy;

import com.cloud.template.TemplateManager;

import com.cloud.template.VirtualMachineTemplate;

import com.cloud.user.Account;

import com.cloud.user.AccountDetailsDao;

import com.cloud.user.AccountManager;

import com.cloud.user.AccountService;

import com.cloud.user.AccountVO;

import com.cloud.user.ResourceLimitService;

import com.cloud.user.SSHKeyPairVO;

import com.cloud.user.User;

import com.cloud.user.UserAccount;

import com.cloud.user.UserStatisticsVO;

import com.cloud.user.UserVO;

import com.cloud.user.dao.AccountDao;

import com.cloud.user.dao.SSHKeyPairDao;

import com.cloud.user.dao.UserDao;

import com.cloud.user.dao.UserStatisticsDao;

import com.cloud.uservm.UserVm;

import com.cloud.utils.EnumUtils;

import com.cloud.utils.Pair;

import com.cloud.vm.ConsoleProxyVO;

import com.cloud.vm.DomainRouterVO;

import com.cloud.vm.InstanceGroup;

import com.cloud.vm.InstanceGroupVO;

import com.cloud.vm.NicProfile;

import com.cloud.vm.NicVO;

import com.cloud.vm.VMInstanceDetailVO;

import com.cloud.vm.UserVmManager;

import com.cloud.vm.UserVmVO;

import com.cloud.vm.VMInstanceVO;

import com.cloud.vm.VirtualMachine;

import com.cloud.vm.VirtualMachineManager;

import com.cloud.vm.VmDetailConstants;

import com.cloud.vm.VmStats;

import com.cloud.vm.dao.ConsoleProxyDao;

import com.cloud.vm.dao.DomainRouterDao;

import com.cloud.vm.dao.NicDao;

import com.cloud.vm.dao.NicSecondaryIpDao;

import com.cloud.vm.dao.NicSecondaryIpVO;

import com.cloud.vm.dao.UserVmDao;

import com.cloud.vm.dao.VMInstanceDetailsDao;

import com.cloud.vm.dao.VMInstanceDao;

import com.cloud.vm.snapshot.VMSnapshot;

import com.cloud.vm.snapshot.dao.VMSnapshotDao;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

public class ApiDBUtils {

private static final Logger log = LogManager.getLogger(ApiDBUtils.class);

private static ManagementServer s_ms;

static AsyncJobManager s_asyncMgr;

static SecurityGroupManager s_securityGroupMgr;

static StorageManager s_storageMgr;

static VolumeOrchestrationService s_volumeMgr;

static UserVmManager s_userVmMgr;

static NetworkModel s_networkModel;

static NetworkOrchestrationService s_networkMgr;

static TemplateManager s_templateMgr;

static ConfigurationManager s_configMgr;

static StatsCollector s_statsCollector;

static AccountDao s_accountDao;

static AccountVlanMapDao s_accountVlanMapDao;

static ClusterDao s_clusterDao;

static CapacityDao s_capacityDao;

static DiskOfferingDao s_diskOfferingDao;

static DiskOfferingJoinDao s_diskOfferingJoinDao;

static DiskOfferingDetailsDao s_diskOfferingDetailsDao;

static DataCenterJoinDao s_dcJoinDao;

static DomainDao s_domainDao;

static DomainJoinDao s_domainJoinDao;

static DomainRouterDao s_domainRouterDao;

static DomainRouterJoinDao s_domainRouterJoinDao;

static GuestOSDao s_guestOSDao;

static GuestOSCategoryDao s_guestOSCategoryDao;

static HostDao s_hostDao;

static AccountGuestVlanMapDao s_accountGuestVlanMapDao;

static IPAddressDao s_ipAddressDao;

static LoadBalancerDao s_loadBalancerDao;

static SecurityGroupDao s_securityGroupDao;

static SecurityGroupJoinDao s_securityGroupJoinDao;

static ServiceOfferingJoinDao s_serviceOfferingJoinDao;

static NetworkRuleConfigDao s_networkRuleConfigDao;

static HostPodDao s_podDao;

static ServiceOfferingDao s_serviceOfferingDao;

static ServiceOfferingDetailsDao s_serviceOfferingDetailsDao;

static SnapshotDao s_snapshotDao;

static PrimaryDataStoreDao s_storagePoolDao;

static VMTemplateDao s_templateDao;

static VMTemplateDetailsDao s_templateDetailsDao;

static UploadDao s_uploadDao;

static UserDao s_userDao;

static UserStatisticsDao s_userStatsDao;

static UserVmDao s_userVmDao;

static UserVmJoinDao s_userVmJoinDao;

static VlanDao s_vlanDao;

static VolumeDao s_volumeDao;

static Site2SiteVpnGatewayDao s_site2SiteVpnGatewayDao;

static Site2SiteCustomerGatewayDao s_site2SiteCustomerGatewayDao;

static DataCenterDao s_zoneDao;

static NetworkOfferingDao s_networkOfferingDao;

static NetworkOfferingJoinDao s_networkOfferingJoinDao;

static NetworkDao s_networkDao;

static PhysicalNetworkDao s_physicalNetworkDao;

static ConfigurationService s_configSvc;

static ConfigurationDao s_configDao;

static ConsoleProxyDao s_consoleProxyDao;

static FirewallRulesCidrsDao s_firewallCidrsDao;

static FirewallRulesDcidrsDao s_firewallDcidrsDao;

static VMInstanceDao s_vmDao;

static ResourceLimitService s_resourceLimitMgr;

static ProjectService s_projectMgr;

static ResourceManager s_resourceMgr;

static DomainDetailsDao s_domainDetailsDao;

static AccountDetailsDao s_accountDetailsDao;

static NetworkDomainDao s_networkDomainDao;

static HighAvailabilityManager s_haMgr;

static VpcManager s_vpcMgr;

static TaggedResourceService s_taggedResourceService;

static VMInstanceDetailsDao s_vmInstanceDetailsDao;

static SSHKeyPairDao s_sshKeyPairDao;

static ConditionDao s_asConditionDao;

static AutoScalePolicyConditionMapDao s_asPolicyConditionMapDao;

static AutoScaleVmGroupPolicyMapDao s_asVmGroupPolicyMapDao;

static AutoScaleVmGroupVmMapDao s_autoScaleVmGroupVmMapDao;

static AutoScalePolicyDao s_asPolicyDao;

static AutoScaleVmProfileDao s_asVmProfileDao;

static AutoScaleVmGroupDao s_asVmGroupDao;

static CounterDao s_counterDao;

static ResourceTagJoinDao s_tagJoinDao;

static ResourceIconDao s_resourceIconDao;

static EventJoinDao s_eventJoinDao;

static InstanceGroupJoinDao s_vmGroupJoinDao;

static UserAccountJoinDao s_userAccountJoinDao;

static ProjectJoinDao s_projectJoinDao;

static ProjectAccountJoinDao s_projectAccountJoinDao;

static ProjectInvitationJoinDao s_projectInvitationJoinDao;

static HostJoinDao s_hostJoinDao;

static VolumeJoinDao s_volJoinDao;

static StoragePoolJoinDao s_poolJoinDao;

static StoragePoolTagsDao s_tagDao;

static HostTagsDao s_hostTagDao;

static ImageStoreJoinDao s_imageStoreJoinDao;

static AccountJoinDao s_accountJoinDao;

static AsyncJobJoinDao s_jobJoinDao;

static TemplateJoinDao s_templateJoinDao;

static SnapshotJoinDao s_snapshotJoinDao;

static PhysicalNetworkTrafficTypeDao s_physicalNetworkTrafficTypeDao;

static PhysicalNetworkServiceProviderDao s_physicalNetworkServiceProviderDao;

static FirewallRulesDao s_firewallRuleDao;

static StaticRouteDao s_staticRouteDao;

static VpcGatewayDao s_vpcGatewayDao;

static VpcDao s_vpcDao;

static VpcOfferingDao s_vpcOfferingDao;

static VpcOfferingJoinDao s_vpcOfferingJoinDao;

static SnapshotPolicyDao s_snapshotPolicyDao;

static AsyncJobDao s_asyncJobDao;

static HostDetailsDao s_hostDetailsDao;

static VMSnapshotDao s_vmSnapshotDao;

static ClusterDetailsDao s_clusterDetailsDao;

static NicSecondaryIpDao s_nicSecondaryIpDao;

static VpcProvisioningService s_vpcProvSvc;

static AffinityGroupDao s_affinityGroupDao;

static AffinityGroupJoinDao s_affinityGroupJoinDao;

static GlobalLoadBalancingRulesService s_gslbService;

static NetworkACLDao s_networkACLDao;

static RoleService s_roleService;

static AccountService s_accountService;

static ResourceMetaDataService s_resourceDetailsService;

static HostGpuGroupsDao s_hostGpuGroupsDao;

static VGPUTypesDao s_vgpuTypesDao;

static BackupDao s_backupDao;

static BackupScheduleDao s_backupScheduleDao;

static BackupOfferingDao s_backupOfferingDao;

static NicDao s_nicDao;

static ResourceManagerUtil s_resourceManagerUtil;

static SnapshotPolicyDetailsDao s_snapshotPolicyDetailsDao;

static ObjectStoreDao s_objectStoreDao;

static SharedFSJoinDao s_sharedFSJoinDao;

static BucketDao s_bucketDao;

static VirtualMachineManager s_virtualMachineManager;

@Inject

private ManagementServer ms;

@Inject

public AsyncJobManager asyncMgr;

@Inject

private SecurityGroupManager securityGroupMgr;

@Inject

private StorageManager storageMgr;

@Inject

private UserVmManager userVmMgr;

@Inject

private NetworkModel networkModel;

@Inject

private NetworkOrchestrationService networkMgr;

@Inject

private StatsCollector statsCollector;

@Inject

private TemplateManager templateMgr;

@Inject

private VolumeOrchestrationService volumeMgr;

@Inject

private AccountDao accountDao;

@Inject

private AccountVlanMapDao accountVlanMapDao;

@Inject

private ClusterDao clusterDao;

@Inject

private CapacityDao capacityDao;

@Inject

private DataCenterJoinDao dcJoinDao;

@Inject

private DiskOfferingDao diskOfferingDao;

@Inject

private DiskOfferingJoinDao diskOfferingJoinDao;

@Inject

private DiskOfferingDetailsDao diskOfferingDetailsDao;

@Inject

private DomainDao domainDao;

@Inject

private DomainJoinDao domainJoinDao;

@Inject

private DomainRouterDao domainRouterDao;

@Inject

private DomainRouterJoinDao domainRouterJoinDao;

@Inject

private GuestOSDao guestOSDao;

@Inject

private GuestOSCategoryDao guestOSCategoryDao;

@Inject

private HostDao hostDao;

@Inject

private AccountGuestVlanMapDao accountGuestVlanMapDao;

@Inject

private IPAddressDao ipAddressDao;

@Inject

private LoadBalancerDao loadBalancerDao;

@Inject

private SecurityGroupDao securityGroupDao;

@Inject

private SecurityGroupJoinDao securityGroupJoinDao;

@Inject

private ServiceOfferingJoinDao serviceOfferingJoinDao;

@Inject

private NetworkRuleConfigDao networkRuleConfigDao;

@Inject

private HostPodDao podDao;

@Inject

private ServiceOfferingDao serviceOfferingDao;

@Inject

private ServiceOfferingDetailsDao serviceOfferingDetailsDao;

@Inject

private SnapshotDao snapshotDao;

@Inject

private PrimaryDataStoreDao storagePoolDao;

@Inject

private VMTemplateDao templateDao;

@Inject

private VMTemplateDetailsDao templateDetailsDao;

@Inject

private UploadDao uploadDao;

@Inject

private UserDao userDao;

@Inject

private UserStatisticsDao userStatsDao;

@Inject

private UserVmDao userVmDao;

@Inject

private UserVmJoinDao userVmJoinDao;

@Inject

private VlanDao vlanDao;

@Inject

private VolumeDao volumeDao;

@Inject

private Site2SiteVpnGatewayDao site2SiteVpnGatewayDao;

@Inject

private Site2SiteCustomerGatewayDao site2SiteCustomerGatewayDao;

@Inject

private DataCenterDao zoneDao;

@Inject

private NetworkOfferingDao networkOfferingDao;

@Inject

private NetworkOfferingJoinDao networkOfferingJoinDao;

@Inject

private NetworkDao networkDao;

@Inject

private PhysicalNetworkDao physicalNetworkDao;

@Inject

private ConfigurationService configSvc;

@Inject

private ConfigurationDao configDao;

@Inject

private ConsoleProxyDao consoleProxyDao;

@Inject

private FirewallRulesCidrsDao firewallCidrsDao;

@Inject

private FirewallRulesDcidrsDao firewalDcidrsDao;

@Inject

private VMInstanceDao vmDao;

@Inject

private ResourceLimitService resourceLimitMgr;

@Inject

private ProjectService projectMgr;

@Inject

private ResourceManager resourceMgr;

@Inject

private DomainDetailsDao domainDetailsDao;

@Inject

private AccountDetailsDao accountDetailsDao;

@Inject

private NetworkDomainDao networkDomainDao;

@Inject

private HighAvailabilityManager haMgr;

@Inject

private VpcManager vpcMgr;

@Inject

private TaggedResourceService taggedResourceService;

@Inject

private VMInstanceDetailsDao vmInstanceDetailsDao;

@Inject

private SSHKeyPairDao sshKeyPairDao;

@Inject

private ConditionDao asConditionDao;

@Inject

private AutoScalePolicyConditionMapDao asPolicyConditionMapDao;

@Inject

private AutoScaleVmGroupPolicyMapDao asVmGroupPolicyMapDao;

@Inject

private AutoScaleVmGroupVmMapDao autoScaleVmGroupVmMapDao;

@Inject

private AutoScalePolicyDao asPolicyDao;

@Inject

private AutoScaleVmProfileDao asVmProfileDao;

@Inject

private AutoScaleVmGroupDao asVmGroupDao;

@Inject

private CounterDao counterDao;

@Inject

private ResourceTagJoinDao tagJoinDao;

@Inject

private EventJoinDao eventJoinDao;

@Inject

private InstanceGroupJoinDao vmGroupJoinDao;

@Inject

private UserAccountJoinDao userAccountJoinDao;

@Inject

private ProjectJoinDao projectJoinDao;

@Inject

private ProjectAccountJoinDao projectAccountJoinDao;

@Inject

private ProjectInvitationJoinDao projectInvitationJoinDao;

@Inject

private HostJoinDao hostJoinDao;

@Inject

private VolumeJoinDao volJoinDao;

@Inject

private StoragePoolJoinDao poolJoinDao;

@Inject

private StoragePoolTagsDao tagDao;

@Inject

private HostTagsDao hosttagDao;

@Inject

private ImageStoreJoinDao imageStoreJoinDao;

@Inject

private AccountJoinDao accountJoinDao;

@Inject

private AsyncJobJoinDao jobJoinDao;

@Inject

private TemplateJoinDao templateJoinDao;

@Inject

private SnapshotJoinDao snapshotJoinDao;

@Inject

private PhysicalNetworkTrafficTypeDao physicalNetworkTrafficTypeDao;

@Inject

private PhysicalNetworkServiceProviderDao physicalNetworkServiceProviderDao;

@Inject

private FirewallRulesDao firewallRuleDao;

@Inject

private StaticRouteDao staticRouteDao;

@Inject

private VpcGatewayDao vpcGatewayDao;

@Inject

private VpcDao vpcDao;

@Inject

private VpcOfferingDao vpcOfferingDao;

@Inject

private VpcOfferingJoinDao vpcOfferingJoinDao;

@Inject

private SnapshotPolicyDao snapshotPolicyDao;

@Inject

private AsyncJobDao asyncJobDao;

@Inject

private HostDetailsDao hostDetailsDao;

@Inject

private ClusterDetailsDao clusterDetailsDao;

@Inject

private VMSnapshotDao vmSnapshotDao;

@Inject

private NicSecondaryIpDao nicSecondaryIpDao;

@Inject

private VpcProvisioningService vpcProvSvc;

@Inject

private AffinityGroupDao affinityGroupDao;

@Inject

private AffinityGroupJoinDao affinityGroupJoinDao;

@Inject

private GlobalLoadBalancingRulesService gslbService;

@Inject

private NetworkACLDao networkACLDao;

@Inject

private RoleService roleService;

@Inject

private AccountService accountService;

@Inject

private ConfigurationManager configMgr;

@Inject

private ResourceMetaDataService resourceDetailsService;

@Inject

private HostGpuGroupsDao hostGpuGroupsDao;

@Inject

private VGPUTypesDao vgpuTypesDao;

@Inject

private BackupDao backupDao;

@Inject

private BackupOfferingDao backupOfferingDao;

@Inject

private BackupScheduleDao backupScheduleDao;

@Inject

private NicDao nicDao;

@Inject

private ResourceIconDao resourceIconDao;

@Inject

private ResourceManagerUtil resourceManagerUtil;

@Inject

SnapshotPolicyDetailsDao snapshotPolicyDetailsDao;

@Inject

private ObjectStoreDao objectStoreDao;

@Inject

private BucketDao bucketDao;

@Inject

private VirtualMachineManager virtualMachineManager;

@Inject

private SharedFSJoinDao sharedFSJoinDao;

@PostConstruct

void init() {

s_ms = ms;

s_configMgr = configMgr;

s_asyncMgr = asyncMgr;

s_securityGroupMgr = securityGroupMgr;

s_storageMgr = storageMgr;

s_userVmMgr = userVmMgr;

s_networkModel = networkModel;

s_networkMgr = networkMgr;

s_configSvc = configSvc;

s_templateMgr = templateMgr;

s_accountDao = accountDao;

s_accountGuestVlanMapDao = accountGuestVlanMapDao;

s_accountVlanMapDao = accountVlanMapDao;

s_clusterDao = clusterDao;

s_capacityDao = capacityDao;

s_dcJoinDao = dcJoinDao;

s_diskOfferingDao = diskOfferingDao;

s_diskOfferingJoinDao = diskOfferingJoinDao;

s_diskOfferingDetailsDao = diskOfferingDetailsDao;

s_domainDao = domainDao;

s_domainJoinDao = domainJoinDao;

s_domainRouterDao = domainRouterDao;

s_domainRouterJoinDao = domainRouterJoinDao;

s_guestOSDao = guestOSDao;

s_guestOSCategoryDao = guestOSCategoryDao;

s_hostDao = hostDao;

s_ipAddressDao = ipAddressDao;

s_loadBalancerDao = loadBalancerDao;

s_networkRuleConfigDao = networkRuleConfigDao;

s_podDao = podDao;

s_serviceOfferingDao = serviceOfferingDao;

s_serviceOfferingDetailsDao = serviceOfferingDetailsDao;

s_serviceOfferingJoinDao = serviceOfferingJoinDao;

s_snapshotDao = snapshotDao;

s_storagePoolDao = storagePoolDao;

s_templateDao = templateDao;

s_templateDetailsDao = templateDetailsDao;

s_uploadDao = uploadDao;

s_userDao = userDao;

s_userStatsDao = userStatsDao;

s_userVmDao = userVmDao;

s_userVmJoinDao = userVmJoinDao;

s_vlanDao = vlanDao;

s_volumeDao = volumeDao;

s_site2SiteVpnGatewayDao = site2SiteVpnGatewayDao;

s_site2SiteCustomerGatewayDao = site2SiteCustomerGatewayDao;

s_zoneDao = zoneDao;

s_securityGroupDao = securityGroupDao;

s_securityGroupJoinDao = securityGroupJoinDao;

s_networkOfferingDao = networkOfferingDao;

s_networkOfferingJoinDao = networkOfferingJoinDao;

s_networkDao = networkDao;

s_physicalNetworkDao = physicalNetworkDao;

s_configDao = configDao;

s_consoleProxyDao = consoleProxyDao;

s_firewallCidrsDao = firewallCidrsDao;

s_firewallDcidrsDao = firewalDcidrsDao;

s_vmDao = vmDao;

s_resourceLimitMgr = resourceLimitMgr;

s_projectMgr = projectMgr;

s_resourceMgr = resourceMgr;

s_domainDetailsDao = domainDetailsDao;

s_accountDetailsDao = accountDetailsDao;

s_networkDomainDao = networkDomainDao;

s_haMgr = haMgr;

s_vpcMgr = vpcMgr;

s_taggedResourceService = taggedResourceService;

s_sshKeyPairDao = sshKeyPairDao;

s_vmInstanceDetailsDao = vmInstanceDetailsDao;

s_asConditionDao = asConditionDao;

s_asPolicyDao = asPolicyDao;

s_asPolicyConditionMapDao = asPolicyConditionMapDao;

s_counterDao = counterDao;

s_asVmGroupPolicyMapDao = asVmGroupPolicyMapDao;

s_autoScaleVmGroupVmMapDao = autoScaleVmGroupVmMapDao;

s_tagJoinDao = tagJoinDao;

s_vmGroupJoinDao = vmGroupJoinDao;

s_eventJoinDao = eventJoinDao;

s_userAccountJoinDao = userAccountJoinDao;

s_projectJoinDao = projectJoinDao;

s_projectAccountJoinDao = projectAccountJoinDao;

s_projectInvitationJoinDao = projectInvitationJoinDao;

s_hostJoinDao = hostJoinDao;

s_volJoinDao = volJoinDao;

s_poolJoinDao = poolJoinDao;

s_tagDao = tagDao;

s_hostTagDao = hosttagDao;

s_imageStoreJoinDao = imageStoreJoinDao;

s_accountJoinDao = accountJoinDao;

s_jobJoinDao = jobJoinDao;

s_templateJoinDao = templateJoinDao;

s_snapshotJoinDao = snapshotJoinDao;

s_physicalNetworkTrafficTypeDao = physicalNetworkTrafficTypeDao;

s_physicalNetworkServiceProviderDao = physicalNetworkServiceProviderDao;

s_firewallRuleDao = firewallRuleDao;

s_staticRouteDao = staticRouteDao;

s_vpcGatewayDao = vpcGatewayDao;

s_asVmProfileDao = asVmProfileDao;

s_asVmGroupDao = asVmGroupDao;

s_vpcDao = vpcDao;

s_vpcOfferingDao = vpcOfferingDao;

s_vpcOfferingJoinDao = vpcOfferingJoinDao;

s_snapshotPolicyDao = snapshotPolicyDao;

s_snapshotPolicyDetailsDao = snapshotPolicyDetailsDao;

s_asyncJobDao = asyncJobDao;

s_hostDetailsDao = hostDetailsDao;

s_clusterDetailsDao = clusterDetailsDao;

s_vmSnapshotDao = vmSnapshotDao;

s_nicDao = nicDao;

s_nicSecondaryIpDao = nicSecondaryIpDao;

s_vpcProvSvc = vpcProvSvc;

s_affinityGroupDao = affinityGroupDao;

s_affinityGroupJoinDao = affinityGroupJoinDao;

s_gslbService = gslbService;

// Note: stats collector should already have been initialized by this time, otherwise a null instance is returned

s_statsCollector = StatsCollector.getInstance();

s_networkACLDao = networkACLDao;

s_roleService = roleService;

s_accountService = accountService;

s_resourceDetailsService = resourceDetailsService;

s_hostGpuGroupsDao = hostGpuGroupsDao;

s_vgpuTypesDao = vgpuTypesDao;

s_backupDao = backupDao;

s_backupScheduleDao = backupScheduleDao;

s_backupOfferingDao = backupOfferingDao;

s_resourceIconDao = resourceIconDao;

s_resourceManagerUtil = resourceManagerUtil;

s_objectStoreDao = objectStoreDao;

s_bucketDao = bucketDao;

s_virtualMachineManager = virtualMachineManager;

s_sharedFSJoinDao = sharedFSJoinDao;

}

// ///////////////////////////////////////////////////////////

// ManagementServer methods //

// ///////////////////////////////////////////////////////////

public static VMInstanceVO findVMInstanceById(long vmId) {

return s_vmDao.findByIdIncludingRemoved(vmId);

}

public static long getStorageCapacitybyPool(Long poolId, short capacityType) {

// TODO: This method is for the API only, but it has configuration values (ramSize for system vms)

// so if this Utils class can have some kind of config rather than a static initializer (maybe from

// management server instantiation?) then maybe the management server method can be moved entirely

// into this utils class.

return s_ms.getMemoryOrCpuCapacityByHost(poolId, capacityType);

}

public static List<SummedCapacity> getCapacityByClusterPodZone(Long zoneId, Long podId, Long clusterId) {

return s_capacityDao.findByClusterPodZone(zoneId, podId, clusterId);

}

public static List<SummedCapacity> findNonSharedStorageForClusterPodZone(Long zoneId, Long podId, Long clusterId) {

return s_capacityDao.findNonSharedStorageForClusterPodZone(zoneId, podId, clusterId);

}

public static List<CapacityVO> getCapacityByPod() {

return null;

}

public static Long getPodIdForVlan(long vlanDbId) {

return s_networkModel.getPodIdForVlan(vlanDbId);

}

public static String getVersion() {

return s_ms.getVersion();

}

// ///////////////////////////////////////////////////////////

// Manager methods //

// ///////////////////////////////////////////////////////////

public static long findCorrectResourceLimitForDomain(ResourceType type, long domainId) {

DomainVO domain = s_domainDao.findById(domainId);

if (domain == null) {

return -1;

}

return s_resourceLimitMgr.findCorrectResourceLimitForDomain(domain, type, null);

}

public static long findCorrectResourceLimitForDomain(Long limit, boolean isRootDomain, ResourceType type, long domainId) {

long max = Resource.RESOURCE_UNLIMITED; // if resource limit is not found, then we treat it as unlimited

// No limits for Root domain

if (isRootDomain) {

return max;

}

if (limit != null) {

return limit.longValue();

} else {

return findCorrectResourceLimitForDomain(type, domainId);

}

}

public static long findCorrectResourceLimit(Long limit, long accountId, ResourceType type) {

return s_resourceLimitMgr.findCorrectResourceLimitForAccount(accountId, limit, type);

}

public static long findCorrectResourceLimitForDomain(Long limit, ResourceType resourceType, long domainId) {

//-- No limits for Root domain

if (domainId == Domain.ROOT_DOMAIN) {

return Resource.RESOURCE_UNLIMITED;

}

//--If limit doesn't have a value then fetch default limit from the configs

return (limit == null) ? s_resourceLimitMgr.findDefaultResourceLimitForDomain(resourceType) : limit;

}

public static long getResourceCount(ResourceType type, long accountId) {

AccountVO account = s_accountDao.findById(accountId);

if (account == null) {

return -1;

}

return s_resourceLimitMgr.getResourceCount(account, type, null);

}

public static String getSecurityGroupsNamesForVm(long vmId) {

return s_securityGroupMgr.getSecurityGroupsNamesForVm(vmId);