Method RunSync

apps/cli/internal/sync/engine.go:54–113

RunSync syncs tasks for a single source configuration.

(srcCfg SourceConfig)

// RunSync syncs tasks for a single source configuration.
func (e *Engine) RunSync(srcCfg SourceConfig) (*SyncResult, error) {
	src, err := GetSource(srcCfg.Name)
	if err != nil {
		return nil, err
	}

	if err := src.ValidateConfig(srcCfg); err != nil {
		return nil, fmt.Errorf("invalid config for source %q: %w", srcCfg.Name, err)
	}

	externalTasks, err := src.FetchTasks(srcCfg)
	if err != nil {
		return nil, fmt.Errorf("failed to fetch tasks from %q: %w", srcCfg.Name, err)
	}

	state, err := LoadState(e.ConfigDir, srcCfg.Name)
	if err != nil {
		return nil, fmt.Errorf("failed to load state: %w", err)
	}

	existingIDs, err := e.scanExistingIDs(srcCfg.OutputDir)
	if err != nil {
		return nil, fmt.Errorf("failed to scan existing tasks: %w", err)
	}

	result := &SyncResult{}
	now := time.Now()

	for _, ext := range externalTasks {
		action, syncErr := e.syncTask(ext, srcCfg, state, existingIDs, now)
		if syncErr != nil {
			result.Errors = append(result.Errors, SyncError{
				ExternalID: ext.ExternalID,
				Title:      ext.Title,
				Err:        syncErr,
			})
			continue
		}
		switch action.Reason {
		case "created":
			result.Created = append(result.Created, action)
			existingIDs = append(existingIDs, action.LocalID)
		case "updated":
			result.Updated = append(result.Updated, action)
		case "conflict":
			result.Conflicts = append(result.Conflicts, action)
		default:
			result.Skipped = append(result.Skipped, action)
		}
	}

	if !e.DryRun {
		state.LastSync = now
		if err := SaveState(e.ConfigDir, srcCfg.Name, state); err != nil {
			return result, fmt.Errorf("failed to save state: %w", err)
		}
	}