vendure/packages/dashboard/plugin/data-processor/base-data-processor.ts

import { Injector } from '@vendure/core';
import { Serializable } from 'node:child_process';

import { DASHBOARD_PLUGIN_OPTIONS } from '../constants';
import { SearchIndexingStrategy } from '../search-index/search-indexing.strategy';

import { DbIndexingStrategy } from '../search-index/db-indexing.strategy';
import { DashboardPluginOptions } from '../types';
import { DataProcessorInterface } from './data-processor.interface';

export abstract class BaseDataProcessor implements DataProcessorInterface {
    protected searchIndexingStrategy: SearchIndexingStrategy;

    init(injector: Injector) {
        const options = injector.get(DASHBOARD_PLUGIN_OPTIONS) as DashboardPluginOptions;
        this.searchIndexingStrategy = options.globalSearch?.indexingStrategy ?? new DbIndexingStrategy();
    }

    getBatchSize(): number {
        throw new Error('Not implemented');
    }

    getTotalResults(metadata: Record<string, Serializable> | undefined): Promise<number> {
        throw new Error('Not implemented');
    }

    processOne(id: string, metadata: Record<string, Serializable> | undefined): Promise<void> {
        throw new Error('Not implemented');
    }

    processBatch(
        skip: number,
        limit: number,
        metadata: Record<string, Serializable> | undefined,
    ): AsyncGenerator<void> {
        throw new Error('Not implemented');
    }
}