portal/main.go

package main

import (
	"context"
	"embed"
	"fmt"
	"git.lumeweb.com/LumeWeb/portal/config"
	"git.lumeweb.com/LumeWeb/portal/controller"
	"git.lumeweb.com/LumeWeb/portal/db"
	_ "git.lumeweb.com/LumeWeb/portal/docs"
	"git.lumeweb.com/LumeWeb/portal/logger"
	"git.lumeweb.com/LumeWeb/portal/middleware"
	"git.lumeweb.com/LumeWeb/portal/service/auth"
	"git.lumeweb.com/LumeWeb/portal/service/files"
	"git.lumeweb.com/LumeWeb/portal/shared"
	"git.lumeweb.com/LumeWeb/portal/tus"
	nriris "github.com/iris-contrib/middleware/newrelic"
	"github.com/iris-contrib/swagger"
	"github.com/iris-contrib/swagger/swaggerFiles"
	"github.com/kataras/iris/v12"
	irisContext "github.com/kataras/iris/v12/context"
	"github.com/kataras/iris/v12/middleware/cors"
	"github.com/kataras/iris/v12/mvc"
	"github.com/newrelic/go-agent/v3/newrelic"
	"github.com/spf13/viper"
	"go.uber.org/zap"
	"log"
	"net/http"
	"os"
)

// Embed a directory of static files for serving from the app's root path
//
//go:embed app/*
var embedFrontend embed.FS

//	@title			Lume Web Portal
//	@version		1.0
//	@description	A decentralized data storage portal for the open web

//	@contact.name	Lume Web Project
//	@contact.url	https://lumeweb.com
//	@contact.email	contact@lumeweb.com

//	@license.name	MIT
//	@license.url	https://opensource.org/license/mit/

// @externalDocs.description	OpenAPI
// @externalDocs.url			https://swagger.io/resources/open-api/
func main() {
	// Initialize the configuration settings
	config.Init()

	// Initialize the database connection
	db.Init()
	defer func() {
		err := db.Close()

		if err != nil {
			logger.Get().Error("Failed to close db connection", zap.Error(err))
		}
	}()
	logger.Init()
	files.Init()
	auth.Init()

	// Create a new Iris app instance
	app := iris.New()
	// Enable Gzip compression for responses
	app.Use(iris.Compression)
	app.UseRouter(cors.New().Handler())

	// Serve static files from the embedded directory at the app's root path
	app.HandleDir("/", embedFrontend)

	api := app.Party("/api")
	v1 := api.Party("/v1")

	tusHandler := tus.Init()

	if viper.IsSet("newrelic.license") {
		nrAapp, err := newrelic.NewApplication(
			newrelic.ConfigAppName(viper.GetString("newrelic.appname")),
			newrelic.ConfigLicense(viper.GetString("newrelic.license")),
			newrelic.ConfigAppLogForwardingEnabled(true),
		)

		if nil != err {
			fmt.Println(err)
			os.Exit(1)
		}

		app.Use(nriris.New(nrAapp))
	}

	// Register the AccountController with the MVC framework and attach it to the "/api/account" path
	mvc.Configure(v1.Party("/account"), func(app *mvc.Application) {
		app.Handle(new(controller.AccountController))
	})

	mvc.Configure(v1.Party("/auth"), func(app *mvc.Application) {
		app.Handle(new(controller.AuthController))
	})

	mvc.Configure(v1.Party("/files"), func(app *mvc.Application) {
		tusRoute := app.Router.Party(tus.TUS_API_PATH)
		tusRoute.Use(middleware.VerifyJwt)

		fromStd := func(handler http.Handler) func(ctx *irisContext.Context) {
			return func(ctx *irisContext.Context) {
				newCtx := context.WithValue(ctx.Request().Context(), shared.TusRequestContextKey, ctx)
				handler.ServeHTTP(ctx.ResponseWriter(), ctx.Request().WithContext(newCtx))
			}
		}

		tusRoute.Any("/{fileparam:path}", fromStd(http.StripPrefix(v1.GetRelPath()+tus.TUS_API_PATH+"/", tusHandler)))
		tusRoute.Post("/", fromStd(http.StripPrefix(tusRoute.GetRelPath()+tus.TUS_API_PATH, tusHandler)))

		app.Handle(new(controller.FilesController))
	})

	swaggerConfig := swagger.Config{
		// The url pointing to API definition.
		URL:          "http://localhost:8080/swagger/doc.json",
		DeepLinking:  true,
		DocExpansion: "list",
		DomID:        "#swagger-ui",
		// The UI prefix URL (see route).
		Prefix: "/swagger",
	}
	swaggerUI := swagger.Handler(swaggerFiles.Handler, swaggerConfig)

	app.Get("/swagger", swaggerUI)
	// And the wildcard one for index.html, *.js, *.css and e.t.c.
	app.Get("/swagger/{any:path}", swaggerUI)

	// Start the Iris app and listen for incoming requests on port 80
	err := app.Listen(":8080", func(app *iris.Application) {
		routes := app.GetRoutes()
		for _, route := range routes {
			log.Println(route)
		}
	})

	if err != nil {
		logger.Get().Error("Failed starting webserver", zap.Error(err))
	}
}