X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fadapter%2Focloud_repository.py;h=8b54f53fa6f19e05a5b4d6050bef194c1849665a;hb=209f349b35b0919ac133bc2264f25753a73e5b8f;hp=bd147221092135f7c703ad51e97eff1f8a9cedf5;hpb=f2998d71e3fe6c455d5ea5070866d927e59a65c9;p=pti%2Fo2.git diff --git a/o2ims/adapter/ocloud_repository.py b/o2ims/adapter/ocloud_repository.py index bd14722..8b54f53 100644 --- a/o2ims/adapter/ocloud_repository.py +++ b/o2ims/adapter/ocloud_repository.py @@ -14,11 +14,11 @@ from typing import List -from o2ims.domain import ocloud, subscription_obj +from o2ims.domain import ocloud, subscription_obj, configuration_obj from o2ims.domain.ocloud_repo import OcloudRepository, ResourceTypeRepository,\ ResourcePoolRepository, ResourceRepository, DeploymentManagerRepository -from o2ims.domain.subscription_repo import SubscriptionRepository, \ - RegistrationRepository +from o2ims.domain.subscription_repo import SubscriptionRepository +from o2ims.domain.configuration_repo import ConfigurationRepository from o2common.helper import o2logging logger = o2logging.get_logger(__name__) @@ -162,24 +162,24 @@ class SubscriptionSqlAlchemyRepository(SubscriptionRepository): subscriptionId=subscription_id).delete() -class RegistrationSqlAlchemyRepository(RegistrationRepository): +class ConfigurationSqlAlchemyRepository(ConfigurationRepository): def __init__(self, session): super().__init__() self.session = session - def _add(self, registration: subscription_obj.Registration): - self.session.add(registration) + def _add(self, configuration: configuration_obj.Configuration): + self.session.add(configuration) - def _get(self, registration_id) -> subscription_obj.Registration: - return self.session.query(subscription_obj.Registration).filter_by( - registrationId=registration_id).first() + def _get(self, configuration_id) -> configuration_obj.Configuration: + return self.session.query(configuration_obj.Configuration).filter_by( + configurationId=configuration_id).first() - def _list(self) -> List[subscription_obj.Registration]: - return self.session.query(subscription_obj.Registration) + def _list(self) -> List[configuration_obj.Configuration]: + return self.session.query(configuration_obj.Configuration) - def _update(self, registration: subscription_obj.Registration): - self.session.add(registration) + def _update(self, configuration: configuration_obj.Configuration): + self.session.add(configuration) - def _delete(self, registration_id): - self.session.query(subscription_obj.Registration).filter_by( - registrationId=registration_id).delete() + def _delete(self, configuration_id): + self.session.query(configuration_obj.Configuration).filter_by( + configurationId=configuration_id).delete()