| 375 | } |
| 376 | |
| 377 | func (i *imlImportConfigController) publish(ctx context.Context) error { |
| 378 | data, err := unmarshal[service_dto.ExportService]("service") |
| 379 | if err != nil { |
| 380 | return err |
| 381 | } |
| 382 | for _, d := range data { |
| 383 | serviceId := d.Id |
| 384 | newReleaseId, err := i.releaseModule.Create(ctx, serviceId, &dto2.CreateInput{ |
| 385 | Version: "v1", |
| 386 | Remark: "demo release", |
| 387 | }) |
| 388 | if err != nil { |
| 389 | continue |
| 390 | } |
| 391 | apply, err := i.publishModule.Apply(ctx, serviceId, &dto.ApplyInput{ |
| 392 | Release: newReleaseId, |
| 393 | Remark: "发布申请", |
| 394 | }) |
| 395 | if err != nil { |
| 396 | return err |
| 397 | } |
| 398 | err = i.publishModule.Accept(ctx, serviceId, apply.Id, "") |
| 399 | if err != nil { |
| 400 | i.releaseModule.Delete(ctx, serviceId, newReleaseId) |
| 401 | return err |
| 402 | } |
| 403 | err = i.publishModule.Publish(ctx, serviceId, apply.Id) |
| 404 | if err != nil { |
| 405 | i.releaseModule.Delete(ctx, serviceId, newReleaseId) |
| 406 | return err |
| 407 | } |
| 408 | err = i.publishModule.Publish(ctx, serviceId, apply.Id) |
| 409 | if err != nil { |
| 410 | i.releaseModule.Delete(ctx, serviceId, newReleaseId) |
| 411 | return err |
| 412 | } |
| 413 | } |
| 414 | return nil |
| 415 | } |
| 416 | |
| 417 | func (i *imlImportConfigController) importSubscribers(ctx context.Context) error { |
| 418 | |