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
43 lines
1.2 KiB
Go
43 lines
1.2 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
|
|
config "openreplay/backend/internal/config/integrations"
|
|
"openreplay/backend/pkg/db/postgres/pool"
|
|
"openreplay/backend/pkg/integrations"
|
|
"openreplay/backend/pkg/logger"
|
|
"openreplay/backend/pkg/metrics"
|
|
"openreplay/backend/pkg/metrics/database"
|
|
"openreplay/backend/pkg/metrics/web"
|
|
"openreplay/backend/pkg/server"
|
|
"openreplay/backend/pkg/server/api"
|
|
)
|
|
|
|
func main() {
|
|
ctx := context.Background()
|
|
log := logger.New()
|
|
cfg := config.New(log)
|
|
webMetrics := web.New("integrations")
|
|
metrics.New(log, append(webMetrics.List(), database.List()...))
|
|
|
|
pgConn, err := pool.New(cfg.Postgres.String())
|
|
if err != nil {
|
|
log.Fatal(ctx, "can't init postgres connection: %s", err)
|
|
}
|
|
defer pgConn.Close()
|
|
|
|
builder, err := integrations.NewServiceBuilder(log, cfg, webMetrics, pgConn)
|
|
if err != nil {
|
|
log.Fatal(ctx, "can't init 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.IntegrationsAPI)
|
|
router.AddMiddlewares(builder.Auth.Middleware, builder.RateLimiter.Middleware, builder.AuditTrail.Middleware)
|
|
|
|
server.Run(ctx, log, &cfg.HTTP, router)
|
|
}
|