upcoming: [DI-29904] - Changes for logs integration with metrics (#13460)

* upcoming: [DI-29904] - Changes for logs integration with metrics

* upcoming: [DI-29904] - Changeset

* upcoming: [DI-29904] - Some quick refactorings

* upcoming: [DI-29904] - Revert changes in dashboard select

Author: venkymano-akamai

packages/manager/.changeset/pr-13460-upcoming-features-1772610973355.md

@@ -0,0 +1,5 @@
+---
+"@linode/manager": Upcoming Features
+---
+
+Logs service integration changes for onboarding with `CloudPulse Metrics` ([#13460](https://github.com/linode/manager/pull/13460))

packages/manager/src/features/CloudPulse/Utils/FilterConfig.ts

@@ -9,6 +9,7 @@ import {
   PARENT_ENTITY_REGION,
   REGION,
   RESOURCE_ID,
+  STATUS_CODE_PLACEHOLDER_TEXT,
 } from './constants';
 import { CloudPulseAvailableViews, CloudPulseSelectTypes } from './models';
 import { filterKubernetesClusters, getValidSortedEndpoints } from './utils';
@@ -657,6 +658,45 @@ export const NETLOADBALANCER_CONFIG: Readonly<CloudPulseServiceTypeFilterMap> =
     ],
     serviceType: 'netloadbalancer',
   };
+
+export const LOGS_CONFIG: Readonly<CloudPulseServiceTypeFilterMap> = {
+  capability: capabilityServiceTypeMapping['logs'],
+  filters: [
+    {
+      configuration: {
+        filterKey: 'resource_id',
+        filterType: 'string',
+        isFilterable: true,
+        isMetricsFilter: true,
+        isMultiSelect: true,
+        name: 'Stream Names',
+        neededInViews: [CloudPulseAvailableViews.central],
+        placeholder: 'Select Stream Names',
+        priority: 2,
+      },
+      name: 'Stream Names',
+    },
+    {
+      configuration: {
+        filterKey: 'status_code',
+        filterType: 'string',
+        isFilterable: true,
+        isMetricsFilter: false,
+        name: 'Status Code',
+        dimensionKey: 'status_code',
+        neededInViews: [
+          CloudPulseAvailableViews.central,
+          CloudPulseAvailableViews.service,
+        ],
+        isOptional: true,
+        placeholder: STATUS_CODE_PLACEHOLDER_TEXT,
+        priority: 2,
+      },
+      name: 'Status Code',
+    },
+  ],
+  serviceType: 'logs',
+};
 export const FILTER_CONFIG: Readonly<
   Map<number, CloudPulseServiceTypeFilterMap>
 > = new Map([
@@ -670,6 +710,7 @@ export const FILTER_CONFIG: Readonly<
   [8, FIREWALL_NODEBALANCER_CONFIG],
   [9, LKE_CONFIG],
   [10, ENDPOINT_DASHBOARD_CONFIG],
+  [11, LOGS_CONFIG],
 ]);
 
 /**

packages/manager/src/features/CloudPulse/Utils/constants.ts

@@ -51,6 +51,8 @@ export const INTERFACE_ID = 'interface_id';
 
 export const FIREWALL = 'Firewall';
 
+export const STATUS_CODE = 'status_code';
+
 export const PORTS_HELPER_TEXT =
   'Enter one or more port numbers (1-65535) separated by commas.';
 
@@ -72,6 +74,22 @@ export const PORTS_LEADING_COMMA_ERROR_MESSAGE =
 export const PORTS_LIMIT_ERROR_MESSAGE =
   'Port list must be 100 characters or less.';
 
+export const STATUS_CODE_HELPER_TEXT =
+  'Enter one or more Status Codes separated by commas.';
+
+export const STATUS_CODE_ERROR_MESSAGE =
+  'Enter valid status codes as integers separated by commas without spaces.';
+
+export const STATUS_CODE_CONSECUTIVE_COMMAS_ERROR_MESSAGE =
+  'Use a single comma to separate status codes.';
+export const STATUS_CODE_LEADING_COMMA_ERROR_MESSAGE =
+  'First character must be an integer.';
+
+export const STATUS_CODE_LIMIT_ERROR_MESSAGE =
+  'Status code list must be 100 characters or less.';
+
+export const STATUS_CODE_PLACEHOLDER_TEXT = 'e.g., 200,400';
+
 export const PORTS_PLACEHOLDER_TEXT = 'e.g., 80,443,3000';
 
 export const INTERFACE_IDS_HELPER_TEXT =

packages/manager/src/features/CloudPulse/Utils/utils.ts

@@ -20,6 +20,11 @@ import {
   PORTS_LEADING_ZERO_ERROR_MESSAGE,
   PORTS_LIMIT_ERROR_MESSAGE,
   PORTS_RANGE_ERROR_MESSAGE,
+  STATUS_CODE,
+  STATUS_CODE_CONSECUTIVE_COMMAS_ERROR_MESSAGE,
+  STATUS_CODE_ERROR_MESSAGE,
+  STATUS_CODE_LEADING_COMMA_ERROR_MESSAGE,
+  STATUS_CODE_LIMIT_ERROR_MESSAGE,
 } from './constants';
 
 import type { FetchOptions } from '../Alerts/CreateAlert/Criteria/DimensionFilterValue/constants';
@@ -391,6 +396,31 @@ export const areValidInterfaceIds = (
   return undefined;
 };
 
+export const areValidStatusCodes = (
+  statusCodes: string
+): string | undefined => {
+  if (statusCodes === '') {
+    return undefined;
+  }
+
+  if (statusCodes.length > 100) {
+    return STATUS_CODE_LIMIT_ERROR_MESSAGE;
+  }
+  if (statusCodes.startsWith(',')) {
+    return STATUS_CODE_LEADING_COMMA_ERROR_MESSAGE;
+  }
+
+  if (statusCodes.includes(',,')) {
+    return STATUS_CODE_CONSECUTIVE_COMMAS_ERROR_MESSAGE;
+  }
+
+  if (!/^[\d,]+$/.test(statusCodes)) {
+    return STATUS_CODE_ERROR_MESSAGE;
+  }
+
+  return undefined;
+};
+
 /**
  * @param filterKey
  * @returns validation function for the filter key
@@ -401,6 +431,7 @@ export const validationFunction: Record<
 > = {
   [PORT]: arePortsValid,
   [INTERFACE_ID]: areValidInterfaceIds,
+  [STATUS_CODE]: areValidStatusCodes,
 };
 
 /**

packages/manager/src/features/CloudPulse/shared/CloudPulseComponentRenderer.tsx

@@ -64,6 +64,7 @@ const Components: {
   associated_entity_region: CloudPulseRegionSelect,
   endpoint: CloudPulseEndpointsSelect,
   nodebalancer_id: CloudPulseFirewallNodebalancersSelect,
+  status_code: CloudPulseTextFilter,
 };
 
 const buildComponent = (props: CloudPulseComponentRendererProps) => {

packages/manager/src/features/CloudPulse/shared/CloudPulseDashboardFilterBuilder.tsx

@@ -20,6 +20,7 @@ import {
   REGION,
   RESOURCE_ID,
   RESOURCES,
+  STATUS_CODE,
   TAGS,
 } from '../Utils/constants';
 import {
@@ -379,7 +380,8 @@ export const CloudPulseDashboardFilterBuilder = React.memo(
           );
         } else if (
           config.configuration.filterKey === PORT ||
-          config.configuration.filterKey === INTERFACE_ID
+          config.configuration.filterKey === INTERFACE_ID ||
+          config.configuration.filterKey === STATUS_CODE
         ) {
           return getTextFilterProperties(
             {

packages/manager/src/mocks/serverHandlers.ts

@@ -4072,6 +4072,16 @@ export const handlers = [
       );
     }
 
+    if (params.serviceType === 'logs') {
+      response.data.push(
+        dashboardFactory.build({
+          id: 11,
+          service_type: 'logs',
+          label: 'Log Delivery Status',
+        })
+      );
+    }
+
     return HttpResponse.json(response);
   }),
   http.get(
@@ -4528,6 +4538,41 @@ export const handlers = [
       ];
       serviceType = 'netloadbalancer';
       dashboardLabel = 'Network Load Balancer';
+    } else if (id === '11') {
+      serviceType = 'logs';
+      dashboardLabel = 'Log Delivery Status';
+      widgets = [
+        {
+          metric: 'success_upload_count',
+          unit: 'Count',
+          label: 'Success Upload',
+          color: 'default',
+          size: 6,
+          chart_type: 'area',
+          y_label: 'success_upload_count',
+          aggregate_function: 'sum',
+        },
+        {
+          metric: 'error_upload_count',
+          unit: 'Count',
+          label: 'Error Upload',
+          color: 'default',
+          size: 6,
+          chart_type: 'area',
+          y_label: 'error_upload_count',
+          aggregate_function: 'sum',
+        },
+        {
+          metric: 'error_upload_rate',
+          unit: '%',
+          label: 'Error Rate',
+          color: 'default',
+          size: 12,
+          chart_type: 'area',
+          y_label: 'error_upload_rate',
+          aggregate_function: 'avg',
+        },
+      ];
     } else {
       serviceType = 'linode';
       dashboardLabel = 'Linode Service I/O Statistics';