service

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 6, 2026 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

Package service provides business logic services for the application.

Package service provides business logic services for GoatFlow.

Index

Constants

View Source 
const (
	WebAuthnUserTypeAgent    = "agent"
	WebAuthnUserTypeCustomer = "customer"
)

Variables

This section is empty.

Functions

func AgentWebAuthnUserKey 

func AgentWebAuthnUserKey(userID int) string

func SetConfigAdapter 

func SetConfigAdapter(ca *yamlmgmt.ConfigAdapter)

Types

type AuthService 

type AuthService struct {
	// contains filtered or unexported fields
}

AuthService handles authentication and authorization.

func NewAuthService 

func NewAuthService(db *sql.DB, jwtManager *auth.JWTManager, oidcClient *http.Client, stateStore auth.StateStore) *AuthService

NewAuthService creates a new authentication service with a JWT manager.

func (*AuthService) GetUser 

func (s *AuthService) GetUser(ctx context.Context, identifier string) (*platformmodels.User, error)

GetUser retrieves user information by identifier.

func (*AuthService) Login 

func (s *AuthService) Login(ctx context.Context, username, password string) (*platformmodels.User, string, string, error)

Login authenticates a user and returns JWT tokens.

func (*AuthService) RefreshToken 

func (s *AuthService) RefreshToken(refreshToken string) (string, error)

RefreshToken generates a new access token from a refresh token.

func (*AuthService) ValidateToken 

func (s *AuthService) ValidateToken(tokenString string) (*platformmodels.User, error)

ValidateToken validates a JWT token and returns the user.

type CustomerPreferencesBackend 

type CustomerPreferencesBackend struct {
	// contains filtered or unexported fields
}

CustomerPreferencesBackend stores preferences in customer_preferences table (string user_id/login).

func NewCustomerPreferencesBackend 

func NewCustomerPreferencesBackend(db *sql.DB, userLogin string) *CustomerPreferencesBackend

NewCustomerPreferencesBackend creates a backend for customer users.

func (*CustomerPreferencesBackend) Delete 

func (b *CustomerPreferencesBackend) Delete(key string) error

func (*CustomerPreferencesBackend) Get 

func (b *CustomerPreferencesBackend) Get(key string) (string, error)

func (*CustomerPreferencesBackend) Set 

func (b *CustomerPreferencesBackend) Set(key, value string) error

func (*CustomerPreferencesBackend) SetAndDelete 

func (b *CustomerPreferencesBackend) SetAndDelete(sets map[string]string, deletes []string) error

SetAndDelete performs multiple set and delete operations atomically.

type DashboardWidgetConfig 

type DashboardWidgetConfig struct {
	WidgetID string `json:"widget_id"` // Format: "plugin_name:widget_id"
	Enabled  bool   `json:"enabled"`
	Position int    `json:"position"`    // Order on dashboard (lower = first)
	X        int    `json:"x"`           // Grid column position
	Y        int    `json:"y"`           // Grid row position
	W        int    `json:"w,omitempty"` // Grid width (columns)
	H        int    `json:"h,omitempty"` // Grid height (rows)
}

DashboardWidgetConfig represents the configuration for a dashboard widget.

type PasskeyLoginResult 

type PasskeyLoginResult struct {
	UserType string
	UserKey  string
}

type PreferencesBackend 

type PreferencesBackend interface {
	Get(key string) (string, error)
	Set(key, value string) error
	Delete(key string) error
	// SetAndDelete performs multiple set and delete operations atomically in a single transaction.
	// This ensures all-or-nothing semantics for multi-step preference changes.
	SetAndDelete(sets map[string]string, deletes []string) error
}

PreferencesBackend abstracts preference storage for TOTP. Allows the same TOTP logic to work with different storage backends.

type TOTPService 

type TOTPService struct {
	// contains filtered or unexported fields
}

TOTPService handles two-factor authentication using TOTP.

func NewCustomerTOTPService 

func NewCustomerTOTPService(db *sql.DB, issuer string, userLogin string) *TOTPService

NewCustomerTOTPService creates a TOTP service for customer users (string login).

func NewTOTPService 

func NewTOTPService(db *sql.DB, issuer string) *TOTPService

NewTOTPService creates a TOTP service for agent/admin users (numeric ID).

func (*TOTPService) ConfirmSetup 

func (s *TOTPService) ConfirmSetup(userID int, code string) error

ConfirmSetup verifies the TOTP code and enables 2FA for the user.

func (*TOTPService) ConfirmSetupForCustomer 

func (s *TOTPService) ConfirmSetupForCustomer(userLogin string, code string) error

ConfirmSetupForCustomer verifies and enables 2FA for a customer.

func (*TOTPService) Disable 

func (s *TOTPService) Disable(userID int, code string) error

Disable turns off 2FA for a user.

func (*TOTPService) DisableForCustomer 

func (s *TOTPService) DisableForCustomer(userLogin string, code string) error

DisableForCustomer turns off 2FA for a customer.

func (*TOTPService) ForCustomer 

func (s *TOTPService) ForCustomer(userLogin string) *TOTPService

ForCustomer returns a TOTPService bound to a specific customer login.

func (*TOTPService) ForUser 

func (s *TOTPService) ForUser(userID int) *TOTPService

ForUser returns a TOTPService bound to a specific agent user ID.

func (*TOTPService) ForceDisable 

func (s *TOTPService) ForceDisable(userID int) error

ForceDisable turns off 2FA for a user without requiring a code (admin override).

func (*TOTPService) ForceDisableForCustomer 

func (s *TOTPService) ForceDisableForCustomer(userLogin string) error

ForceDisableForCustomer turns off 2FA for a customer without requiring a code (admin override).

func (*TOTPService) GenerateSetup 

func (s *TOTPService) GenerateSetup(userID int, userEmail string) (*TOTPSetupData, error)

GenerateSetup creates a new TOTP secret and recovery codes for a user. The secret is NOT saved until ConfirmSetup is called with a valid code.

func (*TOTPService) GenerateSetupForCustomer 

func (s *TOTPService) GenerateSetupForCustomer(userLogin string) (*TOTPSetupData, error)

GenerateSetupForCustomer creates a new TOTP secret for a customer.

func (*TOTPService) GetRemainingRecoveryCodes 

func (s *TOTPService) GetRemainingRecoveryCodes(userID int) int

GetRemainingRecoveryCodes returns count of unused recovery codes.

func (*TOTPService) GetRemainingRecoveryCodesForCustomer 

func (s *TOTPService) GetRemainingRecoveryCodesForCustomer(userLogin string) int

GetRemainingRecoveryCodesForCustomer returns count for a customer.

func (*TOTPService) IsEnabled 

func (s *TOTPService) IsEnabled(userID int) bool

IsEnabled checks if 2FA is enabled for a user.

func (*TOTPService) IsEnabledForCustomer 

func (s *TOTPService) IsEnabledForCustomer(userLogin string) bool

IsEnabledForCustomer checks if 2FA is enabled for a customer.

func (*TOTPService) ValidateCode 

func (s *TOTPService) ValidateCode(userID int, code string) (bool, error)

ValidateCode checks if a TOTP code is valid for the user.

func (*TOTPService) ValidateCodeForCustomer 

func (s *TOTPService) ValidateCodeForCustomer(userLogin string, code string) (bool, error)

ValidateCodeForCustomer checks if a TOTP code is valid for a customer.

type TOTPSetupData 

type TOTPSetupData struct {
	Secret        string   `json:"secret"`
	URL           string   `json:"url"`
	RecoveryCodes []string `json:"recovery_codes"`
}

TOTPSetupData contains data needed for 2FA setup.

type UserPreferencesBackend 

type UserPreferencesBackend struct {
	// contains filtered or unexported fields
}

UserPreferencesBackend stores preferences in user_preferences table (numeric user_id).

func NewUserPreferencesBackend 

func NewUserPreferencesBackend(db *sql.DB, userID int) *UserPreferencesBackend

NewUserPreferencesBackend creates a backend for agent/admin users.

func (*UserPreferencesBackend) Delete 

func (b *UserPreferencesBackend) Delete(key string) error

func (*UserPreferencesBackend) Get 

func (b *UserPreferencesBackend) Get(key string) (string, error)

func (*UserPreferencesBackend) Set 

func (b *UserPreferencesBackend) Set(key, value string) error

func (*UserPreferencesBackend) SetAndDelete 

func (b *UserPreferencesBackend) SetAndDelete(sets map[string]string, deletes []string) error

SetAndDelete performs multiple set and delete operations atomically.

type UserPreferencesService 

type UserPreferencesService struct {
	// contains filtered or unexported fields
}

UserPreferencesService handles user preference operations.

func NewUserPreferencesService 

func NewUserPreferencesService(db *sql.DB) *UserPreferencesService

NewUserPreferencesService creates a new user preferences service.

func (*UserPreferencesService) DeletePreference 

func (s *UserPreferencesService) DeletePreference(userID int, key string) error

DeletePreference removes a user preference.

func (*UserPreferencesService) GetAllPreferences 

func (s *UserPreferencesService) GetAllPreferences(userID int) (map[string]string, error)

GetAllPreferences returns all preferences for a user.

func (*UserPreferencesService) GetDashboardWidgets 

func (s *UserPreferencesService) GetDashboardWidgets(userID int) ([]DashboardWidgetConfig, error)

GetDashboardWidgets returns the user's dashboard widget configuration. Returns nil if no configuration is set (show all widgets with defaults).

func (*UserPreferencesService) GetLanguage 

func (s *UserPreferencesService) GetLanguage(userID int) string

GetLanguage returns the user's preferred language. Returns empty string if no preference is set (use system detection).

func (*UserPreferencesService) GetPreference 

func (s *UserPreferencesService) GetPreference(userID int, key string) (string, error)

GetPreference retrieves a user preference by key.

func (*UserPreferencesService) GetRemindersEnabled 

func (s *UserPreferencesService) GetRemindersEnabled(userID int) bool

GetRemindersEnabled returns whether pending reminders are enabled for the user. Returns true if no preference is set (default: enabled).

func (*UserPreferencesService) GetSessionTimeout 

func (s *UserPreferencesService) GetSessionTimeout(userID int) int

Returns 0 if no preference is set (use system default).

func (*UserPreferencesService) GetTheme 

func (s *UserPreferencesService) GetTheme(userID int) string

GetTheme returns the user's preferred theme. Returns empty string if no preference is set.

func (*UserPreferencesService) GetThemeMode 

func (s *UserPreferencesService) GetThemeMode(userID int) string

GetThemeMode returns the user's preferred theme mode (light/dark). Returns empty string if no preference is set.

func (*UserPreferencesService) IsWidgetEnabled 

func (s *UserPreferencesService) IsWidgetEnabled(userID int, pluginName, widgetID string) bool

IsWidgetEnabled checks if a specific widget is enabled for the user. If no config exists, returns true (all widgets enabled by default).

func (*UserPreferencesService) SetDashboardWidgets 

func (s *UserPreferencesService) SetDashboardWidgets(userID int, config []DashboardWidgetConfig) error

SetDashboardWidgets saves the user's dashboard widget configuration.

func (*UserPreferencesService) SetLanguage 

func (s *UserPreferencesService) SetLanguage(userID int, lang string) error

SetLanguage sets the user's preferred language.

func (*UserPreferencesService) SetPreference 

func (s *UserPreferencesService) SetPreference(userID int, key string, value string) error

SetPreference sets a user preference. Uses delete-then-insert within a transaction to avoid duplicates and ensure atomicity. (MySQL reports 0 rows affected when UPDATE sets the same value, which would cause incorrect INSERT with the old update-then-insert pattern.)

func (*UserPreferencesService) SetRemindersEnabled 

func (s *UserPreferencesService) SetRemindersEnabled(userID int, enabled bool) error

SetRemindersEnabled sets whether pending reminders are enabled for the user.

func (*UserPreferencesService) SetSessionTimeout 

func (s *UserPreferencesService) SetSessionTimeout(userID int, timeout int) error

SetSessionTimeout sets the user's preferred session timeout.

func (*UserPreferencesService) SetTheme 

func (s *UserPreferencesService) SetTheme(userID int, theme string) error

SetTheme sets the user's preferred theme.

func (*UserPreferencesService) SetThemeMode 

func (s *UserPreferencesService) SetThemeMode(userID int, mode string) error

SetThemeMode sets the user's preferred theme mode (light/dark).

type WebAuthnCredentialRecord 

type WebAuthnCredentialRecord struct {
	ID           int64      `json:"id"`
	UserType     string     `json:"user_type"`
	UserKey      string     `json:"user_key"`
	CredentialID string     `json:"credential_id"`
	Name         string     `json:"name"`
	SignCount    uint32     `json:"sign_count"`
	LastUsedAt   *time.Time `json:"last_used_at,omitempty"`
	CreatedAt    time.Time  `json:"created_at"`
	UpdatedAt    time.Time  `json:"updated_at"`
	// contains filtered or unexported fields
}

type WebAuthnService 

type WebAuthnService struct {
	// contains filtered or unexported fields
}

func NewWebAuthnService 

func NewWebAuthnService(db *sql.DB, r *http.Request) (*WebAuthnService, error)

func (*WebAuthnService) BeginLogin 

func (s *WebAuthnService) BeginLogin(userType, userKey, displayName string) (interface{}, error)

func (*WebAuthnService) BeginPasskeyLogin 

func (s *WebAuthnService) BeginPasskeyLogin(userType string) (interface{}, string, error)

func (*WebAuthnService) BeginRegistration 

func (s *WebAuthnService) BeginRegistration(userType, userKey, displayName string) (interface{}, error)

func (*WebAuthnService) CountCredentials 

func (s *WebAuthnService) CountCredentials(userType, userKey string) (int, error)

func (*WebAuthnService) DeleteAllCredentials 

func (s *WebAuthnService) DeleteAllCredentials(userType, userKey string) error

func (*WebAuthnService) DeleteCredential 

func (s *WebAuthnService) DeleteCredential(userType, userKey string, id int64) error

func (*WebAuthnService) FinishLogin 

func (s *WebAuthnService) FinishLogin(userType, userKey, displayName string, r *http.Request) error

func (*WebAuthnService) FinishPasskeyLogin 

func (s *WebAuthnService) FinishPasskeyLogin(userType, token string, r *http.Request) (*PasskeyLoginResult, error)

func (*WebAuthnService) FinishRegistration 

func (s *WebAuthnService) FinishRegistration(userType, userKey, displayName, keyName string, r *http.Request) (*WebAuthnCredentialRecord, error)

func (*WebAuthnService) IsEnabled 

func (s *WebAuthnService) IsEnabled(userType, userKey string) bool

func (*WebAuthnService) ListCredentials 

func (s *WebAuthnService) ListCredentials(userType, userKey string) ([]WebAuthnCredentialRecord, error)

func (*WebAuthnService) RenameCredential 

func (s *WebAuthnService) RenameCredential(userType, userKey string, id int64, name string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.