ftp

Documentation

Index

• Variables

Variables

var FTPSyncCmd = &cobra.Command{
	Use:          "sync <localdir> <ftpurl>",
	Short:        "sync ICE's FTP directory to a local path",
	SilenceUsage: true,
	RunE: func(cmd *cobra.Command, args []string) error {
		if len(args) != 2 || args[0] == "" || args[1] == "" {
			return cmd.Help()
		}

		dataDir := args[0]
		rawFtpURL := args[1]
		ftpURL, err := url.Parse(rawFtpURL)
		if err != nil {
			log.Error("Please provide a valid url!")
			return err
		}

		if err := os.MkdirAll(dataDir, 0777); err != nil {
			log.Error("Cannot create local storage directory: %+v", err)
			return err
		}

		password, ok := ftpURL.User.Password()
		if !ok {
			log.Error("Please provide a password in the FTP url!")
			return err
		}
		client, err := ftp.NewClient(ftpURL.User.Username(), password, ftpURL.Host)
		if err != nil {
			log.Error("Unable to connect to ICE: %+v", err)
			return err
		}
		defer func() { client.Close() }()

		log.Info("Succesfully connected to ICE: %+v", ftpURL)

		reorgLoader := ftp.NewDownloader(client, ftpURL.Path, dataDir, enum.ReorgFilePrefix)
		newFiles, err := reorgLoader.Sync()
		if err != nil {
			log.Error("Error occurred while downloading files: %+v", err)
			return err
		}
		log.Info("New reorg files downloaded: %+v", newFiles)

		sirsLoader := ftp.NewDownloader(client, ftpURL.Path, dataDir, enum.SirsFilePrefix)
		newFiles, err = sirsLoader.Sync()
		if err != nil {
			log.Error("Error occurred while downloading files: %+v", err)
			return err
		}
		log.Info("New sirs files downloaded: %+v", newFiles)

		return nil
	},
}

FTPSyncCmd downloads reorg and sirs files from ICE's ftp directory to a local path