ocppsim 0.1.0

A terminal OCPP-J charge point simulator.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

use super::super::*;

impl Simulator {
  /// Handles OCPP 1.6 `TriggerMessage.req` by enqueueing requested messages.
  pub(in crate::simulator) fn trigger_message_v1_6(
    &mut self,
    requested: TriggerMessage_V1_6,
    connector: Option<u16>,
  ) -> Result<()> {
    match requested {
      TriggerMessage_V1_6::BootNotification => {
        self.enqueue_boot_notification();
      }
      TriggerMessage_V1_6::Heartbeat => {
        self.enqueue_heartbeat();
      }
      TriggerMessage_V1_6::MeterValues => {
        if let Some(connector_id) = connector {
          self.enqueue_meter_values(connector_id)?;
        } else {
          let connectors: Vec<u16> = self.connectors.keys().copied().collect();
          for connector_id in connectors {
            self.enqueue_meter_values(connector_id)?;
          }
        }
      }
      TriggerMessage_V1_6::StatusNotification => {
        if let Some(connector_id) = connector {
          self.enqueue_status_notification(connector_id)?;
        } else {
          let connectors: Vec<u16> = self.connectors.keys().copied().collect();
          for connector_id in connectors {
            self.enqueue_status_notification(connector_id)?;
          }
        }
      }
    }
    Ok(())
  }

  /// Handles OCPP 2.x `TriggerMessage.req` by enqueueing requested messages.
  pub(in crate::simulator) fn trigger_message_v2_x(
    &mut self,
    requested: TriggerMessage_V2_X,
    connector: Option<u16>,
  ) -> Result<()> {
    match requested {
      TriggerMessage_V2_X::BootNotification => {
        self.enqueue_boot_notification();
      }
      TriggerMessage_V2_X::Heartbeat => {
        self.enqueue_heartbeat();
      }
      TriggerMessage_V2_X::MeterValues => {
        if let Some(connector_id) = connector {
          self.enqueue_meter_values(connector_id)?;
        } else {
          let connectors: Vec<u16> = self.connectors.keys().copied().collect();
          for connector_id in connectors {
            self.enqueue_meter_values(connector_id)?;
          }
        }
      }
      TriggerMessage_V2_X::StatusNotification => {
        if let Some(connector_id) = connector {
          self.enqueue_status_notification(connector_id)?;
        } else {
          let connectors: Vec<u16> = self.connectors.keys().copied().collect();
          for connector_id in connectors {
            self.enqueue_status_notification(connector_id)?;
          }
        }
      }
    }
    Ok(())
  }
}