fix(apisix): store stream route name correctly

apps/cli/src/linter/schema.ts

@@ -218,12 +218,7 @@ const serviceSchema = z
 
     upstream: upstreamSchema.optional(),
     plugins: pluginsSchema.optional(),
-    path_prefix: z
-      .string()
-      .optional()
-      .refine((val) => val?.startsWith('/'), {
-        message: 'Path prefix must start with "/"',
-      }),
+    path_prefix: z.string().optional(),
     strip_path_prefix: z.boolean().optional(),
     hosts: z.array(z.string()).optional(),
 
@@ -237,6 +232,15 @@ const serviceSchema = z
       message:
         'HTTP routes and Stream routes are mutually exclusive and should not exist in the same service',
     },
+  )
+  .refine(
+    (val) => {
+      if (!val.path_prefix) return true;
+      return val.path_prefix.startsWith('/');
+    },
+    {
+      message: 'Path prefix must start with "/"',
+    },
   );
 
 const sslSchema = z

libs/backend-apisix/src/transformer.ts

@@ -1,9 +1,20 @@
 import * as ADCSDK from '@api7/adc-sdk';
-import { isEmpty, unset } from 'lodash';
+import { filter, isEmpty, unset } from 'lodash';
 
 import * as typing from './typing';
 
 export class ToADC {
+  private static transformLabels(labels?: ADCSDK.Labels): ADCSDK.Labels {
+    if (!labels) return undefined;
+    const filteredLabels = filter(
+      labels,
+      (val, key) => key !== '__ADC_NAME',
+    ) as unknown as ADCSDK.Labels;
+    return Object.values(filteredLabels).length > 0
+      ? filteredLabels
+      : undefined;
+  }
+
   public transformRoute(route: typing.Route): ADCSDK.Route {
     return ADCSDK.utils.recursiveOmitUndefined({
       name: route.name ?? route.id,
@@ -120,9 +131,9 @@ export class ToADC {
     streamRoute: typing.StreamRoute,
   ): ADCSDK.StreamRoute {
     return ADCSDK.utils.recursiveOmitUndefined({
-      name: streamRoute.name ?? streamRoute.id,
+      name: streamRoute.labels?.__ADC_NAME ?? streamRoute.id,
       description: streamRoute.desc,
-      labels: streamRoute.labels,
+      labels: ToADC.transformLabels(streamRoute.labels),
 
       remote_addr: streamRoute.remote_addr,
       server_addr: streamRoute.server_addr,
@@ -343,10 +354,18 @@ export class FromADC {
     streamRoute: ADCSDK.StreamRoute,
   ): typing.StreamRoute {
     return ADCSDK.utils.recursiveOmitUndefined({
-      ...streamRoute,
       id: undefined,
-      labels: FromADC.transformLabels(streamRoute.labels),
-    });
+      desc: streamRoute.description,
+      labels: {
+        ...FromADC.transformLabels(streamRoute.labels),
+        __ADC_NAME: streamRoute.name,
+      },
+      plugins: streamRoute.plugins,
+      remote_addr: streamRoute.remote_addr,
+      server_addr: streamRoute.server_addr,
+      server_port: streamRoute.server_port,
+      sni: streamRoute.sni,
+    } as typing.StreamRoute);
   }
 
   public transformUpstream(upstream: ADCSDK.Upstream): typing.Upstream {

libs/backend-apisix/src/typing.ts

@@ -108,7 +108,7 @@ export interface StreamRoute {
   id: string;
   desc?: string;
   labels?: Labels;
-  name: string;
+  //name: string; // As of 3.9.1, APISIX does not support name on the stream route
 
   remote_addr?: string;
   server_addr?: string;

schema.json

@@ -230,6 +230,9 @@
                     "additionalProperties": false
                   }
                 },
+                "required": [
+                  "active"
+                ],
                 "additionalProperties": false
               },
               "nodes": {
@@ -538,8 +541,7 @@
           }
         },
         "required": [
-          "name",
-          "path_prefix"
+          "name"
         ],
         "additionalProperties": false
       }