Signal Parser: Extract Trading Data from Channel Messages

SIGNAL #TRX/USDT

Open SHORT in the zone $0.2898 – $0.2930 with 25x leverage.

Take-profit targets:
TP1: $0.2875
TP2: $0.2864
TP3: $0.2838

STOP-LOSS: $0.3027

const SIGNAL_FORMAT: ParseFormat<SignalFields> = {
  symbol: {
    pattern: /#([A-Z0-9]+)\/USDT/,
    group: 1,
    validate: (v) => v.length > 0,
  },
  direction: {
    pattern: /(ШОРТ|ЛОНГ)/i,
    transform: (raw) => (raw.toUpperCase() === "ШОРТ" ? "short" : "long"),
    validate: (v) => v === "short" || v === "long",
  },
  entry: {
    pattern: /зоне\s+\$?([\d.,]+)\s*[-–—]\s*(?:\$?[\d.,]+\s*[-–—]\s*)?\$?([\d.,]+)(?=\s)/i,
    transform: (_, m) => ({ from: num(m[1]), to: num(m[2]) }),
    validate: (v) => isNum(v.from) && isNum(v.to) && v.from < v.to,
  },
  targets: {
    pattern: /Закрыть(?:\s+ордер)?\s+по(?:\s+цене)?\s+\$?([\d.,]+)/gi,
    transform: (_, m) => num(m[1]),
    validate: (v) => isNum(v),
    multi: true,
  },
  stoploss: {
    pattern: /СТОП-?ЛОСС:\s*\$?([\d.,]+)/i,
    transform: (_, m) => num(m[1]),
    validate: (v) => isNum(v),
  },
};

interface ExtractConfig<T> {
  /** The extraction regex. Must have the global flag when multi = true. */
  pattern: RegExp;

  /** Capture group index to extract. Defaults to 1. */
  group?: number;

  /** Transforms the raw string match into the desired type. Receives the
   *  raw captured string and the full RegExpMatchArray. */
  transform?: (raw: string, match: RegExpMatchArray) => T;

  /** Returns false to reject the extracted value (the whole message fails). */
  validate?: (value: T) => boolean;

  /** If true, collect all matches via matchAll (requires global flag on pattern). */
  multi?: boolean;

  /** If true, a missing match does not fail the whole message. */
  optional?: boolean;
}

public parseDay = async <M extends FieldMapping>(
  messages: ScraperMessage[],
  format: M,
): Promise<ParserMessageBase<M>[]> => {
  this.loggerService.log("parserService parseDay", {
    messagesLen: messages.length,
  });

  const result: ParserMessageBase<M>[] = [];

  for (const msg of messages) {
    const extracted = EXTRACT_DATA_FN(msg.content, format);
    console.log("Parsed: ", {
      message: msg.content.slice(0, MAX_PREVIEW_CHARS).split("\n").join(" "),
      extracted,
    });
    result.push({
      ...msg,
      data: extracted,
    });
  }

  return result;
};