osm_common/temporal/activities/paas.py

   1 #######################################################################################
   2 # Copyright ETSI Contributors and Others.
   3 #
   4 # Licensed under the Apache License, Version 2.0 (the "License");
   5 # you may not use this file except in compliance with the License.
   6 # You may obtain a copy of the License at
   7 #
   8 #    http://www.apache.org/licenses/LICENSE-2.0
   9 #
  10 # Unless required by applicable law or agreed to in writing, software
  11 # distributed under the License is distributed on an "AS IS" BASIS,
  12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
  13 # implied.
  14 # See the License for the specific language governing permissions and
  15 # limitations under the License.
  16 #######################################################################################
  17
  18 from dataclasses import dataclass
  19
  20 from osm_common.dbbase import DbBase
  21 from osm_common.temporal.activities.base import BaseActivity
  22 from osm_common.temporal.dataclasses_common import CharmInfo, VduComputeConstraints
  23
  24
  25 class TestVimConnectivity(BaseActivity):
  26     """Validates the credentials by attempting to connect to the given Juju Controller.
  27
  28     Collaborators:
  29         Juju Controller:    Connect only
  30
  31     Raises  (Retryable):
  32         ApplicationError    If any of password, cacert, cloud_credentials is invalid
  33                             or Juju controller is not reachable
  34
  35     Activity Lifecycle:
  36         This activity should complete relatively quickly (in a few seconds).
  37         However, it would be reasonable to wait more than 72 seconds (network timeout)
  38         incase there are network issues.
  39
  40         This activity will not report a heartbeat due to its
  41         short-running nature.
  42
  43         It is recommended, although not necessary to implement a
  44         back-off strategy for this activity, as it will naturally block
  45         and wait on each connection attempt.
  46     """
  47
  48     @dataclass
  49     class Input:
  50         """
  51         Input dataclass for the Test Vim Connectivity Ativity
  52
  53         Attributes:
  54         -----------
  55         vim_uuid : str
  56             The UUID of the VIM account as stored in the OSM vim
  57             collection in Mongo
  58         """
  59
  60         vim_uuid: str
  61
  62     def __init__(self, juju_controller):
  63         super().__init__()
  64         self.juju_controller = juju_controller
  65
  66     async def __call__(self, activity_input: Input) -> None:
  67         raise NotImplementedError()
  68
  69
  70 class CreateModel(BaseActivity):
  71     """Connects to Juju Controller. Creates a new model.
  72
  73     Collaborators:
  74         DB Read:            vim_accounts
  75         Juju Controller:    Connect and create model.
  76
  77     Raises  (Retryable):
  78         ApplicationError    If Juju controller is not reachable.
  79                             If the model already exists.
  80
  81     Activity Lifecycle:
  82         This activity should complete relatively quickly (in a few seconds).
  83         However, it would be reasonable to wait more than 72 seconds (network timeout)
  84         incase there are network issues.
  85
  86         This activity will not report a heartbeat due to its
  87         short-running nature.
  88
  89         It is recommended, although not necessary to implement a
  90         back-off strategy for this activity, as it will naturally block
  91         and wait on each connection attempt.
  92     """
  93
  94     @dataclass
  95     class Input:
  96         """
  97         Contains the information related to a model.
  98
  99         Attributes:
 100         -----------
 101         vim_uuid : str
 102             The UUID of the VIM as stored in the OSM vim_accounts
 103             collection in Mongo.
 104
 105         model_name : str
 106             Name of the Juju model used to deploy charms.
 107         """
 108
 109         vim_uuid: str
 110         model_name: str
 111
 112     def __init__(self, db: DbBase, juju_controller):
 113         super().__init__()
 114         self.db: DbBase = db
 115         self.juju_controller = juju_controller
 116
 117     async def __call__(self, activity_input: Input) -> None:
 118         raise NotImplementedError()
 119
 120
 121 class DeployCharm(BaseActivity):
 122     """Deploys a charm.
 123
 124     Collaborators:
 125         Juju Controller:    Connect and deploy charm
 126
 127     Raises  (Retryable):
 128         ApplicationError    If Juju controller is not reachable
 129                             If application already exists
 130
 131     Activity Lifecycle:
 132         This activity should complete relatively quickly (in a few seconds).
 133         However, it would be reasonable to wait more than 72 seconds (network timeout)
 134         incase there are network issues.
 135
 136         This activity will not report a heartbeat due to its
 137         short-running nature.
 138
 139         It is recommended, although not necessary to implement a
 140         back-off strategy for this activity, as it will naturally block
 141         and wait on each connection attempt.
 142     """
 143
 144     @dataclass
 145     class Input:
 146         """
 147         Input dataclass for workflow that instantiates a VDU.
 148
 149         vim_uuid: str
 150
 151         model_name: str
 152
 153         charm_info : CharmInfo
 154
 155         constraints: VduComputeConstraints
 156
 157         cloud: VIM cloud type
 158
 159         config: Config details of application
 160         """
 161
 162         vim_uuid: str
 163         model_name: str
 164         charm_info: CharmInfo
 165         constraints: VduComputeConstraints
 166         cloud: str
 167         config: dict
 168
 169     def __init__(self, juju_controller):
 170         super().__init__()
 171         self.juju_controller = juju_controller
 172
 173     async def __call__(self, activity_input: Input) -> None:
 174         raise NotImplementedError()
 175
 176
 177 class CheckCharmStatus(BaseActivity):
 178     """Checks the ready status of the charm.  This activity will block until the status of
 179     the application is either "active" or "blocked".  Additionally, it also blocks until
 180     the workload status of each of its units is also either "active" or "blocked".
 181
 182     Collaborators:
 183         Juju Controller:    Connect to controller and check charm status.
 184
 185     Raises  (Retryable):
 186         ApplicationError    If any of password, cacert, cloud_credentials is invalid
 187                             or Juju controller is not reachable
 188
 189     Activity Lifecycle:
 190         This activity will continue indefinitely until the specified charm deployment
 191         has reached a ready state.  Heartbeats are performed to ensure this activity
 192         does not time out.
 193
 194         A start-to-close of something reasonable (such as 5 minutes) should be implemented
 195         at the workflow level and such a timeout shall trigger workflow failure logic.
 196     """
 197
 198     @dataclass
 199     class Input:
 200         """
 201         Input dataclass for checking on a specific charm's deployment
 202         status
 203
 204         Attributes:
 205         -----------
 206         vim_uuid : str
 207             The UUID of the VIM as stored in the OSM vim_accounts
 208             collection in Mongo.
 209
 210         model_name : str
 211             Name of the model to create in Juju.
 212
 213         application_name : str
 214             Name of the application that the state is going to be
 215             awaited.
 216
 217         poll_interval : int (optional)
 218             Time, in seconds, to wait between status checks.
 219         """
 220
 221         vim_uuid: str
 222         model_name: str
 223         application_name: str
 224         poll_interval: int = 1
 225
 226     def __init__(self, juju_controller):
 227         super().__init__()
 228         self.juju_controller = juju_controller
 229
 230     async def __call__(self, activity_input: Input) -> None:
 231         raise NotImplementedError()