feat: event gateway static keys

internal/cmd/root/products/konnect/declarative/declarative.go

@@ -2291,6 +2291,7 @@ func createStateClient(kkClient helpers.SDKAPI) *state.Client {
 		EventGatewayProducePolicyAPI:        kkClient.GetEventGatewayProducePolicyAPI(),
 		EventGatewayConsumePolicyAPI:        kkClient.GetEventGatewayConsumePolicyAPI(),
 		EventGatewaySchemaRegistryAPI:       kkClient.GetEventGatewaySchemaRegistryAPI(),
+		EventGatewayStaticKeyAPI:            kkClient.GetEventGatewayStaticKeyAPI(),
 		// Organization APIs
 		OrganizationTeamAPI: kkClient.GetOrganizationTeamAPI(),
 	})

internal/cmd/root/products/konnect/eventgateway/child_common.go

@@ -47,6 +47,12 @@ const (
 	schemaRegistryIDConfigPath   = "konnect.event-gateway.schema-registry.id"
 	schemaRegistryNameConfigPath = "konnect.event-gateway.schema-registry.name"
 
+	staticKeyIDFlagName   = "static-key-id"
+	staticKeyNameFlagName = "static-key-name"
+
+	staticKeyIDConfigPath   = "konnect.event-gateway.static-key.id"
+	staticKeyNameConfigPath = "konnect.event-gateway.static-key.name"
+
 	valueNA = "n/a"
 )
 
@@ -277,6 +283,42 @@ func getSchemaRegistryIdentifiers(cfg config.Hook) (id string, name string) {
 	return cfg.GetString(schemaRegistryIDConfigPath), cfg.GetString(schemaRegistryNameConfigPath)
 }
 
+func addStaticKeyChildFlags(cmd *cobra.Command) {
+	cmd.Flags().String(staticKeyIDFlagName, "",
+		fmt.Sprintf(`The ID of the static key to retrieve.
+- Config path: [ %s ]`, staticKeyIDConfigPath))
+	cmd.Flags().String(staticKeyNameFlagName, "",
+		fmt.Sprintf(`The name of the static key to retrieve.
+- Config path: [ %s ]`, staticKeyNameConfigPath))
+	cmd.MarkFlagsMutuallyExclusive(staticKeyIDFlagName, staticKeyNameFlagName)
+}
+
+func bindStaticKeyChildFlags(c *cobra.Command, args []string) error {
+	helper := cmd.BuildHelper(c, args)
+	cfg, err := helper.GetConfig()
+	if err != nil {
+		return err
+	}
+
+	if flag := c.Flags().Lookup(staticKeyIDFlagName); flag != nil {
+		if err := cfg.BindFlag(staticKeyIDConfigPath, flag); err != nil {
+			return err
+		}
+	}
+
+	if flag := c.Flags().Lookup(staticKeyNameFlagName); flag != nil {
+		if err := cfg.BindFlag(staticKeyNameConfigPath, flag); err != nil {
+			return err
+		}
+	}
+
+	return nil
+}
+
+func getStaticKeyIdentifiers(cfg config.Hook) (id string, name string) {
+	return cfg.GetString(staticKeyIDConfigPath), cfg.GetString(staticKeyNameConfigPath)
+}
+
 func resolveEventGatewayIDByName(
 	name string,
 	gatewayClient helpers.EGWControlPlaneAPI,

internal/cmd/root/products/konnect/eventgateway/getEventGateway.go

@@ -525,6 +525,11 @@ func newGetEventGatewayControlPlaneCmd(verb verbs.VerbValue,
 		rv.AddCommand(schemaRegistriesCmd)
 	}
 
+	staticKeysCmd := newGetEventGatewayStaticKeysCmd(verb, addParentFlags, parentPreRun)
+	if staticKeysCmd != nil {
+		rv.AddCommand(staticKeysCmd)
+	}
+
 	listenerPoliciesCmd := newGetEventGatewayListenerPoliciesCmd(verb, addParentFlags, parentPreRun)
 	if listenerPoliciesCmd != nil {
 		rv.AddCommand(listenerPoliciesCmd)

internal/cmd/root/products/konnect/eventgateway/interactive_children.go

@@ -20,6 +20,7 @@ func init() {
 	tableview.RegisterChildLoader("event-gateway", "data-plane-certificates", loadEventGatewayDataPlaneCertificates)
 	tableview.RegisterChildLoader("event-gateway", "listeners", loadEventGatewayListeners)
 	tableview.RegisterChildLoader("event-gateway", "schema-registries", loadEventGatewaySchemaRegistries)
+	tableview.RegisterChildLoader("event-gateway", "static-keys", loadEventGatewayStaticKeys)
 	tableview.RegisterChildLoader("listener", "policies", loadEventGatewayListenerPolicies)
 	tableview.RegisterChildLoader("virtual-cluster", "cluster-policies", loadEventGatewayVirtualClusterClusterPolicies)
 	tableview.RegisterChildLoader("virtual-cluster", "produce-policies", loadEventGatewayVirtualClusterProducePolicies)
@@ -448,3 +449,41 @@ func loadEventGatewaySchemaRegistries(
 
 	return buildSchemaRegistryChildView(registries), nil
 }
+
+func loadEventGatewayStaticKeys(
+	_ context.Context,
+	helper cmd.Helper,
+	parent any,
+) (tableview.ChildView, error) {
+	gatewayID, err := eventGatewayIDFromParent(parent)
+	if err != nil {
+		return tableview.ChildView{}, err
+	}
+
+	cfg, err := helper.GetConfig()
+	if err != nil {
+		return tableview.ChildView{}, err
+	}
+
+	logger, err := helper.GetLogger()
+	if err != nil {
+		return tableview.ChildView{}, err
+	}
+
+	sdk, err := helper.GetKonnectSDK(cfg, logger)
+	if err != nil {
+		return tableview.ChildView{}, err
+	}
+
+	staticKeyAPI := sdk.GetEventGatewayStaticKeyAPI()
+	if staticKeyAPI == nil {
+		return tableview.ChildView{}, fmt.Errorf("event gateway static key client is not available")
+	}
+
+	keys, err := fetchStaticKeys(helper, staticKeyAPI, gatewayID, cfg, "")
+	if err != nil {
+		return tableview.ChildView{}, err
+	}
+
+	return buildStaticKeyChildView(keys), nil
+}