CREATEFUNCTION_possible_args() RETURNS jsonbAS

$BODY$

RETURNjson_build_object(

RETURNjsonb_build_object(

'node','node name (default: master)',

'name','job name',

'comments','some comments on job',

$BODY$

LANGUAGE plpgsqlset search_pathFROM CURRENT;

CREATEFUNCTION_get_cron_from_attrs(params jsonb) RETURNS jsonbAS

CREATEFUNCTION_get_cron_from_attrs(params jsonb, prev jsonb) RETURNS jsonbAS

$BODY$

DECLARE

datestext[];

cron jsonb;

rule jsonb;

clean_cron jsonb;

Ninteger;

nametext;

updatePrevboolean;

updatePrev := true;

IF NOT params?'cron'AND NOT params?'rule'AND NOT params?'date'AND NOT params?'dates' THEN

RAISE EXCEPTION'There is no information about job''s schedule'

USING HINT='Use''cron'' - cron string,''rule'' - json to set schedule rules or''date'' and''dates'' to set exact date(s)';

END IF;

IF params?'cron' THEN

EXECUTE'SELECT cron2jsontext($1::cstring)::jsonb'

INTO cron

USING params->>'cron';

ELSIF params?'rule' THEN

cron := params->'rule';

ELSIF NOT params?'date'AND NOT params?'dates' THEN

RAISE EXCEPTION'There is no information about job''s schedule'

USING HINT='Use''cron'' - cron string,''rule'' - json to set schedule rules or''date'' and''dates'' to set exact date(s)';

END IF;

IF cronIS NOT NULL THEN

IF cron?'date' THEN

dates := _get_array_from_jsonb(dates, cron->'date');

END IF;

IF cron?'dates' THEN

dates := _get_array_from_jsonb(dates, cron->'dates');

END IF;

IF params?'rule' THEN

rule := params->'rule';

updatePrev := false;

END IF;

cron := coalesce(cron,'{}'::jsonb)|| coalesce(rule,'{}'::jsonb);

IF cron?'date' THEN

dates := _get_array_from_jsonb(dates, cron->'date');

END IF;

IF cron?'dates' THEN

dates := _get_array_from_jsonb(dates, cron->'dates');

END IF;

IF params?'date' THEN

IF N>0 THEN

EXECUTE'SELECT array_agg(lll) FROM (SELECT distinct(date_trunc(''min'', unnest::timestamp with time zone)) as lll FROM unnest($1) ORDER BY date_trunc(''min'', unnest::timestamp with time zone)) as Z'

INTO dates USING dates;

cron :=COALESCE(cron,'{}'::jsonb)||json_build_object('dates', array_to_json(dates))::jsonb;

cron := cron||jsonb_build_object('dates', array_to_json(dates));

END IF;

IF updatePrevAND prevIS NOT NULL THEN

cron := prev|| cron;

END IF;

clean_cron :='{}'::jsonb;

FOR nameINSELECT*FROM unnest('{dates, crontab, onstart, days, hours, wdays, months, minutes}'::text[])

LOOP

RAISE WARNING'You used excess keys in params: %.', array_to_string(excess,',');

END IF;

cron := _get_cron_from_attrs(params);

cron := _get_cron_from_attrs(params,NULL);

commands := _get_commands_from_attrs(params);

executor := _get_executor_from_attrs(params);

node :='master';

CREATEFUNCTIONcreate_job(crontext, commandtext, nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('cron', cron,'command', command,'node', node)::jsonb);

RETURN create_job(jsonb_build_object('cron', cron,'command', command,'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dttimestamp with time zone, commandtext, nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('date', dt::text,'command', command,'node', node)::jsonb);

RETURN create_job(jsonb_build_object('date', dt::text,'command', command,'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dtstimestamp with time zone[], commandtext, nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('dates', array_to_json(dts),'command', command,'node', node)::jsonb);

RETURN create_job(jsonb_build_object('dates', array_to_json(dts),'command', command,'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(crontext, commandstext[], nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('cron', cron,'commands', array_to_json(commands),'node', node)::jsonb);

RETURN create_job(jsonb_build_object('cron', cron,'commands', array_to_json(commands),'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dttimestamp with time zone, commandstext[], nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('date', dt::text,'commands', array_to_json(commands),'node', node)::jsonb);

RETURN create_job(jsonb_build_object('date', dt::text,'commands', array_to_json(commands),'node', node));

END

$BODY$

LANGUAGE plpgsql

CREATEFUNCTIONcreate_job(dtstimestamp with time zone[], commandstext[], nodetext DEFAULTNULL) RETURNSintegerAS

$BODY$

RETURN create_job(json_build_object('dates', array_to_json(dts),'commands', array_to_json(commands),'node', node)::jsonb);

RETURN create_job(jsonb_build_object('dates', array_to_json(dts),'commands', array_to_json(commands),'node', node));

END

$BODY$

LANGUAGE plpgsql

IF attrs?'cron'OR attrs?'date'OR attrs?'dates'OR attrs?'rule' THEN

cmd := cmd||'rule ='||

quote_literal(_get_cron_from_attrs(attrs))||'::jsonb,';

quote_literal(_get_cron_from_attrs(attrs,job.rule))||'::jsonb,';

END IF;

IF attrs?'command'OR attrs?'commands' THEN

LANGUAGE plpgsql

SECURITY DEFINERset search_pathFROM CURRENT;

CREATEFUNCTIONset_job_attribute(jobIdinteger, nametext, value jsonb) RETURNSbooleanAS

$BODY$

IF name<>'rule' THEN

RAISE EXCEPTION'key % cannot have a jsonb value. Only "rule" allowed', name;

END IF;

RETURN set_job_attributes(jobId, jsonb_build_object(name, value));

END

$BODY$

LANGUAGE plpgsql

SECURITY DEFINERset search_pathFROM CURRENT;

CREATEFUNCTIONset_job_attribute(jobIdinteger, nametext, value anyarray) RETURNSbooleanAS

$BODY$

IF name<>'dates'AND name<>'commands' THEN

RAISE EXCEPTION'key % cannot have an array value. Only dates, commands allowed', name;

END IF;

RETURN set_job_attributes(jobId,json_build_object(name, array_to_json(value))::jsonb);

RETURN set_job_attributes(jobId,jsonb_build_object(name, array_to_json(value)));

END

$BODY$

LANGUAGE plpgsql

attrs jsonb;

IF name='dates'OR name='commands' THEN

attrs := json_build_object(name, array_to_json(value::text[]));

attrs := jsonb_build_object(name, array_to_json(value::text[]));

ELSIF name='rule' THEN

attrs := jsonb_build_object('rule', value::jsonb);

ELSE

attrs :=json_build_object(name, value);

attrs :=jsonb_build_object(name, value);

END IF;

RETURN set_job_attributes(jobId, attrs);

END