feature: add support for dynamo v2 (ran-isenberg#798)

* feature: add support for dynamo v2 poetry update --------- Co-authored-by: Ran Isenberg <ran.isenberg@ranthebuilder.cloud>

Author: ran-isenberg

.github/workflows/main-serverless-service.yml

@@ -71,7 +71,7 @@ jobs:
  env:
  ENVIRONMENT: staging # Custom environment variable
  - name: Codecov
- uses: codecov/codecov-action@eaaf4bedf32dbdc6b720b63067d99c4d77d6047d # v3.1.4
+ uses: codecov/codecov-action@f30e4959ba63075080d4f7f90cacc18d9f3fafd7 # v4.0.0
  with:
  token: ${{ secrets.CODECOV_TOKEN }}
  files: ./coverage.xml

.github/workflows/pr-serverless-service.yml

@@ -92,7 +92,7 @@ jobs:
  - name: Code coverage tests
  run: make coverage-tests
  - name: Codecov
- uses: codecov/codecov-action@eaaf4bedf32dbdc6b720b63067d99c4d77d6047d # v3.1.4
+ uses: codecov/codecov-action@f30e4959ba63075080d4f7f90cacc18d9f3fafd7 # v4.0.0
  with:
  token: ${{ secrets.CODECOV_TOKEN }}
  files: ./coverage.xml

.github/workflows/scorecard.yml

@@ -59,7 +59,7 @@ jobs:
  # Upload the results as artifacts (optional). Commenting out will disable uploads of run results in SARIF
  # format to the repository Actions tab.
  - name: "Upload artifact"
- uses: actions/upload-artifact@c7d193f32edcb7bfad88892161225aeda64e9392 # v4.0.0
+ uses: actions/upload-artifact@26f96dfa697d77e81fd5907df203aa23a56210a8 # v4.3.0
  with:
  name: SARIF file
  path: results.sarif

.pre-commit-config.yaml

@@ -26,7 +26,7 @@ repos:
  exclude: "^(?!helpers/)"
  - repo: https://github.com/astral-sh/ruff-pre-commit
  # Ruff version.
- rev: v0.1.15
+ rev: v0.2.0
  hooks:
  # Run the Ruff linter.
  - id: ruff

cdk/service/api_construct.py

@@ -58,7 +58,7 @@ def _build_api_gw(self) -> aws_apigateway.RestApi:
  CfnOutput(self, id=constants.APIGATEWAY, value=rest_api.url).override_logical_id(constants.APIGATEWAY)
  return rest_api
 
- def _build_lambda_role(self, db: dynamodb.Table, idempotency_table: dynamodb.Table) -> iam.Role:
+ def _build_lambda_role(self, db: dynamodb.TableV2, idempotency_table: dynamodb.TableV2) -> iam.Role:
  return iam.Role(
  self,
  constants.SERVICE_ROLE_ARN,
@@ -107,7 +107,12 @@ def _build_common_layer(self) -> PythonLayerVersion:
  )
 
  def _add_post_lambda_integration(
- self, api_resource: aws_apigateway.Resource, role: iam.Role, db: dynamodb.Table, appconfig_app_name: str, idempotency_table: dynamodb.Table
+ self,
+ api_resource: aws_apigateway.Resource,
+ role: iam.Role,
+ db: dynamodb.TableV2,
+ appconfig_app_name: str,
+ idempotency_table: dynamodb.TableV2,
  ) -> _lambda.Function:
  lambda_function = _lambda.Function(
  self,

cdk/service/api_db_construct.py

@@ -9,17 +9,17 @@ class ApiDbConstruct(Construct):
  def __init__(self, scope: Construct, id_: str) -> None:
  super().__init__(scope, id_)
 
- self.db: dynamodb.Table = self._build_db(id_)
- self.idempotency_db: dynamodb.Table = self._build_idempotency_table(id_)
+ self.db: dynamodb.TableV2 = self._build_db(id_)
+ self.idempotency_db: dynamodb.TableV2 = self._build_idempotency_table(id_)
 
- def _build_idempotency_table(self, id_: str) -> dynamodb.Table:
+ def _build_idempotency_table(self, id_: str) -> dynamodb.TableV2:
  table_id = f'{id_}{constants.IDEMPOTENCY_TABLE_NAME}'
- table = dynamodb.Table(
+ table = dynamodb.TableV2(
  self,
  table_id,
  table_name=table_id,
  partition_key=dynamodb.Attribute(name='id', type=dynamodb.AttributeType.STRING),
- billing_mode=dynamodb.BillingMode.PAY_PER_REQUEST,
+ billing=dynamodb.Billing.on_demand(),
  removal_policy=RemovalPolicy.DESTROY,
  time_to_live_attribute='expiration',
  point_in_time_recovery=True,
@@ -29,14 +29,14 @@ def _build_idempotency_table(self, id_: str) -> dynamodb.Table:
  )
  return table
 
- def _build_db(self, id_prefix: str) -> dynamodb.Table:
+ def _build_db(self, id_prefix: str) -> dynamodb.TableV2:
  table_id = f'{id_prefix}{constants.TABLE_NAME}'
- table = dynamodb.Table(
+ table = dynamodb.TableV2(
  self,
  table_id,
  table_name=table_id,
  partition_key=dynamodb.Attribute(name='id', type=dynamodb.AttributeType.STRING),
- billing_mode=dynamodb.BillingMode.PAY_PER_REQUEST,
+ billing=dynamodb.Billing.on_demand(),
  point_in_time_recovery=True,
  removal_policy=RemovalPolicy.DESTROY,
  )

cdk/service/constants.py

@@ -2,8 +2,8 @@
 LAMBDA_BASIC_EXECUTION_ROLE = 'AWSLambdaBasicExecutionRole'
 SERVICE_ROLE = 'ServiceRole'
 CREATE_LAMBDA = 'CreateOrder'
-TABLE_NAME = 'ordersDb'
-IDEMPOTENCY_TABLE_NAME = 'IdempotencyTable'
+TABLE_NAME = 'orders'
+IDEMPOTENCY_TABLE_NAME = 'Idempotency'
 TABLE_NAME_OUTPUT = 'DbOutput'
 IDEMPOTENCY_TABLE_NAME_OUTPUT = 'IdempotencyDbOutput'
 APIGATEWAY = 'Apigateway'

cdk/service/monitoring.py

@@ -24,8 +24,8 @@ def __init__(
  scope: Construct,
  id_: str,
  crud_api: aws_apigateway.RestApi,
- db: dynamodb.Table,
- idempotency_table: dynamodb.Table,
+ db: dynamodb.TableV2,
+ idempotency_table: dynamodb.TableV2,
  functions: list[_lambda.Function],
  ) -> None:
  super().__init__(scope, id_)
@@ -84,7 +84,9 @@ def _build_high_level_dashboard(self, crud_api: aws_apigateway.RestApi, topic: s
  group = CustomMetricGroup(metrics=[create_metric], title='Daily Order Requests')
  high_level_facade.monitor_custom(metric_groups=[group], human_readable_name='Daily KPIs', alarm_friendly_name='KPIs')
 
- def _build_low_level_dashboard(self, db: dynamodb.Table, idempotency_table: dynamodb.Table, functions: list[_lambda.Function], topic: sns.Topic):
+ def _build_low_level_dashboard(
+ self, db: dynamodb.TableV2, idempotency_table: dynamodb.TableV2, functions: list[_lambda.Function], topic: sns.Topic
+ ):
  low_level_facade = MonitoringFacade(
  self,
  f'{self.id_}LowFacade',

docs/getting_started.md

@@ -77,8 +77,8 @@ If there's an error in the pre-commit stage, it gets auto fixed. However, are re
 Be sure to commit all the changes that ``make pr`` does for you.
 
 ## **OpenAPI Swagger Generation**
-Run either ``make pr`` or ``make openopi`` to generate an updated swagger OpenAPI JSON file and place it at docs/swagger/openapi.json location.
 
+Run either ``make pr`` or ``make openopi`` to generate an updated swagger OpenAPI JSON file and place it at docs/swagger/openapi.json location.
 
 ## **GitHub Pages Documentation**
 

docs/pipeline.md

@@ -55,7 +55,11 @@ The two most important ones are `pr-serverless-service` and `main-serverless-se
 
 It includes two jobs: 'quality_standards' and 'tests' where a failure in 'quality_standards' does not trigger 'tests'. Both jobs MUST pass in order to to be able to merge.
 
-'quality_standards' includes all linters, pre-commit checks and units tests and 'tests' deploys the service to AWS, runs code coverage checks, checks that your OpenAPI file is up to date and corresponds to the actual deployment (fails if it does not, hence your documentation is out of date), security checks and E2E tests. Stack is destroyed at the end. Stack has a 'dev' prefix as part of its name. Each environment has a pre-defined stack prefix.
+'quality_standards' includes all linters, pre-commit checks and units tests and 'tests' deploys the service to AWS, runs code coverage checks,
+
+checks that your OpenAPI file is up to date and corresponds to the actual deployment (fails if it does not, hence your documentation is out of date), security checks and E2E tests. Stack is destroyed at the end. Stack has a 'dev'
+
+prefix as part of its name. Each environment has a pre-defined stack prefix.
 
 Once merged, `main-serverless-service` will run.