processor.ts

import { Axios } from 'axios';

import { BlocksClient } from '../clients/blocks';
import { CatalogClient } from '../clients/catalog';
import { EVMClient } from '../clients/evm';
import { IPFSClient } from '../clients/ipfs';
import { NOIZDClient } from '../clients/noizd';
import { SolanaClient } from '../clients/solana';
import { SoundClient } from '../clients/sound';
import { DBClient } from '../db/db';

import { ChainId } from './chain';
import { ProcessedTrack } from './track';
import { Cursor, Trigger } from './trigger';

export type TrackAPIClient = {
  fetchTracksByTrackId: (trackIds: string[]) => Promise<any[]>;
}

export type TrackAPIClientWithPremints = TrackAPIClient & {
  fetchLatestTrackCursor: () => Promise<string>;
  getTracksFrom: (cursor: string) => Promise<any[]>;
  getAPITrackCursor: (track: any) => string
  mapAPITrack: (apiTrack: any) => ProcessedTrack
}

export type Clients = {
  db: DBClient,
  blocks: BlocksClient,
  axios: Axios,
  ipfs: IPFSClient,
  catalog: CatalogClient,
  sound: SoundClient,
  noizd: NOIZDClient
  solana: SolanaClient;
  evmChain: { [chainId in ChainId]: EVMClient };
}

export type Processor = {
  name?: string,
  trigger: Trigger<Cursor | undefined>,
  processorFunction: (newTriggerItems: any, clients: Clients) => Promise<void>;
  initialCursor?: Cursor | undefined;
};