93 lines
2.4 KiB
Go
93 lines
2.4 KiB
Go
package main
|
|
|
|
import (
|
|
"flag"
|
|
|
|
"src.dualinventive.com/go/mtinfo-go"
|
|
|
|
"github.com/go-openapi/loads"
|
|
diConfig "src.dualinventive.com/go/lib/config"
|
|
"src.dualinventive.com/go/lib/dilog"
|
|
"src.dualinventive.com/go/users-service/config"
|
|
"src.dualinventive.com/go/users-service/internal/storage/gorm"
|
|
"src.dualinventive.com/go/users-service/internal/users"
|
|
apiServer "src.dualinventive.com/go/users-service/rest/server"
|
|
"src.dualinventive.com/go/users-service/rest/server/operations"
|
|
)
|
|
|
|
var (
|
|
// ApplicationName is the name of the application
|
|
ApplicationName = "users-service-rest" //nolint: gochecknoglobals
|
|
// ApplicationVersion is the version of the application
|
|
ApplicationVersion = "0.0.0-dev" //nolint: gochecknoglobals
|
|
c = config.New() //nolint: gochecknoglobals
|
|
)
|
|
|
|
func main() {
|
|
var confFile string
|
|
flag.StringVar(&confFile, "config", ApplicationName, "Configuration-file name")
|
|
flag.Parse()
|
|
|
|
logger, err := diConfig.Load(confFile, &c)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
logger.WithFields(dilog.Fields{
|
|
"app-name": ApplicationName,
|
|
"app-version": ApplicationVersion,
|
|
}).Info("starting")
|
|
|
|
mtinfoClient, err := mtinfo.NewClient(mtinfo.GRPC, c.MtinfoClientConfig)
|
|
if err != nil {
|
|
logger.WithError(err).Fatal("error creating Mtinfo")
|
|
}
|
|
|
|
repoDatabase, err := gorm.NewMySQLConnection(
|
|
c.DatabaseConfig.Host,
|
|
c.DatabaseConfig.Port,
|
|
c.DatabaseConfig.Name,
|
|
c.DatabaseConfig.User,
|
|
c.DatabaseConfig.Password,
|
|
)
|
|
if err != nil {
|
|
logger.WithError(err).Fatal("error connecting to database")
|
|
}
|
|
userRepository, err := gorm.NewUserRepository(logger, repoDatabase)
|
|
if err != nil {
|
|
logger.WithError(err).Fatal("error creating UserRepository")
|
|
}
|
|
|
|
server, err := initRESTAPI(
|
|
c.RestConfig.Port,
|
|
&users.UserService{Logger: logger, UserRepository: userRepository, Mtinfo: mtinfoClient},
|
|
)
|
|
if err != nil {
|
|
logger.Fatal(err)
|
|
}
|
|
defer server.Shutdown() //nolint:errcheck
|
|
if err := server.Serve(); err != nil {
|
|
logger.Fatal(err)
|
|
}
|
|
}
|
|
|
|
func initRESTAPI(
|
|
port int,
|
|
userService *users.UserService,
|
|
) (*apiServer.Server, error) {
|
|
swaggerSpec, err := loads.Analyzed(apiServer.SwaggerJSON, "")
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
api := operations.NewUsersAPI(swaggerSpec)
|
|
server := apiServer.NewServer(api)
|
|
initHandlers(api, userService)
|
|
server.ConfigureAPI()
|
|
|
|
server.Port = port
|
|
server.EnabledListeners = []string{"http"} // overwrite setting in swagger file
|
|
|
|
return server, nil
|
|
}
|