CRAN release 0.7.0

Author: shikokuchuo

DESCRIPTION

@@ -1,7 +1,7 @@
 Package: nanonext
 Type: Package
 Title: NNG (Nanomsg Next Gen) Lightweight Messaging Library
-Version: 0.6.0.9700
+Version: 0.7.0
 Description: R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is 
     a socket library providing high-performance scalability protocols,
     implementing a cross-platform standard for messaging and communications.

NEWS.md

@@ -1,6 +1,6 @@
-# nanonext 0.6.0.9700 (0.7.0 release candidate)
+# nanonext 0.7.0
 
-*nanonext 0.7 has focused on optimising the API after completing feature additions and performance enhancements; the API is again expected to remain stable after these changes*
+*nanonext 0.7 implements API optimisations after recent enhancements; the API is again intended to remain stable after these changes*
 
 #### New Features
 
@@ -24,7 +24,7 @@
 
 *Other changes:*
 
-* Integer send/recv (and setopt) arguments implemented in 0.5.3 are now documented and considered part of the API. This is a performance feature that skips matching the character argument value.
+* Integer `send()`/`recv()` arguments for 'mode' and `setopt()` arguments for 'type' implemented in 0.5.3 are now documented and considered part of the API. This is a performance feature that skips matching the character argument value.
 * Fixes bug introduced in 0.6.0 where Aios returning 'errorValues' are not cached with the class, returning only integer values when accessed subsequently.
 * Fixes potential crash when `base64dec()` encounters invalid input data. Error messages have been revised to be more accurate.
 * Fixes the `$` method for 'recvAio' objects for when the object has been stopped using `stop_aio()`.

README.md

@@ -365,7 +365,7 @@ aio
 #> < recvAio >
 #>  - $data for message data
 aio$data |> str()
-#>  num [1:100000000] 1.5473 -1.808 0.0313 -0.8537 -2.4185 ...
+#>  num [1:100000000] -0.994 -1.507 -0.857 -0.88 -0.294 ...
 ```
 
 As `call_aio()` is blocking and will wait for completion, an alternative
@@ -526,11 +526,11 @@ ncurl("https://httpbin.org/headers")
 #>   [1] 7b 0a 20 20 22 68 65 61 64 65 72 73 22 3a 20 7b 0a 20 20 20 20 22 48 6f 73
 #>  [26] 74 22 3a 20 22 68 74 74 70 62 69 6e 2e 6f 72 67 22 2c 20 0a 20 20 20 20 22
 #>  [51] 58 2d 41 6d 7a 6e 2d 54 72 61 63 65 2d 49 64 22 3a 20 22 52 6f 6f 74 3d 31
-#>  [76] 2d 36 33 36 35 34 63 38 31 2d 34 63 38 33 63 36 37 64 37 38 36 35 65 66 32
-#> [101] 35 32 61 65 38 61 35 38 30 22 0a 20 20 7d 0a 7d 0a
+#>  [76] 2d 36 33 36 38 64 33 39 34 2d 36 30 39 61 32 32 61 35 33 36 35 63 31 31 62
+#> [101] 36 34 38 35 30 65 64 34 65 22 0a 20 20 7d 0a 7d 0a
 #> 
 #> $data
-#> [1] "{\n  \"headers\": {\n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-63654c81-4c83c67d7865ef252ae8a580\"\n  }\n}\n"
+#> [1] "{\n  \"headers\": {\n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-6368d394-609a22a5365c11b64850ed4e\"\n  }\n}\n"
 ```
 
 For advanced use, supports additional HTTP methods such as POST or PUT.
@@ -551,13 +551,13 @@ res
 
 call_aio(res)$headers
 #> $Date
-#> [1] "Fri, 04 Nov 2022 17:31:45 GMT"
+#> [1] "Mon, 07 Nov 2022 09:44:52 GMT"
 #> 
 #> $Server
 #> [1] "gunicorn/19.9.0"
 
 res$data
-#> [1] "{\n  \"args\": {}, \n  \"data\": \"{\\\"key\\\": \\\"value\\\"}\", \n  \"files\": {}, \n  \"form\": {}, \n  \"headers\": {\n    \"Authorization\": \"Bearer APIKEY\", \n    \"Content-Length\": \"16\", \n    \"Content-Type\": \"application/json\", \n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-63654c81-75d995a77f18b2cf33ed5448\"\n  }, \n  \"json\": {\n    \"key\": \"value\"\n  }, \n  \"origin\": \"213.86.169.34\", \n  \"url\": \"http://httpbin.org/post\"\n}\n"
+#> [1] "{\n  \"args\": {}, \n  \"data\": \"{\\\"key\\\": \\\"value\\\"}\", \n  \"files\": {}, \n  \"form\": {}, \n  \"headers\": {\n    \"Authorization\": \"Bearer APIKEY\", \n    \"Content-Length\": \"16\", \n    \"Content-Type\": \"application/json\", \n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-6368d394-3a93bcc6609ccb4b6f98b635\"\n  }, \n  \"json\": {\n    \"key\": \"value\"\n  }, \n  \"origin\": \"79.173.129.2\", \n  \"url\": \"http://httpbin.org/post\"\n}\n"
 ```
 
 In this respect, it may be used as a performant and lightweight method
@@ -599,10 +599,10 @@ s |> send('{"action": "subscribe", "symbols": "EURUSD"}')
 #> [1] 0
 
 s |> recv()
-#> [1] "{\"s\":\"EURUSD\",\"a\":0.99199,\"b\":0.99192,\"dc\":\"1.7208\",\"dd\":\"0.0171\",\"ppms\":false,\"t\":1667583106000}"
+#> [1] "{\"s\":\"EURUSD\",\"a\":0.99892,\"b\":0.99885,\"dc\":\"0.6117\",\"dd\":\"0.0061\",\"ppms\":false,\"t\":1667814293000}"
 
 s |> recv()
-#> [1] "{\"s\":\"EURUSD\",\"a\":0.99198,\"b\":0.99196,\"dd\":\"0.0171\",\"dc\":\"1.7198\",\"ppms\":false,\"t\":1667583106000}"
+#> [1] "{\"s\":\"EURUSD\",\"a\":0.99891,\"b\":0.99884,\"dc\":\"0.6107\",\"dd\":\"0.0061\",\"ppms\":false,\"t\":1667814293000}"
 
 close(s)
 ```

src/aio.c

@@ -135,38 +135,38 @@ static void haio_finalizer(SEXP xptr) {
 
 }
 
-static SEXP mk_error_saio(const int xc, SEXP env) {
+static SEXP mk_error_saio(const int xc, SEXP clo) {
 
   SEXP err = PROTECT(Rf_ScalarInteger(xc));
   SET_ATTRIB(err, nano_error);
   SET_OBJECT(err, 1);
-  Rf_defineVar(nano_ResultSymbol, err, ENCLOS(env));
+  Rf_defineVar(nano_ResultSymbol, err, clo);
   UNPROTECT(1);
   return err;
 
 }
 
-static SEXP mk_error_raio(const int xc, SEXP env) {
+static SEXP mk_error_raio(const int xc, SEXP clo) {
 
   SEXP err = PROTECT(Rf_ScalarInteger(xc));
   SET_ATTRIB(err, nano_error);
   SET_OBJECT(err, 1);
-  Rf_defineVar(nano_RawSymbol, err, ENCLOS(env));
-  Rf_defineVar(nano_DataSymbol, err, ENCLOS(env));
+  Rf_defineVar(nano_RawSymbol, err, clo);
+  Rf_defineVar(nano_DataSymbol, err, clo);
   UNPROTECT(1);
   return err;
 
 }
 
-static SEXP mk_error_haio(const int xc, SEXP env) {
+static SEXP mk_error_haio(const int xc, SEXP clo) {
 
   SEXP err = PROTECT(Rf_ScalarInteger(xc));
   SET_ATTRIB(err, nano_error);
   SET_OBJECT(err, 1);
-  Rf_defineVar(nano_StatusSymbol, err, ENCLOS(env));
-  Rf_defineVar(nano_IdSymbol, err, ENCLOS(env));
-  Rf_defineVar(nano_RawSymbol, err, ENCLOS(env));
-  Rf_defineVar(nano_ProtocolSymbol, err, ENCLOS(env));
+  Rf_defineVar(nano_StatusSymbol, err, clo);
+  Rf_defineVar(nano_IdSymbol, err, clo);
+  Rf_defineVar(nano_RawSymbol, err, clo);
+  Rf_defineVar(nano_ProtocolSymbol, err, clo);
   UNPROTECT(1);
   return err;
 
@@ -205,7 +205,7 @@ SEXP rnng_aio_result(SEXP env) {
     return nano_unresolved;
 
   if (aiop->result)
-    return mk_error_saio(aiop->result, env);
+    return mk_error_saio(aiop->result, ENCLOS(env));
 
   Rf_defineVar(nano_ResultSymbol, nano_success, ENCLOS(env));
   return nano_success;
@@ -230,7 +230,7 @@ SEXP rnng_aio_get_msgraw(SEXP env) {
     return nano_unresolved;
 
   if (raio->result)
-    return mk_error_raio(raio->result, env);
+    return mk_error_raio(raio->result, ENCLOS(env));
 
   SEXP out;
   const int mod = -raio->mode, kpr = 1;
@@ -274,7 +274,7 @@ SEXP rnng_aio_get_msgdata(SEXP env) {
     return nano_unresolved;
 
   if (raio->result)
-    return mk_error_raio(raio->result, env);
+    return mk_error_raio(raio->result, ENCLOS(env));
 
   SEXP out;
   const int kpr = raio->mode > 0 ? 0 : 1, mod = kpr ? -raio->mode : raio->mode;
@@ -810,7 +810,7 @@ SEXP rnng_aio_http(SEXP env, SEXP response, SEXP which) {
     return nano_unresolved;
 
   if (haio->result)
-    return mk_error_haio(haio->result, env);
+    return mk_error_haio(haio->result, ENCLOS(env));
 
   void *dat;
   size_t sz;