feat(mnq): add AMQP credentials (#26)

scaleway · Jul 26, 2022 · bb5eac7 · bb5eac7
1 parent 38905d8
commit bb5eac7
Show file tree

Hide file tree

Showing 2 changed files with 66 additions and 3 deletions.
diff --git a/packages/clients/src/api/mnq/v1alpha1/marshalling.gen.ts b/packages/clients/src/api/mnq/v1alpha1/marshalling.gen.ts
@@ -10,9 +10,11 @@ import type {
   CreateCredentialRequest,
   CreateNamespaceRequest,
   Credential,
+  CredentialAMQPCreds,
   CredentialNATSCredsFile,
   CredentialSQSSNSCreds,
   CredentialSummary,
+  CredentialSummaryAMQPCreds,
   CredentialSummarySQSSNSCreds,
   ListCredentialsResponse,
   ListNamespacesResponse,
@@ -36,6 +38,21 @@ const unmarshalPermissions = (data: unknown) => {
   } as Permissions
 }
 
+const unmarshalCredentialSummaryAMQPCreds = (data: unknown) => {
+  if (!isJSONObject(data)) {
+    throw new TypeError(
+      `Unmarshalling the type 'CredentialSummaryAMQPCreds' failed as data isn't a dictionary.`,
+    )
+  }
+
+  return {
+    permissions: data.permissions
+      ? unmarshalPermissions(data.permissions)
+      : undefined,
+    username: data.username,
+  } as CredentialSummaryAMQPCreds
+}
+
 const unmarshalCredentialSummarySQSSNSCreds = (data: unknown) => {
   if (!isJSONObject(data)) {
     throw new TypeError(
@@ -51,6 +68,22 @@ const unmarshalCredentialSummarySQSSNSCreds = (data: unknown) => {
   } as CredentialSummarySQSSNSCreds
 }
 
+const unmarshalCredentialAMQPCreds = (data: unknown) => {
+  if (!isJSONObject(data)) {
+    throw new TypeError(
+      `Unmarshalling the type 'CredentialAMQPCreds' failed as data isn't a dictionary.`,
+    )
+  }
+
+  return {
+    password: data.password,
+    permissions: data.permissions
+      ? unmarshalPermissions(data.permissions)
+      : undefined,
+    username: data.username,
+  } as CredentialAMQPCreds
+}
+
 const unmarshalCredentialNATSCredsFile = (data: unknown) => {
   if (!isJSONObject(data)) {
     throw new TypeError(
@@ -85,6 +118,9 @@ const unmarshalCredentialSummary = (data: unknown) => {
   }
 
   return {
+    amqpCredentials: data.amqp_credentials
+      ? unmarshalCredentialSummaryAMQPCreds(data.amqp_credentials)
+      : undefined,
     id: data.id,
     name: data.name,
     namespaceId: data.namespace_id,
@@ -120,6 +156,9 @@ export const unmarshalCredential = (data: unknown) => {
   }
 
   return {
+    amqpCredentials: data.amqp_credentials
+      ? unmarshalCredentialAMQPCreds(data.amqp_credentials)
+      : undefined,
     id: data.id,
     name: data.name,
     namespaceId: data.namespace_id,

diff --git a/packages/clients/src/api/mnq/v1alpha1/types.gen.ts b/packages/clients/src/api/mnq/v1alpha1/types.gen.ts
@@ -25,14 +25,25 @@ export interface Credential {
   protocol: NamespaceProtocol
   /**
    * One-of ('credentialType'): at most one of 'natsCredentials',
-   * 'sqsSnsCredentials' could be set.
+   * 'sqsSnsCredentials', 'amqpCredentials' could be set.
    */
   natsCredentials?: CredentialNATSCredsFile
   /**
    * One-of ('credentialType'): at most one of 'natsCredentials',
-   * 'sqsSnsCredentials' could be set.
+   * 'sqsSnsCredentials', 'amqpCredentials' could be set.
    */
   sqsSnsCredentials?: CredentialSQSSNSCreds
+  /**
+   * One-of ('credentialType'): at most one of 'natsCredentials',
+   * 'sqsSnsCredentials', 'amqpCredentials' could be set.
+   */
+  amqpCredentials?: CredentialAMQPCreds
+}
+
+export interface CredentialAMQPCreds {
+  username: string
+  password?: string
+  permissions?: Permissions
 }
 
 export interface CredentialNATSCredsFile {
@@ -50,8 +61,21 @@ export interface CredentialSummary {
   name: string
   namespaceId: string
   protocol: NamespaceProtocol
-  /** One-of ('credentialType'): at most one of 'sqsSnsCredentials' could be set. */
+  /**
+   * One-of ('credentialType'): at most one of 'sqsSnsCredentials',
+   * 'amqpCredentials' could be set.
+   */
   sqsSnsCredentials?: CredentialSummarySQSSNSCreds
+  /**
+   * One-of ('credentialType'): at most one of 'sqsSnsCredentials',
+   * 'amqpCredentials' could be set.
+   */
+  amqpCredentials?: CredentialSummaryAMQPCreds
+}
+
+export interface CredentialSummaryAMQPCreds {
+  username: string
+  permissions?: Permissions
 }
 
 export interface CredentialSummarySQSSNSCreds {