mirror of
https://github.com/xbgmsharp/postgsail.git
synced 2025-09-17 03:07:47 +00:00
Cleanup metrics trigger from http api call
This commit is contained in:
@@ -402,17 +402,6 @@ CREATE FUNCTION metrics_trigger_fn() RETURNS trigger AS $metrics$
|
|||||||
valid_status BOOLEAN;
|
valid_status BOOLEAN;
|
||||||
_vessel_id TEXT;
|
_vessel_id TEXT;
|
||||||
BEGIN
|
BEGIN
|
||||||
-- Force vessel_id to import from SQL cli run as username role
|
|
||||||
SELECT vessel_id INTO _vessel_id FROM api.metadata WHERE client_id = NEW.client_id;
|
|
||||||
IF _vessel_id IS NOT NULL THEN
|
|
||||||
NEW.vessel_id = _vessel_id;
|
|
||||||
PERFORM set_config('vessel.id', _vessel_id, false) as vessel_id;
|
|
||||||
RAISE NOTICE 'metrics_trigger_fn set vessel_id [%] [%] ', NEW.vessel_id, NEW.client_id;
|
|
||||||
ELSE
|
|
||||||
RAISE EXCEPTION 'Invalid vessel.id'
|
|
||||||
USING HINT = 'Unknow vessel.id';
|
|
||||||
RETURN NULL; -- Ingore insert if no vessel_id
|
|
||||||
END IF;
|
|
||||||
-- Set client_id to new value to allow RLS
|
-- Set client_id to new value to allow RLS
|
||||||
--PERFORM set_config('vessel.client_id', NEW.client_id, false);
|
--PERFORM set_config('vessel.client_id', NEW.client_id, false);
|
||||||
NEW.vessel_id = current_setting('vessel.id', true);
|
NEW.vessel_id = current_setting('vessel.id', true);
|
||||||
@@ -443,7 +432,7 @@ CREATE FUNCTION metrics_trigger_fn() RETURNS trigger AS $metrics$
|
|||||||
END IF;
|
END IF;
|
||||||
-- Check if status is null
|
-- Check if status is null
|
||||||
IF NEW.status IS NULL THEN
|
IF NEW.status IS NULL THEN
|
||||||
RAISE WARNING 'Metrics Unknow NEW.status, null status, set to default moored [%]', NEW;
|
RAISE WARNING 'Metrics Unknow NEW.status, vessel_id [%], null status, set to default moored from [%]', NEW.vessel_id, NEW.status;
|
||||||
NEW.status := 'moored';
|
NEW.status := 'moored';
|
||||||
END IF;
|
END IF;
|
||||||
IF previous_status IS NULL THEN
|
IF previous_status IS NULL THEN
|
||||||
|
Reference in New Issue
Block a user