-- Indexers and download clients (M502 #5518).

-- name: ListAcquisitionServices :many
-- Returns no secret, only whether one is set: this feeds the settings page.
SELECT code, kind, protocol, label, enabled, base_url,
       (api_key <> '')::boolean  AS has_api_key,
       (password <> '')::boolean AS has_password,
       username, category, timeout_ms,
       serves_search, serves_downloads, serves_enrichment,
       local_path, remote_path, searches_per_hour,
       created_at, updated_at
FROM acquisition_services
ORDER BY kind, label, code;

-- name: GetAcquisitionService :one
-- The full row, credentials included. For building a client, never for a
-- response.
SELECT * FROM acquisition_services WHERE code = sqlc.arg(code);

-- name: ListUsableAcquisitionServices :many
-- Every enabled, addressed service doing one job. An exchange row does a job
-- when its switch for it is on; any other row does the job its kind names.
-- Ordered by code so a fan-out is deterministic.
SELECT * FROM acquisition_services
WHERE enabled AND base_url <> ''
  AND CASE WHEN protocol = 'exchange' THEN
           CASE sqlc.arg(job)::text
               WHEN 'search'     THEN serves_search
               WHEN 'download'   THEN serves_downloads
               WHEN 'enrichment' THEN serves_enrichment
               ELSE false
           END
       ELSE kind = sqlc.arg(job)::text
  END
ORDER BY code;

-- name: CreateAcquisitionService :one
-- ON CONFLICT so the caller can try the next code when this one is taken.
INSERT INTO acquisition_services
    (code, kind, protocol, label, category, timeout_ms, searches_per_hour)
VALUES
    (sqlc.arg(code), sqlc.arg(kind), sqlc.arg(protocol), sqlc.arg(label),
     sqlc.arg(category), sqlc.arg(timeout_ms), sqlc.arg(searches_per_hour))
ON CONFLICT (code) DO NOTHING
RETURNING *;

-- name: UpdateAcquisitionService :one
-- Everything on the settings form except the credentials, which have their
-- own write-only calls.
UPDATE acquisition_services SET
    label             = sqlc.arg(label),
    enabled           = sqlc.arg(enabled),
    base_url          = sqlc.arg(base_url),
    username          = sqlc.arg(username),
    category          = sqlc.arg(category),
    timeout_ms        = sqlc.arg(timeout_ms),
    serves_search     = sqlc.arg(serves_search),
    serves_downloads  = sqlc.arg(serves_downloads),
    serves_enrichment = sqlc.arg(serves_enrichment),
    local_path        = sqlc.arg(local_path),
    remote_path       = sqlc.arg(remote_path),
    searches_per_hour = sqlc.arg(searches_per_hour),
    updated_at        = now()
WHERE code = sqlc.arg(code)
RETURNING *;

-- name: DeleteAcquisitionService :execrows
DELETE FROM acquisition_services WHERE code = sqlc.arg(code);

-- name: SetAcquisitionServiceAPIKey :execrows
UPDATE acquisition_services SET api_key = sqlc.arg(api_key), updated_at = now()
WHERE code = sqlc.arg(code);

-- name: SetAcquisitionServicePassword :execrows
UPDATE acquisition_services SET password = sqlc.arg(password), updated_at = now()
WHERE code = sqlc.arg(code);