diff --git a/Cloud/Controllers/ValveController.cs b/Cloud/Controllers/ValveController.cs index 5708820..dbc081a 100644 --- a/Cloud/Controllers/ValveController.cs +++ b/Cloud/Controllers/ValveController.cs @@ -21,7 +21,7 @@ namespace Cloud.Controllers _producerService = producerService; } - [HttpPost("farm/{farmId}/greenhouse/{greenhouseId}/watering")] + [HttpPost("farm/{farmId}/greenhouse/{ghId}/watering")] public async Task interactValve([FromBody] ValveRequest request, int farmId, int ghId) { var kafkaRequest = new @@ -32,10 +32,11 @@ namespace Cloud.Controllers }; var message = JsonSerializer.Serialize(kafkaRequest); + return Ok(kafkaRequest); - await _producerService.ProduceMessageAsync("InventoryUpdates", message); + /*await _producerService.ProduceMessageAsync("ValvesHeatersRequest", message); - return Ok($"Valve status is {request.Action}"); + return Ok($"Valve status is {request.Action}");*/ } } }