devops-lab4/src/CommunicationControl/DevOpsProject/Controllers/HiveController.cs

using Asp.Versioning;
using DevOpsProject.CommunicationControl.Logic.Services.Interfaces;
using DevOpsProject.Shared.Models;
using Microsoft.AspNetCore.Mvc;

namespace DevOpsProject.CommunicationControl.API.Controllers
{
    [ApiVersion("1.0")]
    [ApiController]
    [Route("api/v{version:apiVersion}/hive")]
    public class HiveController : Controller
    {
        private readonly ICommunicationControlService _communicationControlService;
        private readonly ILogger<HiveController> _logger;

        public HiveController(ICommunicationControlService communicationControlService, ILogger<HiveController> logger)
        {
            _communicationControlService = communicationControlService;
            _logger = logger;
        }

        [HttpPost("connect")]
        public async Task<IActionResult> Connect(HiveConnectRequest request)
        {
            var hiveModel = new HiveModel
            {
                HiveID = request.HiveID,
                HiveIP = request.HiveIP,
                HivePort = request.HivePort,
                HiveSchema = request.HiveSchema
            };

            var hiveOperationalArea = await _communicationControlService.ConnectHive(hiveModel);
            var connectResponse = new HiveConnectResponse
            {
                ConnectResult = true,
                OperationalArea = hiveOperationalArea,
            };

            return Ok(connectResponse);

        }

        [HttpPost("telemetry")]
        public async Task<IActionResult> Telemetry(HiveTelemetryRequest request)
        {
            var hiveTelemetryModel = new HiveTelemetryModel
            {
                HiveID = request.HiveID,
                Location = request.Location,
                Speed = request.Speed,
                Height = request.Height,
                State = request.State,
                Timestamp = DateTime.Now
            };

            bool isHiveConnected = await _communicationControlService.IsHiveConnected(request.HiveID);
            if (isHiveConnected)
            {
                var telemetryUpdateTimestamp = await _communicationControlService.AddTelemetry(hiveTelemetryModel);
                var telemetryResponse = new HiveTelemetryResponse
                {
                    Timestamp = telemetryUpdateTimestamp
                };

                return Ok(telemetryResponse);
            }
            else
            {
                _logger.LogWarning("Failed to write telemetry. Hive with HiveID: {hiveId} is not connected. Request: {@request}", request.HiveID, request);
                return NotFound($"Failed to write telemetry. Hive with HiveID: {request.HiveID} is not connected");
            }
        }

    }
}