authen.public

Parameters

Name	Type	Mode
event_type	text	IN
event_data	json	IN (DEFAULT NULL)
prop_id	integer	IN (DEFAULT NULL)
user_id	integer	IN (DEFAULT NULL)

Definition

declare
    realtime_conn text;
    prop_code TEXT;
    user_name TEXT;
    error     TEXT;
    v_state   TEXT;
    v_detail  TEXT;
    v_hint    TEXT;
    v_context TEXT;
    v_msgtext TEXT;
    sql_text TEXT
    ='insert into queue_realtime (prop_code, user_name, realtime_type, datas) values (%L, %L, %L, %L::json)';
BEGIN
    realtime_conn := coalesce(fn_get_session('strconn_realtime'));
    prop_code := (SELECT p.code FROM property p WHERE p.id = prop_id);
    user_name := (SELECT u.user_name FROM users u WHERE u.id = user_id);
    
    sql_text = format(sql_text, prop_code, user_name, event_type, event_data);
   
    PERFORM dblink_exec(realtime_conn, sql_text);

    return true;
EXCEPTION
    WHEN OTHERS THEN
    GET STACKED DIAGNOSTICS
        v_state   = RETURNED_SQLSTATE,
        v_msgtext = MESSAGE_TEXT,
        v_detail  = PG_EXCEPTION_DETAIL,
        v_hint    = PG_EXCEPTION_HINT,
        v_context = PG_EXCEPTION_CONTEXT;
    error = coalesce('message   : '||NULLIF(v_msgtext, '')||E'\n\n' , '') ||
            coalesce('detail    : '||NULLIF(v_detail, '') ||E'\n\n' , '') ||
            coalesce('hint      : '||NULLIF(v_hint, '')   ||E'\n\n' , '') ||
            coalesce('context   : '||NULLIF(v_context, '')||E'\n\n', '')  ||
            coalesce('sql_state : '||NULLIF(v_state, '')  ||E'\n\n' , '') ||
            coalesce('property  : '||NULLIF(prop_code, '')||E'\n\n' , '') ||  
            coalesce('user      : '||NULLIF(user_name, '')||E'\n\n' , '') || 
            coalesce('connection: '||NULLIF(realtime_conn, '')||E'\n\n' , '')|| 
            coalesce('event_type: '||NULLIF(event_type, '')||E'\n\n' , ''); 
    IF event_data IS NOT NULL THEN 
        error := error || coalesce('event_data: '||E'\n'||jsonb_pretty(event_data::jsonb)||E'\n', '');
    END IF;  
   
    PERFORM sp_system_notify('Error: sp_notify_realtime_event (authen)', error);

    RETURN FALSE;
END;