dao

type Article struct {
	Id int64 `gorm:"primaryKey,autoIncrement"`
	// create an index for frequently queried column
	AuthorId int64  `gorm:"index"`
	Topic    string `gorm:"type=varchar(4096)"`
	Content  string `gorm:"type=BLOB"`
	// why use int64 here
	// bson doesn't support time.Time?
	Status uint8
	Ctime  int64
	Utime  int64
}

type ArticleDAO interface {
	GetById(context.Context, int64) (Article, error)
	GetByPublishedId(context.Context, int64) (PublishedArticle, error)
	Insert(context.Context, Article) (int64, error)
	GetByAuthorId(context.Context, int64, int, int) ([]Article, error)
	Sync(context.Context, Article) (int64, error)
	UpdateById(context.Context, Article) error
	SyncStatus(ctx context.Context, userId int64, artId int64, status domain.ArticleStatus) error
	ListPub(context.Context, time.Time, int, int) ([]PublishedArticle, error)
}

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

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

type AsyncSms struct {
	Id       int64  `gorm:"primaryKey, autoIncrement"`
	Config   []byte `gorm:"type:json"`
	Status   uint8
	RetryCnt int
	RetryMax int
	Utime    int64 `gorm:"index"`
	Ctime    int64
}

type AsyncSmsDAO interface {
	Insert(ctx context.Context, sms AsyncSms) error
	GetPreemptiveSms(ctx context.Context) (AsyncSms, error)
	MarkSuccess(ctx context.Context, smsId int64) error
	MarkFailure(ctx context.Context, smsId int64) error
}

type PublishedArticle struct {
	Article
}

type SmsConfig struct {
	TplId     string
	Args      []string
	PhoneNums []string
}

type User struct {
	Id       int64          `gorm:"primaryKey, autoIncrement"`
	Email    sql.NullString `gorm:"unique"`
	Password string
	Phone    sql.NullString `gorm:"unique"`

	Nickname string `gorm:"type=varchar(128)"`

	// YYYY-MM-DD
	Birthday int64
	AboutMe  string `gorm:"type=varchar(4096)"`

	// 数据库溯源
	Ctime int64
	Utime int64
}

type UserActivity struct {
	// 联合唯一索引：防止并发写入问题
	// 保证任何时刻这两个列都是一致的
	Id          int64  `gorm:"primaryKey,autoIncrement"`
	Biz         string `gorm:"type:varchar(128);uniqueIndex:biz_type_id"`
	BizId       int64  `gorm:"uniqueIndex:biz_type_id"`
	ReadCnt     int64
	LikeCnt     int64
	BookmarkCnt int64
	Utime       int64
	Ctime       int64
}

type UserActivityDAO interface {
	IncrReadCntIfPresent(ctx context.Context, biz string, bizId int64) error
	BatchIncrReadCntIfPresent(ctx context.Context, bizs []string, bizIds []int64) error
	GetReadByIds(ctx context.Context, biz string, bizIds []int64) ([]UserActivity, error)
}

type UserDAO interface {
	Insert(context.Context, User) error
	Create(context.Context, User) error
	FindByEmail(context.Context, string) (User, error)
	FindByPhone(context.Context, string) (User, error)
	FindById(context.Context, int64) (User, error)
	UpdateById(context.Context, User) error
}

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