feat: add consumer credential operator

api7 · Sep 1, 2024 · 6507dd3 · 6507dd3
1 parent 796c348
commit 6507dd3
Showing 1 changed file with 32 additions and 0 deletions.
diff --git a/libs/backend-api7/src/operator.ts b/libs/backend-api7/src/operator.ts
@@ -53,6 +53,20 @@ export class Operator {
             { validateStatus: () => true },
           );
           task.output = buildReqAndRespDebugOutput(resp);
+        } else if (
+          event.resourceType === ADCSDK.ResourceType.CONSUMER_CREDENTIAL
+        ) {
+          resp = await this.client.put(
+            `/apisix/admin/consumers/${event.parentId}/credentials/${event.resourceId}`,
+            this.fromADC(event),
+            {
+              params: {
+                gateway_group_id: ctx.gatewayGroupId,
+              },
+              validateStatus: () => true,
+            },
+          );
+          task.output = buildReqAndRespDebugOutput(resp);
         } else {
           resp = await this.client.put(
             `/apisix/admin/${this.generateResourceTypeInAPI(event.resourceType)}/${event.resourceId}`,
@@ -152,6 +166,20 @@ export class Operator {
           );
           task.output = buildReqAndRespDebugOutput(resp);
           return;
+        } else if (
+          event.resourceType === ADCSDK.ResourceType.CONSUMER_CREDENTIAL
+        ) {
+          const resp = await this.client.delete(
+            `/apisix/admin/consumers/${event.parentId}/credentials/${event.resourceId}`,
+            {
+              params: {
+                gateway_group_id: ctx.gatewayGroupId,
+              },
+              validateStatus: () => true,
+            },
+          );
+          task.output = buildReqAndRespDebugOutput(resp);
+          return;
         }
 
         const resp = await this.client.delete(
@@ -258,6 +286,10 @@ export class Operator {
         );
       case ADCSDK.ResourceType.SSL:
         return fromADC.transformSSL(event.newValue as ADCSDK.SSL);
+      case ADCSDK.ResourceType.CONSUMER_CREDENTIAL:
+        return fromADC.transformConsumerCredential(
+          event.newValue as ADCSDK.ConsumerCredential,
+        );
     }
   }
 }