Function cleanLeftoversIO

packages/migrate/src/views/handleViewsIO.ts:99–131

* - Delete every *.sql file in the subfolders of viewsDir * - Delete any empty subfolders * - Delete viewsDir if it is empty

(viewsDir: string, viewFilesToKeep: string[] = [])

 * - Delete viewsDir if it is empty
 */
async function cleanLeftoversIO(viewsDir: string, viewFilesToKeep: string[] = []): Promise<void> {
  const pipeline = pipe(
    // remove any SQL files in the views directory beyond the ones just created, concurrently, collapsing the possible errors
    fsFunctional.getFilesInDir(viewsDir, '**/*/*.sql'),
    T.chain((filesInViewsDir) => {
      const viewFilesToRemove = filesInViewsDir.filter((file) => !viewFilesToKeep.includes(file))
      return TE.traverseArray(fsFunctional.removeFile)(viewFilesToRemove)
    }),

    // remove any empty directories in the views directory, recursively
    TE.chainW(() => fsFunctional.removeEmptyDirs(viewsDir)),
  )

  const either = await pipeline()

  if (E.isRight(either)) {
    return
  }

  // failure: check which error to throw
  const error = match(either.left)
    .with({ type: 'fs-remove-empty-dirs' }, (e) => {
      throw new Error(`Error removing empty directories in: ${e.meta.dir}.\n${e.error}.`)
    })
    .with({ type: 'fs-remove-file' }, (e) => {
      throw new Error(`Error removing the file: ${e.meta.filePath}.\n${e.error}.`)
    })
    .exhaustive()
  // We execute the cleanup and ignore the possible errors
  await pipeline()

  throw error
}