config: updates the config related changes in schemas, CRUD and logic (…

…#101)

* updates the config related changes in schemas and logic

* updates schema and adds table for scanNotify

* adds simple CRUD for scannotify

* modularize the notifier for systems like linear, jirs etc

* adds logic of notifier who would poll evaluate the conditions and create issues

* comments unwanted struct for now until thought better

cmd/agent.go

@@ -225,6 +225,13 @@ func processTask(server, token string, task agenttasks.GetAgentTaskResponse, wor
 		return
 	}
 
+	// step 6: Verify scans.Notify field exist
+	// Todo: if exists update the status to notify_pending else complete
+	err = updateScanStatus(server, token, scan.ID, "notify_pending")
+	if err != nil {
+		log.Printf("Failed to update scan status to 'scan_in_progress': %v", err)
+	}
+
 	if err := updateAgentTaskStatus(server, token, task.ID, agentID, "complete"); err != nil {
 		log.Printf("Failed to update agent_task status to 'complete': %v", err)
 	}
@@ -356,7 +363,6 @@ func uploadReport(server, token string, scanID uuid.UUID, reportPath string) err
 	reqBody := scans.UpdateScanRequest{
 		ID:     scanID,
 		Report: json.RawMessage(report),
-		Status: strPtr("success"),
 	}
 	reqBodyJSON, err := json.Marshal(reqBody)
 	if err != nil {

cmd/server.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"github.com/shinobistack/gokakashi/internal/assigner"
 	"github.com/shinobistack/gokakashi/internal/db"
+	"github.com/shinobistack/gokakashi/internal/notifier"
 	"log"
 	"os"
 	"os/signal"
@@ -82,11 +83,9 @@ func handleConfigV1() {
 	if err != nil {
 		log.Fatalf("Error: %v", err)
 	}
-
-	// ToDo: To set a separate connection for API calls
-	// Initialize a separate connection for API calls
-	//apiDB := restapiv1.InitDB()
-	//defer apiDB.Close()
+	// Todo: To implement connection pooling. Explore and implement.
+	//dbClient := restapiv1.InitDB(cfg.Database)
+	//defer dbClient.Close()
 
 	log.Println("Starting API server for scan functionality...")
 	s := &restapiv1.Server{
@@ -98,16 +97,18 @@ func handleConfigV1() {
 	go s.Serve()
 
 	dbConfig := cfg.Database
+
 	// Initialize a separate connection for configuration tasks
 	configDB := restapiv1.InitDB(dbConfig)
 	defer configDB.Close()
-
 	db.RunMigrations(configDB)
 	// Populate the database
 	db.PopulateDatabase(configDB, cfg)
 
 	// ToDo: To be go routine who independently and routinely checks and assigns scans in agentTasks table
 	go assigner.StartAssigner(cfg.Site.Host, cfg.Site.Port, cfg.Site.APIToken, 1*time.Minute)
+	// Todo: To introduce API calls for scanNotify and remove client passing
+	go notifier.StartScanNotifier(cfg.Site.Host, cfg.Site.Port, cfg.Site.APIToken, 1*time.Minute)
 
 }