Function RunImport

apps/cli/internal/sync/import_engine.go:41–73

RunImport fetches tasks from an external source and writes them as local task files. Unlike RunSync, it performs no state tracking — it is a one-shot operation that detects duplicates via external_id in existing task files.

(cfg ImportConfig)

// task files. Unlike RunSync, it performs no state tracking — it is a one-shot
// operation that detects duplicates via external_id in existing task files.
func RunImport(cfg ImportConfig) (*ImportResult, error) {
	externalTasks, err := fetchImportTasks(cfg)
	if err != nil {
		return nil, err
	}

	existingIDs, externalIDs, err := scanExistingTasks(cfg.ScanDir, cfg.Verbose)
	if err != nil {
		return nil, fmt.Errorf("failed to scan existing tasks: %w", err)
	}

	fieldMap := resolveImportFieldMap(cfg.SourceName, cfg.SourceCfg.FieldMap)
	result := &ImportResult{}

	for _, ext := range externalTasks {
		action, ids := importTask(ext, cfg, fieldMap, existingIDs, externalIDs)
		existingIDs = ids

		switch action.Reason {
		case "skipped_duplicate":
			result.Skipped = append(result.Skipped, action.ImportAction)
		case "error":
			result.Errors = append(result.Errors, SyncError{
				ExternalID: ext.ExternalID, Title: ext.Title, Err: action.err,
			})
		default:
			result.Created = append(result.Created, action.ImportAction)
			externalIDs[ext.ExternalID] = true
		}
	}

	return result, nil
}

func fetchImportTasks(cfg ImportConfig) ([]ExternalTask, error) {
	src, err := GetSource(cfg.SourceName)