Revert "feat(ocpp): 添加对WebSocket子协议的支持和缺失参数检查"
This reverts commit 216a8e118d.
This commit is contained in:
@@ -85,12 +85,8 @@ app.get(
|
|||||||
'/ocpp/:chargePointId',
|
'/ocpp/:chargePointId',
|
||||||
upgradeWebSocket((c) => {
|
upgradeWebSocket((c) => {
|
||||||
const chargePointId = c.req.param('chargePointId')
|
const chargePointId = c.req.param('chargePointId')
|
||||||
if (!chargePointId) {
|
|
||||||
throw new Error('Missing chargePointId route param')
|
|
||||||
}
|
|
||||||
const connInfo = getConnInfo(c)
|
const connInfo = getConnInfo(c)
|
||||||
const requestedProtocol = c.req.header('sec-websocket-protocol')
|
return createOcppHandler(chargePointId, connInfo.remote.address)
|
||||||
return createOcppHandler(chargePointId, connInfo.remote.address, requestedProtocol)
|
|
||||||
}),
|
}),
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|||||||
@@ -92,26 +92,6 @@ function sendCallError(
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
function pickOcppSubprotocol(
|
|
||||||
negotiatedProtocol?: string | null,
|
|
||||||
requestedHeader?: string | null,
|
|
||||||
) {
|
|
||||||
if (negotiatedProtocol && isSupportedOCPP(negotiatedProtocol)) {
|
|
||||||
return negotiatedProtocol
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!requestedHeader) {
|
|
||||||
return null
|
|
||||||
}
|
|
||||||
|
|
||||||
const requestedProtocols = requestedHeader
|
|
||||||
.split(',')
|
|
||||||
.map((value) => value.trim())
|
|
||||||
.filter(Boolean)
|
|
||||||
|
|
||||||
return requestedProtocols.find((protocol) => isSupportedOCPP(protocol)) ?? null
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Factory that produces a hono-ws event handler object for a single
|
* Factory that produces a hono-ws event handler object for a single
|
||||||
* OCPP WebSocket connection.
|
* OCPP WebSocket connection.
|
||||||
@@ -119,11 +99,7 @@ function pickOcppSubprotocol(
|
|||||||
* Usage in route:
|
* Usage in route:
|
||||||
* upgradeWebSocket((c) => createOcppHandler(c.req.param('chargePointId'), remoteAddr))
|
* upgradeWebSocket((c) => createOcppHandler(c.req.param('chargePointId'), remoteAddr))
|
||||||
*/
|
*/
|
||||||
export function createOcppHandler(
|
export function createOcppHandler(chargePointIdentifier: string, remoteAddr?: string) {
|
||||||
chargePointIdentifier: string,
|
|
||||||
remoteAddr?: string,
|
|
||||||
requestedProtocolHeader?: string,
|
|
||||||
) {
|
|
||||||
const ctx: OcppConnectionContext = {
|
const ctx: OcppConnectionContext = {
|
||||||
chargePointIdentifier,
|
chargePointIdentifier,
|
||||||
isRegistered: false,
|
isRegistered: false,
|
||||||
@@ -131,14 +107,14 @@ export function createOcppHandler(
|
|||||||
|
|
||||||
return {
|
return {
|
||||||
onOpen(_evt: Event, ws: WSContext) {
|
onOpen(_evt: Event, ws: WSContext) {
|
||||||
const subProtocol = pickOcppSubprotocol(ws.protocol, requestedProtocolHeader)
|
const subProtocol = ws.protocol ?? 'unknown'
|
||||||
if (!subProtocol) {
|
if (!isSupportedOCPP(subProtocol)) {
|
||||||
ws.close(1002, 'Unsupported subprotocol')
|
ws.close(1002, 'Unsupported subprotocol')
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
ocppConnections.set(chargePointIdentifier, ws)
|
ocppConnections.set(chargePointIdentifier, ws)
|
||||||
console.log(
|
console.log(
|
||||||
`[OCPP] ${chargePointIdentifier} connected (${subProtocol})` +
|
`[OCPP] ${chargePointIdentifier} connected` +
|
||||||
(remoteAddr ? ` from ${remoteAddr}` : ''),
|
(remoteAddr ? ` from ${remoteAddr}` : ''),
|
||||||
)
|
)
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -1,2 +1 @@
|
|||||||
#define MG_ARCH MG_ARCH_ESP32
|
#define MG_ARCH MG_ARCH_ESP32
|
||||||
#define MG_TLS MG_TLS_MBED // Use ESP-IDF built-in mbedTLS for WSS support
|
|
||||||
|
|||||||
Reference in New Issue
Block a user