mirror of
https://github.com/raseels-repos/golang-saas-starter-kit.git
synced 2025-06-06 23:46:29 +02:00
238 lines
11 KiB
Go
238 lines
11 KiB
Go
package account
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
"database/sql/driver"
|
|
"encoding/json"
|
|
"geeks-accelerator/oss/saas-starter-kit/internal/platform/web"
|
|
"time"
|
|
|
|
"github.com/lib/pq"
|
|
"github.com/pkg/errors"
|
|
"gopkg.in/go-playground/validator.v9"
|
|
)
|
|
|
|
// Account represents someone with access to our system.
|
|
type Account struct {
|
|
ID string `json:"id" validate:"required,uuid" example:"c4653bf9-5978-48b7-89c5-95704aebb7e2"`
|
|
Name string `json:"name" validate:"required,unique" example:"Company Name"`
|
|
Address1 string `json:"address1" validate:"required" example:"221 Tatitlek Ave"`
|
|
Address2 string `json:"address2" validate:"omitempty" example:"Box #1832"`
|
|
City string `json:"city" validate:"required" example:"Valdez"`
|
|
Region string `json:"region" validate:"required" example:"AK"`
|
|
Country string `json:"country" validate:"required" example:"USA"`
|
|
Zipcode string `json:"zipcode" validate:"required" example:"99686"`
|
|
Status AccountStatus `json:"status" validate:"omitempty,oneof=active pending disabled" swaggertype:"string" enums:"active,pending,disabled" example:"active"`
|
|
Timezone string `json:"timezone" validate:"omitempty" example:"America/Anchorage"`
|
|
SignupUserID *sql.NullString `json:"signup_user_id,omitempty" validate:"omitempty,uuid" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
BillingUserID *sql.NullString `json:"billing_user_id,omitempty" validate:"omitempty,uuid" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
CreatedAt time.Time `json:"created_at"`
|
|
UpdatedAt time.Time `json:"updated_at"`
|
|
ArchivedAt *pq.NullTime `json:"archived_at,omitempty"`
|
|
}
|
|
|
|
// AccountResponse represents someone with access to our system that is returned for display.
|
|
type AccountResponse struct {
|
|
ID string `json:"id" example:"c4653bf9-5978-48b7-89c5-95704aebb7e2"`
|
|
Name string `json:"name" example:"Company Name"`
|
|
Address1 string `json:"address1" example:"221 Tatitlek Ave"`
|
|
Address2 string `json:"address2" example:"Box #1832"`
|
|
City string `json:"city" example:"Valdez"`
|
|
Region string `json:"region" example:"AK"`
|
|
Country string `json:"country" example:"USA"`
|
|
Zipcode string `json:"zipcode" example:"99686"`
|
|
Status web.EnumResponse `json:"status"` // Status is enum with values [active, pending, disabled].
|
|
Timezone string `json:"timezone" example:"America/Anchorage"`
|
|
SignupUserID *string `json:"signup_user_id,omitempty" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
BillingUserID *string `json:"billing_user_id,omitempty" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
CreatedAt web.TimeResponse `json:"created_at"` // CreatedAt contains multiple format options for display.
|
|
UpdatedAt web.TimeResponse `json:"updated_at"` // UpdatedAt contains multiple format options for display.
|
|
ArchivedAt *web.TimeResponse `json:"archived_at,omitempty"` // ArchivedAt contains multiple format options for display.
|
|
}
|
|
|
|
// Response transforms Account and AccountResponse that is used for display.
|
|
// Additional filtering by context values or translations could be applied.
|
|
func (m *Account) Response(ctx context.Context) *AccountResponse {
|
|
if m == nil {
|
|
return nil
|
|
}
|
|
|
|
r := &AccountResponse{
|
|
ID: m.ID,
|
|
Name: m.Name,
|
|
Address1: m.Address1,
|
|
Address2: m.Address2,
|
|
City: m.City,
|
|
Region: m.Region,
|
|
Country: m.Country,
|
|
Zipcode: m.Zipcode,
|
|
Timezone: m.Timezone,
|
|
Status: web.NewEnumResponse(ctx, m.Status, AccountStatus_ValuesInterface()...),
|
|
CreatedAt: web.NewTimeResponse(ctx, m.CreatedAt),
|
|
UpdatedAt: web.NewTimeResponse(ctx, m.UpdatedAt),
|
|
}
|
|
|
|
if m.SignupUserID != nil {
|
|
r.SignupUserID = &m.SignupUserID.String
|
|
}
|
|
if m.BillingUserID != nil {
|
|
r.BillingUserID = &m.BillingUserID.String
|
|
}
|
|
|
|
if m.ArchivedAt != nil && !m.ArchivedAt.Time.IsZero() {
|
|
at := web.NewTimeResponse(ctx, m.ArchivedAt.Time)
|
|
r.ArchivedAt = &at
|
|
}
|
|
|
|
return r
|
|
}
|
|
|
|
func (m *AccountResponse) UnmarshalBinary(data []byte) error {
|
|
if data == nil || len(data) == 0 {
|
|
return nil
|
|
}
|
|
return json.Unmarshal(data, m)
|
|
}
|
|
|
|
func (m *AccountResponse) MarshalBinary() ([]byte, error) {
|
|
return json.Marshal(m)
|
|
}
|
|
|
|
// Accounts a list of Accounts.
|
|
type Accounts []*Account
|
|
|
|
// Response transforms a list of Accounts to a list of AccountResponses.
|
|
func (m *Accounts) Response(ctx context.Context) []*AccountResponse {
|
|
var l []*AccountResponse
|
|
if m != nil && len(*m) > 0 {
|
|
for _, n := range *m {
|
|
l = append(l, n.Response(ctx))
|
|
}
|
|
}
|
|
|
|
return l
|
|
}
|
|
|
|
// AccountCreateRequest contains information needed to create a new Account.
|
|
type AccountCreateRequest struct {
|
|
Name string `json:"name" validate:"required,unique" example:"Company Name"`
|
|
Address1 string `json:"address1" validate:"required" example:"221 Tatitlek Ave"`
|
|
Address2 string `json:"address2" validate:"omitempty" example:"Box #1832"`
|
|
City string `json:"city" validate:"required" example:"Valdez"`
|
|
Region string `json:"region" validate:"required" example:"AK"`
|
|
Country string `json:"country" validate:"required" example:"USA"`
|
|
Zipcode string `json:"zipcode" validate:"required" example:"99686"`
|
|
Status *AccountStatus `json:"status,omitempty" validate:"omitempty,oneof=active pending disabled" swaggertype:"string" enums:"active,pending,disabled" example:"active"`
|
|
Timezone *string `json:"timezone,omitempty" validate:"omitempty" example:"America/Anchorage"`
|
|
SignupUserID *string `json:"signup_user_id,omitempty" validate:"omitempty,uuid" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
BillingUserID *string `json:"billing_user_id,omitempty" validate:"omitempty,uuid" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
}
|
|
|
|
// AccountReadRequest defines the information needed to read an account.
|
|
type AccountReadRequest struct {
|
|
ID string `json:"id" validate:"required,uuid" example:"c4653bf9-5978-48b7-89c5-95704aebb7e2"`
|
|
IncludeArchived bool `json:"include-archived" example:"false"`
|
|
}
|
|
|
|
// AccountUpdateRequest defines what information may be provided to modify an existing
|
|
// Account. All fields are optional so clients can send just the fields they want
|
|
// changed. It uses pointer fields so we can differentiate between a field that
|
|
// was not provided and a field that was provided as explicitly blank. Normally
|
|
// we do not want to use pointers to basic types but we make exceptions around
|
|
// marshalling/unmarshalling.
|
|
type AccountUpdateRequest struct {
|
|
ID string `json:"id" validate:"required,uuid" example:"c4653bf9-5978-48b7-89c5-95704aebb7e2"`
|
|
Name *string `json:"name,omitempty" validate:"omitempty,unique" example:"Company Name"`
|
|
Address1 *string `json:"address1,omitempty" validate:"omitempty" example:"221 Tatitlek Ave"`
|
|
Address2 *string `json:"address2,omitempty" validate:"omitempty" example:"Box #1832"`
|
|
City *string `json:"city,omitempty" validate:"omitempty" example:"Valdez"`
|
|
Region *string `json:"region,omitempty" validate:"omitempty" example:"AK"`
|
|
Country *string `json:"country,omitempty" validate:"omitempty" example:"USA"`
|
|
Zipcode *string `json:"zipcode,omitempty" validate:"omitempty" example:"99686"`
|
|
Status *AccountStatus `json:"status,omitempty" validate:"omitempty,oneof=active pending disabled" swaggertype:"string" enums:"active,pending,disabled" example:"disabled"`
|
|
Timezone *string `json:"timezone,omitempty" validate:"omitempty" example:"America/Anchorage"`
|
|
SignupUserID *string `json:"signup_user_id,omitempty" validate:"omitempty,uuid" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
BillingUserID *string `json:"billing_user_id,omitempty" validate:"omitempty,uuid" swaggertype:"string" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
}
|
|
|
|
// AccountArchiveRequest defines the information needed to archive an account. This will archive (soft-delete) the
|
|
// existing database entry.
|
|
type AccountArchiveRequest struct {
|
|
ID string `json:"id" validate:"required,uuid" example:"c4653bf9-5978-48b7-89c5-95704aebb7e2"`
|
|
}
|
|
|
|
// AccountDeleteRequest defines the information needed to delete a user.
|
|
type AccountDeleteRequest struct {
|
|
ID string `json:"id" validate:"required,uuid" example:"d69bdef7-173f-4d29-b52c-3edc60baf6a2"`
|
|
}
|
|
|
|
// AccountFindRequest defines the possible options to search for accounts. By default
|
|
// archived accounts will be excluded from response.
|
|
type AccountFindRequest struct {
|
|
Where string `json:"where" example:"name = ? and status = ?"`
|
|
Args []interface{} `json:"args" swaggertype:"array,string" example:"Company Name,active"`
|
|
Order []string `json:"order" example:"created_at desc"`
|
|
Limit *uint `json:"limit" example:"10"`
|
|
Offset *uint `json:"offset" example:"20"`
|
|
IncludeArchived bool `json:"include-archived" example:"false"`
|
|
}
|
|
|
|
// AccountStatus represents the status of an account.
|
|
type AccountStatus string
|
|
|
|
// AccountStatus values define the status field of a user account.
|
|
const (
|
|
// AccountStatus_Active defines the state when a user can access an account.
|
|
AccountStatus_Active AccountStatus = "active"
|
|
// AccountStatus_Pending defined the state when an account was created but
|
|
// not activated.
|
|
AccountStatus_Pending AccountStatus = "pending"
|
|
// AccountStatus_Disabled defines the state when a user has been disabled from
|
|
// accessing an account.
|
|
AccountStatus_Disabled AccountStatus = "disabled"
|
|
)
|
|
|
|
// AccountStatus_Values provides list of valid AccountStatus values.
|
|
var AccountStatus_Values = []AccountStatus{
|
|
AccountStatus_Active,
|
|
AccountStatus_Pending,
|
|
AccountStatus_Disabled,
|
|
}
|
|
|
|
// AccountStatus_ValuesInterface returns the AccountStatus options as a slice interface.
|
|
func AccountStatus_ValuesInterface() []interface{} {
|
|
var l []interface{}
|
|
for _, v := range AccountStatus_Values {
|
|
l = append(l, v.String())
|
|
}
|
|
return l
|
|
}
|
|
|
|
// Scan supports reading the AccountStatus value from the database.
|
|
func (s *AccountStatus) Scan(value interface{}) error {
|
|
asBytes, ok := value.([]byte)
|
|
if !ok {
|
|
return errors.New("Scan source is not []byte")
|
|
}
|
|
*s = AccountStatus(string(asBytes))
|
|
return nil
|
|
}
|
|
|
|
// Value converts the AccountStatus value to be stored in the database.
|
|
func (s AccountStatus) Value() (driver.Value, error) {
|
|
v := validator.New()
|
|
|
|
errs := v.Var(s, "required,oneof=active invited disabled")
|
|
if errs != nil {
|
|
return nil, errs
|
|
}
|
|
|
|
return string(s), nil
|
|
}
|
|
|
|
// String converts the AccountStatus value to a string.
|
|
func (s AccountStatus) String() string {
|
|
return string(s)
|
|
}
|