add single def set

interface/map_def/srce_map_def_set_single.sql

@@ -0,0 +1,94 @@
+CREATE OR REPLACE FUNCTION tps.srce_map_def_set_single(_defn jsonb) RETURNS jsonb
+AS
+$f$
+
+DECLARE
+    _message jsonb;
+    _rebuild boolean;
+    _MESSAGE_TEXT text;
+    _PG_EXCEPTION_DETAIL text;
+    _PG_EXCEPTION_HINT text;
+
+BEGIN
+
+    ---------test if anythign is changing--------------------------------------------------------------------------------------------
+
+    IF _defn = (SELECT regex FROM tps.map_rm WHERE srce = _defn->>'name') THEN
+         _message:= 
+        (
+            $$
+                {
+                "status":"complete",
+                "message":"source was not different no action taken"
+                }
+            $$::jsonb
+        );
+        RETURN _message;
+    END IF;
+
+    ---------do the rebuild-----------------------------------------------------------------------------------------------------------
+
+    INSERT INTO
+        tps.map_rm (srce, target, regex, seq, hist)
+    SELECT
+        --data source
+        _defn->>'srce'
+        --map name
+        ,_defn->>'name'
+        --map definition
+        ,_defn
+        --map aggregation sequence
+        ,(_defn->>'sequence')::INTEGER
+        --history definition
+        ,jsonb_build_object(
+            'hist_defn',_defn
+            ,'effective',jsonb_build_array(CURRENT_TIMESTAMP,null::timestamptz)
+        ) || '[]'::jsonb
+    ON CONFLICT ON CONSTRAINT map_rm_pk DO UPDATE SET
+        srce = excluded.srce
+        ,target = excluded.target
+        ,regex = excluded.regex
+        ,seq = excluded.seq
+        ,hist = 
+                --the new definition going to position -0-
+                jsonb_build_object(
+                    'hist_defn',excluded.regex
+                    ,'effective',jsonb_build_array(CURRENT_TIMESTAMP,null::timestamptz)
+                ) 
+                --the previous definition, set upper bound of effective range which was previously null
+                || jsonb_set(
+                    map_rm.hist
+                    ,'{0,effective,1}'::text[]
+                    ,to_jsonb(CURRENT_TIMESTAMP)
+                );
+
+    --------------if rebuild was flag call the rebuild--------------------------------------------------------------------------------
+
+    SELECT
+        x.message
+    INTO
+        _message
+    FROM
+        tps.srce_map_overwrite as X(message)
+
+    EXCEPTION WHEN OTHERS THEN
+    GET STACKED DIAGNOSTICS 
+            _MESSAGE_TEXT = MESSAGE_TEXT,
+            _PG_EXCEPTION_DETAIL = PG_EXCEPTION_DETAIL,
+            _PG_EXCEPTION_HINT = PG_EXCEPTION_HINT;
+        _message:= 
+        ($$
+            {
+                "status":"fail",
+                "message":"error setting definition"
+            }
+        $$::jsonb)
+        ||jsonb_build_object('message_text',_MESSAGE_TEXT)
+        ||jsonb_build_object('pg_exception_detail',_PG_EXCEPTION_DETAIL);
+        return _message;
+
+
+
+END;
+$f$
+language plpgsql