// Code generated by sqlc. DO NOT EDIT.
// versions:
//   sqlc v1.31.1
// source: workspace_wakeup.sql

package db

import (
	"context"

	"github.com/jackc/pgx/v5/pgtype"
)

const listWorkspaceWakeups = `-- name: ListWorkspaceWakeups :one
WITH base AS MATERIALIZED (
 SELECT w.id,w.issue_id,i.title AS issue_title,ws.issue_prefix||'-'||i.number AS issue_identifier,
  w.agent_id,a.name AS agent_name,w.kind,w.mode,w.event_types,w.filter_actor_type,
 (CASE WHEN actor_agent.id IS NOT NULL OR actor_member.user_id IS NOT NULL THEN w.filter_actor_id END)::uuid AS filter_actor_id,
 COALESCE(actor_agent.name,actor_user.name,'')::text AS filter_actor_name,
  CASE WHEN source.id IS NOT NULL THEN w.filter_agent_id END AS filter_agent_id,
  source.name AS filter_agent_name,
  CASE WHEN EXISTS(SELECT 1 FROM agent_task_queue ft JOIN agent fa ON fa.id=ft.agent_id AND fa.workspace_id=w.workspace_id
   WHERE ft.id=w.filter_task_id AND ft.issue_id=w.issue_id AND fa.id=ANY($1::uuid[])) THEN w.filter_task_id END AS filter_task_id,
  w.interval_seconds,w.cron_expression,w.timezone,
  w.next_fire_at,w.enabled,w.revision,w.disabled_at,w.last_task_id,w.last_error,w.created_at,
  w.expires_at,w.expiry_seconds,w.on_timeout,w.timed_out_at,
  w.condition,w.max_fires,w.fire_count,w.paused_reason,
  (w.source_task_id IS NOT NULL) AS created_by_agent,creator.name AS created_by_name,
  CASE WHEN creator_agent.id IS NOT NULL THEN creator_agent.id END AS source_agent_id,creator_agent.name AS source_agent_name,
  (i.status IN ('done','cancelled') OR EXISTS(SELECT 1 FROM issue_status s WHERE s.workspace_id=i.workspace_id AND s.key=i.status AND s.category IN ('done','closed'))) AS issue_closed,
  COALESCE((w.created_by= $2::uuid OR $3::boolean),false) AS can_manage,
  COALESCE(r.active_runs,0)::int AS active_runs,
  (CASE WHEN w.source_task_id IS NOT NULL THEN 'agent' ELSE 'member' END)::text AS source,
  NULL::text AS rule,NULL::int AS system_stage,NULL::text AS target_type,NULL::int AS system_remaining
 FROM issue_wakeup w
 JOIN workspace ws ON ws.id=w.workspace_id
 JOIN issue i ON i.id=w.issue_id AND i.workspace_id=w.workspace_id
 JOIN agent a ON a.id=w.agent_id AND a.workspace_id=w.workspace_id
 LEFT JOIN agent actor_agent ON w.filter_actor_type='agent' AND actor_agent.id=w.filter_actor_id AND actor_agent.workspace_id=w.workspace_id AND actor_agent.id=ANY($1::uuid[])
LEFT JOIN member actor_member ON w.filter_actor_type='member' AND actor_member.user_id=w.filter_actor_id AND actor_member.workspace_id=w.workspace_id
LEFT JOIN "user" actor_user ON actor_user.id=actor_member.user_id
 LEFT JOIN agent source ON source.id=w.filter_agent_id AND source.workspace_id=w.workspace_id AND source.id=ANY($1::uuid[])
 LEFT JOIN "user" creator ON creator.id=w.created_by
 LEFT JOIN agent_task_queue creator_task ON creator_task.id=w.source_task_id
 LEFT JOIN agent creator_agent ON creator_agent.id=creator_task.agent_id AND creator_agent.workspace_id=w.workspace_id AND creator_agent.id=ANY($1::uuid[])
 LEFT JOIN LATERAL (
  SELECT count(*) AS active_runs FROM agent_task_queue t
  WHERE t.context->>'wakeup_id'=w.id::text AND t.issue_id=w.issue_id AND t.agent_id=w.agent_id
   AND t.status IN ('queued','deferred','dispatched','running','waiting_local_directory')
 ) r ON true
 WHERE w.workspace_id= $4 AND w.system_rule IS NULL
 UNION ALL
 -- The child-done system rule of each open parent that still waits for a
 -- sub-issue: every child when unstaged, else its lowest unfinished stage.
 -- Its target is the parent's assignee (a squad's leader) at the moment.
 SELECT w.id,w.issue_id,p.title,ws.issue_prefix||'-'||p.number,
  COALESCE(ta.id,leader.id),COALESCE(ta.name,leader.name,''),w.kind,w.mode,w.event_types,NULL::text,
  NULL::uuid,''::text,NULL::uuid,NULL::text,NULL::uuid,
  NULL::bigint,NULL::text,w.timezone,
  NULL::timestamptz,w.enabled,w.revision,w.disabled_at,w.last_task_id,w.last_error,w.created_at,
  NULL::timestamptz,NULL::bigint,NULL::text,NULL::timestamptz,
  w.condition,w.max_fires,w.fire_count,w.paused_reason,
  false,NULL::text,
  NULL::uuid,NULL::text,
  false,true,COALESCE(sr.active_runs,0)::int,
  'system',w.system_rule,ch.stage,p.assignee_type,ch.remaining
 FROM issue_wakeup w
 JOIN issue p ON p.id=w.issue_id AND p.workspace_id=w.workspace_id
 JOIN workspace ws ON ws.id=p.workspace_id
 LEFT JOIN agent ta ON p.assignee_type='agent' AND ta.id=p.assignee_id AND ta.workspace_id=p.workspace_id
 LEFT JOIN squad sq ON p.assignee_type='squad' AND sq.id=p.assignee_id AND sq.workspace_id=p.workspace_id
 LEFT JOIN agent leader ON leader.id=sq.leader_id AND leader.workspace_id=p.workspace_id
 CROSS JOIN LATERAL (
  SELECT bool_or(ci.stage IS NOT NULL) AS staged,
   min(ci.stage) FILTER(WHERE ci.stage IS NOT NULL AND NOT (ci.status IN ('done','cancelled') OR EXISTS(SELECT 1 FROM issue_status cs WHERE cs.workspace_id=ci.workspace_id AND cs.key=ci.status AND cs.category IN ('done','closed')))) AS stage,
   count(*) FILTER(WHERE NOT (ci.status IN ('done','cancelled') OR EXISTS(SELECT 1 FROM issue_status cs WHERE cs.workspace_id=ci.workspace_id AND cs.key=ci.status AND cs.category IN ('done','closed')))) AS open_count
  FROM issue ci WHERE ci.parent_issue_id=p.id AND ci.workspace_id=p.workspace_id
 ) agg
 CROSS JOIN LATERAL (
  SELECT (CASE WHEN agg.staged THEN agg.stage END)::int AS stage,
   (CASE WHEN agg.staged AND agg.stage IS NOT NULL THEN (SELECT count(*) FROM issue ci WHERE ci.parent_issue_id=p.id AND ci.workspace_id=p.workspace_id
     AND ci.stage=agg.stage AND NOT (ci.status IN ('done','cancelled') OR EXISTS(SELECT 1 FROM issue_status cs WHERE cs.workspace_id=ci.workspace_id AND cs.key=ci.status AND cs.category IN ('done','closed')))) ELSE agg.open_count END)::int AS remaining
 ) ch
 LEFT JOIN LATERAL (
  SELECT count(*) AS active_runs FROM agent_task_queue t
  WHERE t.context->>'wakeup_id'=w.id::text AND t.issue_id=w.issue_id
   AND t.status IN ('queued','deferred','dispatched','running','waiting_local_directory')
 ) sr ON true
 WHERE w.workspace_id= $4 AND w.system_rule IS NOT NULL AND agg.open_count>0
  AND p.status NOT IN ('done','cancelled')
  AND NOT EXISTS(SELECT 1 FROM issue_status s WHERE s.workspace_id=p.workspace_id AND s.key=p.status AND s.category IN ('done','closed'))
), classified AS (
 SELECT id, issue_id, issue_title, issue_identifier, agent_id, agent_name, kind, mode, event_types, filter_actor_type, filter_actor_id, filter_actor_name, filter_agent_id, filter_agent_name, filter_task_id, interval_seconds, cron_expression, timezone, next_fire_at, enabled, revision, disabled_at, last_task_id, last_error, created_at, expires_at, expiry_seconds, on_timeout, timed_out_at, condition, max_fires, fire_count, paused_reason, created_by_agent, created_by_name, source_agent_id, source_agent_name, issue_closed, can_manage, active_runs, source, rule, system_stage, target_type, system_remaining,CASE WHEN (enabled AND NOT issue_closed) OR active_runs>0 THEN 'active'
  WHEN NOT issue_closed AND paused_reason IS NOT NULL THEN 'paused'
  WHEN NOT issue_closed AND (disabled_at IS NOT NULL OR source='system') THEN 'disabled' ELSE 'ended' END AS scope
 FROM base
), filtered AS (
 SELECT id, issue_id, issue_title, issue_identifier, agent_id, agent_name, kind, mode, event_types, filter_actor_type, filter_actor_id, filter_actor_name, filter_agent_id, filter_agent_name, filter_task_id, interval_seconds, cron_expression, timezone, next_fire_at, enabled, revision, disabled_at, last_task_id, last_error, created_at, expires_at, expiry_seconds, on_timeout, timed_out_at, condition, max_fires, fire_count, paused_reason, created_by_agent, created_by_name, source_agent_id, source_agent_name, issue_closed, can_manage, active_runs, source, rule, system_stage, target_type, system_remaining, scope FROM classified WHERE ($5::text='all' OR scope= $5)
  AND ($6::text='all' OR ($6='event' AND kind='event') OR ($6='at' AND kind='at') OR ($6='recurring' AND kind IN ('every','cron')))
  AND ($7::text='' OR source= $7)
  AND ($8::text='' OR agent_id::text= $8)
  AND ($9::text='' OR strpos(lower(issue_title||' '||issue_identifier||' '||agent_name),lower($9))>0)
), page AS (
 SELECT id, issue_id, issue_title, issue_identifier, agent_id, agent_name, kind, mode, event_types, filter_actor_type, filter_actor_id, filter_actor_name, filter_agent_id, filter_agent_name, filter_task_id, interval_seconds, cron_expression, timezone, next_fire_at, enabled, revision, disabled_at, last_task_id, last_error, created_at, expires_at, expiry_seconds, on_timeout, timed_out_at, condition, max_fires, fire_count, paused_reason, created_by_agent, created_by_name, source_agent_id, source_agent_name, issue_closed, can_manage, active_runs, source, rule, system_stage, target_type, system_remaining, scope FROM filtered ORDER BY created_at DESC,id DESC LIMIT $11::int OFFSET $10::int
), details AS (
 SELECT p.id, p.issue_id, p.issue_title, p.issue_identifier, p.agent_id, p.agent_name, p.kind, p.mode, p.event_types, p.filter_actor_type, p.filter_actor_id, p.filter_actor_name, p.filter_agent_id, p.filter_agent_name, p.filter_task_id, p.interval_seconds, p.cron_expression, p.timezone, p.next_fire_at, p.enabled, p.revision, p.disabled_at, p.last_task_id, p.last_error, p.created_at, p.expires_at, p.expiry_seconds, p.on_timeout, p.timed_out_at, p.condition, p.max_fires, p.fire_count, p.paused_reason, p.created_by_agent, p.created_by_name, p.source_agent_id, p.source_agent_name, p.issue_closed, p.can_manage, p.active_runs, p.source, p.rule, p.system_stage, p.target_type, p.system_remaining, p.scope,r.status AS last_task_status,
  (SELECT count(*) FROM agent_task_queue t7 WHERE t7.context->>'wakeup_id'=p.id::text AND t7.issue_id=p.issue_id
    AND t7.created_at>now()-interval '7 days')::int AS runs_7d,
  CASE WHEN r.id IS NOT NULL THEN jsonb_build_object(
   'id',r.id,'agent_id',r.agent_id,'runtime_id',r.runtime_id,'issue_id',r.issue_id,'wakeup_id',p.id,
   'status',r.status,'priority',r.priority,'created_at',r.created_at,'started_at',r.started_at,
   'dispatched_at',r.dispatched_at,'completed_at',r.completed_at
  ) END AS task
 FROM page p
 LEFT JOIN LATERAL (
  SELECT candidate.id, candidate.agent_id, candidate.runtime_id, candidate.issue_id, candidate.status, candidate.priority, candidate.created_at, candidate.started_at, candidate.dispatched_at, candidate.completed_at, candidate.active FROM (
   (SELECT t.id,t.agent_id,t.runtime_id,t.issue_id,t.status,t.priority,t.created_at,t.started_at,t.dispatched_at,t.completed_at,1 AS active
    FROM agent_task_queue t WHERE t.context->>'wakeup_id'=p.id::text AND t.issue_id=p.issue_id AND (p.source='system' OR t.agent_id=p.agent_id)
     AND t.status IN ('queued','deferred','dispatched','running','waiting_local_directory')
    ORDER BY (t.status IN ('running','waiting_local_directory','dispatched')) DESC,t.created_at DESC,t.id DESC LIMIT 1)
   UNION ALL
   (SELECT t.id,t.agent_id,t.runtime_id,t.issue_id,t.status,t.priority,t.created_at,t.started_at,t.dispatched_at,t.completed_at,0 AS active
    FROM agent_task_queue t WHERE t.context->>'wakeup_id'=p.id::text AND t.issue_id=p.issue_id AND (p.source='system' OR t.agent_id=p.agent_id)
     AND t.status NOT IN ('queued','deferred','dispatched','running','waiting_local_directory')
    ORDER BY t.created_at DESC,t.id DESC LIMIT 1)
  ) candidate ORDER BY active DESC LIMIT 1
 ) r ON true
)
SELECT jsonb_build_object(
 'items',COALESCE((SELECT jsonb_agg(to_jsonb(details)-'created_at'-'scope' ORDER BY created_at DESC,id DESC) FROM details),'[]'::jsonb),
 'total',(SELECT count(*) FROM filtered),
 'counts',jsonb_build_object('all',(SELECT count(*) FROM classified),'active',(SELECT count(*) FROM classified WHERE scope='active'),
  'paused',(SELECT count(*) FROM classified WHERE scope='paused'),
  'disabled',(SELECT count(*) FROM classified WHERE scope='disabled'),'ended',(SELECT count(*) FROM classified WHERE scope='ended')),
 'agents',COALESCE((SELECT jsonb_agg(x ORDER BY x.name,x.id) FROM (SELECT DISTINCT agent_id AS id,agent_name AS name FROM base WHERE agent_id IS NOT NULL) x),'[]'::jsonb)
) AS result
`

type ListWorkspaceWakeupsParams struct {
	AgentIds    []pgtype.UUID `json:"agent_ids"`
	MemberID    pgtype.UUID   `json:"member_id"`
	IsAdmin     bool          `json:"is_admin"`
	WorkspaceID pgtype.UUID   `json:"workspace_id"`
	Scope       string        `json:"scope"`
	Kind        string        `json:"kind"`
	Source      string        `json:"source"`
	AgentID     string        `json:"agent_id"`
	Search      string        `json:"search"`
	PageOffset  int32         `json:"page_offset"`
	PageLimit   int32         `json:"page_limit"`
}

// Counts, filter choices, and page share one snapshot and the same access scope.
func (q *Queries) ListWorkspaceWakeups(ctx context.Context, arg ListWorkspaceWakeupsParams) ([]byte, error) {
	row := q.db.QueryRow(ctx, listWorkspaceWakeups,
		arg.AgentIds,
		arg.MemberID,
		arg.IsAdmin,
		arg.WorkspaceID,
		arg.Scope,
		arg.Kind,
		arg.Source,
		arg.AgentID,
		arg.Search,
		arg.PageOffset,
		arg.PageLimit,
	)
	var result []byte
	err := row.Scan(&result)
	return result, err
}