migration: fix files' URL on Windows (#132)

ariga · Jun 9, 2024 · 9aaee34 · 9aaee34
1 parent 547b653
commit 9aaee34
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/internal/provider/atlas_migration_data_source.go b/internal/provider/atlas_migration_data_source.go
@@ -144,7 +144,7 @@ func (d *MigrationDataSource) Read(ctx context.Context, req datasource.ReadReque
 		return
 	}
 	r, err := d.client.MigrateStatus(ctx, &atlas.MigrateStatusParams{
-		ConfigURL: fmt.Sprintf("file://%s", cfgPath),
+		ConfigURL: fmt.Sprintf("file://%s", filepath.ToSlash(cfgPath)),
 		Env:       "tf",
 	})
 	if err != nil {

diff --git a/internal/provider/atlas_migration_resource.go b/internal/provider/atlas_migration_resource.go
@@ -310,7 +310,7 @@ func (r *MigrationResource) ModifyPlan(ctx context.Context, req resource.ModifyP
 			return
 		}
 		report, err := r.client.MigrateStatus(ctx, &atlas.MigrateStatusParams{
-			ConfigURL: fmt.Sprintf("file://%s", cfgPath),
+			ConfigURL: fmt.Sprintf("file://%s", filepath.ToSlash(cfgPath)),
 			Env:       defaultString(plan.EnvName, "tf"),
 		})
 		if err != nil {
@@ -339,7 +339,7 @@ func (r *MigrationResource) ModifyPlan(ctx context.Context, req resource.ModifyP
 			return
 		}
 		lint, err := r.client.MigrateLint(ctx, &atlas.MigrateLintParams{
-			ConfigURL: fmt.Sprintf("file://%s", cfgPath),
+			ConfigURL: fmt.Sprintf("file://%s", filepath.ToSlash(cfgPath)),
 			Env:       defaultString(plan.EnvName, "tf"),
 			Latest:    pendingCount,
 		})
@@ -383,7 +383,7 @@ func (r *MigrationResource) migrate(ctx context.Context, data *MigrationResource
 		return
 	}
 	statusReport, err := r.client.MigrateStatus(ctx, &atlas.MigrateStatusParams{
-		ConfigURL: fmt.Sprintf("file://%s", cfgPath),
+		ConfigURL: fmt.Sprintf("file://%s", filepath.ToSlash(cfgPath)),
 		Env:       defaultString(data.EnvName, "tf"),
 	})
 	if err != nil {
@@ -401,7 +401,7 @@ func (r *MigrationResource) migrate(ctx context.Context, data *MigrationResource
 			return
 		}
 		_, err := r.client.MigrateApply(ctx, &atlas.MigrateApplyParams{
-			ConfigURL: fmt.Sprintf("file://%s", cfgPath),
+			ConfigURL: fmt.Sprintf("file://%s", filepath.ToSlash(cfgPath)),
 			Env:       defaultString(data.EnvName, "tf"),
 			Amount:    amount,
 			Context: &atlas.DeployRunContext{
@@ -434,7 +434,7 @@ func (r *MigrationResource) buildStatus(ctx context.Context, data *MigrationReso
 		return
 	}
 	report, err := r.client.MigrateStatus(ctx, &atlas.MigrateStatusParams{
-		ConfigURL: fmt.Sprintf("file://%s", cfgPath),
+		ConfigURL: fmt.Sprintf("file://%s", filepath.ToSlash(cfgPath)),
 		Env:       defaultString(data.EnvName, "tf"),
 	})
 	if err != nil {