forked from algertc/ALPR-Database
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathmigrations.sql
More file actions
9732 lines (9063 loc) 路 429 KB
/
Copy pathmigrations.sql
File metadata and controls
9732 lines (9063 loc) 路 429 KB
1
2
3
4
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
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
CREATE EXTENSION IF NOT EXISTS pg_trgm WITH SCHEMA public;
CREATE EXTENSION IF NOT EXISTS fuzzystrmatch WITH SCHEMA public;
-- Modify plate_notifications
ALTER TABLE IF EXISTS public.plate_notifications
ADD COLUMN IF NOT EXISTS priority integer DEFAULT 1;
-- Modify plate_reads
ALTER TABLE IF EXISTS public.plate_reads
ADD COLUMN IF NOT EXISTS camera_name character varying(25),
ADD COLUMN IF NOT EXISTS image_path varchar(255),
ADD COLUMN IF NOT EXISTS thumbnail_path varchar(255),
ADD COLUMN IF NOT EXISTS bi_path varchar(100),
ADD COLUMN IF NOT EXISTS plate_annotation varchar(255),
ADD COLUMN IF NOT EXISTS crop_coordinates int[],
ADD COLUMN IF NOT EXISTS ocr_annotation jsonb,
ADD COLUMN IF NOT EXISTS confidence decimal,
ADD COLUMN IF NOT EXISTS bi_zone varchar(30),
ADD COLUMN IF NOT EXISTS validated boolean DEFAULT false,
ADD COLUMN IF NOT EXISTS event_identity varchar(80);
-- Exact Blue Iris resubmissions are identified by plate, event time, and
-- camera. The camera column keeps simultaneous observations independent.
CREATE INDEX IF NOT EXISTS idx_plate_reads_event_identity
ON public.plate_reads (plate_number, timestamp, camera_name);
-- New reads carry a stable event identity. The partial unique index lets
-- historical rows remain nullable while atomically suppressing concurrent
-- resubmissions of the same Blue Iris event.
CREATE UNIQUE INDEX IF NOT EXISTS uq_plate_reads_event_identity
ON public.plate_reads (event_identity)
WHERE event_identity IS NOT NULL;
-- Please for the love of god work...
-- Fix in reference to #57 and ipct reports about db config on new installs
DO $$
BEGIN
IF NOT EXISTS (
SELECT 1 FROM pg_constraint
WHERE conname = 'plates_pkey'
AND conrelid = 'public.plates'::regclass
) THEN
ALTER TABLE public.plates ADD CONSTRAINT plates_pkey PRIMARY KEY (plate_number);
END IF;
END $$;
-- Modify known_plates
ALTER TABLE IF EXISTS public.known_plates
ADD COLUMN IF NOT EXISTS ignore BOOLEAN DEFAULT FALSE;
-- Modify plates
ALTER TABLE IF EXISTS public.plates
ADD COLUMN IF NOT EXISTS occurrence_count INTEGER NOT NULL DEFAULT 0;
-- Create index if not exists
DO $$
BEGIN
IF NOT EXISTS (SELECT 1 FROM pg_indexes WHERE indexname = 'idx_plates_occurrence_count') THEN
CREATE INDEX idx_plates_occurrence_count ON plates(occurrence_count);
END IF;
END $$;
-- Count incrementing function
CREATE OR REPLACE FUNCTION update_plate_occurrence_count()
RETURNS TRIGGER AS $$
BEGIN
-- Handle INSERT operation
IF TG_OP = 'INSERT' THEN
INSERT INTO plates (plate_number, occurrence_count)
VALUES (NEW.plate_number, 1)
ON CONFLICT (plate_number)
DO UPDATE SET occurrence_count = plates.occurrence_count + 1;
-- Handle UPDATE operation (plate number correction)
ELSIF TG_OP = 'UPDATE' AND OLD.plate_number != NEW.plate_number THEN
-- Increment the new plate number count (or create if not exists)
INSERT INTO plates (plate_number, occurrence_count)
VALUES (NEW.plate_number, 1)
ON CONFLICT (plate_number)
DO UPDATE SET occurrence_count = plates.occurrence_count + 1;
-- Only decrement the old plate if it still exists
UPDATE plates
SET occurrence_count = occurrence_count - 1
WHERE plate_number = OLD.plate_number;
-- Clean up if occurrence count reaches zero
DELETE FROM plates
WHERE plate_number = OLD.plate_number
AND occurrence_count <= 0;
-- Handle DELETE operation
ELSIF TG_OP = 'DELETE' THEN
-- Only attempt to decrement if the plate still exists
UPDATE plates
SET occurrence_count = occurrence_count - 1
WHERE plate_number = OLD.plate_number;
-- Clean up if occurrence count reaches zero
DELETE FROM plates
WHERE plate_number = OLD.plate_number
AND occurrence_count <= 0;
END IF;
RETURN NULL;
END;
$$ LANGUAGE plpgsql;
-- Update trigger to also handle UPDATE operations
DO $$
BEGIN
-- Drop the existing trigger if it exists
DROP TRIGGER IF EXISTS plate_reads_count_trigger ON plate_reads;
-- Create the updated trigger
CREATE TRIGGER plate_reads_count_trigger
AFTER INSERT OR UPDATE OR DELETE ON plate_reads
FOR EACH ROW
EXECUTE FUNCTION update_plate_occurrence_count();
END $$;
-- Clerical stuff
CREATE TABLE IF NOT EXISTS devmgmt (
id SERIAL PRIMARY KEY,
update1 BOOLEAN DEFAULT FALSE
);
INSERT INTO devmgmt (id, update1)
SELECT 1, false
WHERE NOT EXISTS (SELECT 1 FROM devmgmt);
ALTER TABLE IF EXISTS public.devmgmt
ADD COLUMN IF NOT EXISTS training_last_record INTEGER DEFAULT 0;
CREATE TABLE IF NOT EXISTS mqttbrokers (
id SERIAL PRIMARY KEY,
name VARCHAR(255),
broker VARCHAR(255),
port INTEGER DEFAULT 1883,
topic VARCHAR(255),
username VARCHAR(255),
password VARCHAR(255),
use_tls BOOLEAN DEFAULT FALSE
);
CREATE TABLE IF NOT EXISTS mqttnotifications (
id SERIAL PRIMARY KEY,
plate_number VARCHAR(50),
name VARCHAR(255),
enabled BOOLEAN DEFAULT TRUE,
brokerid INTEGER REFERENCES mqttbrokers(id) ON DELETE CASCADE,
message TEXT,
includeKnownPlateInfo BOOLEAN DEFAULT TRUE
);
-- MQTT integration v2 -------------------------------------------------------
-- Keep the legacy topic column and mqttnotifications table intact so this
-- migration is non-destructive. The new application no longer uses them.
ALTER TABLE IF EXISTS public.mqttbrokers
ADD COLUMN IF NOT EXISTS enabled BOOLEAN NOT NULL DEFAULT TRUE,
ADD COLUMN IF NOT EXISTS client_id VARCHAR(255),
ADD COLUMN IF NOT EXISTS created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
ADD COLUMN IF NOT EXISTS updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP;
CREATE TABLE IF NOT EXISTS public.mqtt_settings (
id SMALLINT PRIMARY KEY DEFAULT 1 CHECK (id = 1),
enabled BOOLEAN NOT NULL DEFAULT FALSE,
base_topic VARCHAR(512) NOT NULL DEFAULT 'Blue Iris/ALPR',
camera_topic_template VARCHAR(512) NOT NULL DEFAULT '{base_topic}/{camera_key}',
default_qos SMALLINT NOT NULL DEFAULT 1 CHECK (default_qos BETWEEN 0 AND 2),
retain_messages BOOLEAN NOT NULL DEFAULT FALSE,
payload_profile VARCHAR(50) NOT NULL DEFAULT 'generic_json'
CHECK (payload_profile IN ('generic_json', 'homeseer', 'home_assistant')),
local_timezone VARCHAR(100) NOT NULL DEFAULT 'UTC',
hour_format SMALLINT NOT NULL DEFAULT 12 CHECK (hour_format IN (12, 24)),
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
INSERT INTO public.mqtt_settings (id)
VALUES (1)
ON CONFLICT (id) DO NOTHING;
CREATE TABLE IF NOT EXISTS public.mqtt_cameras (
id SERIAL PRIMARY KEY,
camera_name VARCHAR(255) NOT NULL,
camera_key VARCHAR(100) NOT NULL UNIQUE,
enabled BOOLEAN NOT NULL DEFAULT TRUE,
topic_override VARCHAR(65535),
first_seen_at TIMESTAMPTZ,
last_seen_at TIMESTAMPTZ,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT mqtt_cameras_camera_key_format
CHECK (camera_key ~ '^[a-z0-9]+(-[a-z0-9]+)*$')
);
CREATE UNIQUE INDEX IF NOT EXISTS mqtt_cameras_camera_name_lower_key
ON public.mqtt_cameras (LOWER(camera_name));
CREATE TABLE IF NOT EXISTS public.mqtt_rules (
id SERIAL PRIMARY KEY,
name VARCHAR(255) NOT NULL,
enabled BOOLEAN NOT NULL DEFAULT TRUE,
match_type VARCHAR(50) NOT NULL
CHECK (match_type IN (
'any_plate',
'exact_plate',
'any_known_plate',
'known_name',
'tag'
)),
match_value TEXT,
plate_match_mode VARCHAR(20) NOT NULL DEFAULT 'off'
CHECK (plate_match_mode IN ('off', 'strict', 'balanced', 'broad')),
fuzzy_enabled BOOLEAN NOT NULL DEFAULT FALSE,
fuzzy_max_distance SMALLINT NOT NULL DEFAULT 1
CHECK (fuzzy_max_distance BETWEEN 0 AND 2),
fuzzy_min_length SMALLINT NOT NULL DEFAULT 5
CHECK (fuzzy_min_length BETWEEN 1 AND 20),
fuzzy_require_unique BOOLEAN NOT NULL DEFAULT TRUE,
fuzzy_ocr_aware BOOLEAN NOT NULL DEFAULT TRUE,
broker_id INTEGER NOT NULL REFERENCES public.mqttbrokers(id) ON DELETE RESTRICT,
destination_mode VARCHAR(50) NOT NULL DEFAULT 'per_camera'
CHECK (destination_mode IN ('per_camera', 'fixed_topic')),
fixed_topic VARCHAR(65535),
message TEXT,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT mqtt_rules_match_value_required CHECK (
match_type IN ('any_plate', 'any_known_plate')
OR NULLIF(BTRIM(match_value), '') IS NOT NULL
),
CONSTRAINT mqtt_rules_fixed_topic_required CHECK (
destination_mode = 'per_camera'
OR NULLIF(BTRIM(fixed_topic), '') IS NOT NULL
)
);
ALTER TABLE public.mqtt_rules
ADD COLUMN IF NOT EXISTS plate_match_mode VARCHAR(20);
UPDATE public.mqtt_rules
SET plate_match_mode = CASE
WHEN fuzzy_enabled THEN 'balanced'
ELSE 'off'
END
WHERE plate_match_mode IS NULL;
ALTER TABLE public.mqtt_rules
ALTER COLUMN plate_match_mode SET DEFAULT 'off',
ALTER COLUMN plate_match_mode SET NOT NULL;
ALTER TABLE public.mqtt_rules
DROP CONSTRAINT IF EXISTS mqtt_rules_plate_match_mode_check;
ALTER TABLE public.mqtt_rules
ADD CONSTRAINT mqtt_rules_plate_match_mode_check
CHECK (plate_match_mode IN ('off', 'strict', 'balanced', 'broad'));
CREATE TABLE IF NOT EXISTS public.mqtt_rule_cameras (
rule_id INTEGER NOT NULL REFERENCES public.mqtt_rules(id) ON DELETE CASCADE,
camera_id INTEGER NOT NULL REFERENCES public.mqtt_cameras(id) ON DELETE CASCADE,
PRIMARY KEY (rule_id, camera_id)
);
CREATE INDEX IF NOT EXISTS idx_mqtt_rules_enabled
ON public.mqtt_rules (enabled) WHERE enabled = TRUE;
CREATE INDEX IF NOT EXISTS idx_mqtt_rules_broker_id
ON public.mqtt_rules (broker_id);
CREATE INDEX IF NOT EXISTS idx_mqtt_rule_cameras_camera_id
ON public.mqtt_rule_cameras (camera_id);
CREATE INDEX IF NOT EXISTS idx_mqtt_cameras_enabled
ON public.mqtt_cameras (enabled) WHERE enabled = TRUE;
CREATE OR REPLACE FUNCTION public.mqtt_set_updated_at()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = CURRENT_TIMESTAMP;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
DROP TRIGGER IF EXISTS mqttbrokers_set_updated_at ON public.mqttbrokers;
CREATE TRIGGER mqttbrokers_set_updated_at
BEFORE UPDATE ON public.mqttbrokers
FOR EACH ROW EXECUTE FUNCTION public.mqtt_set_updated_at();
DROP TRIGGER IF EXISTS mqtt_settings_set_updated_at ON public.mqtt_settings;
CREATE TRIGGER mqtt_settings_set_updated_at
BEFORE UPDATE ON public.mqtt_settings
FOR EACH ROW EXECUTE FUNCTION public.mqtt_set_updated_at();
DROP TRIGGER IF EXISTS mqtt_cameras_set_updated_at ON public.mqtt_cameras;
CREATE TRIGGER mqtt_cameras_set_updated_at
BEFORE UPDATE ON public.mqtt_cameras
FOR EACH ROW EXECUTE FUNCTION public.mqtt_set_updated_at();
DROP TRIGGER IF EXISTS mqtt_rules_set_updated_at ON public.mqtt_rules;
CREATE TRIGGER mqtt_rules_set_updated_at
BEFORE UPDATE ON public.mqtt_rules
FOR EACH ROW EXECUTE FUNCTION public.mqtt_set_updated_at();
-- Durable MQTT delivery outbox and activity history -------------------------
-- A queue row represents one camera observation going to one broker/topic.
-- The unique dedupe key suppresses only an exact resubmission of that same
-- camera event and destination; different cameras remain independent.
CREATE TABLE IF NOT EXISTS public.mqtt_deliveries (
id BIGSERIAL PRIMARY KEY,
dedupe_key VARCHAR(80) NOT NULL UNIQUE,
event_id VARCHAR(255) NOT NULL,
read_id INTEGER REFERENCES public.plate_reads(id) ON DELETE SET NULL,
camera_id INTEGER REFERENCES public.mqtt_cameras(id) ON DELETE SET NULL,
camera_key VARCHAR(100) NOT NULL,
camera_name VARCHAR(255) NOT NULL,
broker_id INTEGER NOT NULL REFERENCES public.mqttbrokers(id) ON DELETE RESTRICT,
topic VARCHAR(65535) NOT NULL,
payload JSONB NOT NULL,
qos SMALLINT NOT NULL DEFAULT 1 CHECK (qos BETWEEN 0 AND 2),
retain BOOLEAN NOT NULL DEFAULT FALSE,
status VARCHAR(20) NOT NULL DEFAULT 'pending'
CHECK (status IN ('pending', 'processing', 'retry', 'succeeded', 'dead')),
attempt_count INTEGER NOT NULL DEFAULT 0 CHECK (attempt_count >= 0),
max_attempts SMALLINT NOT NULL DEFAULT 5 CHECK (max_attempts BETWEEN 1 AND 20),
next_attempt_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
locked_at TIMESTAMPTZ,
locked_by VARCHAR(255),
last_error TEXT,
published_at TIMESTAMPTZ,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT mqtt_deliveries_camera_key_format
CHECK (camera_key ~ '^[a-z0-9]+(-[a-z0-9]+)*$'),
CONSTRAINT mqtt_deliveries_payload_object
CHECK (jsonb_typeof(payload) = 'object'),
CONSTRAINT mqtt_deliveries_lock_state CHECK (
(
status = 'processing'
AND locked_at IS NOT NULL
AND NULLIF(BTRIM(locked_by), '') IS NOT NULL
)
OR
(
status <> 'processing'
AND locked_at IS NULL
AND locked_by IS NULL
)
),
CONSTRAINT mqtt_deliveries_published_state CHECK (
(status = 'succeeded' AND published_at IS NOT NULL)
OR
(status <> 'succeeded' AND published_at IS NULL)
)
);
CREATE TABLE IF NOT EXISTS public.mqtt_delivery_attempts (
id BIGSERIAL PRIMARY KEY,
delivery_id BIGINT NOT NULL
REFERENCES public.mqtt_deliveries(id) ON DELETE CASCADE,
attempt_number INTEGER NOT NULL CHECK (attempt_number > 0),
outcome VARCHAR(20) NOT NULL
CHECK (outcome IN ('succeeded', 'retry', 'dead')),
worker_id VARCHAR(255),
error_code VARCHAR(100),
error_message TEXT,
started_at TIMESTAMPTZ NOT NULL,
completed_at TIMESTAMPTZ NOT NULL,
UNIQUE (delivery_id, attempt_number)
);
CREATE INDEX IF NOT EXISTS idx_mqtt_deliveries_due
ON public.mqtt_deliveries (next_attempt_at, id)
WHERE status IN ('pending', 'retry');
CREATE INDEX IF NOT EXISTS idx_mqtt_deliveries_created_at
ON public.mqtt_deliveries (created_at DESC, id DESC);
CREATE INDEX IF NOT EXISTS idx_mqtt_deliveries_read_id
ON public.mqtt_deliveries (read_id);
CREATE INDEX IF NOT EXISTS idx_mqtt_deliveries_broker_id
ON public.mqtt_deliveries (broker_id);
CREATE INDEX IF NOT EXISTS idx_mqtt_delivery_attempts_delivery_id
ON public.mqtt_delivery_attempts (delivery_id, attempt_number DESC);
DROP TRIGGER IF EXISTS mqtt_deliveries_set_updated_at ON public.mqtt_deliveries;
CREATE TRIGGER mqtt_deliveries_set_updated_at
BEFORE UPDATE ON public.mqtt_deliveries
FOR EACH ROW EXECUTE FUNCTION public.mqtt_set_updated_at();
-- Identity, roles, and audit foundation --------------------------------------
-- This first slice is deliberately non-disruptive: it creates the durable
-- identity model without changing the existing password-only login. A later
-- migration will bootstrap the first named owner and cut sessions over only
-- after the compatibility path has been tested.
CREATE TABLE IF NOT EXISTS public.schema_migrations (
version VARCHAR(100) PRIMARY KEY,
description TEXT NOT NULL,
applied_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE TABLE IF NOT EXISTS public.users (
id BIGSERIAL PRIMARY KEY,
username VARCHAR(64) NOT NULL,
display_name VARCHAR(120) NOT NULL,
password_hash TEXT NOT NULL,
status VARCHAR(20) NOT NULL DEFAULT 'active'
CHECK (status IN ('active', 'disabled')),
password_changed_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
last_login_at TIMESTAMPTZ,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT users_username_normalized
CHECK (
username = LOWER(username)
AND username ~ '^[a-z0-9][a-z0-9._-]{1,62}[a-z0-9]$'
),
CONSTRAINT users_display_name_present
CHECK (NULLIF(BTRIM(display_name), '') IS NOT NULL),
CONSTRAINT users_password_hash_present
CHECK (NULLIF(BTRIM(password_hash), '') IS NOT NULL)
);
CREATE UNIQUE INDEX IF NOT EXISTS users_username_lower_key
ON public.users (LOWER(username));
ALTER TABLE public.users
ADD COLUMN IF NOT EXISTS deleted_at TIMESTAMPTZ;
ALTER TABLE public.users
ADD COLUMN IF NOT EXISTS must_change_password BOOLEAN NOT NULL DEFAULT FALSE;
CREATE TABLE IF NOT EXISTS public.roles (
id SMALLSERIAL PRIMARY KEY,
name VARCHAR(50) NOT NULL UNIQUE,
display_name VARCHAR(80) NOT NULL,
description TEXT NOT NULL,
system_role BOOLEAN NOT NULL DEFAULT TRUE,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT roles_name_format
CHECK (name ~ '^[a-z][a-z0-9_]{2,49}$')
);
CREATE TABLE IF NOT EXISTS public.permissions (
id SMALLSERIAL PRIMARY KEY,
permission_key VARCHAR(100) NOT NULL UNIQUE,
description TEXT NOT NULL,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT permissions_key_format
CHECK (permission_key ~ '^[a-z][a-z0-9_]*(\.[a-z][a-z0-9_]*)+$')
);
CREATE TABLE IF NOT EXISTS public.role_permissions (
role_id SMALLINT NOT NULL REFERENCES public.roles(id) ON DELETE CASCADE,
permission_id SMALLINT NOT NULL
REFERENCES public.permissions(id) ON DELETE CASCADE,
PRIMARY KEY (role_id, permission_id)
);
CREATE TABLE IF NOT EXISTS public.user_roles (
user_id BIGINT NOT NULL REFERENCES public.users(id) ON DELETE CASCADE,
role_id SMALLINT NOT NULL REFERENCES public.roles(id) ON DELETE RESTRICT,
granted_by_user_id BIGINT REFERENCES public.users(id) ON DELETE RESTRICT,
granted_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY (user_id, role_id)
);
CREATE TABLE IF NOT EXISTS public.user_sessions (
id BIGSERIAL PRIMARY KEY,
user_id BIGINT NOT NULL REFERENCES public.users(id) ON DELETE CASCADE,
token_hash CHAR(64) NOT NULL UNIQUE,
user_agent VARCHAR(255) NOT NULL DEFAULT 'Unknown Device',
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
last_used_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
expires_at TIMESTAMPTZ NOT NULL,
revoked_at TIMESTAMPTZ,
revoke_reason VARCHAR(100),
CONSTRAINT user_sessions_token_hash_format
CHECK (token_hash ~ '^[0-9a-f]{64}$'),
CONSTRAINT user_sessions_expiration_order
CHECK (expires_at > created_at),
CONSTRAINT user_sessions_revocation_pair
CHECK (
(revoked_at IS NULL AND revoke_reason IS NULL)
OR
(revoked_at IS NOT NULL AND NULLIF(BTRIM(revoke_reason), '') IS NOT NULL)
)
);
CREATE INDEX IF NOT EXISTS idx_user_sessions_active
ON public.user_sessions (user_id, expires_at)
WHERE revoked_at IS NULL;
CREATE TABLE IF NOT EXISTS public.login_attempt_limits (
subject_hash CHAR(64) PRIMARY KEY,
failed_attempts INTEGER NOT NULL DEFAULT 0
CHECK (failed_attempts >= 0),
window_started_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
blocked_until TIMESTAMPTZ,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT login_attempt_limits_subject_hash_format
CHECK (subject_hash ~ '^[0-9a-f]{64}$')
);
CREATE INDEX IF NOT EXISTS idx_login_attempt_limits_updated_at
ON public.login_attempt_limits (updated_at);
CREATE TABLE IF NOT EXISTS public.api_credentials (
id BIGSERIAL PRIMARY KEY,
owner_user_id BIGINT REFERENCES public.users(id) ON DELETE RESTRICT,
name VARCHAR(120) NOT NULL,
key_prefix VARCHAR(16) NOT NULL UNIQUE,
secret_hash CHAR(64) NOT NULL UNIQUE,
scopes TEXT[] NOT NULL DEFAULT ARRAY[]::TEXT[],
status VARCHAR(20) NOT NULL DEFAULT 'active'
CHECK (status IN ('active', 'revoked')),
last_used_at TIMESTAMPTZ,
expires_at TIMESTAMPTZ,
revoked_at TIMESTAMPTZ,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT api_credentials_name_present
CHECK (NULLIF(BTRIM(name), '') IS NOT NULL),
CONSTRAINT api_credentials_prefix_format
CHECK (key_prefix ~ '^[0-9a-f]{8,16}$'),
CONSTRAINT api_credentials_secret_hash_format
CHECK (secret_hash ~ '^[0-9a-f]{64}$'),
CONSTRAINT api_credentials_scope_values_present
CHECK (array_position(scopes, NULL) IS NULL)
);
CREATE INDEX IF NOT EXISTS idx_api_credentials_owner
ON public.api_credentials (owner_user_id, status);
CREATE TABLE IF NOT EXISTS public.audit_events (
id BIGSERIAL PRIMARY KEY,
actor_user_id BIGINT REFERENCES public.users(id) ON DELETE RESTRICT,
actor_api_credential_id BIGINT
REFERENCES public.api_credentials(id) ON DELETE RESTRICT,
source VARCHAR(20) NOT NULL
CHECK (source IN ('browser', 'api', 'system')),
event_type VARCHAR(100) NOT NULL,
resource_type VARCHAR(100),
resource_id VARCHAR(255),
outcome VARCHAR(20) NOT NULL
CHECK (outcome IN ('succeeded', 'denied', 'failed')),
reason TEXT,
request_id VARCHAR(100),
metadata JSONB NOT NULL DEFAULT '{}'::JSONB
CHECK (jsonb_typeof(metadata) = 'object'),
occurred_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT audit_events_single_actor
CHECK (num_nonnulls(actor_user_id, actor_api_credential_id) <= 1),
CONSTRAINT audit_events_type_present
CHECK (NULLIF(BTRIM(event_type), '') IS NOT NULL)
);
CREATE INDEX IF NOT EXISTS idx_audit_events_occurred_at
ON public.audit_events (occurred_at DESC, id DESC);
CREATE INDEX IF NOT EXISTS idx_audit_events_actor_user
ON public.audit_events (actor_user_id, occurred_at DESC)
WHERE actor_user_id IS NOT NULL;
CREATE INDEX IF NOT EXISTS idx_audit_events_resource
ON public.audit_events (resource_type, resource_id, occurred_at DESC)
WHERE resource_type IS NOT NULL;
CREATE OR REPLACE FUNCTION public.identity_set_updated_at()
RETURNS TRIGGER AS $$
BEGIN
NEW.updated_at = CURRENT_TIMESTAMP;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
DROP TRIGGER IF EXISTS users_set_updated_at ON public.users;
CREATE TRIGGER users_set_updated_at
BEFORE UPDATE ON public.users
FOR EACH ROW EXECUTE FUNCTION public.identity_set_updated_at();
DROP TRIGGER IF EXISTS roles_set_updated_at ON public.roles;
CREATE TRIGGER roles_set_updated_at
BEFORE UPDATE ON public.roles
FOR EACH ROW EXECUTE FUNCTION public.identity_set_updated_at();
CREATE OR REPLACE FUNCTION public.prevent_audit_event_mutation()
RETURNS TRIGGER AS $$
BEGIN
RAISE EXCEPTION 'audit_events is append-only';
END;
$$ LANGUAGE plpgsql;
DROP TRIGGER IF EXISTS audit_events_append_only ON public.audit_events;
CREATE TRIGGER audit_events_append_only
BEFORE UPDATE OR DELETE ON public.audit_events
FOR EACH ROW EXECUTE FUNCTION public.prevent_audit_event_mutation();
INSERT INTO public.roles (name, display_name, description)
VALUES
('administrator', 'Administrator', 'Full application and security administration.'),
('operator', 'Operator', 'Day-to-day plate review, automation, and data management.'),
('viewer', 'Viewer', 'Read-only access to plate data and approved exports.'),
('auditor', 'Auditor', 'Read-only investigations with audit-history access.')
ON CONFLICT (name) DO UPDATE
SET display_name = EXCLUDED.display_name,
description = EXCLUDED.description;
INSERT INTO public.permissions (permission_key, description)
VALUES
('system.manage_users', 'Create, disable, delete, and assign roles to users.'),
('system.manage_settings', 'Change application and integration settings.'),
('system.view_audit', 'View append-only audit history.'),
('assistant.use', 'Use configured AI assistants for ALPR queries.'),
('plate.read', 'View plate reads, images, and known-plate details.'),
('plate.review', 'Confirm, correct, or reject plate reads.'),
('plate.delete', 'Delete plate reads and plate records.'),
('known_plate.manage', 'Manage known plates and their notes.'),
('tag.manage', 'Create, edit, assign, and remove tags.'),
('notification.manage', 'Manage notification rules and delivery state.'),
('mqtt.manage', 'Manage MQTT brokers, cameras, rules, and activity.'),
('export.create', 'Create and download approved exports.'),
('maintenance.manage', 'Run approved storage and database maintenance.')
ON CONFLICT (permission_key) DO UPDATE
SET description = EXCLUDED.description;
-- Keep the durable database grants synchronized with the application role
-- matrix when an existing installation receives a least-privilege correction.
DELETE FROM public.role_permissions AS role_permission
USING public.roles AS role
WHERE role_permission.role_id = role.id
AND role.name IN ('administrator', 'operator', 'viewer', 'auditor');
INSERT INTO public.role_permissions (role_id, permission_id)
SELECT role.id, permission.id
FROM public.roles AS role
CROSS JOIN public.permissions AS permission
WHERE
role.name = 'administrator'
OR (
role.name = 'operator'
AND permission.permission_key IN (
'plate.read',
'plate.review',
'known_plate.manage',
'tag.manage'
)
)
OR (
role.name = 'viewer'
AND permission.permission_key IN (
'plate.read'
)
)
OR (
role.name = 'auditor'
AND permission.permission_key IN (
'plate.read',
'system.view_audit',
'export.create'
)
)
ON CONFLICT (role_id, permission_id) DO NOTHING;
INSERT INTO public.schema_migrations (version, description)
VALUES (
'2026071901_identity_audit_foundation',
'Create users, roles, permissions, database sessions, scoped credentials, and append-only audit events.'
)
ON CONFLICT (version) DO NOTHING;
INSERT INTO public.schema_migrations (version, description)
VALUES (
'2026071902_assistant_authorization',
'Restrict AI Assistant access to explicitly authorized administrators.'
)
ON CONFLICT (version) DO NOTHING;
-- Immutable plate observations, append-only review history, and reviewed aliases
ALTER TABLE public.plate_reads
ADD COLUMN IF NOT EXISTS observed_plate VARCHAR(10),
ADD COLUMN IF NOT EXISTS review_status VARCHAR(24) NOT NULL DEFAULT 'unreviewed',
ADD COLUMN IF NOT EXISTS review_revision INTEGER NOT NULL DEFAULT 0,
ADD COLUMN IF NOT EXISTS last_reviewed_at TIMESTAMPTZ,
ADD COLUMN IF NOT EXISTS last_reviewed_by BIGINT REFERENCES public.users(id) ON DELETE SET NULL;
UPDATE public.plate_reads
SET observed_plate = plate_number
WHERE observed_plate IS NULL;
UPDATE public.plate_reads
SET review_status = CASE WHEN validated THEN 'confirmed' ELSE 'unreviewed' END
WHERE review_revision = 0
AND review_status = 'unreviewed';
ALTER TABLE public.plate_reads
ALTER COLUMN observed_plate SET NOT NULL;
DO $$
BEGIN
IF NOT EXISTS (
SELECT 1 FROM pg_constraint
WHERE conname = 'plate_reads_review_status_check'
) THEN
ALTER TABLE public.plate_reads
ADD CONSTRAINT plate_reads_review_status_check
CHECK (review_status IN (
'unreviewed', 'confirmed', 'corrected', 'rejected', 'alias_resolved'
));
END IF;
IF NOT EXISTS (
SELECT 1 FROM pg_constraint
WHERE conname = 'plate_reads_review_revision_check'
) THEN
ALTER TABLE public.plate_reads
ADD CONSTRAINT plate_reads_review_revision_check
CHECK (review_revision >= 0);
END IF;
END;
$$;
CREATE TABLE IF NOT EXISTS public.plate_aliases (
id BIGSERIAL PRIMARY KEY,
source_plate VARCHAR(10) NOT NULL,
target_plate VARCHAR(10) NOT NULL,
camera_name VARCHAR(30),
enabled BOOLEAN NOT NULL DEFAULT TRUE,
reason VARCHAR(120) NOT NULL,
created_by_user_id BIGINT REFERENCES public.users(id) ON DELETE SET NULL,
created_by_username VARCHAR(64) NOT NULL,
created_by_display_name VARCHAR(120) NOT NULL,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
disabled_by_user_id BIGINT REFERENCES public.users(id) ON DELETE SET NULL,
disabled_at TIMESTAMPTZ,
use_count BIGINT NOT NULL DEFAULT 0,
last_used_at TIMESTAMPTZ,
CONSTRAINT plate_aliases_different_values CHECK (source_plate <> target_plate),
CONSTRAINT plate_aliases_use_count_check CHECK (use_count >= 0)
);
CREATE UNIQUE INDEX IF NOT EXISTS uq_plate_aliases_enabled_scope
ON public.plate_aliases (
source_plate,
COALESCE(LOWER(camera_name), '')
)
WHERE enabled = TRUE;
CREATE INDEX IF NOT EXISTS idx_plate_aliases_target
ON public.plate_aliases (target_plate, enabled);
ALTER TABLE public.plate_reads
ADD COLUMN IF NOT EXISTS applied_alias_id BIGINT
REFERENCES public.plate_aliases(id) ON DELETE SET NULL;
CREATE TABLE IF NOT EXISTS public.plate_review_batches (
id BIGSERIAL PRIMARY KEY,
source_plate VARCHAR(10) NOT NULL,
target_plate VARCHAR(10) NOT NULL,
criteria JSONB NOT NULL DEFAULT '{}'::JSONB
CHECK (jsonb_typeof(criteria) = 'object'),
matched_count INTEGER NOT NULL CHECK (matched_count > 0),
actor_user_id BIGINT REFERENCES public.users(id) ON DELETE SET NULL,
actor_username VARCHAR(64) NOT NULL,
actor_display_name VARCHAR(120) NOT NULL,
reason VARCHAR(120) NOT NULL,
notes TEXT,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE TABLE IF NOT EXISTS public.plate_read_reviews (
id BIGSERIAL PRIMARY KEY,
read_id INTEGER REFERENCES public.plate_reads(id) ON DELETE RESTRICT,
read_event_identity VARCHAR(80),
action VARCHAR(24) NOT NULL
CHECK (action IN (
'confirm', 'correct', 'reject', 'reopen', 'reverse', 'alias_applied'
)),
previous_plate VARCHAR(10) NOT NULL,
new_plate VARCHAR(10) NOT NULL,
previous_status VARCHAR(24) NOT NULL
CHECK (previous_status IN (
'unreviewed', 'confirmed', 'corrected', 'rejected', 'alias_resolved'
)),
new_status VARCHAR(24) NOT NULL
CHECK (new_status IN (
'unreviewed', 'confirmed', 'corrected', 'rejected', 'alias_resolved'
)),
reason VARCHAR(120),
notes TEXT,
actor_user_id BIGINT REFERENCES public.users(id) ON DELETE SET NULL,
actor_username VARCHAR(64) NOT NULL,
actor_display_name VARCHAR(120) NOT NULL,
alias_id BIGINT REFERENCES public.plate_aliases(id) ON DELETE SET NULL,
batch_id BIGINT REFERENCES public.plate_review_batches(id) ON DELETE SET NULL,
reverses_review_id BIGINT REFERENCES public.plate_read_reviews(id) ON DELETE SET NULL,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP
);
CREATE INDEX IF NOT EXISTS idx_plate_read_reviews_read
ON public.plate_read_reviews (read_id, created_at DESC, id DESC);
CREATE INDEX IF NOT EXISTS idx_plate_read_reviews_actor
ON public.plate_read_reviews (actor_user_id, created_at DESC)
WHERE actor_user_id IS NOT NULL;
CREATE INDEX IF NOT EXISTS idx_plate_read_reviews_batch
ON public.plate_read_reviews (batch_id)
WHERE batch_id IS NOT NULL;
CREATE OR REPLACE FUNCTION public.preserve_observed_plate()
RETURNS TRIGGER AS $$
BEGIN
IF TG_OP = 'INSERT' AND NEW.observed_plate IS NULL THEN
NEW.observed_plate = NEW.plate_number;
ELSIF TG_OP = 'UPDATE'
AND OLD.observed_plate IS DISTINCT FROM NEW.observed_plate THEN
RAISE EXCEPTION 'plate_reads.observed_plate is immutable';
END IF;
RETURN NEW;
END;
$$ LANGUAGE plpgsql;
DROP TRIGGER IF EXISTS plate_reads_preserve_observed ON public.plate_reads;
CREATE TRIGGER plate_reads_preserve_observed
BEFORE INSERT OR UPDATE ON public.plate_reads
FOR EACH ROW EXECUTE FUNCTION public.preserve_observed_plate();
CREATE OR REPLACE FUNCTION public.prevent_plate_review_mutation()
RETURNS TRIGGER AS $$
BEGIN
RAISE EXCEPTION 'plate_read_reviews is append-only';
END;
$$ LANGUAGE plpgsql;
DROP TRIGGER IF EXISTS plate_read_reviews_append_only ON public.plate_read_reviews;
CREATE TRIGGER plate_read_reviews_append_only
BEFORE UPDATE OR DELETE ON public.plate_read_reviews
FOR EACH ROW EXECUTE FUNCTION public.prevent_plate_review_mutation();
CREATE OR REPLACE FUNCTION public.prevent_plate_alias_delete()
RETURNS TRIGGER AS $$
BEGIN
RAISE EXCEPTION 'plate aliases must be disabled, not deleted';
END;
$$ LANGUAGE plpgsql;
DROP TRIGGER IF EXISTS plate_aliases_no_delete ON public.plate_aliases;
CREATE TRIGGER plate_aliases_no_delete
BEFORE DELETE ON public.plate_aliases
FOR EACH ROW EXECUTE FUNCTION public.prevent_plate_alias_delete();
INSERT INTO public.permissions (permission_key, description)
VALUES
('plate.review.batch', 'Preview and apply reviewed bulk plate corrections.'),
('plate.alias.manage', 'Create and disable recurring plate misread aliases.')
ON CONFLICT (permission_key) DO UPDATE
SET description = EXCLUDED.description;
INSERT INTO public.role_permissions (role_id, permission_id)
SELECT role.id, permission.id
FROM public.roles AS role
CROSS JOIN public.permissions AS permission
WHERE role.name = 'administrator'
AND permission.permission_key IN ('plate.review.batch', 'plate.alias.manage')
ON CONFLICT (role_id, permission_id) DO NOTHING;
INSERT INTO public.schema_migrations (version, description)
VALUES (
'2026071903_immutable_plate_reviews',
'Preserve observed plates, append plate review history, and add reviewed recurring aliases.'
)
ON CONFLICT (version) DO NOTHING;
-- Reconcile stored plate occurrence counts after bulk imports.
DO $$
DECLARE
mismatch_count BIGINT;
BEGIN
IF NOT EXISTS (
SELECT 1
FROM public.schema_migrations
WHERE version = '2026072101_repair_plate_occurrence_counts'
) THEN
WITH actual_counts AS (
SELECT plate_number, COUNT(*)::INTEGER AS read_count
FROM public.plate_reads
GROUP BY plate_number
)
UPDATE public.plates AS plate
SET occurrence_count = actual.read_count
FROM actual_counts AS actual
WHERE actual.plate_number = plate.plate_number
AND plate.occurrence_count IS DISTINCT FROM actual.read_count;
UPDATE public.plates AS plate
SET occurrence_count = 0
WHERE plate.occurrence_count <> 0
AND NOT EXISTS (
SELECT 1
FROM public.plate_reads AS read
WHERE read.plate_number = plate.plate_number
);
SELECT COUNT(*)
INTO mismatch_count
FROM (
SELECT
COALESCE(plate.plate_number, actual.plate_number) AS plate_number,
plate.occurrence_count,
COALESCE(actual.read_count, 0) AS read_count
FROM public.plates AS plate
FULL OUTER JOIN (
SELECT plate_number, COUNT(*)::INTEGER AS read_count
FROM public.plate_reads
GROUP BY plate_number
) AS actual
ON actual.plate_number = plate.plate_number
WHERE plate.plate_number IS NULL
OR plate.occurrence_count IS DISTINCT FROM COALESCE(actual.read_count, 0)
) AS mismatches;
IF mismatch_count <> 0 THEN
RAISE EXCEPTION
'Plate occurrence reconciliation left % mismatched plate rows',
mismatch_count;
END IF;
INSERT INTO public.schema_migrations (version, description)
VALUES (
'2026072101_repair_plate_occurrence_counts',
'Reconcile stored plate occurrence counts with imported plate reads.'
);
END IF;
END $$;
-- Channel-neutral notification rule foundation -----------------------------
-- This schema is intentionally inert until existing Pushover and MQTT paths
-- are migrated in a later release. New rules default disabled, and this
-- migration neither copies nor changes any existing notification behavior.
CREATE TABLE IF NOT EXISTS public.notification_rules (
id BIGSERIAL PRIMARY KEY,
name VARCHAR(255) NOT NULL,
description TEXT,
enabled BOOLEAN NOT NULL DEFAULT FALSE,
event_type VARCHAR(50) NOT NULL DEFAULT 'plate_read.accepted'
CHECK (event_type IN ('plate_read.accepted', 'camera.activity_check')),
cooldown_seconds INTEGER NOT NULL DEFAULT 0
CHECK (cooldown_seconds BETWEEN 0 AND 2678400),
version INTEGER NOT NULL DEFAULT 1 CHECK (version > 0),
created_by_user_id BIGINT REFERENCES public.users(id) ON DELETE SET NULL,
updated_by_user_id BIGINT REFERENCES public.users(id) ON DELETE SET NULL,
created_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at TIMESTAMPTZ NOT NULL DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT notification_rules_name_present
CHECK (NULLIF(BTRIM(name), '') IS NOT NULL)
);
CREATE TABLE IF NOT EXISTS public.notification_condition_groups (
id BIGSERIAL PRIMARY KEY,
rule_id BIGINT NOT NULL REFERENCES public.notification_rules(id) ON DELETE CASCADE,
parent_group_id BIGINT,
combinator VARCHAR(10) NOT NULL DEFAULT 'all'
CHECK (combinator IN ('all', 'any', 'not')),
negated BOOLEAN NOT NULL DEFAULT FALSE,
position INTEGER NOT NULL DEFAULT 0 CHECK (position >= 0),
UNIQUE (id, rule_id),
CONSTRAINT notification_condition_groups_parent_same_rule
FOREIGN KEY (parent_group_id, rule_id)
REFERENCES public.notification_condition_groups(id, rule_id)
ON DELETE CASCADE
);
CREATE UNIQUE INDEX IF NOT EXISTS uq_notification_condition_groups_root
ON public.notification_condition_groups (rule_id)
WHERE parent_group_id IS NULL;
CREATE INDEX IF NOT EXISTS idx_notification_condition_groups_parent
ON public.notification_condition_groups (parent_group_id, position);
CREATE TABLE IF NOT EXISTS public.notification_conditions (
id BIGSERIAL PRIMARY KEY,
group_id BIGINT NOT NULL
REFERENCES public.notification_condition_groups(id) ON DELETE CASCADE,
condition_type VARCHAR(50) NOT NULL
CHECK (condition_type IN (
'always',
'event_type',
'plate_match',
'camera',
'known_plate',
'known_name',
'tag',
'watchlist',
'confidence',
'read_count',
'local_time_window'
)),
operator VARCHAR(30) NOT NULL,
operand JSONB NOT NULL DEFAULT '{}'::JSONB,
position INTEGER NOT NULL DEFAULT 0 CHECK (position >= 0),
CONSTRAINT notification_conditions_operand_object
CHECK (jsonb_typeof(operand) = 'object')
);
CREATE INDEX IF NOT EXISTS idx_notification_conditions_group