Plugin Kit v0.3.0

defmodule MyOsintAdapter do
  @moduledoc """
  OSINT data collection adapter for social media monitoring.
  Implements the PrismaticPlugin.Adapter behaviour.
  """

  use PrismaticPlugin.Adapter

  @impl PrismaticPlugin.Adapter
  def search(query, opts \\ []) do
    with {:ok, data} <- fetch_data(query),
         {:ok, normalized} <- normalize_data(data) do
      {:ok, normalized}
    else
      {:error, reason} -> {:error, reason}
    end
  end

  @impl PrismaticPlugin.Adapter
  def stream(query, callback) when is_function(callback, 1) do
    # Real-time data streaming implementation
    start_stream(query, callback)
  end

  # Private implementation functions
  defp fetch_data(query) do
    # API calls with rate limiting and error handling
  end

  defp normalize_data(raw_data) do
    # Data transformation and validation
  end
end""",
        config: """
# config/config.exs
config :my_osint_adapter,
  api_key: {:system, "OSINT_API_KEY"},
  rate_limit: [
    requests_per_minute: 60,
    burst_size: 10
  ],
  retry_policy: [
    max_attempts: 3,
    backoff: :exponential
  ]""",
        test: """
defmodule MyOsintAdapterTest do
  use PrismaticPlugin.TestCase

  test "search returns normalized data" do
    mock_response = %{
      "results" => [
        %{"user" => "test", "content" => "test post"}
      ]
    }

    expect_http_call("/search", mock_response)

    {:ok, results} = MyOsintAdapter.search("test query")

    assert length(results) == 1
    assert %{source: "osint", data: _} = hd(results)
  end
end"""
      },
      "financial" => %{
        init_command: "prismatic-plugin init my-financial-adapter --template=financial",
        code: """
defmodule MyFinancialAdapter do
  @moduledoc """
  Financial data adapter with SEC compliance features.
  """

  use PrismaticPlugin.Adapter
  use PrismaticPlugin.Compliance, :sec

  @impl PrismaticPlugin.Adapter
  def search(query, opts \\ []) do
    with {:ok, validated_query} <- validate_compliance(query),
         {:ok, data} <- fetch_sec_data(validated_query),
         {:ok, enriched} <- enrich_financial_data(data) do
      {:ok, enriched}
    end
  end

  # SEC compliance validation
  defp validate_compliance(query) do
    case PrismaticPlugin.Compliance.SEC.validate(query) do
      :ok -> {:ok, query}
      {:error, violations} -> {:error, {:compliance_error, violations}}
    end
  end

  # Secure financial data fetching
  defp fetch_sec_data(query) do
    # Implementation with audit trails
  end
end""",
        config: """
# config/config.exs
config :my_financial_adapter,
  sec_api_key: {:system, "SEC_API_KEY"},
  compliance_level: :strict,
  audit_trail: true,
  encryption: [
    algorithm: :aes_gcm,
    key_rotation_days: 30
  ]""",
        test: """
defmodule MyFinancialAdapterTest do
  use PrismaticPlugin.TestCase
  use PrismaticPlugin.ComplianceTestCase, :sec

  test "validates SEC compliance before data access" do
    invalid_query = %{insider_trading: true}

    assert {:error, {:compliance_error, _}} =
      MyFinancialAdapter.search(invalid_query)
  end

  test "maintains audit trail" do
    query = %{symbol: "AAPL"}
    {:ok, _results} = MyFinancialAdapter.search(query)

    assert_audit_logged(:financial_query, query)
  end
end