96 lines
2.2 KiB
Go
96 lines
2.2 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"embed"
|
|
"flag"
|
|
"fmt"
|
|
"log"
|
|
"net/http"
|
|
|
|
"github.com/joho/godotenv"
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/labstack/echo/v4/middleware"
|
|
|
|
"goth.stack/api"
|
|
"goth.stack/lib"
|
|
"goth.stack/lib/pubsub"
|
|
"goth.stack/lib/pubsub/adapters"
|
|
"goth.stack/pages"
|
|
)
|
|
|
|
//go:embed public/*
|
|
var PublicFS embed.FS
|
|
|
|
func main() {
|
|
// Load environment variables
|
|
godotenv.Load(".env")
|
|
|
|
// Initialize Redis client
|
|
adapters.RedisClient = adapters.NewRedisClient()
|
|
|
|
// Test Redis connection
|
|
_, err := adapters.RedisClient.Ping(context.Background()).Result()
|
|
|
|
// Initialize pubsub
|
|
var pubSub pubsub.PubSub
|
|
if err != nil {
|
|
lib.LogWarning.Printf("\n[PUBSUB/INIT] Failed to connect to Redis: %v\n", err)
|
|
lib.LogWarning.Printf("\n[PUBSUB/INIT] Falling back to LocalPubSub\n")
|
|
pubSub = &adapters.LocalPubSub{}
|
|
} else {
|
|
pubSub = &adapters.RedisPubSub{
|
|
Client: adapters.RedisClient,
|
|
}
|
|
}
|
|
|
|
// Initialize Echo router
|
|
e := echo.New()
|
|
|
|
// Middleware
|
|
e.Use(middleware.Logger())
|
|
e.Use(middleware.Recover())
|
|
e.Pre(middleware.RemoveTrailingSlash())
|
|
e.Use(middleware.RequestID())
|
|
e.Use(middleware.Secure())
|
|
e.Use(middleware.GzipWithConfig(middleware.GzipConfig{
|
|
Level: 5,
|
|
}))
|
|
e.Use(middleware.RateLimiter(middleware.NewRateLimiterMemoryStore(50)))
|
|
|
|
// Static server
|
|
fs := http.FS(PublicFS)
|
|
e.GET("/public/*", echo.WrapHandler(http.FileServer(fs)))
|
|
|
|
// Page routes
|
|
e.GET("/", pages.Home)
|
|
e.GET("/blog", pages.Blog)
|
|
e.GET("/post/:post", pages.Post)
|
|
e.GET("/sse", pages.SSEDemo)
|
|
e.GET("/rss", pages.RSSFeedHandler)
|
|
|
|
// API Routes:
|
|
apiGroup := e.Group("/api")
|
|
apiGroup.GET("/ping", api.Ping)
|
|
|
|
apiGroup.GET("/sse", func(c echo.Context) error {
|
|
return api.SSE(c, pubSub)
|
|
})
|
|
|
|
apiGroup.POST("/sendsse", func(c echo.Context) error {
|
|
return api.SSEDemoSend(c, pubSub)
|
|
})
|
|
|
|
// Parse command-line arguments for IP and port
|
|
ip := flag.String("ip", "", "IP address to bind the server to")
|
|
port := flag.String("port", "3000", "Port to bind the server to")
|
|
flag.Parse()
|
|
|
|
// Start server with HTTP/2 support
|
|
s := &http.Server{
|
|
Addr: fmt.Sprintf("%s:%s", *ip, *port),
|
|
Handler: e,
|
|
}
|
|
e.Logger.Fatal(e.StartServer(s))
|
|
log.Println("Server started on port", *port)
|
|
}
|