Merge pull request #9 from zrougamed/feature/instant-notification

Add Instant Notification Endpoint and Config Fixes ✉️⚙️

config/config.go

@@ -50,6 +50,13 @@ type ScheduledJob struct {
 	LastRun            sql.NullTime `json:"last_run,omitempty"`
 }
 
+// InstantJob struct
+type InstantJob struct {
+	NotificationType string  `json:"notification_type"`
+	Recipient        string  `json:"recipient"`
+	Message          Message `json:"message"`
+}
+
 type Notifier interface {
 	Name() string
 	Type() string

main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"dynamic-notification-system/config"
+	"dynamic-notification-system/notifier"
 	"dynamic-notification-system/plugins"
 	"dynamic-notification-system/scheduler"
 	"fmt"
@@ -25,6 +26,9 @@ func main() {
 		log.Fatalf("Error loading plugins: %v", err)
 	}
 
+	// Pass the loaded notifiers to the notifier package
+	notifier.SetNotifiers(notifiers)
+
 	// Initialize Scheduler if enabled
 	if cfg.Scheduler {
 		fmt.Println("Starting scheduled jobs...")
@@ -39,12 +43,15 @@ func main() {
 
 	r := mux.NewRouter()
 	if cfg.Scheduler {
+		// Scheduled notification endpoints
 		r.HandleFunc("/schema/job", scheduler.GetJobSchema())
 		r.HandleFunc("/jobs", scheduler.HandlePostJob).Methods("POST")
 		r.HandleFunc("/jobs", scheduler.HandleGetJobs).Methods("GET")
 	} else {
 		fmt.Println("Scheduling endpoints are disabled.")
 	}
+	// Instant notification endpoint
+	r.HandleFunc("/notify", notifier.HandlePostJob).Methods("POST")
 
 	fmt.Println("Server listening on port 8080")
 	log.Fatal(http.ListenAndServe(":8080", r))

notifier/notifier.go

@@ -0,0 +1,50 @@
+package notifier
+
+import (
+	"dynamic-notification-system/config"
+	"encoding/json"
+	"fmt"
+	"log"
+	"net/http"
+)
+
+var notifiers []config.Notifier
+
+// SetNotifiers initializes the notifiers
+func SetNotifiers(n []config.Notifier) {
+	notifiers = n
+}
+
+func HandlePostJob(w http.ResponseWriter, r *http.Request) {
+	var job config.InstantJob
+
+	err := json.NewDecoder(r.Body).Decode(&job)
+	if err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+
+	if err := validateJob(&job); err != nil {
+		http.Error(w, err.Error(), http.StatusBadRequest)
+		return
+	}
+	jobCopy := job
+	for _, notifier := range notifiers {
+		if notifier.Type() == jobCopy.NotificationType {
+			fmt.Printf("Running job: %s \n", jobCopy.Recipient)
+			err := notifier.Notify(&jobCopy.Message)
+			if err != nil {
+				log.Printf("Error sending notification via %s: %v", notifier.Name(), err)
+			}
+		}
+	}
+	w.WriteHeader(http.StatusCreated)
+	json.NewEncoder(w).Encode(job)
+}
+
+func validateJob(job *config.InstantJob) error { // add instant notification
+	if job.NotificationType == "" {
+		return fmt.Errorf("NotificationType is required")
+	}
+	return nil
+}