Add creator_id to the Notifications model

Author: VeljkoMaksimovic

front/lib/front/models/notification.ex

@@ -58,7 +58,7 @@ defmodule Front.Models.Notification do
 
   def create(user_id, org_id, notification_data, _metadata \\ nil) do
     Watchman.benchmark("notifications.create_notification_request.duration", fn ->
-      notification = construct_notification(notification_data)
+      notification = construct_notification(notification_data, user_id)
 
       {:ok, channel} = GRPC.Stub.connect(api_endpoint())
 
@@ -90,7 +90,7 @@ defmodule Front.Models.Notification do
 
   def update(user_id, org_id, notification_data) do
     Watchman.benchmark("notifications.update_notification_request.duration", fn ->
-      notification = construct_notification(notification_data)
+      notification = construct_notification(notification_data, user_id)
 
       {:ok, channel} = GRPC.Stub.connect(api_endpoint())
 
@@ -110,13 +110,13 @@ defmodule Front.Models.Notification do
     end)
   end
 
-  def construct_notification(data) do
+  def construct_notification(data, creator_id) do
     rules =
       data.rules
       |> Enum.map(&construct_rule(&1))
 
     PublicApi.Notification.new(
-      metadata: PublicApi.Notification.Metadata.new(name: data.name),
+      metadata: PublicApi.Notification.Metadata.new(name: data.name, creator_id: creator_id),
       spec: PublicApi.Notification.Spec.new(rules: rules)
     )
   end

notifications/lib/notifications/api/internal_api.ex

@@ -7,6 +7,8 @@ defmodule Notifications.Api.InternalApi do
   use Sentry.Grpc, service: Api.NotificationsApi.Service
 
   def list(req, _call) do
+    IO.puts("LIST INTERNAL")
+    IO.inspect(req)
     Notifications.Api.InternalApi.List.run(req)
   end
 

notifications/lib/notifications/api/internal_api/create.ex

@@ -8,10 +8,6 @@ defmodule Notifications.Api.InternalApi.Create do
   alias InternalApi.Notifications.CreateResponse
 
   def run(req) do
-    IO.puts("REQ RUN")
-    IO.inspect(req.metadata)
-    IO.inspect(req)
-
     org_id = req.metadata.org_id
 
     with {:ok, :valid} <- Validator.validate(req.notification),
@@ -37,6 +33,7 @@ defmodule Notifications.Api.InternalApi.Create do
         Models.Notification.new(
           org_id,
           notification.name,
+          notification.creator_id,
           Notifications.Util.Transforms.encode_spec(%{rules: notification.rules})
         )
 

notifications/lib/notifications/api/public_api/create.ex

@@ -45,6 +45,7 @@ defmodule Notifications.Api.PublicApi.Create do
         Models.Notification.new(
           org_id,
           notification.metadata.name,
+          notification.metadata.creator_id,
           Notifications.Util.Transforms.encode_spec(notification.spec)
         )
 

notifications/lib/notifications/models/notification.ex

@@ -18,10 +18,11 @@ defmodule Notifications.Models.Notification do
     timestamps()
   end
 
-  def new(org_id, name, spec) do
+  def new(org_id, name, creator_id, spec) do
     %__MODULE__{}
     |> changeset(%{
       org_id: org_id,
+      creator_id: creator_id,
       name: name,
       spec: spec
     })
@@ -78,8 +79,8 @@ defmodule Notifications.Models.Notification do
 
   def changeset(notification, params \\ %{}) do
     notification
-    |> cast(params, [:org_id, :name, :spec])
-    |> validate_required([:org_id, :name, :spec])
+    |> cast(params, [:org_id, :creator_id, :name, :spec])
+    |> validate_required([:org_id, :creator_id, :name, :spec])
     |> valid_name_format(params)
     |> unique_constraint(
       :unique_names,