Env config

Author: THardy98

src/Temporalio/Bridge/Cargo.lock

@@ -3,7 +3,8 @@
 
 namespace Temporalio.Bridge.Interop
 {
-    internal enum TemporalCoreForwardedLogLevel
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreForwardedLogLevel : uint
     {
         Trace = 0,
         Debug,
@@ -12,15 +13,17 @@ internal enum TemporalCoreForwardedLogLevel
         Error,
     }
 
-    internal enum TemporalCoreMetricAttributeValueType
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreMetricAttributeValueType : uint
     {
         String = 1,
         Int,
         Float,
         Bool,
     }
 
-    internal enum TemporalCoreMetricKind
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreMetricKind : uint
     {
         CounterInteger = 1,
         HistogramInteger,
@@ -30,19 +33,22 @@ internal enum TemporalCoreMetricKind
         GaugeFloat,
     }
 
-    internal enum TemporalCoreOpenTelemetryMetricTemporality
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreOpenTelemetryMetricTemporality : uint
     {
         Cumulative = 1,
         Delta,
     }
 
-    internal enum TemporalCoreOpenTelemetryProtocol
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreOpenTelemetryProtocol : uint
     {
         Grpc = 1,
         Http,
     }
 
-    internal enum TemporalCoreRpcService
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreRpcService : uint
     {
         Workflow = 1,
         Operator,
@@ -51,7 +57,8 @@ internal enum TemporalCoreRpcService
         Health,
     }
 
-    internal enum TemporalCoreSlotKindType
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreSlotKindType : uint
     {
         WorkflowSlotKindType,
         ActivitySlotKindType,
@@ -245,6 +252,9 @@ internal unsafe partial struct TemporalCoreRpcCallOptions
     [UnmanagedFunctionPointer(CallingConvention.Cdecl)]
     internal unsafe delegate void TemporalCoreClientRpcCallCallback(void* user_data, [NativeTypeName("const struct TemporalCoreByteArray *")] TemporalCoreByteArray* success, [NativeTypeName("uint32_t")] uint status_code, [NativeTypeName("const struct TemporalCoreByteArray *")] TemporalCoreByteArray* failure_message, [NativeTypeName("const struct TemporalCoreByteArray *")] TemporalCoreByteArray* failure_details);
 
+    [UnmanagedFunctionPointer(CallingConvention.Cdecl)]
+    internal unsafe delegate void TemporalCoreClientConfigCallback(void* user_data, [NativeTypeName("const struct TemporalCoreByteArray *")] TemporalCoreByteArray* success, [NativeTypeName("const struct TemporalCoreByteArray *")] TemporalCoreByteArray* fail);
+
     [StructLayout(LayoutKind.Explicit)]
     internal partial struct TemporalCoreMetricAttributeValue
     {
@@ -585,7 +595,8 @@ internal partial struct TemporalCoreLegacyBuildIdBasedStrategy
         public TemporalCoreByteArrayRef build_id;
     }
 
-    internal enum TemporalCoreWorkerVersioningStrategy_Tag
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreWorkerVersioningStrategy_Tag : uint
     {
         None,
         DeploymentBased,
@@ -596,7 +607,7 @@ internal unsafe partial struct TemporalCoreWorkerVersioningStrategy
     {
         public TemporalCoreWorkerVersioningStrategy_Tag tag;
 
-        [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L421_C3")]
+        [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L431_C3")]
         public _Anonymous_e__Union Anonymous;
 
         internal ref TemporalCoreWorkerVersioningNone none
@@ -636,15 +647,15 @@ internal ref TemporalCoreLegacyBuildIdBasedStrategy legacy_build_id_based
         internal unsafe partial struct _Anonymous_e__Union
         {
             [FieldOffset(0)]
-            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L422_C5")]
+            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L432_C5")]
             public _Anonymous1_1_e__Struct Anonymous1_1;
 
             [FieldOffset(0)]
-            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L425_C5")]
+            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L435_C5")]
             public _Anonymous2_1_e__Struct Anonymous2_1;
 
             [FieldOffset(0)]
-            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L428_C5")]
+            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L438_C5")]
             public _Anonymous3_1_e__Struct Anonymous3_1;
 
             internal partial struct _Anonymous1_1_e__Struct
@@ -725,7 +736,8 @@ internal unsafe partial struct TemporalCoreSlotReserveCtx
     [return: NativeTypeName("uintptr_t")]
     internal unsafe delegate UIntPtr TemporalCoreCustomTryReserveSlotCallback([NativeTypeName("const struct TemporalCoreSlotReserveCtx *")] TemporalCoreSlotReserveCtx* ctx);
 
-    internal enum TemporalCoreSlotInfo_Tag
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreSlotInfo_Tag : uint
     {
         WorkflowSlotInfo,
         ActivitySlotInfo,
@@ -767,7 +779,7 @@ internal unsafe partial struct TemporalCoreSlotInfo
     {
         public TemporalCoreSlotInfo_Tag tag;
 
-        [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L496_C3")]
+        [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L506_C3")]
         public _Anonymous_e__Union Anonymous;
 
         internal ref TemporalCoreWorkflowSlotInfo_Body workflow_slot_info
@@ -885,7 +897,8 @@ internal unsafe partial struct TemporalCoreCustomSlotSupplierCallbacksImpl
         public TemporalCoreCustomSlotSupplierCallbacks* _0;
     }
 
-    internal enum TemporalCoreSlotSupplier_Tag
+    [NativeTypeName("unsigned int")]
+    internal enum TemporalCoreSlotSupplier_Tag : uint
     {
         FixedSize,
         ResourceBased,
@@ -896,7 +909,7 @@ internal unsafe partial struct TemporalCoreSlotSupplier
     {
         public TemporalCoreSlotSupplier_Tag tag;
 
-        [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L547_C3")]
+        [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L557_C3")]
         public _Anonymous_e__Union Anonymous;
 
         internal ref TemporalCoreFixedSizeSlotSupplier fixed_size
@@ -936,15 +949,15 @@ internal ref TemporalCoreCustomSlotSupplierCallbacksImpl custom
         internal unsafe partial struct _Anonymous_e__Union
         {
             [FieldOffset(0)]
-            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L548_C5")]
+            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L558_C5")]
             public _Anonymous1_1_e__Struct Anonymous1_1;
 
             [FieldOffset(0)]
-            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L551_C5")]
+            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L561_C5")]
             public _Anonymous2_1_e__Struct Anonymous2_1;
 
             [FieldOffset(0)]
-            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L554_C5")]
+            [NativeTypeName("__AnonymousRecord_temporal-sdk-core-c-bridge_L564_C5")]
             public _Anonymous3_1_e__Struct Anonymous3_1;
 
             internal partial struct _Anonymous1_1_e__Struct
@@ -1120,6 +1133,12 @@ internal static unsafe partial class Methods
         [DllImport("temporal_sdk_core_c_bridge", CallingConvention = CallingConvention.Cdecl, ExactSpelling = true)]
         public static extern void temporal_core_client_rpc_call([NativeTypeName("struct TemporalCoreClient *")] TemporalCoreClient* client, [NativeTypeName("const struct TemporalCoreRpcCallOptions *")] TemporalCoreRpcCallOptions* options, void* user_data, [NativeTypeName("TemporalCoreClientRpcCallCallback")] IntPtr callback);
 
+        [DllImport("temporal_sdk_core_c_bridge", CallingConvention = CallingConvention.Cdecl, ExactSpelling = true)]
+        public static extern void temporal_core_client_config_load([NativeTypeName("const char *")] sbyte* path, [NativeTypeName("struct TemporalCoreByteArrayRef")] TemporalCoreByteArrayRef data, [NativeTypeName("bool")] byte disable_file, [NativeTypeName("bool")] byte config_file_strict, [NativeTypeName("struct TemporalCoreByteArrayRef")] TemporalCoreByteArrayRef env_vars, void* user_data, [NativeTypeName("TemporalCoreClientConfigCallback")] IntPtr callback);
+
+        [DllImport("temporal_sdk_core_c_bridge", CallingConvention = CallingConvention.Cdecl, ExactSpelling = true)]
+        public static extern void temporal_core_client_config_profile_load([NativeTypeName("const char *")] sbyte* profile, [NativeTypeName("const char *")] sbyte* path, [NativeTypeName("struct TemporalCoreByteArrayRef")] TemporalCoreByteArrayRef data, [NativeTypeName("bool")] byte disable_file, [NativeTypeName("bool")] byte disable_env, [NativeTypeName("bool")] byte config_file_strict, [NativeTypeName("struct TemporalCoreByteArrayRef")] TemporalCoreByteArrayRef env_vars, void* user_data, [NativeTypeName("TemporalCoreClientConfigCallback")] IntPtr callback);
+
         [DllImport("temporal_sdk_core_c_bridge", CallingConvention = CallingConvention.Cdecl, ExactSpelling = true)]
         [return: NativeTypeName("struct TemporalCoreMetricMeter *")]
         public static extern TemporalCoreMetricMeter* temporal_core_metric_meter_new([NativeTypeName("struct TemporalCoreRuntime *")] TemporalCoreRuntime* runtime);

src/Temporalio/Bridge/EnvConfig.cs

@@ -0,0 +1,124 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text.Json;
+
+namespace Temporalio.Client.Configuration
+{
+    /// <summary>
+    /// Represents the overall client configuration.
+    /// </summary>
+    public sealed class ClientConfig : ICloneable
+    {
+        /// <summary>
+        /// Initializes a new instance of the <see cref="ClientConfig"/> class.
+        /// </summary>
+        /// <param name="profiles">The configuration profiles.</param>
+        public ClientConfig(IReadOnlyDictionary<string, ClientConfigProfile> profiles)
+        {
+            Profiles = profiles ?? new Dictionary<string, ClientConfigProfile>();
+        }
+
+        /// <summary>
+        /// Gets the configuration profiles.
+        /// </summary>
+        public IReadOnlyDictionary<string, ClientConfigProfile> Profiles { get; private set; }
+
+        /// <summary>
+        /// Load client configuration from environment variables and configuration files.
+        /// </summary>
+        /// <param name="configSource">The data source to load from.</param>
+        /// <param name="disableFile">If true, do not load from file (only from environment).</param>
+        /// <param name="configFileStrict">If true, fail if configuration file is invalid.</param>
+        /// <param name="overrideEnvVars">Environment variables to use, or null to use system environment.</param>
+        /// <returns>Loaded configuration data.</returns>
+        public static ClientConfig Load(
+            DataSource? configSource = null,
+            bool disableFile = false,
+            bool configFileStrict = false,
+            Dictionary<string, string>? overrideEnvVars = null)
+        {
+            var runtime = Runtime.TemporalRuntime.Default.Runtime;
+            var profiles = Bridge.EnvConfig.LoadClientConfig(
+                runtime,
+                configSource ?? DataSource.FromDefault(),
+                disableFile,
+                configFileStrict,
+                overrideEnvVars);
+            return new ClientConfig(profiles);
+        }
+
+        /// <summary>
+        /// Load client connection options directly from configuration.
+        /// </summary>
+        /// <param name="profile">Name of the profile to load. If null, "default" is used.</param>
+        /// <param name="configSource">The data source to load from.</param>
+        /// <param name="disableFile">If true, do not load from file (only from environment).</param>
+        /// <param name="disableEnv">If true, disable environment variable overrides.</param>
+        /// <param name="configFileStrict">If true, fail if configuration file is invalid.</param>
+        /// <param name="overrideEnvVars">Environment variables to use, or null to use system environment.</param>
+        /// <returns>Client connection options.</returns>
+        public static TemporalClientConnectOptions LoadClientConnectOptions(
+            string? profile = null,
+            DataSource? configSource = null,
+            bool disableFile = false,
+            bool disableEnv = false,
+            bool configFileStrict = false,
+            Dictionary<string, string>? overrideEnvVars = null)
+        {
+            var profileName = profile ?? "default";
+            var clientProfile = ClientConfigProfile.Load(
+                profileName,
+                configSource,
+                disableFile,
+                disableEnv,
+                configFileStrict,
+                overrideEnvVars);
+            return clientProfile.ToConnectionOptions();
+        }
+
+        /// <summary>
+        /// Deserialize client configuration from JSON.
+        /// </summary>
+        /// <param name="json">JSON string to deserialize.</param>
+        /// <param name="options">Optional JSON serializer options.</param>
+        /// <returns>Client configuration instance.</returns>
+        public static ClientConfig FromJson(string json, JsonSerializerOptions? options = null)
+        {
+            return JsonSerializer.Deserialize<ClientConfig>(json, options ?? GetDefaultJsonOptions())
+                ?? throw new JsonException("Failed to deserialize ClientConfig from JSON.");
+        }
+
+        /// <summary>
+        /// Serialize this client configuration to JSON.
+        /// </summary>
+        /// <param name="options">Optional JSON serializer options.</param>
+        /// <returns>JSON string representation.</returns>
+        public string ToJson(JsonSerializerOptions? options = null)
+        {
+            return JsonSerializer.Serialize(this, options ?? GetDefaultJsonOptions());
+        }
+
+        /// <inheritdoc />
+        public object Clone()
+        {
+            var newConfig = (ClientConfig)MemberwiseClone();
+            var clonedProfiles = new Dictionary<string, ClientConfigProfile>();
+            foreach (var kvp in Profiles)
+            {
+                clonedProfiles[kvp.Key] = (ClientConfigProfile)kvp.Value.Clone();
+            }
+            newConfig.Profiles = clonedProfiles;
+            return newConfig;
+        }
+
+        private static JsonSerializerOptions GetDefaultJsonOptions()
+        {
+            return new JsonSerializerOptions
+            {
+                PropertyNamingPolicy = JsonNamingPolicy.CamelCase,
+                WriteIndented = true,
+            };
+        }
+    }
+}