TelpoKafkaConsole/TelpoKafkaConsole.WebApi/Controllers/WeatherForecastController.cs

using Confluent.Kafka;
using Confluent.Kafka.Admin;
using Microsoft.AspNetCore.Mvc;
using TelpoKafkaConsole.Service;
using TelpoKafkaConsole.WebApi.Controllers.Api;

namespace TelpoKafkaConsole.WebApi.Controllers
{
    [ApiController]
    [Route("[controller]")]
    public class WeatherForecastController : ControllerBase
    {
        private readonly KafkaAdminService _servicekafkaAdmin;

       
        private static readonly string[] Summaries = new[]
        {
            "Freezing", "Bracing", "Chilly", "Cool", "Mild", "Warm", "Balmy", "Hot", "Sweltering", "Scorching"
        };

        private readonly ILogger<WeatherForecastController> _logger;

        public WeatherForecastController(ILogger<WeatherForecastController> logger, KafkaAdminService kafkaAdminService)
        {
            _logger = logger;
            _servicekafkaAdmin = kafkaAdminService;
        }

        //[HttpGet(Name = "GetWeatherForecast")]
        //public IEnumerable<WeatherForecast> Get()
        //{
        //    return Enumerable.Range(1, 5).Select(index => new WeatherForecast
        //    {
        //        Date = DateTime.Now.AddDays(index),
        //        TemperatureC = Random.Shared.Next(-20, 55),
        //        Summary = Summaries[Random.Shared.Next(Summaries.Length)]
        //    })
        //    .ToArray();
        //}
        //[HttpGet(Name = "GetGroup")]
        //public ApiResponse<List<GroupInfo>> GetGroup()
        //{
        //    var group = _servicekafkaAdmin.ListGroups();
        //    return ApiResponse<List<GroupInfo>>.Success(group); 
        //}

        [HttpGet(Name = "GetGroup")]
        public async Task<ApiResponse<string>> GetGroupAsync()
        {
           // var group = _servicekafkaAdmin.ListGroups();
            List<AclBinding> aclBindings = new()
            {
                new AclBinding()
                {
                    Pattern = new ResourcePattern
                    {
                        Type = ResourceType.Broker,
                        Name = "kafka-cluster",
                        ResourcePatternType = ResourcePatternType.Literal
                    },
                    Entry = new AccessControlEntry
                    {
                        Principal = $"User:telpo-consumer",
                        Host = "*",
                        Operation = AclOperation.All,
                        PermissionType = AclPermissionType.Deny
                    }
                }
            };
            await _servicekafkaAdmin.CreateAclsAsync(aclBindings);
            return ApiResponse<string>.Success("ok");
        }
    }
}