37 lines
1.2 KiB
C#
37 lines
1.2 KiB
C#
using System.Collections.Generic;
|
|
using System.Threading.Tasks;
|
|
using GameAuthApi.Models;
|
|
using Microsoft.Extensions.Configuration;
|
|
using MongoDB.Driver;
|
|
|
|
namespace GameAuthApi.Services;
|
|
|
|
public class UserService
|
|
{
|
|
private readonly IMongoCollection<User> _users;
|
|
|
|
public UserService(IConfiguration config)
|
|
{
|
|
var client = new MongoClient(config["MongoDB:ConnectionString"]);
|
|
var database = client.GetDatabase(config["MongoDB:DatabaseName"]);
|
|
_users = database.GetCollection<User>("Users");
|
|
}
|
|
|
|
public virtual async Task<User> GetByUsernameAsync(string username) =>
|
|
await _users.Find(u => u.Username == username).FirstOrDefaultAsync();
|
|
|
|
public virtual async Task<List<User>> GetAllAsync() =>
|
|
await _users.Find(_ => true).ToListAsync();
|
|
|
|
public virtual async Task<bool> DeleteAsync(string username)
|
|
{
|
|
var result = await _users.DeleteOneAsync(u => u.Username == username);
|
|
return result.DeletedCount > 0;
|
|
}
|
|
|
|
public virtual async Task CreateAsync(User user) =>
|
|
await _users.InsertOneAsync(user);
|
|
|
|
public virtual async Task UpdateAsync(User user) =>
|
|
await _users.ReplaceOneAsync(u => u.Id == user.Id, user);
|
|
} |