Process incoming reports by upcating status of all EVSE

This may be a waste of effort since not every report will change the EVSE
status, but I want to make sure we capture any changes so for now it is worth
the extra overhead.

Author: wfvining

src/ocpp_device_model.erl

@@ -6,7 +6,7 @@
 
 -feature(maybe_expr, enable).
 
--export([new/0, add_variable/5, add_attribute/8, get_value/5, update_attribute/6]).
+-export([new/0, add_variable/5, add_attribute/8, get_value/5, update_attribute/6, get_evse_availability/1]).
 
 -export_type([device_model/0, attribute/0, charactersitics/0,
               variable_identifiers/0, attribute_type/0]).
@@ -246,6 +246,13 @@ get_value(#device_model{attributes = Attributes},
         _ -> error(ambiguous)
     end.
 
+-spec get_evse_availability(DeviceModel :: device_model()) -> [{pos_integer(), string()}].
+get_evse_availability(#device_model{attributes = Attributes}) ->
+    Component = make_component_identifier(<<"EVSE">>, [{evse, '$1'}]),
+    Variable = make_variable_identifier(<<"AvailabilityState">>, []),
+    [{EVSE, Availability}
+     || [EVSE, Availability] <- ets:match(Attributes, {{Component, Variable, 'Actual'}, '$2', '_', '_'})].
+
 parse_value(_, undefined) ->
     undefined;
 parse_value(_, <<"">>) ->

src/ocpp_station.erl

@@ -645,10 +645,23 @@ process_report(ReportMsg, Data) ->
     if ToBeContinued ->
             Data;
        not ToBeContinued ->
+            NewData = update_evse_status(Data),
             ocpp_handler:report_received(Data#data.stationid, RequestId),
-            Data#data{expecting_report = lists:delete(RequestId, Data#data.expecting_report)}
+            NewData#data{expecting_report = lists:delete(RequestId, Data#data.expecting_report)}
     end.
 
+update_evse_status(Data) ->
+    NewEVSE = lists:foldl(
+                fun({EVSEId, Status}, Acc) ->
+                        maps:update_with(
+                          EVSEId,
+                          fun(EVSE) -> ocpp_evse:set_evse_status(EVSE, Status) end,
+                          Acc)
+                end,
+                Data#data.evse,
+                ocpp_device_model:get_evse_availability(Data#data.device_model)),
+    Data#data{evse = NewEVSE}.
+
 process_report_data(ReportData, DeviceModel) ->
     ComponentName = ocpp_message:get(<<"component/name">>, ReportData),
     VariableName = ocpp_message:get(<<"variable/name">>, ReportData),