50 lines
1.7 KiB
C#
50 lines
1.7 KiB
C#
using LocationsApi.Models;
|
|
using MongoDB.Driver;
|
|
|
|
namespace LocationsApi.Services;
|
|
|
|
public class LocationStore
|
|
{
|
|
private readonly IMongoCollection<Location> _col;
|
|
|
|
public LocationStore(IConfiguration cfg)
|
|
{
|
|
var cs = cfg["MongoDB:ConnectionString"] ?? "mongodb://127.0.0.1:27017";
|
|
var dbName = cfg["MongoDB:DatabaseName"] ?? "GameDb";
|
|
var client = new MongoClient(cs);
|
|
var db = client.GetDatabase(dbName);
|
|
_col = db.GetCollection<Location>("Locations");
|
|
|
|
var ownerIndex = Builders<Location>.IndexKeys.Ascending(l => l.OwnerUserId);
|
|
_col.Indexes.CreateOne(new CreateIndexModel<Location>(ownerIndex));
|
|
}
|
|
|
|
public Task CreateAsync(Location location) => _col.InsertOneAsync(location);
|
|
|
|
public Task<List<Location>> GetForOwnerAsync(string ownerUserId) =>
|
|
_col.Find(l => l.OwnerUserId == ownerUserId).ToListAsync();
|
|
|
|
public async Task<bool> DeleteForOwnerAsync(string id, string ownerUserId, bool allowAnyOwner)
|
|
{
|
|
var filter = Builders<Location>.Filter.Eq(l => l.Id, id);
|
|
if (!allowAnyOwner)
|
|
{
|
|
filter = Builders<Location>.Filter.And(
|
|
filter,
|
|
Builders<Location>.Filter.Eq(l => l.OwnerUserId, ownerUserId)
|
|
);
|
|
}
|
|
|
|
var result = await _col.DeleteOneAsync(filter);
|
|
return result.DeletedCount > 0;
|
|
}
|
|
|
|
public async Task<bool> UpdateNameAsync(string id, string name)
|
|
{
|
|
var filter = Builders<Location>.Filter.Eq(l => l.Id, id);
|
|
var update = Builders<Location>.Update.Set(l => l.Name, name);
|
|
var result = await _col.UpdateOneAsync(filter, update);
|
|
return result.ModifiedCount > 0;
|
|
}
|
|
}
|