return result_id if the row does not exists yet

getlago · Dec 19, 2024 · e7534d3 · e7534d3
1 parent 6da0c9e
commit e7534d3
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 10 deletions.
diff --git a/app/models/subscription_event_trigger.rb b/app/models/subscription_event_trigger.rb
@@ -2,6 +2,10 @@
 
 class SubscriptionEventTrigger < ApplicationRecord
   validates :organization_id, :external_subscription_id, :created_at, presence: true
+
+  def self.trigger(organization_id:, external_subscription_id:)
+    connection.select_all sanitize_sql_array(["call trigger_subscription_update(?,?, null)", organization_id, external_subscription_id])
+  end
 end
 
 # == Schema Information

diff --git a/db/events_structure.sql b/db/events_structure.sql
diff --git a/db/migrate/20241203140905_add_stored_procedure_for_triggering_subscription.rb b/db/migrate/20241203140905_add_stored_procedure_for_triggering_subscription.rb
@@ -6,7 +6,8 @@ def up
       execute "
   CREATE OR REPLACE PROCEDURE trigger_subscription_update(
       p_organization_id UUID,
-      p_external_subscription_id varchar
+      p_external_subscription_id varchar,
+      result_id INOUT UUID
   )
   LANGUAGE plpgsql
   AS $$
@@ -21,7 +22,8 @@ def up
           p_external_subscription_id,
           NOW()
       )
-      ON CONFLICT DO NOTHING;
+      ON CONFLICT DO NOTHING
+      RETURNING id INTO result_id;
   END;
   $$;"
     end

diff --git a/db/structure.sql b/db/structure.sql