chore(dotnet): Get clusterId from API

sdk-dotnet/src/API/Models.cs

@@ -19,10 +19,16 @@ public override void Write(Utf8JsonWriter writer, JsonSchema value, JsonSerializ
 
   public struct CreateMachineInput
   {
-    [JsonPropertyName("service")]
-    public required string Service { get; set; }
-    [JsonPropertyName("functions")]
-    public required List<Function> Functions { get; set; }
+    [
+      JsonPropertyName("service"),
+      JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)
+    ]
+    public string Service { get; set; }
+    [
+      JsonPropertyName("functions"),
+      JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)
+    ]
+    public List<Function> Functions { get; set; }
   }
 
   public struct CreateMachineResult

sdk-dotnet/src/Inferable.cs

@@ -37,7 +37,6 @@ public class InferableOptions
     public string? BaseUrl { get; set; }
     public string? ApiSecret { get; set; }
     public string? MachineId { get; set; }
-    public string? ClusterId { get; set; }
   }
 
   public struct PollRunOptions
@@ -68,7 +67,7 @@ public class InferableClient
 
     private readonly ApiClient _client;
     private readonly ILogger<InferableClient> _logger;
-    private readonly string? _clusterId;
+    private string? _clusterId;
 
     // Dictionary of service name to list of functions
     private Dictionary<string, List<IFunctionRegistration>> _functionRegistry = new Dictionary<string, List<IFunctionRegistration>>();
@@ -128,7 +127,6 @@ public InferableClient(InferableOptions? options = null, ILogger<InferableClient
       string? apiSecret = options?.ApiSecret ?? Environment.GetEnvironmentVariable("INFERABLE_API_SECRET");
       string baseUrl = options?.BaseUrl ?? Environment.GetEnvironmentVariable("INFERABLE_API_ENDPOINT") ?? DefaultBaseUrl;
       string machineId = options?.MachineId ?? Machine.GenerateMachineId();
-      this._clusterId = options?.ClusterId ?? Environment.GetEnvironmentVariable("INFERABLE_CLUSTER_ID");
 
       if (apiSecret == null)
       {
@@ -202,11 +200,8 @@ public RegisteredService RegisterService(string name)
     /// </summary>
     async public Task<RunReference> CreateRunAsync(CreateRunInput input)
     {
-      if (this._clusterId == null) {
-        throw new ArgumentException("Cluster ID must be provided to manage runs");
-      }
-
-      var result = await this._client.CreateRunAsync(this._clusterId, input);
+      var clusterId = await this.GetClusterId();
+      var result = await this._client.CreateRunAsync(clusterId, input);
 
       return new RunReference {
         ID = result.ID,
@@ -217,7 +212,7 @@ async public Task<RunReference> CreateRunAsync(CreateRunInput input)
           var start = DateTime.Now;
           var end = start + MaxWaitTime;
           while (DateTime.Now < end) {
-            var pollResult = await this._client.GetRun(this._clusterId, result.ID);
+            var pollResult = await this._client.GetRun(clusterId, result.ID);
 
             var transientStates = new List<string> { "paused", "pending", "running" };
             if (transientStates.Contains(pollResult.Status)) {
@@ -295,7 +290,7 @@ internal async Task StartServiceAsync(string name) {
 
       var functions = this._functionRegistry[name];
 
-      var service = new Service(name, this._client, this._logger, functions);
+      var service = new Service(name, await this.GetClusterId(), this._client, this._logger, functions);
 
       this._services.Add(service);
       await service.Start();
@@ -308,6 +303,16 @@ internal async Task StopServiceAsync(string name) {
       }
       await existing.Stop();
     }
+
+    internal async Task<string> GetClusterId() {
+      if (this._clusterId == null) {
+        // Call register machine without any services to test API key and get clusterId
+        var registerResult = await _client.CreateMachine(new CreateMachineInput {});
+        this._clusterId = registerResult.ClusterId;
+      }
+
+      return this._clusterId;
+    }
   }
 
   public struct RegisteredService
@@ -357,6 +362,4 @@ async public Task StopAsync() {
       await this._inferable.StopServiceAsync(this._name);
     }
   }
-
-
 }

sdk-dotnet/src/Service.cs

@@ -13,7 +13,7 @@ internal class Service
     static int DEFAULT_RETRY_AFTER_SECONDS = 10;
 
     private string _name;
-    private string? _clusterId;
+    private string _clusterId;
     private bool _polling = false;
 
     private int _retryAfter = DEFAULT_RETRY_AFTER_SECONDS;
@@ -23,10 +23,11 @@ internal class Service
 
     private List<IFunctionRegistration> _functions = new List<IFunctionRegistration>();
 
-    internal Service(string name, ApiClient client, ILogger? logger, List<IFunctionRegistration> functions)
+    internal Service(string name, string clusterId, ApiClient client, ILogger? logger, List<IFunctionRegistration> functions)
     {
       this._name = name;
       this._functions = functions;
+      this._clusterId = clusterId;
 
       this._client = client;
       this._logger = logger ?? NullLogger.Instance;
@@ -51,7 +52,7 @@ internal bool Polling
     async internal Task<string> Start()
     {
       this._logger.LogDebug("Starting service '{name}'", this._name);
-      this._clusterId = await RegisterMachine();
+      await RegisterMachine();
 
       // Purposely not awaiting
       _ = this.runLoop();
@@ -131,7 +132,7 @@ async private Task pollIteration()
       _logger.LogDebug($"Polling service {this._name}");
     }
 
-    async private Task<string> RegisterMachine()
+    async private Task RegisterMachine()
     {
       this._logger.LogDebug("Registering machine");
       var functions = new List<Function>();
@@ -152,8 +153,6 @@ async private Task<string> RegisterMachine()
           Service = this._name,
           Functions = functions
           });
-
-      return registerResult.ClusterId;
     }
   }
 }

sdk-dotnet/tests/Inferable.Tests/InferableTest.cs

@@ -35,7 +35,6 @@ static InferableClient CreateInferableClient()
       return new InferableClient(new InferableOptions {
           ApiSecret = System.Environment.GetEnvironmentVariable("INFERABLE_TEST_API_SECRET")!,
           BaseUrl = System.Environment.GetEnvironmentVariable("INFERABLE_TEST_API_ENDPOINT")!,
-          ClusterId = System.Environment.GetEnvironmentVariable("INFERABLE_TEST_CLUSTER_ID")!,
       }, logger);
     }
 

sdk-go/inferable.go

@@ -29,7 +29,7 @@ type Inferable struct {
 	apiSecret        string
 	functionRegistry functionRegistry
 	machineID        string
-	clusterID        string
+	_clusterID        string
 	// Convenience reference to a service with the name 'default'.
 	//
 	// Returns:
@@ -137,15 +137,10 @@ func New(options InferableOptions) (*Inferable, error) {
 		return nil, fmt.Errorf("error registering default service: %v", err)
 	}
 
-  // Call register machine without any services to test API key and get clusterId
-  clusterId, err := inferable.registerMachine(nil);
-
   if err != nil {
     return nil, fmt.Errorf("error registering machine: %v", err)
   }
 
-  inferable.clusterID = clusterId
-
 	return inferable, nil
 }
 
@@ -185,10 +180,10 @@ func (i *Inferable) RegisterService(serviceName string) (*service, error) {
 	if _, exists := i.functionRegistry.services[serviceName]; exists {
 		return nil, fmt.Errorf("service with name '%s' already registered", serviceName)
 	}
+
 	service := &service{
 		Name:      serviceName,
 		Functions: make(map[string]Function),
-    ClusterID: i.clusterID,
 		inferable: i, // Set the reference to the Inferable instance
 	}
 	i.functionRegistry.services[serviceName] = service
@@ -204,8 +199,13 @@ func (i *Inferable) getRun(runID string) (*runResult, error) {
 		"X-Machine-SDK-Language": "go",
 	}
 
+  clusterId, err := i.GetClusterId()
+  if err != nil {
+    return nil, fmt.Errorf("failed to get cluster id: %v", err)
+  }
+
 	options := client.FetchDataOptions{
-		Path:    fmt.Sprintf("/clusters/%s/runs/%s", i.clusterID, runID),
+		Path:    fmt.Sprintf("/clusters/%s/runs/%s", clusterId, runID),
 		Method:  "GET",
 		Headers: headers,
 	}
@@ -254,9 +254,10 @@ func (i *Inferable) getRun(runID string) (*runResult, error) {
 //
 //	fmt.Println("Run result:", result)
 func (i *Inferable) CreateRun(input CreateRunInput) (*runReference, error) {
-	if i.clusterID == "" {
-		return nil, fmt.Errorf("cluster ID must be provided to manage runs")
-	}
+  clusterId, err := i.GetClusterId()
+  if err != nil {
+    return nil, fmt.Errorf("failed to get cluster id: %v", err)
+  }
 
 	// Marshal the payload to JSON
 	jsonPayload, err := json.Marshal(input)
@@ -273,7 +274,7 @@ func (i *Inferable) CreateRun(input CreateRunInput) (*runReference, error) {
 	}
 
 	options := client.FetchDataOptions{
-		Path:    fmt.Sprintf("/clusters/%s/runs", i.clusterID),
+		Path:    fmt.Sprintf("/clusters/%s/runs", clusterId),
 		Method:  "POST",
 		Headers: headers,
 		Body:    string(jsonPayload),
@@ -424,6 +425,19 @@ func (i *Inferable) serverOk() error {
 	return nil
 }
 
+func (i *Inferable) GetClusterId() (string, error) {
+  if i._clusterID == "" {
+    clusterId, err := i.registerMachine(nil)
+    if err != nil {
+      return "", fmt.Errorf("failed to register machine: %v", err)
+    }
+
+    i._clusterID = clusterId
+  }
+
+  return i._clusterID, nil
+}
+
 func (i *Inferable) registerMachine(s *service) (string, error) {
 
 	// Prepare the payload for registration

sdk-go/service.go

@@ -32,7 +32,6 @@ type service struct {
 	Name       string
 	Functions  map[string]Function
 	inferable  *Inferable
-	ClusterID  string
 	ctx        context.Context
 	cancel     context.CancelFunc
 	retryAfter int
@@ -199,8 +198,13 @@ func (s *service) poll() error {
 		"X-Machine-SDK-Language": "go",
 	}
 
+  clusterId, err := s.inferable.GetClusterId()
+  if err != nil {
+    return fmt.Errorf("failed to get cluster id: %v", err)
+  }
+
 	options := client.FetchDataOptions{
-		Path:    fmt.Sprintf("/clusters/%s/calls?acknowledge=true&service=%s&status=pending&limit=10", s.ClusterID, s.Name),
+		Path:    fmt.Sprintf("/clusters/%s/calls?acknowledge=true&service=%s&status=pending&limit=10", clusterId, s.Name),
 		Method:  "GET",
 		Headers: headers,
 	}
@@ -316,8 +320,13 @@ func (s *service) persistJobResult(jobID string, result callResult) error {
 		"X-Machine-SDK-Language": "go",
 	}
 
+  clusterId, err := s.inferable.GetClusterId()
+  if err != nil {
+    return fmt.Errorf("failed to get cluster id: %v", err)
+  }
+
 	options := client.FetchDataOptions{
-		Path:    fmt.Sprintf("/clusters/%s/calls/%s/result", s.ClusterID, jobID),
+		Path:    fmt.Sprintf("/clusters/%s/calls/%s/result", clusterId, jobID),
 		Method:  "POST",
 		Headers: headers,
 		Body:    string(payloadJSON),