Hypernet/Interactive
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 Fix determine subscription has or not

Browse Source
This commit is contained in:
LittleSheep 2024-09-17 01:43:01 +08:00
parent d2f24d0be2
commit 86cdf28b22
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/internal/services/subscriptions.go
View File

@ -50,7 +50,7 @@ func GetSubscriptionOnCategory(user models.Account, target models.Category) (*mo
func SubscribeToUser(user models.Account, target models.Account) (models.Subscription, error) { func SubscribeToUser(user models.Account, target models.Account) (models.Subscription, error) {
var subscription models.Subscription var subscription models.Subscription
if err := database.C.Where("follower_id = ? AND account_id = ?", user.ID, target.ID).First(&subscription).Error; err != nil { if err := database.C.Where("follower_id = ? AND account_id = ?", user.ID, target.ID).First(&subscription).Error; err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) { if !errors.Is(err, gorm.ErrRecordNotFound) {
return subscription, fmt.Errorf("subscription already exists") return subscription, fmt.Errorf("subscription already exists")
} }
return subscription, fmt.Errorf("unable to check subscription is exists or not: %v", err) return subscription, fmt.Errorf("unable to check subscription is exists or not: %v", err)
@ -68,7 +68,7 @@ func SubscribeToUser(user models.Account, target models.Account) (models.Subscri
func SubscribeToTag(user models.Account, target models.Tag) (models.Subscription, error) { func SubscribeToTag(user models.Account, target models.Tag) (models.Subscription, error) {
var subscription models.Subscription var subscription models.Subscription
if err := database.C.Where("follower_id = ? AND tag_id = ?", user.ID, target.ID).First(&subscription).Error; err != nil { if err := database.C.Where("follower_id = ? AND tag_id = ?", user.ID, target.ID).First(&subscription).Error; err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) { if !errors.Is(err, gorm.ErrRecordNotFound) {
return subscription, fmt.Errorf("subscription already exists") return subscription, fmt.Errorf("subscription already exists")
} }
return subscription, fmt.Errorf("unable to check subscription is exists or not: %v", err) return subscription, fmt.Errorf("unable to check subscription is exists or not: %v", err)
@ -86,7 +86,7 @@ func SubscribeToTag(user models.Account, target models.Tag) (models.Subscription
func SubscribeToCategory(user models.Account, target models.Category) (models.Subscription, error) { func SubscribeToCategory(user models.Account, target models.Category) (models.Subscription, error) {
var subscription models.Subscription var subscription models.Subscription
if err := database.C.Where("follower_id = ? AND category_id = ?", user.ID, target.ID).First(&subscription).Error; err != nil { if err := database.C.Where("follower_id = ? AND category_id = ?", user.ID, target.ID).First(&subscription).Error; err != nil {
if errors.Is(err, gorm.ErrRecordNotFound) { if !errors.Is(err, gorm.ErrRecordNotFound) {
return subscription, fmt.Errorf("subscription already exists") return subscription, fmt.Errorf("subscription already exists")
} }
return subscription, fmt.Errorf("unable to check subscription is exists or not: %v", err) return subscription, fmt.Errorf("unable to check subscription is exists or not: %v", err)