Skip to content

Commit

Permalink
update parkingSpace naming
Browse files Browse the repository at this point in the history
  • Loading branch information
Joren vanGoethem committed Jan 16, 2024
1 parent fa719a8 commit 947024c
Show file tree
Hide file tree
Showing 5 changed files with 22 additions and 21 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@

namespace DKSRDomain;

public class ParkingLotResponse
public class ParkingSpaceResponse
{
public ParkingLotSensorData[] SensorData { get; set; }
public ParkingSpaceSensorData[] SensorData { get; set; }
}

// {
Expand All @@ -29,7 +29,7 @@ public class ParkingLotResponse
// "eventType": "ParkinglotSNEventType"
// }

public class ParkingLotSensorData
public class ParkingSpaceSensorData
{
[JsonProperty("ignored")] public bool Ignored { get; set; }

Expand Down
2 changes: 1 addition & 1 deletion Importer/Constants/Endpoints.cs
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ public static class Endpoints
public const string TreesenseEndpoint =
"/UrbanPulseData/historic/sensordata?eventtype=fac3edb2-53fa-4319-a897-e3e3c02102cc";

public const string ParkingLotEndpoint =
public const string ParkingSpaceEndpoint =
"/UrbanPulseData/historic/sensordata?eventtype=2a4ce3e9-92db-455e-bece-0176c62fafba";

public static string GetAuthenticatedEndpointUrl(string? username, string? password, string socket)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@

namespace Importer.Importers;

public class ParkingLotImporter : Importer
public class ParkingSpaceImporter : Importer
{
private Timer _importerTimer;

public ParkingLotImporter(ILogger logger) : base(logger, "ParkingLot", "Occupancy")
public ParkingSpaceImporter(ILogger logger) : base(logger, "ParkingSpace", "Occupancy")
{
_importerTimer = new Timer(Import, null, 0, 60 * 1000 * 2); // every 2 minutes
}
Expand All @@ -20,22 +20,22 @@ public ParkingLotImporter(ILogger logger) : base(logger, "ParkingLot", "Occupanc
{
Logger.LogInformation($"{DateTime.Now} - Updating {DataType} Data...");
var data = await GetDksrData();
foreach (var dksrParkingLot in data.SensorData)
foreach (var parkingSpace in data.SensorData)
try
{
Thing thing;
var frostThing = await GetFrostThingData(dksrParkingLot.Sid);
var frostThing = await GetFrostThingData(parkingSpace.Sid);
if (frostThing.Value.Count == 0)
{
thing = Mappers.MapDksrResponse(dksrParkingLot, DataType);
thing = Mappers.MapDksrResponse(parkingSpace, DataType);
await CreateNewThing(thing);
frostThing = await GetFrostThingData(dksrParkingLot.Sid);
frostThing = await GetFrostThingData(parkingSpace.Sid);
}

if (frostThing.Value.Count < 1)
throw new Exception($"Creating new thing with id {dksrParkingLot.Sid} seems to have failed...");
throw new Exception($"Creating new thing with id {parkingSpace.Sid} seems to have failed...");

thing = Mappers.MapDksrResponse(dksrParkingLot, DataType);
thing = Mappers.MapDksrResponse(parkingSpace, DataType);
thing.Id = frostThing.Value.First().Id;
await Update(thing);
}
Expand All @@ -50,14 +50,14 @@ public ParkingLotImporter(ILogger logger) : base(logger, "ParkingLot", "Occupanc
}
}

private async Task<ParkingLotResponse> GetDksrData()
private async Task<ParkingSpaceResponse> GetDksrData()
{
try
{
var response =
await Client.GetAsync(
Endpoints.GetAuthenticatedEndpointUrl(Username, Password, Endpoints.ParkingLotEndpoint));
var result = await response.Content.ReadAsAsync<ParkingLotResponse>();
Endpoints.GetAuthenticatedEndpointUrl(Username, Password, Endpoints.ParkingSpaceEndpoint));
var result = await response.Content.ReadAsAsync<ParkingSpaceResponse>();
return result;
}
catch (Exception e)
Expand Down
11 changes: 6 additions & 5 deletions Importer/Mappers.cs
Original file line number Diff line number Diff line change
Expand Up @@ -17,17 +17,18 @@ public static Thing MapDksrResponse(TreeSenseSensorData treeData, string dataTyp
return Thing.Create($"{dataType}-{treeData.Sid}", dataType, properties, treeData.Lat, treeData.Lng, observation);
}

public static Thing MapDksrResponse(ParkingLotSensorData parkingLot, string dataType)
public static Thing MapDksrResponse(ParkingSpaceSensorData parkingSpace, string dataType)
{
var properties = new Dictionary<string, string>
{
{ "Id", parkingLot.Sid }, { "ParkingSpaceId", parkingLot.ParkingSpaceId.ToString() },
{ "ParkingLotId", parkingLot.ParkingLotId.ToString() }
{ "Id", parkingSpace.Sid },
{ "ParkingSpaceId", parkingSpace.ParkingSpaceId.ToString() },
{ "ParkingLotId", parkingSpace.ParkingLotId.ToString() }
};

var observation = new Observation { Result = parkingLot.Occupied, PhenomenonTime = parkingLot.Timestamp };
var observation = new Observation { Result = parkingSpace.Occupied, PhenomenonTime = parkingSpace.Timestamp };

return Thing.Create($"{dataType}-{parkingLot.Sid}", dataType, properties, parkingLot.Lat, parkingLot.Lon, observation);
return Thing.Create($"{dataType}-{parkingSpace.Sid}", dataType, properties, parkingSpace.Lat, parkingSpace.Lon, observation);
}

public static DataStream MapFrostResponseToDataStream(DataStreamResponse? response)
Expand Down
2 changes: 1 addition & 1 deletion Importer/Program.cs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ private static void Main(string[] args)
_logger = serviceProvider.GetRequiredService<ILogger<Program>>();

var treeImporter = new TreeImporter(_logger);
var parkingLotImporter = new ParkingLotImporter(_logger);
var parkingSpaceImporter = new ParkingSpaceImporter(_logger);

Process.GetCurrentProcess().WaitForExit();
}
Expand Down

0 comments on commit 947024c

Please sign in to comment.