main.go

package main

import (
	"github.com/goal-web/application"
	"github.com/goal-web/application/signal"
	"github.com/goal-web/auth"
	"github.com/goal-web/bloomfilter"
	"github.com/goal-web/cache"
	"github.com/goal-web/config"
	"github.com/goal-web/console"
	"github.com/goal-web/contracts"
	"github.com/goal-web/database"
	"github.com/goal-web/email"
	"github.com/goal-web/encryption"
	"github.com/goal-web/events"
	"github.com/goal-web/filesystem"
	console2 "github.com/goal-web/goal/app/console"
	"github.com/goal-web/goal/app/exceptions"
	"github.com/goal-web/goal/app/providers"
	config2 "github.com/goal-web/goal/config"
	"github.com/goal-web/goal/database/migrations"
	"github.com/goal-web/goal/routes"
	"github.com/goal-web/hashing"
	"github.com/goal-web/http"
	"github.com/goal-web/http/sse"
	"github.com/goal-web/queue"
	"github.com/goal-web/ratelimiter"
	"github.com/goal-web/redis"
	"github.com/goal-web/serialization"
	"github.com/goal-web/session"
	"github.com/goal-web/websocket"
	"os"
)

func main() {
	app := application.Singleton()
	path, _ := os.Getwd()
	app.Instance("path", path)

	// 设置异常处理器
	app.Singleton("exceptions.handler", func() contracts.ExceptionHandler {
		return exceptions.NewHandler()
	})

	app.RegisterServices(
		config.Service(os.Getenv("env"), path, config2.Configs()),
		hashing.ServiceProvider{},
		encryption.ServiceProvider{},
		filesystem.ServiceProvider{},
		&serialization.ServiceProvider{},
		events.ServiceProvider{},
		redis.ServiceProvider{},
		cache.ServiceProvider{},
		&bloomfilter.ServiceProvider{},
		&session.ServiceProvider{},
		auth.ServiceProvider{},
		&ratelimiter.ServiceProvider{},
		&console.ServiceProvider{
			ConsoleProvider: console2.NewKernel,
		},
		database.Service(migrations.Migrations),
		&queue.ServiceProvider{},
		&email.ServiceProvider{},
		&http.ServiceProvider{RouteCollectors: []interface{}{
			// 路由收集器
			routes.ApiRoutes,
			routes.WebSocketRoutes,
			routes.SseRoutes,
		}},
		sse.ServiceProvider{},
		websocket.ServiceProvider{},
		providers.App{},
		providers.Gate(),
		providers.Micro(),
		&signal.ServiceProvider{},
	)

	app.Call(func(console3 contracts.Console, input contracts.ConsoleInput) {
		console3.Run(input)
	})
}