Method plan

lib/deployer.go:182–237

plan figures out which files need to be uploaded.

(ctx context.Context)

// plan figures out which files need to be uploaded.
func (d *Deployer) plan(ctx context.Context) error {
	remoteFiles, err := d.store.FileMap(ctx)
	if err != nil {
		return err
	}
	d.printf("Found %d remote files\n", len(remoteFiles))

	// All local files at sourcePath
	localFiles := make(chan *osFile)
	d.g.Go(func() error {
		return d.walk(ctx, d.cfg.SourcePath, localFiles)
	})

	for f := range localFiles {
		// default: upload because local file not found on remote.
		up := true
		reason := reasonNotFound

		bucketPath := f.keyPath
		if d.cfg.BucketPath != "" {
			bucketPath = pathJoin(d.cfg.BucketPath, bucketPath)
		}

		if remoteFile, ok := remoteFiles[bucketPath]; ok {
			if d.cfg.Force {
				up = true
				reason = reasonForce
			} else {
				up, reason = f.shouldThisReplace(remoteFile)
			}
			// remove from map, whatever is leftover should be deleted:
			delete(remoteFiles, bucketPath)
		}

		f.reason = reason

		if up {
			d.enqueueUpload(ctx, f)
		} else {
			d.skipFile(f)
		}
	}
	close(d.filesToUpload)

	// any remote files not found locally should be removed:
	// except for ignored files
	for key := range remoteFiles {
		if d.cfg.shouldIgnoreRemote(key) {
			d.printf("%s ignored …\n", key)
			continue
		}
		d.enqueueDelete(key)
	}

	return nil
}

// walk a local directory