docs: GH pages for client docs

.github/dependabot.yml

@@ -1,41 +0,0 @@
-# To get started with Dependabot version updates, you'll need to specify which
-# package ecosystems to update and where the package manifests are located.
-# Please see the documentation for all configuration options:
-# https://docs.github.com/github/administering-a-repository/configuration-options-for-dependency-updates
-
-version: 2
-updates:
-  - package-ecosystem: "cargo" # See documentation for possible values
-    directory: "/" # Location of package manifests
-    schedule:
-      interval: "weekly"
-
-  - package-ecosystem: "pip"
-    directory: "python"
-    schedule:
-      interval: "weekly"
-
-  - package-ecosystem: "mix"
-    directory: "elixir"
-    schedule:
-      interval: "weekly"
-
-  - package-ecosystem: "npm"
-    directory: "node"
-    schedule:
-      interval: "weekly"
-
-  - package-ecosystem: "composer"
-    directory: "/"
-    schedule:
-      interval: "weekly"
-
-  - package-ecosystem: "bundler"
-    directory: "ruby"
-    schedule:
-      interval: "weekly"
-
-  - package-ecosystem: "gomod"
-    directory: "/"
-    schedule:
-      interval: "weekly"

.github/workflows/ci.yml

@@ -3,8 +3,8 @@ on: [pull_request, workflow_dispatch]
 name: CI
 
 env:
+  RUNTIME_MANIFEST: runtime/Cargo.toml
   RUNTIME_CRATE: extism-runtime
-  LIBEXTISM_CRATE: libextism
   RUST_SDK_CRATE: extism
 
 jobs:
@@ -41,7 +41,7 @@ jobs:
       - name: Build
         if: steps.cache-libextism.outputs.cache-hit != 'true'
         shell: bash
-        run: cargo build --release -p ${{ env.LIBEXTISM_CRATE }}
+        run: cargo build --release -p ${{ env.RUNTIME_CRATE }}
       - name: Upload artifact
         uses: actions/upload-artifact@v3
         with:
@@ -170,7 +170,6 @@ jobs:
       - name: Test Python Host SDK
         run: |
           cd python
-          cp ../README.md .
           poetry install
           poetry run python example.py
           poetry run python -m unittest discover
@@ -226,12 +225,6 @@ jobs:
           LD_LIBRARY_PATH=/usr/local/lib npm run example
           LD_LIBRARY_PATH=/usr/local/lib npm run test
 
-      - name: Test Browser Runtime
-        run: |
-          cd browser
-          npm i
-          npm run test
-
   ocaml:
     name: OCaml
     needs: lib
@@ -254,11 +247,10 @@ jobs:
         uses: actions/cache@v3
         with:
           path: _build
-          key: ${{ runner.os }}-ocaml-${{ hashFiles('ocaml/lib/**') }}-${{ hashFiles('ocaml/bin/**') }}-${{ hashFiles('dune-project') }}
+          key: ${{ runner.os }}-ocaml-${{ hashFiles('ocaml/**') }}-${{ hashFiles('dune-project') }}
       - name: Build OCaml Host SDK
         if: steps.cache-ocaml.outputs.cache-hit != 'true'
         run: |
-          opam install -y --deps-only .
           cd ocaml
           LD_LIBRARY_PATH=/usr/local/lib opam exec -- dune build
       - name: Test OCaml Host SDK

.github/workflows/docs.yml

@@ -0,0 +1,34 @@
+name: Docs
+
+# Controls when the workflow will run
+on:
+  # Triggers the workflow on push or pull request events but only for the "main" branch
+  push:
+    branches: [ "main" ]
+
+  # Allows you to run this workflow manually from the Actions tab
+  workflow_dispatch:
+
+# A workflow run is made up of one or more jobs that can run sequentially or in parallel
+jobs:
+  # This workflow contains a single job called "build"
+  build:
+    # The type of runner that the job will run on
+    runs-on: ubuntu-latest
+
+    # Steps represent a sequence of tasks that will be executed as part of the job
+    steps:
+      # Checks-out your repository under $GITHUB_WORKSPACE, so your job can access it
+      - uses: actions/checkout@v3
+
+      - name: Setup Python env
+        uses: actions/setup-python@v4
+        with:
+          python-version: "3.9"
+          check-latest: true
+          
+      - name: Build Python Docs
+        run: |
+          cd python
+          make prepare
+          make docs

.github/workflows/release-elixir.yaml

@@ -1,28 +0,0 @@
-on:
-  workflow_dispatch:
-
-name: Release Elixir SDK
-
-jobs:
-  release-sdks:
-    name: release-elixir
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-
-      - name: Setup Elixir Host SDK
-        uses: erlef/setup-beam@v1
-        with:
-          experimental-otp: true
-          otp-version: '25.0.4'
-          elixir-version: '1.14.0'
-
-      - name: Publish Elixir Host SDK to hex.pm
-        env:
-          HEX_API_KEY: ${{ secrets.HEX_PM_API_TOKEN }}
-        run: |
-          cd elixir
-          cp ../LICENSE .
-          make publish
-  

.github/workflows/release-node.yaml

@@ -1,30 +0,0 @@
-on:
-  workflow_dispatch:
-
-name: Release Node SDK
-
-jobs:
-  release-sdks:
-    name: release-node
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-
-      - name: Setup Node env
-        uses: actions/setup-node@v3
-        with:
-          node-version: 16
-          registry-url: "https://registry.npmjs.org"
-        env:
-          NODE_AUTH_TOKEN: ${{ secrets.NPM_API_TOKEN }}
-          CI: true
-
-      - name: Release Node Host SDK
-        env:
-          NODE_AUTH_TOKEN: ${{ secrets.NPM_API_TOKEN }}
-          CI: true
-        run: |
-          cd node
-          make publish
-  

.github/workflows/release-python.yaml

@@ -1,37 +0,0 @@
-on:
-  workflow_dispatch:
-
-name: Release Python SDK
-
-jobs:
-  release-sdks:
-    name: release-python
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-
-      - name: Setup Python env
-        uses: actions/setup-python@v4
-        with:
-          python-version: "3.9"
-          check-latest: true
-      - name: Run image
-        uses: abatilo/actions-poetry@v2
-
-      - name: Build Python Host SDK
-        run: |
-          cd python
-          cp ../LICENSE .
-          cp ../README.md .
-          make clean
-          make prepare
-          poetry build
-
-      - name: Release Python Host SDK
-        uses: pypa/gh-action-pypi-publish@release/v1
-        with:
-          user: ${{ secrets.PYPI_API_USER }}
-          password: ${{ secrets.PYPI_API_TOKEN }}
-          packages_dir: python/dist/
-

.github/workflows/release-ruby.yaml

@@ -1,25 +0,0 @@
-on:
-  workflow_dispatch:
-
-name: Release Ruby SDK
-
-jobs:
-  release-sdks:
-    name: release-ruby
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-
-      - name: Setup Ruby
-        uses: actions/setup-ruby@v1
-        with:
-          ruby-version: '3.1' # Version range or exact version of a Ruby version to use, using semvers version range syntax.
-
-      - name: Publish Ruby Gem
-        env:
-          RUBYGEMS_API_KEY: ${{ secrets.RUBYGEMS_API_TOKEN }}
-        run: |
-          cd ruby
-          make publish
-      

.github/workflows/release-rust.yaml

@@ -1,35 +0,0 @@
-on:
-  workflow_dispatch:
-
-name: Release Rust SDK
-
-jobs:
-  release-sdks:
-    name: release-rust
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v3
-      
-      - name: Setup Rust env
-        uses: actions-rs/toolchain@v1
-        with:
-          toolchain: stable
-          profile: minimal
-          override: true
-          target: ${{ matrix.target }}
-
-      - name: Release Rust Host SDK
-        env:
-          CARGO_REGISTRY_TOKEN: ${{ secrets.CARGO_API_TOKEN }}
-        run: |
-          # order of crate publication matter: manifest, runtime, rust
-
-          cargo publish --manifest-path manifest/Cargo.toml
-          # allow for crates.io to update so dependant crates can locate extism-manifest
-          sleep 5 
-
-          cargo publish --manifest-path runtime/Cargo.toml --no-verify
-          cargo publish --manifest-path rust/Cargo.toml
-      
-  

.github/workflows/release.yml

@@ -1,13 +1,12 @@
 on:
   release:
     types: [created]
-  workflow_dispatch:
 
 name: Release
 
 env:
   RUNTIME_MANIFEST: runtime/Cargo.toml
-  RUNTIME_CRATE: libextism
+  RUNTIME_CRATE: extism-runtime
   RUSTFLAGS: -C target-feature=-crt-static
   ARTIFACT_DIR: release-artifacts
 
@@ -214,3 +213,112 @@ jobs:
           files: |
             *.tar.gz
             *.txt
+
+  release-sdks:
+    needs: [release-linux, release-macos] # release-windows
+    name: publish-sdks
+    runs-on: ubuntu-latest
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v3
+
+      - name: Setup Node env
+        uses: actions/setup-node@v3
+        with:
+          node-version: 16
+          registry-url: "https://registry.npmjs.org"
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_API_TOKEN }}
+          CI: true
+
+      - name: Release Node Host SDK
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_API_TOKEN }}
+          CI: true
+        run: |
+          cd node
+          npm publish
+
+      - name: Setup Rust env
+        uses: actions-rs/toolchain@v1
+        with:
+          toolchain: stable
+          profile: minimal
+          override: true
+          target: ${{ matrix.target }}
+
+      - name: Release Rust Host SDK
+        env:
+          CARGO_REGISTRY_TOKEN: ${{ secrets.CARGO_API_TOKEN }}
+        run: |
+          # order of crate publication matter: manifest, runtime, rust
+
+          cargo publish --manifest-path manifest/Cargo.toml
+          # allow for crates.io to update so dependant crates can locate extism-manifest
+          sleep 5 
+
+          cargo publish --manifest-path runtime/Cargo.toml --no-verify
+          cargo publish --manifest-path rust/Cargo.toml
+
+      - name: Setup Elixir Host SDK
+        uses: erlef/setup-beam@v1
+        with:
+          experimental-otp: true
+          otp-version: '25.0.4'
+          elixir-version: '1.14.0'
+
+      - name: Publish Elixir Host SDK to hex.pm
+        env:
+          HEX_API_KEY: ${{ secrets.HEX_PM_API_TOKEN }}
+        run: |
+          cd elixir
+          cp ../LICENSE .
+          mix do deps.get, deps.compile
+          mix hex.build
+          mix hex.publish --yes
+
+      - name: Setup Ruby
+        uses: actions/setup-ruby@v1
+        with:
+          ruby-version: '3.1' # Version range or exact version of a Ruby version to use, using semvers version range syntax.
+
+      - name: Publish Ruby Gem
+        env:
+          RUBYGEMS_API_KEY: ${{ secrets.RUBYGEMS_API_TOKEN }}
+        run: |
+          cd ruby
+          gem build extism.gemspec
+          gem push extism*.gem -k $RUBYGEMS_API_KEY
+        
+      - name: Publish Elixir Host SDK to hex.pm
+        env:
+          HEX_API_KEY: ${{ secrets.HEX_PM_API_TOKEN }}
+        run: |
+          cd elixir
+          mix do deps.get, deps.compile
+          mix hex.build
+          mix hex.publish --yes
+
+      - name: Setup Python env
+        uses: actions/setup-python@v4
+        with:
+          python-version: "3.9"
+          check-latest: true
+
+      - name: Build Python Host SDK
+        run: |
+          pushd python
+          python3 -m pip install --upgrade build
+          cp ../LICENSE .
+          cp ../README.md .
+          python3 -m poetry build
+          popd
+
+      - name: Release Python Host SDK
+        uses: pypa/gh-action-pypi-publish@release/v1
+        env:
+          INPUT_VERIFY_METADATA: false
+        with:
+          user: ${{ secrets.PYPI_API_USER }}
+          password: ${{ secrets.PYPI_API_TOKEN }}
+          packages_dir: python/dist/

Cargo.toml

@@ -3,8 +3,8 @@ members = [
   "manifest",
   "runtime",
   "rust",
-  "libextism"
 ]
 exclude = [
   "elixir/native/extism_nif"
 ]
+

Makefile

@@ -25,7 +25,7 @@ lint:
 	cargo clippy --release --no-deps --manifest-path runtime/Cargo.toml
 
 build:
-	cargo build --release $(FEATURE_FLAGS) --manifest-path libextism/Cargo.toml
+	cargo build --release $(FEATURE_FLAGS) --manifest-path runtime/Cargo.toml
 
 install:
 	install runtime/extism.h $(DEST)/include

README.md

@@ -15,11 +15,9 @@ The universal plug-in system. Run WebAssembly extensions inside your app. Use id
 Plug-in development kits (PDK) for plug-in authors supported in [Rust](https://github.com/extism/rust-pdk), [AssemblyScript](https://github.com/extism/assemblyscript-pdk), [Go](https://github.com/extism/go-pdk), [C/C++](https://github.com/extism/c-pdk).
 
 <p align="center">
-  <img style="width: 70%;" src="https://user-images.githubusercontent.com/7517515/200043015-ddfe5833-0252-43a8-bc9e-5b3f829c37d1.png" alt="Extism embedded SDK language support"/>
+  <img style="width: 70%;" src="https://user-images.githubusercontent.com/7517515/198499438-f3de06e5-71b4-439d-ab31-a3672acc6ede.png"/>
 </p>
 
-
-
 Add a flexible, secure, and _bLaZiNg FaSt_ plug-in system to your project. Server, desktop, mobile, web, database -- you name it. Enable users to write and execute safe extensions to your software in **3 easy steps:**
 
 ### 1. Import

browser/.gitignore

@@ -1,130 +0,0 @@
-# Logs
-logs
-*.log
-npm-debug.log*
-yarn-debug.log*
-yarn-error.log*
-lerna-debug.log*
-.pnpm-debug.log*
-
-# Diagnostic reports (https://nodejs.org/api/report.html)
-report.[0-9]*.[0-9]*.[0-9]*.[0-9]*.json
-
-# Runtime data
-pids
-*.pid
-*.seed
-*.pid.lock
-
-# Directory for instrumented libs generated by jscoverage/JSCover
-lib-cov
-
-# Coverage directory used by tools like istanbul
-coverage
-*.lcov
-
-# nyc test coverage
-.nyc_output
-
-# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
-.grunt
-
-# Bower dependency directory (https://bower.io/)
-bower_components
-
-# node-waf configuration
-.lock-wscript
-
-# Compiled binary addons (https://nodejs.org/api/addons.html)
-build/Release
-
-# Dependency directories
-node_modules/
-jspm_packages/
-
-# Snowpack dependency directory (https://snowpack.dev/)
-web_modules/
-
-# TypeScript cache
-*.tsbuildinfo
-
-# Optional npm cache directory
-.npm
-
-# Optional eslint cache
-.eslintcache
-
-# Optional stylelint cache
-.stylelintcache
-
-# Microbundle cache
-.rpt2_cache/
-.rts2_cache_cjs/
-.rts2_cache_es/
-.rts2_cache_umd/
-
-# Optional REPL history
-.node_repl_history
-
-# Output of 'npm pack'
-*.tgz
-
-# Yarn Integrity file
-.yarn-integrity
-
-# dotenv environment variable files
-.env
-.env.development.local
-.env.test.local
-.env.production.local
-.env.local
-
-# parcel-bundler cache (https://parceljs.org/)
-.cache
-.parcel-cache
-
-# Next.js build output
-.next
-out
-
-# Nuxt.js build / generate output
-.nuxt
-dist
-
-# Gatsby files
-.cache/
-# Comment in the public line in if your project uses Gatsby and not Next.js
-# https://nextjs.org/blog/next-9-1#public-directory-support
-# public
-
-# vuepress build output
-.vuepress/dist
-
-# vuepress v2.x temp and cache directory
-.temp
-.cache
-
-# Docusaurus cache and generated files
-.docusaurus
-
-# Serverless directories
-.serverless/
-
-# FuseBox cache
-.fusebox/
-
-# DynamoDB Local files
-.dynamodb/
-
-# TernJS port file
-.tern-port
-
-# Stores VSCode versions used for testing VSCode extensions
-.vscode-test
-
-# yarn v2
-.yarn/cache
-.yarn/unplugged
-.yarn/build-state.yml
-.yarn/install-state.gz
-.pnp.*

browser/.prettierrc

@@ -1,5 +0,0 @@
-{
-  "printWidth": 120,
-  "trailingComma": "all",
-  "singleQuote": true
-}

browser/build.js

@@ -1,23 +0,0 @@
-const { build } = require("esbuild");
-const { dependencies, peerDependencies } = require('./package.json')
-
-const sharedConfig = {
-    entryPoints: ["src/index.ts"],
-    bundle: true,
-    minify: false,
-    drop: [], // preseve debugger statements
-    external: Object.keys(dependencies || {}).concat(Object.keys(peerDependencies || {})),
-};
-
-build({
-    ...sharedConfig,
-    platform: 'node', // for CJS
-    outfile: "dist/index.js",
-});
-
-build({
-    ...sharedConfig,
-    outfile: "dist/index.esm.js",
-    platform: 'neutral', // for ESM
-    format: "esm",
-});

browser/index.html

@@ -1,238 +0,0 @@
-<html>
-  <head>
-    <script src="https://unpkg.com/babel-standalone@6/babel.min.js"></script>
-    <script src="https://unpkg.com/react@18/umd/react.development.js" crossorigin></script>
-    <script src="https://unpkg.com/react-dom@18/umd/react-dom.development.js" crossorigin></script>
-    <style>
-      #main {
-        width: 100%;
-      }
-      .manifest {
-        display: flex; /* or inline-flex */
-        flex-direction: row;
-        flex-wrap: nowrap;
-        width: 100%;
-      }
-      .urlInput {
-        width: 600px;
-      }
-      .funcName {
-        width: 150px;
-      }
-      .textAreas {
-        display: flex; /* or inline-flex */
-        flex-direction: row;
-        flex-wrap: nowrap;
-        width: 100%;
-        height: 300px;
-      }
-      .inputBox {
-        width: 100%;
-        height: 100%; 
-      }
-      .inputBox > textarea {
-        width: 100%;
-        height: 100%; 
-      }
-      .outputBox {
-        width: 100%;
-        height: 100%; 
-      }
-      .outputBox > textarea {
-        width: 100%;
-        height: 100%; 
-      }
-      .space {
-        height: 80px;
-      }
-      .dragAreas {
-        display: flex; /* or inline-flex */
-        flex-direction: row;
-        flex-wrap: nowrap;
-        width: 100%;
-        height: 200px;
-      }
-      .dragInput {
-        width: 100%;
-        height: 100%; 
-        border-style: dotted;
-        border-color: #000;
-      }
-      .dragOutput {
-        width: 100%;
-        height: 100%; 
-      }
-      .dropZone {
-        width: 100%;
-        height: 100%; 
-      } 
-      .outputImage {
-        width: 100%;
-        height: 100%; 
-      }
-      
-    </style>
-
-    <script type="text/babel">
-      function getBase64(file, cb) {
-        var reader = new FileReader();
-        reader.readAsDataURL(file);
-        reader.onload = function () {
-          cb(reader.result)
-        };
-        reader.onerror = function (error) {
-          console.log("error")
-        };
-      }
-
-      function arrayTob64(buffer) {
-        var binary = '';
-        var bytes = [].slice.call(buffer);
-        bytes.forEach((b) => binary += String.fromCharCode(b));
-        return window.btoa(binary);
-      }
-
-
-      class App extends React.Component {
-        state = {
-          url: "https://raw.githubusercontent.com/extism/extism/main/wasm/code.wasm",
-          input: new Uint8Array(),
-          output: new Uint8Array(),
-          func_name: "count_vowels",
-          functions: []
-        }
-
-        async loadFunctions(url) {
-            let plugin = await this.extismContext.newPlugin({ "wasm": [ { "path": url } ] }) 
-            let functions = await plugin.getExportedFunctions()
-            console.log("funcs ", functions)
-            this.setState({functions})
-        }
-
-        componentDidMount() {
-          this.loadFunctions(this.state.url)
-        }
-
-        constructor(props) {
-          super(props)
-          this.extismContext = props.extismContext
-        }
-
-        handleInputChange(e) {
-          e.preventDefault();
-          this.setState({ [e.target.name]: e.target.value })
-          if (e.target.name === "url") {
-            this.loadFunctions(e.target.value)
-          }
-        }
-
-        onInputKeyPress(e) {
-          if (e.keyCode == 13 && e.shiftKey == true) {
-            e.preventDefault()
-            this.handleOnRun()
-          }
-        }
-
-        async handleOnRun(e) {
-          e && e.preventDefault && e.preventDefault();
-          let plugin = await this.extismContext.newPlugin({ "wasm": [ { "path": this.state.url } ] }) 
-          let result = await plugin.call(this.state.func_name, this.state.input)
-          let output = result
-          this.setState({output})
-        }
-
-        nop = (e) => {
-          e.preventDefault();
-          e.stopPropagation();
-        };
-        handleDrop = e => {
-          e.preventDefault();
-          e.stopPropagation();
-          let files = [...e.dataTransfer.files];
-          if (files && files.length == 1) {
-            let file = files[0]
-            console.log(file)
-            file.arrayBuffer().then(b => {
-              this.setState({input: new Uint8Array(b)})
-              this.handleOnRun()
-            })
-          } else {
-            throw Error("Only one file please")
-          }
-        };
-
-        render() {
-          const funcOptions = this.state.functions.map(f => <option value={f}>{f}</option>)
-          let image = null
-          if (this.state.output) {
-              image = <img src={`data:image/png;base64,${arrayTob64(this.state.output)}`}/>
-          }
-
-          return <div className="app">
-            <div className="manifest">
-              <div>
-                <label>WASM Url: </label>
-                <input type="text" name="url" className="urlInput" value={this.state.url} onChange={this.handleInputChange.bind(this)} />
-              </div>
-              <div>
-                <label>Function: </label>
-                <select type="text" name="func_name" className="funcName" value={this.state.func_name} onChange={this.handleInputChange.bind(this)}>
-                  {funcOptions}
-                </select>
-              </div>
-              <div>
-                <button onClick={this.handleOnRun.bind(this)}>Run</button>
-              </div>
-            </div>
-            <div className="textAreas">
-              <div className="inputBox">
-                <h3>Text Input</h3>
-                <textarea name="input" value={this.state.input} onChange={this.handleInputChange.bind(this)} onKeyDown={this.onInputKeyPress.bind(this)}></textarea>
-              </div>
-              <div className="outputBox">
-                <h3>Text Output</h3>
-                <textarea name="output" value={new TextDecoder().decode(this.state.output)} ></textarea>
-              </div>
-            </div>
-            <div className="space" />
-            <div className="dragAreas">
-              <div className="dragInput">
-                <h3>Image Input</h3>
-                <div className="dropZone"
-                  onDrop={this.handleDrop.bind(this)}
-                  onDragOver={this.nop.bind(this)}
-                  onDragEnter={this.nop.bind(this)}
-                  onDragLeave={this.nop.bind(this)}
-                >
-                </div>
-              </div>
-              <div className="dragOutput">
-                <h3>Image Output</h3>
-                <div className="outputImage">
-                  {image}
-                </div>
-              </div>
-            </div>
-          </div>
-        }
-      }
-      window.App = App
-    </script>
-
-    <script type="module">
-      import {ExtismContext} from './dist/index.esm.js'
-      const e = React.createElement;
-
-      window.onload = () => {
-        const domContainer = document.getElementById('main');
-        console.log(domContainer)
-        const root = ReactDOM.createRoot(domContainer);
-        const extismContext = new ExtismContext()
-        root.render(e(App, {extismContext}));
-      }
-    </script>
-  </head>
-  <body>
-    <div id="main"></div>
-  </body>
-</html>

browser/jest.config.js

@@ -1,5 +0,0 @@
-/** @type {import('ts-jest/dist/types').InitialOptionsTsJest} */
-module.exports = {
-  preset: 'ts-jest',
-  testEnvironment: 'node',
-};

browser/package.json

@@ -1,34 +0,0 @@
-{
-  "name": "@extism/runtime-browser",
-  "version": "0.0.1",
-  "description": "Extism runtime in the browser",
-  "scripts": {
-    "build": "node build.js && tsc --emitDeclarationOnly --outDir dist",
-    "format": "prettier --write \"src/**/*.ts\"",
-    "lint": "tslint -p tsconfig.json",
-    "test": "jest --config jest.config.js"
-  },
-  "private": false,
-  "publishConfig": {
-    "access": "public"
-  },
-  "files": [
-    "dist/*"
-  ],
-  "module": "dist/index.esm.js",
-  "main": "dist/index.js",
-  "typings": "dist/index.d.ts",
-  "author": "The Extism Authors <oss@extism.org>",
-  "license": "BSD-3-Clause",
-  "devDependencies": {
-    "@types/jest": "^29.2.2",
-    "esbuild": "^0.15.13",
-    "jest": "^29.2.2",
-    "prettier": "^2.7.1",
-    "ts-jest": "^29.0.3",
-    "tslint": "^6.1.3",
-    "tslint-config-prettier": "^1.18.0",
-    "typedoc": "^0.23.20",
-    "typescript": "^4.8.4"
-  }
-}

browser/src/allocator.ts

@@ -1,104 +0,0 @@
-type MemoryBlock = { offset: bigint; length: bigint };
-
-export default class Allocator {
-  currentIndex: bigint;
-  active: Record<number, MemoryBlock>;
-  freed: MemoryBlock[];
-  memory: Uint8Array;
-
-  constructor(n: number) {
-    this.currentIndex = BigInt(1);
-    this.active = {};
-    this.freed = [];
-    this.memory = new Uint8Array(n);
-  }
-
-  reset() {
-    this.currentIndex = BigInt(1);
-    this.active = {};
-    this.freed = [];
-  }
-
-  alloc(length: bigint): bigint {
-    for (var i = 0; i < this.freed.length; i++) {
-      let block = this.freed[i];
-      if (block.length === length) {
-        this.active[Number(block.offset)] = block;
-        this.freed.splice(i, 1);
-        return block.offset;
-      } else if (block.length > length + BigInt(64)) {
-        const newBlock = { offset: block.offset, length };
-        block.offset += length;
-        block.length -= length;
-        return newBlock.offset;
-      }
-    }
-
-    // Resize memory if needed
-    // TODO: put a limit on the memory size
-    if (BigInt(this.memory.length) < this.currentIndex + length) {
-      const tmp = new Uint8Array(Number(this.currentIndex + length + BigInt(64)));
-      tmp.set(this.memory);
-      this.memory = tmp;
-    }
-
-    const offset = this.currentIndex;
-    this.currentIndex += length;
-    this.active[Number(offset)] = { offset, length };
-    return offset;
-  }
-
-  getBytes(offset: bigint): Uint8Array | null {
-    const block = this.active[Number(offset)];
-    if (!block) {
-      return null;
-    }
-
-    return new Uint8Array(this.memory.buffer, Number(offset), Number(block.length));
-  }
-
-  getString(offset: bigint): string | null {
-    const bytes = this.getBytes(offset);
-    if (bytes === null) {
-      return null;
-    }
-
-    return new TextDecoder().decode(bytes);
-  }
-
-  allocBytes(data: Uint8Array): bigint {
-    const offs = this.alloc(BigInt(data.length));
-    const bytes = this.getBytes(offs);
-    if (bytes === null) {
-      this.free(offs);
-      return BigInt(0);
-    }
-
-    bytes.set(data);
-    return offs;
-  }
-
-  allocString(data: string): bigint {
-    const bytes = new TextEncoder().encode(data);
-    return this.allocBytes(bytes);
-  }
-
-  getLength(offset: bigint): bigint {
-    const block = this.active[Number(offset)];
-    if (!block) {
-      return BigInt(0);
-    }
-
-    return block.length;
-  }
-
-  free(offset: bigint) {
-    const block = this.active[Number(offset)];
-    if (!block) {
-      return;
-    }
-
-    delete this.active[Number(offset)];
-    this.freed.push(block);
-  }
-}

browser/src/context.ts

@@ -1,45 +0,0 @@
-import { Manifest, PluginConfig, ManifestWasmFile, ManifestWasmData } from './manifest';
-import ExtismPlugin from './plugin';
-
-/**
- * Can be a {@link Manifest} or just the raw bytes of the WASM module as an ArrayBuffer.
- * We recommend using {@link Manifest}
- */
-type ManifestData = Manifest | ArrayBuffer;
-
-/**
- * A Context is needed to create plugins. The Context
- * is where your plugins live. Freeing the context
- * frees all of the plugins in its scope.
- */
-export default class ExtismContext {
-  /**
-   * Create a plugin managed by this context
-   *
-   * @param manifest - The {@link ManifestData} describing the plugin code and config
-   * @param config - Config details for the plugin
-   * @returns A new Plugin scoped to this Context
-   */
-  async newPlugin(manifest: ManifestData, config?: PluginConfig) {
-    let moduleData: ArrayBuffer | null = null;
-    if (manifest instanceof ArrayBuffer) {
-      moduleData = manifest;
-    } else if ((manifest as Manifest).wasm) {
-      const wasmData = (manifest as Manifest).wasm;
-      if (wasmData.length > 1) throw Error('This runtime only supports one module in Manifest.wasm');
-      const wasm = wasmData[0];
-      if ((wasm as ManifestWasmData).data) {
-        moduleData = (wasm as ManifestWasmData).data;
-      } else if ((wasm as ManifestWasmFile).path) {
-        const response = await fetch((wasm as ManifestWasmFile).path);
-        moduleData = await response.arrayBuffer();
-        console.dir(moduleData);
-      }
-    }
-    if (!moduleData) {
-      throw Error(`Unsure how to interpret manifest ${manifest}`);
-    }
-
-    return new ExtismPlugin(moduleData, config);
-  }
-}

browser/src/index.test.ts

@@ -1,23 +0,0 @@
-import { ExtismContext } from './';
-import fs from 'fs';
-import path from 'path';
-
-function parse(bytes: Uint8Array): any {
-  return JSON.parse(new TextDecoder().decode(bytes));
-}
-
-describe('', () => {
-  it('can load and call a plugin', async () => {
-    const data = fs.readFileSync(path.join(__dirname, '..', 'data', 'code.wasm'));
-    const ctx = new ExtismContext();
-    const plugin = await ctx.newPlugin({ wasm: [{ data: data }] });
-    const functions = await plugin.getExports();
-    expect(Object.keys(functions).filter(x => !x.startsWith("__") && x !== "memory")).toEqual(['count_vowels']);
-    let output = await plugin.call('count_vowels', 'this is a test');
-    expect(parse(output)).toEqual({ count: 4 });
-    output = await plugin.call('count_vowels', 'this is a test again');
-    expect(parse(output)).toEqual({ count: 7 });
-    output = await plugin.call('count_vowels', 'this is a test thrice');
-    expect(parse(output)).toEqual({ count: 6 });
-  });
-});

browser/src/index.ts

@@ -1,3 +0,0 @@
-import ExtismContext from './context';
-
-export { ExtismContext };

browser/src/manifest.ts

@@ -1,40 +0,0 @@
-/**
- * Represents a path or url to a WASM module
- */
-export type ManifestWasmFile = {
-  path: string;
-  name?: string;
-  hash?: string;
-};
-
-/**
- * Represents the raw bytes of a WASM file loaded into memory
- */
-export type ManifestWasmData = {
-  data: Uint8Array;
-  name?: string;
-  hash?: string;
-};
-
-/**
- * {@link ExtismPlugin} Config
- */
-export type PluginConfig = Map<string, string>;
-
-/**
- * The WASM to load as bytes or a path
- */
-export type ManifestWasm = ManifestWasmFile | ManifestWasmData;
-
-/**
- * The manifest which describes the {@link ExtismPlugin} code and
- * runtime constraints.
- *
- * @see [Extism > Concepts > Manifest](https://extism.org/docs/concepts/manifest)
- */
-export type Manifest = {
-  wasm: Array<ManifestWasm>;
-  //memory?: ManifestMemory;
-  config?: PluginConfig;
-  allowed_hosts?: Array<string>;
-};

browser/src/plugin.ts

@@ -1,170 +0,0 @@
-import Allocator from './allocator';
-import { PluginConfig } from './manifest';
-
-export default class ExtismPlugin {
-  moduleData: ArrayBuffer;
-  allocator: Allocator;
-  config?: PluginConfig;
-  vars: Record<string, Uint8Array>;
-  input: Uint8Array;
-  output: Uint8Array;
-  module?: WebAssembly.WebAssemblyInstantiatedSource;
-
-  constructor(moduleData: ArrayBuffer, config?: PluginConfig) {
-    this.moduleData = moduleData;
-    this.allocator = new Allocator(1024 * 1024);
-    this.config = config;
-    this.vars = {};
-    this.input = new Uint8Array();
-    this.output = new Uint8Array();
-  }
-
-  async getExports(): Promise<WebAssembly.Exports> {
-    const module = await this._instantiateModule();
-    return module.instance.exports;
-  }
-
-  async getImports(): Promise<WebAssembly.ModuleImportDescriptor[]> {
-    const module = await this._instantiateModule();
-    return WebAssembly.Module.imports(module.module);
-  }
-
-  async getInstance(): Promise<WebAssembly.Instance> {
-    const module = await this._instantiateModule();
-    return module.instance;
-  }
-
-  async call(func_name: string, input: Uint8Array | string): Promise<Uint8Array> {
-    const module = await this._instantiateModule();
-
-    if (typeof input === 'string') {
-      this.input = new TextEncoder().encode(input);
-    } else if (input instanceof Uint8Array) {
-      this.input = input;
-    } else {
-      throw new Error('input should be string or Uint8Array');
-    }
-
-    this.allocator.reset();
-
-    let func = module.instance.exports[func_name];
-    if (!func) {
-      throw Error(`function does not exist ${func_name}`);
-    }
-    //@ts-ignore
-    func();
-    return this.output;
-  }
-
-  async _instantiateModule(): Promise<WebAssembly.WebAssemblyInstantiatedSource> {
-    if (this.module) {
-      return this.module;
-    }
-    const environment = this.makeEnv();
-    this.module = await WebAssembly.instantiate(this.moduleData, { env: environment });
-    return this.module;
-  }
-
-  makeEnv(): any {
-    const plugin = this;
-    return {
-      extism_alloc(n: bigint): bigint {
-        return plugin.allocator.alloc(n);
-      },
-      extism_free(n: bigint) {
-        plugin.allocator.free(n);
-      },
-      extism_load_u8(n: bigint): number {
-        return plugin.allocator.memory[Number(n)];
-      },
-      extism_load_u64(n: bigint): bigint {
-        let cast = new DataView(plugin.allocator.memory.buffer, Number(n));
-        return cast.getBigUint64(0, true);
-      },
-      extism_store_u8(offset: bigint, n: number) {
-        plugin.allocator.memory[Number(offset)] = Number(n);
-      },
-      extism_store_u64(offset: bigint, n: bigint) {
-        const tmp = new DataView(plugin.allocator.memory.buffer, Number(offset));
-        tmp.setBigUint64(0, n, true);
-      },
-      extism_input_length(): bigint {
-        return BigInt(plugin.input.length);
-      },
-      extism_input_load_u8(i: bigint): number {
-        return plugin.input[Number(i)];
-      },
-      extism_input_load_u64(idx: bigint): bigint {
-        let cast = new DataView(plugin.input.buffer, Number(idx));
-        return cast.getBigUint64(0, true);
-      },
-      extism_output_set(offset: bigint, length: bigint) {
-        const offs = Number(offset);
-        const len = Number(length);
-        plugin.output = plugin.allocator.memory.slice(offs, offs + len);
-      },
-      extism_error_set(i: bigint) {
-        throw plugin.allocator.getString(i);
-      },
-      extism_config_get(i: bigint): bigint {
-        if (typeof plugin.config === 'undefined') {
-          return BigInt(0);
-        }
-        const key = plugin.allocator.getString(i);
-        if (key === null) {
-          return BigInt(0);
-        }
-        const value = plugin.config.get(key);
-        if (typeof value === 'undefined') {
-          return BigInt(0);
-        }
-        return plugin.allocator.allocString(value);
-      },
-      extism_var_get(i: bigint): bigint {
-        const key = plugin.allocator.getString(i);
-        if (key === null) {
-          return BigInt(0);
-        }
-        const value = plugin.vars[key];
-        if (typeof value === 'undefined') {
-          return BigInt(0);
-        }
-        return plugin.allocator.allocBytes(value);
-      },
-      extism_var_set(n: bigint, i: bigint) {
-        const key = plugin.allocator.getString(n);
-        if (key === null) {
-          return;
-        }
-        const value = plugin.allocator.getBytes(i);
-        if (value === null) {
-          return;
-        }
-        plugin.vars[key] = value;
-      },
-      extism_http_request(n: bigint, i: bigint): number {
-        debugger;
-        return 0;
-      },
-      extism_length(i: bigint): bigint {
-        return plugin.allocator.getLength(i);
-      },
-      extism_log_warn(i: bigint) {
-        const s = plugin.allocator.getString(i);
-        console.warn(s);
-      },
-      extism_log_info(i: bigint) {
-        const s = plugin.allocator.getString(i);
-        console.log(s);
-      },
-      extism_log_debug(i: bigint) {
-        const s = plugin.allocator.getString(i);
-        console.debug(s);
-      },
-      extism_log_error(i: bigint) {
-        const s = plugin.allocator.getString(i);
-        console.error(s);
-      },
-    };
-  }
-}

browser/tsconfig.json

@@ -1,12 +0,0 @@
-{
-    "compilerOptions": {
-      "target": "es2016", 
-      "module": "commonjs",  
-      "esModuleInterop": true,
-      "forceConsistentCasingInFileNames": true,
-      "declaration": true,
-      "strict": true,                   
-      "skipLibCheck": true                  
-    },
-    "exclude": ["node_modules", "dist", "**/*.test.ts"]
-  }

browser/tslint.json

@@ -1,6 +0,0 @@
-{
-    "extends": [
-        "tslint:recommended",
-        "tslint-config-prettier"
-    ]
-}

composer.json

@@ -1,50 +1,50 @@
 {
-  "name": "extism/extism",
-  "description": "Make your software programmable. Run WebAssembly extensions in your app using the first off-the-shelf, universal plug-in system.",
-  "license": "BSD-3-Clause",
-  "type": "library",
-  "keywords": [
-    "WebAssembly",
-    "plugin-system",
-    "runtime",
-    "plug-in"
-  ],
-  "authors": [
-    {
-      "name": "The Extism Authors",
-      "email": "oss@extism.org",
-      "homepage": "https://extism.org"
+    "name": "extism/extism",
+    "description": "Make your software programmable. Run WebAssembly extensions in your app using the first off-the-shelf, universal plug-in system.",
+    "license": "BSD-3-Clause",
+    "type": "library",
+    "keywords": [
+        "WebAssembly",
+        "plugin-system",
+        "runtime",
+        "plug-in"
+    ],
+    "authors": [
+        {
+            "name": "The Extism Authors",
+            "email": "oss@extism.org",
+            "homepage": "https://extism.org"
+        },
+        {
+            "name": "Dylibso, Inc.",
+            "email": "oss@dylib.so",
+            "homepage": "https://dylib.so"
+        }
+    ],
+    "require": {
+        "php": "^7.4 || ^8",
+        "ircmaxell/ffime": "dev-master"
     },
-    {
-      "name": "Dylibso, Inc.",
-      "email": "oss@dylib.so",
-      "homepage": "https://dylib.so"
-    }
-  ],
-  "require": {
-    "php": "^7.4 || ^8",
-    "ircmaxell/ffime": "dev-master"
-  },
-  "suggest": {},
-  "minimum-stability": "dev",
-  "prefer-stable": true,
-  "autoload": {
-    "psr-4": {
-      "Extism\\": "php/src/"
+    "suggest": {},
+    "minimum-stability": "dev",
+    "prefer-stable": true,
+    "autoload": {
+        "psr-4": {
+            "Extism\\": "php/src/"
+        },
+        "files": [
+            "php/src/Plugin.php",
+            "php/src/generate.php",
+            "php/src/extism.h"
+        ]
     },
-    "files": [
-      "php/src/Context.php",
-      "php/src/Plugin.php",
-      "php/src/extism.h"
-    ]
-  },
-  "autoload-dev": {
-    "psr-4": {}
-  },
-  "config": {
-    "sort-packages": true
-  },
-  "extra": {},
-  "scripts": {},
-  "scripts-descriptions": {}
+    "autoload-dev": {
+        "psr-4": {}
+    },
+    "config": {
+        "sort-packages": true
+    },
+    "extra": {},
+    "scripts": {},
+    "scripts-descriptions": {}
 }

elixir/README.md

@@ -13,7 +13,7 @@ You can find this package on [hex.pm](https://hex.pm/packages/extism).
 ```elixir
 def deps do
   [
-    {:extism, "~> 0.0.1-rc.6"}
+    {:extism, "~> 0.0.1-rc.5"}
   ]
 end
 ```

elixir/lib/extism/context.ex

@@ -49,7 +49,7 @@ defmodule Extism.Context do
   ## Parameters
 
     - ctx: The Context to manage this plugin
-    - manifest: The String or Map of the WASM module or [manifest](https://extism.org/docs/concepts/manifest)
+    - manifest: The String or Map of the WASM module or manifest
     - wasi: A bool you set to true if you want WASI support
 
   """

elixir/lib/extism/plugin.ex

@@ -44,14 +44,6 @@ defmodule Extism.Plugin do
 
   @doc """
   Updates the manifest of the given plugin
-
-  ## Parameters
-
-    - ctx: The Context to manage this plugin
-    - manifest: The String or Map of the WASM module or [manifest](https://extism.org/docs/concepts/manifest)
-    - wasi: A bool you set to true if you want WASI support
-
-
   """
   def update(plugin, manifest, wasi) when is_map(manifest) do
     {:ok, manifest_payload} = JSON.encode(manifest)

elixir/mix.exs

@@ -4,7 +4,7 @@ defmodule Extism.MixProject do
   def project do
     [
       app: :extism,
-      version: "0.0.1",
+      version: "0.0.1-rc.5",
       elixir: "~> 1.14",
       start_permanent: Mix.env() == :prod,
       deps: deps(),

elixir/mix.lock

@@ -1,6 +1,6 @@
 %{
   "earmark_parser": {:hex, :earmark_parser, "1.4.29", "149d50dcb3a93d9f3d6f3ecf18c918fb5a2d3c001b5d3305c926cddfbd33355b", [:mix], [], "hexpm", "4902af1b3eb139016aed210888748db8070b8125c2342ce3dcae4f38dcc63503"},
-  "ex_doc": {:hex, :ex_doc, "0.29.1", "b1c652fa5f92ee9cf15c75271168027f92039b3877094290a75abcaac82a9f77", [:mix], [{:earmark_parser, "~> 1.4.19", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.14", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1", [hex: :makeup_erlang, repo: "hexpm", optional: false]}], "hexpm", "b7745fa6374a36daf484e2a2012274950e084815b936b1319aeebcf7809574f6"},
+  "ex_doc": {:hex, :ex_doc, "0.29.0", "4a1cb903ce746aceef9c1f9ae8a6c12b742a5461e6959b9d3b24d813ffbea146", [:mix], [{:earmark_parser, "~> 1.4.19", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.14", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1", [hex: :makeup_erlang, repo: "hexpm", optional: false]}], "hexpm", "f096adb8bbca677d35d278223361c7792d496b3fc0d0224c9d4bc2f651af5db1"},
   "jason": {:hex, :jason, "1.4.0", "e855647bc964a44e2f67df589ccf49105ae039d4179db7f6271dfd3843dc27e6", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "79a3791085b2a0f743ca04cec0f7be26443738779d09302e01318f97bdb82121"},
   "json": {:hex, :json, "1.4.1", "8648f04a9439765ad449bc56a3ff7d8b11dd44ff08ffcdefc4329f7c93843dfa", [:mix], [], "hexpm", "9abf218dbe4ea4fcb875e087d5f904ef263d012ee5ed21d46e9dbca63f053d16"},
   "makeup": {:hex, :makeup, "1.1.0", "6b67c8bc2882a6b6a445859952a602afc1a41c2e08379ca057c0f525366fc3ca", [:mix], [{:nimble_parsec, "~> 1.2.2 or ~> 1.3", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "0a45ed501f4a8897f580eabf99a2e5234ea3e75a4373c8a52824f6e873be57a6"},

elixir/native/extism_nif/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "extism_nif"
-version = "0.0.1-rc.6"
+version = "0.0.1-rc.5"
 edition = "2021"
 authors = ["Benjamin Eckel <bhelx@simst.im>"]
 
@@ -11,5 +11,5 @@ crate-type = ["cdylib"]
 
 [dependencies]
 rustler = "0.26.0"
-extism = { version = "0.0.1-rc.6" }
+extism = { version = "0.0.1-rc.5" }
 log = "0.4"

elixir/native/extism_nif/src/lib.rs

@@ -115,11 +115,8 @@ fn set_log_file(filename: String, log_level: String) -> Result<Atom, rustler::Er
     match log::Level::from_str(&log_level) {
         Err(_e) => Err(rustler::Error::Term(Box::new(format!("{} not a valid log level", log_level)))),
         Ok(level) => {
-            if extism::set_log_file(path, Some(level)) {
-                Ok(atoms::ok())
-            } else {
-                Err(rustler::Error::Term(Box::new("Did not set log file, received false from the API.")))
-            }
+            extism::set_log_file(path, Some(level));
+            Ok(atoms::ok())
         }
     }
 }

elixir/test/extism_test.exs

@@ -35,8 +35,6 @@ defmodule ExtismTest do
     assert JSON.decode(output) == {:ok, %{"count" => 7}}
     {:ok, output} = Extism.Plugin.call(plugin, "count_vowels", "this is a test thrice")
     assert JSON.decode(output) == {:ok, %{"count" => 6}}
-    {:ok, output} = Extism.Plugin.call(plugin, "count_vowels", "🌎hello🌎world🌎")
-    assert JSON.decode(output) == {:ok, %{"count" => 3}}
     Extism.Context.free(ctx)
   end
 

extism.go

@@ -194,7 +194,7 @@ func (plugin Plugin) SetConfig(data map[string][]byte) error {
 	return nil
 }
 
-// FunctionExists returns true when the named function is present in the plugin
+/// FunctionExists returns true when the name function is present in the plugin
 func (plugin Plugin) FunctionExists(functionName string) bool {
 	name := C.CString(functionName)
 	b := C.extism_plugin_function_exists(plugin.ctx.pointer, C.int(plugin.id), name)
@@ -202,7 +202,7 @@ func (plugin Plugin) FunctionExists(functionName string) bool {
 	return bool(b)
 }
 
-// Call a function by name with the given input, returning the output
+/// Call a function by name with the given input, returning the output
 func (plugin Plugin) Call(functionName string, input []byte) ([]byte, error) {
 	ptr := makePointer(input)
 	name := C.CString(functionName)

haskell/extism.cabal

@@ -1,6 +1,6 @@
 cabal-version:      2.4
 name:               extism
-version:            0.0.1
+version:            0.0.1.0
 
 -- A short (one-line) description of the package.
 synopsis: Extism bindings

libextism/Cargo.toml

@@ -1,23 +0,0 @@
-[package]
-name = "libextism"
-version = "0.0.1"
-edition = "2021"
-authors = ["The Extism Authors", "oss@extism.org"]
-license = "BSD-3-Clause"
-homepage = "https://extism.org"
-repository = "https://github.com/extism/extism"
-description = "libextism"
-
-[lib]
-name = "extism"
-crate-type = ["cdylib"]
-
-[dependencies]
-extism-runtime = {path = "../runtime"}
-
-[features]
-default = ["http", "register-http", "register-filesystem"]
-nn = ["extism-runtime/nn"]
-register-http = ["extism-runtime/register-http"] # enables wasm to be downloaded using http
-register-filesystem = ["extism-runtime/register-filesystem"] # enables wasm to be loaded from disk
-http = ["extism-runtime/http"] # enables extism_http_request

libextism/src/lib.rs

@@ -1,10 +0,0 @@
-//! This crate is used to generate `libextism` using `extism-runtime`
-
-pub use extism_runtime::sdk::*;
-
-#[cfg(test)]
-#[test]
-fn test_version() {
-    let s = unsafe { std::ffi::CStr::from_ptr(extism_version()) };
-    assert!(s.to_bytes() != b"0.0.0");
-}

manifest/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "extism-manifest"
-version = "0.0.1"
+version = "0.0.1-rc.5"
 edition = "2021"
 authors = ["The Extism Authors", "oss@extism.org"]
 license = "BSD-3-Clause"
@@ -9,7 +9,7 @@ repository = "https://github.com/extism/extism"
 description = "Extism plug-in manifest crate"
 
 [dependencies]
-serde = {version = "1", features = ["derive"]}
+serde = {version = "1", features=["derive"]}
 base64 = "0.20.0-alpha"
 schemars = {version = "0.8", optional=true}
 

node/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@extism/extism",
-  "version": "0.0.1",
+  "version": "0.0.1-rc.5",
   "description": "Extism Host SDK for Node",
   "keywords": [
     "extism",
@@ -36,7 +36,7 @@
     "@types/jest": "^29.2.0",
     "@types/node": "^18.11.4",
     "jest": "^29.2.2",
-    "prettier": "2.8.0",
+    "prettier": "2.7.1",
     "ts-jest": "^29.0.3",
     "ts-node": "^10.9.1",
     "typedoc": "^0.23.18",

node/src/index.ts

@@ -161,8 +161,6 @@ export type ManifestWasm = ManifestWasmFile | ManifestWasmData;
 /**
  * The manifest which describes the {@link Plugin} code and
  * runtime constraints.
- * 
- * @see [Extism > Concepts > Manifest](https://extism.org/docs/concepts/manifest)
  */
 export type Manifest = {
   wasm: Array<ManifestWasm>;
@@ -218,7 +216,7 @@ export class Context {
   /**
    * Create a plugin managed by this context
    *
-   * @param manifest - The {@link Manifest} describing the plugin code and config
+   * @param manifest - The Manifest describing the plugin code and config
    * @param wasi - Set to `true` to enable WASI
    * @param config - Config details for the plugin
    * @returns A new Plugin scoped to this Context
@@ -277,7 +275,7 @@ export class Plugin {
    * Constructor for a plugin. @see {@link Context#plugin}.
    *
    * @param ctx - The context to manage this plugin
-   * @param manifest - The {@link Manifest}
+   * @param manifest - The manifest
    * @param wasi - Set to true to enable WASI support
    * @param config - The plugin config
    */
@@ -299,7 +297,7 @@ export class Plugin {
     let plugin = lib.extism_plugin_new(
       ctx.pointer,
       dataRaw,
-      Buffer.byteLength(dataRaw, 'utf-8'),
+      dataRaw.length,
       wasi
     );
     if (plugin < 0) {
@@ -319,14 +317,14 @@ export class Plugin {
 
     if (config != null) {
       let s = JSON.stringify(config);
-      lib.extism_plugin_config(ctx.pointer, this.id, s, Buffer.byteLength(s, 'utf-8'),);
+      lib.extism_plugin_config(ctx.pointer, this.id, s, s.length);
     }
   }
 
   /**
    * Update an existing plugin with new WASM or manifest
    *
-   * @param manifest - The new {@link Manifest} data
+   * @param manifest - The new manifest data
    * @param wasi - Set to true to enable WASI support
    * @param config - The new plugin config
    */
@@ -344,7 +342,7 @@ export class Plugin {
       this.ctx.pointer,
       this.id,
       dataRaw,
-      Buffer.byteLength(dataRaw, 'utf-8'),
+      dataRaw.length,
       wasi
     );
     if (!ok) {
@@ -357,7 +355,7 @@ export class Plugin {
 
     if (config != null) {
       let s = JSON.stringify(config);
-      lib.extism_plugin_config(this.ctx.pointer, this.id, s, Buffer.byteLength(s, 'utf-8'),);
+      lib.extism_plugin_config(this.ctx.pointer, this.id, s, s.length);
     }
   }
 
@@ -401,7 +399,7 @@ export class Plugin {
         this.id,
         functionName,
         input.toString(),
-        Buffer.byteLength(input, 'utf-8'),
+        input.length
       );
       if (rc !== 0) {
         var err = lib.extism_error(this.ctx.pointer, this.id);

node/tests/index.test.ts

@@ -31,9 +31,6 @@ describe("test extism", () => {
       output = await plugin.call("count_vowels", "this is a test thrice");
       result = JSON.parse(output.toString());
       expect(result["count"]).toBe(6);
-      output = await plugin.call("count_vowels", "🌎hello🌎world🌎");
-      result = JSON.parse(output.toString());
-      expect(result["count"]).toBe(3);
     });
   });
 

php/example/composer.json

@@ -1,22 +1,22 @@
 {
-  "name": "extism/example",
-  "description": "Example running the Extism PHP Host SDK",
-  "license": "BSD-3-Clause",
-  "type": "project",
-  "authors": [
-    {
-      "name": "The Extism Authors",
-      "email": "oss@extism.org"
-    }
-  ],
-  "require": {
-    "extism/extism": "*"
-  },
-  "repositories": [
-    {
-      "type": "path",
-      "url": "../../"
-    }
-  ],
-  "minimum-stability": "dev"
+    "name": "extism/example",
+    "description": "Example running the Extism PHP Host SDK",
+    "license": "BSD-3-Clause",
+    "type": "project",
+    "authors": [
+        {
+            "name": "The Extism Authors",
+            "email": "oss@extism.org"
+        }
+    ],
+    "require": {
+        "extism/extism": "*"
+    },
+    "repositories": [
+        {
+            "type": "path",
+            "url": "../../"
+        }
+    ],
+    "minimum-stability": "dev"
 }

php/example/composer.lock

@@ -8,11 +8,11 @@
     "packages": [
         {
             "name": "extism/extism",
-            "version": "dev-php-sdk-fix",
+            "version": "dev-feat-reuse-plugins",
             "dist": {
                 "type": "path",
                 "url": "../..",
-                "reference": "6119eae37bcb2e02f7c7b5b203ab9f959819e83d"
+                "reference": "9e5f576acff0aa9c8720fdf6d1103b7c1996bf14"
             },
             "require": {
                 "ircmaxell/ffime": "dev-master",
@@ -22,12 +22,7 @@
             "autoload": {
                 "psr-4": {
                     "Extism\\": "php/src/"
-                },
-                "files": [
-                    "php/src/Context.php",
-                    "php/src/Plugin.php",
-                    "php/src/extism.h"
-                ]
+                }
             },
             "autoload-dev": {
                 "psr-4": []
@@ -64,12 +59,12 @@
             "source": {
                 "type": "git",
                 "url": "https://github.com/ircmaxell/FFIMe.git",
-                "reference": "f6911d7a6a7090a9782a21a946819a2efa9a2ff7"
+                "reference": "7b9e0bf23adceddd5fde3130d30275a45cfc1867"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/ircmaxell/FFIMe/zipball/f6911d7a6a7090a9782a21a946819a2efa9a2ff7",
-                "reference": "f6911d7a6a7090a9782a21a946819a2efa9a2ff7",
+                "url": "https://api.github.com/repos/ircmaxell/FFIMe/zipball/7b9e0bf23adceddd5fde3130d30275a45cfc1867",
+                "reference": "7b9e0bf23adceddd5fde3130d30275a45cfc1867",
                 "shasum": ""
             },
             "require": {
@@ -102,7 +97,7 @@
                 "issues": "https://github.com/ircmaxell/FFIMe/issues",
                 "source": "https://github.com/ircmaxell/FFIMe/tree/master"
             },
-            "time": "2022-09-25T18:13:59+00:00"
+            "time": "2022-09-07T19:50:56+00:00"
         },
         {
             "name": "ircmaxell/php-c-parser",
@@ -110,12 +105,12 @@
             "source": {
                 "type": "git",
                 "url": "https://github.com/ircmaxell/php-c-parser.git",
-                "reference": "fd8f5efefd0fcc6c5119d945694acaa3a6790ada"
+                "reference": "55e0a4fdf88d6e955d928860e1e107a68492c1cf"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/ircmaxell/php-c-parser/zipball/fd8f5efefd0fcc6c5119d945694acaa3a6790ada",
-                "reference": "fd8f5efefd0fcc6c5119d945694acaa3a6790ada",
+                "url": "https://api.github.com/repos/ircmaxell/php-c-parser/zipball/55e0a4fdf88d6e955d928860e1e107a68492c1cf",
+                "reference": "55e0a4fdf88d6e955d928860e1e107a68492c1cf",
                 "shasum": ""
             },
             "require": {
@@ -151,7 +146,7 @@
                 "issues": "https://github.com/ircmaxell/php-c-parser/issues",
                 "source": "https://github.com/ircmaxell/php-c-parser/tree/master"
             },
-            "time": "2022-09-23T19:39:35+00:00"
+            "time": "2022-08-27T17:37:14+00:00"
         },
         {
             "name": "ircmaxell/php-object-symbolresolver",
@@ -159,12 +154,12 @@
             "source": {
                 "type": "git",
                 "url": "https://github.com/ircmaxell/php-object-symbolresolver.git",
-                "reference": "dfe1b1aa6c15b198bdef50fff8485e98e89f2a09"
+                "reference": "88c918a0f4621ef59dc4a4c21ead7f39bd720337"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/ircmaxell/php-object-symbolresolver/zipball/dfe1b1aa6c15b198bdef50fff8485e98e89f2a09",
-                "reference": "dfe1b1aa6c15b198bdef50fff8485e98e89f2a09",
+                "url": "https://api.github.com/repos/ircmaxell/php-object-symbolresolver/zipball/88c918a0f4621ef59dc4a4c21ead7f39bd720337",
+                "reference": "88c918a0f4621ef59dc4a4c21ead7f39bd720337",
                 "shasum": ""
             },
             "require": {
@@ -196,7 +191,7 @@
                 "issues": "https://github.com/ircmaxell/php-object-symbolresolver/issues",
                 "source": "https://github.com/ircmaxell/php-object-symbolresolver/tree/master"
             },
-            "time": "2022-09-15T18:21:50+00:00"
+            "time": "2022-09-07T19:47:04+00:00"
         }
     ],
     "packages-dev": [],

php/src/Context.php

@@ -3,37 +3,12 @@ declare(strict_types=1);
 namespace Extism;
 
 require_once "vendor/autoload.php";
-
-function generate_extism_lib() {
-    return (new \FFIMe\FFIMe("libextism.".soext()))
-        ->include("extism.h")
-        ->showWarnings(false)
-        ->codeGen('ExtismLib', __DIR__.'/ExtismLib.php');
-}
-
-function soext() {
-    $platform = php_uname("s");
-    switch ($platform) {
-        case "Darwin":
-            return "dylib";
-        case "Linux": 
-            return "so";
-        case "Windows":
-            return "dll";
-        default:
-            throw new \Exception("Extism: unsupported platform ".$platform);
-    }
-}
-
-if (!file_exists(__DIR__."/ExtismLib.php")) {
-    generate_extism_lib();
-}
-
+require_once "generate.php";
 require_once "ExtismLib.php";
 
 $lib = new \ExtismLib(\ExtismLib::SOFILE);
 if ($lib == null) {
-    throw new \Exception("Extism: failed to create new runtime instance");
+    throw new Exception("Extism: failed to create new runtime instance");
 }
 
 class Context

php/src/Plugin.php

@@ -2,6 +2,8 @@
 declare(strict_types=1);
 namespace Extism;
 
+require_once "vendor/autoload.php";
+require_once "generate.php";
 require_once "ExtismLib.php";
 
 class Plugin
@@ -32,13 +34,13 @@ class Plugin
         $id = $this->lib->extism_plugin_new($ctx->pointer, $data, count($data), (int)$wasi);
         if ($id < 0) {
             $err = $this->lib->extism_error($ctx->pointer, -1);
-            throw new \Exception("Extism: unable to load plugin: " . $err);
+            throw new Exception("Extism: unable to load plugin: " . $err);
         }
         $this->id = $id;
         $this->context = $ctx;
 
-        if ($this->config != null) {
-            $cfg = string_to_bytes(json_encode($config));
+        if ($config != null) {
+            $cfg = string_to_bytes(json_encode(config));
             $this->lib->extism_plugin_config($ctx->pointer, $this->id, $cfg, count($cfg));
         }
     }
@@ -71,14 +73,14 @@ class Plugin
             if ($err) {
                 $msg = $msg . ", error = " . $err;
             }
-            throw new \Exception("Extism: call to '".$name."' failed with " . $msg);
+            throw new Execption("Extism: call to '".$name."' failed with " . $msg);
         }
 
         $length = $this->lib->extism_plugin_output_length($this->context->pointer, $this->id);
 
         $buf = $this->lib->extism_plugin_output_data($this->context->pointer, $this->id);
 
-        $output = [];
+        $ouput = [];
         $data = $buf->getData();
         for ($i = 0; $i < $length; $i++) {
             $output[$i] = $data[$i];
@@ -99,7 +101,7 @@ class Plugin
         $ok = $this->lib->extism_plugin_update($this->context->pointer, $this->id, $data, count($data), (int)$wasi);
         if (!$ok) {
             $err = $this->lib->extism_error($this->context->pointer, -1);
-            throw new \Exception("Extism: unable to update plugin: " . $err);
+            throw new Exception("Extism: unable to update plugin: " . $err);
         }
 
         if ($config != null) {

php/src/generate.php

@@ -0,0 +1,29 @@
+<?php
+require_once "vendor/autoload.php";
+
+
+function generate() {
+    return (new FFIMe\FFIMe("libextism.".soext()))
+        ->include("extism.h")
+        ->showWarnings(false)
+        ->codeGen('ExtismLib', __DIR__.'/ExtismLib.php');
+}
+
+function soext() {
+    $platform = php_uname("s");
+    switch ($platform) {
+        case "Darwin":
+            return "dylib";
+        case "Linux": 
+            return "so";
+        case "Windows":
+            return "dll";
+        default:
+            throw new Exeception("Extism: unsupported platform ".$platform);
+    }
+}
+
+if (!file_exists(__DIR__."/ExtismLib.php")) {
+    generate();
+}
+    

python/extism/extism.py

@@ -168,7 +168,7 @@ class Context:
         Parameters
         ----------
         manifest : Union[str, bytes, dict]
-            A manifest dictionary describing the plugin or the raw bytes for a module. See [Extism > Concepts > Manifest](https://extism.org/docs/concepts/manifest/).
+            A manifest dictionary describing the plugin or the raw bytes for a module
         wasi : bool
             Set to `True` to enable WASI support
         config : dict
@@ -220,7 +220,7 @@ class Plugin:
         Parameters
         ----------
         plugin : Union[str, bytes, dict]
-            A manifest dictionary describing the plugin or the raw bytes for a module. See [Extism > Concepts > Manifest](https://extism.org/docs/concepts/manifest/).
+            A manifest dictionary describing the plugin or the raw bytes for a module
         wasi : bool
             Set to `True` to enable WASI support
         config : dict

python/pyproject.toml

@@ -1,10 +1,9 @@
 [tool.poetry]
 name = "extism"
-version = "0.0.1"
-description = "Extism Host SDK for python"
+version = "0.0.1-rc.5"
+description = ""
 authors = ["The Extism Authors <oss@extism.org>"]
 license = "BSD-3-Clause"
-readme = "../README.md"
 
 [tool.poetry.dependencies]
 python = "^3.7"

python/tests/test_extism.py

@@ -20,8 +20,6 @@ class TestExtism(unittest.TestCase):
             self.assertEqual(j["count"], 7)
             j = json.loads(plugin.call("count_vowels", "this is a test thrice"))
             self.assertEqual(j["count"], 6)
-            j = json.loads(plugin.call("count_vowels", "🌎hello🌎world🌎"))
-            self.assertEqual(j["count"], 3)
 
     def test_update_plugin_manifest(self):
         with extism.Context() as ctx:

ruby/lib/extism.rb

@@ -86,7 +86,7 @@ module Extism
 
     # Create a new plugin from a WASM module or JSON encoded manifest
     #
-    # @param wasm [Hash, String] The manifest for the plugin. See https://extism.org/docs/concepts/manifest/.
+    # @param wasm [Hash, String] The manifest for the plugin
     # @param wasi [Boolean] Enable WASI support
     # @param config [Hash] The plugin config
     # @return [Plugin]
@@ -121,7 +121,7 @@ module Extism
     #
     # @see Extism::Context#plugin
     # @param context [Context] The context to manager this plugin
-    # @param wasm [Hash, String] The manifest or WASM binary. See https://extism.org/docs/concepts/manifest/.
+    # @param wasm [Hash, String] The manifest or WASM binary
     # @param wasi [Boolean] Enable WASI support
     # @param config [Hash] The plugin config
     def initialize(context, wasm, wasi = false, config = nil)
@@ -151,7 +151,7 @@ module Extism
 
     # Update a plugin with new WASM module or manifest
     #
-    # @param wasm [Hash, String] The manifest or WASM binary. See https://extism.org/docs/concepts/manifest/.
+    # @param wasm [Hash, String] The manifest or WASM binary
     # @param wasi [Boolean] Enable WASI support
     # @param config [Hash] The plugin config
     # @return [void]

ruby/lib/extism/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Extism
-  VERSION = "0.0.1"
+  VERSION = "0.0.1.rc4"
 end

ruby/test/test_extism.rb

@@ -20,8 +20,6 @@ class TestExtism < Minitest::Test
       assert_equal res["count"], 7
       res = JSON.parse(plugin.call("count_vowels", "this is a test thrice"))
       assert_equal res["count"], 6
-      res = JSON.parse(plugin.call("count_vowels", "🌎hello🌎world🌎"))
-      assert_equal res["count"], 3
     end
   end
 

runtime/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "extism-runtime"
-version = "0.0.1"
+version = "0.0.1-rc.5"
 edition = "2021"
 authors = ["The Extism Authors", "oss@extism.org"]
 license = "BSD-3-Clause"
@@ -8,21 +8,27 @@ homepage = "https://extism.org"
 repository = "https://github.com/extism/extism"
 description = "Extism runtime component"
 
+[lib]
+name = "extism"
+crate-type = ["cdylib"]
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
 [dependencies]
-wasmtime = "3.0.0"
-wasmtime-wasi = "3.0.0"
-wasmtime-wasi-nn = {version = "3.0.0", optional=true}
+wasmtime = "1.0.0"
+wasmtime-wasi = "1.0.0"
+wasmtime-wasi-nn = {version = "1.0.1", optional=true}
 anyhow = "1"
-serde = {version = "1", features = ["derive"]}
-serde_json = "1"
+serde = { version = "1", features=["derive"] }
 toml = "0.5"
+serde_json = "1"
 sha2 = "0.10"
 log = "0.4"
 log4rs = "1.1"
-url = "2"
+url = "2.3"
 glob = "0.3"
 ureq = {version = "2.5", optional=true}
-extism-manifest = { version = "0.0.1-rc.6", path = "../manifest" }
+extism-manifest = { version = "0.0.1-rc.4", path = "../manifest" }
 pretty-hex = { version = "0.3" }
 
 [features]

runtime/build.rs

@@ -1,6 +1,10 @@
+use std::env;
+
 fn main() {
+    let crate_dir = env::var("CARGO_MANIFEST_DIR").unwrap();
+
     if let Ok(bindings) = cbindgen::Builder::new()
-        .with_crate(".")
+        .with_crate(crate_dir)
         .with_language(cbindgen::Language::C)
         .with_no_includes()
         .with_sys_include("stdint.h")

runtime/src/context.rs

@@ -29,7 +29,7 @@ impl Context {
 
     /// Get the next valid plugin ID
     pub fn next_id(&mut self) -> Result<PluginIndex, Error> {
-        // Make sure we haven't exhausted all plugin IDs, to reach this it would require the machine
+        // Make sure we haven't exhausted all plugin IDs, it reach this it would require the machine
         // running this code to have a lot of memory - no computer I tested on was able to allocate
         // the max number of plugins.
         //
@@ -37,7 +37,7 @@ impl Context {
         // try to use one of those before returning an error
         let exhausted = self.next_id.load(std::sync::atomic::Ordering::SeqCst) == PluginIndex::MAX;
 
-        // If there are a significant number of old IDs we can start to re-use them
+        // If there is a significant number of old IDs we can start to re-use them
         if self.reclaimed_ids.len() >= START_REUSING_IDS || exhausted {
             if let Some(x) = self.reclaimed_ids.pop_front() {
                 return Ok(x);
@@ -55,32 +55,6 @@ impl Context {
             .fetch_add(1, std::sync::atomic::Ordering::SeqCst))
     }
 
-    pub fn insert(&mut self, plugin: Plugin) -> PluginIndex {
-        // Generate a new plugin ID
-        let id: i32 = match self.next_id() {
-            Ok(id) => id,
-            Err(e) => {
-                error!("Error creating Plugin: {:?}", e);
-                self.set_error(e);
-                return -1;
-            }
-        };
-        self.plugins.insert(id, plugin);
-        id
-    }
-
-    pub fn new_plugin(&mut self, data: impl AsRef<[u8]>, with_wasi: bool) -> PluginIndex {
-        let plugin = match Plugin::new(data, with_wasi) {
-            Ok(x) => x,
-            Err(e) => {
-                error!("Error creating Plugin: {:?}", e);
-                self.set_error(e);
-                return -1;
-            }
-        };
-        self.insert(plugin)
-    }
-
     /// Set the context error
     pub fn set_error(&mut self, e: impl std::fmt::Debug) {
         trace!("Set context error: {:?}", e);
@@ -104,9 +78,9 @@ impl Context {
 
     /// Remove a plugin from the context
     pub fn remove(&mut self, id: PluginIndex) {
-        if self.plugins.remove(&id).is_some() {
-            // Collect old IDs in case we need to re-use them
-            self.reclaimed_ids.push_back(id);
-        }
+        self.plugins.remove(&id);
+
+        // Collect old IDs in case we need to re-use them
+        self.reclaimed_ids.push_back(id);
     }
 }

runtime/src/export.rs

@@ -7,7 +7,7 @@ macro_rules! args {
     ($input:expr, $index:expr, $ty:ident) => {
         match $input[$index].$ty() {
             Some(x) => x,
-            None => return Err(Error::msg("Invalid input type"))
+            None => return Err(Trap::new("Invalid input type"))
         }
     };
     ($input:expr, $(($index:expr, $ty:ident)),*$(,)?) => {
@@ -24,7 +24,7 @@ pub(crate) fn input_length(
     caller: Caller<Internal>,
     _input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &Internal = caller.data();
     output[0] = Val::I64(data.input_length as i64);
     Ok(())
@@ -37,7 +37,7 @@ pub(crate) fn input_load_u8(
     caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &Internal = caller.data();
     if data.input.is_null() {
         return Ok(());
@@ -53,7 +53,7 @@ pub(crate) fn input_load_u64(
     caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &Internal = caller.data();
     if data.input.is_null() {
         return Ok(());
@@ -72,10 +72,12 @@ pub(crate) fn store_u8(
     mut caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let (offset, byte) = args!(input, (0, i64), (1, i32));
-    data.memory_mut().store_u8(offset as usize, byte as u8)?;
+    data.memory_mut()
+        .store_u8(offset as usize, byte as u8)
+        .map_err(|_| Trap::new("Write error"))?;
     Ok(())
 }
 
@@ -86,14 +88,51 @@ pub(crate) fn load_u8(
     caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &Internal = caller.data();
     let offset = args!(input, 0, i64) as usize;
-    let byte = data.memory().load_u8(offset)?;
+    let byte = data
+        .memory()
+        .load_u8(offset)
+        .map_err(|_| Trap::new("Read error"))?;
     output[0] = Val::I32(byte as i32);
     Ok(())
 }
 
+/// Store an unsigned 32 bit integer in memory
+/// Params: i64 (offset), i32 (int)
+/// Returns: none
+pub(crate) fn store_u32(
+    mut caller: Caller<Internal>,
+    input: &[Val],
+    _output: &mut [Val],
+) -> Result<(), Trap> {
+    let data: &mut Internal = caller.data_mut();
+    let (offset, b) = args!(input, (0, i64), (1, i32));
+    data.memory_mut()
+        .store_u32(offset as usize, b as u32)
+        .map_err(|_| Trap::new("Write error"))?;
+    Ok(())
+}
+
+/// Load an unsigned 32 bit integer from memory
+/// Params: i64 (offset)
+/// Returns: i32 (int)
+pub(crate) fn load_u32(
+    caller: Caller<Internal>,
+    input: &[Val],
+    output: &mut [Val],
+) -> Result<(), Trap> {
+    let data: &Internal = caller.data();
+    let offset = args!(input, 0, i64) as usize;
+    let b = data
+        .memory()
+        .load_u32(offset)
+        .map_err(|_| Trap::new("Read error"))?;
+    output[0] = Val::I32(b as i32);
+    Ok(())
+}
+
 /// Store an unsigned 64 bit integer in memory
 /// Params: i64 (offset), i64 (int)
 /// Returns: none
@@ -101,10 +140,12 @@ pub(crate) fn store_u64(
     mut caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let (offset, b) = args!(input, (0, i64), (1, i64));
-    data.memory_mut().store_u64(offset as usize, b as u64)?;
+    data.memory_mut()
+        .store_u64(offset as usize, b as u64)
+        .map_err(|_| Trap::new("Write error"))?;
     Ok(())
 }
 
@@ -115,10 +156,13 @@ pub(crate) fn load_u64(
     caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &Internal = caller.data();
     let offset = args!(input, 0, i64) as usize;
-    let byte = data.memory().load_u64(offset)?;
+    let byte = data
+        .memory()
+        .load_u64(offset)
+        .map_err(|_| Trap::new("Read error"))?;
     output[0] = Val::I64(byte as i64);
     Ok(())
 }
@@ -130,7 +174,7 @@ pub(crate) fn output_set(
     mut caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let (offset, length) = args!(input, (0, i64), (1, i64));
     data.output_offset = offset as usize;
@@ -145,7 +189,7 @@ pub(crate) fn alloc(
     mut caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let offs = data.memory_mut().alloc(input[0].unwrap_i64() as _)?;
     output[0] = Val::I64(offs.offset as i64);
@@ -160,7 +204,7 @@ pub(crate) fn free(
     mut caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let offset = args!(input, 0, i64) as usize;
     data.memory_mut().free(offset);
@@ -174,7 +218,7 @@ pub(crate) fn error_set(
     mut caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let offset = args!(input, 0, i64) as usize;
 
@@ -196,7 +240,7 @@ pub(crate) fn config_get(
     mut caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let plugin = data.plugin_mut();
 
@@ -221,7 +265,7 @@ pub(crate) fn var_get(
     mut caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let plugin = data.plugin_mut();
 
@@ -248,7 +292,7 @@ pub(crate) fn var_set(
     mut caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let plugin = data.plugin_mut();
 
@@ -261,7 +305,7 @@ pub(crate) fn var_set(
 
     // If the store is larger than 100MB then stop adding things
     if size > 1024 * 1024 * 100 && voffset != 0 {
-        return Err(Error::msg("Variable store is full"));
+        return Err(Trap::new("Variable store is full"));
     }
 
     let key_offs = args!(input, 0, i64) as usize;
@@ -288,12 +332,12 @@ pub(crate) fn http_request(
     #[allow(unused_mut)] mut caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     #[cfg(not(feature = "http"))]
     {
         let _ = (caller, input);
 
-        output[0] = Val::I64(0);
+        output[0] = Val::I64(0 as i64);
         error!("http_request is not enabled");
         return Ok(());
     }
@@ -305,13 +349,14 @@ pub(crate) fn http_request(
         let http_req_offset = args!(input, 0, i64) as usize;
 
         let req: extism_manifest::HttpRequest =
-            serde_json::from_slice(data.memory().get(http_req_offset)?)?;
+            serde_json::from_slice(data.memory().get(http_req_offset)?)
+                .map_err(|_| Trap::new("Invalid http request"))?;
 
         let body_offset = args!(input, 1, i64) as usize;
 
         let url = match url::Url::parse(&req.url) {
             Ok(u) => u,
-            Err(e) => return Err(Error::msg(format!("Invalid URL: {e:?}"))),
+            Err(e) => return Err(Trap::new(format!("Invalid URL: {e:?}"))),
         };
         let allowed_hosts = &data.plugin().manifest.as_ref().allowed_hosts;
         let host_str = url.host_str().unwrap_or_default();
@@ -325,7 +370,7 @@ pub(crate) fn http_request(
                 pat.matches(host_str)
             });
             if !allowed_hosts.is_empty() && !host_matches_allowed {
-                return Err(Error::msg(format!(
+                return Err(Trap::new(format!(
                     "HTTP request to {} is not allowed",
                     req.url
                 )));
@@ -338,20 +383,20 @@ pub(crate) fn http_request(
             r = r.set(k, v);
         }
 
-        let res = if body_offset > 0 {
+        let mut res = if body_offset > 0 {
             let buf = data.memory().get(body_offset)?;
-            let res = r.send_bytes(buf)?;
-            data.http_status = res.status();
-            res.into_reader()
+            r.send_bytes(buf)
+                .map_err(|e| Trap::new(&format!("Request error: {e:?}")))?
+                .into_reader()
         } else {
-            let res = r.call()?;
-            data.http_status = res.status();
-            res.into_reader()
+            r.call()
+                .map_err(|e| Trap::new(format!("{:?}", e)))?
+                .into_reader()
         };
 
         let mut buf = Vec::new();
-        res.take(1024 * 1024 * 50) // TODO: make this limit configurable
-            .read_to_end(&mut buf)?;
+        res.read_to_end(&mut buf)
+            .map_err(|e| Trap::new(format!("{:?}", e)))?;
 
         let mem = data.memory_mut().alloc_bytes(buf)?;
 
@@ -360,19 +405,6 @@ pub(crate) fn http_request(
     }
 }
 
-/// Get the status code of the last HTTP request
-/// Params: none
-/// Returns: i32 (status code)
-pub(crate) fn http_status_code(
-    mut caller: Caller<Internal>,
-    _input: &[Val],
-    output: &mut [Val],
-) -> Result<(), Error> {
-    let data: &mut Internal = caller.data_mut();
-    output[0] = Val::I32(data.http_status as i32);
-    Ok(())
-}
-
 /// Get the length of an allocated block given the offset
 /// Params: i64 (offset)
 /// Returns: i64 (length or 0)
@@ -380,7 +412,7 @@ pub(crate) fn length(
     mut caller: Caller<Internal>,
     input: &[Val],
     output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &mut Internal = caller.data_mut();
     let offset = args!(input, 0, i64) as usize;
     if offset == 0 {
@@ -389,7 +421,7 @@ pub(crate) fn length(
     }
     let length = match data.memory().block_length(offset) {
         Some(x) => x,
-        None => return Err(Error::msg("Unable to find length for offset")),
+        None => return Err(Trap::new("Unable to find length for offset")),
     };
     output[0] = Val::I64(length as i64);
     Ok(())
@@ -400,7 +432,7 @@ pub fn log(
     caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     let data: &Internal = caller.data();
     let offset = args!(input, 0, i64) as usize;
     let buf = data.memory().get(offset)?;
@@ -419,7 +451,7 @@ pub(crate) fn log_warn(
     caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     log(log::Level::Warn, caller, input, _output)
 }
 
@@ -430,7 +462,7 @@ pub(crate) fn log_info(
     caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     log(log::Level::Info, caller, input, _output)
 }
 
@@ -441,7 +473,7 @@ pub(crate) fn log_debug(
     caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     log(log::Level::Debug, caller, input, _output)
 }
 
@@ -452,6 +484,6 @@ pub(crate) fn log_error(
     caller: Caller<Internal>,
     input: &[Val],
     _output: &mut [Val],
-) -> Result<(), Error> {
+) -> Result<(), Trap> {
     log(log::Level::Error, caller, input, _output)
 }

runtime/src/lib.rs

@@ -2,9 +2,9 @@ pub use anyhow::Error;
 pub(crate) use wasmtime::*;
 
 mod context;
+pub(crate) mod export;
 pub mod manifest;
 mod memory;
-pub(crate) mod pdk;
 mod plugin;
 mod plugin_ref;
 pub mod sdk;

runtime/src/memory.rs

@@ -84,6 +84,30 @@ impl PluginMemory {
         Ok(self.memory.data(&self.store)[offs])
     }
 
+    /// Write u32 to memory
+    pub(crate) fn store_u32(&mut self, offs: usize, data: u32) -> Result<(), Error> {
+        trace!("store_u32: {data:x} at offset {offs}");
+        let handle = MemoryBlock {
+            offset: offs,
+            length: 4,
+        };
+        self.write(handle, data.to_ne_bytes())?;
+        Ok(())
+    }
+
+    /// Read u32 from memory
+    pub(crate) fn load_u32(&self, offs: usize) -> Result<u32, Error> {
+        trace!("load_u32: offset {offs}");
+        let mut buf = [0; 4];
+
+        let handle = MemoryBlock {
+            offset: offs,
+            length: 4,
+        };
+        self.read(handle, &mut buf)?;
+        Ok(u32::from_ne_bytes(buf))
+    }
+
     /// Write u64 to memory
     pub(crate) fn store_u64(&mut self, offs: usize, data: u64) -> Result<(), Error> {
         trace!("store_u64: {data:x} at offset {offs}");

runtime/src/plugin.rs

@@ -20,7 +20,6 @@ pub struct Internal {
     pub output_length: usize,
     pub plugin: *mut Plugin,
     pub wasi: Option<Wasi>,
-    pub http_status: u16,
 }
 
 pub struct Wasi {
@@ -43,7 +42,6 @@ impl Internal {
             let nn = wasmtime_wasi_nn::WasiNnCtx::new()?;
 
             #[cfg(not(feature = "nn"))]
-            #[allow(clippy::let_unit_value)]
             let nn = ();
 
             Some(Wasi {
@@ -61,7 +59,6 @@ impl Internal {
             input: std::ptr::null(),
             wasi,
             plugin: std::ptr::null_mut(),
-            http_status: 0,
         })
     }
 
@@ -118,7 +115,7 @@ impl Plugin {
                 $(
                     concat!("extism_", stringify!($name)) => {
                         let t = FuncType::new([$($args),*], [$($($r),*)?]);
-                        let f = Func::new(&mut memory.store, t, pdk::$name);
+                        let f = Func::new(&mut memory.store, t, export::$name);
                         linker.define(EXPORT_MODULE_NAME, concat!("extism_", stringify!($name)), Extern::Func(f))?;
                         continue
                     }
@@ -140,8 +137,10 @@ impl Plugin {
                         alloc(I64) -> I64;
                         free(I64);
                         load_u8(I64) -> I32;
+                        load_u32(I64) -> I32;
                         load_u64(I64) -> I64;
                         store_u8(I64, I32);
+                        store_u32(I64, I32);
                         store_u64(I64, I64);
                         input_length() -> I64;
                         input_load_u8(I64) -> I32;
@@ -152,7 +151,6 @@ impl Plugin {
                         var_get(I64) -> I64;
                         var_set(I64, I64);
                         http_request(I64, I64) -> I64;
-                        http_status_code() -> I32;
                         length(I64) -> I64;
                         log_warn(I64);
                         log_info(I64);

runtime/src/sdk.rs

@@ -36,8 +36,29 @@ pub unsafe extern "C" fn extism_plugin_new(
 ) -> PluginIndex {
     trace!("Call to extism_plugin_new with wasm pointer {:?}", wasm);
     let ctx = &mut *ctx;
+
     let data = std::slice::from_raw_parts(wasm, wasm_size as usize);
-    ctx.new_plugin(data, with_wasi)
+    let plugin = match Plugin::new(data, with_wasi) {
+        Ok(x) => x,
+        Err(e) => {
+            error!("Error creating Plugin: {:?}", e);
+            ctx.set_error(e);
+            return -1;
+        }
+    };
+
+    // Allocate a new plugin ID
+    let id: i32 = match ctx.next_id() {
+        Ok(id) => id,
+        Err(e) => {
+            error!("Error creating Plugin: {:?}", e);
+            ctx.set_error(e);
+            return -1;
+        }
+    };
+    ctx.plugins.insert(id, plugin);
+    info!("New plugin added: {id}");
+    id
 }
 
 /// Update a plugin, keeping the existing ID
@@ -221,29 +242,12 @@ pub unsafe extern "C" fn extism_plugin_call(
         None => return plugin.error(format!("Function not found: {name}"), -1),
     };
 
-    // Check the number of results, reject functions with more than 1 result
-    let n_results = func.ty(&plugin.memory.store).results().len();
-    if n_results > 1 {
-        return plugin.error(
-            format!("Function {name} has {n_results} results, expected 0 or 1"),
-            -1,
-        );
-    }
-
-    let mut results = vec![Val::null(); n_results];
+    // Call function with offset+length pointing to input data.
+    let mut results = vec![Val::I32(0)];
     match func.call(&mut plugin.memory.store, &[], results.as_mut_slice()) {
         Ok(r) => r,
         Err(e) => {
             plugin.dump_memory();
-
-            if let Some(exit) = e.downcast_ref::<wasmtime_wasi::I32Exit>() {
-                error!("WASI return code: {}", exit.0);
-                if exit.0 != 0 {
-                    return plugin.error(&e, exit.0);
-                }
-                return exit.0;
-            }
-
             error!("Call: {e:?}");
             return plugin.error(e.context("Call failed"), -1);
         }
@@ -251,12 +255,6 @@ pub unsafe extern "C" fn extism_plugin_call(
 
     plugin.dump_memory();
 
-    // If `results` is empty then the return value is expected to be returned
-    // in the error block of the func call above using `I32Exit`
-    if results.is_empty() {
-        return 0;
-    }
-
     // Return result to caller
     results[0].unwrap_i32()
 }

rust/Cargo.toml

@@ -1,16 +1,15 @@
 [package]
 name = "extism"
-version = "0.0.1"
+version = "0.0.1-rc.5"
 edition = "2021"
 authors = ["The Extism Authors", "oss@extism.org"]
 license = "BSD-3-Clause"
+links = "extism"
 homepage = "https://extism.org"
 repository = "https://github.com/extism/extism"
 description = "Extism Host SDK for Rust"
 
 [dependencies]
-extism-manifest = { version = "0.0.1-rc.6", path = "../manifest" }
-extism-runtime = { version = "0.0.1-rc.6", path = "../runtime"}
+extism-manifest = { version = "0.0.1-rc.4", path = "../manifest" }
 serde_json = "1"
-log = "0.4"
-thiserror = "1"
+log = "0.4"

rust/build.rs

@@ -0,0 +1,10 @@
+fn main() {
+    println!("cargo:rustc-link-search=/usr/local/lib");
+
+    if let Ok(home) = std::env::var("HOME") {
+        let path = std::path::PathBuf::from(home).join(".local").join("lib");
+        println!("cargo:rustc-link-search={}", path.display());
+    }
+
+    println!("cargo:rustc-link-lib=extism");
+}

rust/src/context.rs

@@ -1,6 +1,8 @@
 use crate::*;
 
-pub struct Context(pub(crate) std::sync::Arc<std::sync::Mutex<extism_runtime::Context>>);
+pub struct Context {
+    pub(crate) pointer: *mut bindings::ExtismContext,
+}
 
 impl Default for Context {
     fn default() -> Context {
@@ -11,20 +13,25 @@ impl Default for Context {
 impl Context {
     /// Create a new context
     pub fn new() -> Context {
-        Context(std::sync::Arc::new(std::sync::Mutex::new(
-            extism_runtime::Context::new(),
-        )))
+        let pointer = unsafe { bindings::extism_context_new() };
+        Context { pointer }
     }
 
     /// Remove all registered plugins
     pub fn reset(&mut self) {
-        unsafe { bindings::extism_context_reset(&mut *self.lock()) }
-    }
-
-    pub(crate) fn lock(&self) -> std::sync::MutexGuard<extism_runtime::Context> {
-        match self.0.lock() {
-            Ok(x) => x,
-            Err(x) => x.into_inner(),
-        }
+        unsafe { bindings::extism_context_reset(self.pointer) }
+    }
+}
+
+unsafe impl Send for Context {}
+unsafe impl Sync for Context {}
+
+impl Drop for Context {
+    fn drop(&mut self) {
+        if self.pointer.is_null() {
+            return;
+        }
+        unsafe { bindings::extism_context_free(self.pointer) }
+        self.pointer = std::ptr::null_mut();
     }
 }

rust/src/lib.rs

@@ -1,5 +1,9 @@
-pub use extism_manifest::{self as manifest, Manifest};
-pub use extism_runtime::sdk as bindings;
+use std::collections::BTreeMap;
+
+use extism_manifest::Manifest;
+
+#[allow(non_camel_case_types)]
+pub(crate) mod bindings;
 
 mod context;
 mod plugin;
@@ -7,16 +11,17 @@ mod plugin;
 pub use context::Context;
 pub use plugin::Plugin;
 
-#[derive(Debug, thiserror::Error)]
+#[derive(Debug)]
 pub enum Error {
-    #[error("Unable to load plugin: {0}")]
     UnableToLoadPlugin(String),
-    #[error("{0}")]
     Message(String),
-    #[error("JSON: {0}")]
-    Json(#[from] serde_json::Error),
-    #[error("Runtime: {0}")]
-    Runtime(#[from] extism_runtime::Error),
+    Json(serde_json::Error),
+}
+
+impl From<serde_json::Error> for Error {
+    fn from(e: serde_json::Error) -> Self {
+        Error::Json(e)
+    }
 }
 
 /// Gets the version of Extism
@@ -49,7 +54,7 @@ mod tests {
         let wasm_start = Instant::now();
         set_log_file("test.log", Some(log::Level::Info));
         let context = Context::new();
-        let mut plugin = Plugin::new(&context, WASM, false).unwrap();
+        let plugin = Plugin::new(&context, WASM, false).unwrap();
         println!("register loaded plugin: {:?}", wasm_start.elapsed());
 
         let repeat = 1182;
@@ -141,20 +146,20 @@ mod tests {
         use std::io::Write;
         std::thread::spawn(|| {
             let context = Context::new();
-            let mut plugin = Plugin::new(&context, WASM, false).unwrap();
+            let plugin = Plugin::new(&context, WASM, false).unwrap();
             let output = plugin.call("count_vowels", "this is a test").unwrap();
             std::io::stdout().write_all(output).unwrap();
         });
 
         std::thread::spawn(|| {
             let context = Context::new();
-            let mut plugin = Plugin::new(&context, WASM, false).unwrap();
+            let plugin = Plugin::new(&context, WASM, false).unwrap();
             let output = plugin.call("count_vowels", "this is a test aaa").unwrap();
             std::io::stdout().write_all(output).unwrap();
         });
 
         let context = Context::new();
-        let mut plugin = Plugin::new(&context, WASM, false).unwrap();
+        let plugin = Plugin::new(&context, WASM, false).unwrap();
         let output = plugin.call("count_vowels", "abc123").unwrap();
         std::io::stdout().write_all(output).unwrap();
     }

rust/src/plugin.rs

@@ -1,18 +1,16 @@
 use crate::*;
-use std::collections::BTreeMap;
 
 pub struct Plugin<'a> {
-    id: extism_runtime::PluginIndex,
+    id: bindings::ExtismPlugin,
     context: &'a Context,
 }
 
 impl<'a> Plugin<'a> {
-    /// Create plugin from a known-good ID
-    ///
-    /// # Safety
-    /// This function does not check to ensure the provided ID is valid
     pub unsafe fn from_id(id: i32, context: &'a Context) -> Plugin<'a> {
-        Plugin { id, context }
+        Plugin {
+            id,
+            context: context,
+        }
     }
 
     pub fn as_i32(&self) -> i32 {
@@ -21,7 +19,7 @@ impl<'a> Plugin<'a> {
 
     /// Create a new plugin from the given manifest
     pub fn new_with_manifest(
-        ctx: &'a mut Context,
+        ctx: &'a Context,
         manifest: &Manifest,
         wasi: bool,
     ) -> Result<Plugin<'a>, Error> {
@@ -31,10 +29,17 @@ impl<'a> Plugin<'a> {
 
     /// Create a new plugin from a WASM module
     pub fn new(ctx: &'a Context, data: impl AsRef<[u8]>, wasi: bool) -> Result<Plugin, Error> {
-        let plugin = ctx.lock().new_plugin(data, wasi);
+        let plugin = unsafe {
+            bindings::extism_plugin_new(
+                ctx.pointer,
+                data.as_ref().as_ptr(),
+                data.as_ref().len() as u64,
+                wasi,
+            )
+        };
 
         if plugin < 0 {
-            let err = unsafe { bindings::extism_error(&mut *ctx.lock(), -1) };
+            let err = unsafe { bindings::extism_error(ctx.pointer, -1) };
             let buf = unsafe { std::ffi::CStr::from_ptr(err) };
             let buf = buf.to_str().unwrap().to_string();
             return Err(Error::UnableToLoadPlugin(buf));
@@ -50,7 +55,7 @@ impl<'a> Plugin<'a> {
     pub fn update(&mut self, data: impl AsRef<[u8]>, wasi: bool) -> Result<(), Error> {
         let b = unsafe {
             bindings::extism_plugin_update(
-                &mut *self.context.lock(),
+                self.context.pointer,
                 self.id,
                 data.as_ref().as_ptr(),
                 data.as_ref().len() as u64,
@@ -61,7 +66,7 @@ impl<'a> Plugin<'a> {
             return Ok(());
         }
 
-        let err = unsafe { bindings::extism_error(&mut *self.context.lock(), -1) };
+        let err = unsafe { bindings::extism_error(self.context.pointer, -1) };
         if !err.is_null() {
             let s = unsafe { std::ffi::CStr::from_ptr(err) };
             return Err(Error::Message(s.to_str().unwrap().to_string()));
@@ -77,11 +82,11 @@ impl<'a> Plugin<'a> {
     }
 
     /// Set configuration values
-    pub fn set_config(&mut self, config: &BTreeMap<String, Option<String>>) -> Result<(), Error> {
+    pub fn set_config(&self, config: &BTreeMap<String, Option<String>>) -> Result<(), Error> {
         let encoded = serde_json::to_vec(config)?;
         unsafe {
             bindings::extism_plugin_config(
-                &mut *self.context.lock(),
+                self.context.pointer,
                 self.id,
                 encoded.as_ptr() as *const _,
                 encoded.len() as u64,
@@ -91,7 +96,7 @@ impl<'a> Plugin<'a> {
     }
 
     /// Set configuration values, builder-style
-    pub fn with_config(mut self, config: &BTreeMap<String, Option<String>>) -> Result<Self, Error> {
+    pub fn with_config(self, config: &BTreeMap<String, Option<String>>) -> Result<Self, Error> {
         self.set_config(config)?;
         Ok(self)
     }
@@ -101,7 +106,7 @@ impl<'a> Plugin<'a> {
         let name = std::ffi::CString::new(name.as_ref()).expect("Invalid function name");
         unsafe {
             bindings::extism_plugin_function_exists(
-                &mut *self.context.lock(),
+                self.context.pointer,
                 self.id,
                 name.as_ptr() as *const _,
             )
@@ -109,11 +114,11 @@ impl<'a> Plugin<'a> {
     }
 
     /// Call a function with the given input
-    pub fn call(&mut self, name: impl AsRef<str>, input: impl AsRef<[u8]>) -> Result<&[u8], Error> {
+    pub fn call(&self, name: impl AsRef<str>, input: impl AsRef<[u8]>) -> Result<&[u8], Error> {
         let name = std::ffi::CString::new(name.as_ref()).expect("Invalid function name");
         let rc = unsafe {
             bindings::extism_plugin_call(
-                &mut *self.context.lock(),
+                self.context.pointer,
                 self.id,
                 name.as_ptr() as *const _,
                 input.as_ref().as_ptr() as *const _,
@@ -122,7 +127,7 @@ impl<'a> Plugin<'a> {
         };
 
         if rc != 0 {
-            let err = unsafe { bindings::extism_error(&mut *self.context.lock(), self.id) };
+            let err = unsafe { bindings::extism_error(self.context.pointer, self.id) };
             if !err.is_null() {
                 let s = unsafe { std::ffi::CStr::from_ptr(err) };
                 return Err(Error::Message(s.to_str().unwrap().to_string()));
@@ -132,9 +137,9 @@ impl<'a> Plugin<'a> {
         }
 
         let out_len =
-            unsafe { bindings::extism_plugin_output_length(&mut *self.context.lock(), self.id) };
+            unsafe { bindings::extism_plugin_output_length(self.context.pointer, self.id) };
         unsafe {
-            let ptr = bindings::extism_plugin_output_data(&mut *self.context.lock(), self.id);
+            let ptr = bindings::extism_plugin_output_data(self.context.pointer, self.id);
             Ok(std::slice::from_raw_parts(ptr, out_len as usize))
         }
     }
@@ -142,6 +147,9 @@ impl<'a> Plugin<'a> {
 
 impl<'a> Drop for Plugin<'a> {
     fn drop(&mut self) {
-        unsafe { bindings::extism_plugin_free(&mut *self.context.lock(), self.id) }
+        if self.context.pointer.is_null() {
+            return;
+        }
+        unsafe { bindings::extism_plugin_free(self.context.pointer, self.id) }
     }
 }