quickstart

var Cmd = &cobra.Command{
	Use:   "quickstart",
	Short: "Quickstart operations",
	Long:  "Helpers for docker-compose based quickstart setup. Should not be used in production systems.",
}

var Cron = &cobra.Command{
	Use:   "cron",
	Short: "Schedule the required cron jobs in the background.",
	RunE: func(cmd *cobra.Command, args []string) error {
		s, err := gocron.NewScheduler(
			gocron.WithLogger(slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
				Level: slog.LevelInfo,
			}))),
		)
		if err != nil {
			return err
		}

		namespaces := []string{"default"}
		batchSize := 10

		_, err = s.NewJob(
			gocron.DurationJob(time.Hour),
			gocron.NewTask(func() {
				slog.Info("Syncing subscriptions")

				err := internal.App.BillingSubscriptionReconciler.All(cmd.Context(), reconciler.ReconcilerAllInput{
					ReconcilerListSubscriptionsInput: reconciler.ReconcilerListSubscriptionsInput{
						Namespaces: namespaces,
						Lookback:   time.Hour,
					},
					Force: false,
				})
				if err != nil {
					slog.Error("Error syncing subscriptions", "error", err)
				}
			}),
		)
		if err != nil {
			return err
		}

		_, err = s.NewJob(
			gocron.DurationJob(time.Minute),
			gocron.NewTask(func() {
				slog.Info("Collecting invoices")

				err := internal.App.BillingCollector.All(cmd.Context(), namespaces, nil, batchSize)
				if err != nil {
					slog.Error("Error collecting invoices", "error", err)
				}
			}),
		)
		if err != nil {
			return err
		}

		_, err = s.NewJob(
			gocron.DurationJob(time.Minute),
			gocron.NewTask(func() {
				slog.Info("Advancing invoices")

				err := internal.App.BillingAutoAdvancer.All(cmd.Context(), namespaces, batchSize)
				if err != nil {
					slog.Error("Error advancing invoices", "error", err)
				}
			}),
		)
		if err != nil {
			return err
		}

		if internal.App.ChargesAutoAdvancer != nil {
			_, err = s.NewJob(
				gocron.DurationJob(time.Minute),
				gocron.NewTask(func() {
					slog.Info("Advancing charges")

					err := internal.App.ChargesAutoAdvancer.All(cmd.Context(), namespaces)
					if err != nil {
						slog.Error("Error advancing charges", "error", err)
					}
				}),
			)
			if err != nil {
				return err
			}
		}

		s.Start()

		<-cmd.Context().Done()
		if err := s.Shutdown(); err != nil {
			return err
		}

		return nil
	},
}