feat: update simple example with observations and failure

Updates the simple.js example test to include handling observation
messages. Also updates to exit early and fail tests on failures.

Signed-off-by: Daniel Mangum <georgedanielmangum@gmail.com>

examples/simple.js

@@ -1,28 +1,31 @@
+import { fail } from 'k6';
 import { Client } from 'k6/x/coap';
 
+
 export default function() {
 	// Create new client and connect.
 	let client;
 	try {
 		client = new Client("coap.golioth.io:5684");
 	} catch (e) {
 		console.log(e);
+		fail(e);
 	}
 
 	// Verify connection.
 	try {
 		let res = client.get("/hello", 10);
 		console.log(String.fromCharCode(...res.body));
 	} catch (e) {
-		console.log(e);
+		fail(e);
 	}
 
 	// Send data.
 	try {
 		let res = client.post("/.s", "application/json", '{"hello": "world"}', 10);
 		console.log(res.code);
 	} catch (e) {
-		console.log(e);
+		fail(e);
 	}
 
 	// Get JSON data.
@@ -31,13 +34,36 @@ export default function() {
 		let json = JSON.parse(String.fromCharCode(...res.body));
 		console.log(json.sequenceNumber);
 	} catch (e) {
-		console.log(e);
+		fail(e);
+	}
+
+	// Observe.
+	try {
+		client.observe("/.rpc", 20, (req) => {
+			let json;
+			try {
+				json = JSON.parse(String.fromCharCode(...req.body));
+			} catch (e) {
+				// First message is acknowledgement of
+				// observation.
+				console.log(e);
+				return;
+			}
+			try {
+				console.log(json);
+				client.post("/.rpc/status", "application/json", '{"id": "' + json.id + '", "statusCode": 0, "detail":"ack"}', 10);
+			} catch (e) {
+				fail(e);
+			}
+		});
+	} catch (e) {
+		fail(e);
 	}
 
 	// Close connection.
 	try {
 		client.close();
 	} catch (e) {
-		console.log(e);
+		fail(e);
 	}
 }