-- 10_error_handling.sql: Error paths — null args, nonexistent endpoints, invalid inputs
-- pg_regress test for ulak
-- ============================================================================
-- SEND WITH NULL ARGS (STRICT C function returns NULL)
-- ============================================================================
-- send() is STRICT: NULL endpoint_name returns NULL without error
SELECT ulak.send(NULL, '{"test": true}'::jsonb) IS NULL AS send_null_endpoint;
 send_null_endpoint 
--------------------
 t
(1 row)

-- send() is STRICT: NULL payload returns NULL without error
SELECT ulak.send('test_http_endpoint', NULL) IS NULL AS send_null_payload;
 send_null_payload 
-------------------
 t
(1 row)

-- send() is STRICT: both NULL returns NULL without error
SELECT ulak.send(NULL, NULL) IS NULL AS send_both_null;
 send_both_null 
----------------
 t
(1 row)

-- ============================================================================
-- DROP NONEXISTENT ENDPOINT (STRICT: NULL returns NULL)
-- ============================================================================
-- drop_endpoint is STRICT: NULL name returns NULL
SELECT ulak.drop_endpoint(NULL) IS NULL AS drop_null_returns_null;
 drop_null_returns_null 
------------------------
 t
(1 row)

-- ============================================================================
-- ENABLE/DISABLE NONEXISTENT ENDPOINT
-- ============================================================================
-- enable_endpoint raises exception for nonexistent endpoint
SELECT ulak.enable_endpoint('nonexistent_endpoint_xyz');
ERROR:  Endpoint 'nonexistent_endpoint_xyz' does not exist
CONTEXT:  PL/pgSQL function ulak.enable_endpoint(text) line 10 at RAISE
-- disable_endpoint raises exception for nonexistent endpoint
SELECT ulak.disable_endpoint('nonexistent_endpoint_xyz');
ERROR:  Endpoint 'nonexistent_endpoint_xyz' does not exist
CONTEXT:  PL/pgSQL function ulak.disable_endpoint(text) line 10 at RAISE
-- ============================================================================
-- INVALID CONSTRAINT VIOLATIONS
-- ============================================================================
-- NULL endpoint name should fail NOT NULL constraint
DO $$
BEGIN
    INSERT INTO ulak.endpoints (name, protocol, config)
    VALUES (NULL, 'http', '{"url":"http://localhost"}'::jsonb);
EXCEPTION WHEN not_null_violation THEN
    RAISE NOTICE 'NOT NULL violation: %', SQLERRM;
END
$$;
NOTICE:  NOT NULL violation: null value in column "name" of relation "endpoints" violates not-null constraint
-- NULL protocol should fail NOT NULL constraint
DO $$
BEGIN
    INSERT INTO ulak.endpoints (name, protocol, config)
    VALUES ('err_test_ep', NULL, '{"url":"http://localhost"}'::jsonb);
EXCEPTION WHEN not_null_violation THEN
    RAISE NOTICE 'NOT NULL violation: %', SQLERRM;
END
$$;
NOTICE:  NOT NULL violation: null value in column "protocol" of relation "endpoints" violates not-null constraint
-- NULL config should fail NOT NULL constraint
DO $$
BEGIN
    INSERT INTO ulak.endpoints (name, protocol, config)
    VALUES ('err_test_ep', 'http', NULL);
EXCEPTION WHEN not_null_violation THEN
    RAISE NOTICE 'NOT NULL violation: %', SQLERRM;
END
$$;
NOTICE:  NOT NULL violation: null value in column "config" of relation "endpoints" violates not-null constraint
-- NULL payload in queue should fail NOT NULL constraint
DO $$
DECLARE
    v_eid bigint;
BEGIN
    SELECT id INTO v_eid FROM ulak.endpoints WHERE name = 'test_http_endpoint';
    INSERT INTO ulak.queue (endpoint_id, payload)
    VALUES (v_eid, NULL);
EXCEPTION WHEN not_null_violation THEN
    RAISE NOTICE 'NOT NULL violation: %', SQLERRM;
END
$$;
NOTICE:  NOT NULL violation: null value in column "payload" of relation "queue" violates not-null constraint
-- ============================================================================
-- VALIDATE_ENDPOINT_CONFIG WITH NULL (STRICT: returns NULL)
-- ============================================================================
SELECT ulak.validate_endpoint_config(NULL, '{"url":"http://example.com"}'::jsonb) IS NULL AS validate_null_protocol;
 validate_null_protocol 
------------------------
 t
(1 row)

SELECT ulak.validate_endpoint_config('http', NULL) IS NULL AS validate_null_config;
 validate_null_config 
----------------------
 t
(1 row)

-- ============================================================================
-- QUEUE FOREIGN KEY VIOLATION
-- ============================================================================
-- Insert into queue with non-existent endpoint_id
DO $$
BEGIN
    INSERT INTO ulak.queue (endpoint_id, payload)
    VALUES (999999, '{"error_test": true}'::jsonb);
EXCEPTION WHEN foreign_key_violation THEN
    RAISE NOTICE 'FK violation: %', SQLERRM;
END
$$;
NOTICE:  FK violation: insert or update on table "queue" violates foreign key constraint "queue_endpoint_id_fkey"