Method Execute

internal/deletion/executor.go:218–277

Execute performs the deletion for a manifest.

(ctx context.Context, manifestID string, opts *ExecuteOptions)

// Execute performs the deletion for a manifest.
func (e *Executor) Execute(ctx context.Context, manifestID string, opts *ExecuteOptions) error {
	if opts == nil {
		opts = DefaultExecuteOptions()
	}

	manifest, path, err := e.prepareExecution(manifestID, opts.Method)
	if err != nil {
		return err
	}

	// Determine starting point
	startIndex := 0
	if opts.Resume && manifest.Execution != nil {
		startIndex = manifest.Execution.LastProcessedIndex
	}

	e.logger.Debug("executing deletion",
		"manifest", manifestID,
		"total", len(manifest.GmailIDs),
		"start_index", startIndex,
		"method", opts.Method,
	)

	e.progress.OnStart(len(manifest.GmailIDs), startIndex)

	// Execute deletions
	succeeded := manifest.Execution.Succeeded
	failed := manifest.Execution.Failed
	failedIDs := manifest.Execution.FailedIDs

	for i := startIndex; i < len(manifest.GmailIDs); i++ {
		select {
		case <-ctx.Done():
			e.saveCheckpoint(manifest, path, i, succeeded, failed, failedIDs)
			return ctx.Err()
		default:
		}

		result, delErr := e.deleteOne(ctx, manifest.GmailIDs[i], opts.Method)
		switch result {
		case resultSuccess:
			succeeded++
		case resultFatal:
			e.saveCheckpoint(manifest, path, i, succeeded, failed, failedIDs)
			return fmt.Errorf("delete message: %w", delErr)
		case resultFailed:
			failed++
			failedIDs = append(failedIDs, manifest.GmailIDs[i])
		}

		// Save checkpoint periodically
		if (i+1)%opts.BatchSize == 0 {
			e.saveCheckpoint(manifest, path, i+1, succeeded, failed, failedIDs)
			e.progress.OnProgress(i+1, succeeded, failed)
		}
	}

	e.finalizeExecution(manifestID, manifest, path, succeeded, failed, failedIDs, true)