Class: CreateJazariTables

Inherits:
Object
  • Object
show all
Defined in:
lib/generators/jazari/install/templates/create_jazari_tables.rb

Overview

Host-adopted deliberately: jazari never auto-appends its migrations.

Instance Method Summary collapse

Instance Method Details

#change ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
 
# File 'lib/generators/jazari/install/templates/create_jazari_tables.rb', line 5

def change
  adapter = connection.adapter_name
  unless %w[PostgreSQL SQLite].include?(adapter)
    raise ActiveRecord::AdapterNotSpecified, "jazari supports PostgreSQL and SQLite, not #{adapter}"
  end
  postgres = adapter == "PostgreSQL"

  create_table :jazari_recipes do |t|
    t.string  :recipe_id, null: false
    t.integer :version, null: false, default: 1
    t.string  :topic, null: false
    t.text    :description, null: false, default: ""
    postgres ? t.jsonb(:checklist, null: false, default: []) : t.json(:checklist, null: false, default: [])
    t.string  :run_policy, null: false, default: "unrestricted"
    t.timestamps
    t.index :recipe_id, unique: true
    t.check_constraint "run_policy IN ('unrestricted', 'once_per_calendar_day')",
      name: "jazari_recipes_run_policy_chk"
  end

  create_table :jazari_anchors do |t|
    t.string :scope_type, null: false
    t.bigint :scope_id, null: false
    t.string :key, null: false
    t.timestamps
    t.index i[scope_type scope_id key], unique: true
  end

  create_table :jazari_runbooks do |t|
    t.string  :runbookable_type, null: false
    t.bigint  :runbookable_id, null: false
    t.string  :recipe_id, null: false
    t.string  :topic, null: false
    t.text    :description, null: false, default: ""
    postgres ? t.jsonb(:checklist, null: false, default: []) : t.json(:checklist, null: false, default: [])
    # Provenance, host-defined and nullable. A runbook that exists because a
    # backfill created it is a migration artifact; one that exists because an
    # operator edited it is a decision. Both differ from the canon, so
    # comparing content cannot tell them apart — only provenance can, and NULL
    # honestly means "we did not record why".
    t.string  :origin
    t.integer :lock_version, null: false, default: 0
    t.timestamps
    t.index i[runbookable_type runbookable_id], unique: true
    t.index :recipe_id
  end

  create_table :jazari_runs do |t|
    t.string     :recipe_id, null: false
    t.string     :source_digest, null: false
    t.string     :subject_type
    t.bigint     :subject_id
    t.string     :actor_ref, null: false
    postgres ? t.timestamptz(:started_at, null: false) : t.datetime(:started_at, null: false)
    t.date       :started_on, null: false
    t.string     :idempotency_policy, null: false, default: "unrestricted"
    postgres ? t.timestamptz(:finished_at) : t.datetime(:finished_at)
    t.string     :outcome
    if postgres
      t.jsonb :checklist_snapshot, null: false
      t.jsonb :ticks, null: false, default: []
      t.jsonb :evidence, null: false, default: []
    else
      t.json :checklist_snapshot, null: false
      t.json :ticks, null: false, default: []
      t.json :evidence, null: false, default: []
    end
    t.integer    :lock_version, null: false, default: 0
    t.timestamps
    t.index i[recipe_id started_at]
    t.index i[subject_type subject_id started_at]
    t.check_constraint "idempotency_policy IN ('unrestricted', 'once_per_calendar_day')",
      name: "jazari_runs_idempotency_policy_chk"
    utc_date_expression = if postgres
      "started_on = (started_at AT TIME ZONE 'UTC')::date"
    else
      "started_on = date(started_at)"
    end
    t.check_constraint utc_date_expression,
      name: "jazari_runs_started_on_utc_chk"
    t.check_constraint "(subject_type IS NULL AND subject_id IS NULL) OR " \
                       "(subject_type IS NOT NULL AND subject_id IS NOT NULL)",
      name: "jazari_runs_subject_pair_chk"
  end

  # The idempotency constraint. COALESCE collapses the nullable polymorphic
  # subject so queue runs (both columns NULL) share one uniqueness key —
  # a plain unique index would not constrain them at all, because NULL != NULL.
  execute "    CREATE UNIQUE INDEX jazari_runs_once_per_day_idx\n    ON jazari_runs (\n      recipe_id,\n      COALESCE(subject_type, ''),\n      COALESCE(subject_id, 0),\n      started_on\n    )\n    WHERE idempotency_policy = 'once_per_calendar_day';\n  SQL\nend\n"