internal static AzureMonitorResource? CreateAzureMonitorResource()

in sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/src/Internals/ResourceExtensions.cs [31:166]
118 lines of code
30 McCabe index (conditional complexity)

    internal static AzureMonitorResource? CreateAzureMonitorResource(this Resource resource, string? instrumentationKey, IPlatform platform)
    {
        if (resource == null)
        {
            return null;
        }

        MetricsData? metricsData = null;
        AksResourceProcessor? aksResourceProcessor = null;
        string? serviceName = null;
        string? serviceNamespace = null;
        string? serviceInstance = null;
        string? serviceVersion = null;
        bool? hasDefaultServiceName = null;

        if (instrumentationKey != null && resource.Attributes.Any())
        {
            metricsData = new MetricsData(Version);
        }

        foreach (var attribute in resource.Attributes)
        {
            switch (attribute.Key)
            {
                case SemanticConventions.AttributeServiceName when attribute.Value is string _serviceName:
                    serviceName = _serviceName;
                    if (serviceName.StartsWith(DefaultServiceName))
                    {
                        hasDefaultServiceName = true;
                        break;
                    }

                    hasDefaultServiceName = false;
                    break;
                case SemanticConventions.AttributeServiceNamespace when attribute.Value is string _serviceNamespace:
                    serviceNamespace = $"[{_serviceNamespace}]";
                    break;
                case SemanticConventions.AttributeServiceInstance when attribute.Value is string _serviceInstance:
                    serviceInstance = _serviceInstance;
                    break;
                case AiSdkPrefixKey when attribute.Value is string _aiSdkPrefixValue:
                    SdkVersionUtils.SdkVersionPrefix = _aiSdkPrefixValue;
                    continue;
                case SemanticConventions.AttributeServiceVersion when attribute.Value is string _serviceVersion:
                    serviceVersion = _serviceVersion;
                    break;
                case TelemetryDistroNameKey when attribute.Value is string _aiSdkDistroValue:
                    if (_aiSdkDistroValue == "Azure.Monitor.OpenTelemetry.AspNetCore")
                    {
                        SdkVersionUtils.IsDistro = true;
                    }
                    break;
                default:
                    if (attribute.Key.StartsWith("k8s"))
                    {
                        aksResourceProcessor = aksResourceProcessor ?? new AksResourceProcessor();
                        aksResourceProcessor.MapAttributeToProperty(attribute);
                    }
                    break;
            }

            if (metricsData != null && attribute.Key.Length <= SchemaConstants.MetricsData_Properties_MaxKeyLength && attribute.Value != null)
            {
                // Note: if Key exceeds MaxLength or if Value is null, the entire KVP will be dropped.
                metricsData.Properties.Add(new KeyValuePair<string, string>(attribute.Key, attribute.Value.ToString().Truncate(SchemaConstants.MetricsData_Properties_MaxValueLength) ?? "null"));
            }
        }

        string? roleName = null, roleInstance = null;

        // TODO: Check if service.name as unknown_service should be sent.
        // (2023-07) we need to drop the "unknown_service."
        if (serviceName != null && serviceNamespace != null)
        {
            roleName = string.Concat(serviceNamespace, "/", serviceName);
        }
        else
        {
            roleName = serviceName;
        }

        try
        {
            roleInstance = serviceInstance ?? Dns.GetHostName();
        }
        catch (Exception ex)
        {
            AzureMonitorExporterEventSource.Log.ErrorInitializingRoleInstanceToHostName(ex);
        }

        if (aksResourceProcessor != null)
        {
            var aksRoleName = aksResourceProcessor.GetRoleName();
            var aksRoleInstanceName = aksResourceProcessor.GetRoleInstance();

            if (hasDefaultServiceName != false && aksRoleName != null)
            {
                roleName = aksRoleName;
            }

            if (serviceInstance == null && aksRoleInstanceName != null)
            {
                roleInstance = aksRoleInstanceName;
            }
        }

        bool shouldReportMetricTelemetry = false;
        try
        {
            var exportResource = platform.GetEnvironmentVariable(EnvironmentVariableConstants.EXPORT_RESOURCE_METRIC);
            if (exportResource != null && exportResource.Equals("true", StringComparison.OrdinalIgnoreCase))
            {
                shouldReportMetricTelemetry = true;
            }
        }
        catch
        {
        }

        MonitorBase? monitorBaseData = null;

        if (shouldReportMetricTelemetry && metricsData != null)
        {
            monitorBaseData = new MonitorBase
            {
                BaseType = "MetricData",
                BaseData = metricsData
            };
        }

        return new AzureMonitorResource(
            roleName: roleName,
            roleInstance: roleInstance,
            serviceVersion: serviceVersion,
            monitorBaseData: monitorBaseData);
    }