app.go

// Copyright 2022 Paul Greenberg greenpau@outlook.com
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package security

import (
	"github.com/caddyserver/caddy/v2"
	"github.com/greenpau/go-authcrunch"
	"github.com/greenpau/go-authcrunch/pkg/authn"
	"github.com/greenpau/go-authcrunch/pkg/authz"
	"go.uber.org/zap"
)

var (
	appName = "security"

	// Interface guards
	_ caddy.Provisioner = (*App)(nil)
	_ caddy.Module      = (*App)(nil)
	_ caddy.App         = (*App)(nil)
)

func init() {
	caddy.RegisterModule(App{})
}

// App implements security manager.
type App struct {
	Name        string             `json:"-"`
	Config      *authcrunch.Config `json:"config,omitempty"`
	logger      *zap.Logger
	portals     []*authn.Portal
	gatekeepers []*authz.Gatekeeper
}

// CaddyModule returns the Caddy module information.
func (App) CaddyModule() caddy.ModuleInfo {
	return caddy.ModuleInfo{
		// ID:  caddy.ModuleID("security"),
		ID:  "security",
		New: func() caddy.Module { return new(App) },
	}
}

// Provision sets up the repo manager.
func (app *App) Provision(ctx caddy.Context) error {
	app.Name = appName
	app.logger = ctx.Logger(app)

	app.logger.Info(
		"provisioning app instance",
		zap.String("app", app.Name),
	)

	for _, cfg := range app.Config.Portals {
		portal, err := authn.NewPortal(cfg, app.logger)
		if err != nil {
			app.logger.Error(
				"failed initializing auth portal",
				zap.String("app", app.Name),
				zap.String("portal_name", cfg.Name),
				zap.Error(err),
			)
			return err
		}

		if app.Config.Credentials != nil {
			portal.SetCredentials(app.Config.Credentials)
		}

		if app.Config.Messaging != nil {
			portal.SetMessaging(app.Config.Messaging)
		}

		if err := portal.Register(); err != nil {
			app.logger.Error(
				"failed registering auth portal",
				zap.String("app", app.Name),
				zap.String("portal_name", cfg.Name),
				zap.Error(err),
			)
			return err
		}
		app.portals = append(app.portals, portal)
	}

	for _, cfg := range app.Config.Policies {
		gatekeeper, err := authz.NewGatekeeper(cfg, app.logger)
		if err != nil {
			app.logger.Error(
				"failed initializing gatekeeper",
				zap.String("app", app.Name),
				zap.String("gatekeeper_name", cfg.Name),
				zap.Error(err),
			)
			return err
		}
		if err := gatekeeper.Register(); err != nil {
			app.logger.Error(
				"failed registering gatekeeper",
				zap.String("app", app.Name),
				zap.String("gatekeeper_name", cfg.Name),
				zap.Error(err),
			)
			return err
		}
		app.gatekeepers = append(app.gatekeepers, gatekeeper)
	}

	app.logger.Info(
		"provisioned app instance",
		zap.String("app", app.Name),
	)
	return nil
}

// Start starts the App.
func (app App) Start() error {
	app.logger.Debug(
		"starting app instance",
		zap.String("app", app.Name),
	)

	/*
		if msgs := app.manager.Start(); msgs != nil {
			for _, msg := range msgs {
				app.logger.Error(
					"failed managing git repo",
					zap.String("app", app.Name),
					zap.String("repo", msg.Repository),
					zap.Error(msg.Error),
				)
			}
			return fmt.Errorf("git repo manager failed to start")
		}
	*/

	app.logger.Debug(
		"started app instance",
		zap.String("app", app.Name),
	)

	return nil
}

// Stop stops the App.
func (app App) Stop() error {
	app.logger.Debug(
		"stopping app instance",
		zap.String("app", app.Name),
	)

	/*
		if msgs := app.manager.Stop(); msgs != nil {
			for _, msg := range msgs {
				app.logger.Error(
					"failed stoppint git repo manager",
					zap.String("app", app.Name),
					zap.String("repo", msg.Repository),
					zap.Error(msg.Error),
				)
			}
			return fmt.Errorf("git repo manager failed to stop properly")
		}
	*/

	app.logger.Debug(
		"stopped app instance",
		zap.String("app", app.Name),
	)
	return nil
}