dao

package
v2.9.3 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

Convert Entity to JSON Response Data Structure for API TODO: (refactor) consider to extract this file to a new package

Index

Constants

View Source 
const (
	UserByIDKey            = "user#id=%d"
	UserByNameEmailKey     = "user#name=%s;email=%s"
	UserIDByEmailKey       = "user_id#email=%s"
	SiteByIDKey            = "site#id=%d"
	SiteByNameKey          = "site#name=%s"
	PageByIDKey            = "page#id=%d"
	PageByKeySiteNameKey   = "page#key=%s;site_name=%s"
	CommentByIDKey         = "comment#id=%d"
	CommentChildIDsByIDKey = "comment_child_ids#id=%d"
	NotifyByUserCommentKey = "notify#user_id=%d;comment_id=%d"
)
View Source 
const CommonDateTimeFormat = "2006-01-02 15:04:05"

Variables

This section is empty.

Functions

func FindCreateAction 

func FindCreateAction[T EntityHasIsEmpty](
	key string,
	findAction func() (T, error),
	createAction func() (T, error),
) (T, error)

FindCreateAction is a thread-safe function that attempts to find an entity using the provided findAction function. If the entity does not exist or the result is empty, it will execute the createAction function to create a new entity.

The function ensures that only one goroutine can perform the find or create operation for a given key at a time, using the singleflight mechanism to prevent duplicate operations.

func GetTitleByURL 

func GetTitleByURL(url string) (string, error)

func QueryDBWithCache 

func QueryDBWithCache[T any](dao *Dao, name string, queryDB func() (T, error)) (T, error)

func QueryDBWithoutCache 

func QueryDBWithoutCache[T any](dao *Dao, name string, queryDB func() (T, error)) (T, error)

Types

type DB 

type DB = gorm.DB

type Dao 

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

func NewDao 

func NewDao(db *DB) *Dao

Create new dao instance

This function will auto migrate database tables

func (*Dao) CacheAction 

func (dao *Dao) CacheAction(fn func(cache *DaoCache))

func (*Dao) CacheFlushAll 

func (dao *Dao) CacheFlushAll()

清空缓存

func (*Dao) CacheWarmUp 

func (dao *Dao) CacheWarmUp()

缓存预热

func (*Dao) CookAllComments 

func (dao *Dao) CookAllComments(comments []*entity.Comment) []entity.CookedComment

func (*Dao) CookAllNotifies 

func (dao *Dao) CookAllNotifies(notifies []entity.Notify) []entity.CookedNotify

func (*Dao) CookAllPages 

func (dao *Dao) CookAllPages(pages []entity.Page) []entity.CookedPage

func (*Dao) CookComment 

func (dao *Dao) CookComment(c *entity.Comment) entity.CookedComment

func (*Dao) CookCommentForEmail 

func (dao *Dao) CookCommentForEmail(c *entity.Comment) entity.CookedCommentForEmail

func (*Dao) CookNotify 

func (dao *Dao) CookNotify(n *entity.Notify) entity.CookedNotify

func (*Dao) CookPage 

func (dao *Dao) CookPage(p *entity.Page) entity.CookedPage

func (*Dao) CookSite 

func (dao *Dao) CookSite(s *entity.Site) entity.CookedSite

func (*Dao) CookUser 

func (dao *Dao) CookUser(u *entity.User) entity.CookedUser

func (*Dao) CreateAuthIdentity 

func (dao *Dao) CreateAuthIdentity(identity *entity.AuthIdentity) error

func (*Dao) CreateComment 

func (dao *Dao) CreateComment(comment *entity.Comment) error

func (*Dao) CreatePage 

func (dao *Dao) CreatePage(page *entity.Page) error

func (*Dao) CreateSite 

func (dao *Dao) CreateSite(site *entity.Site) error

func (*Dao) CreateUser 

func (dao *Dao) CreateUser(user *entity.User) error

func (*Dao) DB 

func (dao *Dao) DB() *DB

func (*Dao) DelAuthIdentity 

func (dao *Dao) DelAuthIdentity(authIdentity *entity.AuthIdentity) error

func (*Dao) DelComment 

func (dao *Dao) DelComment(comment *entity.Comment) error

func (*Dao) DelCommentChildren 

func (dao *Dao) DelCommentChildren(parentID uint) error

删除所有子评论

func (*Dao) DelPage 

func (dao *Dao) DelPage(page *entity.Page) error

func (*Dao) DelSite 

func (dao *Dao) DelSite(site *entity.Site) error

func (*Dao) DelUser 

func (dao *Dao) DelUser(user *entity.User) error

func (*Dao) DropConstraintsIfExist 

func (dao *Dao) DropConstraintsIfExist()

Remove all constraints

func (*Dao) FetchCommentForNotify 

func (dao *Dao) FetchCommentForNotify(n *entity.Notify) entity.Comment

func (*Dao) FetchPageForComment 

func (dao *Dao) FetchPageForComment(c *entity.Comment) entity.Page

func (*Dao) FetchPageFromURL 

func (dao *Dao) FetchPageFromURL(p *entity.Page) error

func (*Dao) FetchSiteForComment 

func (dao *Dao) FetchSiteForComment(c *entity.Comment) entity.Site

func (*Dao) FetchSiteForPage 

func (dao *Dao) FetchSiteForPage(p *entity.Page) entity.Site

func (*Dao) FetchUserForComment 

func (dao *Dao) FetchUserForComment(c *entity.Comment) entity.User

func (*Dao) FetchUserForNotify 

func (dao *Dao) FetchUserForNotify(n *entity.Notify) entity.User

获取接收通知的用户

func (*Dao) FindAllSites 

func (dao *Dao) FindAllSites() []entity.Site

func (*Dao) FindAllSitesCooked 

func (dao *Dao) FindAllSitesCooked() []entity.CookedSite

func (*Dao) FindAuthIdentityByRemoteUID 

func (dao *Dao) FindAuthIdentityByRemoteUID(provider string, remoteUID string) entity.AuthIdentity

func (*Dao) FindAuthIdentityByToken 

func (dao *Dao) FindAuthIdentityByToken(provider string, token string) entity.AuthIdentity

func (*Dao) FindAuthIdentityByUserID 

func (dao *Dao) FindAuthIdentityByUserID(provider string, userID uint) entity.AuthIdentity

func (*Dao) FindComment 

func (dao *Dao) FindComment(id uint, checkers ...func(*entity.Comment) bool) entity.Comment

func (*Dao) FindCommentChildren 

func (dao *Dao) FindCommentChildren(parentID uint, checkers ...func(*entity.Comment) bool) []entity.Comment

func (*Dao) FindCommentChildrenShallow 

func (dao *Dao) FindCommentChildrenShallow(parentID uint, checkers ...func(*entity.Comment) bool) []entity.Comment

(Cached：parent-comments)

func (*Dao) FindCommentRootID 

func (dao *Dao) FindCommentRootID(rid uint) uint

func (*Dao) FindCreateNotify 

func (dao *Dao) FindCreateNotify(userID uint, commentID uint) entity.Notify

func (*Dao) FindCreatePage 

func (dao *Dao) FindCreatePage(pageKey string, pageTitle string, siteName string) entity.Page

func (*Dao) FindCreateSite 

func (dao *Dao) FindCreateSite(siteName string, siteURLs string) entity.Site

func (*Dao) FindCreateUser 

func (dao *Dao) FindCreateUser(name string, email string, link string) (entity.User, error)

func (*Dao) FindNotify 

func (dao *Dao) FindNotify(userID uint, commentID uint) entity.Notify

#region Notify

func (*Dao) FindNotifyForComment 

func (dao *Dao) FindNotifyForComment(commentID uint, key string) entity.Notify

func (*Dao) FindNotifyParentComment 

func (dao *Dao) FindNotifyParentComment(n *entity.Notify) entity.Comment

func (*Dao) FindPage 

func (dao *Dao) FindPage(key string, siteName string) entity.Page

func (*Dao) FindPageByID 

func (dao *Dao) FindPageByID(id uint) entity.Page

func (*Dao) FindSite 

func (dao *Dao) FindSite(name string) entity.Site

func (*Dao) FindSiteByID 

func (dao *Dao) FindSiteByID(id uint) entity.Site

func (*Dao) FindUnreadNotifies 

func (dao *Dao) FindUnreadNotifies(userID uint) []entity.Notify

func (*Dao) FindUser 

func (dao *Dao) FindUser(name string, email string) entity.User

查找用户 (精确查找 name & email)

func (*Dao) FindUserByID 

func (dao *Dao) FindUserByID(id uint) entity.User

查找用户 (通过 ID)

func (*Dao) FindUserIdsByEmail 

func (dao *Dao) FindUserIdsByEmail(email string) []uint

查找用户 ID (仅根据 email)

func (*Dao) FindUsersByEmail 

func (dao *Dao) FindUsersByEmail(email string) []entity.User

查找用户 (仅根据 email)

func (*Dao) GetAllAdminIDs 

func (dao *Dao) GetAllAdminIDs() []uint

func (*Dao) GetAllAdmins 

func (dao *Dao) GetAllAdmins() []entity.User

#region 管理员账号检测

func (*Dao) GetLinkToReplyByComment 

func (dao *Dao) GetLinkToReplyByComment(c *entity.Comment, notifyKey ...string) string

获取评论回复链接

func (*Dao) GetPageAccessibleURL 

func (dao *Dao) GetPageAccessibleURL(p *entity.Page, s ...*entity.Site) string

获取可访问链接

func (*Dao) GetReadLinkByNotify 

func (dao *Dao) GetReadLinkByNotify(n *entity.Notify) string

func (*Dao) GetTableName 

func (dao *Dao) GetTableName(entity any) string

Get the table name of the entity

func (*Dao) GetUserAllCommentIDs 

func (dao *Dao) GetUserAllCommentIDs(userID uint) []uint

func (*Dao) GetVoteNum 

func (dao *Dao) GetVoteNum(targetID uint, voteType string) int

#region Vote

func (*Dao) GetVoteNumUpDown 

func (dao *Dao) GetVoteNumUpDown(targetID uint, voteTo string) (int, int)

func (*Dao) IsAdminUser 

func (dao *Dao) IsAdminUser(userID uint) bool

func (*Dao) IsAdminUserByNameEmail 

func (dao *Dao) IsAdminUserByNameEmail(name string, email string) bool

func (*Dao) MergePages 

func (dao *Dao) MergePages()

func (*Dao) MigrateModels 

func (dao *Dao) MigrateModels()

func (*Dao) MigrateRootID 

func (dao *Dao) MigrateRootID()

func (*Dao) NewNotify 

func (dao *Dao) NewNotify(userID uint, commentID uint) entity.Notify

func (*Dao) NewPage 

func (dao *Dao) NewPage(key string, pageTitle string, siteName string) entity.Page

func (*Dao) NewSite 

func (dao *Dao) NewSite(name string, urls string) entity.Site

func (*Dao) NewUser 

func (dao *Dao) NewUser(name string, email string, link string) (entity.User, error)

func (*Dao) NewVote 

func (dao *Dao) NewVote(targetID uint, voteType entity.VoteType, userID uint, ua string, ip string) (entity.Vote, error)

func (*Dao) NotifySetEmailed 

func (dao *Dao) NotifySetEmailed(n *entity.Notify) error

func (*Dao) NotifySetInitial 

func (dao *Dao) NotifySetInitial(n *entity.Notify) error

func (*Dao) NotifySetRead 

func (dao *Dao) NotifySetRead(n *entity.Notify) error

func (*Dao) SetCache 

func (dao *Dao) SetCache(cache *DaoCache)

func (*Dao) SetCommentEmailHashFunc 

func (dao *Dao) SetCommentEmailHashFunc(fn func(string) string)

func (*Dao) UpdateAuthIdentity 

func (dao *Dao) UpdateAuthIdentity(authIdentity *entity.AuthIdentity) error

func (*Dao) UpdateComment 

func (dao *Dao) UpdateComment(comment *entity.Comment) error

更新评论

func (*Dao) UpdatePage 

func (dao *Dao) UpdatePage(page *entity.Page) error

func (*Dao) UpdateSite 

func (dao *Dao) UpdateSite(site *entity.Site) error

func (*Dao) UpdateUser 

func (dao *Dao) UpdateUser(user *entity.User) error

func (*Dao) UserNotifyMarkAllAsRead 

func (dao *Dao) UserNotifyMarkAllAsRead(userID uint) error

func (*Dao) UserToCookedForAdmin 

func (dao *Dao) UserToCookedForAdmin(u *entity.User) entity.CookedUserForAdmin

func (*Dao) VoteSync 

func (dao *Dao) VoteSync()

type DaoCache 

type DaoCache struct {
	*cache.Cache
}

func NewCacheAdaptor 

func NewCacheAdaptor(cache *cache.Cache) *DaoCache

func (*DaoCache) ChildCommentCacheDel 

func (c *DaoCache) ChildCommentCacheDel(comment *entity.Comment)

func (*DaoCache) ChildCommentCacheSave 

func (c *DaoCache) ChildCommentCacheSave(comment *entity.Comment) error

缓存 父ID=>子ID 评论数据

func (*DaoCache) CommentCacheDel 

func (c *DaoCache) CommentCacheDel(comment *entity.Comment)

func (*DaoCache) CommentCacheSave 

func (c *DaoCache) CommentCacheSave(comment *entity.Comment) (err error)

func (*DaoCache) PageCacheDel 

func (c *DaoCache) PageCacheDel(page *entity.Page)

func (*DaoCache) PageCacheSave 

func (c *DaoCache) PageCacheSave(page *entity.Page) error

func (*DaoCache) SiteCacheDel 

func (c *DaoCache) SiteCacheDel(site *entity.Site)

func (*DaoCache) SiteCacheSave 

func (c *DaoCache) SiteCacheSave(site *entity.Site) error

func (*DaoCache) UserCacheDel 

func (c *DaoCache) UserCacheDel(user *entity.User)

func (*DaoCache) UserCacheSave 

func (c *DaoCache) UserCacheSave(user *entity.User) error

type EntityHasIsEmpty 

type EntityHasIsEmpty interface {
	IsEmpty() bool
}

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.