request.go

package llrp

import (
	"math/rand"
)

const (
	V_1011_All = iota
	V_1011_General_Device_Capabilities
	V_1011_LLRP_Capabilities
	V_1011_Regulatory_Capabilities
	V_1011_Air_Protocol_LLRP_Capabilities
)

/*
This message is issued by the Reader to the Client. This message can be used by the Client to monitor the LLRP-layer connectivity with the Reader. The Client configures the trigger at the Reader to send the Keepalive message. The configuration is done using the KeepaliveSpec parameter
*/
func SEND_KEEPALIVE(messageId int) []byte {
	return bundle(
		M_KEEPALIVE_ACK,
		messageId,
		nil,
	)
}

/*
This message is issued by the Client to the Reader to get the tag reports. In response to this message, the Reader SHALL return tag reports accumulated. If no reports are available to send as a response to a GET_REPORT message, the Reader MAY return an empty RO_ACCESS_REPORT message.
*/
func GET_REPORT(messageId int) []byte {
	return bundle(
		M_GET_REPORT,
		messageId,
		nil,
	)
}

// Convert custom pack to protocol []byte
func CustomPack(messageType, messageId int, config []interface{}, params ...[]interface{}) []byte {
	return bundle(messageType, messageId, config, params...)
}

/*
This command is issued by the Client to the Reader. This command instructs the Reader to gracefully close its connection with the Client. Under normal operating conditions, a Client SHALL attempt to send this command before closing an LLRP connection
*/
func CLOSE_CONNECTION(messageId int) []byte {
	return bundle(
		M_CLOSE_CONNECTION,
		messageId,
		nil,
	)
}

/*
This message is issued by the Client to the Reader. Upon receiving the message, the Reader starts the ROSpec corresponding to ROSpecID passed in this message, if the ROSpec is in the enabled state.
*/
func START_ROSPEC(messageId, ROSpecID int) []byte {
	return bundle(
		M_START_ROSPEC,
		messageId,
		[]interface{}{
			uint32(preventZero(ROSpecID)),
		},
	)
}
func preventZero(c int) int {
	if c == 0 {
		return int(rand.Uint32())
	}
	return c
}

/*
This message is issued by the Client to the Reader. Upon receiving the message, the Reader stops the execution of the ROSpec corresponding to the ROSpecID passed in this message. STOP_ROSPEC overrides all other priorities and stops the execution. This basically moves the ROSpec’s state to Inactive. This message does not the delete the ROSpec.
*/
func STOP_ROSPEC(messageId, ROSpecID int) []byte {
	return bundle(
		M_STOP_ROSPEC,
		messageId,
		[]interface{}{
			uint32(preventZero(ROSpecID)),
		},
	)
}

/*
This message is issued by the Client to the Reader. Upon receiving the message, the Reader moves the ROSpec corresponding to the ROSpecID passed in this message to the disabled state.
*/
func DISABLE_ROSPEC(messageId, ROSpecID int) []byte {
	return bundle(
		M_DISABLE_ROSPEC,
		messageId,
		[]interface{}{
			uint32(ROSpecID),
		},
	)
}

/*
This message can be issued by the Client to the Reader after a LLRP connection is established. The Client uses this message to inform the Reader that it can remove its hold on event and report messages. Readers that are configured to hold events and reports on reconnection (See Section 13.2.6.4) respond to this message by returning the tag reports accumulated (same way they respond to GET_REPORT (See Section 13.1.1)).
*/
func ENABLE_EVENTS_AND_REPORTS(messageId int) []byte {
	return bundle(
		M_ENABLE_EVENTS_AND_REPORTS,
		messageId,
		nil,
	)
}

/*
This message is issued by the Client to the Reader. Upon receiving the message, the Reader moves the ROSpec corresponding to the ROSpecID passed in this message from the disabled to the inactive state.
*/
func ENABLE_ROSPEC(messageId, ROSpecID int) []byte {
	return bundle(
		M_ENABLE_ROSPEC,
		messageId,
		[]interface{}{
			uint32(ROSpecID),
		},
	)
}

func GET_READER_CAPABILITIES_V1011(messageId, v_1011 int) []byte {
	data := []interface{}{
		uint8(v_1011),
	}
	return bundle(
		M_GET_READER_CAPABILITIES,
		messageId,
		data,
	)
}

const (
	C_GET_READER_CONFIG_All = iota
	C_GET_READER_CONFIG_Identification
	C_GET_READER_CONFIG_AntennaProperties
	C_GET_READER_CONFIG_AntennaConfiguration
	C_GET_READER_CONFIG_ROReportSpec
	C_GET_READER_CONFIG_ReaderEventNotificationSpec
	C_GET_READER_CONFIG_AccessReportSpec
	C_GET_READER_CONFIG_LLRPConfigurationStateValue
	C_GET_READER_CONFIG_KeepaliveSpec
	C_GET_READER_CONFIG_GPIPortCurrentState
	C_GET_READER_CONFIG_GPOWriteData
	C_GET_READER_CONFIG_EventsAndReports
)

func GET_READER_CONFIG(messageId, AntennaID, C_TYPE, GPIPortNum, GPOPortNum int) []byte {
	return bundle(
		M_GET_READER_CONFIG,
		messageId,
		[]interface{}{
			uint16(AntennaID),
			uint8(C_TYPE),
			uint16(GPIPortNum),
			uint16(GPOPortNum),
		},
	)
}

func SET_READER_CONFIG(messageId int, restore_factory_setting bool, params ...[]interface{}) []byte {
	f := uint8(0)
	if restore_factory_setting {
		f = uint8(0x80)
	}
	config := []interface{}{
		f,
	}
	return bundle(
		M_SET_READER_CONFIG,
		messageId,
		config,
		params...,
	)
}
func DEL_ROSPEC(messageId, spec int) []byte {
	return bundle(
		M_DELETE_ROSPEC,
		messageId,
		[]interface{}{uint32(spec)},
	)
}

func ADD_ROSPEC(messageId int, params ...[]interface{}) []byte {
	return bundle(
		M_ADD_ROSPEC,
		messageId,
		nil,
		params...,
	)
}