Merge pull request #12 from StarFleetCPTN/development

Switch to glebarez/sqlite and add migration support

.github/workflows/docker-publish-dockerhub.yml

@@ -44,7 +44,7 @@ jobs:
         id: meta
         uses: docker/metadata-action@v5
         with:
-          images: ${{ env.REGISTRY }}/${{ env.IMAGE_NAME }}
+          images: starfleetcptn/gomft
           tags: |
             type=semver,pattern={{version}}
             type=semver,pattern={{major}}.{{minor}}

.gitignore

@@ -49,4 +49,15 @@ components/*.go
 data/
 
 # Ignore the tmp directory
-tmp/ 
+tmp/ 
+
+# Ignore the configs directory
+configs/
+
+# Ignore Dirs
+source/
+destination/
+archive/
+
+# Ignore binaries
+gomft

README.md

@@ -19,8 +19,8 @@ GoMFT is a web-based managed file transfer application built with Go, leveraging
 ![Job Scheduling](screenshots/new.job.gomft.png)
 *Scheduling transfers with flexible cron expressions*
 
-### User Mangement
+### User Management
-![User Mangement](screenshots/user.management.gomft.png)
+![User Management](screenshots/user.management.gomft.png)
 *Create user accounts and manage them*
 
 
@@ -49,6 +49,8 @@ GoMFT is a web-based managed file transfer application built with Go, leveraging
 - **Password Recovery**: Self-service password reset via email with secure token-based authentication
 - **User Profile Management**: Personal settings including theme preferences
 - **Modern UI**: Built with Templ, HTMX and Tailwind CSS for a responsive experience
+- **Docker Support**: Easy deployment with Docker images and Docker Compose support
+- **Portable Deployment**: Run on any platform that supports Docker or Go
 
 ## Prerequisites
 
@@ -58,6 +60,8 @@ GoMFT is a web-based managed file transfer application built with Go, leveraging
 
 ## Installation
 
+### Standard Installation
+
 1. Clone the repository:
 ```bash
 git clone https://github.com/starfleetcptn/gomft.git
@@ -74,6 +78,54 @@ go mod download
 go build -o gomft
 ```
 
+### Docker Installation
+
+GoMFT is available as a Docker image for quick and easy deployment.
+
+1. Pull the latest image from Docker Hub:
+```bash
+docker pull starfleetcptn/gomft:latest
+```
+
+2. Run the container:
+```bash
+docker run -d \
+  --name gomft \
+  -p 8080:8080 \
+  -v /path/to/data:/app/data \
+  starfleetcptn/gomft:latest
+```
+
+3. Access the web interface at `http://localhost:8080`
+
+#### Docker Compose Example
+
+For production deployments, you can use Docker Compose:
+
+```yaml
+version: '3'
+services:
+  gomft:
+    image: starfleetcptn/gomft:latest
+    container_name: gomft
+    restart: unless-stopped
+    ports:
+      - "8080:8080"
+    volumes:
+      - ./data:/app/data
+      - ./backups:/app/data/gomft/backups
+    environment:
+      - TZ=UTC
+```
+
+Save this as `docker-compose.yml` and run:
+
+```bash
+docker-compose up -d
+```
+
+For more information and available tags, visit the [GoMFT Docker Hub page](https://hub.docker.com/r/starfleetcptn/gomft).
+
 ## Configuration
 
 GoMFT uses a configuration file located at `./data/gomft/config.json`. On first run, a default configuration will be created:
@@ -244,6 +296,7 @@ To configure email functionality:
 - **Authentication**: JWT (JSON Web Tokens)
 - **Database**: GORM with SQLite
 - **File Transfer**: rclone
+- **Deployment**: Docker containerization and traditional installation
 
 ### Building from Source
 
@@ -273,4 +326,4 @@ air
 
 ## License
 
-MIT License - see LICENSE file for details
+MIT License - see LICENSE file for details

components/config_form.templ

@@ -60,6 +60,7 @@ func getInitialData(config *db.TransferConfig) string {
 	destPassiveMode := true
 	archivePath := ""
 	archiveEnabled := false
+	deleteAfterTransfer := false
 	rcloneFlags := ""
 
 	if config != nil {
@@ -104,6 +105,7 @@ func getInitialData(config *db.TransferConfig) string {
 		destPassiveMode = config.DestPassiveMode
 		archivePath = config.ArchivePath
 		archiveEnabled = config.ArchiveEnabled
+		deleteAfterTransfer = config.DeleteAfterTransfer
 		rcloneFlags = config.RcloneFlags
 	}
 
@@ -147,6 +149,7 @@ func getInitialData(config *db.TransferConfig) string {
 		// Existing fields
 		archivePath: '%s',
 		archiveEnabled: %v,
+		deleteAfterTransfer: %v,
 		rcloneFlags: '%s',
 		loading: false,
 		validate() {
@@ -209,7 +212,7 @@ func getInitialData(config *db.TransferConfig) string {
 		filePattern, outputPattern, destinationType, destinationPath, destHost, destPort, destUser, destPassword, destKeyFile,
 		destBucket, destRegion, destAccessKey, destSecretKey, destEndpoint,
 		destShare, destDomain, destPassiveMode,
-		archivePath, archiveEnabled, rcloneFlags)
+		archivePath, archiveEnabled, deleteAfterTransfer, rcloneFlags)
 }
 
 templ ConfigForm(ctx context.Context, data ConfigFormData) {
@@ -1303,6 +1306,25 @@ templ ConfigForm(ctx context.Context, data ConfigFormData) {
 											</div>
 										</div>
 
+										<div class="sm:col-span-6 mt-4">
+											<div class="flex items-center">
+												<input
+													type="checkbox"
+													id="delete_after_transfer"
+													x-model="deleteAfterTransfer"
+													class="h-4 w-4 text-primary-600 focus:ring-primary-500 border-secondary-300 dark:border-secondary-700 rounded"/>
+												<input type="hidden" name="delete_after_transfer" :value="deleteAfterTransfer.toString()"/>
+												<label for="delete_after_transfer" class="ml-2 block text-sm text-secondary-700 dark:text-secondary-300">
+													Delete files from source after transfer
+												</label>
+											</div>
+											<p class="mt-2 text-sm text-secondary-500 dark:text-secondary-400">
+												<i class="fas fa-exclamation-triangle text-yellow-500 mr-1"></i>
+												Original files will be permanently deleted from source after successful transfer
+												<span x-show="archiveEnabled">and archiving</span>
+											</p>
+										</div>
+
 										<div class="sm:col-span-6">
 											<label for="rclone_flags" class="block text-sm font-medium text-secondary-700 dark:text-secondary-300 mb-1">Rclone Flags</label>
 											<div class="relative">

components/configs.templ

@@ -6,12 +6,204 @@ import (
 	"github.com/starfleetcptn/gomft/internal/db"
 )
 
+// Dialog component for confirmation dialogs
+templ ConfigDialog(id string, title string, message string, confirmClass string, confirmText string, action string, configID uint, configName string) {
+	<div id={ id } class="hidden fixed inset-0 bg-secondary-900/50 dark:bg-secondary-900/80 backdrop-blur-sm z-50 flex items-center justify-center">
+		<div class="bg-white dark:bg-secondary-800 rounded-lg shadow-xl max-w-md w-full mx-4 overflow-hidden">
+			<div class="px-6 pt-5 pb-3 text-center">
+				<div class="flex justify-center mb-2">
+					<i class="fas fa-exclamation-triangle text-yellow-400 text-3xl"></i>
+				</div>
+				<h3 class="text-xl font-medium text-secondary-900 dark:text-secondary-100">
+					{ title }
+				</h3>
+			</div>
+			<div class="px-6 py-4 text-center">
+				<p class="text-secondary-700 dark:text-secondary-300">
+					{ message }
+				</p>
+			</div>
+			<div class="px-6 py-4 flex justify-end space-x-3">
+				<button type="button" class="btn-secondary" onclick={ hideConfigDialog(id) }>
+					Cancel
+				</button>
+				<button 
+					type="button" 
+					class={ confirmClass }
+					hx-delete={ fmt.Sprintf("/configs/%d", configID) }
+					hx-target="closest li"
+					hx-swap="delete"
+					data-config-name={ configName }
+					data-config-id={ fmt.Sprint(configID) }
+					id={ fmt.Sprintf("delete-config-btn-%d", configID) }
+					onclick={ triggerConfigDelete(id, configID, configName) }>
+					{ confirmText }
+				</button>
+			</div>
+		</div>
+	</div>
+}
+
+script hideConfigDialog(id string) {
+	document.getElementById(id).classList.add("hidden");
+}
+
+script showConfigDialog(id string) {
+	document.getElementById(id).classList.remove("hidden");
+}
+
+script triggerConfigDelete(dialogId string, configID uint, configName string) {
+	// Hide the dialog
+	document.getElementById(dialogId).classList.add("hidden");
+		
+	// Store data in a way that's accessible to event handlers
+	window.lastDeletedConfig = {
+		id: configID,
+		name: configName
+	};
+
+	// Add custom marker to track this deletion
+	window.currentlyDeletingConfig = true;
+}
+
 type ConfigsData struct {
 	Configs []db.TransferConfig
 }
 
 templ Configs(ctx context.Context, data ConfigsData) {
 	@LayoutWithContext("Transfer Configurations", ctx) {
+		<script>
+			// Debug notification system
+			console.log("Configs template loaded, setting up notification system");
+			
+			// Create a global notyf instance if it doesn't exist yet
+			if (!window.notyf) {
+				window.notyf = new Notyf({
+					duration: 3000,
+					position: {
+						x: 'right',
+						y: 'top',
+					},
+					types: [
+						{
+							type: 'success',
+							background: '#38c172',
+							icon: {
+								className: 'fas fa-check-circle',
+								tagName: 'i'
+							}
+						},
+						{
+							type: 'error',
+							background: '#e3342f',
+							icon: {
+								className: 'fas fa-exclamation-circle',
+								tagName: 'i'
+							}
+						}
+					]
+				});
+				console.log("Notyf initialized:", window.notyf);
+			}
+
+			// Track all HTMX events for debugging
+			document.addEventListener('htmx:beforeRequest', function(event) {
+				
+				// Check if this is a DELETE request by examining the URL and method
+				const path = event.detail.path;
+				const method = event.detail.verb;
+								
+				// Pattern match for config deletions (e.g., /configs/123)
+				if (path && method === 'DELETE' && path.match(/^\/configs\/\d+$/)) {
+					
+					// This is definitely a delete request - store this information
+					window.isConfigDeleteRequest = true;
+				}
+			});
+
+			// Track HTMX after-request events for config deletion
+			document.addEventListener('htmx:afterRequest', function(event) {
+				
+				// Check for config deletion multiple ways
+				const isDeleteRequest = 
+					// Check global flag from the triggerConfigDelete function
+					window.currentlyDeletingConfig ||
+					// Check flag from beforeRequest handler
+					window.isConfigDeleteRequest ||
+					// Check URL pattern directly from this event
+					(event.detail.pathInfo && event.detail.pathInfo.requestPath && 
+					 event.detail.pathInfo.requestPath.match(/^\/configs\/\d+$/) && 
+					 event.detail.verb === 'DELETE');
+				
+				
+				// If this is a successful delete request, show notification
+				if (isDeleteRequest && event.detail.successful) {
+					
+					let configName = "Unknown";
+					
+					// Try multiple sources for config name
+					if (event.detail.elt && event.detail.elt.getAttribute) {
+						configName = event.detail.elt.getAttribute('data-config-name') || configName;
+					}
+					
+					if (configName === "Unknown" && window.lastDeletedConfig) {
+						// Fallback to our stored config info
+						configName = window.lastDeletedConfig.name;
+					}
+					
+					window.notyf.success(`Configuration "${configName}" deleted successfully`);
+					
+					// Clear flags
+					window.currentlyDeletingConfig = false;
+					window.isConfigDeleteRequest = false;
+					window.lastDeletedConfig = null;
+				}
+			});
+			
+			// Track HTMX error events for config deletion
+			document.addEventListener('htmx:responseError', function(event) {
+				
+				// Similar logic as success but for errors
+				const isDeleteRequest = 
+					window.currentlyDeletingConfig ||
+					window.isConfigDeleteRequest ||
+					(event.detail.pathInfo && event.detail.pathInfo.requestPath && 
+					 event.detail.pathInfo.requestPath.match(/^\/configs\/\d+$/) && 
+					 event.detail.verb === 'DELETE');
+				
+				if (isDeleteRequest) {
+					
+					let configName = "Unknown";
+					
+					// Try multiple sources for config name
+					if (event.detail.elt && event.detail.elt.getAttribute) {
+						configName = event.detail.elt.getAttribute('data-config-name') || configName;
+					}
+					
+					if (configName === "Unknown" && window.lastDeletedConfig) {
+						// Fallback to our stored config info
+						configName = window.lastDeletedConfig.name;
+					}
+					
+					let errorMsg = `Failed to delete configuration "${configName}"`;
+					
+					if (event.detail.xhr && event.detail.xhr.responseText) {
+						errorMsg = event.detail.xhr.responseText
+						// error message is a json object
+						const error = JSON.parse(errorMsg);
+						errorMsg = `Error: ${error.error}`;
+					}
+					
+					window.notyf.error(errorMsg);
+					
+					// Clear flags
+					window.currentlyDeletingConfig = false;
+					window.isConfigDeleteRequest = false;
+					window.lastDeletedConfig = null;
+				}
+			});
+		</script>
+		
 		<div class="py-6">
 			<div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8">
 				<div class="flex justify-between items-center mb-8">
@@ -58,11 +250,20 @@ templ Configs(ctx context.Context, data ConfigsData) {
 															<i class="fas fa-edit mr-1"></i>
 															Edit
 														</a>
+														<!-- Add delete dialog for each configuration -->
+														@ConfigDialog(
+															fmt.Sprintf("delete-config-dialog-%d", config.ID),
+															"Delete Configuration",
+															fmt.Sprintf("Are you sure you want to delete the configuration '%s'? This cannot be undone.", config.Name),
+															"btn-danger",
+															"Delete",
+															"delete",
+															config.ID,
+															config.Name,
+														)
 														<button 
-															hx-delete={ fmt.Sprintf("/configs/%d", config.ID) }
+															type="button"
-															hx-confirm="Are you sure you want to delete this configuration?"
+															onclick={ showConfigDialog(fmt.Sprintf("delete-config-dialog-%d", config.ID)) }
-															hx-target="closest li"
-															hx-swap="outerHTML"
 															class="btn-danger btn-sm">
 															<i class="fas fa-trash-alt mr-1"></i>
 															Delete

components/jobs.templ

@@ -6,12 +6,243 @@ import (
 	"github.com/starfleetcptn/gomft/internal/db"
 )
 
+// Dialog component for confirmation dialogs - copied from admin_tools.templ
+templ JobDialog(id string, title string, message string, confirmClass string, confirmText string, action string, jobID uint, jobName string) {
+	<div id={ id } class="hidden fixed inset-0 bg-secondary-900/50 dark:bg-secondary-900/80 backdrop-blur-sm z-50 flex items-center justify-center">
+		<div class="bg-white dark:bg-secondary-800 rounded-lg shadow-xl max-w-md w-full mx-4 overflow-hidden">
+			<div class="px-6 pt-5 pb-3 text-center">
+				<div class="flex justify-center mb-2">
+					<i class="fas fa-exclamation-triangle text-yellow-400 text-3xl"></i>
+				</div>
+				<h3 class="text-xl font-medium text-secondary-900 dark:text-secondary-100">
+					{ title }
+				</h3>
+			</div>
+			<div class="px-6 py-4 text-center">
+				<p class="text-secondary-700 dark:text-secondary-300">
+					{ message }
+				</p>
+			</div>
+			<div class="px-6 py-4 flex justify-end space-x-3">
+				<button type="button" class="btn-secondary" onclick={ hideJobDialog(id) }>
+					Cancel
+				</button>
+				<button 
+					type="button" 
+					class={ confirmClass }
+					hx-delete={ fmt.Sprintf("/jobs/%d", jobID) }
+					hx-target="closest li"
+					hx-swap="delete"
+					data-job-name={ jobName }
+					data-job-id={ fmt.Sprint(jobID) }
+					id={ fmt.Sprintf("delete-btn-%d", jobID) }
+					onclick={ triggerJobDelete(id, jobID, jobName) }>
+					{ confirmText }
+				</button>
+			</div>
+		</div>
+	</div>
+}
+
+script hideJobDialog(id string) {
+	document.getElementById(id).classList.add("hidden");
+}
+
+script showJobDialog(id string) {
+	document.getElementById(id).classList.remove("hidden");
+}
+
+script triggerJobDelete(dialogId string, jobID uint, jobName string) {
+	// Hide the dialog
+	document.getElementById(dialogId).classList.add("hidden");
+	
+	// Add debugging info
+	console.log(`Job deletion triggered for: ${jobName} (ID: ${jobID})`);
+	
+	// Store data in a way that's accessible to event handlers
+	window.lastDeletedJob = {
+		id: jobID,
+		name: jobName
+	};
+
+	// Add custom marker to track this deletion
+	window.currentlyDeletingJob = true;
+}
+
 type JobsData struct {
 	Jobs []db.Job
 }
 
 templ Jobs(ctx context.Context, data JobsData) {
 	@LayoutWithContext("Transfer Jobs", ctx) {
+		<script>
+			// Debug notification system
+			console.log("Jobs template loaded, setting up notification system");
+			
+			// Create a global notyf instance immediately
+			window.notyf = new Notyf({
+				duration: 3000,
+				position: {
+					x: 'right',
+					y: 'top',
+				},
+				types: [
+					{
+						type: 'success',
+						background: '#38c172',
+						icon: {
+							className: 'fas fa-check-circle',
+							tagName: 'i'
+						}
+					},
+					{
+						type: 'error',
+						background: '#e3342f',
+						icon: {
+							className: 'fas fa-exclamation-circle',
+							tagName: 'i'
+						}
+					}
+				]
+			});
+			console.log("Notyf initialized:", window.notyf);
+			
+			// Global function to handle job running
+			window.runJob = function(button) {
+				// Get job data from button attributes
+				const jobId = button.getAttribute('data-job-id');
+				const jobName = button.getAttribute('data-job-name') || `Job #${jobId}`;
+				
+				console.log(`Run job clicked for: ${jobName} (ID: ${jobId})`);
+				
+				// No loading notification - just listen for the response
+				button.addEventListener('htmx:afterRequest', function(event) {
+					console.log("Run job request completed:", event.detail);
+					if (event.detail.successful) {
+						let displayName = jobName;
+						// Try to extract job name from response headers
+						if (event.detail.headers && event.detail.headers['HX-Job-Name']) {
+							displayName = event.detail.headers['HX-Job-Name'];
+						}
+						console.log(`Showing success notification for job: ${displayName}`);
+						window.notyf.success(`Job "${displayName}" started successfully!`);
+					} else {
+						let errorMsg = `Failed to start job "${jobName}"`;
+						if (event.detail.xhr && event.detail.xhr.responseText) {
+							errorMsg = `Error: ${event.detail.xhr.responseText}`;
+						}
+						console.log(`Showing error notification: ${errorMsg}`);
+						window.notyf.error(errorMsg);
+					}
+				}, { once: true });
+			};
+
+			// Track all HTMX events for debugging
+			document.addEventListener('htmx:beforeRequest', function(event) {
+				console.log("HTMX before request:", event.detail);
+				
+				// Check if this is a DELETE request by examining the URL and method
+				const path = event.detail.path;
+				const method = event.detail.verb;
+				
+				console.log(`Request path: ${path}, method: ${method}`);
+				
+				// Pattern match for job deletions (e.g., /jobs/123)
+				if (path && method === 'DELETE' && path.match(/^\/jobs\/\d+$/)) {
+					console.log("Detected job deletion request via URL pattern");
+					
+					// This is definitely a delete request - store this information
+					window.isJobDeleteRequest = true;
+				}
+			});
+
+			// Track HTMX after-request events for job deletion
+			document.addEventListener('htmx:afterRequest', function(event) {
+				console.log("HTMX after request:", event.detail);
+				
+				// Check for job deletion multiple ways
+				const isDeleteRequest = 
+					// Check global flag from the triggerJobDelete function
+					window.currentlyDeletingJob ||
+					// Check flag from beforeRequest handler
+					window.isJobDeleteRequest ||
+					// Check URL pattern directly from this event
+					(event.detail.pathInfo && event.detail.pathInfo.requestPath && 
+					 event.detail.pathInfo.requestPath.match(/^\/jobs\/\d+$/) && 
+					 event.detail.verb === 'DELETE');
+				
+				console.log(`Is delete request: ${isDeleteRequest}`);
+				
+				// If this is a successful delete request, show notification
+				if (isDeleteRequest && event.detail.successful) {
+					console.log("Delete request was successful");
+					
+					let jobName = "Unknown";
+					
+					// Try multiple sources for job name
+					if (event.detail.elt && event.detail.elt.getAttribute) {
+						jobName = event.detail.elt.getAttribute('data-job-name') || jobName;
+					}
+					
+					if (jobName === "Unknown" && window.lastDeletedJob) {
+						// Fallback to our stored job info
+						jobName = window.lastDeletedJob.name;
+					}
+					
+					console.log(`Showing success notification for deleted job: ${jobName}`);
+					window.notyf.success(`Job "${jobName}" deleted successfully`);
+					
+					// Clear flags
+					window.currentlyDeletingJob = false;
+					window.isJobDeleteRequest = false;
+					window.lastDeletedJob = null;
+				}
+			});
+			
+			// Track HTMX error events for job deletion
+			document.addEventListener('htmx:responseError', function(event) {
+				console.log("HTMX response error:", event.detail);
+				
+				// Similar logic as success but for errors
+				const isDeleteRequest = 
+					window.currentlyDeletingJob ||
+					window.isJobDeleteRequest ||
+					(event.detail.pathInfo && event.detail.pathInfo.requestPath && 
+					 event.detail.pathInfo.requestPath.match(/^\/jobs\/\d+$/) && 
+					 event.detail.verb === 'DELETE');
+				
+				if (isDeleteRequest) {
+					console.log("Delete request failed");
+					
+					let jobName = "Unknown";
+					
+					// Try multiple sources for job name
+					if (event.detail.elt && event.detail.elt.getAttribute) {
+						jobName = event.detail.elt.getAttribute('data-job-name') || jobName;
+					}
+					
+					if (jobName === "Unknown" && window.lastDeletedJob) {
+						// Fallback to our stored job info
+						jobName = window.lastDeletedJob.name;
+					}
+					
+					let errorMsg = `Failed to delete job "${jobName}"`;
+					
+					if (event.detail.xhr && event.detail.xhr.responseText) {
+						errorMsg = `Error: ${event.detail.xhr.responseText}`;
+					}
+					
+					console.log(`Showing error notification: ${errorMsg}`);
+					window.notyf.error(errorMsg);
+					
+					// Clear flags
+					window.currentlyDeletingJob = false;
+					window.isJobDeleteRequest = false;
+					window.lastDeletedJob = null;
+				}
+			});
+		</script>
+		
 		<div class="py-6">
 			<div class="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8">
 				<div class="flex justify-between items-center mb-8">
@@ -68,15 +299,34 @@ templ Jobs(ctx context.Context, data JobsData) {
 														}
 													</div>
 													<div class="ml-2 flex-shrink-0 flex space-x-2">
+														<button 
+															hx-post={ fmt.Sprintf("/jobs/%d/run", job.ID) }
+															hx-swap="none"
+															class="btn-primary btn-sm"
+															data-job-id={ fmt.Sprint(job.ID) }
+															data-job-name={ job.Name }
+															onclick="window.runJob(this)">
+															<i class="fas fa-play mr-1"></i>
+															Run Now
+														</button>
 														<a href={ templ.SafeURL(fmt.Sprintf("/jobs/%d", job.ID)) } class="btn-secondary btn-sm">
 															<i class="fas fa-edit mr-1"></i>
 															Edit
 														</a>
+														<!-- Add delete dialog for each job -->
+														@JobDialog(
+															fmt.Sprintf("delete-job-dialog-%d", job.ID),
+															"Delete Job",
+															fmt.Sprintf("Are you sure you want to delete the job '%s'? This cannot be undone.", determineJobName(job)),
+															"btn-danger",
+															"Delete",
+															"delete",
+															job.ID,
+															determineJobName(job),
+														)
 														<button 
-															hx-delete={ fmt.Sprintf("/jobs/%d", job.ID) }
+															type="button"
-															hx-confirm="Are you sure you want to delete this job?"
+															onclick={ showJobDialog(fmt.Sprintf("delete-job-dialog-%d", job.ID)) }
-															hx-target="closest li"
-															hx-swap="outerHTML"
 															class="btn-danger btn-sm">
 															<i class="fas fa-trash-alt mr-1"></i>
 															Delete
@@ -128,4 +378,12 @@ templ Jobs(ctx context.Context, data JobsData) {
 			</div>
 		</div>
 	}
+}
+
+// Helper function to determine the job name (reuse this logic to keep it consistent)
+func determineJobName(job db.Job) string {
+	if job.Name != "" {
+		return job.Name
+	}
+	return job.Config.Name
 }

components/layout.templ

@@ -47,6 +47,42 @@ templ LayoutWithContext(title string, ctx context.Context) {
 			<script src="/static/js/app.js"></script>
 			<link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.4.0/css/all.min.css" />
 			<link rel="stylesheet" href="/static/css/app.css"/>
+			<!-- Notyf Toast Notifications -->
+			<link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/notyf@3/notyf.min.css" />
+			<script src="https://cdn.jsdelivr.net/npm/notyf@3/notyf.min.js"></script>
+			<script>
+				// Initialize Notyf and make it available globally
+				document.addEventListener('DOMContentLoaded', function() {
+					window.notyfInstance = new Notyf({
+						duration: 3000,
+						position: {
+							x: 'right',
+							y: 'bottom',
+						},
+						types: [
+							{
+								type: 'success',
+								className: 'notyf__toast--success',
+								background: '#10B981',
+								icon: {
+									className: 'fas fa-check-circle',
+									tagName: 'i'
+								}
+							},
+							{
+								type: 'error',
+								className: 'notyf__toast--error',
+								background: '#EF4444',
+								icon: {
+									className: 'fas fa-exclamation-circle',
+									tagName: 'i'
+								}
+							}
+						]
+					});
+					
+				});
+			</script>
 			<script>
 				tailwind.config = {
 					darkMode: 'class',
@@ -377,6 +413,9 @@ templ LayoutWithContext(title string, ctx context.Context) {
 				</div>
 			}
 			<main class="flex-grow w-full max-w-7xl mx-auto py-6 px-4 sm:px-6 lg:px-8 animate-fadeIn pb-mobile-nav">
+				<!-- Hidden notification area for HTMX targets -->
+				<div id="notification-area" class="hidden" hx-swap-oob="true"></div>
+				
 				{ children... }
 			</main>
 			<footer class="bg-white dark:bg-secondary-800 shadow-inner mt-auto w-full">

go.mod

@@ -5,10 +5,11 @@ go 1.24.0
 require (
 	github.com/a-h/templ v0.3.833
 	github.com/gin-gonic/gin v1.10.0
+	github.com/glebarez/sqlite v1.11.0
+	github.com/go-gormigrate/gormigrate/v2 v2.1.3
 	github.com/golang-jwt/jwt/v5 v5.2.1
 	github.com/robfig/cron/v3 v3.0.1
 	golang.org/x/crypto v0.35.0
-	gorm.io/driver/sqlite v1.5.7
 	gorm.io/gorm v1.25.12
 )
 
@@ -16,22 +17,25 @@ require (
 	github.com/bytedance/sonic v1.12.9 // indirect
 	github.com/bytedance/sonic/loader v0.2.3 // indirect
 	github.com/cloudwego/base64x v0.1.5 // indirect
+	github.com/dustin/go-humanize v1.0.1 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
 	github.com/gin-contrib/sse v1.0.0 // indirect
+	github.com/glebarez/go-sqlite v1.21.2 // indirect
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
 	github.com/go-playground/validator/v10 v10.25.0 // indirect
 	github.com/goccy/go-json v0.10.5 // indirect
+	github.com/google/uuid v1.3.0 // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.10 // indirect
 	github.com/leodido/go-urn v1.4.0 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
-	github.com/mattn/go-sqlite3 v1.14.24 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
 	github.com/pelletier/go-toml/v2 v2.2.3 // indirect
+	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
 	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
 	github.com/ugorji/go/codec v1.2.12 // indirect
 	golang.org/x/arch v0.14.0 // indirect
@@ -40,4 +44,8 @@ require (
 	golang.org/x/text v0.22.0 // indirect
 	google.golang.org/protobuf v1.36.5 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
+	modernc.org/libc v1.22.5 // indirect
+	modernc.org/mathutil v1.5.0 // indirect
+	modernc.org/memory v1.5.0 // indirect
+	modernc.org/sqlite v1.23.1 // indirect
 )

go.sum

@@ -11,12 +11,20 @@ github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQ
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=
+github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
 github.com/gabriel-vasile/mimetype v1.4.8 h1:FfZ3gj38NjllZIeJAmMhr+qKL8Wu+nOoI3GqacKw1NM=
 github.com/gabriel-vasile/mimetype v1.4.8/go.mod h1:ByKUIKGjh1ODkGM1asKUbQZOLGrPjydw3hYPU2YU9t8=
 github.com/gin-contrib/sse v1.0.0 h1:y3bT1mUWUxDpW4JLQg/HnTqV4rozuW4tC9eFKTxYI9E=
 github.com/gin-contrib/sse v1.0.0/go.mod h1:zNuFdwarAygJBht0NTKiSi3jRf6RbqeILZ9Sp6Slhe0=
 github.com/gin-gonic/gin v1.10.0 h1:nTuyha1TYqgedzytsKYqna+DfLos46nTv2ygFy86HFU=
 github.com/gin-gonic/gin v1.10.0/go.mod h1:4PMNQiOhvDRa013RKVbsiNwoyezlm2rm0uX/T7kzp5Y=
+github.com/glebarez/go-sqlite v1.21.2 h1:3a6LFC4sKahUunAmynQKLZceZCOzUthkRkEAl9gAXWo=
+github.com/glebarez/go-sqlite v1.21.2/go.mod h1:sfxdZyhQjTM2Wry3gVYWaW072Ri1WMdWJi0k6+3382k=
+github.com/glebarez/sqlite v1.11.0 h1:wSG0irqzP6VurnMEpFGer5Li19RpIRi2qvQz++w0GMw=
+github.com/glebarez/sqlite v1.11.0/go.mod h1:h8/o8j5wiAsqSPoWELDUdJXhjAhsVliSn7bWZjOhrgQ=
+github.com/go-gormigrate/gormigrate/v2 v2.1.3 h1:ei3Vq/rpPI/jCJY9mRHJAKg5vU+EhZyWhBAkaAomQuw=
+github.com/go-gormigrate/gormigrate/v2 v2.1.3/go.mod h1:VJ9FIOBAur+NmQ8c4tDVwOuiJcgupTG105FexPFrXzA=
 github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s=
 github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4=
 github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA=
@@ -32,6 +40,10 @@ github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVI
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
 github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
+github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26 h1:Xim43kblpZXfIBQsbuBVKCudVG457BR2GZFIz3uw3hQ=
+github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26/go.mod h1:dDKJzRmX4S37WGHujM7tX//fmj1uioxKzKxz3lo4HJo=
+github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
+github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
 github.com/jinzhu/inflection v1.0.0/go.mod h1:h+uFLlag+Qp1Va5pdKtLDYj+kHp5pxUVkryuEj+Srlc=
 github.com/jinzhu/now v1.1.5 h1:/o9tlHleP7gOFmsnYNz3RGnqzefHA47wQpKrrdTIwXQ=
@@ -46,8 +58,6 @@ github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ=
 github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI=
 github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=
 github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=
-github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
-github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=
 github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg=
 github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q=
@@ -57,6 +67,9 @@ github.com/pelletier/go-toml/v2 v2.2.3 h1:YmeHyLY8mFWbdkNWwpr+qIL2bEqT0o95WSdkNH
 github.com/pelletier/go-toml/v2 v2.2.3/go.mod h1:MfCQTFTvCcUyyvvwm1+G6H/jORL20Xlb6rzQu9GuUkc=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
+github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=
+github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 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=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
@@ -93,8 +106,14 @@ gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-gorm.io/driver/sqlite v1.5.7 h1:8NvsrhP0ifM7LX9G4zPB97NwovUakUxc+2V2uuf3Z1I=
-gorm.io/driver/sqlite v1.5.7/go.mod h1:U+J8craQU6Fzkcvu8oLeAQmi50TkwPEhHDEjQZXDah4=
 gorm.io/gorm v1.25.12 h1:I0u8i2hWQItBq1WfE0o2+WuL9+8L21K9e2HHSTE/0f8=
 gorm.io/gorm v1.25.12/go.mod h1:xh7N7RHfYlNc5EmcI/El95gXusucDrQnHXe0+CgWcLQ=
+modernc.org/libc v1.22.5 h1:91BNch/e5B0uPbJFgqbxXuOnxBQjlS//icfQEGmvyjE=
+modernc.org/libc v1.22.5/go.mod h1:jj+Z7dTNX8fBScMVNRAYZ/jF91K8fdT2hYMThc3YjBY=
+modernc.org/mathutil v1.5.0 h1:rV0Ko/6SfM+8G+yKiyI830l3Wuz1zRutdslNoQ0kfiQ=
+modernc.org/mathutil v1.5.0/go.mod h1:mZW8CKdRPY1v87qxC/wUdX5O1qDzXMP5TH3wjfpga6E=
+modernc.org/memory v1.5.0 h1:N+/8c5rE6EqugZwHii4IFsaJ7MUhoWX07J5tC/iI5Ds=
+modernc.org/memory v1.5.0/go.mod h1:PkUhL0Mugw21sHPeskwZW4D6VscE/GQJOnIpCnW6pSU=
+modernc.org/sqlite v1.23.1 h1:nrSBg4aRQQwq59JpvGEQ15tNxoO5pX/kUjcRNwSAGQM=
+modernc.org/sqlite v1.23.1/go.mod h1:OrDj17Mggn6MhE+iPbBNf7RGKODDE9NFT0f3EwDzJqk=
 nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50=

internal/db/db.go

@@ -8,7 +8,7 @@ import (
 	"time"
 
 	"github.com/starfleetcptn/gomft/internal/auth"
-	"gorm.io/driver/sqlite"
+	"github.com/glebarez/sqlite"
 	"gorm.io/gorm"
 )
 
@@ -91,6 +91,7 @@ type TransferConfig struct {
 	ArchivePath     string `form:"archive_path"`
 	ArchiveEnabled  bool   `gorm:"default:false" form:"archive_enabled"`
 	RcloneFlags     string `form:"rclone_flags"`
+	DeleteAfterTransfer bool   `gorm:"default:false" form:"delete_after_transfer"`
 	CreatedBy       uint
 	User            User `gorm:"foreignkey:CreatedBy"`
 	CreatedAt       time.Time
@@ -135,7 +136,7 @@ func Initialize(dbPath string) (*DB, error) {
 		return nil, fmt.Errorf("failed to create database directory: %v", err)
 	}
 
-	// Open database connection
+	// Open database connection with modernc.org/sqlite driver
 	db, err := gorm.Open(sqlite.Open(dbPath), &gorm.Config{})
 	if err != nil {
 		return nil, fmt.Errorf("failed to connect to database: %v", err)

internal/db/migrations/add_delete_after_transfer.go

@@ -0,0 +1,19 @@
+package migrations
+
+import (
+	"github.com/go-gormigrate/gormigrate/v2"
+	"gorm.io/gorm"
+)
+
+// AddDeleteAfterTransferColumn adds the delete_after_transfer column to transfer_configs table
+func AddDeleteAfterTransferColumn() *gormigrate.Migration {
+	return &gormigrate.Migration{
+		ID: "add_delete_after_transfer_column",
+		Migrate: func(tx *gorm.DB) error {
+			return tx.Exec("ALTER TABLE transfer_configs ADD COLUMN delete_after_transfer BOOLEAN NOT NULL DEFAULT false").Error
+		},
+		Rollback: func(tx *gorm.DB) error {
+			return tx.Exec("ALTER TABLE transfer_configs DROP COLUMN delete_after_transfer").Error
+		},
+	}
+} 

internal/db/migrations/migrations.go

@@ -0,0 +1,16 @@
+package migrations
+
+import (
+	"github.com/go-gormigrate/gormigrate/v2"
+	"gorm.io/gorm"
+)
+
+// InitMigrations initializes the migrations
+func InitMigrations() *gormigrate.Gormigrate {
+	migrations := []*gormigrate.Migration{
+		// ... existing migrations
+		AddDeleteAfterTransferColumn(),
+	}
+	
+	return gormigrate.New(db, gormigrate.DefaultOptions, migrations)
+} 

internal/scheduler/scheduler.go

@@ -161,7 +161,7 @@ func (s *Scheduler) executeJob(jobID uint) {
 		"--config", configPath,
 		"size",
 		"--include", job.Config.FilePattern,
-		job.Config.SourcePath,
+		fmt.Sprintf("source_%d:%s", job.Config.ID, job.Config.SourcePath),
 	}
 	// Get the rclone path from the environment variable or use the default path
 	rclonePath := os.Getenv("RCLONE_PATH")
@@ -169,9 +169,16 @@ func (s *Scheduler) executeJob(jobID uint) {
 		rclonePath = "rclone"
 	}
 	output, err := exec.Command(rclonePath, sizeArgs...).CombinedOutput()
-	fmt.Printf("Running rclone size: %v\nOutput: %s\n", sizeArgs, output)
+	fmt.Printf("Running rclone size: %s %s\nOutput: %s\n", rclonePath, strings.Join(sizeArgs, " "), output)
 	if err != nil {
 		fmt.Printf("Error running rclone size: %v\nOutput: %s\n", err, output)
+		// Update job history with error
+		history.Status = "failed"
+		history.ErrorMessage = fmt.Sprintf("Size calculation error: %v\nOutput: %s", err, string(output))
+		history.EndTime = &startTime // Use start time as end time for a quick failure
+		if err := s.db.UpdateJobHistory(history); err != nil {
+			fmt.Printf("Error updating job history for job %d: %v\n", jobID, err)
+		}
 		return
 	}
 
@@ -232,7 +239,7 @@ func (s *Scheduler) executeJob(jobID uint) {
 			// Prepare moveto command for transfer
 			transferArgs := []string{
 				"--config", configPath,
-				"moveto",
+				"copyto",
 				"--progress",
 				"--stats-one-line",
 				"--verbose",
@@ -317,6 +324,21 @@ func (s *Scheduler) executeJob(jobID uint) {
 							fmt.Sprintf("Archive error for file %s: %v", file, archiveErr))
 					}
 				}
+				if job.Config.DeleteAfterTransfer {
+					fmt.Printf("Deleting file %s for job %d\n", file, jobID)
+					deleteArgs := []string{
+						"--config", configPath,
+						"deletefile",
+						sourcePath,					}
+					deleteCmd := exec.Command(rclonePath, deleteArgs...)
+					deleteOutput, deleteErr := deleteCmd.CombinedOutput()
+					fmt.Printf("Output for file %s: %s\n", file, string(deleteOutput))
+					if deleteErr != nil {
+						fmt.Printf("Error deleting file %s for job %d: %v\n", file, jobID, deleteErr)
+						transferErrors = append(transferErrors, 
+							fmt.Sprintf("Delete error for file %s: %v", file, deleteErr))
+					}
+				}
 			}
 		}
 		

internal/web/handlers/api_handlers.go

@@ -248,8 +248,48 @@ func (h *Handlers) HandleAPIDeleteJob(c *gin.Context) {
 
 // HandleAPIRunJob handles the API run job request
 func (h *Handlers) HandleAPIRunJob(c *gin.Context) {
-	// Implementation will be moved from the old handlers.go
+	id := c.Param("id")
-	c.JSON(http.StatusOK, gin.H{"message": "API run job handler stub"})
+	userID := c.GetUint("userID")
+	
+	var job db.Job
+	if err := h.DB.First(&job, id).Error; err != nil {
+		c.JSON(http.StatusNotFound, gin.H{"error": "Job not found"})
+		return
+	}
+
+	// Check if user owns this job
+	if job.CreatedBy != userID {
+		// Check if user is admin
+		isAdmin, exists := c.Get("isAdmin")
+		if !exists || isAdmin != true {
+			c.JSON(http.StatusForbidden, gin.H{"error": "You do not have permission to run this job"})
+			return
+		}
+	}
+
+	// Determine job name for response
+	jobName := job.Name
+	if jobName == "" {
+		// If job name is empty, try to get config name
+		var config db.TransferConfig
+		if err := h.DB.First(&config, job.ConfigID).Error; err == nil {
+			jobName = config.Name
+		} else {
+			jobName = fmt.Sprintf("Job #%d", job.ID)
+		}
+	}
+
+	// Run the job immediately using the scheduler
+	if err := h.Scheduler.RunJobNow(job.ID); err != nil {
+		c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to run job: " + err.Error()})
+		return
+	}
+	
+	c.JSON(http.StatusOK, gin.H{
+		"message": "Job started successfully",
+		"jobId":   job.ID,
+		"jobName": jobName,
+	})
 }
 
 // HandleAPIHistory handles the API history request

internal/web/handlers/job_handlers.go

@@ -1,6 +1,7 @@
 package handlers
 
 import (
+	"fmt"
 	"net/http"
 
 	"github.com/gin-gonic/gin"
@@ -274,7 +275,8 @@ func (h *Handlers) HandleRunJob(c *gin.Context) {
 	
 	var job db.Job
 	if err := h.DB.First(&job, id).Error; err != nil {
-		c.JSON(http.StatusNotFound, gin.H{"error": "Job not found"})
+		c.Header("Content-Type", "text/html")
+		c.String(http.StatusNotFound, "<script>window.notyfInstance.error('Job not found')</script>")
 		return
 	}
 
@@ -283,19 +285,37 @@ func (h *Handlers) HandleRunJob(c *gin.Context) {
 		// Check if user is admin
 		isAdmin, exists := c.Get("isAdmin")
 		if !exists || isAdmin != true {
-			c.JSON(http.StatusForbidden, gin.H{"error": "You do not have permission to run this job"})
+			c.Header("Content-Type", "text/html")
+			c.String(http.StatusForbidden, "<script>window.notyfInstance.error('You do not have permission to run this job')</script>")
 			return
 		}
 	}
 
+	// Determine job name for response
+	jobName := job.Name
+	if jobName == "" {
+		// If job name is empty, try to get config name
+		var config db.TransferConfig
+		if err := h.DB.First(&config, job.ConfigID).Error; err == nil {
+			jobName = config.Name
+		} else {
+			jobName = fmt.Sprintf("Job #%d", job.ID)
+		}
+	}
+
 	// Run the job immediately using the scheduler
 	if err := h.Scheduler.RunJobNow(job.ID); err != nil {
-		c.JSON(http.StatusInternalServerError, gin.H{"error": "Failed to run job: " + err.Error()})
+		c.Header("Content-Type", "text/html")
+		errorMsg := fmt.Sprintf("<script>window.notyfInstance.error('Failed to run job: %s')</script>", err.Error())
+		c.String(http.StatusInternalServerError, errorMsg)
 		return
 	}
 
-	c.JSON(http.StatusOK, gin.H{
+	// Set custom header with job name for HTMX to use in the toast notification
-		"message": "Job started successfully",
+	c.Header("HX-Job-Name", jobName)
-		"jobId":   job.ID,
+	c.Header("Content-Type", "text/html")
-	})
+	
+	// Return HTML with JavaScript to trigger the notification
+	successScript := fmt.Sprintf("<script>window.notyfInstance.success('Job \"%s\" has been started successfully')</script>", jobName)
+	c.String(http.StatusOK, successScript)
 }