Data Flow: parser-items to screen-items MongoDB Collections

// packages/core/src/schema/Parser.schema.ts
interface IParserDto {
  channel: string;          // Telegram channel identifier, e.g. "crypto_yoda_channel"
  source: string;           // Same as channel (reserved for multi-source future use)
  messageId: number;        // Telegram message ID — part of the unique compound index
  publishedAt: Date;        // UTC timestamp of the original Telegram message
  note: string;             // Raw message text as received from Telegram

  symbol: string;           // Trading pair, e.g. "SOLUSDT"
  direction: "long" | "short";
  entry: { from: number; to: number };  // Entry price zone
  targets: number[];        // Ordered take-profit levels (targets[2] is TP used by strategy)
  stoploss: number;         // Hard stop-loss price level

  content: unknown;         // Full parsed data object (Mixed, for audit)
}

interface IParserRow extends IParserDto {
  id: string;               // MongoDB ObjectId as string
  visited: boolean;         // false until SignalJobService processes this row
  createDate: Date;
  updatedDate: Date;
}

// Unique constraint: one document per (channel, messageId)
ParserSchema.index({ channel: 1, messageId: 1 }, { unique: true });

// Query pattern: latest signals for a given symbol
ParserSchema.index({ symbol: 1, publishedAt: -1 });

// packages/core/src/schema/Screen.schema.ts
interface IScreenDto {
  parserItemId: string;     // ObjectId string of the originating parser-items document

  channel: string;
  source: string;
  publishedAt: Date;
  symbol: string;

  direction: "long" | "short";
  entryFrom: number;        // Flattened from parser entry.from
  entryTo: number;          // Flattened from parser entry.to
  targets: number[];
  stoploss: number;

  // LLM risk verdict fields (from RiskOutlineContract)
  riskAction: "skip" | "follow";
  riskSureLevel: "low" | "low_medium" | "medium" | "medium_high" | "high";
  riskConfidence: "reliable" | "not_reliable";
  riskDescription: string;  // 2-3 sentence human-readable verdict
  riskReasoning: string;    // Step-by-step audit string with \n separators

  note: string;             // Raw message text (copied from parser item)
  content: unknown;         // Full parsed payload (copied from parser item)
}

interface IScreenRow extends IScreenDto {
  id: string;
  createDate: Date;
  updatedDate: Date;
}

// Unique constraint: one screen record per parser item
ScreenSchema.index({ parserItemId: 1 }, { unique: true });

// Query pattern: latest risk verdicts for a given symbol
ScreenSchema.index({ symbol: 1, publishedAt: -1 });

// Strategy usage — content/jan_2026.strategy/jan_2026.strategy.ts
const signal = await core.signalMainService.getLast4HourSignal(symbol, when);

if (!signal)                        return null;  // no recent signal
if (signal.riskAction === "skip")   return null;  // LLM vetoed