repositories
/
e-mobility-charging-stations-simulator.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add a shared cache per worker for authorized tags
[e-mobility-charging-stations-simulator.git]
/
src
/
charging-station
/
ocpp
/
1.6
/
OCPP16IncomingRequestService.ts
diff --git
a/src/charging-station/ocpp/1.6/OCPP16IncomingRequestService.ts
b/src/charging-station/ocpp/1.6/OCPP16IncomingRequestService.ts
index f51cc65526ecc684a99fd8045989cb6c982ea196..7aad17a15e9a95d2ee3cfb173a89296d86cb1d06 100644
(file)
--- a/
src/charging-station/ocpp/1.6/OCPP16IncomingRequestService.ts
+++ b/
src/charging-station/ocpp/1.6/OCPP16IncomingRequestService.ts
@@
-58,9
+58,11
@@
import {
OCPP16StandardParametersKey,
OCPP16SupportedFeatureProfiles,
} from '../../../types/ocpp/1.6/Configuration';
OCPP16StandardParametersKey,
OCPP16SupportedFeatureProfiles,
} from '../../../types/ocpp/1.6/Configuration';
+import { URL, fileURLToPath } from 'url';
import type ChargingStation from '../../ChargingStation';
import { ChargingStationConfigurationUtils } from '../../ChargingStationConfigurationUtils';
import type ChargingStation from '../../ChargingStation';
import { ChargingStationConfigurationUtils } from '../../ChargingStationConfigurationUtils';
+import { ChargingStationUtils } from '../../ChargingStationUtils';
import Constants from '../../../utils/Constants';
import { DefaultResponse } from '../../../types/ocpp/Responses';
import { ErrorType } from '../../../types/ocpp/ErrorType';
import Constants from '../../../utils/Constants';
import { DefaultResponse } from '../../../types/ocpp/Responses';
import { ErrorType } from '../../../types/ocpp/ErrorType';
@@
-73,7
+75,6
@@
import { OCPP16ServiceUtils } from './OCPP16ServiceUtils';
import { OCPPConfigurationKey } from '../../../types/ocpp/Configuration';
import OCPPError from '../../../exception/OCPPError';
import OCPPIncomingRequestService from '../OCPPIncomingRequestService';
import { OCPPConfigurationKey } from '../../../types/ocpp/Configuration';
import OCPPError from '../../../exception/OCPPError';
import OCPPIncomingRequestService from '../OCPPIncomingRequestService';
-import { URL } from 'url';
import Utils from '../../../utils/Utils';
import fs from 'fs';
import logger from '../../../utils/Logger';
import Utils from '../../../utils/Utils';
import fs from 'fs';
import logger from '../../../utils/Logger';
@@
-511,7
+512,7
@@
export default class OCPP16IncomingRequestService extends OCPPIncomingRequestSer
clearCurrentCP = true;
}
if (clearCurrentCP) {
clearCurrentCP = true;
}
if (clearCurrentCP) {
- connectorStatus.chargingProfiles
[index] = {} as OCPP16ChargingProfile
;
+ connectorStatus.chargingProfiles
.splice(index, 1)
;
logger.debug(
`${chargingStation.logPrefix()} Matching charging profile(s) cleared on connector id ${
commandPayload.connectorId
logger.debug(
`${chargingStation.logPrefix()} Matching charging profile(s) cleared on connector id ${
commandPayload.connectorId
@@
-614,7
+615,11
@@
export default class OCPP16IncomingRequestService extends OCPPIncomingRequestSer
if (
chargingStation.getLocalAuthListEnabled() &&
chargingStation.hasAuthorizedTags() &&
if (
chargingStation.getLocalAuthListEnabled() &&
chargingStation.hasAuthorizedTags() &&
- chargingStation.authorizedTags.find((value) => value === commandPayload.idTag)
+ chargingStation.authorizedTagsCache
+ .getAuthorizedTags(
+ ChargingStationUtils.getAuthorizationFile(chargingStation.stationInfo)
+ )
+ .find((value) => value === commandPayload.idTag)
) {
connectorStatus.localAuthorizeIdTag = commandPayload.idTag;
connectorStatus.idTagLocalAuthorized = true;
) {
connectorStatus.localAuthorizeIdTag = commandPayload.idTag;
connectorStatus.idTagLocalAuthorized = true;
@@
-881,7
+886,7
@@
export default class OCPP16IncomingRequestService extends OCPPIncomingRequestSer
let ftpClient: Client;
try {
const logFiles = fs
let ftpClient: Client;
try {
const logFiles = fs
- .readdirSync(path.resolve(
__dirname
, '../../../../'))
+ .readdirSync(path.resolve(
path.dirname(fileURLToPath(import.meta.url))
, '../../../../'))
.filter((file) => file.endsWith('.log'))
.map((file) => path.join('./', file));
const diagnosticsArchive = chargingStation.stationInfo.chargingStationId + '_logs.tar.gz';
.filter((file) => file.endsWith('.log'))
.map((file) => path.join('./', file));
const diagnosticsArchive = chargingStation.stationInfo.chargingStationId + '_logs.tar.gz';
@@
-910,7
+915,10
@@
export default class OCPP16IncomingRequestService extends OCPPIncomingRequestSer
});
});
uploadResponse = await ftpClient.uploadFrom(
});
});
uploadResponse = await ftpClient.uploadFrom(
- path.join(path.resolve(__dirname, '../../../../'), diagnosticsArchive),
+ path.join(
+ path.resolve(path.dirname(fileURLToPath(import.meta.url)), '../../../../'),
+ diagnosticsArchive
+ ),
uri.pathname + diagnosticsArchive
);
if (uploadResponse.code === 226) {
uri.pathname + diagnosticsArchive
);
if (uploadResponse.code === 226) {