6830c8879f
* feat(server): moved an http server object into a pkg subdir to be reusable for http, spots, and integrations * feat(web): isolated web module (server, router, middleware, utils) used in spots and new integrations * feat(web): removed possible panic * feat(web): split all handlers from http service into different packages for better management. * feat(web): changed router's method signature * feat(web): added missing handlers interface * feat(web): added health middleware to remove unnecessary checks * feat(web): customizable middleware set for web servers * feat(web): simplified the handler's structure * feat(web): created an unified server.Run method for all web services (http, spot, integrations) * feat(web): fixed a json size limit issue * feat(web): removed Keys and PG connection from router * feat(web): simplified integration's main file * feat(web): simplified spot's main file * feat(web): simplified http's main file (builder) * feat(web): refactored audit trail functionality * feat(web): added ee version of audit trail * feat(web): added ee version of conditions module * feat(web): moved ee version of some web session structs * feat(web): new format of web metrics * feat(web): added new web metrics to all handlers * feat(web): added justExpired feature to web ingest handler * feat(web): added small integrations improvements
54 lines
1.5 KiB
Go
54 lines
1.5 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
|
|
"openreplay/backend/internal/config/http"
|
|
"openreplay/backend/internal/http/services"
|
|
"openreplay/backend/pkg/db/postgres/pool"
|
|
"openreplay/backend/pkg/db/redis"
|
|
"openreplay/backend/pkg/logger"
|
|
"openreplay/backend/pkg/metrics"
|
|
databaseMetrics "openreplay/backend/pkg/metrics/database"
|
|
"openreplay/backend/pkg/metrics/web"
|
|
"openreplay/backend/pkg/queue"
|
|
"openreplay/backend/pkg/server"
|
|
"openreplay/backend/pkg/server/api"
|
|
)
|
|
|
|
func main() {
|
|
ctx := context.Background()
|
|
log := logger.New()
|
|
cfg := http.New(log)
|
|
webMetrics := web.New("http")
|
|
metrics.New(log, append(webMetrics.List(), databaseMetrics.List()...))
|
|
|
|
producer := queue.NewProducer(cfg.MessageSizeLimit, true)
|
|
defer producer.Close(15000)
|
|
|
|
pgConn, err := pool.New(cfg.Postgres.String())
|
|
if err != nil {
|
|
log.Fatal(ctx, "can't init postgres connection: %s", err)
|
|
}
|
|
defer pgConn.Close()
|
|
|
|
redisClient, err := redis.New(&cfg.Redis)
|
|
if err != nil {
|
|
log.Info(ctx, "no redis cache: %s", err)
|
|
}
|
|
defer redisClient.Close()
|
|
|
|
builder, err := services.New(log, cfg, webMetrics, producer, pgConn, redisClient)
|
|
if err != nil {
|
|
log.Fatal(ctx, "failed while creating services: %s", err)
|
|
}
|
|
|
|
router, err := api.NewRouter(&cfg.HTTP, log)
|
|
if err != nil {
|
|
log.Fatal(ctx, "failed while creating router: %s", err)
|
|
}
|
|
router.AddHandlers(api.NoPrefix, builder.WebAPI, builder.MobileAPI, builder.ConditionsAPI, builder.FeatureFlagsAPI,
|
|
builder.TagsAPI, builder.UxTestsAPI)
|
|
|
|
server.Run(ctx, log, &cfg.HTTP, router)
|
|
}
|