Function BatchImport

internal/run.go:19–148

(ctx context.Context, cfg config.NonInteractiveModeConfig)

)

func BatchImport(ctx context.Context, cfg config.NonInteractiveModeConfig) error {
	var c meta.Meta = internalmeta.NewGroupMetaDummy(cfg.ResourceGroupName, cfg.ProviderName)
	if !cfg.MockMeta {
		var err error
		c, err = meta.NewMeta(cfg.Config)
		if err != nil {
			return err
		}
	}

	var errors []string

	f := func(msg Messager) error {
		msg.SetStatus("Initializing...")
		if err := c.Init(ctx); err != nil {
			return err
		}

		defer func() {
			msg.SetStatus("DeInitializing...")
			// #nosec G104
			c.DeInit(ctx)
		}()

		msg.SetStatus("Listing resources...")
		list, err := c.ListResource(ctx)
		if err != nil {
			return err
		}

		msg.SetStatus("Exporting Skipped Resource file...")
		if err := c.WriteSkippedResources(ctx, list); err != nil {
			return fmt.Errorf("exporting Skipped Resource file: %v", err)
		}

		msg.SetStatus("Exporting Resource Mapping file...")
		if err := c.WriteResourceMapping(ctx, list); err != nil {
			return fmt.Errorf("exporting Resource Mapping file: %v", err)
		}

		if len(list.NonSkipped()) == 0 {
			return fmt.Errorf("no resource found")
		}

		// Return early if only generating mapping file
		if cfg.GenMappingFileOnly {
			return nil
		}

		for i := 0; i < len(list); i += cfg.Parallelism {
			n := cfg.Parallelism
			if i+cfg.Parallelism > len(list) {
				n = len(list) - i
			}

			var importList []*meta.ImportItem
			messages := []string{"Importing resources..."}