Method importSubscribers

controller/system/import.go:417–454

(ctx context.Context)

}

func (i *imlImportConfigController) importSubscribers(ctx context.Context) error {

	applyData, err := unmarshal[subscribe_dto.ExportApproval]("apply")
	if err != nil {
		return err
	}
	for _, d := range applyData {
		err = i.catalogueModule.Subscribe(ctx, &catalogue_dto.SubscribeService{
			Service: d.Service,
			Applications: []string{
				d.Application,
			},
			Reason: d.Reason,
		})
		if err != nil {
			return fmt.Errorf("application(%s) subscribe service(%s) error: %v", d.Application, d.Service, err)
		}
	}
	data, err := unmarshal[subscribe_dto.ExportSubscriber]("subscribe")
	if err != nil {
		return err
	}
	for _, d := range data {
		err = i.subscribeModule.ExistSubscriber(ctx, d.Service, d.Subscriber)
		if err == nil {
			continue
		}
		err = i.subscribeModule.AddSubscriber(ctx, d.Service, &subscribe_dto.AddSubscriber{
			Application: d.Subscriber,
		})
		if err != nil {
			return fmt.Errorf("update subscriber(%s) error: %v", d.Id, err)
		}

	}

	return nil
}