Skip to content

Commit

Permalink
fix: bugs
Browse files Browse the repository at this point in the history
  • Loading branch information
nana4rider committed Jan 17, 2025
1 parent b1ee0c0 commit 6df41f2
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 8 deletions.
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
{
"name": "wisun2mqtt",
"version": "1.0.8",
"version": "1.0.9",
"main": "dist/index.js",
"type": "module",
"homepage": "https://github.com/nana4rider/wisun2mqtt",
Expand Down
10 changes: 5 additions & 5 deletions src/connector/BP35Connector.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ const SCAN_DURATION = 6;
const COMMAND_TIMEOUT = 3000;
/** SKSCAN 2のタイムアウト スキャン時間 0.0096 sec * (2^<DURATION> + 1) */
const SCAN_TIMEOUT =
0.0096 * (2 ^ (SCAN_DURATION + 1)) * 28 * 1000 + COMMAND_TIMEOUT;
0.0096 * 2 ** (SCAN_DURATION + 1) * 28 * 1000 + COMMAND_TIMEOUT;
/** SKJOINのタイムアウト */
const JOIN_TIMEOUT = 38000 + COMMAND_TIMEOUT;

Expand Down Expand Up @@ -53,7 +53,7 @@ export class BP35Connector extends Emitter<Events> implements WiSunConnector {
constructor(device: string, side: 0 | 1 | undefined = undefined) {
super();

this.extendArg = side ? ` ${side}` : "";
this.extendArg = side !== undefined ? ` ${side}` : "";
this.serialPort = new SerialPort({ path: device, baudRate: BAUDRATE });
this.parser = this.serialPort.pipe(
new DelimiterParser({ delimiter: Buffer.from(CRLF, "utf-8") }),
Expand Down Expand Up @@ -82,17 +82,17 @@ export class BP35Connector extends Emitter<Events> implements WiSunConnector {
logger.error(`Invalid data format in ERXUDP message: ${textData}`);
return;
}
assert(commandMatcher.input && commandMatcher.groups);
assert(commandMatcher.groups);

// バイナリデータを切り出し
const binaryDataStartIndex = commandMatcher.input.length + 1;
const binaryDataStartIndex = commandMatcher[0].length;
const binaryDataLength = parseInt(commandMatcher.groups.datalen, 16);
const message = data.subarray(
binaryDataStartIndex,
binaryDataStartIndex + binaryDataLength,
);
logger.debug(
`SerialPort response: ${commandMatcher.input}<HEX:${message.toString("hex")}>`,
`SerialPort response: ${commandMatcher[0]}<HEX:${message.toString("hex")}>`,
);

// ポートとヘッダを確認
Expand Down
3 changes: 1 addition & 2 deletions src/service/smartMeter.ts
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ import logger from "@/logger";
import { getDecimalPlaces, parseJson } from "@/util/dataTransformUtil";
import assert from "assert";
import fileExists from "file-exists";
import { readFile, rm, writeFile } from "fs/promises";
import { readFile, writeFile } from "fs/promises";
import { pEvent } from "p-event";

export type SmartMeterClient = {
Expand Down Expand Up @@ -188,7 +188,6 @@ async function initializeWiSunConnector(): Promise<[WiSunConnector, PanInfo]> {
}
} catch (err) {
logger.warn("[SmartMeter] キャッシュされたPan情報で接続失敗", err);
await rm(env.PAN_INFO_PATH);
}
}
if (!panInfo) {
Expand Down

0 comments on commit 6df41f2

Please sign in to comment.