use timestamptz for journaled outbox event timestamps (#57)

Author: effron

Gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: .
   specs:
-    journaled (6.2.0)
+    journaled (6.2.1)
       activejob
       activerecord
       activesupport

db/migrate/2_create_journaled_events.rb

@@ -3,7 +3,7 @@
 class CreateJournaledEvents < ActiveRecord::Migration[7.2]
   def change
     # UUID v7 primary key (auto-generated by database using uuid_generate_v7())
-    create_table :journaled_outbox_events, id: :uuid, default: -> { "uuid_generate_v7()" } do |t|
+    create_table :journaled_outbox_events, id: :uuid, default: -> { "uuid_generate_v7()" } do |t| # rubocop:disable Rails/CreateTableWithTimestamps
       # Event identification and data
       t.string :event_type, null: false
       t.jsonb :event_data, null: false
@@ -12,8 +12,8 @@ def change
 
       t.text :failure_reason
 
-      t.datetime :failed_at
-      t.datetime :created_at, null: false, default: -> { "clock_timestamp()" }
+      t.column :failed_at, :timestamptz
+      t.column :created_at, :timestamptz, null: false, default: -> { "clock_timestamp()" }
     end
 
     # Index for querying failed events

gemfiles/rails_7_2.gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: ..
   specs:
-    journaled (6.2.0)
+    journaled (6.2.1)
       activejob
       activerecord
       activesupport

gemfiles/rails_8_0.gemfile.lock

@@ -1,7 +1,7 @@
 PATH
   remote: ..
   specs:
-    journaled (6.2.0)
+    journaled (6.2.1)
       activejob
       activerecord
       activesupport

lib/journaled/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Journaled
-  VERSION = "6.2.0"
+  VERSION = "6.2.1"
 end

spec/dummy/db/schema.rb

@@ -38,21 +38,17 @@
     t.string "other_column"
   end
 
-  # Use uuid_generate_v7() for PostgreSQL, nil for SQLite (outbox tests require PostgreSQL)
-  id_default = if ActiveRecord::Base.connection.adapter_name == 'PostgreSQL'
-    -> { "uuid_generate_v7()" }
-  else
-    nil
-  end
-
-  create_table "journaled_outbox_events", id: :uuid, default: id_default, force: :cascade do |t|
-    t.string "event_type", null: false
-    t.text "event_data", null: false
-    t.string "partition_key", null: false
-    t.string "stream_name", null: false
-    t.text "failure_reason"
-    t.datetime "failed_at"
-    t.datetime "created_at", null: false, default: -> { "clock_timestamp()" }
-    t.index ["failed_at"], name: "index_journaled_outbox_events_on_failed_at"
+  # Outbox events table is PostgreSQL-only (uses jsonb, timestamptz, uuid_generate_v7)
+  if ActiveRecord::Base.connection.adapter_name == 'PostgreSQL'
+    create_table "journaled_outbox_events", id: :uuid, default: -> { "uuid_generate_v7()" }, force: :cascade do |t|
+      t.string "event_type", null: false
+      t.jsonb "event_data", null: false
+      t.string "partition_key", null: false
+      t.string "stream_name", null: false
+      t.text "failure_reason"
+      t.timestamptz "failed_at"
+      t.timestamptz "created_at", null: false, default: -> { "clock_timestamp()" }
+      t.index ["failed_at"], name: "index_journaled_outbox_events_on_failed_at"
+    end
   end
 end