@spec chat_messages_stream(map()) :: {:ok, map()} | {:error, any()}

Stream chat messages matching filter criteria (cursor-paginated).

Parameters

• params: A map of query parameters
  • :text_filter / :author / :author_id
  • :server_type — Messaging service type (e.g., "telegram", "discord")
  • :server_id / :room_id
  • :from / :until / :size / :cursor

Examples

{:ok, result} = Intel471Ex.Sources.chat_messages_stream(%{server_type: "telegram", size: 10})

@spec data_leak_site_posts_stream(map()) :: {:ok, map()} | {:error, any()}

Stream data leak site posts matching filter criteria (cursor-paginated).

Parameters

• params: A map of query parameters
  • :website_id — Filter by website ID
  • :thread_id — Filter by thread ID
  • :text_filter — Free text search
  • :from / :until / :size / :cursor

Examples

{:ok, result} = Intel471Ex.Sources.data_leak_site_posts_stream(%{text_filter: "ransomware", size: 10})

@spec forums_posts_stream(map()) :: {:ok, map()} | {:error, any()}

Stream forum posts matching filter criteria (cursor-paginated).

Parameters

• params: A map of query parameters
  • :thread_id / :author / :author_id / :forum_title
  • :text_filter — Free text search
  • :from / :until / :size / :cursor

Examples

{:ok, result} = Intel471Ex.Sources.forums_posts_stream(%{author: "username", size: 10})

@spec forums_private_messages_stream(map()) :: {:ok, map()} | {:error, any()}

Stream forum private messages matching filter criteria (cursor-paginated).

Parameters

• params: A map of query parameters
  • :text_filter / :author / :author_id / :forum_title
  • :subject / :recipient / :recipient_id / :forum_id
  • :from / :until / :size / :cursor

Examples

{:ok, result} = Intel471Ex.Sources.forums_private_messages_stream(%{author: "username", size: 10})

@spec get_chat_message(String.t()) :: {:ok, map()} | {:error, any()}

Get a chat message by ID.

Examples

{:ok, msg} = Intel471Ex.Sources.get_chat_message("message-id")

@spec get_data_leak_site_file_listing(String.t()) :: {:ok, map()} | {:error, any()}

Get a data leak site file listing (raw binary).

Examples

{:ok, %{body: data}} = Intel471Ex.Sources.get_data_leak_site_file_listing("listing-id")

@spec get_forum_post(String.t()) :: {:ok, map()} | {:error, any()}

Get a forum post by ID.

Examples

{:ok, post} = Intel471Ex.Sources.get_forum_post("post-id")

@spec get_forum_private_message(String.t()) :: {:ok, map()} | {:error, any()}

Get a forum private message by ID.

Examples

{:ok, pm} = Intel471Ex.Sources.get_forum_private_message("pm-id")

@spec get_image(String.t(), String.t(), String.t()) :: {:ok, map()} | {:error, any()}

Get an image from a source (raw binary).

Parameters

• type: Image type (e.g., "forum", "chat")
• hash: Image hash
• name: Image filename

Examples

{:ok, %{body: img}} = Intel471Ex.Sources.get_image("forum", "abc123", "screenshot.png")