32 lines
No EOL
1.2 KiB
C#
32 lines
No EOL
1.2 KiB
C#
using Iceshrimp.Backend.Core.Database;
|
|
using Iceshrimp.Backend.Core.Database.Tables;
|
|
using Microsoft.EntityFrameworkCore;
|
|
|
|
namespace Iceshrimp.Backend.Core.Services;
|
|
|
|
public class PollService(
|
|
DatabaseContext db,
|
|
ActivityPub.ActivityRenderer activityRenderer,
|
|
ActivityPub.UserRenderer userRenderer,
|
|
ActivityPub.ActivityDeliverService deliverSvc
|
|
)
|
|
{
|
|
public async Task RegisterPollVote(PollVote pollVote, Poll poll, Note note, bool updateVotersCount = true)
|
|
{
|
|
await db.Database
|
|
.ExecuteSqlAsync($"""UPDATE "poll" SET "votes"[{pollVote.Choice + 1}] = "votes"[{pollVote.Choice + 1}] + 1 WHERE "noteId" = {note.Id}""");
|
|
|
|
if (poll.UserHost == null)
|
|
{
|
|
if (!updateVotersCount) return;
|
|
await db.Database
|
|
.ExecuteSqlAsync($"""UPDATE "poll" SET "votersCount" = (SELECT COUNT(*) FROM (SELECT DISTINCT "userId" FROM "poll_vote" WHERE "noteId" = {poll.NoteId})) WHERE "noteId" = {poll.NoteId};""");
|
|
return;
|
|
}
|
|
|
|
var vote = activityRenderer.RenderVote(pollVote, poll, note);
|
|
var actor = userRenderer.RenderLite(pollVote.User);
|
|
var activity = ActivityPub.ActivityRenderer.RenderCreate(vote, actor);
|
|
await deliverSvc.DeliverToAsync(activity, pollVote.User, note.User);
|
|
}
|
|
} |