-- name: CountRepositories :oneselect count(*) from repositories; -- name: CountThreads :oneselect count(*) from threads; -- name: CountOpenThreads :oneselect count(*) from threads where state = 'open' and closed_at_local is null; -- name: CountClusters :oneselect count(*) from cluster_groups; -- name: MaxSuccessfulSyncFinishedAt :oneselect cast(coalesce(max(finished_at), '') as text) as last_sync from sync_runs where status in ('success', 'completed'); -- name: PortableExportedAt :oneselect value from portable_metadata where key = 'exported_at'; -- name: RepoSyncStateLastSync :oneselect cast(coalesce(  max(last_open_close_reconciled_at),  max(last_overlapping_open_scan_completed_at),  max(last_non_overlapping_scan_completed_at),  max(last_full_open_scan_started_at),  max(updated_at),  '') as text) as last_sync from repo_sync_state; -- name: UpsertRepository :oneinsert into repositories(owner, name, full_name, github_repo_id, raw_json, updated_at)values(sqlc.arg(owner), sqlc.arg(name), sqlc.arg(full_name), sqlc.narg(github_repo_id), sqlc.arg(raw_json), sqlc.arg(updated_at))on conflict(full_name) do update set  owner=excluded.owner,  name=excluded.name,  github_repo_id=excluded.github_repo_id,  raw_json=excluded.raw_json,  updated_at=excluded.updated_atreturning id; -- name: RepositoryByFullName :oneselect id, owner, name, full_name, github_repo_id, coalesce(raw_json, '') as raw_json, updated_atfrom repositorieswhere full_name = sqlc.arg(full_name); -- name: ListRepositories :manyselect id, owner, name, full_name, github_repo_id, coalesce(raw_json, '') as raw_json, updated_atfrom repositoriesorder by coalesce(updated_at, '') desc, id desc; -- name: UpsertThread :oneinsert into threads(  repo_id, github_id, number, kind, state, title, body, author_login, author_type, author_association, html_url,  labels_json, assignees_json, raw_json, content_hash, is_draft,  created_at_gh, updated_at_gh, closed_at_gh, merged_at_gh,  first_pulled_at, last_pulled_at, observation_sequence, updated_at)values(  sqlc.arg(repo_id), sqlc.arg(github_id), sqlc.arg(number), sqlc.arg(kind), sqlc.arg(state), sqlc.arg(title),  sqlc.narg(body), sqlc.narg(author_login), sqlc.narg(author_type), sqlc.narg(author_association), sqlc.arg(html_url),  sqlc.arg(labels_json), sqlc.arg(assignees_json), sqlc.arg(raw_json), sqlc.arg(content_hash), sqlc.arg(is_draft),  sqlc.narg(created_at_gh), sqlc.narg(updated_at_gh), sqlc.narg(closed_at_gh), sqlc.narg(merged_at_gh),  sqlc.narg(first_pulled_at), sqlc.narg(last_pulled_at), sqlc.arg(observation_sequence), sqlc.arg(updated_at))on conflict(repo_id, kind, number) do update set  github_id=excluded.github_id,  state=excluded.state,  title=excluded.title,  body=excluded.body,  author_login=excluded.author_login,  author_type=excluded.author_type,  author_association=excluded.author_association,  html_url=excluded.html_url,  labels_json=excluded.labels_json,  assignees_json=excluded.assignees_json,  raw_json=excluded.raw_json,  content_hash=excluded.content_hash,  is_draft=excluded.is_draft,  created_at_gh=excluded.created_at_gh,  updated_at_gh=excluded.updated_at_gh,  closed_at_gh=excluded.closed_at_gh,  merged_at_gh=excluded.merged_at_gh,  last_pulled_at=excluded.last_pulled_at,  observation_sequence=excluded.observation_sequence,  updated_at=excluded.updated_atreturning id; -- name: UpsertThreadPreservingDraft :oneinsert into threads(  repo_id, github_id, number, kind, state, title, body, author_login, author_type, author_association, html_url,  labels_json, assignees_json, raw_json, content_hash, is_draft,  created_at_gh, updated_at_gh, closed_at_gh, merged_at_gh,  first_pulled_at, last_pulled_at, observation_sequence, updated_at)values(  sqlc.arg(repo_id), sqlc.arg(github_id), sqlc.arg(number), sqlc.arg(kind), sqlc.arg(state), sqlc.arg(title),  sqlc.narg(body), sqlc.narg(author_login), sqlc.narg(author_type), sqlc.narg(author_association), sqlc.arg(html_url),  sqlc.arg(labels_json), sqlc.arg(assignees_json), sqlc.arg(raw_json), sqlc.arg(content_hash), sqlc.arg(is_draft),  sqlc.narg(created_at_gh), sqlc.narg(updated_at_gh), sqlc.narg(closed_at_gh), sqlc.narg(merged_at_gh),  sqlc.narg(first_pulled_at), sqlc.narg(last_pulled_at), sqlc.arg(observation_sequence), sqlc.arg(updated_at))on conflict(repo_id, kind, number) do update set  github_id=excluded.github_id,  state=excluded.state,  title=excluded.title,  body=excluded.body,  author_login=excluded.author_login,  author_type=excluded.author_type,  author_association=excluded.author_association,  html_url=excluded.html_url,  labels_json=excluded.labels_json,  assignees_json=excluded.assignees_json,  raw_json=excluded.raw_json,  content_hash=excluded.content_hash,  is_draft=threads.is_draft,  created_at_gh=excluded.created_at_gh,  updated_at_gh=excluded.updated_at_gh,  closed_at_gh=excluded.closed_at_gh,  merged_at_gh=excluded.merged_at_gh,  last_pulled_at=excluded.last_pulled_at,  observation_sequence=excluded.observation_sequence,  updated_at=excluded.updated_atreturning id; -- name: MarkOpenThreadClosedFromGitHub :execrowsupdate threadsset github_id = sqlc.arg(github_id),  state = sqlc.arg(state),  title = sqlc.arg(title),  body = sqlc.narg(body),  author_login = sqlc.narg(author_login),  author_type = sqlc.narg(author_type),  author_association = sqlc.narg(author_association),  html_url = sqlc.arg(html_url),  labels_json = sqlc.arg(labels_json),  assignees_json = sqlc.arg(assignees_json),  raw_json = sqlc.arg(raw_json),  content_hash = sqlc.arg(content_hash),  created_at_gh = sqlc.narg(created_at_gh),  updated_at_gh = sqlc.narg(updated_at_gh),  closed_at_gh = sqlc.narg(closed_at_gh),  merged_at_gh = sqlc.narg(merged_at_gh),  last_pulled_at = sqlc.narg(last_pulled_at),  updated_at = sqlc.arg(updated_at)where repo_id = sqlc.arg(repo_id)  and kind = sqlc.arg(kind)  and number = sqlc.arg(number)  and state = 'open'  and closed_at_local is null; -- name: ListThreadsCurrentSchema :manyselect id, repo_id, github_id, number, kind, state, title, body, author_login, author_type, author_association, html_url,  labels_json, assignees_json, coalesce(raw_json, '') as raw_json, content_hash, is_draft, created_at_gh, updated_at_gh,  closed_at_gh, merged_at_gh, first_pulled_at, last_pulled_at, updated_at, closed_at_local, close_reason_localfrom threadswhere repo_id = sqlc.arg(repo_id)  and (sqlc.arg(include_closed) != 0 or closed_at_local is null)order by numberlimit case when sqlc.arg(row_limit) <= 0 then -1 else sqlc.arg(row_limit) end; -- name: CloseThreadLocally :execrowsupdate threadsset closed_at_local = sqlc.arg(closed_at), close_reason_local = sqlc.arg(reason), updated_at = sqlc.arg(closed_at)where repo_id = sqlc.arg(repo_id) and number = sqlc.arg(number); -- name: ReopenThreadLocally :execrowsupdate threadsset closed_at_local = null, close_reason_local = null, updated_at = sqlc.arg(updated_at)where repo_id = sqlc.arg(repo_id) and number = sqlc.arg(number); -- name: UpsertComment :oneinsert into comments(thread_id, github_id, comment_type, author_login, author_type, body, is_bot, raw_json, created_at_gh, updated_at_gh, deleted_at, deletion_reason)values(sqlc.arg(thread_id), sqlc.arg(github_id), sqlc.arg(comment_type), sqlc.narg(author_login), sqlc.narg(author_type), sqlc.arg(body), sqlc.arg(is_bot), sqlc.arg(raw_json), sqlc.narg(created_at_gh), sqlc.narg(updated_at_gh), sqlc.narg(deleted_at), sqlc.narg(deletion_reason))on conflict(thread_id, comment_type, github_id) do update set  author_login=excluded.author_login,  author_type=excluded.author_type,  body=excluded.body,  is_bot=excluded.is_bot,  raw_json=excluded.raw_json,  created_at_gh=excluded.created_at_gh,  updated_at_gh=excluded.updated_at_gh,  deleted_at=excluded.deleted_at,  deletion_reason=excluded.deletion_reasonreturning id; -- name: ListComments :manyselect id, thread_id, github_id, comment_type, author_login, author_type, body, is_bot, raw_json, created_at_gh, updated_at_gh, deleted_at, deletion_reasonfrom commentswhere thread_id = sqlc.arg(thread_id)  and deleted_at is nullorder by created_at_gh, id; -- name: UpsertDocument :oneinsert into documents(thread_id, title, body, raw_text, dedupe_text, updated_at)values(sqlc.arg(thread_id), sqlc.arg(title), sqlc.narg(body), sqlc.arg(raw_text), sqlc.arg(dedupe_text), sqlc.arg(updated_at))on conflict(thread_id) do update set  title=excluded.title,  body=excluded.body,  raw_text=excluded.raw_text,  dedupe_text=excluded.dedupe_text,  updated_at=excluded.updated_atwhere documents.title is not excluded.title   or documents.body is not excluded.body   or documents.raw_text is not excluded.raw_text   or documents.dedupe_text is not excluded.dedupe_textreturning id; -- name: RecordSyncRun :oneinsert into sync_runs(repo_id, scope, status, started_at, finished_at, stats_json, error_text)values(sqlc.arg(repo_id), sqlc.arg(scope), sqlc.arg(status), sqlc.arg(started_at), sqlc.narg(finished_at), sqlc.narg(stats_json), sqlc.narg(error_text))returning id; -- name: RecordSummaryRun :oneinsert into summary_runs(repo_id, scope, status, started_at, finished_at, stats_json, error_text)values(sqlc.arg(repo_id), sqlc.arg(scope), sqlc.arg(status), sqlc.arg(started_at), sqlc.narg(finished_at), sqlc.narg(stats_json), sqlc.narg(error_text))returning id; -- name: RecordEmbeddingRun :oneinsert into embedding_runs(repo_id, scope, status, started_at, finished_at, stats_json, error_text)values(sqlc.arg(repo_id), sqlc.arg(scope), sqlc.arg(status), sqlc.arg(started_at), sqlc.narg(finished_at), sqlc.narg(stats_json), sqlc.narg(error_text))returning id; -- name: RecordClusterRun :oneinsert into cluster_runs(repo_id, scope, status, started_at, finished_at, stats_json, error_text)values(sqlc.arg(repo_id), sqlc.arg(scope), sqlc.arg(status), sqlc.arg(started_at), sqlc.narg(finished_at), sqlc.narg(stats_json), sqlc.narg(error_text))returning id; -- name: ListSyncRuns :manyselect id, repo_id, scope, status, started_at, finished_at, stats_json, error_textfrom sync_runswhere repo_id = sqlc.arg(repo_id)order by id desclimit sqlc.arg(row_limit); -- name: ListSummaryRuns :manyselect id, repo_id, scope, status, started_at, finished_at, stats_json, error_textfrom summary_runswhere repo_id = sqlc.arg(repo_id)order by id desclimit sqlc.arg(row_limit); -- name: ListEmbeddingRuns :manyselect id, repo_id, scope, status, started_at, finished_at, stats_json, error_textfrom embedding_runswhere repo_id = sqlc.arg(repo_id)order by id desclimit sqlc.arg(row_limit); -- name: ListClusterRuns :manyselect id, repo_id, scope, status, started_at, finished_at, stats_json, error_textfrom cluster_runswhere repo_id = sqlc.arg(repo_id)order by id desclimit sqlc.arg(row_limit); -- name: LastSuccessfulSyncAt :oneselect cast(coalesce(max(finished_at), '') as text) as last_syncfrom sync_runswhere repo_id = sqlc.arg(repo_id) and status in ('success', 'completed'); -- name: LastSuccessfulListSyncAt :oneselect cast(coalesce(max(finished_at), '') as text) as last_syncfrom sync_runswhere repo_id = sqlc.arg(repo_id)  and status in ('success', 'completed')  and (    (sqlc.arg(state) = 'open' and scope in ('open', 'all')) or    (sqlc.arg(state) = 'closed' and scope in ('closed', 'all')) or    (sqlc.arg(state) = 'all' and scope = 'all')  ); -- name: UpsertPullRequestDetail :execinsert into pull_request_details(thread_id, repo_id, number, base_sha, head_sha, head_ref, head_repo_full_name, mergeable_state, additions, deletions, changed_files, raw_json, fetched_at, updated_at)values(sqlc.arg(thread_id), sqlc.arg(repo_id), sqlc.arg(number), sqlc.narg(base_sha), sqlc.narg(head_sha), sqlc.narg(head_ref), sqlc.narg(head_repo_full_name), sqlc.narg(mergeable_state), sqlc.arg(additions), sqlc.arg(deletions), sqlc.arg(changed_files), sqlc.arg(raw_json), sqlc.arg(fetched_at), sqlc.arg(updated_at))on conflict(thread_id) do update set  repo_id=excluded.repo_id,  number=excluded.number,  base_sha=excluded.base_sha,  head_sha=excluded.head_sha,  head_ref=excluded.head_ref,  head_repo_full_name=excluded.head_repo_full_name,  mergeable_state=excluded.mergeable_state,  additions=excluded.additions,  deletions=excluded.deletions,  changed_files=excluded.changed_files,  raw_json=excluded.raw_json,  fetched_at=excluded.fetched_at,  updated_at=excluded.updated_at; -- name: DeletePullRequestFiles :execdelete from pull_request_files where thread_id = sqlc.arg(thread_id); -- name: InsertPullRequestFile :execinsert into pull_request_files(thread_id, position, path, status, additions, deletions, changes, previous_path, patch, raw_json, fetched_at)values(sqlc.arg(thread_id), sqlc.arg(position), sqlc.arg(path), sqlc.narg(status), sqlc.arg(additions), sqlc.arg(deletions), sqlc.arg(changes), sqlc.narg(previous_path), sqlc.narg(patch), sqlc.arg(raw_json), sqlc.arg(fetched_at)); -- name: UpsertPullRequestCommit :execinsert into pull_request_commits(thread_id, sha, message, author_login, author_name, committed_at, html_url, raw_json, fetched_at, deleted_at, deletion_reason)values(sqlc.arg(thread_id), sqlc.arg(sha), sqlc.narg(message), sqlc.narg(author_login), sqlc.narg(author_name), sqlc.narg(committed_at), sqlc.narg(html_url), sqlc.arg(raw_json), sqlc.arg(fetched_at), sqlc.narg(deleted_at), sqlc.narg(deletion_reason))on conflict(thread_id, sha) do update set  message=excluded.message,  author_login=excluded.author_login,  author_name=excluded.author_name,  committed_at=excluded.committed_at,  html_url=excluded.html_url,  raw_json=excluded.raw_json,  fetched_at=excluded.fetched_at,  deleted_at=excluded.deleted_at,  deletion_reason=excluded.deletion_reason; -- name: DeletePullRequestChecks :execdelete from pull_request_checks where thread_id = sqlc.arg(thread_id); -- name: InsertPullRequestCheck :execinsert into pull_request_checks(thread_id, name, status, conclusion, details_url, workflow_name, started_at, completed_at, raw_json, fetched_at)values(sqlc.arg(thread_id), sqlc.arg(name), sqlc.narg(status), sqlc.narg(conclusion), sqlc.narg(details_url), sqlc.narg(workflow_name), sqlc.narg(started_at), sqlc.narg(completed_at), sqlc.arg(raw_json), sqlc.arg(fetched_at)); -- name: UpsertWorkflowRun :execinsert into github_workflow_runs(repo_id, run_id, run_number, head_branch, head_sha, status, conclusion, workflow_name, event, html_url, created_at_gh, updated_at_gh, raw_json, fetched_at)values(sqlc.arg(repo_id), sqlc.arg(run_id), sqlc.arg(run_number), sqlc.narg(head_branch), sqlc.narg(head_sha), sqlc.narg(status), sqlc.narg(conclusion), sqlc.narg(workflow_name), sqlc.narg(event), sqlc.narg(html_url), sqlc.narg(created_at_gh), sqlc.narg(updated_at_gh), sqlc.arg(raw_json), sqlc.arg(fetched_at))on conflict(repo_id, run_id) do update set  run_number=excluded.run_number,  head_branch=excluded.head_branch,  head_sha=excluded.head_sha,  status=excluded.status,  conclusion=excluded.conclusion,  workflow_name=excluded.workflow_name,  event=excluded.event,  html_url=excluded.html_url,  created_at_gh=excluded.created_at_gh,  updated_at_gh=excluded.updated_at_gh,  raw_json=excluded.raw_json,  fetched_at=excluded.fetched_at; -- name: PullRequestDetail :oneselect thread_id, repo_id, number, base_sha, head_sha, head_ref, head_repo_full_name, mergeable_state, additions, deletions, changed_files, raw_json, fetched_at, updated_atfrom pull_request_detailswhere repo_id = sqlc.arg(repo_id) and number = sqlc.arg(number); -- name: PullRequestFiles :manyselect thread_id, position, path, status, additions, deletions, changes, previous_path, patch, raw_json, fetched_atfrom pull_request_fileswhere thread_id = sqlc.arg(thread_id)order by path, position; -- name: PullRequestCommits :manyselect thread_id, sha, message, author_login, author_name, committed_at, html_url, raw_json, fetched_at, deleted_at, deletion_reasonfrom pull_request_commitswhere thread_id = sqlc.arg(thread_id)  and deleted_at is nullorder by rowid; -- name: PullRequestChecks :manyselect id, thread_id, name, status, conclusion, details_url, workflow_name, started_at, completed_at, raw_json, fetched_atfrom pull_request_checkswhere thread_id = sqlc.arg(thread_id)order by name; -- name: ListWorkflowRuns :manyselect repo_id, run_id, run_number, head_branch, head_sha, status, conclusion, workflow_name, event, html_url, created_at_gh, updated_at_gh, raw_json, fetched_atfrom github_workflow_runswhere repo_id = sqlc.arg(repo_id)  and (sqlc.narg(head_branch) is null or head_branch = sqlc.narg(head_branch))  and (sqlc.narg(head_sha) is null or head_sha = sqlc.narg(head_sha))order by updated_at_gh desc, run_id desclimit sqlc.arg(row_limit); -- name: UpsertPullRequestReviewThreadSync :execinsert into pull_request_review_thread_syncs(thread_id, fetched_at)values(sqlc.arg(thread_id), sqlc.arg(fetched_at))on conflict(thread_id) do update set fetched_at=excluded.fetched_at; -- name: UpsertPullRequestReviewThread :execinsert into pull_request_review_threads(  thread_id, review_thread_id, path, line, start_line, is_resolved, is_outdated,  viewer_can_resolve, viewer_can_unresolve, viewer_can_reply,  first_author_login, first_author_type, first_comment_body, first_comment_url,  first_comment_created_at, first_comment_updated_at, comments_json, raw_json, fetched_at,  deleted_at, deletion_reason)values(  sqlc.arg(thread_id), sqlc.arg(review_thread_id), sqlc.narg(path), sqlc.arg(line), sqlc.arg(start_line), sqlc.arg(is_resolved), sqlc.arg(is_outdated),  sqlc.arg(viewer_can_resolve), sqlc.arg(viewer_can_unresolve), sqlc.arg(viewer_can_reply),  sqlc.narg(first_author_login), sqlc.narg(first_author_type), sqlc.narg(first_comment_body), sqlc.narg(first_comment_url),  sqlc.narg(first_comment_created_at), sqlc.narg(first_comment_updated_at), sqlc.arg(comments_json), sqlc.arg(raw_json), sqlc.arg(fetched_at),  sqlc.narg(deleted_at), sqlc.narg(deletion_reason))on conflict(thread_id, review_thread_id) do update set  path=excluded.path,  line=excluded.line,  start_line=excluded.start_line,  is_resolved=excluded.is_resolved,  is_outdated=excluded.is_outdated,  viewer_can_resolve=excluded.viewer_can_resolve,  viewer_can_unresolve=excluded.viewer_can_unresolve,  viewer_can_reply=excluded.viewer_can_reply,  first_author_login=excluded.first_author_login,  first_author_type=excluded.first_author_type,  first_comment_body=excluded.first_comment_body,  first_comment_url=excluded.first_comment_url,  first_comment_created_at=excluded.first_comment_created_at,  first_comment_updated_at=excluded.first_comment_updated_at,  comments_json=excluded.comments_json,  raw_json=excluded.raw_json,  fetched_at=excluded.fetched_at,  deleted_at=excluded.deleted_at,  deletion_reason=excluded.deletion_reason; -- name: PullRequestReviewThreads :manyselect thread_id, review_thread_id, path, line, start_line, is_resolved, is_outdated,  viewer_can_resolve, viewer_can_unresolve, viewer_can_reply,  first_author_login, first_author_type, first_comment_body, first_comment_url,  first_comment_created_at, first_comment_updated_at, comments_json, raw_json, fetched_at,  deleted_at, deletion_reasonfrom pull_request_review_threadswhere thread_id = sqlc.arg(thread_id)  and deleted_at is nullorder by is_resolved, path, line, review_thread_id; -- name: PullRequestReviewThreadsFetchedAt :oneselect fetched_at from pull_request_review_thread_syncs where thread_id = sqlc.arg(thread_id);