update service registry client

Author: v1r3n

conductor-client/src/main/java/com/netflix/conductor/common/model/AuthMetadata.java

@@ -0,0 +1,25 @@
+/*
+ * Copyright 2025 Conductor Authors.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package com.netflix.conductor.common.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class AuthMetadata {
+    private String key;
+    private String value;
+}

conductor-client/src/main/java/com/netflix/conductor/common/model/ServiceMethod.java

@@ -23,9 +23,13 @@ public class ServiceMethod {
     private Long id;
     private String operationName;
     private String methodName;
-    private String methodType;  //GET, PUT, POST, UNARY, SERVER_STREAMING etc.
+    private String methodType; // GET, PUT, POST, UNARY, SERVER_STREAMING etc.
     private String inputType;
     private String outputType;
+    private Boolean deprecated;
+    private String requestContentType;
+    private String responseContentType;
+    private String description;
 
     // Add request parameters
     private List<RequestParam> requestParams = new ArrayList<>();

conductor-client/src/main/java/com/netflix/conductor/common/model/ServiceRegistry.java

@@ -31,6 +31,8 @@ public class ServiceRegistry {
     private List<RequestParam> requestParams = new ArrayList<>();
     private Config config = new Config();
     private boolean circuitBreakerEnabled = false;
+    private AuthMetadata authMetadata;
+    private List<ServerUrlConfig> servers = new ArrayList<>();
 
     public enum Type {
         HTTP, gRPC, MCP_REMOTE
@@ -42,4 +44,17 @@ public enum Type {
     public static class Config {
         private OrkesCircuitBreakerConfig circuitBreakerConfig = new OrkesCircuitBreakerConfig();
     }
+
+    public enum ServerSource {
+        OPENAPI_SPEC,
+        USER_DEFINED
+    }
+
+    @Data
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class ServerUrlConfig {
+        private String url;
+        private ServerSource type;
+    }
 }

tests/src/test/java/io/orkes/conductor/client/http/ServiceRegistryClientTests.java

@@ -65,6 +65,17 @@ void testBasicCRUDOperations() {
         service.setType(ServiceRegistry.Type.gRPC);
         service.setServiceURI(SERVICE_URI);
 
+        // Set AuthMetadata and Servers
+        com.netflix.conductor.common.model.AuthMetadata authMetadata = new com.netflix.conductor.common.model.AuthMetadata();
+        authMetadata.setKey("Authorization");
+        authMetadata.setValue("Bearer token");
+        service.setAuthMetadata(authMetadata);
+
+        ServiceRegistry.ServerUrlConfig serverUrlConfig = new ServiceRegistry.ServerUrlConfig();
+        serverUrlConfig.setUrl("http://localhost:8080");
+        serverUrlConfig.setType(ServiceRegistry.ServerSource.USER_DEFINED);
+        service.setServers(List.of(serverUrlConfig));
+
         serviceRegistryClient.addOrUpdateService(service);
 
         // Get the service
@@ -74,6 +85,17 @@ void testBasicCRUDOperations() {
         Assertions.assertEquals(SERVICE_URI, retrieved.getServiceURI());
         Assertions.assertEquals(ServiceRegistry.Type.gRPC, retrieved.getType());
 
+        // Verify AuthMetadata
+        Assertions.assertNotNull(retrieved.getAuthMetadata());
+        Assertions.assertEquals("Authorization", retrieved.getAuthMetadata().getKey());
+        Assertions.assertEquals("Bearer token", retrieved.getAuthMetadata().getValue());
+
+        // Verify Servers
+        Assertions.assertNotNull(retrieved.getServers());
+        Assertions.assertEquals(1, retrieved.getServers().size());
+        Assertions.assertEquals("http://localhost:8080", retrieved.getServers().get(0).getUrl());
+        Assertions.assertEquals(ServiceRegistry.ServerSource.USER_DEFINED, retrieved.getServers().get(0).getType());
+
         // Verify it appears in list
         List<ServiceRegistry> services = serviceRegistryClient.getRegisteredServices();
         Assertions.assertTrue(services.stream().anyMatch(s -> s.getName().equals(SERVICE_NAME)));
@@ -167,6 +189,7 @@ void testServiceMethodOperations() {
         method.setMethodType("UNARY");
         method.setInputType("TestRequest");
         method.setOutputType("TestResponse");
+        method.setDescription("Test method description");
 
         // Add method
         serviceRegistryClient.addOrUpdateServiceMethod(SERVICE_NAME, method);
@@ -193,8 +216,8 @@ void testDiscoverMethods() {
         serviceRegistryClient.addOrUpdateService(service);
 
         byte[] protoData = getClass().getClassLoader()
-            .getResourceAsStream("compiled.bin")
-            .readAllBytes();
+                .getResourceAsStream("compiled.bin")
+                .readAllBytes();
 
         serviceRegistryClient.addOrUpdateService(service);
         serviceRegistryClient.setProtoData(SERVICE_NAME, PROTO_FILENAME, protoData);