client_application.go

package goauth2

import (
	"net/url"

	"github.com/inklabs/rangedb"
)

type clientApplication struct {
	IsOnBoarded   bool
	ClientID      string
	ClientSecret  string
	RedirectUri   string
	pendingEvents []rangedb.Event
}

func newClientApplication(records <-chan *rangedb.Record) *clientApplication {
	aggregate := &clientApplication{}

	for record := range records {
		if event, ok := record.Data.(rangedb.Event); ok {
			aggregate.apply(event)
		}
	}

	return aggregate
}

func (a *clientApplication) apply(event rangedb.Event) {
	switch e := event.(type) {
	case *ClientApplicationWasOnBoarded:
		a.IsOnBoarded = true
		a.ClientID = e.ClientID
		a.ClientSecret = e.ClientSecret
		a.RedirectUri = e.RedirectUri

	}
}

func (a *clientApplication) Handle(command Command) {
	switch c := command.(type) {

	case OnBoardClientApplication:
		uri, err := url.Parse(c.RedirectUri)
		if err != nil {
			a.emit(OnBoardClientApplicationWasRejectedDueToInvalidRedirectUri{
				ClientID:    c.ClientID,
				RedirectUri: c.RedirectUri,
			})
			return
		}

		if uri.Scheme != "https" {
			a.emit(OnBoardClientApplicationWasRejectedDueToInsecureRedirectUri{
				ClientID:    c.ClientID,
				RedirectUri: c.RedirectUri,
			})
			return
		}

		a.emit(ClientApplicationWasOnBoarded{
			ClientID:     c.ClientID,
			ClientSecret: c.ClientSecret,
			RedirectUri:  c.RedirectUri,
			UserID:       c.UserID,
		})

	case RequestAccessTokenViaClientCredentialsGrant:
		if !a.IsOnBoarded {
			a.emit(RequestAccessTokenViaClientCredentialsGrantWasRejectedDueToInvalidClientApplicationID{
				ClientID: c.ClientID,
			})
			return
		}

		if a.ClientSecret != c.ClientSecret {
			a.emit(RequestAccessTokenViaClientCredentialsGrantWasRejectedDueToInvalidClientApplicationSecret{
				ClientID: c.ClientID,
			})
			return
		}

		a.emit(AccessTokenWasIssuedToClientApplicationViaClientCredentialsGrant{
			ClientID: c.ClientID,
		})

	}
}

func (a *clientApplication) emit(events ...rangedb.Event) {
	for _, event := range events {
		a.apply(event)
	}

	a.pendingEvents = append(a.pendingEvents, events...)
}

func (a *clientApplication) GetPendingEvents() []rangedb.Event {
	return a.pendingEvents
}