types.go

package main

import (
	"fmt"
	"net/url"
	"os"
	"time"
)

type Campaign struct {
	EmailListID  string       `json:"emailListId"`
	ProviderName ProviderName `json:"providerName"`
	OutputIDs    []string     `json:"outputIds"`
	RedirectUrl  string       `json:"redirectUrl"`
}

func (c Campaign) Link() (string, error) {
	var (
		protocol = os.Getenv(EnvProtocol)
		hostname = os.Getenv(EnvHostname)
	)

	if protocol == "" || hostname == "" {
		return "", missingEnv(EnvProtocol, EnvHostname)
	}

	oauthID, err := decenc.Encode(c.EmailListID, c.ProviderName, c.OutputIDs, c.RedirectUrl)
	if err != nil {
		return "", err
	}

	return fmt.Sprintf("%s//%s/c?c=%s", protocol, hostname, url.QueryEscape(oauthID)), nil
}

type DiscordOAuth2TokenResp struct {
	TokenType    string `json:"token_type"`
	AccessToken  string `json:"access_token"`
	ExpiresIn    int    `json:"expires_in"`
	RefreshToken string `json:"refresh_token"`
	Scope        string `json:"scope"`
}

type DiscordProviderResp struct {
	ID                   string  `json:"id"`
	Username             string  `json:"username"`
	Avatar               string  `json:"avatar"`
	Discriminator        string  `json:"discriminator"`
	PublicFlags          int     `json:"public_flags"`
	Flags                int     `json:"flags"`
	Banner               *string `json:"banner"`
	AccentColor          *int    `json:"accent_color"`
	GlobalName           *string `json:"global_name"`
	AvatarDecorationData *string `json:"avatar_decoration_data"`
	BannerColor          *string `json:"banner_color"`
	Clan                 *string `json:"clan"`
	MfaEnabled           bool    `json:"mfa_enabled"`
	Locale               string  `json:"locale"`
	PremiumType          int     `json:"premium_type"`
	Email                string  `json:"email"`
	Verified             bool    `json:"verified"`
}

type EmailList struct {
	ID        string    `json:"id"`
	UserID    string    `json:"userId"`
	Name      string    `json:"name"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

func NewEmailList(userID string, name string) *EmailList {
	now := time.Now()
	return &EmailList{
		ID:        NewUUID(),
		UserID:    userID,
		Name:      name,
		CreatedAt: now,
		UpdatedAt: now,
	}
}

type EmailListCreationReq struct {
	UserID string `json:"userId"`
	Name   string `json:"name"`
}

type EmailListUpdateReq struct {
	Name string `json:"name"`
}

type GoogleProviderResp struct {
	ID            string `json:"id"`
	Email         string `json:"email"`
	VerifiedEmail bool   `json:"verified_email"`
	Name          string `json:"name"`
	GivenName     string `json:"given_name"`
	FamilyName    string `json:"family_name"`
	Picture       string `json:"picture"`
}

type LoginInfo struct {
	Username string `json:"username"`
	Password string `json:"password"`
}

type Output interface {
	OutputName() OutputName
	GetUserID() string
	Handle(emailAddr string, name string) error
}

type OutputsData map[OutputName][]Output

type OutputCreationReq struct {
	UserID     string     `json:"userId"`
	OutputName OutputName `json:"outputName"`
	ListID     string     `json:"listId"`
	Param1     string     `json:"param1"`
	Param2     string     `json:"param2"`
	Param3     string     `json:"param3"`
}

type OutputUpdateReq struct {
	OutputName OutputName `json:"outputName"`
	ListID     string     `json:"listId"`
	Param1     string     `json:"param1"`
	Param2     string     `json:"param2"`
	Param3     string     `json:"param3"`
}

type AWeberOutput struct {
	ID         string    `json:"id"`
	UserID     string    `json:"userId"`
	ListID     string    `json:"listId"`
	AdTracking string    `json:"adTracking"`
	CreatedAt  time.Time `json:"createdAt"`
	UpdatedAt  time.Time `json:"updatedAt"`
}

type BrevoOutput struct {
	ID        string    `json:"id"`
	UserID    string    `json:"userId"`
	ListID    string    `json:"listId"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

type ResendOutput struct {
	ID         string    `json:"id"`
	UserID     string    `json:"userId"`
	AudienceID string    `json:"audienceId"`
	CreatedAt  time.Time `json:"createdAt"`
	UpdatedAt  time.Time `json:"updatedAt"`
}

type TelegramOutput struct {
	ID        string    `json:"id"`
	UserID    string    `json:"userId"`
	ChatID    string    `json:"chatId"`
	MsgFmt    string    `json:"msgFmt"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

type WebhookOutput struct {
	ID        string    `json:"id"`
	UserID    string    `json:"userId"`
	UrlFmt    string    `json:"urlFmt"`
	CreatedAt time.Time `json:"createdAt"`
	UpdatedAt time.Time `json:"updatedAt"`
}

type ProviderResult struct {
	Name      string `json:"name"`
	EmailAddr string `json:"emailAddr"`
}

type Subscriber struct {
	ID                 string       `json:"id"`
	EmailListID        string       `json:"emailListId"`
	UserID             string       `json:"userId"`
	SourceProviderName ProviderName `json:"sourceProviderName"`
	Name               string       `json:"name"`
	EmailAddr          string       `json:"emailAddr"`
	CreatedAt          time.Time    `json:"createdAt"`
	UpdatedAt          time.Time    `json:"updatedAt"`
}

func NewSubscriber(
	emailListID string,
	userID string,
	sourceProviderName ProviderName,
	name string,
	emailAddr string,
) *Subscriber {
	now := time.Now()
	return &Subscriber{
		ID:                 NewUUID(),
		EmailListID:        emailListID,
		UserID:             userID,
		SourceProviderName: sourceProviderName,
		Name:               name,
		EmailAddr:          emailAddr,
		CreatedAt:          now,
		UpdatedAt:          now,
	}
}

type SubscriberCreationReq struct {
	EmailListID        string       `json:"emailListId"`
	UserID             string       `json:"userId"`
	SourceProviderName ProviderName `json:"sourceProviderName"`
	Name               string       `json:"name"`
	EmailAddr          string       `json:"emailAddr"`
}

type SubscriberUpdateReq struct {
	Name      string `json:"name"`
	EmailAddr string `json:"emailAddr"`
}

type User struct {
	ID             string    `json:"id"`
	Name           string    `json:"name"`
	HashedPassword string    `json:"hashedPassword"`
	CreatedAt      time.Time `json:"createdAt"`
	UpdatedAt      time.Time `json:"updatedAt"`
}

type UserCreationReq struct {
	Name     string `json:"name"`
	Password string `json:"password"`
}

type UserUpdateReq struct {
	Name     string `json:"name"`
	Password string `json:"password"`
}

const (
	ContentTypeApplicationJson               string = "application/json"
	ContentTypeApplicationXwwwFormUrlEncoded string = "application/x-www-form-urlencoded"
)

type CookieName string

const (
	CookieNameCreatedAt    CookieName = "createdAt"
	CookieNameEmailListID  CookieName = "emailListId"
	CookieNameJWT          CookieName = "jwt"
	CookieNameOutputIDs    CookieName = "outputIds"
	CookieNameProviderName CookieName = "providerName"
	CookieNameRedirectURL  CookieName = "redirectUrl"
)

const (
	EnvBrevoApiKey           string = "BREVO_API_KEY"
	EnvCatchAllRedirectUrl   string = "CATCH_ALL_REDIRECT_URL"
	EnvCookieSecret          string = "COOKIE_SECRET"
	EnvCryptoSecret          string = "CRYPTO_SECRET"
	EnvDiscordClientID       string = "DISCORD_CLIENT_ID"
	EnvDiscordClientSecret   string = "DISCORD_CLIENT_SECRET"
	EnvGoogleClientID        string = "GOOGLE_CLIENT_ID"
	EnvGoogleClientSecret    string = "GOOGLE_CLIENT_SECRET"
	EnvGoogleOAuthStateStr   string = "GOOGLE_OAUTH_STATE_STR"
	EnvHostname              string = "HOST_NAME"
	EnvJWTSecret             string = "JWT_SECRET"
	EnvPort                  string = "PORT"
	EnvProtocol              string = "PROTOCOL"
	EnvPostgresConnStr       string = "POSTGRES_CONN_STR"
	EnvResendApiKey          string = "RESEND_API_KEY"
	EnvRootPassword          string = "ROOT_PASSWORD"
	EnvRootUsername          string = "ROOT_USERNAME"
	EnvRunningFromServerless string = "RUNNING_FROM_SERVERLESS"
	EnvTelegramBotID         string = "TELEGRAM_BOT_ID"
)

const (
	FormFieldAdTracking     string = "meta_adtracking"
	FormFieldClientID       string = "client_id"
	FormFieldClientSecret   string = "client_secret"
	FormFieldCode           string = "code"
	FormFieldEmail          string = "email"
	FormFieldGrantType      string = "grant_type"
	FormFieldListName       string = "listname"
	FormFieldName           string = "name"
	FormFieldRedirectUri    string = "redirect_uri"
	FormFieldText           string = "text"
	FormFieldTelegramChatID string = "chat_id"
)

const FormValueAuthorizationCode string = "authorization_code"

const (
	GoogleOauthScopeEmail   string = "email"
	GoogleOauthScopeProfile string = "profile"
)

const (
	HTTPHeaderAcceptEncoding string = "Accept-Encoding"
	HTTPHeaderAuthorization  string = "Authorization"
	HTTPHeaderContentType    string = "Content-Type"
)

const (
	JwtClaimExpiresAt string = "expiresAt"
	JwtClaimData      string = "data"
	JwtClaimUserID    string = "userID"
)

const (
	MuxVarUserID   string = "userID"
	MuxVarOutputID string = "outputID"
)

const JwtHeaderAlg string = "alg"

type OutputName string

const (
	OutputNameAWeber   OutputName = "aweber"
	OutputNameBrevo    OutputName = "brevo"
	OutputNameResend   OutputName = "resend"
	OutputNameTelegram OutputName = "telegram"
	OutputNameWebhook  OutputName = "webhook"
)

type ProviderName string

const (
	ProviderNameDiscord ProviderName = "Discord"
	ProviderNameGoogle  ProviderName = "Google"
)

var providerNames = []ProviderName{
	ProviderNameDiscord,
	ProviderNameGoogle,
}

const (
	QueryParamC     string = "c"
	QueryParamCode  string = "code"
	QueryParamState string = "state"
)

const (
	StringTrue  string = "true"
	StringFalse string = "false"
)

const (
	StrIpolEmailAddr string = "emailAddr"
	StrIpolName      string = "name"
)