Interactive/pkg/services/accounts.go

54 lines
1.6 KiB
Go
Raw Normal View History

2024-02-03 07:20:32 +00:00
package services
import (
2024-03-31 13:46:59 +00:00
"context"
2024-03-20 12:57:21 +00:00
"git.solsynth.dev/hydrogen/identity/pkg/grpc/proto"
"git.solsynth.dev/hydrogen/interactive/pkg/database"
"git.solsynth.dev/hydrogen/interactive/pkg/grpc"
"git.solsynth.dev/hydrogen/interactive/pkg/models"
"github.com/spf13/viper"
"time"
2024-02-03 07:20:32 +00:00
)
func FollowAccount(followerId, followingId uint) error {
relationship := models.AccountMembership{
FollowerID: followerId,
FollowingID: followingId,
}
return database.C.Create(&relationship).Error
}
func UnfollowAccount(followerId, followingId uint) error {
return database.C.Where(models.AccountMembership{
FollowerID: followerId,
FollowingID: followingId,
}).Delete(&models.AccountMembership{}).Error
}
func GetAccountFollowed(user models.Account, target models.Account) (models.AccountMembership, bool) {
var relationship models.AccountMembership
err := database.C.Model(&models.AccountMembership{}).
Where(&models.AccountMembership{FollowerID: user.ID, FollowingID: target.ID}).
2024-02-03 12:44:16 +00:00
First(&relationship).
2024-02-03 07:20:32 +00:00
Error
2024-02-03 12:44:16 +00:00
return relationship, err == nil
2024-02-03 07:20:32 +00:00
}
2024-03-31 13:46:59 +00:00
func NotifyAccount(user models.Account, subject, content string, realtime bool, links ...*proto.NotifyLink) error {
ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
defer cancel()
_, err := grpc.Notify.NotifyUser(ctx, &proto.NotifyRequest{
ClientId: viper.GetString("identity.client_id"),
ClientSecret: viper.GetString("identity.client_secret"),
Subject: subject,
Content: content,
Links: links,
2024-03-31 14:49:32 +00:00
RecipientId: uint64(user.ExternalID),
2024-03-31 13:46:59 +00:00
IsRealtime: realtime,
IsImportant: false,
})
return err
}