api.odds-worklog/main.go at develop · oddsteam/api.odds-worklog · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package main

import (
	"log"
	"os"

	"github.com/joho/godotenv"
	"gitlab.odds.team/worklog/api.odds-worklog/api/file"

	"github.com/labstack/echo"
	"github.com/labstack/echo/middleware"
	"gitlab.odds.team/worklog/api.odds-worklog/api/income"
	income_from_timesheet "gitlab.odds.team/worklog/api.odds-worklog/api/income_from_timesheet"
	"gitlab.odds.team/worklog/api.odds-worklog/api/login"
	sap_export_failure "gitlab.odds.team/worklog/api.odds-worklog/api/sap_export_failure"
	"gitlab.odds.team/worklog/api.odds-worklog/api/site"
	"gitlab.odds.team/worklog/api.odds-worklog/api/user"
	"gitlab.odds.team/worklog/api.odds-worklog/business/models"
	"gitlab.odds.team/worklog/api.odds-worklog/business/usecases"
	"gitlab.odds.team/worklog/api.odds-worklog/pkg/config"
	"gitlab.odds.team/worklog/api.odds-worklog/pkg/mongo"
	"gitlab.odds.team/worklog/api.odds-worklog/pkg/timesheetconsumer"
	"gitlab.odds.team/worklog/api.odds-worklog/repositories"
)

// @title Odds-Worklog Example API
// @version 1.0
// @description This is a sample server odds-worklog server.
// @host http://worklog-dev.odds.team/api
// @BasePath /v1
func main() {
	_ = godotenv.Load()
	jwtSigningKey := os.Getenv("JWT_SIGNING_KEY")
	if jwtSigningKey == "" {
		log.Fatal("JWT_SIGNING_KEY environment variable is required")
	}

	session := mongo.Setup()
	defer session.Close()

	c := config.Config()
	go timesheetconsumer.Start(timesheetconsumer.Config{
		URL:        c.RabbitMQURL,
		Exchange:   c.RabbitMQExchange,
		Queue:      c.RabbitMQQueue,
		RoutingKey: c.RabbitMQRoutingKey,
	}, usecases.NewSyncIncomeFromTimesheetUsecase(
		repositories.NewIncomeFromTimesheetRepository(session),
		user.NewTimesheetUserRepository(session),
		repositories.NewTimesheetEventLogRepository(session),
	))

	// Echo instance
	e := echo.New()

	e.Use(middleware.CORSWithConfig(middleware.CORSConfig{
		AllowHeaders: []string{echo.HeaderOrigin, echo.HeaderContentType, echo.HeaderAccept, echo.HeaderAuthorization},
	}))
	e.Use(middleware.Logger())
	e.Use(middleware.Recover())

	// Middleware
	m := middleware.JWTConfig{
		Claims:     &models.JwtCustomClaims{},
		SigningKey: []byte(jwtSigningKey),
	}

	r := e.Group("/v1")
	login.NewHttpHandler(r, session)
	r.Use(middleware.JWTWithConfig(m))

	// Handler
	user.NewHttpHandler(r, session)
	income.NewHttpHandler(r, session)
	income_from_timesheet.NewHttpHandler(r, session)
	file.NewHttpHandler(r, session)
	site.NewHttpHandler(r, session)
	sap_export_failure.NewHttpHandler(r, session)

	// Start server
	e.Logger.Fatal(e.Start(c.APIPort))
}