in RobotOrchestrator.FleetManager/FleetManager.cs [92:114]
public async Task InsertTelemetriesAndUpdateRobotsAsync(IEnumerable<RobotTelemetry> robotTelemetry)
{
// telemetry handler inserts telemetry into cosmos
await telemetryHandler.InsertTelemetryAsync(robotTelemetry);
// update robot statuses in robot db
foreach (RobotTelemetry telemetry in robotTelemetry)
{
var robot = new Robot()
{
DeviceId = telemetry.RobotId,
Telemetry = telemetry
};
try
{
await UpdateRobotAsync(robot);
}
catch(Exception ex)
{
logger.LogError(ex.Message);
}
}
}