feat: demo smallest possible hooks change

Author: hf

internal/api/anonymous.go

@@ -41,6 +41,9 @@ func (a *API) SignupAnonymously(w http.ResponseWriter, r *http.Request) error {
 		if terr != nil {
 			return terr
 		}
+		if terr := a.triggerAfterUserCreated(); terr != nil {
+			return terr
+		}
 		token, terr = a.issueRefreshToken(r, tx, newUser, models.Anonymous, grantParams)
 		if terr != nil {
 			return terr

internal/api/external.go

@@ -334,6 +334,10 @@ func (a *API) createAccountFromExternalIdentity(tx *storage.Connection, r *http.
 			return nil, terr
 		}
 		user.Identities = append(user.Identities, *identity)
+
+		if terr := a.triggerAfterUserCreated(); terr != nil {
+			return nil, terr
+		}
 	case models.AccountExists:
 		user = decision.User
 		identity = decision.Identities[0]

internal/api/invite.go

@@ -71,6 +71,10 @@ func (a *API) Invite(w http.ResponseWriter, r *http.Request) error {
 				return err
 			}
 			user.Identities = []models.Identity{*identity}
+
+			if err := a.triggerAfterUserCreated(); err != nil {
+				return err
+			}
 		}
 
 		if terr := models.NewAuditLogEntry(r, tx, adminUser, models.UserInvitedAction, "", map[string]interface{}{

internal/api/signup.go

@@ -11,6 +11,7 @@ import (
 	"github.com/supabase/auth/internal/api/apierrors"
 	"github.com/supabase/auth/internal/api/provider"
 	"github.com/supabase/auth/internal/api/sms_provider"
+	"github.com/supabase/auth/internal/hooks/v0hooks"
 	"github.com/supabase/auth/internal/metering"
 	"github.com/supabase/auth/internal/models"
 	"github.com/supabase/auth/internal/storage"
@@ -366,6 +367,10 @@ func sanitizeUser(u *models.User, params *SignupParams) (*models.User, error) {
 func (a *API) signupNewUser(conn *storage.Connection, user *models.User) (*models.User, error) {
 	config := a.config
 
+	if err := a.triggerBeforeUserCreated(); err != nil {
+		return user, err
+	}
+
 	err := conn.Transaction(func(tx *storage.Connection) error {
 		var terr error
 		if terr = tx.Create(user); terr != nil {
@@ -389,3 +394,25 @@ func (a *API) signupNewUser(conn *storage.Connection, user *models.User) (*model
 
 	return user, nil
 }
+
+func (a *API) triggerAfterUserCreated( /* todo: params */ ) error {
+	input := v0hooks.AfterUserCreatedOutput{}
+	output := v0hooks.AfterUserCreatedOutput{}
+	err := a.hooksMgr.InvokeHook(nil, nil, &input, &output)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (a *API) triggerBeforeUserCreated( /* todo: params */ ) error {
+	input := v0hooks.BeforeUserCreatedOutput{}
+	output := v0hooks.BeforeUserCreatedOutput{}
+	err := a.hooksMgr.InvokeHook(nil, nil, &input, &output)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

internal/hooks/v0hooks/v0hooks.go

@@ -107,6 +107,38 @@ type AccessTokenClaims struct {
 	IsAnonymous                   bool                   `json:"is_anonymous"`
 }
 
+type BeforeUserCreatedInput struct {
+	User *models.User `json:"user"`
+}
+
+type BeforeUserCreatedOutput struct {
+	Something string `json:"something"`
+}
+
+func (mf *BeforeUserCreatedOutput) IsError() bool {
+	return false
+}
+
+func (mf *BeforeUserCreatedOutput) Error() string {
+	return ""
+}
+
+type AfterUserCreatedInput struct {
+	User *models.User `json:"user"`
+}
+
+type AfterUserCreatedOutput struct {
+	Something string `json:"something"`
+}
+
+func (mf *AfterUserCreatedOutput) IsError() bool {
+	return false
+}
+
+func (mf *AfterUserCreatedOutput) Error() string {
+	return ""
+}
+
 type MFAVerificationAttemptInput struct {
 	UserID     uuid.UUID `json:"user_id"`
 	FactorID   uuid.UUID `json:"factor_id"`