-- NOTE: This file is auto generated by ./sql-generator

-- IntegrityRepository.getById
select
  "integrity_report".*
from
  "integrity_report"
where
  "id" = $1

-- IntegrityRepository.getIntegrityReportSummary
select
  "type",
  count(*) as "count"
from
  "integrity_report"
group by
  "type"

-- IntegrityRepository.getIntegrityReports
select
  "id",
  "type",
  "path",
  "assetId",
  "fileAssetId",
  "createdAt"
from
  "integrity_report"
where
  "type" = $1
  and "id" <= $2
order by
  "id" desc
limit
  $3

-- IntegrityRepository.getAssetPathsByPaths
select
  "originalPath",
  "encodedVideoPath"
from
  "asset"
where
  (
    "originalPath" in $1
    or "encodedVideoPath" in $2
  )

-- IntegrityRepository.getAssetFilePathsByPaths
select
  "path"
from
  "asset_file"
where
  "path" in $1

-- IntegrityRepository.getAssetCount
select
  count(*) as "count"
from
  "asset"

-- IntegrityRepository.streamAllAssetPaths
select
  "originalPath",
  "encodedVideoPath"
from
  "asset"

-- IntegrityRepository.streamAllAssetFilePaths
select
  "path"
from
  "asset_file"

-- IntegrityRepository.streamAssetPaths
select
  "allPaths"."path" as "path",
  "allPaths"."assetId",
  "allPaths"."fileAssetId",
  "integrity_report"."id" as "reportId"
from
  (
    select
      "asset"."originalPath" as "path",
      "asset"."id" as "assetId",
      null::uuid as "fileAssetId"
    from
      "asset"
    where
      "asset"."deletedAt" is null
    union all
    select
      "asset"."encodedVideoPath" as "path",
      "asset"."id" as "assetId",
      null::uuid as "fileAssetId"
    from
      "asset"
    where
      "asset"."deletedAt" is null
      and "asset"."encodedVideoPath" is not null
      and "asset"."encodedVideoPath" != ''
    union all
    select
      "path",
      null::uuid as "assetId",
      "asset_file"."id" as "fileAssetId"
    from
      "asset_file"
  ) as "allPaths"
  left join "integrity_report" on "integrity_report"."type" = $1
  and (
    "integrity_report"."assetId" = "allPaths"."assetId"
    or "integrity_report"."fileAssetId" = "allPaths"."fileAssetId"
  )

-- IntegrityRepository.streamAssetChecksums
select
  "asset"."originalPath",
  "asset"."checksum",
  "asset"."createdAt",
  "asset"."id" as "assetId",
  "integrity_report"."id" as "reportId"
from
  "asset"
  left join "integrity_report" on "integrity_report"."assetId" = "asset"."id"
  and "integrity_report"."type" = $1
where
  "asset"."deletedAt" is null
  and "createdAt" >= $2
  and "createdAt" <= $3
order by
  "createdAt" asc

-- IntegrityRepository.streamIntegrityReports
select
  "id",
  "type",
  "path",
  "assetId",
  "fileAssetId"
from
  "integrity_report"
where
  "type" = $1
order by
  "createdAt" desc

-- IntegrityRepository.streamIntegrityReportsWithAssetChecksum
select
  "integrity_report"."id" as "reportId",
  "integrity_report"."path"
from
  "integrity_report"
where
  "integrity_report"."type" = $1

-- IntegrityRepository.streamIntegrityReportsByProperty
select
  "id",
  "path",
  "assetId",
  "fileAssetId"
from
  "integrity_report"
where
  "abcdefghi" is not null

-- IntegrityRepository.deleteById
delete from "integrity_report"
where
  "id" = $1

-- IntegrityRepository.deleteByIds
delete from "integrity_report"
where
  "id" in $1