feat: add cobra cli with run and version commands

Author: mujib77

cmd/root.go

@@ -0,0 +1,23 @@
+package cmd
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/spf13/cobra"
+)
+
+var rootCmd = &cobra.Command{
+	Use: "rift",
+	Short: "Rift - a production ready PostgreSQL CDC pipeline",
+	Long: `Rift streams PostgreSQL changes (INSERT/UPDATE/DELETE/DDL) to webhooks, Postgres, and redis destinations using logical replication.
+	
+	Single binary. Single config. No kafka required.`,
+}
+
+func Execute() {
+	if err := rootCmd.Execute(); err != nil {
+		fmt.Println(err)
+		os.Exit(1)
+	}
+}

cmd/run.go

@@ -0,0 +1,53 @@
+package cmd
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"os/signal"
+
+	"github.com/mujib77/rift/internal/config"
+	"github.com/mujib77/rift/internal/engine"
+	"github.com/spf13/cobra"
+)
+
+var configPath string
+
+var runCmd = &cobra.Command{
+	Use:   "run",
+	Short: "Start the Rift CDC pipeline",
+	Run: func(cmd *cobra.Command, args []string) {
+		cfg, err := config.Load(configPath)
+		if err != nil {
+			fmt.Println("error loading config:", err)
+			os.Exit(1)
+		}
+
+		ctx, cancel := context.WithCancel(context.Background())
+		defer cancel()
+
+		go func() {
+			sig := make(chan os.Signal, 1)
+			signal.Notify(sig, os.Interrupt)
+			<-sig
+			fmt.Println("\n  signal received, shutting down...")
+			cancel()
+		}()
+
+		eng, err := engine.New(cfg)
+		if err != nil {
+			fmt.Println("error creating engine:", err)
+			os.Exit(1)
+		}
+
+		if err := eng.Start(ctx); err != nil {
+			fmt.Println("error:", err)
+			os.Exit(1)
+		}
+	},
+}
+
+func init() {
+	runCmd.Flags().StringVarP(&configPath, "config", "c", "rift.yaml", "path to config file")
+	rootCmd.AddCommand(runCmd)
+}

cmd/version.go

@@ -0,0 +1,24 @@
+package  cmd
+
+import (
+	"fmt"
+
+	"github.com/spf13/cobra"
+)
+
+var (
+	version = "dev"
+	commit = "none"
+)
+
+var versionCmd = &cobra.Command{
+	Use:   "version",
+	Short: "Print the version number of Rift",
+	Run: func(cmd *cobra.Command, args []string) {
+		fmt.Printf("rift version %s (%s)\n", version, commit)
+	},
+}
+
+func init() {
+	rootCmd.AddCommand(versionCmd)
+}