Function resolveForwardSenderFromHeader

yvlu/yvlu.ts:293–339

(
  forwardHeader: Api.MessageFwdHeader,
  client: any,
)

      return sender;
    }
  } catch (err) {
    console.debug("[yvlu] getSender failed:", err?.message || err);
  }
  const entity = await getPeerEntity((msg as any).client, peer);
  return entity;
}

function emojiStatusIdFromEntity(entity: any): string | undefined {
  const status = entity?.emojiStatus ?? entity?.emoji_status;
  if (!status) return undefined;
  if (typeof status !== "object") {
    const id = status?.value ?? status;
    return id ? String(id) : undefined;
  }
  const documentId = status.documentId ?? status.document_id ?? status.customEmojiId ?? status.custom_emoji_id ?? status.id;
  if (!documentId) return undefined;
  return String(documentId);
}

const hashCode = (s: any) => {
  const l = s.length;
  let h = 0;
  let i = 0;
  if (l > 0) {
    while (i < l) {
      h = ((h << 5) - h + s.charCodeAt(i++)) | 0;
    }
  }
  return h;
};

// 检测是否为 webm 格式
function isWebmFormat(buffer: Buffer): boolean {
  if (!buffer || buffer.length < 4) return false;
  // WebM 魔数: 0x1A 0x45 0xDF 0xA3 (EBML header)
  return (
    buffer[0] === 0x1a &&
    buffer[1] === 0x45 &&
    buffer[2] === 0xdf &&
    buffer[3] === 0xa3
  );
}

// 检测是否为 TGS 格式 (gzip 压缩的 Lottie JSON)
function isTgsFormat(buffer: Buffer): boolean {
  if (!buffer || buffer.length < 2) return false;
  // gzip 魔数: 0x1F 0x8B
  return buffer[0] === 0x1f && buffer[1] === 0x8b;
}