async run()

in src/commands/collection/move-images.ts [21:88]
51 lines of code
12 McCabe index (conditional complexity)

  async run() {
    const { args } = await this.parse(CollectionMoveImages)

    const profile = this.profile!
    const http = this.http!

    const serviceDiscovery = await new ServiceDiscovery(http, profile.mediaApiHost).discover()
    const collectionsRoot = serviceDiscovery.getLink('collections')
    if (!collectionsRoot) {
      this.error('collections link not found', { exit: 1 })
    }

    // Make sure both from and to collections exist. This guards against casing issues,
    // as the search for collections is case-insensitive, and we might end up adding
    // images to collections that don't exist.
    const collections = await this.fetchCollections(collectionsRoot)
    const flattenedCollections = this.flattenCollections(collections.data)
    const collectionFrom = flattenedCollections.find((collection: any) => this.getCollectionPathStr(collection.data) === args.from)?.data
    const collectionTo = flattenedCollections.find((collection: any) => this.getCollectionPathStr(collection.data) === args.to)?.data
    if (!collectionFrom) {
      this.error(`Collection with path ${args.from} not found.`)
    }

    if (!collectionTo) {
      this.error(`Collection with path ${args.to} not found.`)
    }

    this.log(`Getting images in collection: ${this.getCollectionPathStr(collectionFrom)}`)

    // Fetch the images in the current collection.
    const pageSize = 30
    let images = [] as any
    let offset = 0
    let totalImages = 0

    while (offset === 0 || images.length < totalImages) {
      const results = await this.fetchImagesForCollection(collectionFrom, pageSize, offset)
      totalImages = results.total
      images = [...images, ...results.data]
      offset += pageSize
      this.log(`Fetched ${images.length} of ${totalImages} images`)
    }

    if (images.length === 0) {
      this.log(`No images found for collection: ${this.getCollectionPathStr(collectionFrom)}, stopping.`)
      return
    }

    // Add those images to the new collection
    for (const [index, image] of images.entries()) {
      this.log(`Adding image with id ${image.data.id} to collection: ${this.getCollectionPathStr(collectionTo)} (${index + 1} of ${images.length})`)
      const response: any = await this.addImageToCollection(collectionsRoot, collectionTo, image.data.id)
      if (response.errorKey) {
        this.error(`Error adding image ${image.data.id} to collection: ${this.getCollectionPathStr(collectionTo)} – response from API was ${response.errorMessage}`)
      }
    }

    // Remove those images from the old collection
    for (const [index, image] of images.entries()) {
      this.log(`Removing image with id ${image.data.id} from collection: ${this.getCollectionPathStr(collectionFrom)} (${index + 1} of ${images.length})`)
      const response: any = await this.removeImageFromCollection(collectionsRoot, collectionFrom, image.data.id)
      if (response.errorKey) {
        this.error(`Error removing image ${image.data.id} from collection: ${this.getCollectionPathStr(collectionFrom)} – response from API was ${response.errorMessage}`)
      }
    }

    this.log(`All images have been moved from collection: ${this.getCollectionPathStr(collectionFrom)} to collection: ${this.getCollectionPathStr(collectionTo)}`)
  }