Struct MockPeer 

pub struct MockPeer(/* private fields */);

Available on crate features server and testkit only.

A conformant OCPI party, held in memory.

Cheap to clone: the stores are shared, so a handle handed to the router and a handle kept for the test see the same objects.

Implementations

impl MockPeer

pub fn new(base: Url, party: PartyRef, role: Role) -> Self

A peer filling role, publishing its endpoints under base.

pub fn cpo(base: Url) -> Self

A CPO at test_cpo.

pub fn msp(base: Url) -> Self

An eMSP at test_msp.

pub fn seeded(self) -> Self

Fills every store with one conformant object, so a partner’s first pull is not empty.

Panics

Panics if the crate’s own sample objects are not constructible, which would be a bug here.

pub fn party(&self) -> &PartyRef

The party this peer speaks as.

pub fn token_store(&self) -> Arc<InMemoryTokenStore>

A token store that accepts test_token("c") as this peer’s partner.

The partner is given the opposite role’s party, so the router’s ownership check behaves the way it would in a real deployment: a partner may write under its own party and no other.

pub fn mount(&self, router: OcpiRouter) -> OcpiRouter

Mounts every module this peer serves onto router.

Both interfaces of every object module, so one process can stand in for either side of a roaming relationship. That is only mountable because the router publishes the Receiver interfaces one segment deeper by default; see ServerConfig::receiver_path_prefix.

impl MockPeer

pub fn credentials(&self) -> Credentials

This peer’s own credentials object, as the credentials endpoint returns it.

Trait Implementations

impl CdrsReceiver for MockPeer

async fn cdr(&self, cdr_id: String, _c: RequestContext) -> Handled<Cdr>

Available on crate feature server only.

GET {cdrs}/{cdr_id} — a CDR previously POSTed here.

async fn post_cdr(&self, cdr: Cdr, _c: RequestContext) -> Handled<Url>

Available on crate feature server only.

POST {cdrs} — stores a CDR and returns the URL it can be fetched from.

impl CdrsSender for MockPeer

async fn list(&self, query: PageQuery, _c: RequestContext) -> Handled<Page<Cdr>>

Available on crate feature server only.

GET {cdrs} — one page of CDRs.

impl Clone for MockPeer

fn clone(&self) -> MockPeer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CredentialsHandler for MockPeer

async fn get(&self, _c: RequestContext) -> Handled<Credentials>

Available on crate feature server only.

GET {credentials} — this party’s own credentials object.

async fn post( &self, _credentials: Credentials, _c: RequestContext, ) -> Handled<Credentials>

Available on crate feature server only.

POST {credentials} — register.

async fn put( &self, _credentials: Credentials, _c: RequestContext, ) -> Handled<Credentials>

Available on crate feature server only.

PUT {credentials} — update, rotate the token, or switch version.

async fn delete(&self, _c: RequestContext) -> Handled<()>

Available on crate feature server only.

DELETE {credentials} — unregister.

impl Debug for MockPeer

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for MockPeer

type Target = MockPeerStores

The resulting type after dereferencing.

fn deref(&self) -> &MockPeerStores

Dereferences the value.

impl LocationsReceiver for MockPeer

async fn location( &self, _o: PartyRef, location_id: String, _c: RequestContext, ) -> Handled<Location>

Available on crate feature server only.

GET {locations}/{cc}/{party}/{location_id} — what this party has stored.

async fn put_location( &self, _o: PartyRef, location: Location, _c: RequestContext, ) -> Handled<Created>

Available on crate feature server only.

PUT {locations}/{cc}/{party}/{location_id}.

async fn put_evse( &self, _o: PartyRef, location_id: String, evse: Evse, _c: RequestContext, ) -> Handled<Created>

Available on crate feature server only.

PUT {locations}/{cc}/{party}/{location_id}/{evse_uid}.

async fn put_connector( &self, _o: PartyRef, location_id: String, evse_uid: String, connector: Connector, _c: RequestContext, ) -> Handled<Created>

Available on crate feature server only.

PUT {locations}/{cc}/{party}/{location_id}/{evse_uid}/{connector_id}.

async fn patch( &self, _o: PartyRef, location_id: String, evse_uid: Option<String>, connector_id: Option<String>, patch: Patch<Value>, _c: RequestContext, ) -> Handled<()>

Available on crate feature server only.

PATCH on any of the three levels.

impl LocationsSender for MockPeer

async fn list( &self, query: PageQuery, _c: RequestContext, ) -> Handled<Page<Location>>

Available on crate feature server only.

GET {locations} — one page of Locations.

async fn location( &self, location_id: String, _c: RequestContext, ) -> Handled<Location>

Available on crate feature server only.

GET {locations}/{location_id}.

async fn evse( &self, location_id: String, evse_uid: String, _c: RequestContext, ) -> Handled<Evse>

Available on crate feature server only.

GET {locations}/{location_id}/{evse_uid}.

async fn connector( &self, location_id: String, evse_uid: String, connector_id: String, _c: RequestContext, ) -> Handled<Connector>

Available on crate feature server only.

GET {locations}/{location_id}/{evse_uid}/{connector_id}.

impl SessionsReceiver for MockPeer

async fn session( &self, _o: PartyRef, session_id: String, _c: RequestContext, ) -> Handled<Session>

Available on crate feature server only.

GET {sessions}/{cc}/{party}/{session_id}.

async fn put_session( &self, _o: PartyRef, session: Session, _c: RequestContext, ) -> Handled<Created>

Available on crate feature server only.

PUT {sessions}/{cc}/{party}/{session_id}.

async fn patch_session( &self, _o: PartyRef, session_id: String, patch: Patch<Session>, _c: RequestContext, ) -> Handled<()>

Available on crate feature server only.

PATCH {sessions}/{cc}/{party}/{session_id}.

impl SessionsSender for MockPeer

async fn list( &self, query: PageQuery, _c: RequestContext, ) -> Handled<Page<Session>>

Available on crate feature server only.

GET {sessions} — one page of Sessions.

async fn set_charging_preferences( &self, session_id: String, _preferences: ChargingPreferences, _c: RequestContext, ) -> Handled<ChargingPreferencesResponse>

Available on crate feature server only.

PUT {sessions}/{session_id}/charging_preferences.

impl TariffsReceiver for MockPeer

async fn tariff( &self, _o: PartyRef, tariff_id: String, _c: RequestContext, ) -> Handled<Tariff>

Available on crate feature server only.

GET {tariffs}/{cc}/{party}/{tariff_id}.

async fn put_tariff( &self, _o: PartyRef, tariff: Tariff, _c: RequestContext, ) -> Handled<Created>

Available on crate feature server only.

PUT {tariffs}/{cc}/{party}/{tariff_id}.

async fn delete_tariff( &self, _o: PartyRef, tariff_id: String, _c: RequestContext, ) -> Handled<()>

Available on crate feature server only.

DELETE {tariffs}/{cc}/{party}/{tariff_id}.

impl TariffsSender for MockPeer

async fn list( &self, query: PageQuery, _c: RequestContext, ) -> Handled<Page<Tariff>>

Available on crate feature server only.

GET {tariffs} — one page of Tariffs.

impl TokensReceiver for MockPeer

async fn token( &self, _o: PartyRef, token_uid: String, _token_type: Option<TokenType>, _c: RequestContext, ) -> Handled<Token>

Available on crate feature server only.

GET {tokens}/{cc}/{party}/{token_uid}[?type=].

async fn put_token( &self, _o: PartyRef, token: Token, _c: RequestContext, ) -> Handled<Created>

Available on crate feature server only.

PUT {tokens}/{cc}/{party}/{token_uid}[?type=].

async fn patch_token( &self, _o: PartyRef, token_uid: String, _token_type: Option<TokenType>, patch: Patch<Token>, _c: RequestContext, ) -> Handled<()>

Available on crate feature server only.

PATCH {tokens}/{cc}/{party}/{token_uid}[?type=].

impl TokensSender for MockPeer

async fn list( &self, query: PageQuery, _c: RequestContext, ) -> Handled<Page<Token>>

Available on crate feature server only.

GET {tokens} — one page of Tokens.

async fn authorize( &self, token_uid: String, _token_type: Option<TokenType>, location: Option<LocationReferences>, _c: RequestContext, ) -> Handled<AuthorizationInfo>

Available on crate feature server only.

POST {tokens}/{token_uid}/authorize[?type=] — a real-time authorization.