services

package
v1.2.5 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2025 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DBMutex sync.Mutex
)

Functions

func BalanceWarningFields 

func BalanceWarningFields() []*discordgo.MessageEmbedField

func CheckAccount 

func CheckAccount(ssoCookie string, userID string, captchaAPIKey string) (models.Status, error)

func CheckAccountAge 

func CheckAccountAge(ssoCookie string) (int, int, int, int64, error)

func CheckAccountWithRetry added in v1.2.5 

func CheckAccountWithRetry(ssoCookie, userID, captchaProvider string) (models.Status, error)

func CheckAccounts 

func CheckAccounts(s *discordgo.Session)

func CheckAndNotifyBalance 

func CheckAndNotifyBalance(s *discordgo.Session, userID string, balance float64)

func CheckRateLimitWithBackoff added in v1.1.1 

func CheckRateLimitWithBackoff(userID string, endpoint string) error

func CheckSSOCookieExpiration 

func CheckSSOCookieExpiration(expirationTimestamp int64) (time.Duration, error)

func CheckVIPStatus 

func CheckVIPStatus(ssoCookie string) (bool, error)

func CleanupInactiveUsers 

func CleanupInactiveUsers()

func CleanupOldAnalyticsData 

func CleanupOldAnalyticsData(retentionDays int) error

func CleanupOldRateLimitData 

func CleanupOldRateLimitData()

func CleanupOldShadowbanPeriods added in v1.2.5 

func CleanupOldShadowbanPeriods(retentionDays int) error

func CleanupOldShardInfo added in v1.2.5 

func CleanupOldShardInfo()

func CleanupUsersByShardAssignment added in v1.2.5 

func CleanupUsersByShardAssignment()

func CreateAccountListEmbed added in v1.1.1 

func CreateAccountListEmbed(accounts []models.Account, userID string, page int, totalPages int) *discordgo.MessageEmbed

func CreateAnnouncementEmbed 

func CreateAnnouncementEmbed() *discordgo.MessageEmbed

func CreateCheckResultEmbed added in v1.1.1 

func CreateCheckResultEmbed(account models.Account, status models.Status, userSettings models.UserSettings) *discordgo.MessageEmbed

func CreateComponentsBasedOnConfig added in v1.2.0 

func CreateComponentsBasedOnConfig(components []discordgo.MessageComponent) []discordgo.MessageComponent

func CreateErrorEmbed added in v1.1.1 

func CreateErrorEmbed(title string, errorMessage string) *discordgo.MessageEmbed

func CreateInfoEmbed added in v1.1.1 

func CreateInfoEmbed(title string, message string) *discordgo.MessageEmbed

func CreateLegacyButton added in v1.2.0 

func CreateLegacyButton(label, customID string, style discordgo.ButtonStyle) discordgo.MessageComponent

func CreateShadowbanPeriodsTable added in v1.2.5 

func CreateShadowbanPeriodsTable() error

func CreateSuccessEmbed added in v1.1.1 

func CreateSuccessEmbed(title string, message string) *discordgo.MessageEmbed

func CreateV2Button added in v1.2.0 

func CreateV2Button(label, customID string, style discordgo.ButtonStyle) discordgo.MessageComponent

func DecodeSSOCookie 

func DecodeSSOCookie(encodedStr string) (int64, error)
func FormatDuration(duration time.Duration) string {
	if duration <= 0 {
		return "Expired"
	}

	if duration < 2*time.Hour {
		minutes := int(duration.Minutes())
		if minutes <= 0 {
			return "Less than 1 minute"
		}
		return fmt.Sprintf("%d minutes", minutes)
	}

	days := int(duration.Hours() / 24)
	hours := int(duration.Hours()) % 24

	if days > 0 {
		return fmt.Sprintf("%d days, %d hours", days, hours)
	} else {
		return fmt.Sprintf("%d hours", hours)
	}
}

func DeferWithPreference added in v1.2.0 

func DeferWithPreference(s *discordgo.Session, i *discordgo.InteractionCreate, forceEphemeral bool) error

func DisableUserCaptcha 

func DisableUserCaptcha(s *discordgo.Session, userID string, reason string) error

func DoRequest added in v1.1.1 

func DoRequest(req *http.Request) (*http.Response, error)

func EmbedTitleFromStatus 

func EmbedTitleFromStatus(status models.Status) string

func FilterAccountsByShardAssignment added in v1.1.1 

func FilterAccountsByShardAssignment(accounts []models.Account) []models.Account

func FilterUserSettingsByShardAssignment added in v1.1.1 

func FilterUserSettingsByShardAssignment(settings []models.UserSettings) []models.UserSettings

func FixShardAssignments added in v1.2.5 

func FixShardAssignments() error

func FollowupWithPreference added in v1.2.0 

func FollowupWithPreference(s *discordgo.Session, i *discordgo.InteractionCreate, content string, embeds []*discordgo.MessageEmbed, components []discordgo.MessageComponent, forceEphemeral bool) (*discordgo.Message, error)

func FormatDuration 

func FormatDuration(d time.Duration) string

func FormatExpirationTime 

func FormatExpirationTime(expirationTimestamp int64) string

func GenerateHeaders 

func GenerateHeaders(ssoCookie string) map[string]string

func GetAnalyticsStats added in v1.2.5 

func GetAnalyticsStats(days int) (map[string]interface{}, error)

func GetCheckStatus 

func GetCheckStatus(isCheckDisabled bool) string

func GetColorForStatus 

func GetColorForStatus(status models.Status, isExpiredCookie bool, isCheckDisabled bool) int

func GetCooldownDuration 

func GetCooldownDuration(userSettings models.UserSettings, notificationType string, defaultCooldown time.Duration) time.Duration

func GetDailyStats 

func GetDailyStats(date string) (map[string]interface{}, error)

func GetDefaultCaptchaAPIKey added in v1.2.0 

func GetDefaultCaptchaAPIKey(provider string) (string, error)

func GetDefaultHTTPClient 

func GetDefaultHTTPClient() *http.Client

func GetDefaultSettings 

func GetDefaultSettings() (models.UserSettings, error)

func GetFallbackProvider added in v1.2.0 

func GetFallbackProvider(primaryProvider string) string

func GetGatewayBotInfo added in v1.0.1 

func GetGatewayBotInfo(token string) (*discordgo.GatewayBotResponse, error)

func GetGlobalShadowbanStats added in v1.2.5 

func GetGlobalShadowbanStats(days int) (map[string]interface{}, error)

func GetHTTPClient added in v1.2.0 

func GetHTTPClient() *http.Client

func GetInstallationStats 

func GetInstallationStats() (serverCount int64, directCount int64, err error)

func GetInteractionFlags added in v1.1.1 

func GetInteractionFlags(i *discordgo.InteractionCreate, forceEphemeral bool) discordgo.MessageFlags

func GetLongTimeoutHTTPClient 

func GetLongTimeoutHTTPClient() *http.Client

func GetNotificationChannel 

func GetNotificationChannel(s *discordgo.Session, account models.Account, userSettings models.UserSettings) (string, error)

func GetRateLimitStatus added in v1.1.1 

func GetRateLimitStatus(userID string, action string) (remaining time.Duration, isLimited bool)

func GetResponseChannel 

func GetResponseChannel(s *discordgo.Session, userID string, i *discordgo.InteractionCreate) (string, error)

func GetShadowbanStatistics added in v1.2.5 

func GetShadowbanStatistics(userID string, accountID *uint, days int) (map[string]interface{}, error)

func GetShardAnalytics added in v1.2.5 

func GetShardAnalytics(days int) (map[string]interface{}, error)

func GetShardDistributionStats added in v1.2.5 

func GetShardDistributionStats() (map[string]interface{}, error)

func GetSharedClient added in v1.1.1 

func GetSharedClient() *http.Client

func GetStatusDescription 

func GetStatusDescription(status models.Status, accountTitle string, ban models.Ban) string

func GetStatusIcon 

func GetStatusIcon(status models.Status) string

func GetUserCaptchaKey 

func GetUserCaptchaKey(userID string) (string, float64, error)

func GetUserEphemeralPreference added in v1.1.1 

func GetUserEphemeralPreference(userID string) bool

func GetUserID 

func GetUserID(i *discordgo.InteractionCreate) (string, error)

func GetUserRateLimitStatus 

func GetUserRateLimitStatus(userID string) (bool, time.Duration, int)

func GetUserSettings 

func GetUserSettings(userID string) (models.UserSettings, error)

func HandleAccountError added in v1.2.0 

func HandleAccountError(s *discordgo.Session, account models.Account, errorType string, err error)

func HandleDatabaseConnectionLoss added in v1.2.0 

func HandleDatabaseConnectionLoss()

func HandleDiscordAPIError added in v1.2.0 

func HandleDiscordAPIError(err error, operation string)

func HandleDuplicateInteraction added in v1.2.0 

func HandleDuplicateInteraction(s *discordgo.Session, i *discordgo.InteractionCreate) bool

func HandleGracefulShutdown added in v1.2.0 

func HandleGracefulShutdown(s *discordgo.Session)

func HandleShardFailover added in v1.2.0 

func HandleShardFailover(s *discordgo.Session)

func HandleStatusChange 

func HandleStatusChange(s *discordgo.Session, account models.Account, newStatus models.Status, userSettings *models.UserSettings)

func HandleSuccessfulCheck added in v1.2.0 

func HandleSuccessfulCheck(account models.Account)

func HandleUserRateLimit added in v1.2.0 

func HandleUserRateLimit(s *discordgo.Session, i *discordgo.InteractionCreate) bool

func InitDefaultSettings added in v1.2.0 

func InitDefaultSettings()

func InitHTTPClients 

func InitHTTPClients()

func InitializeProxyStatsAfterDB added in v1.2.0 

func InitializeProxyStatsAfterDB()

func InitializeServices 

func InitializeServices()

func IsServiceEnabled 

func IsServiceEnabled(provider string) bool

func IsUserRateLimited 

func IsUserRateLimited(userID string) bool
func CleanupOldRateLimitData() {
	adaptiveRateLimits.Lock()
	defer adaptiveRateLimits.Unlock()

	now := time.Now()
	initialCount := len(adaptiveRateLimits.UserBackoffs)
	cleaned := 0

	for userID, backoff := range adaptiveRateLimits.UserBackoffs {
		var recentHistory []time.Time
		for _, t := range backoff.NotificationHistory {
			if now.Sub(t) <= adaptiveRateLimits.HistoryWindow {
				recentHistory = append(recentHistory, t)
			}
		}

		if len(recentHistory) == 0 {
			backoff.BackoffMultiplier = 1.0
			backoff.ConsecutiveCount = 0
			cleaned++
		}

		backoff.NotificationHistory = recentHistory

		if len(recentHistory) == 0 && now.Sub(backoff.LastSent) > adaptiveRateLimits.HistoryWindow {
			delete(adaptiveRateLimits.UserBackoffs, userID)
			cleaned++
		}
	}

	logger.Log.Infof("Rate limit cleanup completed: processed %d entries, cleaned %d", initialCount, cleaned)
}

func LoadProxyConfiguration added in v1.1.1 

func LoadProxyConfiguration(pm *ProxyManager)

func LogAccountCheck 

func LogAccountCheck(accountID uint, userID string, success bool, status models.Status, responseTimeMs int64, captchaProvider string, captchaCost float64, errorDetails string)

func LogAccountStatusCheck added in v1.2.0 

func LogAccountStatusCheck(accountID uint, userID string, status models.Status, checkType, errorDetails string)

func LogAnalyticsEvent added in v1.2.5 

func LogAnalyticsEvent(eventType, userID, guildID, commandName, status string, shardID int, instanceID string, metadata map[string]interface{})

func LogCommandExecution 

func LogCommandExecution(commandName, userID, guildID string, success bool, responseTimeMs int64, errorDetails string)

func LogInstallationStats 

func LogInstallationStats(s interface{})

func LogNotification 

func LogNotification(userID string, accountID uint, notificationType string, success bool)

func LogShardEvent added in v1.2.5 

func LogShardEvent(eventType string, metadata map[string]interface{})

func LogStatusChange 

func LogStatusChange(accountID uint, userID string, newStatus, previousStatus models.Status)

func NewHeaderTransport added in v1.1.1 

func NewHeaderTransport(base http.RoundTripper, userAgents []string) http.RoundTripper

func NotifyAdmin 

func NotifyAdmin(s *discordgo.Session, message string)

func NotifyAdminWithCooldown 

func NotifyAdminWithCooldown(s *discordgo.Session, message string, cooldownDuration time.Duration)

func NotifyCookieExpiringSoon 

func NotifyCookieExpiringSoon(s *discordgo.Session, accounts []models.Account) error

func NotifyNewInstallation 

func NotifyNewInstallation(s *discordgo.Session, context string)

func NotifyUserAboutDisabledAccount 

func NotifyUserAboutDisabledAccount(s *discordgo.Session, account models.Account, reason string)

func PerformShardHealthCheck added in v1.2.5 

func PerformShardHealthCheck()

func QueueNotification 

func QueueNotification(userID string, content string)

func RecoverFromPanic added in v1.2.0 

func RecoverFromPanic(operation string)

func RemoveCaptchaKey 

func RemoveCaptchaKey(userID string) error

func ReportCapsolverTaskResult 

func ReportCapsolverTaskResult(token string, isValid bool, errorMessage string)

func ResetRateLimitBackoff added in v1.1.1 

func ResetRateLimitBackoff(userID string, endpoint string) error

func RespondWithPreference added in v1.1.1 

func RespondWithPreference(s *discordgo.Session, i *discordgo.InteractionCreate, content string, embeds []*discordgo.MessageEmbed, forceEphemeral bool) error

func RespondWithPreferenceAndComponents added in v1.2.0 

func RespondWithPreferenceAndComponents(s *discordgo.Session, i *discordgo.InteractionCreate, content string, embeds []*discordgo.MessageEmbed, components []discordgo.MessageComponent, forceEphemeral bool) error

func SafeInteractionRespond added in v1.2.0 

func SafeInteractionRespond(s *discordgo.Session, i *discordgo.InteractionCreate, response *discordgo.InteractionResponse) error

func ScheduleBalanceChecks 

func ScheduleBalanceChecks(s *discordgo.Session)

func ScheduleTempBanNotification 

func ScheduleTempBanNotification(s *discordgo.Session, account models.Account, duration string)

func SendAnnouncementToAllUsers 

func SendAnnouncementToAllUsers(s *discordgo.Session) error

func SendConsolidatedDailyUpdate 

func SendConsolidatedDailyUpdate(s *discordgo.Session, userID string, userSettings models.UserSettings, accounts []models.Account)

func SendEmbedToUser 

func SendEmbedToUser(s *discordgo.Session, userID string, i *discordgo.InteractionCreate, embed *discordgo.MessageEmbed) error

func SendGlobalAnnouncement 

func SendGlobalAnnouncement(s *discordgo.Session, userID string) error

func SendMessageToUser 

func SendMessageToUser(s *discordgo.Session, userID string, i *discordgo.InteractionCreate, message string) error

func SendNotification 

func SendNotification(s *discordgo.Session, account models.Account, embed *discordgo.MessageEmbed, content, notificationType string) error

func SendNotificationWithComponentsV2 added in v1.2.0 

func SendNotificationWithComponentsV2(s *discordgo.Session, account models.Account, embed *discordgo.MessageEmbed, content, notificationType string, components []discordgo.MessageComponent) error

func ShouldUseComponentsV2 added in v1.2.0 

func ShouldUseComponentsV2() bool

func SolveCaptchaWithFallback added in v1.2.0 

func SolveCaptchaWithFallback(userID, siteKey, pageURL string) (string, string, error)

func StartAdminAPI 

func StartAdminAPI()

func StartEdgeCaseCleanupRoutine added in v1.2.0 

func StartEdgeCaseCleanupRoutine(ctx context.Context)

func StartErrorCleanupRoutine added in v1.2.0 

func StartErrorCleanupRoutine(ctx context.Context)

func StartNotificationProcessor 

func StartNotificationProcessor(discord *discordgo.Session)

func StoreCapsolverTaskInfo 

func StoreCapsolverTaskInfo(taskID, token string)

func TrackMessageFailure 

func TrackMessageFailure(userID string, errorMessage string)

func TrackShadowbanTransition added in v1.2.5 

func TrackShadowbanTransition(accountID uint, userID string, previousStatus, newStatus models.Status, banID uint) error

func TrackUserInteraction 

func TrackUserInteraction(s *discordgo.Session, i *discordgo.InteractionCreate) error

func UpdateCaptchaUsage 

func UpdateCaptchaUsage(userID string) error

func UpdateMessageWithPreference added in v1.1.1 

func UpdateMessageWithPreference(s *discordgo.Session, i *discordgo.InteractionCreate, content string, embeds []*discordgo.MessageEmbed, components []discordgo.MessageComponent) error

func UpdateRateLimitBackoff added in v1.1.1 

func UpdateRateLimitBackoff(userID string, endpoint string) error

func ValidateAccountLimits added in v1.2.0 

func ValidateAccountLimits(userID string) error

func ValidateAndSanitizeInput added in v1.2.0 

func ValidateAndSanitizeInput(input string, maxLength int) string

func ValidateCaptchaKey 

func ValidateCaptchaKey(apiKey, provider string) (bool, float64, error)

func ValidateComponentsForDiscord added in v1.2.0 

func ValidateComponentsForDiscord(components []discordgo.MessageComponent) []discordgo.MessageComponent

func ValidateDefaultCapsolverConfig 

func ValidateDefaultCapsolverConfig() error

func ValidateEmbedLimits added in v1.2.0 

func ValidateEmbedLimits(embed *discordgo.MessageEmbed) *discordgo.MessageEmbed

func ValidateInteractionContext added in v1.2.0 

func ValidateInteractionContext(i *discordgo.InteractionCreate) error

func ValidateMessageLimits added in v1.2.0 

func ValidateMessageLimits(content string) string

func ValidateRuntimeHealth added in v1.2.0 

func ValidateRuntimeHealth() error

func ValidateUserShardAssignments added in v1.2.5 

func ValidateUserShardAssignments() (map[string]interface{}, error)

func VerifyEZCaptchaConfig 

func VerifyEZCaptchaConfig() bool

func VerifySSOCookie 

func VerifySSOCookie(ssoCookie string) bool

Types

type AccountValidationResult 

type AccountValidationResult struct {
	IsValid     bool
	Created     int64
	IsVIP       bool
	ExpiresAt   int64
	ProfileData map[string]interface{}
}

func ValidateAndGetAccountInfo 

func ValidateAndGetAccountInfo(ssoCookie string) (*AccountValidationResult, error)

type AdaptiveRateLimits 

type AdaptiveRateLimits struct {
	sync.RWMutex
	UserBackoffs  map[string]*UserBackoff
	BaseLimit     int
	HistoryWindow time.Duration
}

func (*AdaptiveRateLimits) GetBackoffDuration 

func (a *AdaptiveRateLimits) GetBackoffDuration(userID string) time.Duration

type AppShardManager added in v1.1.1 

type AppShardManager struct {
	sync.RWMutex
	ShardID       int
	TotalShards   int
	InstanceID    string
	HeartbeatTime time.Time
	Initialized   bool
	// contains filtered or unexported fields
}

func GetAppShardManager added in v1.1.1 

func GetAppShardManager() *AppShardManager

func (*AppShardManager) EnsureInitialized added in v1.2.5 

func (asm *AppShardManager) EnsureInitialized()

func (*AppShardManager) FallbackToSingleShard added in v1.2.5 

func (asm *AppShardManager) FallbackToSingleShard()

func (*AppShardManager) FilterUsersByShardAssignment added in v1.1.1 

func (asm *AppShardManager) FilterUsersByShardAssignment(userIDs []string) []string

func (*AppShardManager) GetAssignedUserIDs added in v1.2.5 

func (asm *AppShardManager) GetAssignedUserIDs(userIDs []string) []string

func (*AppShardManager) GetGuildShardID added in v1.1.1 

func (asm *AppShardManager) GetGuildShardID(guildID string) int

func (*AppShardManager) GetShardedUserCount added in v1.1.1 

func (asm *AppShardManager) GetShardedUserCount() (int64, error)

func (*AppShardManager) GetShardingStatus added in v1.1.1 

func (asm *AppShardManager) GetShardingStatus() map[string]interface{}

func (*AppShardManager) GetUserShardID added in v1.1.1 

func (asm *AppShardManager) GetUserShardID(userID string) int

func (*AppShardManager) GuildBelongsToInstance added in v1.1.1 

func (asm *AppShardManager) GuildBelongsToInstance(guildID string) bool

func (*AppShardManager) Initialize added in v1.1.1 

func (asm *AppShardManager) Initialize() error

func (*AppShardManager) IsLeader added in v1.2.5 

func (asm *AppShardManager) IsLeader() bool

func (*AppShardManager) IsUserAssignedToShard added in v1.1.1 

func (asm *AppShardManager) IsUserAssignedToShard(userID string) bool

func (*AppShardManager) SafeShardOperation added in v1.2.5 

func (asm *AppShardManager) SafeShardOperation(userID string, operation func() error) error

func (*AppShardManager) ShardBelongsToInstance added in v1.1.1 

func (asm *AppShardManager) ShardBelongsToInstance(userID string) bool

func (*AppShardManager) StartHeartbeat added in v1.1.1 

func (asm *AppShardManager) StartHeartbeat(ctx context.Context)

type BanResponse added in v1.1.1 

type BanResponse struct {
	Error     string `json:"error"`
	Success   string `json:"success"`
	CanAppeal bool   `json:"canAppeal"`
	Bans      []struct {
		Enforcement string `json:"enforcement"`
		Title       string `json:"title"`
		CanAppeal   bool   `json:"canAppeal"`
	} `json:"bans"`
}

type CapsolverSolver 

type CapsolverSolver struct {
	APIKey string
	AppID  string
}

func (*CapsolverSolver) SolveReCaptchaV2 

func (s *CapsolverSolver) SolveReCaptchaV2(siteKey, pageURL string) (string, error)

type CaptchaSolver 

type CaptchaSolver interface {
	SolveReCaptchaV2(siteKey, pageURL string) (string, error)
}

func GetCaptchaSolver 

func GetCaptchaSolver(userID string) (CaptchaSolver, error)

func NewCaptchaSolver 

func NewCaptchaSolver(apiKey, provider string) (CaptchaSolver, error)

type EZCaptchaSolver 

type EZCaptchaSolver struct {
	APIKey  string
	EzappID string
}

func (*EZCaptchaSolver) SolveReCaptchaV2 

func (s *EZCaptchaSolver) SolveReCaptchaV2(siteKey, pageURL string) (string, error)

type EdgeCaseHandler added in v1.2.0 

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

func GetEdgeCaseHandler added in v1.2.0 

func GetEdgeCaseHandler() *EdgeCaseHandler

func (*EdgeCaseHandler) Cleanup added in v1.2.0 

func (ech *EdgeCaseHandler) Cleanup()

func (*EdgeCaseHandler) EndInteraction added in v1.2.0 

func (ech *EdgeCaseHandler) EndInteraction(userID string)

func (*EdgeCaseHandler) IsRateLimited added in v1.2.0 

func (ech *EdgeCaseHandler) IsRateLimited(userID string) bool

func (*EdgeCaseHandler) RecordTemporaryFailure added in v1.2.0 

func (ech *EdgeCaseHandler) RecordTemporaryFailure(identifier string) bool

func (*EdgeCaseHandler) ResetTemporaryFailures added in v1.2.0 

func (ech *EdgeCaseHandler) ResetTemporaryFailures(identifier string)

func (*EdgeCaseHandler) SetRateLimit added in v1.2.0 

func (ech *EdgeCaseHandler) SetRateLimit(userID string, duration time.Duration)

func (*EdgeCaseHandler) StartInteraction added in v1.2.0 

func (ech *EdgeCaseHandler) StartInteraction(userID string) bool

type ErrorHandler added in v1.2.0 

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

func GetErrorHandler added in v1.2.0 

func GetErrorHandler() *ErrorHandler

func (*ErrorHandler) GetErrorStats added in v1.2.0 

func (eh *ErrorHandler) GetErrorStats(userID string) *ErrorStats

func (*ErrorHandler) MarkNotified added in v1.2.0 

func (eh *ErrorHandler) MarkNotified(userID string)

func (*ErrorHandler) RecordError added in v1.2.0 

func (eh *ErrorHandler) RecordError(userID string, errorType string, err error)

func (*ErrorHandler) ResetConsecutiveErrors added in v1.2.0 

func (eh *ErrorHandler) ResetConsecutiveErrors(userID string)

func (*ErrorHandler) ShouldNotifyUser added in v1.2.0 

func (eh *ErrorHandler) ShouldNotifyUser(userID string, errorType string) bool

type ErrorStats added in v1.2.0 

type ErrorStats struct {
	Count             int
	LastError         time.Time
	LastNotified      time.Time
	ConsecutiveErrors int
	ErrorTypes        map[string]int
}

type InstallContext 

type InstallContext string
const (
	ServerContext InstallContext = "server"
	DirectContext InstallContext = "direct"
)

func GetInstallContext 

func GetInstallContext(i *discordgo.InteractionCreate) InstallContext

type NotificationConfig 

type NotificationConfig struct {
	Type              string
	Cooldown          time.Duration
	AllowConsolidated bool
	MaxPerHour        int
}

type NotificationItem 

type NotificationItem struct {
	UserID     string
	Content    string
	AddedAt    time.Time
	RetryCount int
	Priority   int
}

type NotificationLimiter 

type NotificationLimiter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNotificationLimiter 

func NewNotificationLimiter() *NotificationLimiter

func (*NotificationLimiter) CanSendNotification 

func (nl *NotificationLimiter) CanSendNotification(userID string, notificationType string) bool

type NotificationQueue 

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

func (*NotificationQueue) AddNotification 

func (q *NotificationQueue) AddNotification(item NotificationItem)

func (*NotificationQueue) Shutdown 

func (q *NotificationQueue) Shutdown(ctx context.Context) error

type NotificationState 

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

type ProxyManager added in v1.1.1 

type ProxyManager struct {
	sync.RWMutex
	Proxies            []string
	ActiveProxies      map[string]bool
	ProxyFailures      map[string]int
	ProxyLastUsed      map[string]time.Time
	ProxyRateLimits    map[string]time.Time
	DefaultClient      *http.Client
	ProxyClients       map[string]*http.Client
	ProxyEnabled       bool
	RotationStrategy   string
	CurrentProxyIndex  int
	MaxFailures        int
	CooldownPeriod     time.Duration
	ProxyRefreshPeriod time.Duration
	LastRefresh        time.Time
	UserAgents         []string
}

func GetProxyManager added in v1.1.1 

func GetProxyManager() *ProxyManager

func (*ProxyManager) GetClient added in v1.1.1 

func (pm *ProxyManager) GetClient() *http.Client

func (*ProxyManager) MarkProxyFailure added in v1.1.1 

func (pm *ProxyManager) MarkProxyFailure(proxyURL string, reason string)

func (*ProxyManager) MarkProxyRateLimited added in v1.1.1 

func (pm *ProxyManager) MarkProxyRateLimited(proxyURL string, duration time.Duration)

func (*ProxyManager) MarkProxySuccess added in v1.1.1 

func (pm *ProxyManager) MarkProxySuccess(proxyURL string)

func (*ProxyManager) RefreshProxies added in v1.1.1 

func (pm *ProxyManager) RefreshProxies()

type ShadowbanPeriod added in v1.2.5 

type ShadowbanPeriod struct {
	AccountID     uint       `json:"account_id"`
	UserID        string     `json:"user_id"`
	AccountTitle  string     `json:"account_title"`
	StartTime     time.Time  `json:"start_time"`
	EndTime       *time.Time `json:"end_time,omitempty"`
	DurationHours *float64   `json:"duration_hours,omitempty"`
	IsCompleted   bool       `json:"is_completed"`
	StartBanID    uint       `json:"start_ban_id"`
	EndBanID      *uint      `json:"end_ban_id,omitempty"`
	CreatedAt     time.Time  `json:"created_at"`
	UpdatedAt     time.Time  `json:"updated_at"`
}

type ShardHealthReport added in v1.2.5 

type ShardHealthReport struct {
	CheckTime        time.Time              `json:"check_time"`
	Healthy          bool                   `json:"healthy"`
	Issues           []string               `json:"issues"`
	Warnings         []string               `json:"warnings"`
	CurrentShard     int                    `json:"current_shard"`
	TotalShards      int                    `json:"total_shards"`
	ActiveShards     int                    `json:"active_shards"`
	DeadShards       int                    `json:"dead_shards"`
	InstanceID       string                 `json:"instance_id"`
	IsLeader         bool                   `json:"is_leader"`
	TotalAccounts    int                    `json:"total_accounts"`
	ShardAccounts    int                    `json:"shard_accounts"`
	UserDistribution map[string]interface{} `json:"user_distribution"`
}

func ShardHealthCheck added in v1.2.5 

func ShardHealthCheck() (*ShardHealthReport, error)

func (*ShardHealthReport) String added in v1.2.5 

func (r *ShardHealthReport) String() string

type ShardManager added in v1.0.1 

type ShardManager struct {
	sync.Mutex
	Sessions       []*discordgo.Session
	MaxConcurrency int
	TotalShards    int
	StartedShards  int
}

func NewShardManager added in v1.0.1 

func NewShardManager() (*ShardManager, error)

func (*ShardManager) Close added in v1.0.1 

func (sm *ShardManager) Close()

func (*ShardManager) GetSession added in v1.0.1 

func (sm *ShardManager) GetSession(guildID string) *discordgo.Session

func (*ShardManager) StartShards added in v1.0.1 

func (sm *ShardManager) StartShards(token string, handlers map[string]func(*discordgo.Session, *discordgo.InteractionCreate)) error

type TwoCaptchaSolver 

type TwoCaptchaSolver struct {
	APIKey string
	SoftID string
}

func (*TwoCaptchaSolver) SolveReCaptchaV2 

func (s *TwoCaptchaSolver) SolveReCaptchaV2(siteKey, pageURL string) (string, error)

type UserBackoff 

type UserBackoff struct {
	LastSent            time.Time
	NotificationHistory []time.Time
	BackoffMultiplier   float64
	ConsecutiveCount    int
}

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.