mirror of
https://github.com/RIOT-OS/RIOT.git
synced 2024-12-29 04:50:03 +01:00
129 lines
3.6 KiB
C
129 lines
3.6 KiB
C
/*
|
|
* Copyright (C) 2017-2019 Freie Universität Berlin
|
|
*
|
|
* This file is subject to the terms and conditions of the GNU Lesser
|
|
* General Public License v2.1. See the file LICENSE in the top level
|
|
* directory for more details.
|
|
*/
|
|
|
|
/**
|
|
* @ingroup examples
|
|
* @{
|
|
*
|
|
* @file
|
|
* @brief Test application demonstrating the simple registration
|
|
* process to a CoRE RD using gcoap and cord_epsim
|
|
*
|
|
* @author Hauke Petersen <hauke.petersen@fu-berlin.de>
|
|
*
|
|
* @}
|
|
*/
|
|
|
|
#include <stdio.h>
|
|
|
|
#include "net/gcoap.h"
|
|
#include "net/cord/epsim.h"
|
|
#include "net/cord/common.h"
|
|
|
|
#define BUFSIZE (64U)
|
|
#define STARTUP_DELAY (3U) /* wait 3s before sending first request*/
|
|
|
|
static char riot_info[BUFSIZE];
|
|
|
|
/* define some dummy CoAP resources */
|
|
static ssize_t text_resp(coap_pkt_t *pdu, uint8_t *buf, size_t len,
|
|
const char *text, unsigned format)
|
|
{
|
|
gcoap_resp_init(pdu, buf, len, COAP_CODE_CONTENT);
|
|
coap_opt_add_format(pdu, format);
|
|
ssize_t resp_len = coap_opt_finish(pdu, COAP_OPT_FINISH_PAYLOAD);
|
|
size_t slen = strlen(text);
|
|
memcpy(pdu->payload, text, slen);
|
|
return resp_len + slen;
|
|
}
|
|
|
|
static ssize_t handler_info(coap_pkt_t *pdu, uint8_t *buf, size_t len, void *ctx)
|
|
{
|
|
(void)ctx;
|
|
return text_resp(pdu, buf, len, riot_info, COAP_FORMAT_JSON);
|
|
}
|
|
|
|
static ssize_t handler_text(coap_pkt_t *pdu, uint8_t *buf, size_t len, void *ctx)
|
|
{
|
|
return text_resp(pdu, buf, len, (char *)ctx, COAP_FORMAT_TEXT);
|
|
}
|
|
|
|
static const coap_resource_t resources[] = {
|
|
{ "/riot/bar", COAP_GET, handler_text, "foo" },
|
|
{ "/riot/foo", COAP_GET, handler_text, "bar" },
|
|
{ "/riot/info", COAP_GET, handler_info, NULL }
|
|
};
|
|
|
|
static gcoap_listener_t listener = {
|
|
.resources = &resources[0],
|
|
.resources_len = ARRAY_SIZE(resources),
|
|
.next = NULL
|
|
};
|
|
|
|
int main(void)
|
|
{
|
|
puts("Simplified CoRE RD registration example\n");
|
|
|
|
/* fill riot info */
|
|
sprintf(riot_info, "{\"ep\":\"%s\",\"lt\":%u}",
|
|
cord_common_get_ep(), CORD_LT);
|
|
|
|
/* parse RD address information */
|
|
sock_udp_ep_t rd_ep = {
|
|
.family = AF_INET6,
|
|
.netif = SOCK_ADDR_ANY_NETIF,
|
|
.port = RD_PORT,
|
|
};
|
|
|
|
/* parse RD server address */
|
|
if (ipv6_addr_from_str((ipv6_addr_t *)&rd_ep.addr.ipv6, RD_ADDR) == NULL) {
|
|
puts("error: unable to parse RD address from RD_ADDR variable");
|
|
return 1;
|
|
}
|
|
|
|
/* register resource handlers with gcoap */
|
|
gcoap_register_listener(&listener);
|
|
|
|
/* print RD client information */
|
|
puts("epsim configuration:");
|
|
printf(" ep: %s\n", cord_common_get_ep());
|
|
printf(" lt: %is\n", (int)CORD_LT);
|
|
printf(" RD address: [%s]:%u\n\n", RD_ADDR, (unsigned)RD_PORT);
|
|
|
|
xtimer_sleep(STARTUP_DELAY);
|
|
|
|
while (1) {
|
|
int res = cord_epsim_state();
|
|
switch (res) {
|
|
case CORD_EPSIM_OK:
|
|
puts("state: registration active");
|
|
break;
|
|
case CORD_EPSIM_BUSY:
|
|
puts("state: registration in progress");
|
|
break;
|
|
case CORD_EPSIM_ERROR:
|
|
default:
|
|
puts("state: not registered");
|
|
break;
|
|
}
|
|
|
|
printf("updating registration with RD [%s]:%u\n", RD_ADDR,
|
|
(unsigned)RD_PORT);
|
|
res = cord_epsim_register(&rd_ep);
|
|
if (res == CORD_EPSIM_BUSY) {
|
|
puts("warning: registration already in progress");
|
|
}
|
|
else if (res == CORD_EPSIM_ERROR) {
|
|
puts("error: unable to trigger simple registration process");
|
|
}
|
|
xtimer_sleep(CORD_UPDATE_INTERVAL);
|
|
}
|
|
|
|
return 0;
|
|
}
|