database

type FollowDTO struct {
	WhoId int64   `gorm:"not null;index;index:who_id_whom_id"`
	Who   UserDTO `gorm:"primaryKey;foreignkey:WhoId"`

	WhomId int64   `gorm:"not null;index:who_id_whom_id"`
	Whom   UserDTO `gorm:"primaryKey;foreignkey:WhomId"`
}

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

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

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

type ILatestRepository interface {
	Migrate() error
	Set(newValue int) error
	GetCurrent() (int, error)
}

type IMessageRepository interface {
	Migrate() error
	Create(message models.Message) error
	GetWithLimit(limit int) ([]models.Message, error)
	GetByUserId(userId int64, limit int) ([]models.Message, error)
	GetByUserAndItsFollowers(userId int64, limit int) ([]models.Message, error)
	FlagByMsgId(msgId int) (models.Message, error)
}

type IUserRepository interface {
	Migrate() error
	Create(users models.User) error
	GetByID(id int64) (*models.User, error)
	GetByUsername(username string) (*models.User, error)
	NumUsers() (int64, error)

	Follow(whoId int64, whomId int64) error
	Unfollow(whoId int64, whomId int64) error
	IsFollowing(whoId int64, whomId int64) (bool, error)
	AllFollowed(whoId int64) ([]*models.User, error)
}

type LatestDTO struct {
	Id    int `gorm:"primaryKey,autoIncrement"`
	Value int `gorm:"not null"`
}

type MessageDTO struct {
	gorm.Model

	AuthorId int     `gorm:"not null;index"`
	Author   UserDTO `gorm:"foreignkey:AuthorId"`
	Text     string  `gorm:"not null"`
	PubDate  int64   `gorm:"not null;index:,sort:desc"`
	Flagged  bool    `gorm:"not null"`
}

type OpenDatabaseFunc = func() gorm.Dialector

type UserDTO struct {
	gorm.Model

	Username     string `gorm:"not null;index"`
	Email        string `gorm:"not null"`
	PasswordHash string `gorm:"not null"`

	Followed  []FollowDTO `gorm:"foreignkey:WhoId"`
	Followers []FollowDTO `gorm:"foreignkey:WhomId"`
}