import { of, takeUntil, map, distinctUntilChanged, shareReplay, switchMap, iif, Observable, Subject } from 'rxjs' import type { DefinePluginConfig } from '../../../lib/core-types' import { defineGridPlugin } from '../../../lib/core' import { DEFAULT_STACKED_VALUE_AXIS_PARAMS } from '../defaults' import { LAYER_INDEX_OF_AXIS } from '../../const' import { createBaseValueAxis } from '../../base/BaseValueAxis' const pluginName = 'StackedValueAxis' const pluginConfig: DefinePluginConfig = { name: pluginName, defaultParams: DEFAULT_STACKED_VALUE_AXIS_PARAMS, layerIndex: LAYER_INDEX_OF_AXIS, validator: (params, { validateColumns }) => { const result = validateColumns(params, { labelOffset: { toBe: '[number, number]', test: (value: any) => { return Array.isArray(value) && value.length === 2 && typeof value[0] === 'number' && typeof value[1] === 'number' } }, labelColorType: { toBeOption: 'ColorType', }, axisLineVisible: { toBeTypes: ['boolean'] }, axisLineColorType: { toBeOption: 'ColorType', }, ticks: { toBeTypes: ['number', 'null'] }, tickFormat: { toBeTypes: ['string', 'Function'] }, tickLineVisible: { toBeTypes: ['boolean'] }, tickPadding: { toBeTypes: ['number'] }, tickFullLine: { toBeTypes: ['boolean'] }, tickFullLineDasharray: { toBeTypes: ['string'] }, tickColorType: { toBeOption: 'ColorType', }, tickTextRotate: { toBeTypes: ['number'] }, tickTextColorType: { toBeOption: 'ColorType', } }) return result } } export const StackedValueAxis = defineGridPlugin(pluginConfig)(({ selection, name, observer, subject }) => { const destroy$ = new Subject() const unsubscribeBaseValueAxis = createBaseValueAxis(pluginName, { selection, computedData$: observer.computedStackedData$, // 計算疊加value的資料 filteredMinMaxValue$: observer.filteredStackedMinMaxValue$, fullParams$: observer.fullParams$, fullDataFormatter$: observer.fullDataFormatter$, fullChartParams$: observer.fullChartParams$, gridAxesTransform$: observer.gridAxesTransform$, gridAxesReverseTransform$: observer.gridAxesReverseTransform$, gridAxesSize$: observer.gridAxesSize$, gridContainerPosition$: observer.gridContainerPosition$, isSeriesSeprate$: observer.isSeriesSeprate$, }) return () => { destroy$.next(undefined) unsubscribeBaseValueAxis() } })