Orchestrator webhook JSON to require "address" field

livepeer · Jan 16, 2025 · 9503cd2 · 9503cd2
1 parent 1a4c7c7
commit 9503cd2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 8 deletions.
diff --git a/discovery/wh_discovery.go b/discovery/wh_discovery.go
@@ -16,7 +16,7 @@ import (
 )
 
 type webhookResponse struct {
-	Address string  `json:"address,omitempty"`
+	Address string  `json:"address"`
 	Score   float32 `json:"score,omitempty"`
 }
 
@@ -147,12 +147,9 @@ func deserializeWebhookJSON(body []byte) ([]common.OrchestratorLocalInfo, error)
 	}
 	var infos []common.OrchestratorLocalInfo
 	for _, addr := range addrs {
-		if addr.Address == "" {
-			continue
-		}
 		uri, err := url.ParseRequestURI(addr.Address)
 		if err != nil {
-			glog.Errorf("Unable to parse address  %q : %s", addr.Address, err)
+			glog.Errorf("Unable to parse address %q : %s", addr.Address, err)
 			continue
 		}
 		infos = append(infos, common.OrchestratorLocalInfo{URL: uri, Score: addr.Score})

diff --git a/doc/orchwebhook.md b/doc/orchwebhook.md
@@ -9,9 +9,9 @@ For example:
 
 ```json
 [
-    {"address":"https://10.4.3.2:8935"},
-    {"address":"https://10.4.4.3:8935"},
-    {"address":"https://10.4.5.2:8935"}
+    {"address":"https://10.4.3.2:8935", "score": 1.0},
+    {"address":"https://10.4.4.3:8935", "score": 1.0},
+    {"address":"https://10.4.5.2:8935", "score": 1.0}
 ]
 ```