135 lines
3.8 KiB
PL/PgSQL
135 lines
3.8 KiB
PL/PgSQL
CREATE UNIQUE INDEX node_history_user_id_idx ON public.node_history (user_id,"uuid",history_uuid);
|
|
|
|
|
|
ALTER TABLE public.node ALTER COLUMN "uuid" TYPE uuid USING "uuid"::uuid::uuid;
|
|
ALTER TABLE public.node ALTER COLUMN parent_uuid TYPE uuid USING parent_uuid::uuid::uuid;
|
|
ALTER TABLE public.node ALTER COLUMN client TYPE uuid USING client::uuid::uuid;
|
|
|
|
|
|
|
|
CREATE OR REPLACE PROCEDURE public.add_nodes(IN p_user_id integer, IN p_client_uuid uuid, IN p_nodes jsonb)
|
|
LANGUAGE plpgsql
|
|
AS $procedure$
|
|
|
|
DECLARE
|
|
node_data jsonb;
|
|
node_updated timestamptz;
|
|
db_updated timestamptz;
|
|
db_uuid uuid;
|
|
db_client uuid;
|
|
db_client_seq int;
|
|
db_history_uuid uuid;
|
|
node_uuid uuid;
|
|
node_parent_uuid uuid;
|
|
node_history_uuid uuid;
|
|
|
|
BEGIN
|
|
RAISE NOTICE '--------------------------';
|
|
FOR node_data IN SELECT * FROM jsonb_array_elements(p_nodes)
|
|
LOOP
|
|
node_uuid = (node_data->>'UUID')::uuid;
|
|
node_history_uuid = (node_data->>'HistoryUUID')::uuid;
|
|
node_updated = (node_data->>'Updated')::timestamptz;
|
|
|
|
|
|
|
|
-- Frontend is using an all-zero UUID to define the root node.
|
|
-- Database is using NULL.
|
|
IF node_data->>'ParentUUID' = '00000000-0000-0000-0000-000000000000' THEN
|
|
node_parent_uuid = NULL;
|
|
ELSE
|
|
node_parent_uuid = (node_data->>'ParentUUID')::uuid;
|
|
END IF;
|
|
|
|
|
|
|
|
-- Every jode has a new history UUID to keep the history entry uniquely identifiable
|
|
-- across clients. A history entry could potentially be sent again, but should be
|
|
-- safe to ignore as every change to a node should have a new history UUID.
|
|
--
|
|
-- The current node is also stored as history.
|
|
INSERT INTO node_history(
|
|
user_id, "uuid", "history_uuid", parents, created, updated,
|
|
"name", "content", markdown, "content_encrypted",
|
|
client, client_sequence
|
|
)
|
|
VALUES(
|
|
p_user_id, -- combined key
|
|
node_uuid, -- combined key
|
|
node_history_uuid, -- combined key
|
|
(jsonb_populate_record(null::json_ancestor_array, node_data))."Ancestors",
|
|
(node_data->>'Created')::timestamptz,
|
|
(node_data->>'Updated')::timestamptz,
|
|
(node_data->>'Name')::varchar,
|
|
(node_data->>'Content')::text,
|
|
(node_data->>'Markdown')::bool,
|
|
'', /* content_encrypted */
|
|
p_client_uuid,
|
|
(node_data->>'ClientSequence')::int
|
|
)
|
|
ON CONFLICT ("user_id", "uuid", "history_uuid")
|
|
DO NOTHING;
|
|
|
|
|
|
|
|
-- Retrieve the current modified timestamp for this node from the database.
|
|
SELECT
|
|
uuid, updated, client, client_sequence
|
|
INTO
|
|
db_uuid, db_updated, db_client, db_client_seq
|
|
FROM public."node"
|
|
WHERE
|
|
user_id = p_user_id AND
|
|
uuid::uuid = node_uuid::uuid;
|
|
|
|
|
|
|
|
-- Is the node not in database? It needs to be created.
|
|
IF db_uuid IS NULL THEN
|
|
RAISE NOTICE '01 New node %', node_uuid;
|
|
|
|
INSERT INTO public."node" (
|
|
user_id, "uuid", parent_uuid, created, updated,
|
|
"name", "content", markdown, "content_encrypted",
|
|
client, client_sequence
|
|
)
|
|
VALUES(
|
|
p_user_id,
|
|
node_uuid,
|
|
node_parent_uuid,
|
|
(node_data->>'Created')::timestamptz,
|
|
(node_data->>'Updated')::timestamptz,
|
|
(node_data->>'Name')::varchar,
|
|
(node_data->>'Content')::text,
|
|
(node_data->>'Markdown')::bool,
|
|
'', /* content_encrypted */
|
|
p_client_uuid,
|
|
(node_data->>'ClientSequence')::int
|
|
);
|
|
|
|
CONTINUE;
|
|
|
|
END IF;
|
|
|
|
|
|
|
|
-- Update the public node as well if it was older than incoming node.
|
|
IF node_updated > db_updated THEN
|
|
UPDATE public."node"
|
|
SET
|
|
updated = (node_data->>'Updated')::timestamptz,
|
|
updated_seq = nextval('node_updates'),
|
|
name = (node_data->>'Name')::varchar,
|
|
content = (node_data->>'Content')::text,
|
|
markdown = (node_data->>'Markdown')::bool,
|
|
client = p_client_uuid,
|
|
client_sequence = (node_data->>'ClientSequence')::int
|
|
WHERE
|
|
user_id = p_user_id AND
|
|
uuid::uuid = node_uuid::uuid;
|
|
END IF;
|
|
|
|
END LOOP;
|
|
END
|
|
$procedure$
|
|
;
|