this repo has no description
:truck: created internal dir
+20
-11
+14
internal/server.go
+14
internal/server.go
···
1
+
package internal
2
+
3
+
import "net/http"
4
+
5
+
func NewServer(port string) error {
6
+
pubsub := NewPubSub()
7
+
8
+
r := &http.ServeMux{}
9
+
r.HandleFunc("GET /subscribe", middlewareRequestId(middlewareTopicQueryParam(pubsub.HandleSubscribe)))
10
+
r.HandleFunc("POST /publish", middlewareRequestId(middlewareTopicQueryParam(pubsub.HandlePublish)))
11
+
12
+
server := http.Server{Addr: ":" + port, Handler: r}
13
+
return server.ListenAndServe()
14
+
}
+4
-9
main.go
+4
-9
main.go
···
3
3
import (
4
4
"fmt"
5
5
"log"
6
-
"net/http"
6
+
7
+
"github.com/Tulkdan/go-sse/internal"
7
8
)
8
9
9
10
func main() {
10
-
pubsub := NewPubSub()
11
+
fmt.Println("Starting server on 0.0.0.0:8000")
11
12
12
-
r := &http.ServeMux{}
13
-
r.HandleFunc("GET /subscribe", middlewareRequestId(middlewareTopicQueryParam(pubsub.HandleSubscribe)))
14
-
r.HandleFunc("POST /publish", middlewareRequestId(middlewareTopicQueryParam(pubsub.HandlePublish)))
15
-
16
-
server := http.Server{Addr: ":8000", Handler: r}
17
-
fmt.Println("Starting server on 0.0.0.0:8000")
18
-
if err := server.ListenAndServe(); err != nil {
13
+
if err := internal.NewServer("8000"); err != nil {
19
14
log.Fatal(err)
20
15
} else {
21
16
fmt.Println("Killing server")
+1
-1
middleware.go
internal/middleware.go
+1
-1
middleware.go
internal/middleware.go