feat(db): add initial raw check execution schema migrations

Author: pixel365

migrations/.gitkeep

@@ -0,0 +1,5 @@
+-- +goose Up
+CREATE SCHEMA IF NOT EXISTS pulse;
+
+-- +goose Down
+DROP SCHEMA IF EXISTS pulse;

migrations/0001_schema.sql

@@ -0,0 +1,24 @@
+-- +goose Up
+CREATE TYPE pulse.check_status AS ENUM ('success', 'failure');
+
+CREATE TYPE pulse.check_type AS ENUM (
+    'http',
+    'tcp',
+    'grpc',
+    'tls',
+    'dns'
+    );
+
+CREATE TYPE pulse.check_error_kind AS ENUM (
+    'timeout',
+    'network',
+    'protocol',
+    'constraint',
+    'internal',
+    'unknown'
+    );
+
+-- +goose Down
+DROP TYPE IF EXISTS pulse.check_error_kind;
+DROP TYPE IF EXISTS pulse.check_type;
+DROP TYPE IF EXISTS pulse.check_status;

migrations/0002_types.sql

@@ -0,0 +1,22 @@
+-- +goose Up
+-- +goose StatementBegin
+CREATE OR REPLACE FUNCTION pulse.update_prohibited() RETURNS trigger AS
+$$
+BEGIN
+    RAISE EXCEPTION 'Update on table %.% is prohibited', TG_TABLE_SCHEMA, TG_TABLE_NAME
+        USING ERRCODE = 'P1001';
+END;
+$$ LANGUAGE plpgsql;
+
+CREATE OR REPLACE FUNCTION pulse.delete_prohibited() RETURNS trigger AS
+$$
+BEGIN
+    RAISE EXCEPTION 'Delete on table %.% is prohibited', TG_TABLE_SCHEMA, TG_TABLE_NAME
+        USING ERRCODE = 'P1002';
+END;
+$$ LANGUAGE plpgsql;
+-- +goose StatementEnd
+
+-- +goose Down
+DROP FUNCTION pulse.delete_prohibited();
+DROP FUNCTION pulse.update_prohibited();

migrations/0003_trigger_functions.sql

@@ -0,0 +1,45 @@
+-- +goose Up
+CREATE TABLE IF NOT EXISTS pulse.check_executions
+(
+    id             BIGSERIAL PRIMARY KEY,
+    execution_id   uuid                                             NOT NULL,
+    check_id       TEXT                                             NOT NULL,
+    service_id     TEXT                                             NOT NULL,
+    status         pulse.check_status     DEFAULT 'success'         NOT NULL,
+    check_type     pulse.check_type                                 NOT NULL,
+    started_at     TIMESTAMPTZ                                      NOT NULL,
+    finished_at    TIMESTAMPTZ                                      NOT NULL,
+    duration       INTERVAL                                         NOT NULL,
+    attempts_total INTEGER                DEFAULT 1                 NOT NULL,
+    error_kind     pulse.check_error_kind DEFAULT NULL,
+    error_message  TEXT                   DEFAULT NULL,
+    details        JSONB                  DEFAULT NULL,
+    created_at     TIMESTAMPTZ            DEFAULT CURRENT_TIMESTAMP NOT NULL,
+
+    CONSTRAINT finished_check CHECK (finished_at >= started_at),
+    CONSTRAINT attempts_check CHECK (attempts_total >= 1)
+);
+
+CREATE UNIQUE INDEX IF NOT EXISTS check_executions_execution_id_uidx ON pulse.check_executions (execution_id);
+CREATE INDEX IF NOT EXISTS check_executions_check_id_idx ON pulse.check_executions (check_id);
+CREATE INDEX IF NOT EXISTS check_executions_service_id_idx ON pulse.check_executions (service_id);
+
+CREATE TRIGGER check_executions_prohibit_update
+    BEFORE UPDATE
+    ON pulse.check_executions
+    FOR EACH ROW
+EXECUTE FUNCTION pulse.update_prohibited();
+
+CREATE TRIGGER check_executions_prohibit_delete
+    BEFORE DELETE
+    ON pulse.check_executions
+    FOR EACH ROW
+EXECUTE FUNCTION pulse.delete_prohibited();
+
+-- +goose Down
+DROP TRIGGER IF EXISTS check_executions_prohibit_delete ON pulse.check_executions;
+DROP TRIGGER IF EXISTS check_executions_prohibit_update ON pulse.check_executions;
+DROP INDEX IF EXISTS check_executions_service_id_idx;
+DROP INDEX IF EXISTS check_executions_check_id_idx;
+DROP INDEX IF EXISTS check_executions_execution_id_uidx;
+DROP TABLE IF EXISTS pulse.check_executions;