#include <ARpc.h>
#include <ARpcBase.h>
#include <ARpcSrvReady.h>
const char *deviceName="led_blink_test";//имя устройства
const char *deviceId="{9c7ea7a4-5276-476a-914c-e95736ee304e}";//идентификатор устройства
int ledPin=13;//пин светодиода
unsigned long blinksCount=0;//число миганий
const char *interfaceStr="<controls><group title=\"Device controls\"><control sync=\"0\" title=\"Blink\" command=\"blink\"/></group></controls>";
//для получения данных с устройства необходимо подготовить описание датчиков
const char *sensorsDef="<sensors>"
"<sensor name=\"blinks_count\" type=\"single\"/>"//датчик blinks_count
"<sensor name=\"sin_x\" type=\"single\"><constraints dims=\"2\"/></sensor>"//датчик sin_x (двумерный)
"</sensors>";
//Определяем функцию обработки команд, передаваемых устройству.
//Библиотека будет вызывать эту функцию, когда на устройство будут
//приходить команды, например, введенные нами в мониторе порта.
//Эта функция принимает команду, аргументы команды, количество аргументов
//и указатель на объект класса ARpc, от которого пришла команда
void processCommand(const char *cmd,const char *args[],int argsCount,ARpc *parser)
{
if(strcmp(cmd,"blink")==0)//проверяем, что cmd == "blink"
{
//мигаем
digitalWrite(13,HIGH);
delay(200);
digitalWrite(13,LOW);
delay(200);
++blinksCount;
//генерируем "измерение"
parser->writeMeasurement("blinks_count",String(blinksCount).c_str());
//сообщаем библиотеке что команда обработана
parser->writeOk();
}
else parser->writeErr("Unknown cmd");//неизвестная команда
}
//Определяем функцию для передачи сообщений к ПК через последовательный пор
void arpcWriteCallback(const char *str)
{
Serial.print(str);
}
//объявляем объект класса ARpc и передаем ему ссылки на созданные
//выше переменные и функции
ARpc parser(300,&processCommand,&arpcWriteCallback,deviceId,deviceName);
int t=0;
void writeSinVal()
{
String sinVal;
sinVal+=String(sin(0.1*t));
sinVal+="|";
sinVal+=String(cos(0.1*t));
parser.writeMeasurement("sin_x",sinVal.c_str());
++t;
}
//Проихводим инициальзацию пина и последовательного порта в функции setup()
//и установить описание датчиков и интерфейса управления
void setup() {
// put your setup code here, to run once:
Serial.begin(9600);
pinMode(13,OUTPUT);
parser.setControlsInterface(interfaceStr);
parser.setSensorsDescription(sensorsDef);
}
//необходимо проверять последовательный порт на наличие новых данных, передавать их объекту parser, сгенерировать новый отсчет sin, после чего сделать
//задержку на пол-секунды, чтобы отсчеты не генерировались слишком часто
void loop() {
// put your main code here, to run repeatedly:
while(Serial.available())
parser.putChar(Serial.read());
writeSinVal();
delay(500);
}
