Prepare to merge master

This commit is contained in:
Héctor Hurtado
2019-10-08 09:40:51 +02:00
parent 7fdef70e39
commit bb0a283813
2 changed files with 9 additions and 54 deletions
+8 -37
View File
@@ -2,14 +2,8 @@ package server
import (
"fmt"
"log"
"net/url"
"os"
"strconv"
"github.com/BBVA/kapow/server/control"
"github.com/BBVA/kapow/server/data"
"github.com/BBVA/kapow/server/user"
)
// StartServer Starts one instance of each server in a goroutine and remains listening on a channel for trace events generated by them
@@ -26,37 +20,14 @@ func StartServer(bindAddr, certfile, keyfile string, interactive bool) error {
return fmt.Errorf("Error extracting port from provided address %s", bindAddr)
}
if certfile != "" {
if _, err := os.Stat(certfile); err != nil {
if os.IsNotExist(err) {
return fmt.Errorf("Certfile %s does not exist", certfile)
}
}
}
ctrlBindAddr := fmt.Sprintf("%s:%d", userBindAddr.Host, userPort+1)
dataBindAddr := fmt.Sprintf("%s:%d", userBindAddr.Host, userPort+2)
if keyfile != "" {
if _, err := os.Stat(keyfile); err != nil {
if os.IsNotExist(err) {
return fmt.Errorf("Keyfile %s does not exist", keyfile)
}
}
}
fmt.Printf("User server bind address: %s, Control server bind address: %s, Data server bind address: %s", bindAddr, ctrlBindAddr, dataBindAddr)
//go ctrlServer.Start(traceChannel)
//go dataServer.Start(traceChannel)
//go ctrlServer.Start(traceChannel)
ctrlPort := userPort + 1
dataPort := ctrlPort + 1
dataServer := data.NewDataServer(userBindAddr.Host(), dataPort, certfile, keyfile)
ctrlServer := control.NewControlServer(userBindAddr.Host(), ctrlPort, certfile, keyfile) // Needs a reference to the user server in order to manage routes
userServer := user.NewUserServer(userBindAddr.Host(), controlServerPort, certfile, keyfile) // Needs a reference to the data server in order to manage handlers
traceChannel := make(chan string)
go ctrlServer.Start(traceChannel)
go dataServer.Start(traceChannel)
go ctrlServer.Start(traceChannel)
// Wait for ever while writing logs
for {
log.Print(<-traceChannel)
}
// Wait for ever
select {}
}