com.github.niqdev.openwebnet.message

Class Scenario

java.lang.Object

com.github.niqdev.openwebnet.message.Scenario

All Implemented Interfaces:

OpenMessage

public class Scenario
extends java.lang.Object

OpenWebNet Scenario.

 

 import static com.github.niqdev.openwebnet.OpenWebNet.defaultGateway;

 OpenWebNet client = OpenWebNet.newClient(defaultGateway("IP_ADDRESS"));

 // start scenario 31
 client
    .send(Scenario.requestStart("31", Scenario.Version.MH200N))
    .map(Scenario.handleResponse(() -> System.out.println("START"), () -> System.out.println("STOP")))
    .subscribe(System.out::println);

 // requests status scenario 31
 client
    .send(Scenario.requestStatus("31"))
    .map(Scenario.handleStatus(
       () -> System.out.println("STARTED"),
       () -> System.out.println("STOPPED"),
       () -> System.out.println("ENABLED"),
       () -> System.out.println("DISABLED")))
     .subscribe(System.out::println);
 
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Scenario.Version

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	FORMAT_BUS
protected static java.lang.String	FORMAT_DIMENSION
protected static java.lang.String	FORMAT_PREFIX_DIMENSION
protected static java.lang.String	FORMAT_PREFIX_DIMENSION_WHO
protected static java.lang.String	FORMAT_PREFIX_REQUEST_WHO
protected static java.lang.String	FORMAT_PREFIX_RESPONSE
protected static java.lang.String	FORMAT_PREFIX_STATUS_WHO
protected static java.lang.String	FORMAT_REQUEST
protected static java.lang.String	FORMAT_STATUS
static java.lang.String	NO_BUS
static java.lang.String	WHERE_GENERAL_VALUE
protected static java.lang.String	WHERE_GROUP_PREFIX
protected static int	WHERE_MAX_VALUE
protected static int	WHERE_MIN_VALUE

Fields inherited from interface com.github.niqdev.openwebnet.message.OpenMessage

ACK, FRAME_END, FRAME_START, NACK

Method Summary

Modifier and Type	Method and Description
protected static java.lang.String	checkBus(java.lang.String bus)
protected static int	checkIsInteger(java.lang.String value)
protected static void	checkRange(java.lang.Integer from, java.lang.Integer to, java.lang.Integer value)
java.lang.String	getValue() Raw message value.
static rx.functions.Func1<OpenSession,OpenSession>	handleResponse(rx.functions.Action0 onSuccess, rx.functions.Action0 onFail) Handle response from requestStart(String) and requestStop(String).
protected static rx.functions.Func1<OpenSession,OpenSession>	handleResponse(rx.functions.Action0 onSuccess, rx.functions.Action0 onFail, int who)
static rx.functions.Func1<OpenSession,OpenSession>	handleStatus(rx.functions.Action0 startStatus, rx.functions.Action0 stopStatus, rx.functions.Action0 enableStatus, rx.functions.Action0 disableStatus) Handle response from requestStatus(String).
protected static boolean	isInRange(java.lang.Integer from, java.lang.Integer to, java.lang.Integer value)
protected static java.lang.Boolean	isValidBus(java.lang.String bus)
protected static void	isValidPrefixType(OpenMessage request, java.lang.String format, int who)
static Scenario	requestStart(java.lang.String where) OpenWebNet message request to send the START scenario command with value *17*1*WHERE##.
static Scenario	requestStart(java.lang.String where, Scenario.Version version) OpenWebNet message request to send the START scenario command with value *17*1*WHERE##.
static Scenario	requestStatus(java.lang.String where) OpenWebNet message request scenario status with value *#17*WHERE##.
static Scenario	requestStatus(java.lang.String where, Scenario.Version version) OpenWebNet message request scenario status with value *#17*WHERE##.
static Scenario	requestStop(java.lang.String where) OpenWebNet message request to send the STOP scenario command with value *17*2*WHERE##.
static Scenario	requestStop(java.lang.String where, Scenario.Version version) OpenWebNet message request to send the STOP scenario command with value *17*2*WHERE##.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

FORMAT_PREFIX_REQUEST_WHO

protected static final java.lang.String FORMAT_PREFIX_REQUEST_WHO

See Also:

Constant Field Values

FORMAT_PREFIX_DIMENSION_WHO

protected static final java.lang.String FORMAT_PREFIX_DIMENSION_WHO

See Also:

Constant Field Values

FORMAT_PREFIX_STATUS_WHO

protected static final java.lang.String FORMAT_PREFIX_STATUS_WHO

See Also:

Constant Field Values

FORMAT_REQUEST

protected static final java.lang.String FORMAT_REQUEST

See Also:

Constant Field Values

FORMAT_DIMENSION

protected static final java.lang.String FORMAT_DIMENSION

See Also:

Constant Field Values

FORMAT_STATUS

protected static final java.lang.String FORMAT_STATUS

See Also:

Constant Field Values

FORMAT_PREFIX_RESPONSE

protected static final java.lang.String FORMAT_PREFIX_RESPONSE

See Also:

Constant Field Values

FORMAT_PREFIX_DIMENSION

protected static final java.lang.String FORMAT_PREFIX_DIMENSION

See Also:

Constant Field Values

FORMAT_BUS

protected static final java.lang.String FORMAT_BUS

See Also:

Constant Field Values

WHERE_MIN_VALUE

protected static final int WHERE_MIN_VALUE

See Also:

Constant Field Values

WHERE_MAX_VALUE

protected static final int WHERE_MAX_VALUE

See Also:

Constant Field Values

WHERE_GROUP_PREFIX

protected static final java.lang.String WHERE_GROUP_PREFIX

See Also:

Constant Field Values

WHERE_GENERAL_VALUE

public static final java.lang.String WHERE_GENERAL_VALUE

See Also:

Constant Field Values

NO_BUS

public static final java.lang.String NO_BUS

See Also:

Constant Field Values

Method Detail

requestStart

public static Scenario requestStart(java.lang.String where)

OpenWebNet message request to send the START scenario command with value *17*1*WHERE##.

Parameters:

where - Value between 0 and 9999

Returns:

message

requestStart

public static Scenario requestStart(java.lang.String where,
                                    Scenario.Version version)

OpenWebNet message request to send the START scenario command with value *17*1*WHERE##.

Parameters:

where - Value between 0 and 300 if MH200N or 0 and 9999 if MH202

version - MH200N or MH202

Returns:

message

requestStop

public static Scenario requestStop(java.lang.String where)

OpenWebNet message request to send the STOP scenario command with value *17*2*WHERE##.

Parameters:

where - Value between 0 and 9999

Returns:

message

requestStop

public static Scenario requestStop(java.lang.String where,
                                   Scenario.Version version)

OpenWebNet message request to send the STOP scenario command with value *17*2*WHERE##.

Parameters:

where - Value between 0 and 300 if MH200N or 0 and 9999 if MH202

version - MH200N or MH202

Returns:

message

handleResponse

public static rx.functions.Func1<OpenSession,OpenSession> handleResponse(rx.functions.Action0 onSuccess,
                                                                         rx.functions.Action0 onFail)

Handle response from requestStart(String) and requestStop(String).

Parameters:

onSuccess - invoked if the request has been successfully received

onFail - invoked otherwise

Returns:

Observable<OpenSession>

requestStatus

public static Scenario requestStatus(java.lang.String where)

OpenWebNet message request scenario status with value *#17*WHERE##.

Parameters:

where - Value between 0 and 9999

Returns:

message

requestStatus

public static Scenario requestStatus(java.lang.String where,
                                     Scenario.Version version)

OpenWebNet message request scenario status with value *#17*WHERE##.

Parameters:

where - Value between 0 and 300 if MH200N or 0 and 9999 if MH202

version - MH200N or MH202

Returns:

message

handleStatus

public static rx.functions.Func1<OpenSession,OpenSession> handleStatus(rx.functions.Action0 startStatus,
                                                                       rx.functions.Action0 stopStatus,
                                                                       rx.functions.Action0 enableStatus,
                                                                       rx.functions.Action0 disableStatus)

Handle response from requestStatus(String).

Parameters:

startStatus - invoked if scenario is started

stopStatus - invoked if scenario is stopped

enableStatus - invoked if scenario is enabled

disableStatus - invoked if scenario is disabled

Returns:

message

getValue

public java.lang.String getValue()

Description copied from interface: OpenMessage

Raw message value.

Specified by:

getValue in interface OpenMessage

Returns:

value

checkRange

protected static void checkRange(java.lang.Integer from,
                                 java.lang.Integer to,
                                 java.lang.Integer value)

isInRange

protected static boolean isInRange(java.lang.Integer from,
                                   java.lang.Integer to,
                                   java.lang.Integer value)

checkIsInteger

protected static int checkIsInteger(java.lang.String value)

isValidPrefixType

protected static void isValidPrefixType(OpenMessage request,
                                        java.lang.String format,
                                        int who)

handleResponse

protected static rx.functions.Func1<OpenSession,OpenSession> handleResponse(rx.functions.Action0 onSuccess,
                                                                            rx.functions.Action0 onFail,
                                                                            int who)

checkBus

protected static java.lang.String checkBus(java.lang.String bus)

isValidBus

protected static java.lang.Boolean isValidBus(java.lang.String bus)