mirror of
https://github.com/xbgmsharp/postgsail.git
synced 2025-09-17 11:17:46 +00:00
302 lines
9.2 KiB
PL/PgSQL
302 lines
9.2 KiB
PL/PgSQL
---------------------------------------------------------------------------
|
|
-- signalk db api schema
|
|
-- View and Function that have dependency with auth schema
|
|
|
|
-- List current database
|
|
select current_database();
|
|
|
|
-- connect to the DB
|
|
\c signalk
|
|
|
|
-- Link auth.vessels with api.metadata
|
|
ALTER TABLE api.metadata ADD vessel_id TEXT NOT NULL REFERENCES auth.vessels(vessel_id) ON DELETE RESTRICT;
|
|
COMMENT ON COLUMN api.metadata.vessel_id IS 'Link auth.vessels with api.metadata';
|
|
|
|
-- List vessel
|
|
--TODO add geojson with position
|
|
DROP VIEW IF EXISTS api.vessels_view;
|
|
CREATE OR REPLACE VIEW api.vessels_view AS
|
|
WITH metadata AS (
|
|
SELECT COALESCE(
|
|
(SELECT m.time
|
|
FROM api.metadata m
|
|
WHERE m.vessel_id = current_setting('vessel.id')
|
|
)::TEXT ,
|
|
NULL ) as last_contact
|
|
)
|
|
SELECT
|
|
v.name as name,
|
|
v.mmsi as mmsi,
|
|
v.created_at::timestamp(0) as created_at,
|
|
m.last_contact as last_contact
|
|
FROM auth.vessels v, metadata m
|
|
WHERE v.owner_email = current_setting('user.email');
|
|
-- Description
|
|
COMMENT ON VIEW
|
|
api.vessels_view
|
|
IS 'Expose vessels listing to web api';
|
|
|
|
DROP FUNCTION IF EXISTS public.has_vessel_fn;
|
|
CREATE OR REPLACE FUNCTION public.has_vessel_fn() RETURNS BOOLEAN
|
|
AS $has_vessel$
|
|
DECLARE
|
|
BEGIN
|
|
-- Check a vessel and user exist
|
|
RETURN (
|
|
SELECT auth.vessels.name
|
|
FROM auth.vessels, auth.accounts
|
|
WHERE auth.vessels.owner_email = auth.accounts.email
|
|
AND auth.accounts.email = current_setting('user.email')
|
|
) IS NOT NULL;
|
|
END;
|
|
$has_vessel$ language plpgsql security definer;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.has_vessel_fn
|
|
IS 'Expose has vessel to API';
|
|
|
|
-- Or function?
|
|
-- TODO Improve: return null until the vessel has sent metadata?
|
|
DROP FUNCTION IF EXISTS api.vessel_fn;
|
|
CREATE OR REPLACE FUNCTION api.vessel_fn(OUT vessel JSON) RETURNS JSON
|
|
AS $vessel$
|
|
DECLARE
|
|
BEGIN
|
|
SELECT
|
|
json_build_object(
|
|
'name', v.name,
|
|
'mmsi', coalesce(v.mmsi, null),
|
|
'created_at', v.created_at::timestamp(0),
|
|
'last_contact', coalesce(m.time, null),
|
|
'geojson', coalesce(ST_AsGeoJSON(geojson_t.*)::json, null)
|
|
)
|
|
INTO vessel
|
|
FROM auth.vessels v, api.metadata m,
|
|
( SELECT
|
|
t.*
|
|
FROM (
|
|
( select
|
|
current_setting('vessel.name') as name,
|
|
time,
|
|
courseovergroundtrue,
|
|
speedoverground,
|
|
anglespeedapparent,
|
|
longitude,latitude,
|
|
st_makepoint(longitude,latitude) AS geo_point
|
|
FROM api.metrics
|
|
WHERE
|
|
latitude IS NOT NULL
|
|
AND longitude IS NOT NULL
|
|
AND client_id = current_setting('vessel.client_id', false)
|
|
ORDER BY time DESC
|
|
)
|
|
) AS t
|
|
) AS geojson_t
|
|
WHERE
|
|
m.vessel_id = current_setting('vessel.id')
|
|
AND m.vessel_id = v.vessel_id;
|
|
--RAISE notice 'api.vessel_fn %', obj;
|
|
END;
|
|
$vessel$ language plpgsql security definer;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
api.vessel_fn
|
|
IS 'Expose vessel details to API';
|
|
|
|
-- Export user settings
|
|
DROP FUNCTION IF EXISTS api.settings_fn;
|
|
CREATE FUNCTION api.settings_fn(out settings json) RETURNS JSON
|
|
AS $user_settings$
|
|
BEGIN
|
|
select row_to_json(row)::json INTO settings
|
|
from (
|
|
select email,first,last,preferences,created_at,
|
|
INITCAP(CONCAT (LEFT(first, 1), ' ', last)) AS username,
|
|
public.has_vessel_fn() as has_vessel
|
|
from auth.accounts
|
|
where email = current_setting('user.email')
|
|
) row;
|
|
END;
|
|
$user_settings$ language plpgsql security definer;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
api.settings_fn
|
|
IS 'Expose user settings to API';
|
|
|
|
DROP FUNCTION IF EXISTS api.versions_fn;
|
|
CREATE OR REPLACE FUNCTION api.versions_fn() RETURNS JSON
|
|
AS $version$
|
|
DECLARE
|
|
_appv TEXT;
|
|
_sysv TEXT;
|
|
BEGIN
|
|
SELECT
|
|
value, rtrim(substring(version(), 0, 17)) AS sys_version into _appv,_sysv
|
|
FROM app_settings
|
|
WHERE name = 'app.version';
|
|
RETURN json_build_object('api_version', _appv,
|
|
'sys_version', _sysv);
|
|
END;
|
|
$version$ language plpgsql security definer;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
api.versions_fn
|
|
IS 'Expose as a function, app and system version to API';
|
|
|
|
DROP VIEW IF EXISTS api.versions_view;
|
|
CREATE OR REPLACE VIEW api.versions_view AS
|
|
SELECT
|
|
value AS api_version,
|
|
--version() as sys_version
|
|
rtrim(substring(version(), 0, 17)) AS sys_version
|
|
FROM app_settings
|
|
WHERE name = 'app.version';
|
|
-- Description
|
|
COMMENT ON VIEW
|
|
api.versions_view
|
|
IS 'Expose as a table view app and system version to API';
|
|
|
|
CREATE OR REPLACE FUNCTION public.isnumeric(text) RETURNS BOOLEAN AS
|
|
$isnumeric$
|
|
DECLARE x NUMERIC;
|
|
BEGIN
|
|
x = $1::NUMERIC;
|
|
RETURN TRUE;
|
|
EXCEPTION WHEN others THEN
|
|
RETURN FALSE;
|
|
END;
|
|
$isnumeric$
|
|
STRICT
|
|
LANGUAGE plpgsql IMMUTABLE;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.isnumeric
|
|
IS 'Check typeof value is numeric';
|
|
|
|
CREATE OR REPLACE FUNCTION public.isboolean(text) RETURNS BOOLEAN AS
|
|
$isboolean$
|
|
DECLARE x BOOLEAN;
|
|
BEGIN
|
|
x = $1::BOOLEAN;
|
|
RETURN TRUE;
|
|
EXCEPTION WHEN others THEN
|
|
RETURN FALSE;
|
|
END;
|
|
$isboolean$
|
|
STRICT
|
|
LANGUAGE plpgsql IMMUTABLE;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.isboolean
|
|
IS 'Check typeof value is boolean';
|
|
|
|
create or replace function public.isdate(s varchar) returns boolean as $$
|
|
begin
|
|
perform s::date;
|
|
return true;
|
|
exception when others then
|
|
return false;
|
|
end;
|
|
$$ language plpgsql;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.isdate
|
|
IS 'Check typeof value is date';
|
|
|
|
CREATE OR REPLACE FUNCTION public.istimestamptz(text) RETURNS BOOLEAN AS
|
|
$isdate$
|
|
DECLARE x TIMESTAMP WITHOUT TIME ZONE;
|
|
BEGIN
|
|
x = $1::TIMESTAMP WITHOUT TIME ZONE;
|
|
RETURN TRUE;
|
|
EXCEPTION WHEN others THEN
|
|
RETURN FALSE;
|
|
END;
|
|
$isdate$
|
|
STRICT
|
|
LANGUAGE plpgsql IMMUTABLE;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.istimestamptz
|
|
IS 'Check typeof value is TIMESTAMP WITHOUT TIME ZONE';
|
|
|
|
DROP FUNCTION IF EXISTS api.update_user_preferences_fn;
|
|
-- Update/Add a specific user setting into preferences
|
|
CREATE OR REPLACE FUNCTION api.update_user_preferences_fn(IN key TEXT, IN value TEXT) RETURNS BOOLEAN AS
|
|
$update_user_preferences$
|
|
DECLARE
|
|
first_c TEXT := NULL;
|
|
last_c TEXT := NULL;
|
|
_value TEXT := value;
|
|
BEGIN
|
|
-- Is it the only way to check variable type?
|
|
-- Convert string to jsonb and skip type of json obj or integer or boolean
|
|
SELECT SUBSTRING(value, 1, 1),RIGHT(value, 1) INTO first_c,last_c;
|
|
IF first_c <> '{' AND last_c <> '}' AND public.isnumeric(value) IS False
|
|
AND public.isboolean(value) IS False THEN
|
|
--RAISE WARNING '-> first_c:[%] last_c:[%] pg_typeof:[%]', first_c,last_c,pg_typeof(value);
|
|
_value := to_jsonb(value)::jsonb;
|
|
END IF;
|
|
--RAISE WARNING '-> update_user_preferences_fn update preferences for user [%]', current_setting('request.jwt.claims', true)::json->>'email';
|
|
UPDATE auth.accounts
|
|
SET preferences =
|
|
jsonb_set(preferences::jsonb, key::text[], _value::jsonb)
|
|
WHERE
|
|
email = current_setting('user.email', true);
|
|
IF FOUND THEN
|
|
--RAISE WARNING '-> update_user_preferences_fn True';
|
|
RETURN True;
|
|
END IF;
|
|
--RAISE WARNING '-> update_user_preferences_fn False';
|
|
RETURN False;
|
|
END;
|
|
$update_user_preferences$ language plpgsql security definer;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
api.update_user_preferences_fn
|
|
IS 'Update user preferences jsonb key pair value';
|
|
|
|
-- https://stackoverflow.com/questions/42944888/merging-jsonb-values-in-postgresql
|
|
CREATE OR REPLACE FUNCTION public.jsonb_recursive_merge(A jsonb, B jsonb)
|
|
RETURNS jsonb LANGUAGE SQL AS $$
|
|
SELECT
|
|
jsonb_object_agg(
|
|
coalesce(ka, kb),
|
|
CASE
|
|
WHEN va isnull THEN vb
|
|
WHEN vb isnull THEN va
|
|
WHEN jsonb_typeof(va) <> 'object' OR jsonb_typeof(vb) <> 'object' THEN vb
|
|
ELSE jsonb_recursive_merge(va, vb) END
|
|
)
|
|
FROM jsonb_each(A) temptable1(ka, va)
|
|
FULL JOIN jsonb_each(B) temptable2(kb, vb) ON ka = kb
|
|
$$;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.jsonb_recursive_merge
|
|
IS 'Merging JSONB values';
|
|
|
|
-- https://stackoverflow.com/questions/36041784/postgresql-compare-two-jsonb-objects
|
|
CREATE OR REPLACE FUNCTION public.jsonb_diff_val(val1 JSONB,val2 JSONB)
|
|
RETURNS JSONB AS $jsonb_diff_val$
|
|
DECLARE
|
|
result JSONB;
|
|
v RECORD;
|
|
BEGIN
|
|
result = val1;
|
|
FOR v IN SELECT * FROM jsonb_each(val2) LOOP
|
|
IF result @> jsonb_build_object(v.key,v.value)
|
|
THEN result = result - v.key;
|
|
ELSIF result ? v.key THEN CONTINUE;
|
|
ELSE
|
|
result = result || jsonb_build_object(v.key,'null');
|
|
END IF;
|
|
END LOOP;
|
|
RETURN result;
|
|
END;
|
|
$jsonb_diff_val$ LANGUAGE plpgsql;
|
|
-- Description
|
|
COMMENT ON FUNCTION
|
|
public.jsonb_diff_val
|
|
IS 'Compare two jsonb objects';
|