81 lines
2.3 KiB
JavaScript
81 lines
2.3 KiB
JavaScript
import bodyParser from "body-parser";
|
|
|
|
let state = {
|
|
site: {
|
|
grid: { power: 0 },
|
|
pv: { power: 0 },
|
|
battery: { power: 0, soc: 0 },
|
|
},
|
|
loadpoints: [{ power: 0, energy: 0, enabled: false, status: "A" }],
|
|
vehicles: [{ soc: 0, range: 0 }],
|
|
};
|
|
|
|
const stateApiMiddleware = (req, res, next) => {
|
|
if (req.method === "POST" && req.originalUrl === "/api/state") {
|
|
console.log("[simulator] POST /api/state");
|
|
state = req.body;
|
|
res.end();
|
|
} else if (req.method === "POST" && req.originalUrl === "/api/shutdown") {
|
|
console.log("[simulator] POST /api/shutdown");
|
|
res.end();
|
|
process.exit();
|
|
} else if (req.originalUrl === "/api/state") {
|
|
res.end(JSON.stringify(state));
|
|
} else {
|
|
next();
|
|
}
|
|
};
|
|
|
|
const openemsMiddleware = (req, res, next) => {
|
|
const endpoints = {
|
|
"/rest/channel/_sum/GridActivePower": { value: state.site.grid.power },
|
|
"/rest/channel/_sum/ProductionActivePower": { value: state.site.pv.power },
|
|
"/rest/channel/_sum/EssDischargePower": { value: state.site.battery.power },
|
|
"/rest/channel/_sum/EssSoc": { value: state.site.battery.soc },
|
|
};
|
|
const endpoint = endpoints[req.originalUrl];
|
|
if (req.method === "GET" && endpoint) {
|
|
console.log("[simulator] GET", req.originalUrl);
|
|
res.end(JSON.stringify(endpoint));
|
|
} else {
|
|
next();
|
|
}
|
|
};
|
|
|
|
const teslaloggerMiddleware = (req, res, next) => {
|
|
if (req.method === "GET" && req.originalUrl.startsWith("/currentjson/")) {
|
|
const id = parseInt(req.originalUrl.split("/")[2]);
|
|
const vehicle = state.vehicles[id - 1];
|
|
if (!vehicle) {
|
|
res.statusCode = 404;
|
|
res.end(JSON.stringify({ error: "Vehicle not found" }));
|
|
return;
|
|
}
|
|
const data = {
|
|
battery_level: vehicle.soc,
|
|
battery_range_km: vehicle.range,
|
|
plugged_in: true,
|
|
charging: false,
|
|
odometer: 10000,
|
|
is_preconditioning: false,
|
|
charge_current_request: 10,
|
|
};
|
|
res.end(JSON.stringify(data));
|
|
} else {
|
|
next();
|
|
}
|
|
};
|
|
|
|
export default () => ({
|
|
name: "api",
|
|
enforce: "pre",
|
|
configureServer(server) {
|
|
console.log("[simulator] configured");
|
|
return () => {
|
|
server.middlewares.use(bodyParser.json());
|
|
server.middlewares.use(stateApiMiddleware);
|
|
server.middlewares.use(openemsMiddleware);
|
|
server.middlewares.use(teslaloggerMiddleware);
|
|
};
|
|
},
|
|
});
|