///
/// Copyright © 2016-2026 The Thingsboard Authors
///
/// 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
///
///     http://www.apache.org/licenses/LICENSE-2.0
///
/// 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.
///

import { HasEntityDebugSettings, HasTenantId, HasVersion } from '@shared/models/entity.models';
import { BaseData, ExportableEntity } from '@shared/models/base-data';
import { CalculatedFieldId } from '@shared/models/id/calculated-field-id';
import { EntityId } from '@shared/models/id/entity-id';
import { AttributeScope } from '@shared/models/telemetry/telemetry.models';
import { EntityType } from '@shared/models/entity-type.models';
import { AliasFilterType } from '@shared/models/alias.models';
import { Observable } from 'rxjs';
import { TbEditorCompleter } from '@shared/models/ace/completion.models';
import {
  AceHighlightRule,
  AceHighlightRules,
  dotOperatorHighlightRule,
  endGroupHighlightRule
} from '@shared/models/ace/ace.models';
import { EntitySearchDirection } from '@shared/models/relation.models';
import { AbstractControl, FormControl, ValidationErrors, ValidatorFn } from '@angular/forms';
import { AlarmRule } from "@shared/models/alarm-rule.models";
import { AlarmSeverity } from "@shared/models/alarm.models";

export const FORBIDDEN_NAMES = ['ctx', 'e', 'pi'];

interface BaseCalculatedField extends Omit<BaseData<CalculatedFieldId>, 'label'>, HasVersion, HasEntityDebugSettings, HasTenantId, ExportableEntity<CalculatedFieldId> {
  entityId: EntityId;
  additionalInfo?: any;
}

export interface CalculatedFieldSimple extends BaseCalculatedField {
  type: CalculatedFieldType.SIMPLE;
  configuration: CalculatedFieldSimpleConfiguration;
}

export interface CalculatedFieldScript extends BaseCalculatedField {
  type: CalculatedFieldType.SCRIPT;
  configuration: CalculatedFieldScriptConfiguration;
}

export interface CalculatedFieldGeofencing extends BaseCalculatedField {
  type: CalculatedFieldType.GEOFENCING;
  configuration: CalculatedFieldGeofencingConfiguration;
}

export interface CalculatedFieldPropagation extends BaseCalculatedField {
  type: CalculatedFieldType.PROPAGATION;
  configuration: CalculatedFieldPropagationConfiguration;
}

export interface CalculatedFieldAlarmRule extends BaseCalculatedField {
  type: CalculatedFieldType.ALARM;
  configuration: CalculatedFieldAlarmRuleConfiguration;
}

export interface CalculatedFieldRelatedEntityAggregation extends BaseCalculatedField {
  type: CalculatedFieldType.RELATED_ENTITIES_AGGREGATION;
  configuration: CalculatedFieldRelatedAggregationConfiguration;
}


export type CalculatedField =
  | CalculatedFieldSimple
  | CalculatedFieldScript
  | CalculatedFieldGeofencing
  | CalculatedFieldPropagation
  | CalculatedFieldRelatedEntityAggregation
  | CalculatedFieldAlarmRule;

export type WithCalculatedFieldInfo<T> = T & {entityName: string};
export type CalculatedFieldInfo = WithCalculatedFieldInfo<CalculatedField>;
export type CalculatedFieldAlarmRuleInfo = WithCalculatedFieldInfo<CalculatedFieldAlarmRule>;

export enum CalculatedFieldType {
  SIMPLE = 'SIMPLE',
  SCRIPT = 'SCRIPT',
  GEOFENCING = 'GEOFENCING',
  PROPAGATION = 'PROPAGATION',
  RELATED_ENTITIES_AGGREGATION = 'RELATED_ENTITIES_AGGREGATION',
  ENTITY_AGGREGATION = 'ENTITY_AGGREGATION',
  ALARM = 'ALARM',
}

export interface CalculatedFieldTypeTranslate {
  name: string;
  hint?: string;
}

export const CalculatedFieldTypeTranslations = new Map<CalculatedFieldType, CalculatedFieldTypeTranslate>(
  [
    [CalculatedFieldType.SIMPLE, {
      name: 'calculated-fields.type.simple',
      hint: 'calculated-fields.type.simple-hint',
    }],
    [CalculatedFieldType.SCRIPT, {
      name: 'calculated-fields.type.script',
      hint: 'calculated-fields.type.script-hint',
    }],
    [CalculatedFieldType.GEOFENCING, {
      name: 'calculated-fields.type.geofencing',
      hint: 'calculated-fields.type.geofencing-hint',
    }],
    [CalculatedFieldType.PROPAGATION, {
      name: 'calculated-fields.type.propagation',
      hint: 'calculated-fields.type.propagation-hint',
    }],
    [CalculatedFieldType.RELATED_ENTITIES_AGGREGATION, {
      name: 'calculated-fields.type.related-entities-aggregation',
      hint: 'calculated-fields.type.related-entities-aggregation-hint'
    }],
    [CalculatedFieldType.ENTITY_AGGREGATION, {
      name: 'calculated-fields.type.time-series-data-aggregation',
      hint: 'calculated-fields.type.time-series-data-aggregation-hint',
    }],
  ]
)

export const calculatedFieldTypes = Object.values(CalculatedFieldType).filter(type => type !== CalculatedFieldType.ALARM)

export type CalculatedFieldConfiguration =
  | CalculatedFieldSimpleConfiguration
  | CalculatedFieldScriptConfiguration
  | CalculatedFieldGeofencingConfiguration
  | CalculatedFieldPropagationConfiguration
  | CalculatedFieldRelatedAggregationConfiguration
  | CalculatedFieldEntityAggregationConfiguration
  | CalculatedFieldAlarmRuleConfiguration;

export interface CalculatedFieldSimpleConfiguration {
  type: CalculatedFieldType.SIMPLE;
  expression: string;
  arguments: Record<string, CalculatedFieldArgument>;
  useLatestTs: boolean;
  output: CalculatedFieldSimpleOutput;
}

export interface CalculatedFieldScriptConfiguration {
  type: CalculatedFieldType.SCRIPT;
  expression: string;
  arguments: Record<string, CalculatedFieldArgument>;
  output: CalculatedFieldOutput;
}

export interface CalculatedFieldGeofencingConfiguration {
  type: CalculatedFieldType.GEOFENCING;
  zoneGroups: Record<string, CalculatedFieldGeofencing>;
  scheduledUpdateEnabled: boolean;
  scheduledUpdateInterval?: number;
  output: CalculatedFieldOutput;
}

export interface CalculatedFieldRelatedAggregationConfiguration {
  type: CalculatedFieldType.RELATED_ENTITIES_AGGREGATION;
  relation: RelationPathLevel;
  arguments: Record<string, CalculatedFieldArgument>;
  metrics: Record<string, CalculatedFieldAggMetric>;
  deduplicationIntervalInSec: number;
  scheduledUpdateInterval?: number;
  useLatestTs: boolean;
  output: CalculatedFieldOutput & { decimalsByDefault?: number; };
}

export interface CalculatedFieldEntityAggregationConfiguration {
  type: CalculatedFieldType.ENTITY_AGGREGATION;
  arguments: Record<string, CalculatedFieldArgument>;
  metrics: Record<string, CalculatedFieldAggMetric>;
  interval: AggInterval;
  watermark?: WatermarkConfig;
  produceIntermediateResult?: boolean;
  output: CalculatedFieldOutput & { decimalsByDefault?: number; };
}

export interface WatermarkConfig {
  duration: number;
}

interface BasePropagationConfiguration {
  type: CalculatedFieldType.PROPAGATION;
  relation: RelationPathLevel;
  arguments: Record<string, CalculatedFieldArgument>;
  output: CalculatedFieldOutput;
}

export interface CalculatedFieldAlarmRuleConfiguration {
  type: CalculatedFieldType.ALARM;
  arguments: Record<string, CalculatedFieldArgument>;
  createRules: Record<AlarmSeverity, AlarmRule>;
  clearRule?: AlarmRule;
  propagate: boolean;
  propagateToOwner: boolean;
  propagateToTenant: boolean;
  propagateRelationTypes?: Array<string>;
}

export interface PropagationWithNoExpression extends BasePropagationConfiguration {
  applyExpressionToResolvedArguments: false;
}

export interface PropagationWithExpression extends BasePropagationConfiguration {
  applyExpressionToResolvedArguments: true;
  expression: string;
}

export type CalculatedFieldPropagationConfiguration =
  | PropagationWithNoExpression
  | PropagationWithExpression;

export type CalculatedFieldOutput =
  | CalculatedFieldOutputAttribute
  | CalculatedFieldOutputTimeSeries;

export interface CalculatedFieldOutputAttribute {
  type: OutputType.Attribute,
  scope: AttributeScope;
  strategy: AttributeOutputStrategy;
}

export interface CalculatedFieldOutputTimeSeries {
  type: OutputType.Timeseries;
  strategy: TimeSeriesOutputStrategy;
}

export type CalculatedFieldSimpleOutput = CalculatedFieldOutput & {
  name: string;
  decimalsByDefault?: number;
}

export type AttributeOutputStrategy =
  | AttributeImmediateOutputStrategy
  | AttributeRuleChainOutputStrategy;

export interface AttributeImmediateOutputStrategy {
  type: OutputStrategyType.IMMEDIATE;
  updateAttributesOnlyOnValueChange: boolean;
  sendAttributesUpdatedNotification: boolean;
  saveAttribute: boolean;
  sendWsUpdate: boolean;
  processCfs: boolean;
}

export interface AttributeRuleChainOutputStrategy {
  type: OutputStrategyType.RULE_CHAIN;
}

export type TimeSeriesOutputStrategy =
  | TimeSeriesRuleChainOutputStrategy
  | TimeSeriesImmediateOutputStrategy;

export interface TimeSeriesRuleChainOutputStrategy {
  type: OutputStrategyType.IMMEDIATE;
  ttl: number;
  saveTimeSeries: boolean;
  saveLatest: boolean;
  sendWsUpdate: boolean;
  processCfs: boolean;
}

export interface TimeSeriesImmediateOutputStrategy {
  type: OutputStrategyType.RULE_CHAIN;
}

export enum  OutputStrategyType {
  IMMEDIATE = 'IMMEDIATE',
  RULE_CHAIN = 'RULE_CHAIN'
}

export const OutputStrategyTypeTranslations = new Map<OutputStrategyType, string>(
  [
    [OutputStrategyType.IMMEDIATE, 'calculated-fields.output-strategy.process-right-away'],
    [OutputStrategyType.RULE_CHAIN, 'calculated-fields.output-strategy.process-rule-chains'],
  ]
)

export enum ArgumentEntityType {
  Current = 'CURRENT',
  Device = 'DEVICE',
  Asset = 'ASSET',
  Customer = 'CUSTOMER',
  Tenant = 'TENANT',
  Owner = 'CURRENT_OWNER',
  RelationQuery = 'RELATION_PATH_QUERY',
}

export const ArgumentEntityTypeTranslations = new Map<ArgumentEntityType, string>(
  [
    [ArgumentEntityType.Current, 'calculated-fields.argument-current'],
    [ArgumentEntityType.Device, 'calculated-fields.argument-device'],
    [ArgumentEntityType.Asset, 'calculated-fields.argument-asset'],
    [ArgumentEntityType.Customer, 'calculated-fields.argument-customer'],
    [ArgumentEntityType.Tenant, 'calculated-fields.argument-tenant'],
    [ArgumentEntityType.Owner, 'calculated-fields.argument-owner'],
    [ArgumentEntityType.RelationQuery, 'calculated-fields.argument-relation-query'],
  ]
)

export enum GeofencingReportStrategy {
  REPORT_TRANSITION_EVENTS_ONLY = 'REPORT_TRANSITION_EVENTS_ONLY',
  REPORT_PRESENCE_STATUS_ONLY = 'REPORT_PRESENCE_STATUS_ONLY',
  REPORT_TRANSITION_EVENTS_AND_PRESENCE_STATUS = 'REPORT_TRANSITION_EVENTS_AND_PRESENCE_STATUS'
}

export const GeofencingReportStrategyTranslations = new Map<GeofencingReportStrategy, string>(
  [
    [GeofencingReportStrategy.REPORT_TRANSITION_EVENTS_AND_PRESENCE_STATUS, 'calculated-fields.report-transition-event-and-presence'],
    [GeofencingReportStrategy.REPORT_TRANSITION_EVENTS_ONLY, 'calculated-fields.report-transition-event-only'],
    [GeofencingReportStrategy.REPORT_PRESENCE_STATUS_ONLY, 'calculated-fields.report-presence-status-only']
  ]
)

export const GeofencingDirectionTranslations = new Map<EntitySearchDirection, string>(
  [
    [EntitySearchDirection.FROM, 'calculated-fields.direction-from'],
    [EntitySearchDirection.TO, 'calculated-fields.direction-to'],
  ]
)

export const GeofencingDirectionLevelTranslations = new Map<EntitySearchDirection, string>(
  [
    [EntitySearchDirection.FROM, 'calculated-fields.direction-down'],
    [EntitySearchDirection.TO, 'calculated-fields.direction-up'],
  ]
)

export const PropagationDirectionTranslations = new Map<EntitySearchDirection, string>(
  [
    [EntitySearchDirection.FROM, 'calculated-fields.direction-down-child'],
    [EntitySearchDirection.TO, 'calculated-fields.direction-up-parent'],
  ]
)

export enum ArgumentType {
  Attribute = 'ATTRIBUTE',
  LatestTelemetry = 'TS_LATEST',
  Rolling = 'TS_ROLLING',
}

export enum TestArgumentType {
  Single = 'SINGLE_VALUE',
  Rolling = 'TS_ROLLING',
}

export const TestArgumentTypeMap = new Map<ArgumentType, TestArgumentType>(
  [
    [ArgumentType.Attribute, TestArgumentType.Single],
    [ArgumentType.LatestTelemetry, TestArgumentType.Single],
    [ArgumentType.Rolling, TestArgumentType.Rolling],
  ]
)

export enum OutputType {
  Attribute = 'ATTRIBUTES',
  Timeseries = 'TIME_SERIES',
}

export const OutputTypeTranslations = new Map<OutputType, string>(
  [
    [OutputType.Attribute, 'calculated-fields.attribute'],
    [OutputType.Timeseries, 'calculated-fields.timeseries'],
  ]
)

export const ArgumentTypeTranslations = new Map<ArgumentType, string>(
  [
    [ArgumentType.Attribute, 'calculated-fields.attribute'],
    [ArgumentType.LatestTelemetry, 'calculated-fields.latest-telemetry'],
    [ArgumentType.Rolling, 'calculated-fields.rolling'],
  ]
)

export interface CalculatedFieldArgument {
  refEntityKey: RefEntityKey;
  defaultValue?: string;
  refEntityId?: RefEntityId;
  refDynamicSourceConfiguration?: RefDynamicSourceConfiguration;
  limit?: number;
  timeWindow?: number;
}

export interface RefDynamicSourceConfiguration {
  type: ArgumentEntityType.Owner;
}

export enum AggFunction {
  AVG='AVG',
  MIN='MIN',
  MAX='MAX',
  SUM='SUM',
  COUNT='COUNT',
  COUNT_UNIQUE='COUNT_UNIQUE'
}

export const AggFunctionTranslations = new Map<AggFunction, string>([
  [AggFunction.AVG, 'calculated-fields.metrics.aggregation-type.avg'],
  [AggFunction.MIN, 'calculated-fields.metrics.aggregation-type.min'],
  [AggFunction.MAX, 'calculated-fields.metrics.aggregation-type.max'],
  [AggFunction.SUM, 'calculated-fields.metrics.aggregation-type.sum'],
  [AggFunction.COUNT, 'calculated-fields.metrics.aggregation-type.count'],
  [AggFunction.COUNT_UNIQUE, 'calculated-fields.metrics.aggregation-type.count-unique'],
])

export enum AggIntervalType {
  HOUR = 'HOUR',
  DAY = 'DAY',
  WEEK = 'WEEK',
  WEEK_SUN_SAT = 'WEEK_SUN_SAT',
  MONTH = 'MONTH',
  QUARTER = 'QUARTER',
  YEAR = 'YEAR',
  CUSTOM = 'CUSTOM'
}

export const AggIntervalTypeTranslations = new Map<AggIntervalType, string>(
  [
    [AggIntervalType.HOUR, 'calculated-fields.aggregate-period.hour'],
    [AggIntervalType.DAY, 'calculated-fields.aggregate-period.day'],
    [AggIntervalType.WEEK, 'calculated-fields.aggregate-period.week'],
    [AggIntervalType.WEEK_SUN_SAT, 'calculated-fields.aggregate-period.week-sun-sat'],
    [AggIntervalType.MONTH, 'calculated-fields.aggregate-period.month'],
    [AggIntervalType.QUARTER, 'calculated-fields.aggregate-period.quarter'],
    [AggIntervalType.YEAR, 'calculated-fields.aggregate-period.year'],
    [AggIntervalType.CUSTOM, 'calculated-fields.aggregate-period.custom']
  ]
);

export interface AggInterval {
  type: AggIntervalType;
  tz: string;
  offsetSec?: number
  durationSec?: number
}

export interface CalculatedFieldAggMetric {
  function: AggFunction;
  filter?: string;
  input: AggKeyInput | AggFunctionInput;
  defaultValue?: number;
}

export interface CalculatedFieldAggMetricValue extends CalculatedFieldAggMetric {
  name: string;
}

export enum AggInputType {
  key = 'key',
  function = 'function'
}

export const AggInputTypeTranslations = new Map<AggInputType, string>([
  [AggInputType.key, 'calculated-fields.metrics.value-source-type.key'],
  [AggInputType.function, 'calculated-fields.metrics.value-source-type.function'],
])

export interface AggKeyInput {
  type: AggInputType.key;
  key: string;
}

export interface AggFunctionInput {
  type: AggInputType.function;
  function: string;
}

export interface CalculatedFieldGeofencing {
  perimeterKeyName: string;
  reportStrategy: GeofencingReportStrategy;
  refEntityId?: RefEntityId;
  refDynamicSourceConfiguration: RefDynamicSourceGeofencingConfiguration;
  createRelationsWithMatchedZones: boolean;
  relationType: string;
  direction: EntitySearchDirection;
}

export interface RefDynamicSourceGeofencingConfiguration {
  type: ArgumentEntityType.RelationQuery | ArgumentEntityType.Owner;
  levels?: Array<RelationPathLevel>;
}

export interface CalculatedFieldGeofencingValue extends CalculatedFieldGeofencing {
  name: string;
  entityName?: string;
}

export interface RefEntityKey {
  key: string;
  type: ArgumentType;
  scope?: AttributeScope;
}

export interface RefEntityId {
  entityType: ArgumentEntityType;
  id: string;
}

export interface CalculatedFieldArgumentValue extends CalculatedFieldArgument {
  argumentName: string;
  entityName?: string;
}

export type CalculatedFieldTestScriptFn = (calculatedField: CalculatedField, argumentsObj?: Record<string, unknown>, closeAllOnSave?: boolean, expression?: string) => Observable<string>;

export interface CalculatedFieldTestScriptInputParams {
  arguments: CalculatedFieldEventArguments;
  expression: string;
}

export interface ArgumentEntityTypeParams {
  title: string;
  entityType: EntityType
}

export const ArgumentEntityTypeParamsMap =new Map<ArgumentEntityType, ArgumentEntityTypeParams>([
  [ArgumentEntityType.Device, { title: 'calculated-fields.device-name', entityType: EntityType.DEVICE }],
  [ArgumentEntityType.Asset, { title: 'calculated-fields.asset-name', entityType: EntityType.ASSET }],
  [ArgumentEntityType.Customer, { title: 'calculated-fields.customer-name', entityType: EntityType.CUSTOMER }],
])

export const getCalculatedFieldCurrentEntityFilter = (entityName: string, entityId: EntityId) => {
  switch (entityId?.entityType) {
    case EntityType.ASSET_PROFILE:
      return {
        assetTypes: [entityName],
        type: AliasFilterType.assetType
      };
    case EntityType.DEVICE_PROFILE:
      return {
        deviceTypes: [entityName],
        type: AliasFilterType.deviceType
      };
    default:
      return {
        type: AliasFilterType.singleEntity,
        singleEntity: entityId,
      };
  }
}

export const debugCfActionEnabled = (cf: CalculatedField) => {
  return (cf.type === CalculatedFieldType.SCRIPT ||
    (cf.type === CalculatedFieldType.PROPAGATION && cf.configuration.applyExpressionToResolvedArguments)
  );
}

export interface CalculatedFieldArgumentValueBase {
  argumentName: string;
  type: ArgumentType;
}

export interface RelationPathLevel {
  direction: EntitySearchDirection;
  relationType: string;
}

export interface CalculatedFieldAttributeArgumentValue<ValueType = unknown> extends CalculatedFieldArgumentValueBase {
  ts: number;
  value: ValueType;
}

export interface CalculatedFieldLatestTelemetryArgumentValue<ValueType = unknown> extends CalculatedFieldArgumentValueBase {
  ts: number;
  value: ValueType;
}

export interface CalculatedFieldRollingTelemetryArgumentValue<ValueType = unknown> extends CalculatedFieldArgumentValueBase {
  timeWindow: { startTs: number; endTs: number; };
  values: CalculatedFieldSingleArgumentValue<ValueType>[];
}

export type CalculatedFieldSingleArgumentValue<ValueType = unknown> = CalculatedFieldAttributeArgumentValue<ValueType> & CalculatedFieldLatestTelemetryArgumentValue<ValueType>;

export type CalculatedFieldArgumentEventValue<ValueType = unknown> = CalculatedFieldAttributeArgumentValue<ValueType> | CalculatedFieldLatestTelemetryArgumentValue<ValueType> | CalculatedFieldRollingTelemetryArgumentValue<ValueType>;

export type CalculatedFieldEventArguments<ValueType = unknown> = Record<string, CalculatedFieldArgumentEventValue<ValueType>>;

export const calculatedFieldsEntityTypeList = [EntityType.DEVICE, EntityType.ASSET, EntityType.DEVICE_PROFILE, EntityType.ASSET_PROFILE];

export const defaultCalculatedFieldOutput: CalculatedFieldOutputTimeSeries = {
  type: OutputType.Timeseries,
  strategy: {
    type: OutputStrategyType.IMMEDIATE,
    ttl: 0,
    saveTimeSeries: true,
    saveLatest: true,
    sendWsUpdate: true,
    processCfs: true
  }
}

export const defaultSimpleCalculatedFieldOutput: CalculatedFieldSimpleOutput = {
  name: '',
  ...defaultCalculatedFieldOutput
}

export const CalculatedFieldCtxLatestTelemetryArgumentAutocomplete = {
  meta: 'object',
  type: '{ ts: number; value: any; }',
  description: 'Calculated field context latest telemetry value argument.',
  children: {
    ts: {
      meta: 'number',
      type: 'number',
      description: 'Time stamp',
    },
    value: {
      meta: 'any',
      type: 'any',
      description: 'Value',
    }
  },
};

export const CalculatedFieldCtxAttributeValueArgumentAutocomplete = {
  meta: 'object',
  type: '{ ts: number; value: any; }',
  description: 'Calculated field context attribute value argument.',
  children: {
    ts: {
      meta: 'number',
      type: 'number',
      description: 'Time stamp',
    },
    value: {
      meta: 'any',
      type: 'any',
      description: 'Value',
    }
  },
};

export const CalculatedFieldLatestTelemetryArgumentAutocomplete = {
  meta: 'any',
  type: 'any',
  description: 'Calculated field latest telemetry argument value.',
};

export const CalculatedFieldAttributeValueArgumentAutocomplete = {
  meta: 'any',
  type: 'any',
  description: 'Calculated field attribute argument value.',
};

export const CalculatedFieldRollingValueArgumentFunctionsAutocomplete = {
  max: {
    meta: 'function',
    description: 'Returns the maximum value of the rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The maximum value, or NaN if applicable',
      type: 'number'
    }
  },
  min: {
    meta: 'function',
    description: 'Returns the minimum value of the rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The minimum value, or NaN if applicable',
      type: 'number'
    }
  },
  mean: {
    meta: 'function',
    description: 'Computes the mean value of the rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The mean value, or NaN if applicable',
      type: 'number'
    }
  },
  avg: {
    meta: 'function',
    description: 'Computes the average value of the rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The average value, or NaN if applicable',
      type: 'number'
    }
  },
  std: {
    meta: 'function',
    description: 'Computes the standard deviation of the rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The standard deviation, or NaN if applicable',
      type: 'number'
    }
  },
  median: {
    meta: 'function',
    description: 'Computes the median value of the rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The median value, or NaN if applicable',
      type: 'number'
    }
  },
  count: {
    meta: 'function',
    description: 'Counts values of the rolling argument. Counts non-NaN values if ignoreNaN is true, otherwise - total size.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The count of values',
      type: 'number'
    }
  },
  last: {
    meta: 'function',
    description: 'Returns the last non-NaN value of the rolling argument values if ignoreNaN is true, otherwise - the last value.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The last value, or NaN if applicable',
      type: 'number'
    }
  },
  first: {
    meta: 'function',
    description: 'Returns the first non-NaN value of the rolling argument values if ignoreNaN is true, otherwise - the first value.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The first value, or NaN if applicable',
      type: 'number'
    }
  },
  sum: {
    meta: 'function',
    description: 'Computes the sum of rolling argument values. Returns NaN if any value is NaN and ignoreNaN is false.',
    args: [
      {
        name: 'ignoreNaN',
        description: 'Whether to ignore NaN values. Equals true by default.',
        type: 'boolean',
        optional: true,
      }
    ],
    return: {
      description: 'The sum of values, or NaN if applicable',
      type: 'number'
    }
  },
  merge: {
    meta: 'function',
    description: 'Merges current object with other time series rolling argument into a single object by aligning their timestamped values. Supports optional configurable settings.',
    args: [
      {
        name: 'other',
        description: "A time series rolling argument to be merged with the current object.",
        type: "object",
        optional: true
      },
      {
        name: "settings",
        description: "Optional settings controlling the merging process. Supported keys: 'ignoreNaN' (boolean, equals true by default) to determine whether NaN values should be ignored; 'timeWindow' (object, empty by default) to apply time window filtering.",
        type: "object",
        optional: true
      }
    ],
    return: {
      description: 'A new object containing merged timestamped values from all provided arguments, aligned based on timestamps and filtered according to settings.',
      type: '{ values: { ts: number; values: number[]; }[]; timeWindow: { startTs: number; endTs: number } }; }',
    }
  },
  mergeAll: {
    meta: 'function',
    description: 'Merges current object with other time series rolling arguments into a single object by aligning their timestamped values. Supports optional configurable settings.',
    args: [
      {
        name: 'others',
        description: "A list of time series rolling arguments to be merged with the current object.",
        type: "object[]",
        optional: true
      },
      {
        name: "settings",
        description: "Optional settings controlling the merging process. Supported keys: 'ignoreNaN' (boolean, equals true by default) to determine whether NaN values should be ignored; 'timeWindow' (object, empty by default) to apply time window filtering.",
        type: "object",
        optional: true
      }
    ],
    return: {
      description: 'A new object containing merged timestamped values from all provided arguments, aligned based on timestamps and filtered according to settings.',
      type: '{ values: { ts: number; values: number[]; }[]; timeWindow: { startTs: number; endTs: number } }; }',
    }
  }
};

export const CalculatedFieldRollingValueArgumentAutocomplete = {
  meta: 'object',
  type: '{ values: { ts: number; value: number; }[]; timeWindow: { startTs: number; endTs: number } }; }',
  description: 'Calculated field rolling value argument.',
  children: {
    ...CalculatedFieldRollingValueArgumentFunctionsAutocomplete,
    values: {
      meta: 'array',
      type: '{ ts: number; value: any; }[]',
      description: 'Values array',
    },
    timeWindow: {
      meta: 'object',
      type: '{ startTs: number; endTs: number }',
      description: 'Time window configuration',
      children: {
        startTs: {
          meta: 'number',
          type: 'number',
          description: 'Start time stamp',
        },
        endTs: {
          meta: 'number',
          type: 'number',
          description: 'End time stamp',
        }
      }
    }
  },
};

export const getCalculatedFieldArgumentsEditorCompleter = (argumentsObj: Record<string, CalculatedFieldArgument>): TbEditorCompleter => {
  return new TbEditorCompleter(Object.keys(argumentsObj).reduce((acc, key) => {
    switch (argumentsObj[key].refEntityKey.type) {
      case ArgumentType.Attribute:
        acc[key] = CalculatedFieldAttributeValueArgumentAutocomplete;
        acc.ctx.children.args.children[key] = CalculatedFieldCtxAttributeValueArgumentAutocomplete;
        break;
      case ArgumentType.LatestTelemetry:
        acc[key] = CalculatedFieldLatestTelemetryArgumentAutocomplete;
        acc.ctx.children.args.children[key] = CalculatedFieldCtxLatestTelemetryArgumentAutocomplete;
        break;
      case ArgumentType.Rolling:
        acc[key] = CalculatedFieldRollingValueArgumentAutocomplete;
        acc.ctx.children.args.children[key] = CalculatedFieldRollingValueArgumentAutocomplete;
        break;
    }
    return acc;
  }, {
    ctx: {
      meta: 'object',
      type: '{ args: { [key: string]: object } }',
      description: 'Calculated field context.',
      children: {
        args: {
          meta: 'object',
          type: '{ [key: string]: object }',
          description: 'Calculated field context arguments.',
          children: {}
        },
        latestTs: {
          meta: 'constant',
          type: 'number',
          description: 'Latest timestamp (ms) of the arguments telemetry.'
        }
      }
    }
  }));
}

export const getCalculatedFieldArgumentsHighlights = (
  argumentsObj: Record<string, CalculatedFieldArgument>
): AceHighlightRules => {
  const calculatedFieldArgumentsKeys = Object.keys(argumentsObj).map(key => ({
    token: 'tb.calculated-field-key',
    regex: `\\b${key}\\b`,
    next: argumentsObj[key].refEntityKey.type === ArgumentType.Rolling
      ? 'calculatedFieldRollingArgumentValue'
      : 'no_regex'
  }));
  const calculatedFieldCtxArgumentsHighlightRules = {
    calculatedFieldCtxArgs: [
      dotOperatorHighlightRule,
      ...calculatedFieldArgumentsKeys.map(argumentRule => argumentRule.next === 'no_regex' ? {...argumentRule, next: 'calculatedFieldSingleArgumentValue' } : argumentRule),
      endGroupHighlightRule
    ]
  };

  return {
    start: [
      calculatedFieldArgumentsContextHighlightRules,
      ...calculatedFieldArgumentsKeys,
    ],
    ...calculatedFieldArgumentsContextValueHighlightRules,
    ...calculatedFieldCtxArgumentsHighlightRules,
    ...calculatedFieldSingleArgumentValueHighlightRules,
    ...calculatedFieldRollingArgumentValueHighlightRules,
    ...calculatedFieldTimeWindowArgumentValueHighlightRules
  };
};

const calculatedFieldArgumentsContextHighlightRules: AceHighlightRule = {
  token: 'tb.calculated-field-ctx',
  regex: /ctx/,
  next: 'calculatedFieldCtxValue'
}

const calculatedFieldArgumentsContextValueHighlightRules: AceHighlightRules = {
  calculatedFieldCtxValue: [
    dotOperatorHighlightRule,
    {
      token: 'tb.calculated-field-args',
      regex: /args/,
      next: 'calculatedFieldCtxArgs'
    },
    {
      token: 'tb.calculated-field-latestTs',
      regex: /latestTs/,
      next: 'no_regex'
    },
    endGroupHighlightRule
  ]
}

const calculatedFieldSingleArgumentValueHighlightRules: AceHighlightRules = {
  calculatedFieldSingleArgumentValue: [
    dotOperatorHighlightRule,
    {
      token: 'tb.calculated-field-value',
      regex: /value/,
      next: 'no_regex'
    },
    {
      token: 'tb.calculated-field-ts',
      regex: /ts/,
      next: 'no_regex'
    },
    endGroupHighlightRule
  ],
}

const calculatedFieldRollingArgumentValueFunctionsHighlightRules: Array<AceHighlightRule> =
  Object.keys(CalculatedFieldRollingValueArgumentFunctionsAutocomplete).map(funcName => ({
    token: 'tb.calculated-field-func',
    regex: `\\b${funcName}\\b`,
    next: 'no_regex'
  }));

const calculatedFieldRollingArgumentValueHighlightRules: AceHighlightRules = {
  calculatedFieldRollingArgumentValue: [
    dotOperatorHighlightRule,
    {
      token: 'tb.calculated-field-values',
      regex: /values/,
      next: 'no_regex'
    },
    {
      token: 'tb.calculated-field-time-window',
      regex: /timeWindow/,
      next: 'calculatedFieldRollingArgumentTimeWindow'
    },
    ...calculatedFieldRollingArgumentValueFunctionsHighlightRules,
    endGroupHighlightRule
  ],
}

const calculatedFieldTimeWindowArgumentValueHighlightRules: AceHighlightRules = {
  calculatedFieldRollingArgumentTimeWindow: [
    dotOperatorHighlightRule,
    {
      token: 'tb.calculated-field-start-ts',
      regex: /startTs/,
      next: 'no_regex'
    },
    {
      token: 'tb.calculated-field-end-ts',
      regex: /endTs/,
      next: 'no_regex'
    },
    endGroupHighlightRule
  ]
}

export const calculatedFieldDefaultScript =
  '// Sample script to convert temperature readings from Fahrenheit to Celsius\n' +
  'return {\n' +
  '    "temperatureC": (temperatureF - 32) / 1.8\n' +
  '};'

export function notEmptyObjectValidator(): ValidatorFn {
  return (control: AbstractControl): ValidationErrors | null => {
    const value = control.value;
    if (typeof value === 'object' && value !== null && Object.keys(value).length === 0) {
      return {emptyObject: true};
    }
    return null;
  };
}

export function forbiddenNamesValidator(forbiddenNames: string[]): ValidatorFn {
  const forbiddenNameSet = new Set(forbiddenNames);

  return (control: FormControl) => {
    const trimmedValue = (control.value || '').trim();
    return forbiddenNameSet.has(trimmedValue) ? { forbiddenName: true } : null;
  };
}

export function uniqueNameValidator(existingNames: string[]): ValidatorFn {
  const namesSet = new Set((existingNames || []).map(name => name.toLowerCase()));

  return (control: FormControl) => {
    const newName = (control.value || '').trim().toLowerCase();

    if (!newName) {
      return null;
    }

    return namesSet.has(newName) ? { duplicateName: true } : null;
  };
}

export interface CalculatedFieldsQuery {
  types: Array<CalculatedFieldType>;
  entityType?: EntityType;
  entities?: Array<string>;
  name?: Array<string>;
}

export const calculatedFieldMetricFilterDefaultScript =
  '// Sample filter script to include only active and unoccupied parking spaces\n' +
  '// Goal: Count only parking spaces that are active and currently free\n\n' +
  'return active == true && occupied == false;';

export const calculatedFieldMetricMapDefaultScript =
  '// Sample map script to convert temperature from Fahrenheit to Celsius\n' +
  '// Goal: Apply conversion per entity before aggregation (e.g., for average temperature)\n\n' +
  'var temperatureC = (temperature - 32) / 1.8;\n' +
  'return toFixed(temperatureC, 2);';