Rename API endpoints

BBVA · Nov 30, 2018 · ed55a77 · ed55a77
1 parent 981c615
commit ed55a77
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/gossip/processor.go b/gossip/processor.go
@@ -37,7 +37,7 @@ type DummyProcessor struct {
 
 func (d DummyProcessor) Process(b *protocol.BatchSnapshots) {
 	for i := 0; i < len(b.Snapshots); i++ {
-		res, err := http.Get(fmt.Sprintf("http://127.0.0.1:8888/?nodeType=auditor&id=%d", b.Snapshots[0].Snapshot.Version))
+		res, err := http.Get(fmt.Sprintf("http://127.0.0.1:8888/stat/?nodeType=auditor&id=%d", b.Snapshots[0].Snapshot.Version))
 		if err != nil || res == nil {
 			log.Debugf("Error contacting service with error %v", err)
 		}

diff --git a/gossip/publisher/publisher.go b/gossip/publisher/publisher.go
@@ -59,7 +59,7 @@ func (p *Publisher) Process(b *protocol.BatchSnapshots) {
 
 	req := fasthttp.AcquireRequest()
 	// TODO: Implement send to different endpoints
-	req.SetRequestURI(p.Config.SendTo[0] + "/publish")
+	req.SetRequestURI(p.Config.SendTo[0] + "/batch")
 	req.Header.SetMethodBytes([]byte("POST"))
 	req.Header.Add("Content-Type", "application/json")
 	req.SetBody(body)

diff --git a/tests/gossip/test_service.go b/tests/gossip/test_service.go
@@ -92,7 +92,7 @@ func statHandler(w http.ResponseWriter, r *http.Request) {
 	atomic.AddUint64(&count, 1)
 }
 
-func putHandler(kv *kv) func(http.ResponseWriter, *http.Request) {
+func postBatchHandler(kv *kv) func(http.ResponseWriter, *http.Request) {
 
 	return func(w http.ResponseWriter, r *http.Request) {
 		if r.Method == "POST" {
@@ -115,7 +115,8 @@ func putHandler(kv *kv) func(http.ResponseWriter, *http.Request) {
 		http.Error(w, "Invalid request method", http.StatusMethodNotAllowed)
 	}
 }
-func getHandler(kv *kv) func(http.ResponseWriter, *http.Request) {
+
+func getSnapshotHandler(kv *kv) func(http.ResponseWriter, *http.Request) {
 	return func(w http.ResponseWriter, r *http.Request) {
 		if r.Method == "GET" {
 			q := r.URL.Query()
@@ -135,6 +136,7 @@ func getHandler(kv *kv) func(http.ResponseWriter, *http.Request) {
 		http.Error(w, "Invalid request method", http.StatusMethodNotAllowed)
 	}
 }
+
 func main() {
 	var store kv
 
@@ -155,7 +157,7 @@ func main() {
 	}()
 
 	http.HandleFunc("/stat", statHandler)
-	http.HandleFunc("/put", putHandler(&store))
-	http.HandleFunc("/get", getHandler(&store))
+	http.HandleFunc("/batch", postBatchHandler(&store))
+	http.HandleFunc("/snapshot/{id}", getSnapshotHandler(&store))
 	log.Fatal(http.ListenAndServe("127.0.0.1:8888", nil))
 }