fix(trigger): Adds REPLACE option to trigger creation, defaults to true (#26)

Author: bougyman

lib/sequel/pgt_outbox/trigger.rb

@@ -6,7 +6,7 @@ module Rubyists
   module PgtOutbox
     # The Outbox Trigger
     class Trigger
-      DEFAULT_OPTS = { after: true, each_row: true }.freeze
+      DEFAULT_OPTS = { after: true, each_row: true, replace: true }.freeze
 
       attr_reader(*%i[db table function events opts])
 
@@ -27,7 +27,7 @@ def name
       end
 
       def create!
-        db.create_trigger(table, name, function, events:, each_row:, after:, when: where)
+        db.create_trigger(table, name, function, after:, each_row:, events:, replace:, when: where)
         self
       end
 
@@ -43,6 +43,10 @@ def each_row
         trigger_opts.fetch(:each_row)
       end
 
+      def replace
+        trigger_opts.fetch(:replace)
+      end
+
       def trigger_opts
         @trigger_opts ||= DEFAULT_OPTS.merge(opts.fetch(:trigger_opts, {}))
       end