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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111

use super::super::*;

impl Simulator {
  /// Applies a CALLRESULT to the current pending request context.
  pub(in crate::simulator) fn handle_call_result(
    &mut self,
    message_id: &str,
    payload: Value,
  ) -> Result<()> {
    let Some(pending) = &self.pending else {
      self.log(
        UiLogLevel::Warn,
        format!("Unexpected CALLRESULT {} (no pending request).", message_id),
      );
      return Ok(());
    };
    if pending.message_id != message_id {
      self.log(
        UiLogLevel::Warn,
        format!(
          "CALLRESULT {} does not match pending {}.",
          message_id, pending.message_id
        ),
      );
      return Ok(());
    }

    let pending = self.pending.take().expect("pending exists");
    self.apply_call_result_context(&pending.call.context, &payload)?;
    Ok(())
  }

  /// Handles CALLERROR for the current pending request and performs rollback.
  pub(in crate::simulator) fn handle_call_error(
    &mut self,
    message_id: &str,
    code: &str,
    description: &str,
  ) -> Result<()> {
    let Some(pending) = &self.pending else {
      self.log(
        UiLogLevel::Warn,
        format!(
          "Unexpected CALLERROR {}: {} {}",
          message_id, code, description
        ),
      );
      return Ok(());
    };
    if pending.message_id != message_id {
      self.log(
        UiLogLevel::Warn,
        format!(
          "CALLERROR {} does not match pending {}.",
          message_id, pending.message_id
        ),
      );
      return Ok(());
    }

    let pending = self.pending.take().expect("pending exists");
    self.log(
      UiLogLevel::Error,
      format!("{} failed: {} {}", pending.call.action, code, description),
    );

    match pending.call.context {
      PendingContext::StartTxV1_6 {
        connector,
        local_tx_id,
      } => {
        self.cancel_transaction_start(connector, local_tx_id)?;
        self.enqueue_status_notification(connector)?;
      }
      PendingContext::StopTxV1_6 {
        connector,
        local_tx_id,
      } => {
        self.restore_active_transaction_status(connector, local_tx_id)?;
        self.enqueue_status_notification(connector)?;
      }
      PendingContext::TxEvent {
        connector,
        local_tx_id,
        event_type: TxEventType::Started,
      } => {
        self.cancel_transaction_start(connector, local_tx_id)?;
        self.enqueue_status_notification(connector)?;
      }
      PendingContext::TxEvent {
        connector,
        local_tx_id,
        event_type: TxEventType::Ended,
      } => {
        self.restore_active_transaction_status(connector, local_tx_id)?;
        self.enqueue_status_notification(connector)?;
      }
      PendingContext::TxEvent { .. }
      | PendingContext::Boot
      | PendingContext::Heartbeat
      | PendingContext::DataTransfer
      | PendingContext::DiagnosticsStatusNotification
      | PendingContext::FirmwareStatusNotification
      | PendingContext::LogStatusNotification
      | PendingContext::Authorize { .. }
      | PendingContext::StatusNotification { .. }
      | PendingContext::MeterValues { .. } => {}
    }
    Ok(())
  }
}