37 lines
1.1 KiB
C#
37 lines
1.1 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 AuctionService
|
|
{
|
|
private readonly IMongoCollection<Auction> _auctions;
|
|
|
|
public AuctionService(IConfiguration config)
|
|
{
|
|
var client = new MongoClient(config["MongoDB:ConnectionString"]);
|
|
var db = client.GetDatabase(config["MongoDB:DatabaseName"]);
|
|
_auctions = db.GetCollection<Auction>("Auctions");
|
|
}
|
|
|
|
public virtual async Task CreateAsync(Auction auction) =>
|
|
await _auctions.InsertOneAsync(auction);
|
|
|
|
public virtual async Task<Auction> GetByIdAsync(string id)
|
|
{
|
|
if (!MongoDB.Bson.ObjectId.TryParse(id, out _))
|
|
return null;
|
|
|
|
return await _auctions.Find(a => a.Id == id).FirstOrDefaultAsync();
|
|
}
|
|
|
|
public virtual async Task UpdateAsync(Auction auction) =>
|
|
await _auctions.ReplaceOneAsync(a => a.Id == auction.Id, auction);
|
|
|
|
public virtual async Task<List<Auction>> GetActiveAsync() =>
|
|
await _auctions.Find(a => !a.IsClosed).ToListAsync();
|
|
}
|