ocppsim 0.2.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

use super::super::payloads::{StatusPayload, to_value};
use super::super::{ResponseStatus, Result, Simulator, UiLogLevel, WsWrite};

impl Simulator {
  /// Sends a CALLRESULT with a standard `{ "status": "..." }` payload.
  pub(in crate::simulator) async fn send_status_response(
    &mut self,
    write: &mut WsWrite,
    message_id: &str,
    status: ResponseStatus,
  ) -> Result<()> {
    self
      .send_call_result(
        write,
        message_id,
        to_value(&StatusPayload {
          status: status.as_str(),
        }),
      )
      .await
  }

  /// Resolves a requested connector or falls back to the first startable one.
  pub(in crate::simulator) fn requested_or_first_startable_connector(
    &self,
    requested_connector: Option<u16>,
  ) -> Option<u16> {
    match requested_connector {
      Some(connector) => Some(connector),
      None => self.first_startable_connector(),
    }
  }

  /// Resolves a start connector or replies with `Rejected` when none exist.
  pub(in crate::simulator) async fn resolve_start_connector_or_reject(
    &mut self,
    write: &mut WsWrite,
    message_id: &str,
    requested_connector: Option<u16>,
  ) -> Result<Option<u16>> {
    if let Some(connector) =
      self.requested_or_first_startable_connector(requested_connector)
    {
      Ok(Some(connector))
    } else {
      self
        .send_status_response(write, message_id, ResponseStatus::Rejected)
        .await?;
      Ok(None)
    }
  }

  /// Logs and acknowledges a reset request without mutating simulator state.
  pub(in crate::simulator) async fn handle_reset_only_call(
    &mut self,
    write: &mut WsWrite,
    message_id: &str,
  ) -> Result<()> {
    self.log(
      UiLogLevel::Info,
      "Received Reset request. Simulator will acknowledge only.",
    );
    self
      .send_status_response(write, message_id, ResponseStatus::Accepted)
      .await
  }
}