Initial commit

Author: jeikabu

Cargo.toml

@@ -0,0 +1,32 @@
+[package]
+name = "runng-sys"
+version = "1.1.1-rc.2"
+authors = ["Jake W <[email protected]>"]
+
+description = "Bindings to nng (Nanomsg-Next-Generation) aka Nanomsg2"
+keywords = ["nng", "nanomsg", "zeromq"]
+categories = ["network-programming", "external-ffi-bindings", "os"]
+license = "MIT"
+repository = "https://github.com/jeikabu/runng"
+readme = "README.md"
+edition = "2018"
+
+[badges]
+appveyor = { repository = "jake-ruyi/runng", branch = "master", service = "github" }
+travis-ci = { repository = "jeikabu/runng", branch = "master" }
+
+[features]
+default = ["stats"]
+# Use ninja for cmake generator
+ninja = []
+# Enable NNG stats
+stats = []
+# Enable TLS (requires mbedTLS)
+tls = []
+
+[build-dependencies]
+cmake = "0.1"
+bindgen = "0.40"
+
+[package.metadata.docs.rs]
+all-features = false

README.md

@@ -0,0 +1,60 @@
+
+# runng-sys
+
+Rust FFI bindings to [NNG](https://github.com/nanomsg/nng).
+
+## Usage
+
+Version of this crate tracks NNG: `<NNG_version>-rc.<crate_version>` (e.g. `1.1.1-rc.2`).
+
+To use the __latest crate__ for the most recent __stable version of NNG__ (1.1.1), in `Cargo.toml`:
+```toml
+runng-sys = "1.1.1-rc"
+```
+
+For a more ergonomic API to NNG see [runng](https://crates.io/crates/runng).
+
+## Examples
+```rust
+use runng_sys::*;
+use std::ffi::CString;
+
+#[test]
+fn it_works() {
+    unsafe {
+        let url = CString::new("inproc://test").unwrap();
+        let url = url.as_bytes_with_nul().as_ptr() as *const i8;
+
+        // Reply socket
+        let mut rep_socket = nng_socket { id: 0 };
+        assert_eq!(0, nng_rep0_open(&mut rep_socket));
+        assert_eq!(0, nng_listen(rep_socket, url, std::ptr::null_mut(), 0));
+
+        // Request socket
+        let mut req_socket = nng_socket { id: 0 };
+        assert_eq!(0, nng_req0_open(&mut req_socket));
+        assert_eq!(0, nng_dial(req_socket, url, std::ptr::null_mut(), 0));
+
+        // Send message
+        let mut req_msg: *mut nng_msg = std::ptr::null_mut();
+        assert_eq!(0, nng_msg_alloc(&mut req_msg, 0));
+        // Add a value to the body of the message
+        let val = 0x12345678;
+        assert_eq!(0, nng_msg_append_u32(req_msg, val));
+        assert_eq!(0, nng_sendmsg(req_socket, req_msg, 0));
+
+        // Receive it
+        let mut recv_msg: *mut nng_msg = std::ptr::null_mut();
+        assert_eq!(0, nng_recvmsg(rep_socket, &mut recv_msg, 0));
+        // Remove our value from the body of the received message
+        let mut recv_val: u32 = 0;
+        assert_eq!(0, nng_msg_trim_u32(recv_msg, &mut recv_val));
+        assert_eq!(val, recv_val);
+        // Can't do this because nng uses network order (big-endian)
+        //assert_eq!(val, *(nng_msg_body(recv_msg) as *const u32));
+
+        nng_close(req_socket);
+        nng_close(rep_socket);
+    }
+}
+```

build.rs

@@ -0,0 +1,46 @@
+use cmake::Config;
+use std::{env, path::PathBuf};
+
+fn main() {
+    // Compile-time features
+    let generator = if cfg!(feature = "ninja") {
+        "Ninja"
+    } else {
+        "Unix Makefiles"
+    };
+    let stats = if cfg!(feature = "stats") { "ON" } else { "OFF" };
+    let tls = if cfg!(feature = "tls") { "ON" } else { "OFF" };
+
+    // Run cmake to build nng
+    let dst = Config::new("nng")
+        .generator(generator)
+        .define("CMAKE_BUILD_TYPE", "Release")
+        .define("NNG_TESTS", "OFF")
+        .define("NNG_TOOLS", "OFF")
+        .define("NNG_ENABLE_STATS", stats)
+        .define("NNG_ENABLE_TLS", tls)
+        .build();
+
+    // Check output of `cargo build --verbose`, should see something like:
+    // -L native=/path/runng/target/debug/build/runng-sys-abc1234/out
+    // That contains output from cmake
+    println!(
+        "cargo:rustc-link-search=native={}",
+        dst.join("lib").display()
+    );
+    // Tell rustc to use nng static library
+    println!("cargo:rustc-link-lib=static=nng");
+
+    // https://rust-lang-nursery.github.io/rust-bindgen
+    // https://docs.rs/bindgen
+    let bindings = bindgen::Builder::default()
+        .header("wrapper.h")
+        // This is needed if use `#include <nng.h>` instead of `#include "path/nng.h"`
+        //.clang_arg("-Inng/src/")
+        .generate()
+        .expect("Unable to generate bindings");
+    let out_path = PathBuf::from(env::var("OUT_DIR").unwrap());
+    bindings
+        .write_to_file(out_path.join("bindings.rs"))
+        .expect("Couldn't write bindings");
+}

nng

@@ -0,0 +1 @@
+Subproject commit 8a9fd805d96201c780610b765f9e6dd9f2eda642

src/lib.rs

@@ -0,0 +1,9 @@
+// Suppress the flurry of warnings caused by using "C" naming conventions
+#![allow(non_upper_case_globals)]
+#![allow(non_camel_case_types)]
+#![allow(non_snake_case)]
+// Disable clippy since this is all bindgen generated code
+#![allow(clippy::all)]
+
+// This matches bindgen::Builder output
+include!(concat!(env!("OUT_DIR"), "/bindings.rs"));

tests/tests.rs

@@ -0,0 +1,46 @@
+#[cfg(test)]
+mod tests {
+
+    use runng_sys::*;
+    use std::ffi::CString;
+
+    #[test]
+    fn it_works() {
+        unsafe {
+            let url = CString::new("inproc://test").unwrap();
+            let url = url.as_bytes_with_nul().as_ptr() as *const i8;
+
+            // Reply socket
+            let mut rep_socket = nng_socket { id: 0 };
+            assert_eq!(0, nng_rep0_open(&mut rep_socket));
+            assert_eq!(0, nng_listen(rep_socket, url, std::ptr::null_mut(), 0));
+
+            // Request socket
+            let mut req_socket = nng_socket { id: 0 };
+            assert_eq!(0, nng_req0_open(&mut req_socket));
+            assert_eq!(0, nng_dial(req_socket, url, std::ptr::null_mut(), 0));
+
+            // Send message
+            let mut req_msg: *mut nng_msg = std::ptr::null_mut();
+            assert_eq!(0, nng_msg_alloc(&mut req_msg, 0));
+            // Add a value to the body of the message
+            let val = 0x12345678;
+            assert_eq!(0, nng_msg_append_u32(req_msg, val));
+            assert_eq!(0, nng_sendmsg(req_socket, req_msg, 0));
+
+            // Receive it
+            let mut recv_msg: *mut nng_msg = std::ptr::null_mut();
+            assert_eq!(0, nng_recvmsg(rep_socket, &mut recv_msg, 0));
+            // Remove our value from the body of the received message
+            let mut recv_val: u32 = 0;
+            assert_eq!(0, nng_msg_trim_u32(recv_msg, &mut recv_val));
+            assert_eq!(val, recv_val);
+            // Can't do this because nng uses network order (big-endian)
+            //assert_eq!(val, *(nng_msg_body(recv_msg) as *const u32));
+
+            nng_close(req_socket);
+            nng_close(rep_socket);
+        }
+    }
+
+}

wrapper.h

@@ -0,0 +1,22 @@
+#include "nng/src/nng.h"
+
+// protocols
+#include "nng/src/protocol/bus0/bus.h"
+#include "nng/src/protocol/pair0/pair.h"
+#include "nng/src/protocol/pair1/pair.h"
+#include "nng/src/protocol/pipeline0/pull.h"
+#include "nng/src/protocol/pipeline0/push.h"
+#include "nng/src/protocol/pubsub0/pub.h"
+#include "nng/src/protocol/pubsub0/sub.h"
+#include "nng/src/protocol/reqrep0/rep.h"
+#include "nng/src/protocol/reqrep0/req.h"
+#include "nng/src/protocol/survey0/respond.h"
+#include "nng/src/protocol/survey0/survey.h"
+
+// transports
+#include "nng/src/transport/inproc/inproc.h"
+#include "nng/src/transport/ipc/ipc.h"
+#include "nng/src/transport/tcp/tcp.h"
+#include "nng/src/transport/tls/tls.h"
+#include "nng/src/transport/ws/websocket.h"
+#include "nng/src/transport/zerotier/zerotier.h"