update CI

Author: shikokuchuo

.github/workflows/check-standard.yaml

@@ -45,3 +45,5 @@ jobs:
           needs: check
 
       - uses: r-lib/actions/check-r-package@v2
+        with:
+          upload-snapshots: true

.github/workflows/test-coverage.yaml

@@ -0,0 +1,31 @@
+# Workflow derived from https://github.com/r-lib/actions/tree/v2/examples
+# Need help debugging build failures? Start at https://github.com/r-lib/actions#where-to-find-help
+on:
+  push:
+    branches: [main, master]
+  pull_request:
+    branches: [main, master]
+
+name: test-coverage
+
+jobs:
+  test-coverage:
+    runs-on: ubuntu-latest
+    env:
+      GITHUB_PAT: ${{ secrets.GITHUB_TOKEN }}
+
+    steps:
+      - uses: actions/checkout@v2
+
+      - uses: r-lib/actions/setup-r@v2
+        with:
+          use-public-rspm: true
+
+      - uses: r-lib/actions/setup-r-dependencies@v2
+        with:
+          extra-packages: any::covr
+          needs: coverage
+
+      - name: Test coverage
+        run: covr::codecov(quiet = FALSE)
+        shell: Rscript {0}

README.Rmd

@@ -19,6 +19,7 @@ knitr::opts_chunk$set(
 [![CRAN status](https://www.r-pkg.org/badges/version/nanonext?color=112d4e)](https://CRAN.R-project.org/package=nanonext)
 [![nanonext status badge](https://shikokuchuo.r-universe.dev/badges/nanonext?color=3f72af)](https://shikokuchuo.r-universe.dev) 
 [![R-CMD-check](https://github.com/shikokuchuo/nanonext/workflows/R-CMD-check/badge.svg)](https://github.com/shikokuchuo/nanonext/actions)
+[![Codecov test coverage](https://codecov.io/gh/shikokuchuo/nanonext/branch/main/graph/badge.svg)](https://app.codecov.io/gh/shikokuchuo/nanonext)
 <!-- badges: end -->
 
 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. Serves as a concurrency framework for building distributed applications, utilising 'Aio' objects which automatically resolve upon completion of asynchronous operations.

README.md

@@ -10,6 +10,8 @@ status](https://www.r-pkg.org/badges/version/nanonext?color=112d4e)](https://CRA
 [![nanonext status
 badge](https://shikokuchuo.r-universe.dev/badges/nanonext?color=3f72af)](https://shikokuchuo.r-universe.dev)
 [![R-CMD-check](https://github.com/shikokuchuo/nanonext/workflows/R-CMD-check/badge.svg)](https://github.com/shikokuchuo/nanonext/actions)
+[![Codecov test
+coverage](https://codecov.io/gh/shikokuchuo/nanonext/branch/main/graph/badge.svg)](https://app.codecov.io/gh/shikokuchuo/nanonext)
 <!-- badges: end -->
 
 R binding for NNG (Nanomsg Next Gen), a successor to ZeroMQ. NNG is a
@@ -377,7 +379,7 @@ aio
 #> < recvAio >
 #>  - $data for message data
 aio$data |> str()
-#>  num [1:100000000] -0.154 -0.281 -1.865 0.332 2.625 ...
+#>  num [1:100000000] -0.597 -0.351 -0.984 1.93 1.393 ...
 ```
 
 As `call_aio()` is blocking and will wait for completion, an alternative
@@ -514,11 +516,11 @@ ncurl("http://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 32 36 33 32 39 65 32 2d 34 61 64 37 64 36 33 62 35 64 33 62 30 65 63
-#> [101] 62 31 38 63 66 38 32 31 38 22 0a 20 20 7d 0a 7d 0a
+#>  [76] 2d 36 32 36 35 31 34 37 38 2d 31 38 64 62 65 31 36 38 34 32 62 63 62 36 62
+#> [101] 63 33 30 36 61 37 61 63 33 22 0a 20 20 7d 0a 7d 0a
 #> 
 #> $data
-#> [1] "{\n  \"headers\": {\n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-626329e2-4ad7d63b5d3b0ecb18cf8218\"\n  }\n}\n"
+#> [1] "{\n  \"headers\": {\n    \"Host\": \"httpbin.org\", \n    \"X-Amzn-Trace-Id\": \"Root=1-62651478-18dbe16842bcb6bc306a7ac3\"\n  }\n}\n"
 ```
 
 For advanced use, supports additional HTTP methods such as POST or PUT.
@@ -533,7 +535,7 @@ res
 #>  - $raw for raw message
 
 call_aio(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-626329e3-3ad612de0091f2db61bb42eb\"\n  }, \n  \"json\": {\n    \"key\": \"value\"\n  }, \n  \"origin\": \"78.145.225.121\", \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-62651478-224f907c244b4b5053cfdac3\"\n  }, \n  \"json\": {\n    \"key\": \"value\"\n  }, \n  \"origin\": \"78.145.225.121\", \n  \"url\": \"http://httpbin.org/post\"\n}\n"
 ```
 
 In this respect, it may be used as a performant and lightweight method

src/core.c

@@ -58,7 +58,7 @@ SEXP nano_encode(SEXP object) {
       memcpy(RAW(out), LOGICAL(object), sz);
       break;
     case CPLXSXP:
-      sz = xlen * sizeof(double) * 2;
+      sz = xlen * (sizeof(double) + sizeof(double));
       out = Rf_allocVector(RAWSXP, sz);
       memcpy(RAW(out), COMPLEX(object), sz);
       break;
@@ -130,7 +130,7 @@ SEXP nano_decode(unsigned char *buf, const size_t sz, const int mod, const int k
   } else {
     switch (mod) {
     case 3:
-      data = Rf_allocVector(CPLXSXP, sz / (sizeof(double) * 2));
+      data = Rf_allocVector(CPLXSXP, sz / (sizeof(double) + sizeof(double)));
       memcpy(COMPLEX(data), buf, sz);
       break;
     case 4:

tests/tests.R

@@ -38,6 +38,8 @@ nanotestwn(n$send(data.frame(), block = FALSE, echo = FALSE))
 nanotestwn(n1$recv(block = FALSE))
 nanotestwn(n1$send("test", mode = "raw", block = 500, echo = FALSE))
 nanotestwn(n$recv("character", block = 500))
+nanotestwn(n1$send(c(1L, 0L, 0L), mode = "raw"))
+nanotestwn(n$recv("integer", keep.raw = FALSE))
 saio <- n$send_aio(data.frame(), timeout = 500)
 nanotest(identical(is_aio(saio), TRUE))
 nanotest(identical(is_nano(saio), FALSE))
@@ -87,8 +89,17 @@ nanotest(ctx$protocol == "req")
 nanotest(setopt(ctx, "ms", "send-timeout", 1000) == 0L)
 nanotestwn(send_aio(ctx, data.frame(), timeout = 500))
 nanotestwn(recv_aio(ctx1, timeout = 500, keep.raw = FALSE))
-nanotestwn(send(ctx, "context test", mode ="raw", block = 500, echo = FALSE))
-nanotestwn(recv(ctx1, mode = "character", block = 100))
+nanotestwn(send(ctx, "context test", mode ="raw", block = 300, echo = FALSE))
+nanotestwn(recv(ctx1, mode = "character", block = 300))
+nanotestwn(send(ctx, data.frame(), block = 400))
+msg <- recv_aio(ctx1, mode = "serial", timeout = 400, keep.raw = FALSE)
+nanotest(is.logical(unresolved(msg)))
+nanotestn(call_aio(msg)$data)
+nanotest(unresolved(msg) == FALSE)
+nanotestwn(send(ctx, c(TRUE, FALSE, TRUE), block = 500))
+msg <- recv_aio(ctx1, mode = "logical", timeout = 500)
+nanotestn(call_aio(msg)$raw)
+nanotestwn(request(ctx, data.frame(), recv_mode = "complex", timeout = 100))
 nanotest(close(ctx) == 0L)
 nanotestw(close(ctx) > 0L)
 nanotest(ctx$state == "closed")