Added s3_endpoint_alias to all events communicating bucket_id/object_id

ghga_event_schemas/__init__.py

@@ -15,4 +15,4 @@
 
 """A package that collects schemas used for events exchanges between GHGA service."""
 
-__version__ = "0.13.4"
+__version__ = "0.13.5"

ghga_event_schemas/pydantic_.py

@@ -172,6 +172,11 @@ class FileUploadReceived(UploadDateModel):
     bucket_id: str = Field(
         ..., description="The ID/name of the S3 bucket used to store the file."
     )
+    s3_endpoint_alias: str = Field(
+        ...,
+        description="Alias for the object storage location where the given object is stored."
+        + "This can be uniquely mapped to a corresponding endpoint URL in the configuration.",
+    )
     submitter_public_key: str = Field(
         ...,
         description="The public key of the submitter.",
@@ -208,6 +213,11 @@ class FileUploadValidationSuccess(UploadDateModel):
     bucket_id: str = Field(
         ..., description="The ID/name of the S3 bucket used to store the file."
     )
+    s3_endpoint_alias: str = Field(
+        ...,
+        description="Alias for the object storage location where the given object is stored."
+        + "This can be uniquely mapped to a corresponding endpoint URL in the configuration.",
+    )
     decrypted_size: int = Field(
         ...,
         description="The size of the entire decrypted file content in bytes.",
@@ -275,6 +285,11 @@ class FileUploadValidationFailure(UploadDateModel):
         ...,
         description="The ID/name of the S3 bucket used to store the file.",
     )
+    s3_endpoint_alias: str = Field(
+        ...,
+        description="Alias for the object storage location where the given object is stored."
+        + "This can be uniquely mapped to a corresponding endpoint URL in the configuration.",
+    )
     reason: str = Field(
         ...,
         description="The reason why the validation failed.",
@@ -339,6 +354,11 @@ class NonStagedFileRequested(BaseModel):
         ...,
         description="The ID/name of the S3 bucket in which the object was expected.",
     )
+    s3_endpoint_alias: str = Field(
+        ...,
+        description="Alias for the object storage location where the given object is stored."
+        + "This can be uniquely mapped to a corresponding endpoint URL in the configuration.",
+    )
     decrypted_sha256: str = Field(
         ...,
         description="The SHA-256 checksum of the entire decrypted file content.",