wip

Author: nbudin

app/models/event.rb

@@ -19,7 +19,6 @@
 #  organization                 :string
 #  participant_communications   :text
 #  private_signup_list          :boolean          default(FALSE), not null
-#  registration_policy          :jsonb
 #  short_blurb                  :text
 #  status                       :string           default("active"), not null
 #  team_mailing_list_name       :text
@@ -31,21 +30,24 @@
 #  convention_id                :bigint           not null
 #  event_category_id            :bigint           not null
 #  owner_id                     :bigint
+#  registration_policy_id       :bigint           not null
 #  updated_by_id                :bigint
 #
 # Indexes
 #
-#  index_events_on_convention_id      (convention_id)
-#  index_events_on_event_category_id  (event_category_id)
-#  index_events_on_owner_id           (owner_id)
-#  index_events_on_title_vector       (title_vector) USING gin
-#  index_events_on_updated_by_id      (updated_by_id)
+#  index_events_on_convention_id           (convention_id)
+#  index_events_on_event_category_id       (event_category_id)
+#  index_events_on_owner_id                (owner_id)
+#  index_events_on_registration_policy_id  (registration_policy_id)
+#  index_events_on_title_vector            (title_vector) USING gin
+#  index_events_on_updated_by_id           (updated_by_id)
 #
 # Foreign Keys
 #
 #  fk_rails_...  (convention_id => conventions.id)
 #  fk_rails_...  (event_category_id => event_categories.id)
 #  fk_rails_...  (owner_id => users.id)
+#  fk_rails_...  (registration_policy_id => registration_policies.id)
 #  fk_rails_...  (updated_by_id => users.id)
 #
 # rubocop:enable Layout/LineLength, Lint/RedundantCopDisableDirective

app/models/registration_policy_bucket.rb

@@ -0,0 +1,29 @@
+# rubocop:disable Layout/LineLength, Lint/RedundantCopDisableDirective
+# == Schema Information
+#
+# Table name: registration_policy_buckets
+#
+#  id                     :bigint           not null, primary key
+#  counted                :boolean          default(TRUE), not null
+#  description            :text
+#  expose_attendees       :boolean          default(FALSE), not null
+#  flex                   :boolean          default(FALSE), not null
+#  key                    :string           not null
+#  minimum_slots          :integer
+#  name                   :text             not null
+#  position               :integer          not null
+#  preferred_slots        :integer
+#  slots_limited          :boolean          default(FALSE), not null
+#  total_slots            :integer
+#  created_at             :datetime         not null
+#  updated_at             :datetime         not null
+#  registration_policy_id :bigint           not null
+#
+# Indexes
+#
+#  idx_on_registration_policy_id_key_b71cb40026                 (registration_policy_id,key) UNIQUE
+#  index_registration_policy_buckets_on_registration_policy_id  (registration_policy_id)
+#
+# rubocop:enable Layout/LineLength, Lint/RedundantCopDisableDirective
+class RegistrationPolicyBucket < ApplicationRecord
+end

db/migrate/20260615192952_convert_registration_policies_to_tables.rb

@@ -0,0 +1,124 @@
+class ConvertRegistrationPoliciesToTables < ActiveRecord::Migration[8.1]
+  def change
+    create_table :registration_policies do |t|
+      t.boolean :prevent_no_preference_signups, null: false, default: false
+      t.boolean :freeze_no_preference_buckets, null: false, default: false
+
+      t.timestamps
+    end
+
+    create_table :registration_policy_buckets do |t|
+      t.references :registration_policy, null: false
+      t.integer :position, null: false
+      t.string :key, null: false
+      t.text :name, null: false
+      t.text :description
+      t.integer :minimum_slots
+      t.integer :preferred_slots
+      t.integer :total_slots
+      t.boolean :slots_limited, default: false, null: false
+      t.boolean :flex, default: false, null: false
+      t.boolean :counted, default: true, null: false
+      t.boolean :expose_attendees, default: false, null: false
+
+      t.timestamps
+
+      t.index [:registration_policy_id, :key], unique: true
+    end
+
+    add_reference :events, :registration_policy, foreign_key: true
+
+    reversible do |dir|
+      dir.up do
+        data = select_rows("SELECT id, registration_policy FROM events")
+        data.each do |(event_id, policy_json)|
+          policy = JSON.parse(policy_json || "{}")
+          now = Time.zone.now
+
+          registration_policy_id = exec_insert(
+            "INSERT INTO registration_policies (prevent_no_preference_signups, freeze_no_preference_buckets, created_at, updated_at) VALUES ($1, $2, $3, $4)",
+            "RegistrationPolicy insert",
+            [
+              !!policy["prevent_no_preference_signups"],
+              !!policy["freeze_no_preference_buckets"],
+              now,
+              now
+            ],
+            returning: [:id]
+          ).rows.first.first
+
+          now = Time.zone.now
+          bucket_values = (policy["buckets"] || []).each_with_index.map do |bucket, index|
+            {
+              registration_policy_id:,
+              position: index + 1,
+              key: bucket["key"],
+              name: bucket["name"] || bucket["key"],
+              description: bucket["description"],
+              minimum_slots: bucket["minimum_slots"],
+              preferred_slots: bucket["preferred_slots"],
+              total_slots: bucket["total_slots"],
+              slots_limited: !!bucket["slots_limited"],
+              flex: !!bucket["anything"],
+              counted: !bucket["not_counted"], # we're inverting the meaning on this one
+              expose_attendees: !!bucket["expose_attendees"],
+              created_at: now,
+              updated_at: now
+            }
+          end
+
+          exec_insert(
+            <<~SQL.squish,
+              INSERT INTO registration_policy_buckets
+              (
+                registration_policy_id,
+                position,
+                key,
+                name,
+                description,
+                minimum_slots,
+                preferred_slots,
+                total_slots,
+                slots_limited,
+                flex,
+                counted,
+                expose_attendees,
+                created_at,
+                updated_at
+              )
+              SELECT
+                registration_policy_id,
+                position,
+                key,
+                name,
+                description,
+                minimum_slots,
+                preferred_slots,
+                total_slots,
+                slots_limited,
+                flex,
+                counted,
+                expose_attendees,
+                created_at,
+                updated_at
+              FROM jsonb_populate_recordset(NULL::registration_policy_buckets, $1::jsonb)
+            SQL
+            "RegistrationPolicyBucket bulk insert",
+            [bucket_values.to_json]
+          )
+
+          exec_update(
+            "UPDATE events SET registration_policy_id = $1 WHERE id = $2",
+            "Event update",
+            [registration_policy_id, event_id]
+          )
+        end
+      end
+    end
+
+    change_table :events, bulk: true do |t|
+      t.remove :registration_policy, type: :jsonb
+      t.change_null :registration_policy_id, false
+    end
+  end
+end