Validate special props

lib/plausible/event/clickhouse_schema.ex

@@ -1,7 +1,10 @@
 defmodule Plausible.ClickhouseEvent do
   use Ecto.Schema
+
   import Ecto.Changeset
 
+  alias Plausible.ValueHelpers
+
   @primary_key false
   schema "events" do
     field :event_id, :integer
@@ -89,5 +92,27 @@ defmodule Plausible.ClickhouseEvent do
       empty_values: [nil, ""]
     )
     |> validate_required([:name, :domain, :hostname, :pathname, :event_id, :user_id, :timestamp])
+    |> validate_campaign_id()
+    |> validate_product_id()
+  end
+
+  defp validate_campaign_id(changeset) do
+    campaign_id = get_field(changeset, :campaign_id)
+
+    if ValueHelpers.validate(campaign_id, type: :prefixed_id) do
+      changeset
+    else
+      delete_change(changeset, :campaign_id)
+    end
+  end
+
+  defp validate_product_id(changeset) do
+    product_id = get_field(changeset, :product_id)
+
+    if ValueHelpers.validate(product_id, type: :prefixed_id) do
+      changeset
+    else
+      delete_change(changeset, :product_id)
+    end
   end
 end

lib/plausible/helpers/value.ex

@@ -0,0 +1,12 @@
+defmodule Plausible.ValueHelpers do
+  @spec validate(any(), keyword()) :: any()
+  def validate(value, type: :prefixed_id) when is_binary(value) do
+    prefixed_id_pattern = ~r/\A\w+-\d+\Z/
+
+    if Regex.match?(prefixed_id_pattern, value), do: value, else: nil
+  end
+
+  def validate(nil, _), do: nil
+  def validate("", _), do: nil
+  def validate(value, _), do: value
+end

lib/plausible/session/clickhouse_schema.ex

@@ -1,7 +1,10 @@
 defmodule Plausible.ClickhouseSession do
   use Ecto.Schema
+
   import Ecto.Changeset
 
+  alias Plausible.ValueHelpers
+
   @primary_key false
   schema "sessions" do
     field :hostname, :string
@@ -80,5 +83,27 @@ defmodule Plausible.ClickhouseSession do
       :screen_size
     ])
     |> validate_required([:hostname, :domain, :fingerprint, :is_bounce, :start])
+    |> validate_campaign_id()
+    |> validate_product_id()
+  end
+
+  defp validate_campaign_id(changeset) do
+    campaign_id = get_field(changeset, :campaign_id)
+
+    if ValueHelpers.validate(campaign_id, type: :prefixed_id) do
+      changeset
+    else
+      delete_change(changeset, :campaign_id)
+    end
+  end
+
+  defp validate_product_id(changeset) do
+    product_id = get_field(changeset, :product_id)
+
+    if ValueHelpers.validate(product_id, type: :prefixed_id) do
+      changeset
+    else
+      delete_change(changeset, :product_id)
+    end
   end
 end

test/plausible_web/controllers/api/external_controller_test.exs

@@ -527,6 +527,37 @@ defmodule PlausibleWeb.Api.ExternalControllerTest do
       assert Map.get(event, :"meta.value") == []
     end
 
+    test "casts special props, invalidates specific params", %{conn: conn} do
+      params = %{
+        name: "Signup",
+        url: "http://gigride.live/",
+        domain: "special-props-validation-test.com",
+        props: %{
+          campaign_id: "12345",
+          company_id: 10,
+          page_id: 15,
+          product_id: "incorrect-product-id",
+          careers_application_form_uuid: "313a26c2-741c-421c-9a6b-f39c02c8d35c"
+        }
+      }
+
+      conn
+      |> post("/api/event", params)
+
+      event = get_event("special-props-validation-test.com")
+
+      assert Map.get(event, :campaign_id) == ""
+      assert Map.get(event, :product_id) == ""
+      assert Map.get(event, :company_id) == 10
+      assert Map.get(event, :page_id) == 15
+
+      assert Map.get(event, :careers_application_form_uuid) ==
+               "313a26c2-741c-421c-9a6b-f39c02c8d35c"
+
+      assert Map.get(event, :"meta.key") == []
+      assert Map.get(event, :"meta.value") == []
+    end
+
     test "generates event id", %{conn: conn} do
       params = %{
         name: "Signup",