Skip to content

Commit

Permalink
feat(plc-simulator/cbus): implement proper option support
Browse files Browse the repository at this point in the history
  • Loading branch information
@sruehl
sruehl committed Aug 1, 2022
1 parent f44d597 commit 8ddb301
Show file tree
Hide file tree
Showing 2 changed files with 161 additions and 42 deletions.
2 changes: 1 addition & 1 deletion sandbox/plc-simulator/src/main/java/org/apache/plc4x/simulator/PlcSimulator.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ public static PlcSimulatorConfig plcSimulatorConfigFromArgs(String... args) thro
CommandLine cmd = parser.parse(options, args);

// Map options
config.host = cmd.getOptionValue("--host", "localhost");
config.host = cmd.getOptionValue("host", "localhost");

return config;
}
Expand Down
201 changes: 160 additions & 41 deletions ...ator/src/main/java/org/apache/plc4x/simulator/server/cbus/protocol/CBusServerAdapter.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -38,56 +38,37 @@ public class CBusServerAdapter extends ChannelInboundHandlerAdapter {
private Context context;

private static final RequestContext requestContext = new RequestContext(false, false, false);
private static final CBusOptions cBusOptions = new CBusOptions(false, false, false, false, false, false, false, false, true);

private Lock writeLock = new ReentrantLock();
private static boolean connect;
private static boolean smart;
private static boolean idmon;
private static boolean exstat;
private static boolean monitor;
private static boolean monall;
private static boolean pun;
private static boolean pcn;
private static boolean srchk;
private static CBusOptions cBusOptions;

private final Lock writeLock = new ReentrantLock();

private ScheduledFuture<?> sf;

public CBusServerAdapter(Context context) {
this.context = context;
cBusOptions = new CBusOptions(connect, smart, idmon, exstat, monitor, monall, pun, pcn, srchk);
}

@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
super.channelActive(ctx);
sf = ctx.executor().scheduleAtFixedRate(() -> {
try {
writeLock.lock();
MonitoredSAL monitoredSAL;
if (cBusOptions.getExstat()) {
// TODO implement long from
throw new IllegalStateException("Not implemented");
} else {
LightingData lightingData;
double random = Math.random();
if (random < 0.25) {
lightingData = new LightingDataOn(LightingCommandTypeContainer.LightingCommandOn, (byte) 0xAF);
} else if (random > 0.25 && random < 0.5) {
lightingData = new LightingDataOff(LightingCommandTypeContainer.LightingCommandOff, (byte) 0xAF);
} else if (random > 0.5 && random < 0.75) {
lightingData = new LightingDataRampToLevel(LightingCommandTypeContainer.LightingCommandRampToLevel_20Second, (byte) 0xAF, (byte) 0xE0);
} else {
lightingData = new LightingDataTerminateRamp(LightingCommandTypeContainer.LightingCommandTerminateRamp, (byte) 0xAF);
}
SALData salData = new SALDataLighting(null, lightingData);
monitoredSAL = new MonitoredSALShortFormBasicMode((byte) 0x0, (byte) 0x0, (short) 0x0, (short) 0x0, (byte) 0x0, ApplicationIdContainer.LIGHTING_38, salData, cBusOptions);
}
EncodedReply encodedReply = new MonitoredSALReply((byte) 0x0, monitoredSAL, cBusOptions, requestContext);
Reply reply = new ReplyEncodedReply((byte) 0x0, encodedReply, null, cBusOptions, requestContext);
ReplyOrConfirmation replyOrConfirmation = new ReplyOrConfirmationReply((byte) 0x00, reply, new ResponseTermination(), cBusOptions, requestContext);
CBusMessage message = new CBusMessageToClient(replyOrConfirmation, requestContext, cBusOptions);
LOGGER.info("[Monitor] Sending out\n{}\n{}", message, encodedReply);
ctx.writeAndFlush(message);
} finally {
writeLock.unlock();
}
}, 5, 5, TimeUnit.SECONDS);
private static void buildCBusOptions() {
LOGGER.info("Updating options {}", cBusOptions);
cBusOptions = new CBusOptions(connect, smart, idmon, exstat, monitor, monall, pun, pcn, srchk);
LOGGER.info("Updated options {}", cBusOptions);
}

@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
sf.cancel(false);
if (sf != null)
sf.cancel(false);
super.channelInactive(ctx);
}

Expand All @@ -111,8 +92,81 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
}
if (request instanceof RequestDirectCommandAccess) {
RequestDirectCommandAccess requestDirectCommandAccess = (RequestDirectCommandAccess) request;
LOGGER.info("Handling RequestDirectCommandAccess\n{}", requestDirectCommandAccess);
// TODO: handle this
CALData calData = requestDirectCommandAccess.getCalData();
LOGGER.info("Handling RequestDirectCommandAccess\n{}\n{}", requestDirectCommandAccess, calData);

// TODO: handle other cal data type
if (calData instanceof CALDataWrite) {
CALDataWrite calDataWrite = (CALDataWrite) calData;
switch (calDataWrite.getParamNo().getParameterType()) {
case APPLICATION_ADDRESS_1:
// TODO: check settings for subscription etc.
return;
case APPLICATION_ADDRESS_2:
// TODO: check settings for subscription etc.
return;
case INTERFACE_OPTIONS_1:
InterfaceOptions1 interfaceOptions1 = ((ParameterValueInterfaceOptions1) calDataWrite.getParameterValue()).getValue();
idmon = interfaceOptions1.getIdmon();
monitor = interfaceOptions1.getMonitor();
if (monitor) startMonitor(ctx);
else stopMonitor();
smart = interfaceOptions1.getSmart();
srchk = interfaceOptions1.getSrchk();
// TODO: add support for xonxoff
// xonxoff = interfaceOptions1.getXonXoff();
connect = interfaceOptions1.getConnect();
buildCBusOptions();
return;
case INTERFACE_OPTIONS_2:
InterfaceOptions2 interfaceOptions2 = ((ParameterValueInterfaceOptions2) calDataWrite.getParameterValue()).getValue();
// TODO: add support for burden
// burden = interfaceOptions2.getBurden();
// TODO: add support for clockgen
// clockgen = interfaceOptions2.getClockGen();
buildCBusOptions();
return;
case INTERFACE_OPTIONS_3:
InterfaceOptions3 interfaceOptions3Value = ((ParameterValueInterfaceOptions3) calDataWrite.getParameterValue()).getValue();
exstat = interfaceOptions3Value.getExstat();
pun = interfaceOptions3Value.getPun();
// TODO: add support for localsal
// localsal = interfaceOptions3Value.getLocalSal();
pcn = interfaceOptions3Value.getPcn();
buildCBusOptions();
return;
case BAUD_RATE_SELECTOR:
BaudRateSelector baudRateSelector = ((ParameterValueBaudRateSelector) calDataWrite.getParameterValue()).getValue();
// TODO: add support for baudrate
// baudrate = baudRateSelector.getValue();
buildCBusOptions();
return;
case INTERFACE_OPTIONS_1_POWER_UP_SETTINGS:
InterfaceOptions1 interfaceOptions1PowerUpSettings = ((ParameterValueInterfaceOptions1PowerUpSettings) calDataWrite.getParameterValue()).getValue().getInterfaceOptions1();
idmon = interfaceOptions1PowerUpSettings.getIdmon();
monitor = interfaceOptions1PowerUpSettings.getMonitor();
if (monitor) startMonitor(ctx);
else stopMonitor();
smart = interfaceOptions1PowerUpSettings.getSmart();
srchk = interfaceOptions1PowerUpSettings.getSrchk();
// TODO: add support for xonxoff
// xonxoff = interfaceOptions1PowerUpSettings.getXonXoff();
connect = interfaceOptions1PowerUpSettings.getConnect();
buildCBusOptions();
return;
case CUSTOM_MANUFACTURER:
// TODO: handle other parm typed
return;
case SERIAL_NUMBER:
// TODO: handle other parm typed
return;
case CUSTOM_TYPE:
// TODO: handle other parm typed
return;
default:
throw new IllegalStateException("Unmapped type");
}
}
return;
}
if (request instanceof RequestCommand) {
Expand Down Expand Up @@ -223,7 +277,15 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
if (request instanceof RequestReset) {
RequestReset requestReset = (RequestReset) request;
LOGGER.info("Handling RequestReset\n{}", requestReset);
// TODO: handle this
connect = false;
smart = false;
idmon = false;
exstat = false;
monitor = false;
monall = false;
pun = false;
pcn = false;
srchk = false;
return;
}
if (request instanceof RequestSmartConnectShortcut) {
Expand All @@ -237,4 +299,61 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
}
}

private void startMonitor(ChannelHandlerContext ctx) {
if (sf != null) {
LOGGER.debug("Monitor already running");
return;
}
LOGGER.info("Starting monitor");
sf = ctx.executor().scheduleAtFixedRate(() -> {
try {
writeLock.lock();
MonitoredSAL monitoredSAL;
if (cBusOptions.getExstat()) {
LightingData lightingData;
double random = Math.random();
if (random < 0.25) {
lightingData = new LightingDataOn(LightingCommandTypeContainer.LightingCommandOn, (byte) 0xAF);
} else if (random > 0.25 && random < 0.5) {
lightingData = new LightingDataOff(LightingCommandTypeContainer.LightingCommandOff, (byte) 0xAF);
} else if (random > 0.5 && random < 0.75) {
lightingData = new LightingDataRampToLevel(LightingCommandTypeContainer.LightingCommandRampToLevel_20Second, (byte) 0xAF, (byte) 0xE0);
} else {
lightingData = new LightingDataTerminateRamp(LightingCommandTypeContainer.LightingCommandTerminateRamp, (byte) 0xAF);
}
SALData salData = new SALDataLighting(null, lightingData);
monitoredSAL = new MonitoredSALLongFormSmartMode((byte) 0x05, (byte) 0x00, new UnitAddress((byte) 0x0), null, ApplicationIdContainer.LIGHTING_38, (byte) 0x00, null, salData, cBusOptions);
} else {
LightingData lightingData;
double random = Math.random();
if (random < 0.25) {
lightingData = new LightingDataOn(LightingCommandTypeContainer.LightingCommandOn, (byte) 0xAF);
} else if (random > 0.25 && random < 0.5) {
lightingData = new LightingDataOff(LightingCommandTypeContainer.LightingCommandOff, (byte) 0xAF);
} else if (random > 0.5 && random < 0.75) {
lightingData = new LightingDataRampToLevel(LightingCommandTypeContainer.LightingCommandRampToLevel_20Second, (byte) 0xAF, (byte) 0xE0);
} else {
lightingData = new LightingDataTerminateRamp(LightingCommandTypeContainer.LightingCommandTerminateRamp, (byte) 0xAF);
}
SALData salData = new SALDataLighting(null, lightingData);
monitoredSAL = new MonitoredSALShortFormBasicMode((byte) 0x0, (byte) 0x0, (short) 0x0, (short) 0x0, (byte) 0x0, ApplicationIdContainer.LIGHTING_38, salData, cBusOptions);
}
EncodedReply encodedReply = new MonitoredSALReply((byte) 0x0, monitoredSAL, cBusOptions, requestContext);
Reply reply = new ReplyEncodedReply((byte) 0x0, encodedReply, null, cBusOptions, requestContext);
ReplyOrConfirmation replyOrConfirmation = new ReplyOrConfirmationReply((byte) 0x00, reply, new ResponseTermination(), cBusOptions, requestContext);
CBusMessage message = new CBusMessageToClient(replyOrConfirmation, requestContext, cBusOptions);
LOGGER.info("[Monitor] Sending out\n{}\n{}", message, encodedReply);
ctx.writeAndFlush(message);
} finally {
writeLock.unlock();
}
}, 5, 5, TimeUnit.SECONDS);
}

private void stopMonitor() {
LOGGER.info("Stopping monitor");
sf.cancel(false);
sf = null;
}

}

0 comments on commit 8ddb301

Please sign in to comment.