|
85 | 85 | import org.apache.commons.lang3.StringUtils; |
86 | 86 | import org.apache.log4j.Logger; |
87 | 87 | import org.jetbrains.annotations.NotNull; |
| 88 | +import org.springframework.beans.factory.NoSuchBeanDefinitionException; |
88 | 89 |
|
89 | 90 | import com.cloud.api.ApiDBUtils; |
90 | 91 | import com.cloud.api.auth.SetupUserTwoFactorAuthenticationCmd; |
|
172 | 173 | import com.cloud.utils.NumbersUtil; |
173 | 174 | import com.cloud.utils.Pair; |
174 | 175 | import com.cloud.utils.Ternary; |
| 176 | +import com.cloud.utils.component.ComponentContext; |
175 | 177 | import com.cloud.utils.component.Manager; |
176 | 178 | import com.cloud.utils.component.ManagerBase; |
177 | 179 | import com.cloud.utils.component.PluggableService; |
@@ -302,8 +304,6 @@ public class AccountManagerImpl extends ManagerBase implements AccountManager, M |
302 | 304 | private UserDataDao userDataDao; |
303 | 305 | @Inject |
304 | 306 | private NetworkPermissionDao networkPermissionDao; |
305 | | - @Inject |
306 | | - KubernetesServiceHelper kubernetesServiceHelper; |
307 | 307 |
|
308 | 308 | private List<QuerySelector> _querySelectors; |
309 | 309 |
|
@@ -851,6 +851,16 @@ public boolean deleteAccount(AccountVO account, long callerUserId, Account calle |
851 | 851 | return cleanupAccount(account, callerUserId, caller); |
852 | 852 | } |
853 | 853 |
|
| 854 | + protected void cleanupPluginsResourcesIfNeeded(Account account) { |
| 855 | + try { |
| 856 | + KubernetesServiceHelper kubernetesServiceHelper = |
| 857 | + ComponentContext.getDelegateComponentOfType(KubernetesServiceHelper.class); |
| 858 | + kubernetesServiceHelper.cleanupForAccount(account); |
| 859 | + } catch (NoSuchBeanDefinitionException ignored) { |
| 860 | + s_logger.debug("No KubernetesServiceHelper bean found"); |
| 861 | + } |
| 862 | + } |
| 863 | + |
854 | 864 | protected boolean cleanupAccount(AccountVO account, long callerUserId, Account caller) { |
855 | 865 | long accountId = account.getId(); |
856 | 866 | boolean accountCleanupNeeded = false; |
@@ -932,7 +942,7 @@ protected boolean cleanupAccount(AccountVO account, long callerUserId, Account c |
932 | 942 | } |
933 | 943 | } |
934 | 944 |
|
935 | | - kubernetesServiceHelper.cleanupForAccount(account); |
| 945 | + cleanupPluginsResourcesIfNeeded(account); |
936 | 946 |
|
937 | 947 | // Destroy the account's VMs |
938 | 948 | List<UserVmVO> vms = _userVmDao.listByAccountId(accountId); |
|
0 commit comments