app.go

package akigate

import (
	"akigate/filter"
	"akigate/oauth/auth"
	"akigate/reverseProxy"
	"akigate/route"
	"github.com/google/wire"
	"github.com/gutrse3321/aki/pkg/app"
	akihttp "github.com/gutrse3321/aki/pkg/transports/http"
	"github.com/pkg/errors"
	"github.com/spf13/viper"
	"go.uber.org/zap"
)

/**
 * @Author: Tomonori
 * @Date: 2020/6/18 17:12
 * @Title:
 * --- --- ---
 * @Desc:
 */

func NewOptions(v *viper.Viper, logger *zap.Logger) (*app.Options, error) {
	var err error

	opt := &app.Options{}
	if err = v.UnmarshalKey("app", opt); err != nil {
		return nil, errors.Wrap(err, "unmarshal app config error")
	}

	logger.Info("load application config success")
	return opt, err
}

func NewApp(opt *app.Options, logger *zap.Logger, httpServer *akihttp.Server) (*app.Application, error) {
	application, err := app.New(opt, logger, app.HttpServerOption(httpServer))
	if err != nil {
		return nil, errors.Wrap(err, "new application error")
	}

	return application, nil
}

var WireSet = wire.NewSet(
	NewApp,
	NewOptions,
	reverseProxy.NewReverseProxy,
	auth.WireSet,
	filter.UserAuthMiddleware,
	route.WireSet,
)