// Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
-import fs from 'node:fs';
-import path from 'node:path';
+import { createWriteStream, readdirSync } from 'node:fs';
+import { dirname, join, resolve } from 'node:path';
import { URL, fileURLToPath } from 'node:url';
import type { JSONSchemaType } from 'ajv';
import { Client, type FTPResponse } from 'basic-ftp';
-import tar from 'tar';
+import { create } from 'tar';
import { OCPP16Constants } from './OCPP16Constants';
import { OCPP16ServiceUtils } from './OCPP16ServiceUtils';
import {
type ChargingStation,
ChargingStationConfigurationUtils,
- ChargingStationUtils,
+ checkChargingStation,
} from '../../../charging-station';
import { OCPPError } from '../../../exception';
import {
type UnlockConnectorRequest,
type UnlockConnectorResponse,
} from '../../../types';
-import { Constants, Utils, logger } from '../../../utils';
+import {
+ Constants,
+ convertToDate,
+ convertToInt,
+ formatDurationMilliSeconds,
+ getRandomInteger,
+ isEmptyArray,
+ isNotEmptyArray,
+ isNotEmptyString,
+ isNullOrUndefined,
+ isUndefined,
+ logger,
+ sleep,
+} from '../../../utils';
import { OCPPIncomingRequestService } from '../OCPPIncomingRequestService';
const moduleName = 'OCPP16IncomingRequestService';
`${chargingStation.logPrefix()} ${
commandPayload.type
} reset command received, simulating it. The station will be
- back online in ${Utils.formatDurationMilliSeconds(chargingStation.stationInfo.resetTime)}`
+ back online in ${formatDurationMilliSeconds(chargingStation.stationInfo.resetTime)}`
);
return OCPP16Constants.OCPP_RESPONSE_ACCEPTED;
}
): GetConfigurationResponse {
const configurationKey: OCPPConfigurationKey[] = [];
const unknownKey: string[] = [];
- if (Utils.isUndefined(commandPayload.key) === true) {
+ if (isUndefined(commandPayload.key) === true) {
for (const configuration of chargingStation.ocppConfiguration.configurationKey) {
- if (Utils.isUndefined(configuration.visible) === true) {
+ if (isUndefined(configuration.visible) === true) {
configuration.visible = true;
}
if (configuration.visible === false) {
value: configuration.value,
});
}
- } else if (Utils.isNotEmptyArray(commandPayload.key) === true) {
+ } else if (isNotEmptyArray(commandPayload.key) === true) {
for (const key of commandPayload.key) {
const keyFound = ChargingStationConfigurationUtils.getConfigurationKey(
chargingStation,
true
);
if (keyFound) {
- if (Utils.isUndefined(keyFound.visible) === true) {
+ if (isUndefined(keyFound.visible) === true) {
keyFound.visible = true;
}
if (keyFound.visible === false) {
return OCPP16Constants.OCPP_RESPONSE_REJECTED;
}
if (
- Utils.isEmptyArray(
- chargingStation.getConnectorStatus(commandPayload.connectorId)?.chargingProfiles
- )
+ isEmptyArray(chargingStation.getConnectorStatus(commandPayload.connectorId)?.chargingProfiles)
) {
return OCPP16Constants.OCPP_RESPONSE_REJECTED;
}
return OCPP16Constants.OCPP_CLEAR_CHARGING_PROFILE_RESPONSE_UNKNOWN;
}
if (
- !Utils.isNullOrUndefined(commandPayload.connectorId) &&
- Utils.isNotEmptyArray(
+ !isNullOrUndefined(commandPayload.connectorId) &&
+ isNotEmptyArray(
chargingStation.getConnectorStatus(commandPayload.connectorId)?.chargingProfiles
)
) {
);
return OCPP16Constants.OCPP_CLEAR_CHARGING_PROFILE_RESPONSE_ACCEPTED;
}
- if (Utils.isNullOrUndefined(commandPayload.connectorId)) {
+ if (isNullOrUndefined(commandPayload.connectorId)) {
let clearedCP = false;
const clearChargingProfiles = (connectorStatus: ConnectorStatus) => {
- if (Utils.isNotEmptyArray(connectorStatus?.chargingProfiles)) {
+ if (isNotEmptyArray(connectorStatus?.chargingProfiles)) {
connectorStatus?.chargingProfiles?.forEach(
(chargingProfile: OCPP16ChargingProfile, index: number) => {
let clearCurrentCP = false;
return OCPP16Constants.OCPP_RESPONSE_EMPTY;
}
if (
- !Utils.isNullOrUndefined(chargingStation.stationInfo.firmwareStatus) &&
+ !isNullOrUndefined(chargingStation.stationInfo.firmwareStatus) &&
chargingStation.stationInfo.firmwareStatus !== OCPP16FirmwareStatus.Installed
) {
logger.warn(
);
return OCPP16Constants.OCPP_RESPONSE_EMPTY;
}
- const retrieveDate = Utils.convertToDate(commandPayload.retrieveDate);
+ const retrieveDate = convertToDate(commandPayload.retrieveDate);
const now = Date.now();
if (retrieveDate?.getTime() <= now) {
this.runInAsyncScope(
maxDelay = 30,
minDelay = 15
): Promise<void> {
- if (
- ChargingStationUtils.checkChargingStation(chargingStation, chargingStation.logPrefix()) ===
- false
- ) {
+ if (checkChargingStation(chargingStation, chargingStation.logPrefix()) === false) {
return;
}
if (chargingStation.hasEvses) {
chargingStation.stationInfo?.firmwareUpgrade?.failureStatus ===
OCPP16FirmwareStatus.DownloadFailed
) {
- await Utils.sleep(Utils.getRandomInteger(maxDelay, minDelay) * 1000);
+ await sleep(getRandomInteger(maxDelay, minDelay) * 1000);
await chargingStation.ocppRequestService.requestHandler<
OCPP16FirmwareStatusNotificationRequest,
OCPP16FirmwareStatusNotificationResponse
chargingStation.stationInfo?.firmwareUpgrade?.failureStatus;
return;
}
- await Utils.sleep(Utils.getRandomInteger(maxDelay, minDelay) * 1000);
+ await sleep(getRandomInteger(maxDelay, minDelay) * 1000);
await chargingStation.ocppRequestService.requestHandler<
OCPP16FirmwareStatusNotificationRequest,
OCPP16FirmwareStatusNotificationResponse
waitTime / 1000
} seconds before continuing firmware update simulation`
);
- await Utils.sleep(waitTime);
+ await sleep(waitTime);
transactionsStarted = true;
wasTransactionsStarted = true;
} else {
transactionsStarted = false;
}
} while (transactionsStarted);
- !wasTransactionsStarted &&
- (await Utils.sleep(Utils.getRandomInteger(maxDelay, minDelay) * 1000));
- if (
- ChargingStationUtils.checkChargingStation(chargingStation, chargingStation.logPrefix()) ===
- false
- ) {
+ !wasTransactionsStarted && (await sleep(getRandomInteger(maxDelay, minDelay) * 1000));
+ if (checkChargingStation(chargingStation, chargingStation.logPrefix()) === false) {
return;
}
await chargingStation.ocppRequestService.requestHandler<
chargingStation.stationInfo?.firmwareUpgrade?.failureStatus ===
OCPP16FirmwareStatus.InstallationFailed
) {
- await Utils.sleep(Utils.getRandomInteger(maxDelay, minDelay) * 1000);
+ await sleep(getRandomInteger(maxDelay, minDelay) * 1000);
await chargingStation.ocppRequestService.requestHandler<
OCPP16FirmwareStatusNotificationRequest,
OCPP16FirmwareStatusNotificationResponse
return;
}
if (chargingStation.stationInfo?.firmwareUpgrade?.reset === true) {
- await Utils.sleep(Utils.getRandomInteger(maxDelay, minDelay) * 1000);
+ await sleep(getRandomInteger(maxDelay, minDelay) * 1000);
await chargingStation.reset(OCPP16StopTransactionReason.REBOOT);
}
}
if (uri.protocol.startsWith('ftp:')) {
let ftpClient: Client;
try {
- const logFiles = fs
- .readdirSync(path.resolve(path.dirname(fileURLToPath(import.meta.url)), '../'))
+ const logFiles = readdirSync(resolve(dirname(fileURLToPath(import.meta.url)), '../'))
.filter((file) => file.endsWith('.log'))
- .map((file) => path.join('./', file));
+ .map((file) => join('./', file));
const diagnosticsArchive = `${chargingStation.stationInfo.chargingStationId}_logs.tar.gz`;
- tar.create({ gzip: true }, logFiles).pipe(fs.createWriteStream(diagnosticsArchive));
+ create({ gzip: true }, logFiles).pipe(createWriteStream(diagnosticsArchive));
ftpClient = new Client();
const accessResponse = await ftpClient.access({
host: uri.host,
- ...(Utils.isNotEmptyString(uri.port) && { port: Utils.convertToInt(uri.port) }),
- ...(Utils.isNotEmptyString(uri.username) && { user: uri.username }),
- ...(Utils.isNotEmptyString(uri.password) && { password: uri.password }),
+ ...(isNotEmptyString(uri.port) && { port: convertToInt(uri.port) }),
+ ...(isNotEmptyString(uri.username) && { user: uri.username }),
+ ...(isNotEmptyString(uri.password) && { password: uri.password }),
});
let uploadResponse: FTPResponse;
if (accessResponse.code === 220) {
});
});
uploadResponse = await ftpClient.uploadFrom(
- path.join(
- path.resolve(path.dirname(fileURLToPath(import.meta.url)), '../'),
- diagnosticsArchive
- ),
+ join(resolve(dirname(fileURLToPath(import.meta.url)), '../'), diagnosticsArchive),
`${uri.pathname}${diagnosticsArchive}`
);
if (uploadResponse.code === 226) {
return OCPP16Constants.OCPP_TRIGGER_MESSAGE_RESPONSE_ACCEPTED;
case OCPP16MessageTrigger.StatusNotification:
setTimeout(() => {
- if (!Utils.isNullOrUndefined(commandPayload?.connectorId)) {
+ if (!isNullOrUndefined(commandPayload?.connectorId)) {
chargingStation.ocppRequestService
.requestHandler<OCPP16StatusNotificationRequest, OCPP16StatusNotificationResponse>(
chargingStation,