refactor: update GetParameterValueForWatch to accept a watch flag and adjust templates accordingly

lqlive · lqlive · commit 38c7ae7561f5 · 2025-09-12T17:54:40.000+08:00
diff --git a/src/LibKubernetesGenerator/ParamHelper.cs b/src/LibKubernetesGenerator/ParamHelper.cs
@@ -23,7 +23,7 @@ public void RegisterHelper(ScriptObject scriptObject)
             scriptObject.Import(nameof(GetModelCtorParam), new Func<JsonSchema, string>(GetModelCtorParam));
             scriptObject.Import(nameof(IfParamContains), IfParamContains);
             scriptObject.Import(nameof(FilterParameters), FilterParameters);
-            scriptObject.Import(nameof(GetParameterValueForWatch), new Func<OpenApiParameter, string>(GetParameterValueForWatch));
+            scriptObject.Import(nameof(GetParameterValueForWatch), new Func<OpenApiParameter, bool, string>(GetParameterValueForWatch));
         }
 
         public static bool IfParamContains(OpenApiOperation operation, string name)
@@ -47,11 +47,11 @@ public static IEnumerable<OpenApiParameter> FilterParameters(OpenApiOperation op
             return operation.Parameters.Where(p => p.Name != excludeParam);
         }
 
-        public string GetParameterValueForWatch(OpenApiParameter parameter)
+        public string GetParameterValueForWatch(OpenApiParameter parameter, bool watch)
         {
             if (parameter.Name == "watch")
             {
-                return "true";
+                return watch ? "true" : "false";
             }
             else
             {
diff --git a/src/LibKubernetesGenerator/templates/Client.cs.template b/src/LibKubernetesGenerator/templates/Client.cs.template
@@ -38,7 +38,7 @@ public partial class {{name}}Client : ResourceClient
         {{if IfReturnType api.operation "stream"}}
         var _result = await Client.{{group}}.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
             {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
             {{end}}
             null,
             cancellationToken);
@@ -48,7 +48,7 @@ public partial class {{name}}Client : ResourceClient
         {{if IfReturnType api.operation "obj"}}
         using (var _result = await Client.{{group}}.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
             {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
             {{end}}
             null,
             cancellationToken).ConfigureAwait(false))
@@ -59,7 +59,7 @@ public partial class {{name}}Client : ResourceClient
         {{if IfReturnType api.operation "void"}}
         using (var _result = await Client.{{group}}.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
             {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
             {{end}}
             null,
             cancellationToken).ConfigureAwait(false))
@@ -88,7 +88,7 @@ public partial class {{name}}Client : ResourceClient
     {
         using (var _result = await Client.{{group}}.{{GetOperationId api.operation "WithHttpMessagesAsync"}}<T>(
             {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
             {{end}}
             null,
             cancellationToken).ConfigureAwait(false))
@@ -122,7 +122,7 @@ public partial class {{name}}Client : ResourceClient
 
         var responseTask = Client.{{group}}.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
             {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter true}},
             {{ end }}
             null,
             CancellationToken.None);
@@ -150,7 +150,7 @@ public partial class {{name}}Client : ResourceClient
     {
         var responseTask = Client.{{group}}.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
             {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter true}},
             {{ end }}
             null,
             cancellationToken);
diff --git a/src/LibKubernetesGenerator/templates/OperationsExtensions.cs.template b/src/LibKubernetesGenerator/templates/OperationsExtensions.cs.template
@@ -91,7 +91,7 @@ public static partial class {{name}}OperationsExtensions
         {{if IfReturnType api.operation "stream"}}
         var _result = await operations.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
 {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
 {{end}}
             null,
             cancellationToken);
@@ -101,7 +101,7 @@ public static partial class {{name}}OperationsExtensions
         {{if IfReturnType api.operation "obj"}}
         using (var _result = await operations.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
 {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
 {{end}}
             null,
             cancellationToken).ConfigureAwait(false))
@@ -112,7 +112,7 @@ public static partial class {{name}}OperationsExtensions
         {{if IfReturnType api.operation "void"}}
         using (var _result = await operations.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
 {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
 {{end}}
             null,
             cancellationToken).ConfigureAwait(false))
@@ -145,7 +145,7 @@ public static partial class {{name}}OperationsExtensions
     {
         using (var _result = await operations.{{GetOperationId api.operation "WithHttpMessagesAsync"}}<T>(
 {{ for parameter in api.operation.parameters}}
-            {{GetParameterValueForWatch parameter}},
+            {{GetParameterValueForWatch parameter false}},
 {{end}}
             null,
             cancellationToken).ConfigureAwait(false))
@@ -184,7 +184,7 @@ public static Watcher<{{GetReturnType api.operation "T"}}> Watch{{GetOperationId
 
     var responseTask = operations.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
 {{ for parameter in api.operation.parameters}}
-        {{GetParameterValueForWatch parameter}},
+        {{GetParameterValueForWatch parameter true}},
 {{end}}
         null,
         CancellationToken.None);
@@ -216,7 +216,7 @@ public static IAsyncEnumerable<(WatchEventType, {{GetReturnType api.operation "T
 {
     var responseTask = operations.{{GetOperationId api.operation "WithHttpMessagesAsync"}}(
 {{ for parameter in api.operation.parameters}}
-        {{GetParameterValueForWatch parameter}},
+        {{GetParameterValueForWatch parameter true}},
 {{end}}
         null,
         cancellationToken);

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@ public void RegisterHelper(ScriptObject scriptObject)`
`23`	`23`	`scriptObject.Import(nameof(GetModelCtorParam), new Func<JsonSchema, string>(GetModelCtorParam));`
`24`	`24`	`scriptObject.Import(nameof(IfParamContains), IfParamContains);`
`25`	`25`	`scriptObject.Import(nameof(FilterParameters), FilterParameters);`
`26`		`- scriptObject.Import(nameof(GetParameterValueForWatch), new Func<OpenApiParameter, string>(GetParameterValueForWatch));`
	`26`	`+ scriptObject.Import(nameof(GetParameterValueForWatch), new Func<OpenApiParameter, bool, string>(GetParameterValueForWatch));`
`27`	`27`	`}`
`28`	`28`
`29`	`29`	`public static bool IfParamContains(OpenApiOperation operation, string name)`
`@@ -47,11 +47,11 @@ public static IEnumerable<OpenApiParameter> FilterParameters(OpenApiOperation op`
`47`	`47`	`return operation.Parameters.Where(p => p.Name != excludeParam);`
`48`	`48`	`}`
`49`	`49`
`50`		`- public string GetParameterValueForWatch(OpenApiParameter parameter)`
	`50`	`+ public string GetParameterValueForWatch(OpenApiParameter parameter, bool watch)`
`51`	`51`	`{`
`52`	`52`	`if (parameter.Name == "watch")`
`53`	`53`	`{`
`54`		`- return "true";`
	`54`	`+ return watch ? "true" : "false";`
`55`	`55`	`}`
`56`	`56`	`else`
`57`	`57`	`{`