feat: source.service_name for setting the service name on backends (#…

…2166)

* style: tweak dashboard new source position, refactor to heex

* feat: use source.service_name as a grouping for sources

* feat: add in entire event body to dd as metadata

* docs: add in Datadog backend adjustments

* chore: fix tests

docs/docs.logflare.com/docs/backends/datadog.mdx

@@ -21,4 +21,6 @@ The following values are required when creating a webhook backend:
 
 Implementation is based on the [webhook backend](/backends/webhook).
 
-Events will be gzipped and batch with a maximum of 250 events per request. The source name will be set as the service name.
+The entire event body will be set to the `data` key of the events sent to Datadog.
+
+Events will be gzipped and batch with a maximum of 250 events per request. The service name of the source will be used as the `ddservice`. If not set, it will default to the source name.

lib/logflare/backends/adaptor/datadog_adaptor.ex

@@ -76,9 +76,10 @@ defmodule Logflare.Backends.Adaptor.DatadogAdaptor do
     %Logflare.LogEvent{
       le
       | body: %{
-          message: formatted_ts <> " " <> Jason.encode!(le.body),
-          ddsource: "Logflare by Supabase",
-          service: le.source.name
+          "message" => formatted_ts <> " " <> (le.body["message"] || le.body["event_message"]),
+          "ddsource" => "Supabase",
+          "service" => le.source.service_name || le.source.name,
+          "data" => le.body
         }
     }
   end

lib/logflare/sources/source.ex

@@ -12,6 +12,7 @@ defmodule Logflare.Source do
   @derive {Jason.Encoder,
            only: [
              :name,
+             :service_name,
              :token,
              :id,
              :favorite,
@@ -104,6 +105,7 @@ defmodule Logflare.Source do
 
   schema "sources" do
     field(:name, :string)
+    field(:service_name, :string)
     field(:token, Ecto.UUID.Atom, autogenerate: true)
     field(:public_token, :string)
     field(:favorite, :boolean, default: false)
@@ -159,6 +161,7 @@ defmodule Logflare.Source do
     source
     |> cast(attrs, [
       :name,
+      :service_name,
       :token,
       :public_token,
       :favorite,
@@ -186,6 +189,7 @@ defmodule Logflare.Source do
     source
     |> cast(attrs, [
       :name,
+      :service_name,
       :token,
       :public_token,
       :favorite,