using Microsoft.AspNetCore.Mvc;
using MongoDB.Bson;
using MongoDB.Driver;
using System;
using System.Collections.Generic;
using System.Threading.Tasks;
namespace INow.Mongo.Service.Controllers
{
    [Route("api/[Controller]")]
    [ApiController]
    public class serverlesstest : ControllerBase
    {
        private MongoClient client;
        [HttpGet("GetCollectionServerless")]
        public async Task<JsonResult> GetCollectionWithConnectionString([FromQuery] string connectionString, [FromQuery] string databaseName, [FromQuery] string collectionName)
        {
            client = new MongoClient(connectionString);
            IMongoDatabase database = client.GetDatabase(databaseName);
            var collection = database.GetCollection<BsonDocument>(collectionName);
            List<BsonDocument> ResultList = new List<BsonDocument>();
            try
            {
                ResultList = await collection.Find(Builders<BsonDocument>.Filter.Empty).ToListAsync().ConfigureAwait(false);
            }
            catch (Exception ex)
            {
                if (ex is MongoConnectionPoolPausedException)
                {
                    return new JsonResult(ex.Message);
                }
            }
            return new JsonResult($"found {ResultList.Count} item in collection {collectionName}.");
        }
    }
}