X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2FOCPPIncomingRequestService.ts;h=ddffa657f2a131df81b11058b786807eea15e0fd;hb=1431af786f4d2728bad4132d505758144798516b;hp=952e740e7f472c7484a36b8f0efb45175cbc5e30;hpb=4598878063d62259a6046a870dfa455b9d0027ca;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPIncomingRequestService.ts b/src/charging-station/ocpp/OCPPIncomingRequestService.ts index 952e740e..ddffa657 100644 --- a/src/charging-station/ocpp/OCPPIncomingRequestService.ts +++ b/src/charging-station/ocpp/OCPPIncomingRequestService.ts @@ -3,14 +3,17 @@ import { AsyncResource } from 'async_hooks'; import Ajv, { type JSONSchemaType } from 'ajv'; import ajvFormats from 'ajv-formats'; +import OCPPConstants from './OCPPConstants'; +import { OCPPServiceUtils } from './OCPPServiceUtils'; import OCPPError from '../../exception/OCPPError'; import type { HandleErrorParams } from '../../types/Error'; -import type { JsonType } from '../../types/JsonType'; +import type { JsonObject, JsonType } from '../../types/JsonType'; import type { OCPPVersion } from '../../types/ocpp/OCPPVersion'; import type { IncomingRequestCommand } from '../../types/ocpp/Requests'; +import type { ClearCacheResponse } from '../../types/ocpp/Responses'; import logger from '../../utils/Logger'; import type ChargingStation from '../ChargingStation'; -import { OCPPServiceUtils } from './OCPPServiceUtils'; +import { ChargingStationUtils } from '../ChargingStationUtils'; const moduleName = 'OCPPIncomingRequestService'; @@ -19,10 +22,12 @@ export default abstract class OCPPIncomingRequestService { protected asyncResource: AsyncResource; private readonly version: OCPPVersion; private readonly ajv: Ajv; + protected abstract jsonSchemas: Map>; protected constructor(version: OCPPVersion) { this.version = version; this.ajv = new Ajv({ + keywords: ['javaType'], multipleOfPrecision: 2, }); ajvFormats(this.ajv); @@ -84,6 +89,13 @@ export default abstract class OCPPIncomingRequestService { ); } + protected handleRequestClearCache(chargingStation: ChargingStation): ClearCacheResponse { + chargingStation.authorizedTagsCache.deleteAuthorizedTags( + ChargingStationUtils.getAuthorizationFile(chargingStation.stationInfo) + ); + return OCPPConstants.OCPP_RESPONSE_ACCEPTED; + } + public abstract incomingRequestHandler( chargingStation: ChargingStation, messageId: string,