62 lines
1.6 KiB
Go
62 lines
1.6 KiB
Go
|
package services
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"fmt"
|
||
|
|
|
||
|
|
"git.solsynth.dev/hydrogen/dealer/pkg/hyper"
|
||
|
|
"git.solsynth.dev/hydrogen/dealer/pkg/proto"
|
||
|
|
"git.solsynth.dev/hydrogen/messaging/pkg/internal/database"
|
||
|
|
"git.solsynth.dev/hydrogen/messaging/pkg/internal/gap"
|
||
|
|
"git.solsynth.dev/hydrogen/messaging/pkg/internal/models"
|
||
|
|
)
|
||
|
|
|
||
|
|
func SetTypingStatus(channelId uint, userId uint) error {
|
||
|
|
var account models.Account
|
||
|
|
if err := database.C.Where("id = ?", userId).First(&account).Error; err != nil {
|
||
|
|
return fmt.Errorf("account not found: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
var member models.ChannelMember
|
||
|
|
if err := database.C.
|
||
|
|
Where("account_id = ? AND channel_id = ?", userId, channelId).
|
||
|
|
First(&member).Error; err != nil {
|
||
|
|
return fmt.Errorf("channel member not found: %v", err)
|
||
|
|
} else {
|
||
|
|
member.Account = account
|
||
|
|
}
|
||
|
|
|
||
|
|
var channel models.Channel
|
||
|
|
if err := database.C.
|
||
|
|
Preload("Members").
|
||
|
|
Where("id = ?", channelId).
|
||
|
|
First(&channel).Error; err != nil {
|
||
|
|
return fmt.Errorf("channel not found: %v", err)
|
||
|
|
}
|
||
|
|
|
||
|
|
var boardcastTarget []uint64
|
||
|
|
for _, item := range channel.Members {
|
||
|
|
if item.AccountID == member.AccountID {
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
boardcastTarget = append(boardcastTarget, uint64(item.AccountID))
|
||
|
|
}
|
||
|
|
|
||
|
|
sc := proto.NewStreamControllerClient(gap.H.GetDealerGrpcConn())
|
||
|
|
_, err := sc.PushStreamBatch(context.Background(), &proto.PushStreamBatchRequest{
|
||
|
|
UserId: boardcastTarget,
|
||
|
|
Body: hyper.NetworkPackage{
|
||
|
|
Action: "status.typing",
|
||
|
|
Payload: map[string]any{
|
||
|
|
"user_id": userId,
|
||
|
|
"member_id": member.ID,
|
||
|
|
"channel_id": channelId,
|
||
|
|
"member": member,
|
||
|
|
"channel": channel,
|
||
|
|
},
|
||
|
|
}.Marshal(),
|
||
|
|
})
|
||
|
|
|
||
|
|
return err
|
||
|
|
}
|