From c7b352dba3d45a79545bb0704c8600de800decb0 Mon Sep 17 00:00:00 2001
From: Denis Gukov <denguk@gmail.com>
Date: Mon, 30 Sep 2024 00:58:21 +0500
Subject: [PATCH] fix(be): null pointer

---
 api/router.go                |  8 +++++++-
 services/runners/job_pool.go | 25 ++++++++++---------------
 2 files changed, 17 insertions(+), 16 deletions(-)

diff --git a/api/router.go b/api/router.go
index 983a87bd..29800f24 100644
--- a/api/router.go
+++ b/api/router.go
@@ -457,10 +457,16 @@ func serveFile(w http.ResponseWriter, r *http.Request, name string) {
 }
 
 func getSystemInfo(w http.ResponseWriter, r *http.Request) {
+	host := ""
+
+	if util.WebHostURL != nil {
+		host = util.WebHostURL.String()
+	}
+
 	body := map[string]interface{}{
 		"version":           util.Version(),
 		"ansible":           util.AnsibleVersion(),
-		"web_host":          util.WebHostURL.String(),
+		"web_host":          host,
 		"use_remote_runner": util.Config.UseRemoteRunner,
 	}
 
diff --git a/services/runners/job_pool.go b/services/runners/job_pool.go
index fef27e31..8fadc8dd 100644
--- a/services/runners/job_pool.go
+++ b/services/runners/job_pool.go
@@ -29,7 +29,7 @@ type JobPool struct {
 
 	queue []*job
 
-	token *string
+	//token *string
 
 	processing int32
 }
@@ -106,7 +106,7 @@ func (p *JobPool) Unregister() (err error) {
 
 func (p *JobPool) Run() {
 
-	if p.token == nil {
+	if util.Config.Runner.Token == "" {
 		panic("runner token required. Please register runner first or create it from web interface.")
 	}
 
@@ -194,7 +194,7 @@ func (p *JobPool) sendProgress() {
 
 	client := &http.Client{}
 
-	url := util.Config.Runner.Webhook + "/api/internal/runners"
+	url := util.Config.WebHost + "/api/internal/runners"
 
 	body := RunnerProgress{
 		Jobs: nil,
@@ -224,7 +224,7 @@ func (p *JobPool) sendProgress() {
 		return
 	}
 
-	req.Header.Set("X-Runner-Token", *p.token)
+	req.Header.Set("X-Runner-Token", util.Config.Runner.Token)
 
 	resp, err := client.Do(req)
 	if err != nil {
@@ -236,16 +236,13 @@ func (p *JobPool) sendProgress() {
 }
 
 func (p *JobPool) tryRegisterRunner() bool {
-	if p.token != nil {
-		return true
-	}
 
 	log.Info("Attempting to register on the server")
 
-	if util.Config.Runner.Token != "" {
-		p.token = &util.Config.Runner.Token
-		return true
-	}
+	//if util.Config.Runner.Token != "" {
+	//	p.token = &util.Config.Runner.Token
+	//	return true
+	//}
 
 	// Can not restore runner configuration. Register new runner on the server.
 
@@ -297,8 +294,6 @@ func (p *JobPool) tryRegisterRunner() bool {
 
 	err = os.WriteFile(util.Config.Runner.TokenFile, []byte(res.Token), 0644)
 
-	p.token = &res.Token
-
 	defer resp.Body.Close()
 
 	return true
@@ -307,7 +302,7 @@ func (p *JobPool) tryRegisterRunner() bool {
 // checkNewJobs tries to find runner to queued jobs
 func (p *JobPool) checkNewJobs() {
 
-	if p.token == nil {
+	if util.Config.Runner.Token == "" {
 		fmt.Println("Error creating request:", "no token provided")
 		return
 	}
@@ -318,7 +313,7 @@ func (p *JobPool) checkNewJobs() {
 
 	req, err := http.NewRequest("GET", url, nil)
 
-	req.Header.Set("X-Runner-Token", *p.token)
+	req.Header.Set("X-Runner-Token", util.Config.Runner.Token)
 
 	if err != nil {
 		fmt.Println("Error creating request:", err)