Function MigrateEntityStorage

internal/entities/store.go:202–243

MigrateEntityStorage migrates legacy prompt entities to instruction storage idempotently. It reads prompts.json, converts each entity's Kind from "prompt" to "instruction", and writes them to instructions.json. The prompts.json file is left untouched. If instructions.json already exists or prompts.j

()

// prompts.json file is left untouched. If instructions.json already exists or
// prompts.json does not exist, no migration is performed.
func MigrateEntityStorage() error {
	dir := pathutil.ConfigDir()
	oldPath := filepath.Join(dir, "prompts.json")
	newPath := filepath.Join(dir, "instructions.json")

	if _, err := os.Stat(newPath); err == nil {
		return nil
	}

	raw, err := os.ReadFile(oldPath)
	if err != nil {
		if os.IsNotExist(err) {
			return nil
		}
		return fmt.Errorf("entities: read %s: %w", oldPath, err)
	}
	if len(raw) == 0 {
		return nil
	}

	entitiesByName := map[string]Entity{}
	if err := json.Unmarshal(raw, &entitiesByName); err != nil {
		return fmt.Errorf("entities: parse %s: %w", oldPath, err)
	}
	for name, entity := range entitiesByName {
		entity.Kind = KindInstruction
		entitiesByName[name] = entity
	}

	if err := os.MkdirAll(dir, 0o755); err != nil {
		return fmt.Errorf("entities: mkdir %s: %w", dir, err)
	}
	data, err := json.MarshalIndent(entitiesByName, "", "  ")
	if err != nil {
		return fmt.Errorf("entities: marshal migrated instructions: %w", err)
	}
	data = append(data, '\n')
	if err := os.WriteFile(newPath, data, 0o600); err != nil {
		return fmt.Errorf("entities: write %s: %w", newPath, err)
	}
	return nil
}