-
Notifications
You must be signed in to change notification settings - Fork 0
/
FollowsRepository.cs
56 lines (43 loc) · 2.07 KB
/
FollowsRepository.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
using Entities.Models;
using Entities.RequestFeatures;
using Microsoft.EntityFrameworkCore;
using Repositories.Contracts;
namespace Repositories.EFCore
{
public class FollowsRepository(RepositoryContext context) : RepositoryBase<Follows>(context), IFollowsRepository
{
public async Task<IEnumerable<string>> GetAllFollowingIdsAsync(string userId, bool trackChanges)
{
return await FindAll(trackChanges)
.Where(f => f.FollowerId.Equals(userId) && f.RequestStatus)
.Select(f => f.FollowingId)
.ToListAsync();
}
public async Task<PagedList<Follows>> GetAllFollowersAsync(string userId, FollowParameters parameters, bool trackChanges)
{
var followers = await FindAll(trackChanges)
.Include(f => f.FollowerUser)
.Where(f => f.FollowingId.Equals(userId) && f.RequestStatus)
.OrderByDescending(f => f.CreateDate)
.ToListAsync();
return PagedList<Follows>
.ToPagedList(followers, parameters);
}
public async Task<PagedList<Follows>> GetAllFollowingsAsync(string userId, FollowParameters parameters, bool trackChanges)
{
var followers = await FindAll(trackChanges)
.Include(f => f.FollowingUser)
.Where(f => f.FollowerId.Equals(userId) && f.RequestStatus)
.OrderByDescending(f => f.CreateDate)
.ToListAsync();
return PagedList<Follows>
.ToPagedList(followers, parameters);
}
public async Task<Follows?> CheckUserFollowingAsync(string followerId, string followingId, bool trackChanges) =>
await FindByCondition(f => f.FollowerId.Equals(followerId) && f.FollowingId.Equals(followingId), trackChanges)
.SingleOrDefaultAsync();
public void FollowUser(Follows follow) => Create(follow);
public void UnFollowUser(Follows follow) => Delete(follow);
}
}