diff --git a/.pre-commit-config.yaml b/.pre-commit-config.yaml
index d806203c..8206bbd7 100644
--- a/.pre-commit-config.yaml
+++ b/.pre-commit-config.yaml
@@ -17,8 +17,11 @@ repos:
   # Toml formatting,
   # same as vscode extension: https://marketplace.visualstudio.com/items?itemName=tamasfe.even-better-toml
   # Configure from ./taplo.toml
-  - repo: https://github.com/ComPWA/mirrors-taplo
-    rev: v0.8.1
+  # NOTE: temporary source whilst taplo sort out their internal packaging, should switch to proper in the end, see:
+  # https://github.com/tamasfe/taplo/pull/549
+  # https://github.com/tamasfe/taplo/issues/535
+  - repo: https://github.com/redeboer/taplo-pre-commit
+    rev: v0.9.1rc1
     hooks:
       - id: taplo
         args: ["format", "--config", "./taplo.toml"]
diff --git a/.zetch.lock b/.zetch.lock
index 03f668c6..eed55fbe 100644
--- a/.zetch.lock
+++ b/.zetch.lock
@@ -1,23 +1,24 @@
 {
   "version": "0.0.10",
   "files": {
-    "py_rust/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
-    "CODE_OF_CONDUCT.zetch.md": "bf106326ffc75f5167cfde27c997c77c6b97c843a9e392b564355d0e70e50b97",
-    "LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
-    "docs/index.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
+    "rust/pkg/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
     "docs/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
-    "js/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
-    "rust/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
-    "docs/CONTRIBUTING.zetch.md": "bace46dc064746b54cf472eba960d934d705c2f83120b865a4b47032ff1552c5",
-    "opencollector.yaml.zetch": "27c7cbc36a0a6d0eb0af8bece63a6d170bfabe098f26ae0c82e5d671441418ad",
-    "py_rust/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
     "docs/CODE_OF_CONDUCT.zetch.md": "bf106326ffc75f5167cfde27c997c77c6b97c843a9e392b564355d0e70e50b97",
-    "CONTRIBUTING.zetch.md": "bace46dc064746b54cf472eba960d934d705c2f83120b865a4b47032ff1552c5",
+    "py_rust/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
+    "py_rust/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
+    "js/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
     "py/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
-    "rust/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
+    "CODE_OF_CONDUCT.zetch.md": "bf106326ffc75f5167cfde27c997c77c6b97c843a9e392b564355d0e70e50b97",
+    "LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
+    "js/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
     "README.zetch.md": "3c020cafb75c2a7069a565491d6244fd342d1693b9a1f15a2251bdee2db63054",
     "js/tsconfig.zetch.json": "fb5d57b825bb3c2f6dd4254bf939f2444e52946622a7f93b91e3acb75876ebbc",
-    "js/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
-    "py/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b"
+    "py/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b",
+    "docs/index.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
+    "rust/README.zetch.md": "a9d4cc05a87de4f436d4f576c315d171a510b07307df3678420517ff0a2881b1",
+    "opencollector.yaml.zetch": "33aa6a1e9e386b9e01c3d4c010b70260654c06850fb1433afb15545bd85f2f2d",
+    "CONTRIBUTING.zetch.md": "bace46dc064746b54cf472eba960d934d705c2f83120b865a4b47032ff1552c5",
+    "docs/CONTRIBUTING.zetch.md": "bace46dc064746b54cf472eba960d934d705c2f83120b865a4b47032ff1552c5",
+    "rust/LICENSE.zetch.md": "d2c12e539d357957b950a54a5477c3a9f87bd2b3ee707be7a4db7adaf5aacc2b"
   }
 }
\ No newline at end of file
diff --git a/js/bitbazaar/log/log.test.ts b/js/bitbazaar/log/log.test.ts
index a28cc5b2..13f89636 100644
--- a/js/bitbazaar/log/log.test.ts
+++ b/js/bitbazaar/log/log.test.ts
@@ -31,11 +31,22 @@ describe("Logging/Tracing", () => {
                     service_version: "1.0.0",
                 },
             });
+
             LOG.debug("DEBUG");
             LOG.info("INFO");
             LOG.warn("WARN");
             LOG.error("ERROR");
             expect(logs).toEqual(expected_enabled);
+
+            // Empty:
+            logs.length = 0;
+
+            // All console logs should have been overridden to also use the global logger:
+            console.debug("DEBUG");
+            console.info("INFO");
+            console.warn("WARN");
+            console.error("ERROR");
+            expect(logs).toEqual(expected_enabled);
         },
     );
     it("Logs: oltp", async () => {
diff --git a/js/bitbazaar/log/log.ts b/js/bitbazaar/log/log.ts
index 565e6619..f326973f 100644
--- a/js/bitbazaar/log/log.ts
+++ b/js/bitbazaar/log/log.ts
@@ -45,6 +45,11 @@ interface OltpArgs {
     service_version: string; // E.g. "1.0.0"
 }
 
+type ConsoleFns = Record<
+    "log" | "debug" | "info" | "warn" | "error",
+    (message: string, ...optionalParams: any[]) => void
+>;
+
 class GlobalLog {
     loggerProvider: LoggerProvider;
     logger: Logger;
@@ -55,6 +60,9 @@ class GlobalLog {
     console: ConsoleArgs | null;
     oltp: OltpArgs;
 
+    /// We override global console functions to do filtering and emit to oltp, need to keep access to the inner ones:
+    orig_console_fns: ConsoleFns;
+
     /**
      * Get a new Meter instance to record metrics with.
      *
@@ -131,22 +139,22 @@ class GlobalLog {
             switch (this.console.level_from) {
                 case "DEBUG": {
                     emit = true;
-                    emitter = console.debug;
+                    emitter = this.orig_console_fns.debug;
                     break;
                 }
                 case "INFO": {
                     emit = severityText !== "DEBUG";
-                    emitter = console.info;
+                    emitter = this.orig_console_fns.info;
                     break;
                 }
                 case "WARN": {
                     emit = severityText === "WARN" || severityText === "ERROR";
-                    emitter = console.warn;
+                    emitter = this.orig_console_fns.warn;
                     break;
                 }
                 case "ERROR": {
                     emit = severityText === "ERROR";
-                    emitter = console.error;
+                    emitter = this.orig_console_fns.error;
                     break;
                 }
             }
@@ -188,6 +196,21 @@ class GlobalLog {
         }
     }
 
+    _set_console_fns() {
+        this.orig_console_fns = {
+            log: console.log,
+            debug: console.debug,
+            info: console.info,
+            warn: console.warn,
+            error: console.error,
+        };
+        console.log = (msg, ...attrs) => this.info(msg, ...attrs);
+        console.debug = (msg, ...attrs) => this.debug(msg, ...attrs);
+        console.info = (msg, ...attrs) => this.info(msg, ...attrs);
+        console.warn = (msg, ...attrs) => this.warn(msg, ...attrs);
+        console.error = (msg, ...attrs) => this.error(msg, ...attrs);
+    }
+
     /** Create the global logger, must setup oltp (http), console can be optionally setup and will just print logs. */
     constructor({
         otlp,
@@ -198,6 +221,8 @@ class GlobalLog {
     }) {
         this.console = console ? console : null;
         this.oltp = otlp;
+        // Store original console fns and override with those in this global logger:
+        this._set_console_fns();
 
         const resource = new Resource({
             [SemanticResourceAttributes.SERVICE_NAME]: otlp.service_name,
diff --git a/js/bunfig.toml b/js/bunfig.toml
index 89af50d4..2ea93cd0 100644
--- a/js/bunfig.toml
+++ b/js/bunfig.toml
@@ -4,4 +4,4 @@ telemetry = false
 preload = ["./tests/happydom.ts", "./tests/setupTests.ts"]
 coverage = true
 coverageSkipTestFiles = true
-coverageThreshold = 0.95
+coverageThreshold = 0.94
diff --git a/opencollector.yaml b/opencollector.yaml
index b47ed42f..7ee2e638 100644
--- a/opencollector.yaml
+++ b/opencollector.yaml
@@ -4,6 +4,11 @@ receivers:
     protocols:
       grpc:
         endpoint: localhost:4317
+      http:
+        endpoint: localhost:4318
+        cors:
+          allowed_origins:
+            - "*"
 
 processors:
   # Prevent memory usage from exceeding 40% of the total available RAM,
@@ -27,7 +32,7 @@ exporters:
       stream-name: default
   # Writes all opentelemetry logs, traces, metrics to a file, useful for testing:
   file/debug_file_writing:
-    path: /home/runner/work/bitbazaar/bitbazaar/logs/otlp_telemetry_out.log
+    path: /Users/zak/z/code/bitbazaar/logs/otlp_telemetry_out.log
     rotation:
       max_megabytes: 10
       max_days: 3
diff --git a/opencollector.yaml.zetch b/opencollector.yaml.zetch
index 18fec7a9..9357b37a 100644
--- a/opencollector.yaml.zetch
+++ b/opencollector.yaml.zetch
@@ -4,6 +4,11 @@ receivers:
     protocols:
       grpc:
         endpoint: localhost:4317
+      http:
+        endpoint: localhost:4318
+        cors:
+          allowed_origins:
+            - "*"
 
 processors:
   # Prevent memory usage from exceeding 40% of the total available RAM,
diff --git a/py_rust/Cargo.lock b/py_rust/Cargo.lock
index 701d3b60..b4dde1a4 100644
--- a/py_rust/Cargo.lock
+++ b/py_rust/Cargo.lock
@@ -217,7 +217,6 @@ name = "bitbazaar_rs"
 version = "0.0.3"
 dependencies = [
  "bitbazaar",
- "colored",
  "error-stack",
  "parking_lot",
  "pyo3",
diff --git a/py_rust/Cargo.toml b/py_rust/Cargo.toml
index ce01ff39..36d2e9a4 100644
--- a/py_rust/Cargo.toml
+++ b/py_rust/Cargo.toml
@@ -14,7 +14,6 @@ path = "src/lib.rs"
 
 # Add your dependencies here
 [dependencies]
-colored = '2'
 tracing = "0.1"
 error-stack = "0.4"
 bitbazaar = { version = '0.0.31', features = ["opentelemetry"] }
diff --git a/py_rust/src/lib.rs b/py_rust/src/lib.rs
index 60cb88ee..f69d209d 100644
--- a/py_rust/src/lib.rs
+++ b/py_rust/src/lib.rs
@@ -1,13 +1,12 @@
 #![warn(clippy::disallowed_types)]
 
-use colored::Colorize;
 use pyo3::prelude::*;
 
 mod utils;
 
 #[pyfunction]
 pub fn hello() -> String {
-    "Hello, World!".cyan().to_string()
+    "Hello, World!".to_string()
 }
 
 /// A Python module implemented in Rust. The name of this function must match
diff --git a/rust/.config/nextest.toml b/rust/.config/nextest.toml
new file mode 100644
index 00000000..a236338b
--- /dev/null
+++ b/rust/.config/nextest.toml
@@ -0,0 +1,120 @@
+[test-groups]
+serial = { max-threads = 1 }
+
+# A lot of the log tests use static variables or read from files for tests, causing conflicts if run in parallel:
+[[profile.default.overrides]]
+filter = 'test(log::)'
+test-group = 'serial'
+
+# <--- DEFAULTS --->
+
+[store]
+# The directory under the workspace root at which nextest-related files are
+# written. Profile-specific storage is currently written to dir/<profile-name>.
+dir = "target/nextest"
+
+# This section defines the default nextest profile. Custom profiles are layered
+# on top of the default profile.
+[profile.default]
+# "retries" defines the number of times a test should be retried. If set to a
+# non-zero value, tests that succeed on a subsequent attempt will be marked as
+# flaky. Can be overridden through the `--retries` option.
+# Examples
+# * retries = 3
+# * retries = { backoff = "fixed", count = 2, delay = "1s" }
+# * retries = { backoff = "exponential", count = 10, delay = "1s", jitter = true, max-delay = "10s" }
+retries = 0
+
+# The number of threads to run tests with. Supported values are either an integer or
+# the string "num-cpus". Can be overridden through the `--test-threads` option.
+test-threads = "num-cpus"
+
+# The number of threads required for each test. This is generally used in overrides to
+# mark certain tests as heavier than others. However, it can also be set as a global parameter.
+threads-required = 1
+
+# Show these test statuses in the output.
+#
+# The possible values this can take are:
+# * none: no output
+# * fail: show failed (including exec-failed) tests
+# * retry: show flaky and retried tests
+# * slow: show slow tests
+# * pass: show passed tests
+# * skip: show skipped tests (most useful for CI)
+# * all: all of the above
+#
+# Each value includes all the values above it; for example, "slow" includes
+# failed and retried tests.
+#
+# Can be overridden through the `--status-level` flag.
+status-level = "pass"
+
+# Similar to status-level, show these test statuses at the end of the run.
+final-status-level = "flaky"
+
+# "failure-output" defines when standard output and standard error for failing tests are produced.
+# Accepted values are
+# * "immediate": output failures as soon as they happen
+# * "final": output failures at the end of the test run
+# * "immediate-final": output failures as soon as they happen and at the end of
+#   the test run; combination of "immediate" and "final"
+# * "never": don't output failures at all
+#
+# For large test suites and CI it is generally useful to use "immediate-final".
+#
+# Can be overridden through the `--failure-output` option.
+failure-output = "immediate"
+
+# "success-output" controls production of standard output and standard error on success. This should
+# generally be set to "never".
+success-output = "never"
+
+# Cancel the test run on the first failure. For CI runs, consider setting this
+# to false.
+fail-fast = true
+
+# Treat a test that takes longer than the configured 'period' as slow, and print a message.
+# See <https://nexte.st/book/slow-tests> for more information.
+#
+# Optional: specify the parameter 'terminate-after' with a non-zero integer,
+# which will cause slow tests to be terminated after the specified number of
+# periods have passed.
+# Example: slow-timeout = { period = "60s", terminate-after = 2 }
+slow-timeout = { period = "60s" }
+
+# Treat a test as leaky if after the process is shut down, standard output and standard error
+# aren't closed within this duration.
+#
+# This usually happens in case of a test that creates a child process and lets it inherit those
+# handles, but doesn't clean the child process up (especially when it fails).
+#
+# See <https://nexte.st/book/leaky-tests> for more information.
+leak-timeout = "100ms"
+
+[profile.default.junit]
+# Output a JUnit report into the given file inside 'store.dir/<profile-name>'.
+# If unspecified, JUnit is not written out.
+
+# path = "junit.xml"
+
+# The name of the top-level "report" element in JUnit report. If aggregating
+# reports across different test runs, it may be useful to provide separate names
+# for each report.
+report-name = "nextest-run"
+
+# Whether standard output and standard error for passing tests should be stored in the JUnit report.
+# Output is stored in the <system-out> and <system-err> elements of the <testcase> element.
+store-success-output = false
+
+# Whether standard output and standard error for failing tests should be stored in the JUnit report.
+# Output is stored in the <system-out> and <system-err> elements of the <testcase> element.
+#
+# Note that if a description can be extracted from the output, it is always stored in the
+# <description> element.
+store-failure-output = true
+
+# This profile is activated if MIRI_SYSROOT is set.
+[profile.default-miri]
+# Miri tests take up a lot of memory, so only run 1 test at a time by default.
+test-threads = 1
diff --git a/rust/Cargo.lock b/rust/Cargo.lock
index 0e11fb9d..8a2252e7 100644
--- a/rust/Cargo.lock
+++ b/rust/Cargo.lock
@@ -43,9 +43,9 @@ dependencies = [
 
 [[package]]
 name = "anstream"
-version = "0.6.11"
+version = "0.6.12"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "6e2e1ebcb11de5c03c67de28a7df593d32191b44939c482e97702baaaa6ab6a5"
+checksum = "96b09b5178381e0874812a9b157f7fe84982617e48f71f4e3235482775e5b540"
 dependencies = [
  "anstyle",
  "anstyle-parse",
@@ -95,6 +95,12 @@ version = "1.0.79"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "080e9890a082662b09c1ad45f567faeeb47f22b5fb23895fbe1e651e718e25ca"
 
+[[package]]
+name = "anymap2"
+version = "0.13.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d301b3b94cb4b2f23d7917810addbbaff90738e0ca2be692bd027e70d7e0330c"
+
 [[package]]
 name = "async-trait"
 version = "0.1.77"
@@ -178,6 +184,15 @@ version = "0.21.7"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "9d297deb1925b89f2ccc13d7635fa0714f12c87adce1c75356b39ca9b7178567"
 
+[[package]]
+name = "bincode"
+version = "1.3.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b1f45e9417d87227c7a56d22e471c6206462cba514c7590c09aff4cf6d1ddcad"
+dependencies = [
+ "serde",
+]
+
 [[package]]
 name = "bitbazaar"
 version = "0.0.33"
@@ -207,7 +222,6 @@ dependencies = [
  "rustc_version",
  "serde",
  "serde_json",
- "serial_test",
  "sha1_smol",
  "strum",
  "tempfile",
@@ -219,6 +233,7 @@ dependencies = [
  "tracing-log",
  "tracing-opentelemetry",
  "tracing-subscriber",
+ "tracing-subscriber-wasm",
  "uuid",
 ]
 
@@ -367,6 +382,16 @@ dependencies = [
  "void",
 ]
 
+[[package]]
+name = "core-foundation"
+version = "0.9.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "91e195e091a93c46f7102ec7818a2aa394e1e1771c3ab4825963fa03e45afb8f"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
 [[package]]
 name = "core-foundation-sys"
 version = "0.8.6"
@@ -410,19 +435,6 @@ dependencies = [
  "winapi",
 ]
 
-[[package]]
-name = "dashmap"
-version = "5.5.3"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "978747c1d849a7d2ee5e8adc0159961c48fb7e5db2f06af6723b80123bb53856"
-dependencies = [
- "cfg-if",
- "hashbrown 0.14.3",
- "lock_api",
- "once_cell",
- "parking_lot_core",
-]
-
 [[package]]
 name = "deadpool"
 version = "0.10.0"
@@ -469,6 +481,15 @@ version = "1.10.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "11157ac094ffbdde99aa67b23417ebdd801842852b500e395a45a9c0aac03e4a"
 
+[[package]]
+name = "encoding_rs"
+version = "0.8.33"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7268b386296a025e474d5140678f75d6de9493ae55a5d709eeb9dd08149945e1"
+dependencies = [
+ "cfg-if",
+]
+
 [[package]]
 name = "equivalent"
 version = "1.0.1"
@@ -640,6 +661,172 @@ version = "0.3.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "d2fabcfbdc87f4758337ca535fb41a6d701b65693ce38287d856d1674551ec9b"
 
+[[package]]
+name = "gloo"
+version = "0.8.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "28999cda5ef6916ffd33fb4a7b87e1de633c47c0dc6d97905fee1cdaa142b94d"
+dependencies = [
+ "gloo-console",
+ "gloo-dialogs",
+ "gloo-events",
+ "gloo-file",
+ "gloo-history",
+ "gloo-net",
+ "gloo-render",
+ "gloo-storage",
+ "gloo-timers",
+ "gloo-utils",
+ "gloo-worker",
+]
+
+[[package]]
+name = "gloo-console"
+version = "0.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "82b7ce3c05debe147233596904981848862b068862e9ec3e34be446077190d3f"
+dependencies = [
+ "gloo-utils",
+ "js-sys",
+ "serde",
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-dialogs"
+version = "0.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "67062364ac72d27f08445a46cab428188e2e224ec9e37efdba48ae8c289002e6"
+dependencies = [
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-events"
+version = "0.1.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "68b107f8abed8105e4182de63845afcc7b69c098b7852a813ea7462a320992fc"
+dependencies = [
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-file"
+version = "0.2.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a8d5564e570a38b43d78bdc063374a0c3098c4f0d64005b12f9bbe87e869b6d7"
+dependencies = [
+ "gloo-events",
+ "js-sys",
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-history"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "85725d90bf0ed47063b3930ef28e863658a7905989e9929a8708aab74a1d5e7f"
+dependencies = [
+ "gloo-events",
+ "gloo-utils",
+ "serde",
+ "serde-wasm-bindgen",
+ "serde_urlencoded",
+ "thiserror",
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-net"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a66b4e3c7d9ed8d315fd6b97c8b1f74a7c6ecbbc2320e65ae7ed38b7068cc620"
+dependencies = [
+ "futures-channel",
+ "futures-core",
+ "futures-sink",
+ "gloo-utils",
+ "http 0.2.11",
+ "js-sys",
+ "pin-project",
+ "serde",
+ "serde_json",
+ "thiserror",
+ "wasm-bindgen",
+ "wasm-bindgen-futures",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-render"
+version = "0.1.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2fd9306aef67cfd4449823aadcd14e3958e0800aa2183955a309112a84ec7764"
+dependencies = [
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-storage"
+version = "0.2.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5d6ab60bf5dbfd6f0ed1f7843da31b41010515c745735c970e821945ca91e480"
+dependencies = [
+ "gloo-utils",
+ "js-sys",
+ "serde",
+ "serde_json",
+ "thiserror",
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-timers"
+version = "0.2.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9b995a66bb87bebce9a0f4a95aed01daca4872c050bfcb21653361c03bc35e5c"
+dependencies = [
+ "js-sys",
+ "wasm-bindgen",
+]
+
+[[package]]
+name = "gloo-utils"
+version = "0.1.7"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "037fcb07216cb3a30f7292bd0176b050b7b9a052ba830ef7d5d65f6dc64ba58e"
+dependencies = [
+ "js-sys",
+ "serde",
+ "serde_json",
+ "wasm-bindgen",
+ "web-sys",
+]
+
+[[package]]
+name = "gloo-worker"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "13471584da78061a28306d1359dd0178d8d6fc1c7c80e5e35d27260346e0516a"
+dependencies = [
+ "anymap2",
+ "bincode",
+ "gloo-console",
+ "gloo-utils",
+ "js-sys",
+ "serde",
+ "wasm-bindgen",
+ "wasm-bindgen-futures",
+ "web-sys",
+]
+
 [[package]]
 name = "h2"
 version = "0.3.24"
@@ -842,6 +1029,12 @@ dependencies = [
  "hashbrown 0.14.3",
 ]
 
+[[package]]
+name = "ipnet"
+version = "2.9.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8f518f335dce6725a761382244631d86cf0ccb2863413590b31338feb467f9c3"
+
 [[package]]
 name = "itertools"
 version = "0.10.5"
@@ -1065,6 +1258,19 @@ dependencies = [
  "tracing-subscriber",
 ]
 
+[[package]]
+name = "opentelemetry-http"
+version = "0.10.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7f51189ce8be654f9b5f7e70e49967ed894e84a06fc35c6c042e64ac1fc5399e"
+dependencies = [
+ "async-trait",
+ "bytes",
+ "http 0.2.11",
+ "opentelemetry",
+ "reqwest",
+]
+
 [[package]]
 name = "opentelemetry-otlp"
 version = "0.14.0"
@@ -1075,10 +1281,12 @@ dependencies = [
  "futures-core",
  "http 0.2.11",
  "opentelemetry",
+ "opentelemetry-http",
  "opentelemetry-proto",
  "opentelemetry-semantic-conventions",
  "opentelemetry_sdk",
  "prost",
+ "reqwest",
  "thiserror",
  "tokio",
  "tonic",
@@ -1374,6 +1582,42 @@ version = "1.9.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "e898588f33fdd5b9420719948f9f2a32c922a246964576f71ba7f24f80610fbc"
 
+[[package]]
+name = "reqwest"
+version = "0.11.24"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c6920094eb85afde5e4a138be3f2de8bbdf28000f0029e72c45025a56b042251"
+dependencies = [
+ "base64",
+ "bytes",
+ "encoding_rs",
+ "futures-core",
+ "futures-util",
+ "h2",
+ "http 0.2.11",
+ "http-body",
+ "hyper",
+ "ipnet",
+ "js-sys",
+ "log",
+ "mime",
+ "once_cell",
+ "percent-encoding",
+ "pin-project-lite",
+ "serde",
+ "serde_json",
+ "serde_urlencoded",
+ "sync_wrapper",
+ "system-configuration",
+ "tokio",
+ "tower-service",
+ "url",
+ "wasm-bindgen",
+ "wasm-bindgen-futures",
+ "web-sys",
+ "winreg",
+]
+
 [[package]]
 name = "rstest"
 version = "0.18.2"
@@ -1464,6 +1708,17 @@ dependencies = [
  "serde_derive",
 ]
 
+[[package]]
+name = "serde-wasm-bindgen"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f3b143e2833c57ab9ad3ea280d21fd34e285a42837aeb0ee301f4f41890fa00e"
+dependencies = [
+ "js-sys",
+ "serde",
+ "wasm-bindgen",
+]
+
 [[package]]
 name = "serde_derive"
 version = "1.0.196"
@@ -1487,28 +1742,15 @@ dependencies = [
 ]
 
 [[package]]
-name = "serial_test"
-version = "2.0.0"
-source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "0e56dd856803e253c8f298af3f4d7eb0ae5e23a737252cd90bb4f3b435033b2d"
-dependencies = [
- "dashmap",
- "futures",
- "lazy_static",
- "log",
- "parking_lot",
- "serial_test_derive",
-]
-
-[[package]]
-name = "serial_test_derive"
-version = "2.0.0"
+name = "serde_urlencoded"
+version = "0.7.1"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "91d129178576168c589c9ec973feedf7d3126c01ac2bf08795109aa35b69fb8f"
+checksum = "d3491c14715ca2294c4d6a88f15e84739788c1d030eed8c110436aafdaa2f3fd"
 dependencies = [
- "proc-macro2",
- "quote",
- "syn 2.0.49",
+ "form_urlencoded",
+ "itoa",
+ "ryu",
+ "serde",
 ]
 
 [[package]]
@@ -1607,6 +1849,27 @@ version = "0.1.2"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "2047c6ded9c721764247e62cd3b03c09ffc529b2ba5b10ec482ae507a4a70160"
 
+[[package]]
+name = "system-configuration"
+version = "0.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ba3a3adc5c275d719af8cb4272ea1c4a6d668a777f37e115f6d11ddbc1c8e0e7"
+dependencies = [
+ "bitflags 1.3.2",
+ "core-foundation",
+ "system-configuration-sys",
+]
+
+[[package]]
+name = "system-configuration-sys"
+version = "0.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a75fb188eb626b924683e3b95e3a48e63551fcfb51949de2f06a9d91dbee93c9"
+dependencies = [
+ "core-foundation-sys",
+ "libc",
+]
+
 [[package]]
 name = "tempfile"
 version = "3.10.0"
@@ -1918,6 +2181,17 @@ dependencies = [
  "tracing-log",
 ]
 
+[[package]]
+name = "tracing-subscriber-wasm"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "79804e80980173c6c8e53d98508eb24a2dbc4ee17a3e8d2ca8e5bad6bf13a898"
+dependencies = [
+ "gloo",
+ "tracing",
+ "tracing-subscriber",
+]
+
 [[package]]
 name = "try-lock"
 version = "0.2.5"
@@ -2035,6 +2309,18 @@ dependencies = [
  "wasm-bindgen-shared",
 ]
 
+[[package]]
+name = "wasm-bindgen-futures"
+version = "0.4.41"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "877b9c3f61ceea0e56331985743b13f3d25c406a7098d45180fb5f09bc19ed97"
+dependencies = [
+ "cfg-if",
+ "js-sys",
+ "wasm-bindgen",
+ "web-sys",
+]
+
 [[package]]
 name = "wasm-bindgen-macro"
 version = "0.2.91"
@@ -2064,6 +2350,16 @@ version = "0.2.91"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "4f186bd2dcf04330886ce82d6f33dd75a7bfcf69ecf5763b89fcde53b6ac9838"
 
+[[package]]
+name = "web-sys"
+version = "0.3.68"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "96565907687f7aceb35bc5fc03770a8a0471d82e479f25832f54a0e3f4b28446"
+dependencies = [
+ "js-sys",
+ "wasm-bindgen",
+]
+
 [[package]]
 name = "web-time"
 version = "0.2.4"
@@ -2277,6 +2573,16 @@ version = "0.52.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "dff9641d1cd4be8d1a070daf9e3773c5f67e78b4d9d42263020c057706765c04"
 
+[[package]]
+name = "winreg"
+version = "0.50.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "524e57b2c537c0f9b1e69f1965311ec12182b4122e45035b1508cd24d2adadb1"
+dependencies = [
+ "cfg-if",
+ "windows-sys 0.48.0",
+]
+
 [[package]]
 name = "wmi"
 version = "0.13.2"
diff --git a/rust/Cargo.toml b/rust/Cargo.toml
index 96b37f4b..6bc426ce 100644
--- a/rust/Cargo.toml
+++ b/rust/Cargo.toml
@@ -8,7 +8,7 @@ license = "MIT"
 
 [lib]
 name = "bitbazaar"
-crate-type = ["lib"]
+crate-type = ["lib", "cdylib"] # cdylib allows things like wasm to compile
 path = "bitbazaar/lib.rs"
 
 [build-dependencies]
@@ -20,8 +20,11 @@ rustc_version = "0.4.0"
 all-features = true
 
 [features]
-cli = ['dep:normpath', 'dep:conch-parser', 'dep:homedir']
-redis = ['dep:deadpool-redis', 'dep:redis', 'dep:sha1_smol']
+log-filter = ["dep:regex"]
+clap = ["dep:clap"]
+timing = ['dep:comfy-table', 'dep:chrono']
+cli = ['dep:normpath', 'dep:conch-parser', 'dep:homedir', 'dep:chrono', 'dep:strum']
+redis = ['dep:deadpool-redis', 'dep:redis', 'dep:sha1_smol', 'dep:serde_json']
 opentelemetry = [
   'dep:tracing-log',
   'dep:opentelemetry-appender-tracing',
@@ -32,26 +35,38 @@ opentelemetry = [
   'dep:opentelemetry-semantic-conventions',
   'dep:http',
 ]
+opentelemetry-grpc = ['opentelemetry', 'opentelemetry-otlp/grpc-tonic']
+opentelemetry-http = [
+  'opentelemetry',
+  'opentelemetry-otlp/http-proto',
+  'opentelemetry-otlp/reqwest-client',
+]
 
 # Add your dependencies here
 [dependencies]
-parking_lot = { version = "0.12", features = ["deadlock_detection", "serde"] }
 tracing = "0.1"
 tracing-core = "0.1"
 error-stack = "0.4"
-chrono = '0.4'
-colored = '2.0'
-comfy-table = '7.1'
-once_cell = '1.18'
-regex = '1.10'
-tracing-appender = '0.2'
+once_cell = '1'
 tracing-subscriber = { version = "0.3", features = ["fmt", "std", "time"] }
-clap = { version = "4.4", features = ["derive", "string"] }
-strum = { version = "0.25", features = ["derive"] }
+parking_lot = { version = "0.12", features = ["deadlock_detection", "serde"] }
+serde = { version = "1", features = ["derive"] }
 time = { version = "0.3", features = ["local-offset"] }
-hostname = "0.3.1"
-serde = { version = "1.0", features = ["derive"] }
-serde_json = { version = "1.0" }
+colored = '2'
+
+# Not in default, but randomly useful in features:
+chrono = { version = '0.4', optional = true }
+strum = { version = "0.25", features = ["derive"], optional = true }
+serde_json = { version = "1.0", optional = true }
+
+# FEAT: log-filter:
+regex = { version = '1', optional = true }
+
+# FEAT: clap:
+clap = { version = "4.4", features = ["derive", "string"], optional = true }
+
+# FEAT: timing:
+comfy-table = { version = "7.1", optional = true }
 
 # FEAT: cli:
 normpath = { version = '1.1', optional = true }
@@ -65,22 +80,32 @@ sha1_smol = { version = "1.0", optional = true }
 
 # FEAT: opentelemetry:
 tracing-log = { version = "0.2", optional = true } # Only needed whilst we're using ot_tracing_bridge.rs
+http = { version = "1.0", optional = true }
+tracing-opentelemetry = { version = "0.22", optional = true }
 opentelemetry-appender-tracing = { version = "0.2.0", optional = true }
 opentelemetry_sdk = { version = "0.21", features = ["rt-tokio"], optional = true }
-tracing-opentelemetry = { version = "0.22", optional = true }
 opentelemetry = { version = "0.21", default-features = false, features = [
   "trace",
 ], optional = true }
-opentelemetry-otlp = { version = "0.14", features = ["logs", "trace", "metrics"], optional = true }
+opentelemetry-otlp = { version = "0.14", default-features = false, features = [
+  "logs",
+  "trace",
+  "metrics",
+], optional = true }
 opentelemetry-semantic-conventions = { version = "0.13.0", optional = true }
-http = { version = "1.0", optional = true }
+
+[target.'cfg(target_arch = "wasm32")'.dependencies]
+tracing-subscriber-wasm = "0.1.0"
+
+[target.'cfg(not(target_arch = "wasm32"))'.dependencies]
+tracing-appender = '0.2' # This includes threading (non-blocking stuff that can't be used in wasm)
+hostname = "0.3.1"
 
 [dev-dependencies]
 rstest = "0.18"
 portpicker = '0.1.1'
-serial_test = '2.0'
 tempfile = '3.8'
-tokio = { version = '1.35', features = ["rt-multi-thread"] }
+tokio = { version = '1.35', features = ["rt-multi-thread", "macros"] }
 uuid = { version = "1.6", features = ["v4"] }
 
 [profile.profiler]
diff --git a/rust/bitbazaar/errors/mod.rs b/rust/bitbazaar/errors/mod.rs
index 74a40e06..8f331378 100644
--- a/rust/bitbazaar/errors/mod.rs
+++ b/rust/bitbazaar/errors/mod.rs
@@ -4,8 +4,11 @@ mod macros;
 pub use any::AnyErr;
 
 pub(crate) mod prelude {
+    #[allow(unused_imports)]
     pub use error_stack::{bail, report, Result, ResultExt};
 
+    #[allow(unused_imports)]
     pub use super::any::AnyErr;
+    #[allow(unused_imports)]
     pub use crate::anyerr;
 }
diff --git a/rust/bitbazaar/lib.rs b/rust/bitbazaar/lib.rs
index 6d7eb2c6..1dde758e 100644
--- a/rust/bitbazaar/lib.rs
+++ b/rust/bitbazaar/lib.rs
@@ -22,5 +22,6 @@ pub mod misc;
 #[cfg(feature = "redis")]
 /// Redis utilities
 pub mod redis;
+#[cfg(feature = "timing")]
 /// Timing utilities
 pub mod timing;
diff --git a/rust/bitbazaar/log/global_log/builder.rs b/rust/bitbazaar/log/global_log/builder.rs
index c6e30ef3..114a7343 100644
--- a/rust/bitbazaar/log/global_log/builder.rs
+++ b/rust/bitbazaar/log/global_log/builder.rs
@@ -9,7 +9,12 @@ use crate::prelude::*;
 /// Shared that can be set for all output types
 pub struct SharedOpts {
     pub level_from: Level,
+
+    // Keeping when feature disabled to make a bit more concise in usage:
+    #[cfg(feature = "log-filter")]
     pub loc_matcher: Option<regex::Regex>,
+    #[cfg(not(feature = "log-filter"))]
+    pub loc_matcher: Option<bool>,
 }
 
 impl Default for SharedOpts {
@@ -57,8 +62,12 @@ pub struct CustomConf {
 
 #[cfg(feature = "opentelemetry")]
 pub struct OtlpConf {
+    #[cfg(feature = "opentelemetry-grpc")]
     /// The localhost port the open telemetry collector is running on and accepting grpc connections:
-    pub port: u16,
+    pub grpc_port: Option<u16>,
+    #[cfg(feature = "opentelemetry-http")]
+    /// The url string to connect via http to, e.g. "/otlp" or "localhost/otlp":
+    pub http_endpoint: Option<String>,
     /// The name of the service:
     pub service_name: String,
     /// The active version/deployment of the service:
@@ -138,20 +147,48 @@ impl GlobalLogBuilder {
     }
 
     #[cfg(feature = "opentelemetry")]
-    /// Write to an open telemetry provider. This works with the tokio runtime.
+    #[cfg(feature = "opentelemetry-grpc")]
+    /// Write to an open telemetry provider via grpc. This works with the tokio runtime.
     ///
     /// Arguments:
     /// - `port`: The localhost port the open telemetry collector is running on and accepting grpc connections:
     /// - `service_name`: The name of the service:
     /// - `service_version`: The active version/deployment of the service:
-    pub fn otlp(
+    pub fn otlp_grpc(
         mut self,
         port: u16,
         service_name: impl Into<String>,
         service_version: impl Into<String>,
     ) -> Self {
         self.outputs.push(Output::Otlp(OtlpConf {
-            port,
+            grpc_port: Some(port),
+            #[cfg(feature = "opentelemetry-http")]
+            http_endpoint: None,
+            service_name: service_name.into(),
+            service_version: service_version.into(),
+            shared: SharedOpts::default(),
+        }));
+        self
+    }
+
+    #[cfg(feature = "opentelemetry")]
+    #[cfg(feature = "opentelemetry-http")]
+    /// Write to an open telemetry provider via http. This works with wasm!
+    ///
+    /// Arguments:
+    /// - `endpoint`: The url string to connect via http to, e.g. "/otlp" or "http://localhost/otlp":
+    /// - `service_name`: The name of the service:
+    /// - `service_version`: The active version/deployment of the service:
+    pub fn otlp_http(
+        mut self,
+        endpoint: impl Into<String>,
+        service_name: impl Into<String>,
+        service_version: impl Into<String>,
+    ) -> Self {
+        self.outputs.push(Output::Otlp(OtlpConf {
+            #[cfg(feature = "opentelemetry-grpc")]
+            grpc_port: None,
+            http_endpoint: Some(endpoint.into()),
             service_name: service_name.into(),
             service_version: service_version.into(),
             shared: SharedOpts::default(),
@@ -168,6 +205,7 @@ impl GlobalLogBuilder {
         Ok(self)
     }
 
+    #[cfg(feature = "log-filter")]
     /// A regex that must be satisfied for a log to be accepted by this target.
     /// E.g. if regex is 'logging::tests' then only locations containing this will be logged by this target.
     /// Note that when None, will match all locations other than those matched by other layers with a loc_matcher.
diff --git a/rust/bitbazaar/log/global_log/exceptions.rs b/rust/bitbazaar/log/global_log/exceptions.rs
index 968097d0..6f46b323 100644
--- a/rust/bitbazaar/log/global_log/exceptions.rs
+++ b/rust/bitbazaar/log/global_log/exceptions.rs
@@ -14,12 +14,25 @@ pub fn record_exception_inner(
 }
 
 /// Setup the program to automatically log panics as an error event on the current span.
+/// Internally makes sure it only runs once.
 pub fn auto_trace_panics() {
-    let prev_hook = std::panic::take_hook();
-    std::panic::set_hook(Box::new(move |panic_info| {
-        panic_hook(panic_info);
-        prev_hook(panic_info);
-    }));
+    use std::sync::Once;
+    static SET_HOOK: Once = Once::new();
+    SET_HOOK.call_once(|| {
+        // If wasm, know the default browser panic hook is dogshite, so just replace so it doesn't show:
+        #[cfg(target_arch = "wasm32")]
+        {
+            std::panic::set_hook(Box::new(panic_hook));
+        }
+        #[cfg(not(target_arch = "wasm32"))]
+        {
+            let prev_hook = std::panic::take_hook();
+            std::panic::set_hook(Box::new(move |panic_info| {
+                panic_hook(panic_info);
+                prev_hook(panic_info);
+            }));
+        }
+    });
 }
 
 fn panic_hook(panic_info: &std::panic::PanicInfo) {
diff --git a/rust/bitbazaar/log/global_log/out.rs b/rust/bitbazaar/log/global_log/out.rs
index b5a65b3a..c8dce200 100644
--- a/rust/bitbazaar/log/global_log/out.rs
+++ b/rust/bitbazaar/log/global_log/out.rs
@@ -1,12 +1,10 @@
 use once_cell::sync::Lazy;
 use parking_lot::Mutex;
 use tracing::{Dispatch, Level};
-use tracing_appender::non_blocking::WorkerGuard;
 use tracing_subscriber::prelude::*;
 
 use crate::errors::prelude::*;
 
-// When registering globally, hoist the guards out into here, to allow the CreatedSubscriber to go out of scope but keep the guards permanently.
 pub static GLOBAL_LOG: Lazy<Mutex<Option<GlobalLog>>> = Lazy::new(Mutex::default);
 
 /// The global logger/tracer for stdout, file and full open telemetry. Works with the tracing crates (info!, debug!, warn!, error!) and span funcs and decorators.
@@ -40,9 +38,11 @@ pub struct GlobalLog {
     /// Tracing dispatcher, needed to make the global logger.
     pub(crate) dispatch: Option<Dispatch>,
 
+    // tracing_appender not included in wasm:
+    #[cfg(not(target_arch = "wasm32"))]
     /// Need to store these guards, when they go out of scope the logging may stop.
     /// When made global these are hoisted into a static lazy var.
-    pub(crate) _guards: Vec<WorkerGuard>,
+    pub(crate) _guards: Vec<tracing_appender::non_blocking::WorkerGuard>,
 
     #[cfg(feature = "opentelemetry")]
     pub(crate) otlp_providers: OtlpProviders,
diff --git a/rust/bitbazaar/log/global_log/setup.rs b/rust/bitbazaar/log/global_log/setup.rs
index 9ce8f3ba..d7c86435 100644
--- a/rust/bitbazaar/log/global_log/setup.rs
+++ b/rust/bitbazaar/log/global_log/setup.rs
@@ -34,6 +34,7 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
     // If opentelemetry being used, error_stacks should have color turned off, this would break text in external viewers outside terminals:
     error_stack::Report::set_color_mode(error_stack::fmt::ColorMode::None);
 
+    #[cfg(feature = "log-filter")]
     let all_loc_matchers = builder
         .outputs
         .iter()
@@ -49,7 +50,10 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
         meter_provider: opentelemetry_sdk::metrics::MeterProvider::default(),
     };
     let mut out_layers = vec![];
+
+    #[cfg(not(target_arch = "wasm32"))]
     let mut guards = vec![];
+
     for output in builder.outputs {
         macro_rules! add_layer {
             ($shared:expr, $layer:expr) => {
@@ -58,7 +62,9 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
                     $layer
                         .with_filter(filter_layer(
                             $shared.level_from.clone(),
+                            #[cfg(feature = "log-filter")]
                             $shared.loc_matcher.clone(),
+                            #[cfg(feature = "log-filter")]
                             &all_loc_matchers,
                         )?)
                         .boxed(),
@@ -68,13 +74,32 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
 
         match output {
             super::builder::Output::Stdout(stdout) => {
-                let (writer, _guard) = tracing_appender::non_blocking(std::io::stdout());
-                guards.push(_guard);
+                // When not web, normal std out and non-blocking:
+                #[cfg(not(target_arch = "wasm32"))]
+                let writer = {
+                    let (writer, _guard) = tracing_appender::non_blocking(std::io::stdout());
+                    guards.push(_guard);
+                    writer
+                };
+
+                // When web, custom console writer, non-blocking doesn't seem to be supported on web (raises runtime):
+                #[cfg(target_arch = "wasm32")]
+                let writer = {
+                    use tracing_subscriber_wasm::MakeConsoleWriter;
+                    MakeConsoleWriter::default()
+                };
+
                 add_layer!(
                     stdout.shared,
                     create_fmt_layer(stdout.pretty, false, stdout.include_loc, true, writer,)?
                 );
             }
+            // File obvs can't be written in wasm, excluding to keep tracing_appender out of build etc.
+            #[cfg(target_arch = "wasm32")]
+            super::builder::Output::File(_) => {
+                return Err(anyerr!("File logging not supported in wasm."));
+            }
+            #[cfg(not(target_arch = "wasm32"))]
             super::builder::Output::File(file) => {
                 // Throw if dir is an existing file:
                 if file.dir.is_file() {
@@ -124,81 +149,117 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
                     resource, trace as sdktrace,
                 };
 
-                if !crate::misc::is_tcp_port_listening("localhost", otlp.port)? {
-                    return Err(anyerr!("Can't connect to open telemetry collector on local port {}. Are you sure it's running?", otlp.port));
-                }
+                // Theoretically both features could be enabled, so create an array to be able to double initiate two layers (both grpc and http)
+                // makes compiler happy and isn't hacky!
+                let mut exporters: Vec<(
+                    opentelemetry_otlp::LogExporterBuilder,
+                    opentelemetry_otlp::SpanExporterBuilder,
+                    opentelemetry_otlp::MetricsExporterBuilder,
+                )> = vec![];
+
+                #[cfg(feature = "opentelemetry-grpc")]
+                #[allow(unused_variables)]
+                if let Some(port) = otlp.grpc_port {
+                    if !crate::misc::is_tcp_port_listening("localhost", port)? {
+                        return Err(anyerr!("Can't connect to open telemetry collector on local port {}. Are you sure it's running?", port));
+                    }
+                    let endpoint = format!("grpc://localhost:{}", port);
+                    let get_exporter = || new_exporter().tonic().with_endpoint(&endpoint);
+                    exporters.push((
+                        get_exporter().into(),
+                        get_exporter().into(),
+                        get_exporter().into(),
+                    ));
+                };
 
-                let endpoint = format!("grpc://localhost:{}", otlp.port);
-                let get_exporter = || new_exporter().tonic().with_endpoint(&endpoint);
-
-                // Configure the global propagator to use between different services, without this step when you try and connect other services they'll strangely not work (this defaults to a no-op)
-                //
-                // Only enable to the 2 main standard propagators, the w3c trace context and baggage.
-                //
-                // https://opentelemetry.io/docs/concepts/sdk-configuration/general-sdk-configuration/#otel_propagators
-                set_text_map_propagator(TextMapCompositePropagator::new(vec![
-                    Box::new(TraceContextPropagator::new()),
-                    Box::new(BaggagePropagator::new()),
-                ]));
-
-                let resource = resource::Resource::new(vec![
-                    opentelemetry::KeyValue::new(
-                        opentelemetry_semantic_conventions::resource::SERVICE_NAME,
-                        otlp.service_name,
-                    ),
-                    opentelemetry::KeyValue::new(
-                        opentelemetry_semantic_conventions::resource::SERVICE_VERSION,
-                        otlp.service_version,
-                    ),
-                    opentelemetry::KeyValue::new(
-                        opentelemetry_semantic_conventions::resource::SERVICE_INSTANCE_ID,
-                        hostname::get()
-                            .change_context(AnyErr)?
-                            .to_string_lossy()
-                            .to_string(),
-                    ),
-                ]);
-
-                // Different layers are needed for the logger, tracer and meter:
-                let logger = new_pipeline()
-                    .logging()
-                    .with_log_config(sdklogs::Config::default().with_resource(resource.clone()))
-                    .with_exporter(get_exporter())
-                    .install_batch(opentelemetry_sdk::runtime::Tokio)
-                    .change_context(AnyErr)?;
-                let logging_provider = logger
-                    .provider()
-                    .ok_or_else(|| anyerr!("No log provider attached."))?;
-                let log_layer = crate::log::ot_tracing_bridge::OpenTelemetryTracingBridge::new(
-                    &logging_provider,
-                );
-                otlp_providers.logger_provider = Some(logging_provider);
-                add_layer!(otlp.shared, log_layer);
-
-                let tracer = new_pipeline()
-                    .tracing()
-                    .with_trace_config(sdktrace::Config::default().with_resource(resource.clone()))
-                    .with_exporter(get_exporter())
-                    .install_batch(opentelemetry_sdk::runtime::Tokio)
-                    .change_context(AnyErr)?;
-                let tracing_provider = tracer
-                    .provider()
-                    .ok_or_else(|| anyerr!("No tracing provider attached."))?;
-                let trace_layer = tracing_opentelemetry::layer().with_tracer(tracer);
-                otlp_providers.tracer_provider = Some(tracing_provider);
-                add_layer!(otlp.shared, trace_layer);
-
-                let meter_provider = new_pipeline()
-                    .metrics(opentelemetry_sdk::runtime::Tokio)
-                    .with_resource(resource.clone())
-                    .with_exporter(get_exporter())
-                    .build()
-                    .change_context(AnyErr)?;
-                let metric_layer: tracing_opentelemetry::MetricsLayer<
-                    tracing_subscriber::Registry,
-                > = tracing_opentelemetry::MetricsLayer::new(meter_provider.clone());
-                otlp_providers.meter_provider = meter_provider;
-                add_layer!(otlp.shared, metric_layer);
+                #[cfg(feature = "opentelemetry-http")]
+                if let Some(endpoint) = otlp.http_endpoint {
+                    let get_exporter = || new_exporter().http().with_endpoint(&endpoint);
+                    exporters.push((
+                        get_exporter().into(),
+                        get_exporter().into(),
+                        get_exporter().into(),
+                    ));
+                };
+
+                for (log_exporter, trace_exporter, metric_exporter) in exporters {
+                    // Configure the global propagator to use between different services, without this step when you try and connect other services they'll strangely not work (this defaults to a no-op)
+                    //
+                    // Only enable to the 2 main standard propagators, the w3c trace context and baggage.
+                    //
+                    // https://opentelemetry.io/docs/concepts/sdk-configuration/general-sdk-configuration/#otel_propagators
+                    set_text_map_propagator(TextMapCompositePropagator::new(vec![
+                        Box::new(TraceContextPropagator::new()),
+                        Box::new(BaggagePropagator::new()),
+                    ]));
+
+                    #[cfg(not(target_arch = "wasm32"))]
+                    let svc_instance_id = hostname::get()
+                        .change_context(AnyErr)?
+                        .to_string_lossy()
+                        .to_string();
+                    #[cfg(target_arch = "wasm32")]
+                    // TODO: (not much point atm as wasm http doesn't work): maybe something legitimate for web?
+                    let svc_instance_id = "wasm".to_string();
+
+                    let resource = resource::Resource::new(vec![
+                        opentelemetry::KeyValue::new(
+                            opentelemetry_semantic_conventions::resource::SERVICE_NAME,
+                            otlp.service_name.clone(),
+                        ),
+                        opentelemetry::KeyValue::new(
+                            opentelemetry_semantic_conventions::resource::SERVICE_VERSION,
+                            otlp.service_version.clone(),
+                        ),
+                        opentelemetry::KeyValue::new(
+                            opentelemetry_semantic_conventions::resource::SERVICE_INSTANCE_ID,
+                            svc_instance_id,
+                        ),
+                    ]);
+
+                    // Different layers are needed for the logger, tracer and meter:
+                    let logger = new_pipeline()
+                        .logging()
+                        .with_log_config(sdklogs::Config::default().with_resource(resource.clone()))
+                        .with_exporter(log_exporter)
+                        .install_batch(opentelemetry_sdk::runtime::Tokio)
+                        .change_context(AnyErr)?;
+                    let logging_provider = logger
+                        .provider()
+                        .ok_or_else(|| anyerr!("No logger provider attached."))?;
+                    let log_layer = crate::log::ot_tracing_bridge::OpenTelemetryTracingBridge::new(
+                        &logging_provider,
+                    );
+                    otlp_providers.logger_provider = Some(logging_provider.clone());
+                    add_layer!(otlp.shared, log_layer);
+
+                    let tracer = new_pipeline()
+                        .tracing()
+                        .with_trace_config(
+                            sdktrace::Config::default().with_resource(resource.clone()),
+                        )
+                        .with_exporter(trace_exporter)
+                        .install_batch(opentelemetry_sdk::runtime::Tokio)
+                        .change_context(AnyErr)?;
+                    let tracing_provider = tracer
+                        .provider()
+                        .ok_or_else(|| anyerr!("No tracing provider attached."))?;
+                    let trace_layer = tracing_opentelemetry::layer().with_tracer(tracer);
+                    otlp_providers.tracer_provider = Some(tracing_provider);
+                    add_layer!(otlp.shared, trace_layer);
+
+                    let meter_provider = new_pipeline()
+                        .metrics(opentelemetry_sdk::runtime::Tokio)
+                        .with_resource(resource.clone())
+                        .with_exporter(metric_exporter)
+                        .build()
+                        .change_context(AnyErr)?;
+                    let metric_layer: tracing_opentelemetry::MetricsLayer<
+                        tracing_subscriber::Registry,
+                    > = tracing_opentelemetry::MetricsLayer::new(meter_provider.clone());
+                    otlp_providers.meter_provider = meter_provider;
+                    add_layer!(otlp.shared, metric_layer);
+                }
             }
         };
     }
@@ -208,6 +269,7 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
     let dispatch: Dispatch = subscriber.into();
     Ok(GlobalLog {
         dispatch: Some(dispatch),
+        #[cfg(not(target_arch = "wasm32"))]
         _guards: guards,
         #[cfg(feature = "opentelemetry")]
         otlp_providers,
@@ -216,9 +278,10 @@ pub fn builder_into_global_log(builder: GlobalLogBuilder) -> Result<GlobalLog, A
 
 fn filter_layer(
     level_from: Level,
-    loc_matcher: Option<regex::Regex>,
-    all_loc_matchers: &[regex::Regex],
+    #[cfg(feature = "log-filter")] loc_matcher: Option<regex::Regex>,
+    #[cfg(feature = "log-filter")] all_loc_matchers: &[regex::Regex],
 ) -> Result<FilterFn<impl Fn(&Metadata<'_>) -> bool>, AnyErr> {
+    #[cfg(feature = "log-filter")]
     // Needs to be a vec to pass through to the filter fn:
     let all_loc_matchers = all_loc_matchers.to_vec();
 
@@ -228,6 +291,7 @@ fn filter_layer(
             return false;
         }
 
+        #[cfg(feature = "log-filter")]
         // Check loc matching:
         if let Some(file_info) = metadata.file() {
             // Skip log if there's a custom location matcher present that doesn't match the file string:
diff --git a/rust/bitbazaar/log/mod.rs b/rust/bitbazaar/log/mod.rs
index e5b923cb..1928334f 100644
--- a/rust/bitbazaar/log/mod.rs
+++ b/rust/bitbazaar/log/mod.rs
@@ -1,3 +1,4 @@
+#[cfg(feature = "clap")]
 mod clap_log_level_args;
 #[cfg(test)]
 mod diff_file_log;
@@ -6,6 +7,7 @@ mod macros;
 #[cfg(feature = "opentelemetry")]
 mod ot_tracing_bridge;
 
+#[cfg(feature = "clap")]
 pub use clap_log_level_args::ClapLogLevelArgs;
 pub use global_log::{global_fns::*, GlobalLog};
 
@@ -37,7 +39,6 @@ mod tests {
     }
 
     #[rstest]
-    #[serial_test::serial] // Uses static, so parameterized versions can't run in parallel.
     fn test_log_formatting_basic(
         // All combinations of:
         #[values(true, false)] include_timestamp: bool,
@@ -104,7 +105,6 @@ mod tests {
     ).unwrap()), vec!["with_matcher DEBUG LOG1", "no_matcher DEBUG LOG2"])]
     // Matcher failed, so both should be picked up by the one with no matcher:
     #[case::no_match(Some(regex::Regex::new(r"kdkfjdf").unwrap()), vec!["no_matcher DEBUG LOG1", "no_matcher DEBUG LOG2"])]
-    #[serial_test::serial] // Uses static, so parameterized versions can't run in parallel.
     fn test_log_matchers(
         #[case] loc_matcher: Option<regex::Regex>,
         #[case] expected_logs: Vec<&str>,
@@ -155,7 +155,6 @@ mod tests {
     #[case(Level::INFO, vec!["ILOG", "WLOG", "ELOG"])]
     #[case(Level::WARN, vec!["WLOG", "ELOG"])]
     #[case(Level::ERROR, vec!["ELOG"])]
-    #[serial_test::serial] // Uses static, so parameterized versions can't run in parallel.
     fn test_log_filtering(
         #[case] level_from: Level,
         #[case] expected_found: Vec<&str>,
@@ -300,8 +299,11 @@ mod tests {
 
     #[cfg(feature = "opentelemetry")]
     #[rstest]
+    // Testing both as grpc and http:
+    #[case::use_http(false)]
+    #[case::use_http(true)]
     #[tokio::test(flavor = "multi_thread")]
-    async fn test_opentelemetry() -> Result<(), AnyErr> {
+    async fn test_opentelemetry(#[case] use_http: bool) -> Result<(), AnyErr> {
         use std::path::PathBuf;
 
         use crate::misc::in_ci;
@@ -319,10 +321,14 @@ mod tests {
                 .len();
         }
 
-        let log = GlobalLog::builder()
-            .otlp(4317, "rust-test", "0.1.0")
-            .level_from(Level::DEBUG)?
-            .build()?;
+        let mut builder = GlobalLog::builder();
+        // Testing both grpc and http:
+        if use_http {
+            builder = builder.otlp_http("http://localhost:4318", "rust-test", "0.1.0");
+        } else {
+            builder = builder.otlp_grpc(4317, "rust-test", "0.1.0");
+        }
+        let log = builder.level_from(Level::DEBUG)?.build()?;
 
         log.with_tmp_global(|| {
             debug!("BEFORE");
diff --git a/rust/bitbazaar/timing/mod.rs b/rust/bitbazaar/timing/mod.rs
index b3be665d..873f5a6a 100644
--- a/rust/bitbazaar/timing/mod.rs
+++ b/rust/bitbazaar/timing/mod.rs
@@ -62,7 +62,8 @@ mod tests {
 
         let elapsed = recorder.total_elapsed().unwrap();
         assert!(
-            elapsed.as_millis() == 1 || elapsed.as_millis() == 2,
+            // Such a fallible test in CI, making very relaxed:
+            elapsed.as_millis() > 0 && elapsed.as_millis() < 5,
             "elapsed: {:?}",
             elapsed.as_millis()
         );
@@ -78,7 +79,8 @@ mod tests {
         });
         let elapsed = GLOBAL_TIME_RECORDER.total_elapsed().unwrap();
         assert!(
-            elapsed.as_millis() == 1 || elapsed.as_millis() == 2,
+            // Such a fallible test in CI, making very relaxed:
+            elapsed.as_millis() > 0 && elapsed.as_millis() < 5,
             "elapsed: {:?}",
             elapsed.as_millis()
         );