Function handleIncomingMessage

shift/shift.ts:2267–2389

(
  message: any,
  isEdited?: boolean
)

      replyTo: options?.replyTo,
    });

    console.log(
      `[SHIFT] 转发成功: ${fromChatId} -> ${toChatId}, msg=${messageId}, depth=${depth}`
    );

    // Check for chained forwarding
    const nextRule = await getShiftRule(toChatId);
    if (nextRule && !nextRule.paused && nextRule.target_id) {
      // Wait for message to arrive
      await abortableSleep(200, tryGetCurrentGenerationContext()?.signal);

      // Recursive forwarding with depth tracking
      await shiftForwardMessage(
        client,
        toChatId,
        nextRule.target_id,
        messageId,
        depth + 1,
        options
      );
    }
  } catch (error) {
    console.error(
      `[SHIFT] 转发失败: ${fromChatId} -> ${toChatId}, msg=${messageId}`,
      error
    );
    throw error;
  }
}

// Message handler for automatic forwarding
async function handleIncomingMessage(
  message: any,
  isEdited?: boolean
): Promise<void> {
  try {
    if (!message || !message.chat) {
      return;
    }

    const sourceId = getChatIdFromMessage(message, isEdited);
    if (!sourceId) {
      return;
    }

    const rule = await getShiftRule(sourceId);
    if (!rule || rule.paused) {
      return;
    }

    const targetId = rule.target_id;
    if (!targetId) {
      return;
    }

    // Check content protection
    if (message.chat.noforwards) {
      console.log(