examples/unicoap_server: add sample unicoap server application

Author: carl-tud

examples/networking/coap/unicoap_server/Makefile

@@ -0,0 +1,63 @@
+# Default Makefile, for unicoap message APIs
+
+# name of your application
+APPLICATION = unicoap_server
+
+# If no BOARD is found in the environment, use this default:
+BOARD ?= native
+
+# This has to be the absolute path to the RIOT base directory:
+RIOTBASE ?= $(CURDIR)/../../../..
+
+# Include packages that pull up and auto-init the link layer.
+# NOTE: 6LoWPAN will be included if IEEE802.15.4 devices are present
+USEMODULE += netdev_default
+
+# use GNRC by default
+LWIP_IPV4 ?= 0
+LWIP_IPV6 ?= 0
+
+ifeq (,$(filter 1, $(LWIP_IPV4) $(LWIP_IPV6)))
+  USEMODULE += auto_init_gnrc_netif
+  # Specify the mandatory networking modules
+  USEMODULE += gnrc_ipv6_default
+  # Additional networking modules that can be dropped if not needed
+  USEMODULE += gnrc_icmpv6_echo
+else
+  ifeq (1,$(LWIP_IPV4))
+    USEMODULE += ipv4_addr
+
+    USEMODULE += lwip_arp
+    USEMODULE += lwip_ipv4
+    USEMODULE += lwip_dhcp_auto
+    CFLAGS += -DETHARP_SUPPORT_STATIC_ENTRIES=1
+  endif
+
+  ifeq (1,$(LWIP_IPV6))
+    USEMODULE += ipv6_addr
+
+    USEMODULE += lwip_ipv6
+    USEMODULE += lwip_ipv6_autoconfig
+  endif
+endif
+
+USEMODULE += unicoap
+USEMODULE += unicoap_resources_xfa
+
+# This module is needed for CoAP over UDP
+USEMODULE += unicoap_driver_udp
+
+# This module is needed for CoAP over DTLS
+USEMODULE += unicoap_driver_dtls
+
+# It is okay to import only either of the CoAP over UDP and CoAP over DTLS drivers.
+
+# Comment this out to disable code in RIOT that does safety checking
+# which is not needed in a production environment but helps in the
+# development process:
+DEVELHELP ?= 1
+
+# Change this to 0 show compiler invocation lines by default:
+QUIET ?= 1
+
+include $(RIOTBASE)/Makefile.include

examples/networking/coap/unicoap_server/app.config

@@ -0,0 +1,2 @@
+CONFIG_UNICOAP_DEBUG_LOGGING=y
+CONFIG_UNICOAP_ASSIST=y

examples/networking/coap/unicoap_server/client.py

@@ -0,0 +1,118 @@
+#!/usr/bin/env python3
+
+import logging
+import asyncio
+import sys
+from argparse import ArgumentParser, Namespace
+
+from aiocoap import *
+import aiocoap.resource as resource
+
+logging.basicConfig(level=logging.DEBUG)
+
+print("usage: client.py -m <GET|PUT|POST|DELETE|PATCH|iPATCH|FETCH> -u <URI> [--type <NON|CON>] [--observe] [-p <PAYLOAD>]")
+
+def _get(_list, i, default):
+    return _list[i] if len(_list) > i else default
+
+def message_type(arg):
+    return { "CON": CON, "NON": NON }[arg]
+
+def method(arg):
+    return {
+        "GET": GET,
+        "PUT": PUT,
+        "POST": POST,
+        "DELETE": DELETE,
+        "PATCH": PATCH,
+        "iPATCH": iPATCH,
+        "FETCH": FETCH
+    }[arg]
+    
+async def main():
+    parser = ArgumentParser()
+    
+    parser.add_argument(
+        "-m", "--method",
+        help='GET|PUT|POST|DELETE|PATCH|iPATCH|FETCH',
+        required=True)
+    
+    parser.add_argument(
+        "-u", "--uri",
+        help='URI',
+        required=True)
+    
+    parser.add_argument(
+        "-t", "--type",
+        help='NON|CON',
+        default="NON")
+    
+    parser.add_argument(
+        "--observe",
+        action="store_true",
+        help='Register for notifications',
+        default=False)
+        
+    parser.add_argument(
+        "--observe-cancel",
+        action="store_true",
+        help='Cancel notifications',
+        default=False)
+        
+    parser.add_argument(
+        "-p", "--payload",
+        help='Payload',
+        default=None)
+    
+    args = parser.parse_args()
+    
+    observeValue = None
+    
+    if args.observe and args.observe_cancel:
+        raise ValueError("Cannot register for and cancel notifications")
+    
+    if args.observe:
+        observeValue = 0
+    
+    elif args.observe_cancel:
+        observeValue = 1
+    
+    print(f"using {message_type(args.type)} {method(args.method)} request");
+    
+    port = 5600
+    protocol = await Context.create_server_context(bind=("::", port), site=resource.Site())
+    protocol.client_credentials.load_from_dict({
+        '*': {
+            'dtls': {
+                'psk': b'secretPSK',
+                'client-identity': b'Client_identity',
+            }
+        }
+    })
+
+    request = Message(
+        mtype=message_type(args.type),
+        code=method(args.method),
+        uri=args.uri,
+        payload=bytes(args.payload, 'utf-8') if args.payload else "",
+        observe=observeValue
+    )
+
+    try:
+        pr = protocol.request(request)
+        
+        r = await pr.response
+        print("response: %s\n%r" % (r.code, r.payload))
+        
+        if args.observe:
+            print("waiting for resource notifications")
+            async for r in pr.observation:
+                print("notification: %s\n%r" % (r, r.payload))
+                break;
+
+    except Exception as e:
+        print("error:")
+        print(e)
+
+if __name__ == "__main__":
+    asyncio.run(main())