From a056bed0e03b0cc5abfcf1414731376fe560b06f Mon Sep 17 00:00:00 2001
From: Jason Cameron <git@jasoncameron.dev>
Date: Sun, 3 Nov 2024 00:57:25 -0400
Subject: [PATCH] Rewrite ;)

Signed-off-by: Jason Cameron <git@jasoncameron.dev>
---
 .idea/discord.xml         |   2 +-
 cmd/main.go               | 163 ++++++++++++++++++++++++++
 compression/compressor.go |  86 ++++++++++++++
 config.toml               |  40 +++++++
 config/config.go          |  72 ++++++++++++
 go.mod                    |  37 +++---
 go.sum                    |  74 ++++++------
 handlers/filesystem.go    | 114 ++++++++++++++++++
 handlers/handler.go       |   7 ++
 handlers/mysql.go         |  41 +++++++
 main.go                   | 238 --------------------------------------
 storage/s3.go             | 186 +++++++++++++++++++++++++++++
 12 files changed, 770 insertions(+), 290 deletions(-)
 create mode 100644 cmd/main.go
 create mode 100644 compression/compressor.go
 create mode 100644 config.toml
 create mode 100644 config/config.go
 create mode 100644 handlers/filesystem.go
 create mode 100644 handlers/handler.go
 create mode 100644 handlers/mysql.go
 delete mode 100644 main.go
 create mode 100644 storage/s3.go

diff --git a/.idea/discord.xml b/.idea/discord.xml
index 104c42f..912db82 100644
--- a/.idea/discord.xml
+++ b/.idea/discord.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="DiscordProjectSettings">
-    <option name="show" value="ASK" />
+    <option name="show" value="PROJECT_FILES" />
     <option name="description" value="" />
     <option name="applicationTheme" value="default" />
     <option name="iconsTheme" value="default" />
diff --git a/cmd/main.go b/cmd/main.go
new file mode 100644
index 0000000..e38fd78
--- /dev/null
+++ b/cmd/main.go
@@ -0,0 +1,163 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"github.com/mcpt/Sentinel/compression"
+	"log"
+	"os"
+	"os/signal"
+	"path/filepath"
+	"sync"
+	"syscall"
+
+	"github.com/mcpt/Sentinel/config"
+	"github.com/mcpt/Sentinel/handlers"
+	"github.com/mcpt/Sentinel/storage"
+	"github.com/robfig/cron/v3"
+)
+
+func main() {
+	configFile := flag.String("config", "config.toml", "Path to configuration file")
+	flag.Parse()
+
+	// Load configuration
+	err := config.Load(*configFile)
+	if err != nil {
+		log.Fatalf("Failed to load configuration: %v", err)
+	}
+
+	// Initialize backup handlers
+	var backupHandlers []handlers.BackupHandler
+
+	// MySQL handler
+	if config.Cfg.MySQL.Enabled {
+		mysqlHandler, err := handlers.NewMySQLHandler()
+		if err != nil {
+			log.Fatalf("Failed to initialize MySQL handler: %v", err)
+		}
+		backupHandlers = append(backupHandlers, mysqlHandler)
+	}
+
+	// Filesystem handler
+	if config.Cfg.Filesystem.Enabled {
+		fsHandler, err := handlers.NewFileSystemHandler()
+		if err != nil {
+			log.Fatalf("Failed to initialize filesystem handler: %v", err)
+		}
+		backupHandlers = append(backupHandlers, fsHandler)
+	}
+
+	// Initialize S3 uploader
+	s3Uploader, err := storage.NewS3Uploader()
+	if err != nil {
+		log.Fatalf("Failed to initialize S3 uploader: %v", err)
+	}
+
+	// Create cron scheduler
+	// If the schedule is empty, don't schedule the backup, just run it immediately
+	if config.Cfg.Schedule == "" {
+		if err := performBackup(backupHandlers, s3Uploader); err != nil {
+			log.Fatalf("Backup failed: %v", err)
+		}
+		return
+	} else {
+		c := cron.New()
+		_, err = c.AddFunc(config.Cfg.Schedule, func() {
+			if err := performBackup(backupHandlers, s3Uploader); err != nil {
+				log.Printf("Backup failed: %v", err)
+			}
+		})
+		if err != nil {
+			log.Fatalf("Failed to schedule backup: %v", err)
+		}
+
+		// Start cron scheduler
+		c.Start()
+		log.Printf("Backup system started with schedule: %s", config.Cfg.Schedule)
+
+		// Handle shutdown gracefully
+		sigChan := make(chan os.Signal, 1)
+		signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
+		<-sigChan
+
+		c.Stop()
+	}
+}
+
+func performBackup(handlerList []handlers.BackupHandler, uploader *storage.S3Uploader) error {
+	ctx := context.Background()
+	var backupFiles []string
+	var wg sync.WaitGroup
+	var mu sync.Mutex
+	errors := make(chan error, len(handlerList))
+
+	backupPath := filepath.Join(config.Cfg.TempDir, "backup")
+
+	// Create temporary backup directory
+	if err := os.MkdirAll(config.Cfg.TempDir, 0755); err != nil {
+		return err
+	}
+	defer func(path string) {
+		err := os.RemoveAll(path)
+		if err != nil {
+			log.Printf("Failed to remove temporary backup directory: %v", err)
+		}
+	}(config.Cfg.TempDir)
+
+	// Perform backups concurrently
+	for _, h := range handlerList {
+		wg.Add(1)
+		go func(handler handlers.BackupHandler) {
+			defer wg.Done()
+
+			backupFile, err := handler.Backup(ctx)
+			if err != nil {
+				errors <- err
+				return
+			}
+
+			mu.Lock()
+			backupFiles = append(backupFiles, backupFile)
+			mu.Unlock()
+		}(h)
+	}
+
+	wg.Wait()
+	close(errors)
+
+	for err := range errors {
+		if err != nil {
+			return err
+		}
+	}
+
+	// Create final archive
+	compressor, err := compression.NewCompressor(config.Cfg.Compression.Format, config.Cfg.Compression.Level)
+	if err != nil {
+		return err
+	}
+	err = compressor.Compress(backupFiles, backupPath)
+	if err != nil {
+		return err
+	}
+
+	// Upload final archive
+	if err := uploader.UploadDirectory(ctx, backupPath, ""); err != nil {
+		return err
+	}
+
+	// Cleanup
+	for _, file := range backupFiles {
+		err := os.Remove(file)
+		if err != nil {
+			return err
+		}
+	}
+	err = os.RemoveAll(backupPath)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
diff --git a/compression/compressor.go b/compression/compressor.go
new file mode 100644
index 0000000..ae4488c
--- /dev/null
+++ b/compression/compressor.go
@@ -0,0 +1,86 @@
+package compression
+
+import (
+	"compress/gzip"
+	"compress/zlib"
+	"fmt"
+	"io"
+	"os"
+)
+
+type Compressor interface {
+	Compress(src []string, dst string) error
+}
+
+type ZlibCompressor struct {
+	level int // 1-9 see https://pkg.go.dev/compress/flate#pkg-constants
+}
+type GzipCompressor struct{}
+
+func NewCompressor(format string, level int) (Compressor, error) {
+	switch format {
+	case "zlib":
+		return &ZlibCompressor{level: level}, nil
+	case "gzip":
+		return &GzipCompressor{}, nil
+	default:
+		return nil, fmt.Errorf("unsupported compression format: %s", format)
+	}
+}
+
+func (c *ZlibCompressor) Compress(src []string, dst string) error {
+	f, err := os.Create(dst)
+	if err != nil {
+		return err
+	}
+	defer f.Close()
+
+	zw, err := zlib.NewWriterLevel(f, c.level)
+	if err != nil {
+		return err
+	}
+	defer zw.Close()
+
+	for _, file := range src {
+		f, err := os.Open(file)
+		if err != nil {
+			return err
+		}
+		defer f.Close()
+
+		_, err = io.Copy(zw, f)
+		if err != nil {
+			return err
+		}
+	}
+	err = zw.Flush()
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
+func (c *GzipCompressor) Compress(src []string, dst string) error {
+	f, err := os.Create(dst)
+	if err != nil {
+		return err
+	}
+	defer f.Close()
+
+	gw := gzip.NewWriter(f)
+	defer gw.Close()
+
+	for _, file := range src {
+		f, err := os.Open(file)
+		if err != nil {
+			return err
+		}
+		defer f.Close()
+
+		_, err = io.Copy(gw, f)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
diff --git a/config.toml b/config.toml
new file mode 100644
index 0000000..cabe3ea
--- /dev/null
+++ b/config.toml
@@ -0,0 +1,40 @@
+# Backup system configuration
+#schedule = "0 4 * * *"  # Daily at 4 AM
+temp_dir = "/tmp/backups"
+
+[compression]
+format = "zlib"  # or "gzip"
+level = 3        # Compression level (1-9)
+
+[mysql]
+enabled = true
+host = "localhost"
+port = "3306"
+user = "backup_user"
+password = "backup_password"
+database = "myapp"
+
+[filesystem]
+enabled = true
+base_path = "/var/www/myapp"
+include_patterns = [
+    "*.txt",
+    "*.pdf",
+    "config/**",
+    "data/**"
+]
+exclude_patterns = [
+    ".git/**",
+    "node_modules/**",
+    "tmp/**",
+    "*.tmp"
+]
+
+[s3]
+endpoint = "https://s3.amazonaws.com"
+region = "us-east-1"
+bucket = "my-backup-bucket"
+access_key_id = "your_access_key"
+secret_access_key = "your_secret_key"
+max_concurrency = 10
+part_size=0
\ No newline at end of file
diff --git a/config/config.go b/config/config.go
new file mode 100644
index 0000000..8efb14f
--- /dev/null
+++ b/config/config.go
@@ -0,0 +1,72 @@
+package config
+
+import (
+	"fmt"
+	"os"
+
+	"github.com/BurntSushi/toml"
+)
+
+type Config struct {
+	Schedule    string `toml:"schedule"`
+	TempDir     string `toml:"temp_dir"`
+	Compression struct {
+		Format string `toml:"format"` // "zstd" or "lz4"
+		Level  int    `toml:"level"`
+	} `toml:"compression"`
+
+	MySQL struct {
+		Enabled  bool   `toml:"enabled"`
+		Host     string `toml:"host"`
+		Port     string `toml:"port"`
+		User     string `toml:"user"`
+		Password string `toml:"password"`
+		Database string `toml:"database"`
+	} `toml:"mysql"`
+
+	Filesystem struct {
+		Enabled         bool     `toml:"enabled"`
+		BasePath        string   `toml:"base_path"`
+		IncludePatterns []string `toml:"include_patterns"`
+		ExcludePatterns []string `toml:"exclude_patterns"`
+	} `toml:"filesystem"`
+
+	S3 struct {
+		Endpoint        string `toml:"endpoint"`
+		Region          string `toml:"region"`
+		Bucket          string `toml:"bucket"`
+		AccessKeyID     string `toml:"access_key_id"`
+		SecretAccessKey string `toml:"secret_access_key"`
+		MaxConcurrency  int    `toml:"max_concurrency"`
+		PartSize        int64  `toml:"part_size"`
+	} `toml:"s3"`
+}
+
+var Cfg Config
+
+func Load(path string) error {
+	if _, err := toml.DecodeFile(path, &Cfg); err != nil {
+		return fmt.Errorf("failed to decode config file: %v", err)
+	}
+
+	// Validate configuration
+	if err := validateConfig(&Cfg); err != nil {
+		return fmt.Errorf("invalid configuration: %v", err)
+	}
+
+	return nil
+
+}
+
+func validateConfig(config *Config) error {
+
+	if config.TempDir == "" {
+		config.TempDir = os.TempDir()
+	}
+
+	if config.Compression.Format == "" {
+		config.Compression.Format = "zstd"
+	}
+
+	return nil
+}
diff --git a/go.mod b/go.mod
index 30b7f26..03ae180 100644
--- a/go.mod
+++ b/go.mod
@@ -3,26 +3,29 @@ module github.com/mcpt/Sentinel
 go 1.22
 
 require (
-	github.com/aws/aws-sdk-go-v2 v1.31.0
-	github.com/aws/aws-sdk-go-v2/config v1.27.38
-	github.com/aws/aws-sdk-go-v2/credentials v1.17.36
-	github.com/aws/aws-sdk-go-v2/service/s3 v1.63.2
+	github.com/BurntSushi/toml v1.4.0
+	github.com/aws/aws-sdk-go-v2 v1.32.3
+	github.com/aws/aws-sdk-go-v2/config v1.28.1
+	github.com/aws/aws-sdk-go-v2/credentials v1.17.42
+	github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.35
+	github.com/aws/aws-sdk-go-v2/service/s3 v1.66.2
+	github.com/gobwas/glob v0.2.3
 	github.com/robfig/cron/v3 v3.0.1
 )
 
 require (
-	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.5 // indirect
-	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.14 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.18 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.18 // indirect
+	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.6 // indirect
+	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.18 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.22 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.22 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1 // indirect
-	github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.18 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.5 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.20 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.20 // indirect
-	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.18 // indirect
-	github.com/aws/aws-sdk-go-v2/service/sso v1.23.2 // indirect
-	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.27.2 // indirect
-	github.com/aws/aws-sdk-go-v2/service/sts v1.31.2 // indirect
-	github.com/aws/smithy-go v1.21.0 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.22 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.0 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.4.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sso v1.24.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sts v1.32.3 // indirect
+	github.com/aws/smithy-go v1.22.0 // indirect
 )
diff --git a/go.sum b/go.sum
index ab53458..fbbacdd 100644
--- a/go.sum
+++ b/go.sum
@@ -1,38 +1,44 @@
-github.com/aws/aws-sdk-go-v2 v1.31.0 h1:3V05LbxTSItI5kUqNwhJrrrY1BAXxXt0sN0l72QmG5U=
-github.com/aws/aws-sdk-go-v2 v1.31.0/go.mod h1:ztolYtaEUtdpf9Wftr31CJfLVjOnD/CVRkKOOYgF8hA=
-github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.5 h1:xDAuZTn4IMm8o1LnBZvmrL8JA1io4o3YWNXgohbf20g=
-github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.5/go.mod h1:wYSv6iDS621sEFLfKvpPE2ugjTuGlAG7iROg0hLOkfc=
-github.com/aws/aws-sdk-go-v2/config v1.27.38 h1:mMVyJJuSUdbD4zKXoxDgWrgM60QwlFEg+JhihCq6wCw=
-github.com/aws/aws-sdk-go-v2/config v1.27.38/go.mod h1:6xOiNEn58bj/64MPKx89r6G/el9JZn8pvVbquSqTKK4=
-github.com/aws/aws-sdk-go-v2/credentials v1.17.36 h1:zwI5WrT+oWWfzSKoTNmSyeBKQhsFRJRv+PGW/UZW+Yk=
-github.com/aws/aws-sdk-go-v2/credentials v1.17.36/go.mod h1:3AG/sY1rc9NJrNWcN/3KPU4SIDPGTrd/qegKB0TnFdE=
-github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.14 h1:C/d03NAmh8C4BZXhuRNboF/DqhBkBCeDiJDcaqIT5pA=
-github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.14/go.mod h1:7I0Ju7p9mCIdlrfS+JCgqcYD0VXz/N4yozsox+0o078=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.18 h1:kYQ3H1u0ANr9KEKlGs/jTLrBFPo8P8NaH/w7A01NeeM=
-github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.18/go.mod h1:r506HmK5JDUh9+Mw4CfGJGSSoqIiLCndAuqXuhbv67Y=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.18 h1:Z7IdFUONvTcvS7YuhtVxN99v2cCoHRXOS4mTr0B/pUc=
-github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.18/go.mod h1:DkKMmksZVVyat+Y+r1dEOgJEfUeA7UngIHWeKsi0yNc=
+github.com/BurntSushi/toml v1.4.0 h1:kuoIxZQy2WRRk1pttg9asf+WVv6tWQuBNVmK8+nqPr0=
+github.com/BurntSushi/toml v1.4.0/go.mod h1:ukJfTF/6rtPPRCnwkur4qwRxa8vTRFBF0uk2lLoLwho=
+github.com/aws/aws-sdk-go-v2 v1.32.3 h1:T0dRlFBKcdaUPGNtkBSwHZxrtis8CQU17UpNBZYd0wk=
+github.com/aws/aws-sdk-go-v2 v1.32.3/go.mod h1:2SK5n0a2karNTv5tbP1SjsX0uhttou00v/HpXKM1ZUo=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.6 h1:pT3hpW0cOHRJx8Y0DfJUEQuqPild8jRGmSFmBgvydr0=
+github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.6/go.mod h1:j/I2++U0xX+cr44QjHay4Cvxj6FUbnxrgmqN3H1jTZA=
+github.com/aws/aws-sdk-go-v2/config v1.28.1 h1:oxIvOUXy8x0U3fR//0eq+RdCKimWI900+SV+10xsCBw=
+github.com/aws/aws-sdk-go-v2/config v1.28.1/go.mod h1:bRQcttQJiARbd5JZxw6wG0yIK3eLeSCPdg6uqmmlIiI=
+github.com/aws/aws-sdk-go-v2/credentials v1.17.42 h1:sBP0RPjBU4neGpIYyx8mkU2QqLPl5u9cmdTWVzIpHkM=
+github.com/aws/aws-sdk-go-v2/credentials v1.17.42/go.mod h1:FwZBfU530dJ26rv9saAbxa9Ej3eF/AK0OAY86k13n4M=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.18 h1:68jFVtt3NulEzojFesM/WVarlFpCaXLKaBxDpzkQ9OQ=
+github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.18/go.mod h1:Fjnn5jQVIo6VyedMc0/EhPpfNlPl7dHV916O6B+49aE=
+github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.35 h1:ihPPdcCVSN0IvBByXwqVp28/l4VosBZ6sDulcvU2J7w=
+github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.35/go.mod h1:JkgEhs3SVF51Dj3m1Bj+yL8IznpxzkwlA3jLg3x7Kls=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.22 h1:Jw50LwEkVjuVzE1NzkhNKkBf9cRN7MtE1F/b2cOKTUM=
+github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.22/go.mod h1:Y/SmAyPcOTmpeVaWSzSKiILfXTVJwrGmYZhcRbhWuEY=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.22 h1:981MHwBaRZM7+9QSR6XamDzF/o7ouUGxFzr+nVSIhrs=
+github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.22/go.mod h1:1RA1+aBEfn+CAB/Mh0MB6LsdCYCnjZm7tKXtnk499ZQ=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1 h1:VaRN3TlFdd6KxX1x3ILT5ynH6HvKgqdiXoTxAF4HQcQ=
 github.com/aws/aws-sdk-go-v2/internal/ini v1.8.1/go.mod h1:FbtygfRFze9usAadmnGJNc8KsP346kEe+y2/oyhGAGc=
-github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.18 h1:OWYvKL53l1rbsUmW7bQyJVsYU/Ii3bbAAQIIFNbM0Tk=
-github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.18/go.mod h1:CUx0G1v3wG6l01tUB+j7Y8kclA8NSqK4ef0YG79a4cg=
-github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.5 h1:QFASJGfT8wMXtuP3D5CRmMjARHv9ZmzFUMJznHDOY3w=
-github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.11.5/go.mod h1:QdZ3OmoIjSX+8D1OPAzPxDfjXASbBMDsz9qvtyIhtik=
-github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.20 h1:rTWjG6AvWekO2B1LHeM3ktU7MqyX9rzWQ7hgzneZW7E=
-github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.20/go.mod h1:RGW2DDpVc8hu6Y6yG8G5CHVmVOAn1oV8rNKOHRJyswg=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.20 h1:Xbwbmk44URTiHNx6PNo0ujDE6ERlsCKJD3u1zfnzAPg=
-github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.20/go.mod h1:oAfOFzUB14ltPZj1rWwRc3d/6OgD76R8KlvU3EqM9Fg=
-github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.18 h1:eb+tFOIl9ZsUe2259/BKPeniKuz4/02zZFH/i4Nf8Rg=
-github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.18/go.mod h1:GVCC2IJNJTmdlyEsSmofEy7EfJncP7DNnXDzRjJ5Keg=
-github.com/aws/aws-sdk-go-v2/service/s3 v1.63.2 h1:1iXmXy8SJzQVMGvo40TSzBYS9ig6BSyXfRIMzLfmBfE=
-github.com/aws/aws-sdk-go-v2/service/s3 v1.63.2/go.mod h1:NLTqRLe3pUNu3nTEHI6XlHLKYmc8fbHUdMxAB6+s41Q=
-github.com/aws/aws-sdk-go-v2/service/sso v1.23.2 h1:yzi/y/vKlLyzOfG7pSu5ONNGRxHIgLeDrV4w2AMRCo0=
-github.com/aws/aws-sdk-go-v2/service/sso v1.23.2/go.mod h1:XRlMvmad0ZNL+75C5FYdMvbbLkd6qiqz6foR1nA1PXY=
-github.com/aws/aws-sdk-go-v2/service/ssooidc v1.27.2 h1:3gb6pYhYLjo8rB1h2Tqs61wpjRd3rQymYcVq/pp0yxI=
-github.com/aws/aws-sdk-go-v2/service/ssooidc v1.27.2/go.mod h1:FnvDM4sfa+isJ3kDXIzAB9GAwVSzFzSy97uZ3IsHo4E=
-github.com/aws/aws-sdk-go-v2/service/sts v1.31.2 h1:O6tyji8mXmBGsHvTCB0VIhrDw19lGTUSbKIyjnw79s8=
-github.com/aws/aws-sdk-go-v2/service/sts v1.31.2/go.mod h1:yMWe0F+XG0DkRZK5ODZhG7BEFYhLXi2dqGsv6tX0cgI=
-github.com/aws/smithy-go v1.21.0 h1:H7L8dtDRk0P1Qm6y0ji7MCYMQObJ5R9CRpyPhRUkLYA=
-github.com/aws/smithy-go v1.21.0/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
+github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.22 h1:yV+hCAHZZYJQcwAaszoBNwLbPItHvApxT0kVIw6jRgs=
+github.com/aws/aws-sdk-go-v2/internal/v4a v1.3.22/go.mod h1:kbR1TL8llqB1eGnVbybcA4/wgScxdylOdyAd51yxPdw=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.0 h1:TToQNkvGguu209puTojY/ozlqy2d/SFNcoLIqTFi42g=
+github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.12.0/go.mod h1:0jp+ltwkf+SwG2fm/PKo8t4y8pJSgOCO4D8Lz3k0aHQ=
+github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.4.3 h1:kT6BcZsmMtNkP/iYMcRG+mIEA/IbeiUimXtGmqF39y0=
+github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.4.3/go.mod h1:Z8uGua2k4PPaGOYn66pK02rhMrot3Xk3tpBuUFPomZU=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.3 h1:qcxX0JYlgWH3hpPUnd6U0ikcl6LLA9sLkXE2w1fpMvY=
+github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.12.3/go.mod h1:cLSNEmI45soc+Ef8K/L+8sEA3A3pYFEYf5B5UI+6bH4=
+github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.3 h1:ZC7Y/XgKUxwqcdhO5LE8P6oGP1eh6xlQReWNKfhvJno=
+github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.18.3/go.mod h1:WqfO7M9l9yUAw0HcHaikwRd/H6gzYdz7vjejCA5e2oY=
+github.com/aws/aws-sdk-go-v2/service/s3 v1.66.2 h1:p9TNFL8bFUMd+38YIpTAXpoxyz0MxC7FlbFEH4P4E1U=
+github.com/aws/aws-sdk-go-v2/service/s3 v1.66.2/go.mod h1:fNjyo0Coen9QTwQLWeV6WO2Nytwiu+cCcWaTdKCAqqE=
+github.com/aws/aws-sdk-go-v2/service/sso v1.24.3 h1:UTpsIf0loCIWEbrqdLb+0RxnTXfWh2vhw4nQmFi4nPc=
+github.com/aws/aws-sdk-go-v2/service/sso v1.24.3/go.mod h1:FZ9j3PFHHAR+w0BSEjK955w5YD2UwB/l/H0yAK3MJvI=
+github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.3 h1:2YCmIXv3tmiItw0LlYf6v7gEHebLY45kBEnPezbUKyU=
+github.com/aws/aws-sdk-go-v2/service/ssooidc v1.28.3/go.mod h1:u19stRyNPxGhj6dRm+Cdgu6N75qnbW7+QN0q0dsAk58=
+github.com/aws/aws-sdk-go-v2/service/sts v1.32.3 h1:wVnQ6tigGsRqSWDEEyH6lSAJ9OyFUsSnbaUWChuSGzs=
+github.com/aws/aws-sdk-go-v2/service/sts v1.32.3/go.mod h1:VZa9yTFyj4o10YGsmDO4gbQJUvvhY72fhumT8W4LqsE=
+github.com/aws/smithy-go v1.22.0 h1:uunKnWlcoL3zO7q+gG2Pk53joueEOsnNB28QdMsmiMM=
+github.com/aws/smithy-go v1.22.0/go.mod h1:irrKGvNn1InZwb2d7fkIRNucdfwR8R+Ts3wxYa/cJHg=
+github.com/gobwas/glob v0.2.3 h1:A4xDbljILXROh+kObIiy5kIaPYD8e96x1tgBhUI5J+Y=
+github.com/gobwas/glob v0.2.3/go.mod h1:d3Ez4x06l9bZtSvzIay5+Yzi0fmZzPgnTbPcKjJAkT8=
 github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
 github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
diff --git a/handlers/filesystem.go b/handlers/filesystem.go
new file mode 100644
index 0000000..93db46e
--- /dev/null
+++ b/handlers/filesystem.go
@@ -0,0 +1,114 @@
+package handlers
+
+import (
+	"context"
+	"fmt"
+	"github.com/gobwas/glob"
+	"github.com/mcpt/Sentinel/config"
+	"io"
+	"os"
+	"os/exec"
+	"path/filepath"
+	"time"
+)
+
+type FileSystemHandler struct {
+	tempDir string
+}
+
+func NewFileSystemHandler() (*FileSystemHandler, error) {
+	return &FileSystemHandler{
+		tempDir: "/tmp/backups/fs",
+	}, nil
+}
+
+func (h *FileSystemHandler) Backup(ctx context.Context) (string, error) {
+	tempDir := filepath.Join(config.Cfg.TempDir, "fs_backup")
+	if err := os.MkdirAll(tempDir, 0755); err != nil {
+		return "", fmt.Errorf("failed to create temp directory: %v", err)
+	}
+
+	err := filepath.Walk(config.Cfg.Filesystem.BasePath, func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+
+		relPath, err := filepath.Rel(config.Cfg.Filesystem.BasePath, path)
+		if err != nil {
+			return err
+		}
+
+		// Skip if path matches exclude patterns
+		for _, pattern := range config.Cfg.Filesystem.ExcludePatterns {
+			g, err := glob.Compile(pattern)
+			if err != nil {
+				continue
+			}
+			if g.Match(relPath) {
+				return nil
+			}
+		}
+
+		// Check if path matches include patterns
+		included := false
+		for _, pattern := range config.Cfg.Filesystem.IncludePatterns {
+			g, err := glob.Compile(pattern)
+			if err != nil {
+				continue
+			}
+			if g.Match(relPath) {
+				included = true
+				break
+			}
+		}
+
+		if !included {
+			return nil
+		}
+
+		// Create destination directory
+		destPath := filepath.Join(tempDir, relPath)
+		if info.IsDir() {
+			return os.MkdirAll(destPath, info.Mode())
+		}
+
+		// Copy file
+		return copyFile(path, destPath)
+	})
+
+	if err != nil {
+		return "", fmt.Errorf("failed to backup filesystem: %v", err)
+	}
+
+	// Create tar.gz archive
+	timestamp := time.Now().Format("20060102_150405")
+	archivePath := filepath.Join(config.Cfg.TempDir, fmt.Sprintf("fs_backup_%s.tar.gz", timestamp))
+
+	cmd := exec.Command("tar", "-czf", archivePath, "-C", tempDir, ".")
+	if err := cmd.Run(); err != nil {
+		return "", fmt.Errorf("failed to create archive: %v", err)
+	}
+
+	return archivePath, nil
+}
+
+func copyFile(src, dst string) error {
+	if err := os.MkdirAll(filepath.Dir(dst), 0755); err != nil {
+		return err
+	}
+
+	source, err := os.Open(src)
+	if err != nil {
+		return err
+	}
+	defer source.Close()
+
+	destination, err := os.Create(dst)
+	if err != nil {
+		return err
+	}
+	defer destination.Close()
+
+	_, err = io.Copy(destination, source)
+	return err
+}
diff --git a/handlers/handler.go b/handlers/handler.go
new file mode 100644
index 0000000..9ffae50
--- /dev/null
+++ b/handlers/handler.go
@@ -0,0 +1,7 @@
+package handlers
+
+import "context"
+
+type BackupHandler interface {
+	Backup(ctx context.Context) (string, error)
+}
diff --git a/handlers/mysql.go b/handlers/mysql.go
new file mode 100644
index 0000000..97a3c2d
--- /dev/null
+++ b/handlers/mysql.go
@@ -0,0 +1,41 @@
+package handlers
+
+import (
+	"context"
+	"fmt"
+	"os/exec"
+	"path/filepath"
+	"time"
+
+	"github.com/mcpt/Sentinel/config"
+)
+
+type MySQLHandler struct {
+	tempDir string
+}
+
+func NewMySQLHandler() (*MySQLHandler, error) {
+	return &MySQLHandler{
+		tempDir: "/tmp/backups/mysql",
+	}, nil
+}
+
+func (h *MySQLHandler) Backup(ctx context.Context) (string, error) {
+	timestamp := time.Now().Format("20060102_150405")
+	filename := filepath.Join(h.tempDir, fmt.Sprintf("mysql_%s.sql", timestamp))
+
+	cmd := exec.CommandContext(ctx, "mysqldump",
+		"-h", config.Cfg.MySQL.Host,
+		"-P", config.Cfg.MySQL.Port,
+		"-u", config.Cfg.MySQL.User,
+		fmt.Sprintf("-p%s", config.Cfg.MySQL.Password),
+		config.Cfg.MySQL.Database)
+
+	output, err := cmd.Output()
+	if err != nil {
+		return "", fmt.Errorf("failed to perform database backup: %v", err)
+	}
+	fmt.Printf(string(output))
+
+	return filename, nil
+}
diff --git a/main.go b/main.go
deleted file mode 100644
index 975d853..0000000
--- a/main.go
+++ /dev/null
@@ -1,238 +0,0 @@
-package main
-
-import (
-	"bufio"
-	"context"
-	"flag"
-	"fmt"
-	"log"
-	"os"
-	"os/exec"
-	"path/filepath"
-	"strings"
-	"time"
-
-	"github.com/aws/aws-sdk-go-v2/aws"
-	awsCfg "github.com/aws/aws-sdk-go-v2/config"
-	"github.com/aws/aws-sdk-go-v2/credentials"
-	"github.com/aws/aws-sdk-go-v2/service/s3"
-	"github.com/robfig/cron/v3"
-)
-
-type Config struct {
-	Database struct {
-		Host     string
-		Port     string
-		User     string
-		Password string
-		Name     string
-	}
-	S3Compatible struct {
-		Endpoint        string
-		Region          string
-		AccessKeyID     string
-		SecretAccessKey string
-		Bucket          string
-	}
-	BackupPatterns []string
-}
-
-func main() {
-	configFile := flag.String("config", "backup_include.txt", "Path to the backup include configuration file")
-	flag.Parse()
-
-	config, err := loadConfig(*configFile)
-	if err != nil {
-		log.Fatalf("Failed to load configuration: %v", err)
-	}
-
-	c := cron.New()
-	_, err = c.AddFunc("0 4 */14 * *", func() {
-		if err := performBackup(config); err != nil {
-			log.Printf("Backup failed: %v", err)
-		}
-	})
-	if err != nil {
-		log.Fatalf("Failed to schedule backup: %v", err)
-	}
-
-	log.Println("Starting Sentinel backup system...")
-	c.Start()
-
-	// Keep the program running
-	select {}
-}
-
-func loadConfig(configFile string) (Config, error) {
-	var config Config
-
-	// Load database config from env vars
-	config.Database.Host = os.Getenv("DB_HOST")
-	config.Database.Port = os.Getenv("DB_PORT")
-	config.Database.User = os.Getenv("DB_USER")
-	config.Database.Password = os.Getenv("DB_PASSWORD")
-	config.Database.Name = os.Getenv("DB_NAME")
-
-	// Load S3 compatible storage config
-	config.S3Compatible.Endpoint = os.Getenv("S3_ENDPOINT")
-	config.S3Compatible.Region = os.Getenv("S3_REGION")
-	config.S3Compatible.AccessKeyID = os.Getenv("S3_ACCESS_KEY_ID")
-	config.S3Compatible.SecretAccessKey = os.Getenv("S3_SECRET_ACCESS_KEY")
-	config.S3Compatible.Bucket = os.Getenv("S3_BUCKET")
-
-	// Check if all required configurations are set
-	if config.Database.Host == "" || config.Database.Port == "" || config.Database.User == "" ||
-		config.Database.Password == "" || config.Database.Name == "" || config.S3Compatible.Endpoint == "" ||
-		config.S3Compatible.Region == "" || config.S3Compatible.AccessKeyID == "" ||
-		config.S3Compatible.SecretAccessKey == "" || config.S3Compatible.Bucket == "" {
-		return config, fmt.Errorf("missing required environment variables")
-	}
-
-	// Load backup patterns from file
-	patterns, err := loadBackupPatterns(configFile)
-	if err != nil {
-		return config, fmt.Errorf("failed to load backup patterns: %v", err)
-	}
-	config.BackupPatterns = patterns
-
-	return config, nil
-}
-
-func loadBackupPatterns(filename string) ([]string, error) {
-	file, err := os.Open(filename)
-	if err != nil {
-		return nil, err
-	}
-	defer file.Close()
-
-	var patterns []string
-	scanner := bufio.NewScanner(file)
-	for scanner.Scan() {
-		pattern := strings.TrimSpace(scanner.Text())
-		if pattern != "" && !strings.HasPrefix(pattern, "#") {
-			patterns = append(patterns, pattern)
-		}
-	}
-
-	if err := scanner.Err(); err != nil {
-		return nil, err
-	}
-
-	return patterns, nil
-}
-
-func performBackup(config Config) error {
-	timestamp := time.Now().Format("2006-01-02_15-04-05")
-
-	// Backup database
-	dbBackupFile := fmt.Sprintf("db_backup_%s.sql", timestamp)
-	cmd := exec.Command("mysqldump",
-		"-h", config.Database.Host,
-		"-P", config.Database.Port,
-		"-u", config.Database.User,
-		fmt.Sprintf("-p%s", config.Database.Password),
-		config.Database.Name)
-
-	outfile, err := os.Create(dbBackupFile)
-	if err != nil {
-		return fmt.Errorf("failed to create database backup file: %v", err)
-	}
-	defer outfile.Close()
-
-	cmd.Stdout = outfile
-	if err := cmd.Run(); err != nil {
-		return fmt.Errorf("failed to perform database backup: %v", err)
-	}
-
-	// Upload database backup
-	if err := uploadToS3Compatible(config, dbBackupFile); err != nil {
-		return fmt.Errorf("failed to upload database backup: %v", err)
-	}
-
-	// Cleanup local database backup file
-	if err := os.Remove(dbBackupFile); err != nil {
-		log.Printf("Failed to remove local database backup file: %v", err)
-	}
-
-	// Backup and upload files matching the patterns
-	for _, pattern := range config.BackupPatterns {
-		matches, err := filepath.Glob(pattern)
-		if err != nil {
-			log.Printf("Error matching pattern %s: %v", pattern, err)
-			continue
-		}
-
-		for _, match := range matches {
-			info, err := os.Stat(match)
-			if err != nil {
-				log.Printf("Error stating file %s: %v", match, err)
-				continue
-			}
-
-			if info.IsDir() {
-				err := filepath.Walk(match, func(path string, info os.FileInfo, err error) error {
-					if err != nil {
-						return err
-					}
-					if !info.IsDir() {
-						return uploadToS3Compatible(config, path)
-					}
-					return nil
-				})
-				if err != nil {
-					log.Printf("Error walking directory %s: %v", match, err)
-				}
-			} else {
-				if err := uploadToS3Compatible(config, match); err != nil {
-					log.Printf("Error uploading file %s: %v", match, err)
-				}
-			}
-		}
-	}
-
-	return nil
-}
-
-func uploadToS3Compatible(config Config, filepath string) error {
-	ctx := context.TODO()
-
-	// Configure AWS SDK for S3 compatible storage
-	customResolver := aws.EndpointResolverFunc(func(service, region string) (aws.Endpoint, error) {
-		return aws.Endpoint{
-			URL: config.S3Compatible.Endpoint,
-		}, nil
-	})
-
-	cfg, err := awsCfg.LoadDefaultConfig(ctx,
-		awsCfg.WithEndpointResolver(customResolver),
-		awsCfg.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(
-			config.S3Compatible.AccessKeyID,
-			config.S3Compatible.SecretAccessKey,
-			"",
-		)),
-		awsCfg.WithRegion(config.S3Compatible.Region),
-	)
-	if err != nil {
-		return fmt.Errorf("failed to load AWS config: %v", err)
-	}
-
-	client := s3.NewFromConfig(cfg)
-
-	file, err := os.Open(filepath)
-	if err != nil {
-		return fmt.Errorf("failed to open file %s: %v", filepath, err)
-	}
-	defer file.Close()
-
-	_, err = client.PutObject(ctx, &s3.PutObjectInput{
-		Bucket: aws.String(config.S3Compatible.Bucket),
-		Key:    aws.String(filepath),
-		Body:   file,
-	})
-	if err != nil {
-		return fmt.Errorf("failed to upload file %s: %v", filepath, err)
-	}
-
-	log.Printf("Successfully uploaded %s to S3 compatible storage", filepath)
-	return nil
-}
diff --git a/storage/s3.go b/storage/s3.go
new file mode 100644
index 0000000..e9d0b82
--- /dev/null
+++ b/storage/s3.go
@@ -0,0 +1,186 @@
+package storage
+
+import (
+	"context"
+	"fmt"
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/config"
+	"github.com/aws/aws-sdk-go-v2/credentials"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/service/s3"
+	cfg "github.com/mcpt/Sentinel/config"
+	"io"
+	"log"
+	"os"
+	"path/filepath"
+	"sync"
+	"time"
+)
+
+type S3Uploader struct {
+	client   *s3.Client
+	uploader *manager.Uploader
+}
+
+func NewS3Uploader() (*S3Uploader, error) {
+	ctx := context.Background()
+
+	// Set default values if not specified
+	if cfg.Cfg.S3.MaxConcurrency == 0 {
+		cfg.Cfg.S3.MaxConcurrency = 10
+	}
+	if cfg.Cfg.S3.PartSize == 0 {
+		cfg.Cfg.S3.PartSize = 5 * 1024 * 1024 // 5MB default part size
+	}
+
+	customResolver := aws.EndpointResolverFunc(func(service, region string) (aws.Endpoint, error) {
+		if cfg.Cfg.S3.Endpoint != "" {
+			return aws.Endpoint{
+				URL: cfg.Cfg.S3.Endpoint,
+			}, nil
+		}
+		return aws.Endpoint{}, &aws.EndpointNotFoundError{}
+	})
+
+	awsCfg, err := config.LoadDefaultConfig(ctx,
+		config.WithEndpointResolver(customResolver),
+		config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider(
+			cfg.Cfg.S3.AccessKeyID,
+			cfg.Cfg.S3.SecretAccessKey,
+			"",
+		)),
+		config.WithRegion(cfg.Cfg.S3.Region),
+	)
+	if err != nil {
+		return nil, fmt.Errorf("failed to load AWS config: %v", err)
+	}
+
+	client := s3.NewFromConfig(awsCfg)
+	uploader := manager.NewUploader(client, func(u *manager.Uploader) {
+		u.Concurrency = cfg.Cfg.S3.MaxConcurrency
+		u.PartSize = cfg.Cfg.S3.PartSize
+	})
+
+	return &S3Uploader{
+		client:   client,
+		uploader: uploader,
+	}, nil
+}
+
+// UploadDirectory uploads an entire directory to S3
+func (u *S3Uploader) UploadDirectory(ctx context.Context, localPath string, s3Prefix string) error {
+	// Create a buffered channel to control concurrency
+	uploadChan := make(chan string, cfg.Cfg.S3.MaxConcurrency)
+	errChan := make(chan error, 1)
+	var wg sync.WaitGroup
+
+	// Start worker goroutines
+	for i := 0; i < cfg.Cfg.S3.MaxConcurrency; i++ {
+		wg.Add(1)
+		go func() {
+			defer wg.Done()
+			for path := range uploadChan {
+				if err := u.uploadFile(ctx, path, localPath, s3Prefix); err != nil {
+					select {
+					case errChan <- err:
+					default:
+					}
+					return
+				}
+			}
+		}()
+	}
+
+	// Walk the directory and send files to upload
+	go func() {
+		err := filepath.Walk(localPath, func(path string, info os.FileInfo, err error) error {
+			if err != nil {
+				return err
+			}
+			if !info.IsDir() {
+				select {
+				case uploadChan <- path:
+				case <-ctx.Done():
+					return ctx.Err()
+				}
+			}
+			return nil
+		})
+		close(uploadChan)
+		if err != nil {
+			select {
+			case errChan <- err:
+			default:
+			}
+		}
+	}()
+
+	// Wait for all uploads to complete
+	wg.Wait()
+	close(errChan)
+
+	// Check for any errors
+	if err := <-errChan; err != nil {
+		return fmt.Errorf("upload failed: %v", err)
+	}
+
+	return nil
+}
+
+// uploadFile handles the upload of a single file to S3
+func (u *S3Uploader) uploadFile(ctx context.Context, filePath, basePath, s3Prefix string) error {
+	file, err := os.Open(filePath)
+	if err != nil {
+		return fmt.Errorf("failed to open file %s: %v", filePath, err)
+	}
+	defer file.Close()
+
+	// Calculate relative path for S3 key
+	relPath, err := filepath.Rel(basePath, filePath)
+	if err != nil {
+		return fmt.Errorf("failed to get relative path: %v", err)
+	}
+
+	// Create S3 key with prefix and timestamp
+	timestamp := time.Now().Format("20060102-150405")
+	s3Key := filepath.Join(s3Prefix, timestamp, relPath)
+
+	// Create a pipe for streaming
+	pr, pw := io.Pipe()
+
+	// Start upload
+	var uploadErr error
+	var uploadWg sync.WaitGroup
+	uploadWg.Add(1)
+
+	go func() {
+		defer uploadWg.Done()
+		_, uploadErr = u.uploader.Upload(ctx, &s3.PutObjectInput{
+			Bucket: aws.String(cfg.Cfg.S3.Bucket),
+			Key:    aws.String(s3Key),
+			Body:   pr,
+		})
+		pr.Close()
+	}()
+
+	// Copy file to pipe
+	_, err = io.Copy(pw, file)
+	pw.Close()
+	if err != nil {
+		return fmt.Errorf("failed to copy file: %v", err)
+	}
+
+	// Wait for upload to complete
+	uploadWg.Wait()
+	if uploadErr != nil {
+		return fmt.Errorf("failed to upload to S3: %v", uploadErr)
+	}
+
+	log.Printf("Successfully uploaded %s to s3://%s/%s", filePath, cfg.Cfg.S3.Bucket, s3Key)
+	return nil
+}
+
+// UploadFile uploads a single file to S3
+func (u *S3Uploader) UploadFile(ctx context.Context, filePath, s3Prefix string) error {
+	return u.uploadFile(ctx, filePath, filepath.Dir(filePath), s3Prefix)
+}