timber

defmodule Mix.Tasks.Timber.TestThePipes do
  alias Mix.Tasks.Timber.Install.{IOHelper, Messages}
  alias Timber.Events

  def run([]) do
    """
    #{Messages.header()}
    #{Messages.forgot_key()}
    """
    |> IOHelper.puts(:red)
  end

  def run([_api_key]) do

  end

  def log_entries do
    request_id = generate_request_id()
    [
      log_entry(:info, request_id, "The following messages are test messages sent from the installer. They represent a real-world use case to demonstrate the power of context:"),
      log_entry(:info, request_id, http_request(request_id)),
      log_entry(:info, request_id, controller_call()),
      log_entry(:info, request_id, sql_query()),
      log_entry(:info, request_id, http_request_to_stripe(request_id)),
      log_entry(:info, request_id, http_response_from_stripe(request_id)),
      log_entry(:error, request_id, exception_event()),
      log_entry(:error, request_id, custom_event()),
      log_entry(:info, request_id, template_render()),
      log_entry(:info, request_id, http_response(request_id))
    ]
  end

  defp log_entry(level, request_id, %{__struct__: Events.CustomEvent} = event) do
    :timer.sleep(100)
    message = "Checkout failed for customer xd45bfd"
    {level, self(), {Logger, message, now(), [event: event, timber_context: context(request_id)]}}
  end

  defp log_entry(level, request_id, %{__struct__: module} = event) do
    :timer.sleep(100)
    dt = now()
    message = module.message(event)
    {level, self(), {Logger, message, dt, [event: event, timber_context: context(request_id)]}}
  end

  defp log_entry(level, request_id, message) when is_binary(message) do
    :timer.sleep(100)
    dt = now()
    {level, self(), {Logger, message, dt, [timber_context: context(request_id)]}}
  end

  defp now do
    dt = DateTime.utc_now()
    {{dt.year, dt.month, dt.day}, {dt.hour, dt.minute, dt.second, dt.microsecond}}
  end

  defp context(request_id) do
    %{
      http: %{
        method: "POST",
        path: "/orders",
        request_id: request_id,
        remote_addr: "123.123.123.123"
      },
      system: %{
        hostname: "server.host.net",
        pid: "123"
      },
      user: %{
        id: "24",
        name: "Paul Bunyan",
        email: "hi@timber.io"
      }
    }
  end

  defp controller_call do
    %Events.ControllerCallEvent{
      action: "create",
      controller: "OrderController"
    }
  end

  defp custom_event do
    %Events.CustomEvent{
      type: :checkout_failure,
      data: %{
        customer_id: "xd45bfd",
        amount: 523.43
      }
    }
  end

  defp exception_event do
    %Events.ErrorEvent{
      backtrace: [
        %{app_name: "my_app", function: "MyApp.OrderController.create/2", file: "web/controllers/order_controller.ex", line: 23},
        %{app_name: "my_app", function: "MyApp.OrderController.phoenix_controller_pipeline/2", file: "web/controllers/order_controller.ex", line: 1},
        %{app_name: "my_app", function: "MyApp.Endpoint.instrument/4", file: "lib/my_app/endpoint.ex", line: 1},
        %{app_name: "my_app", function: "MyApp.Router.dispatch/2", file: "lib/phoenix/router.ex", line: 261},
        %{app_name: "my_app", function: "MyApp.Router.do_call/1", file: "web/router.ex", line: 1},
        %{app_name: "my_app", function: "MyApp.Endpoint.call/2", file: "lib/my_app/endpoint.ex", line: 1}
      ],
      name: "CaseClauseError",
      message: "no case clause matching: {:ok, 422}"
    }
  end

  defp http_request(request_id) do
    %Events.HTTPRequestEvent{
      body: "{\"credit_card_token\": \"abcd1234\"}",
      direction: "incoming",
      host: "timber-test-events.com",
      headers: %{
        "accept": "application/json",
        "authorization": "Bearer [sanitized]",
        "content-type": "application/json",
        "user-agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_3) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/56.0.2924.87 Safari/537.36",
        "x-request-id": request_id
      },
      method: "POST",
      path: "/orders",
      port: 443,
      query_string: "?secure=true",
      request_id: request_id,
      scheme: "https"
    }
  end

  defp http_response(request_id) do
    %Events.HTTPResponseEvent{
      body: "{\"error\": \"Oops we had a problem\"}",
      direction: "outgoing",
      headers: %{
        "content-type": "application/json",
        "x-request-id": request_id
      },
      request_id: request_id,
      status: 500,
      time_ms: 101.53
    }
  end

  defp http_request_to_stripe(request_id) do
    %Events.HTTPRequestEvent{
      body: "{\"credit_card_token\": \"abcd1234\", \"customer_id\": \"xd45bfd\"}",
      direction: "outgoing",
      headers: %{
        "accept": "application/json",
        "authorization": "Basic [sanitized]",
        "content-type": "application/json",
        "user-agent": "Stripe Elixir Client v1.2",
        "x-request-id": request_id
      },
      host: "api.stripe.com",
      method: "POST",
      path: "/charge",
      port: 443,
      request_id: request_id,
      scheme: "https",
      service_name: "stripe"
    }
  end

  defp http_response_from_stripe(request_id) do
    %Events.HTTPResponseEvent{
      body: "{\"error\": \"credit card has expired\"}",
      direction: "incoming",
      headers: %{
        "content-type": "application/json",
        "x-request-id": request_id
      },
      request_id: request_id,
      service_name: "stripe",
      status: 422,
      time_ms: 86.23
    }
  end

  defp sql_query do
    %Events.SQLQueryEvent{
      sql: "SELECT * FROM productions WHERE id=2",
      time_ms: 13.2
    }
  end

  defp template_render do
    %Events.TemplateRenderEvent{
      name: "error.json",
      time_ms: 2.1
    }
  end

  defp generate_request_id do
    32
    |> :crypto.strong_rand_bytes()
    |> Base.encode16(case: :lower)
    |> binary_part(0, 32)
  end
end