fix: cluster credentials to fit new schema

silverback/_cli.py

@@ -788,8 +788,8 @@ def registry():
 @cluster_client
 def credentials_list(cluster: "ClusterClient"):
     """List container registry credentials"""
-
-    if creds := list(cluster.registry_credentials):
+    
+    if creds := cluster.registry_credentials:
         click.echo(yaml.safe_dump(creds))
 
     else:
@@ -813,17 +813,22 @@ def credentials_info(cluster: "ClusterClient", name: str):
 @click.argument("registry")
 @cluster_client
 def credentials_new(cluster: "ClusterClient", name: str, registry: str):
-    """Add registry private registry credentials. This command will prompt you for a username and
-    password.
+    """Add registry private registry credentials. This command will prompt you for a username,
+    password, and email.
     """
 
     username = click.prompt("Username")
     password = click.prompt("Password", hide_input=True)
+    email = click.prompt("Email")
 
     creds = cluster.new_credentials(
-        name=name, hostname=registry, username=username, password=password
+        name=name,
+        docker_server=registry,
+        docker_username=username,
+        docker_password=password,
+        docker_email=email
     )
-    click.echo(yaml.safe_dump(creds.model_dump(exclude={"id"})))
+    click.echo(yaml.safe_dump(creds.model_dump()))
 
 
 @registry.command(name="update")
@@ -837,9 +842,15 @@ def credentials_update(cluster: "ClusterClient", name: str, registry: str | None
 
     username = click.prompt("Username")
     password = click.prompt("Password", hide_input=True)
+    email = click.prompt("Email")
 
-    creds = creds.update(hostname=registry, username=username, password=password)
-    click.echo(yaml.safe_dump(creds.model_dump(exclude={"id"})))
+    creds = creds.update(
+        docker_server=registry,
+        docker_username=username,
+        docker_password=password,
+        docker_email=email
+    )
+    click.echo(yaml.safe_dump(creds.model_dump()))
 
 
 @registry.command(name="remove")

silverback/cluster/client.py

@@ -7,7 +7,7 @@
 from ape.contracts import ContractInstance
 from ape.logging import LogLevel
 from apepay import Stream, StreamManager
-from pydantic import computed_field
+from pydantic import computed_field, ValidationError
 
 from silverback.exceptions import ClientError
 from silverback.version import version
@@ -73,19 +73,20 @@ def __hash__(self) -> int:
     def update(
         self,
         name: str | None = None,
-        hostname: str | None = None,
-        username: str | None = None,
-        password: str | None = None,
+        docker_server: str | None = None,
+        docker_username: str | None = None,
+        docker_password: str | None = None,
+        docker_email: str | None = None,
     ) -> "RegistryCredentials":
         response = self.cluster.put(
-            f"/credentials/{self.id}",
-            json=dict(name=name, hostname=hostname, username=username, password=password),
+            f"/credentials/{self.name}",
+            json=dict(name=name, docker_server=docker_server, docker_username=docker_username, docker_password=docker_password, docker_email=docker_email),
         )
         handle_error_with_response(response)
         return self
 
     def remove(self):
-        response = self.cluster.delete(f"/credentials/{self.id}")
+        response = self.cluster.delete(f"/credentials/{self.name}")
         handle_error_with_response(response)
 
 
@@ -267,19 +268,26 @@ def health(self) -> ClusterHealth:
     def registry_credentials(self) -> dict[str, RegistryCredentials]:
         response = self.get("/credentials")
         handle_error_with_response(response)
-        return {
-            creds.name: creds for creds in map(RegistryCredentials.model_validate, response.json())
-        }
+
+        return response.json()
 
     def new_credentials(
-        self, name: str, hostname: str, username: str, password: str
+        self, name: str, docker_server: str, docker_username: str, docker_password: str, docker_email: str
     ) -> RegistryCredentials:
-        response = self.post(
-            "/credentials",
-            json=dict(name=name, hostname=hostname, username=username, password=password),
-        )
+        form = dict(
+                name=name,
+                docker_server=docker_server,
+                docker_username=docker_username,
+                docker_password=docker_password,
+                docker_email=docker_email,
+            )
+        response = self.post("/credentials", json=form)
         handle_error_with_response(response)
-        return RegistryCredentials.model_validate(response.json())
+        try:
+            return RegistryCredentials.model_validate(response.json())
+        except ValidationError as e:
+            raise ClientError(f"Invalid response format: {e}")
+
 
     @property
     def variable_groups(self) -> dict[str, VariableGroup]:

silverback/cluster/types.py

@@ -328,11 +328,11 @@ def cluster(self) -> ServiceHealth:
 
 
 class RegistryCredentialsInfo(BaseModel):
-    id: str
     name: str
-    hostname: str
-    created: datetime
-    updated: datetime
+    docker_server: str
+    docker_username: str
+    docker_password: str
+    docker_email: str
 
 
 class VariableGroupInfo(BaseModel):