Amatsugu/AobaV2
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects 1 Releases Wiki Activity

fixed search

Browse Source
This commit is contained in:
Amatsugu
2025-06-13 19:14:33 -04:00
parent adf682a981
commit 9f557043a1
2 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
AobaCore/Services/AobaService.cs
View File

@@ -23,9 +23,12 @@ public class AobaService(IMongoDatabase db)
return await _media.Find(m => m.MediaId == id).FirstOrDefaultAsync(cancellationToken); return await _media.Find(m => m.MediaId == id).FirstOrDefaultAsync(cancellationToken);
} }
public async Task<PagedResult<Media>> FindMediaAsync(string? query, int page = 1, int pageSize = 100) public async Task<PagedResult<Media>> FindMediaAsync(string? query, ObjectId userId, int page = 1, int pageSize = 100)
{ {
var filter = string.IsNullOrWhiteSpace(query) ? "{}" : Builders<Media>.Filter.Text(query); var filter = Builders<Media>.Filter.And([
string.IsNullOrWhiteSpace(query) ? "{}" : Builders<Media>.Filter.Text(query),
Builders<Media>.Filter.Eq(m => m.Owner, userId)
]);
var sort = Builders<Media>.Sort.Descending(m => m.UploadDate); var sort = Builders<Media>.Sort.Descending(m => m.UploadDate);
var find = _media.Find(filter); var find = _media.Find(filter);

3
AobaServer/Services/AobaRpcService.cs
View File

@@ -26,7 +26,8 @@ public class AobaRpcService(AobaService aobaService, AccountsService accountsSer
public override async Task<ListResponse> ListMedia(PageFilter request, ServerCallContext context) public override async Task<ListResponse> ListMedia(PageFilter request, ServerCallContext context)
{ {
var result = await aobaService.FindMediaAsync(request.Query, request.HasPage ? request.Page : 1, request.HasPageSize ? request.PageSize : 100); var user = context.GetUserId();
var result = await aobaService.FindMediaAsync(request.Query, user, request.HasPage ? request.Page : 1, request.HasPageSize ? request.PageSize : 100);
return result.ToResponse(); return result.ToResponse();
} }