new: port some logic, write first nif

20 files changed, 1122 insertions, 20 deletions

diff --git a/.gitignore b/.gitignore
index 7389f60..ffbe771 100644
--- a/.gitignore
+++ b/.gitignore
@@ -24,3 +24,5 @@ thulani-*.tar
 
 # Temporary files, for example, from tests.
 /tmp/
+
+/priv/
diff --git a/config/config.exs b/config/config.exs
index 2cac044..53acb96 100644
--- a/config/config.exs
+++ b/config/config.exs
@@ -10,7 +10,7 @@ config :nostrum,
 
 config :logger,
   compile_time_purge_matching: [
-    [application: :nostrum, level_lower_than: :info]
+    [application: :nostrum, level_lower_than: :warning]
   ]
 
 config :logger, :console,
diff --git a/lib/application.ex b/lib/application.ex
index 3445cf0..be6d76f 100644
--- a/lib/application.ex
+++ b/lib/application.ex
@@ -3,8 +3,17 @@ require Logger
 defmodule Thulani do
   use Application
 
+  @children [
+    Thulani.DiscordConsumer,
+    {Phoenix.PubSub, name: :thulani_pubsub},
+    Thulani.Command,
+    {Registry, keys: :unique, name: Thulani.Audio.Registry}
+  ]
+
   def start(_typ, _arg) do
-    Logger.info('starting up')
-    Supervisor.start_link([Thulani.Consumer], strategy: :one_for_one)
+    Supervisor.start_link(
+      @children,
+      strategy: :one_for_one
+    )
   end
 end
diff --git a/lib/audio/server.ex b/lib/audio/server.ex
new file mode 100644
index 0000000..0ec901f
--- /dev/null
+++ b/lib/audio/server.ex
@@ -0,0 +1,61 @@
+alias Nostrum.Struct
+alias Nostrum.Snowflake
+
+defmodule Audio.Server do
+  use GenServer
+
+  @type which :: String.t()
+  @type audio_ref :: {}
+
+  def start_link(arg) do
+    {:ok, _} = DynamicSupervisor.start_link(__MODULE__, arg, name: __MODULE__.Supervisor)
+    {:ok, _} = Registry.start_link(keys: :unique, name: __MODULE__.Registry)
+  end
+
+  @spec play_now(Struct.Guild.id(), audio_ref) :: which
+  def play_now(guild, audio_ref) do
+    {:ok, which} = GenServer.call(__MODULE__, {:now, guild, audio_ref})
+    which
+  end
+
+  @spec enqueue(Struct.Guild.id(), audio_ref) :: which
+  def enqueue(guild, audio_ref) do
+    GenServer.call(__MODULE__, {:enqueue})
+  end
+
+  @spec cancel(which) :: GenServer.call()
+  def cancel(which) do
+    GenServer.call(__MODULE__, {:cancel, which})
+  end
+
+  @impl true
+  def init(guild) do
+    {:ok, {guild, :queue.new()}}
+  end
+
+  @impl true
+  def handle_call({:now, {type, ref, opts}}, _from, {guild, q}) do
+    if Nostrum.Voice.playing?(guild) do
+      :ok = Nostrum.Voice.stop(guild)
+    end
+
+    id = UUID.uuid4()
+    Nostrum.Voice.play(guild, ref, type, opts)
+
+    q = :queue.in_r({id, ref}, q)
+    {:reply, :ok, {guild, q}}
+  end
+
+  @impl true
+  def handle_call({:enqueue, audio_ref}, _from, {_guild, q}) do
+    id = UUID.uuid4()
+    q = :queue.in({id, audio_ref}, q)
+    {:reply, {:ok, id}, {id, q}}
+  end
+
+  @impl true
+  def handle_call({:cancel, audio_ref}, _from, {guild, q}) do
+    q = :queue.delete_with(fn _elem -> false end, q)
+    {:reply, :ok, {guild, q}}
+  end
+end
diff --git a/lib/audio/supervisor.ex b/lib/audio/supervisor.ex
new file mode 100644
index 0000000..0b86a1c
--- /dev/null
+++ b/lib/audio/supervisor.ex
@@ -0,0 +1,2 @@
+defmodule Thulani.Audio.Supervisor do
+end
diff --git a/lib/calc.ex b/lib/calc.ex
new file mode 100644
index 0000000..0e53c06
--- /dev/null
+++ b/lib/calc.ex
@@ -0,0 +1,6 @@
+defmodule Thulani.Calc do
+  use Rustler, otp_app: :thulani, crate: "thulani_calc"
+
+  @spec eval(String.t()) :: {:ok, number | :inf | :ninf | :nan} | {:error, String.t()}
+  def eval(_expr), do: :erlang.nif_error(:nif_not_loaded)
+end
diff --git a/lib/command/command.ex b/lib/command/command.ex
new file mode 100644
index 0000000..f83f02b
--- /dev/null
+++ b/lib/command/command.ex
@@ -0,0 +1,57 @@
+alias Phoenix.PubSub
+alias Nostrum.Api
+
+defmodule Thulani.Command do
+  use GenServer
+  use Thulani.Command.Util
+  require Logger
+
+  def start_link(arg) do
+    GenServer.start_link(__MODULE__, arg)
+  end
+
+  @impl true
+  def init(_) do
+    PubSub.subscribe(:thulani_pubsub, "cmd")
+    {:ok, %{}}
+  end
+
+  @impl true
+  def handle_info(Util.command("meme", "", msg), state) do
+    {:noreply, state}
+  end
+
+  @impl true
+  def handle_info(Util.command("meme", rest, msg), state) do
+    case rest do
+      "" -> Thulani.Meme
+    end
+
+    {:noreply, state}
+  end
+
+  def handle_info(Util.command("http", rest, msg), state) do
+  end
+
+  def handle_info(Util.command("roll", rest, msg), state) do
+    Logger.info("hi")
+
+    case rest do
+      " " <> expr ->
+        case Thulani.Calc.eval(expr) do
+          {:ok, val} -> Api.create_message!(msg.channel_id, "#{val}")
+          {:error, err} -> Logger.error("BAD: #{err}")
+        end
+
+      _ ->
+        Logger.error("nothing else in the message")
+    end
+
+    {:noreply, state}
+  end
+
+  def handle_info(_msg, state) do
+    Logger.debug("unhandled message")
+    {:noreply, state}
+  end
+end
diff --git a/lib/command/meme.ex b/lib/command/meme.ex
new file mode 100644
index 0000000..3c51334
--- /dev/null
+++ b/lib/command/meme.ex
@@ -0,0 +1,58 @@
+alias Nostrum.Api
+alias Nostrum.Struct.Message
+alias Thulani.Command.Util
+
+defmodule Thulani.Command.Meme do
+  use GenServer
+
+  @type audio_permission :: :unrestrict | boolean
+
+  defmodule Request do
+    alias Thulani.Command.Meme
+
+    @type t ::
+            %__MODULE__{
+              name: :random,
+              audio: Meme.audio_permission(),
+              msg: Message.t()
+            }
+            | %__MODULE__{
+                name: String.t(),
+                audio: nil,
+                msg: Message.t()
+              }
+
+    @enforce_keys [:msg]
+    defstruct name: :random, audio: :unrestrict, msg: nil
+  end
+
+  @spec random_meme(Message.t()) :: GenServer.cast()
+  def random_meme(msg) do
+    GenServer.cast(__MODULE__, %Request{msg: msg})
+  end
+
+  @spec meme(Message.t(), String.t()) :: GenServer.cast()
+  @spec meme(Message.t(), String.t(), audio_permission) :: GenServer.cast()
+  def meme(msg, name, audio \\ :unrestrict) do
+    GenServer.cast(__MODULE__, %Request{name: name, msg: msg, audio: audio})
+  end
+
+  def start_link(arg) do
+    GenServer.start_link(__MODULE__, arg)
+  end
+
+  @impl true
+  def init(_) do
+    {:ok, %{}}
+  end
+
+  @impl true
+  def handle_cast(%Request{name: :random, msg: msg, audio: audio}, state) do
+    {:noreply, state}
+  end
+
+  @impl true
+  def handle_cast(%Request{name: name, msg: msg}, state) do
+    {:noreply, state}
+  end
+end
diff --git a/lib/command/util.ex b/lib/command/util.ex
new file mode 100644
index 0000000..8f2018f
--- /dev/null
+++ b/lib/command/util.ex
@@ -0,0 +1,18 @@
+defmodule Thulani.Command.Util do
+  alias Nostrum.Snowflake
+  @type qualified_channel :: {Snowflake.t(), Snowflake.t()}
+
+  defmacro __using__(_opts) do
+    mod = __MODULE__
+
+    quote do
+      alias unquote(mod)
+    end
+  end
+
+  defmacro command(word, rest, msg) do
+    quote do
+      {:cmd, " #{unquote(word)}" <> unquote(rest), unquote(msg)}
+    end
+  end
+end
diff --git a/lib/consumer.ex b/lib/consumer.ex
index ace0ba8..614c261 100644
--- a/lib/consumer.ex
+++ b/lib/consumer.ex
@@ -1,24 +1,29 @@
 require Logger
-require OK
 
-alias Nostrum.Api
+alias Nostrum.Struct.Message
+alias Phoenix.PubSub
 
-defmodule Thulani.Consumer do
+defmodule Thulani.DiscordConsumer do
   use Nostrum.Consumer
 
   def start_link do
-    Logger.info('starting consumer')
     Nostrum.Consumer.start_link(__MODULE__)
   end
 
   @spec handle_event(Nostrum.Consumer.message_create()) :: nil
-  def handle_event({:MESSAGE_CREATE, message, _ws_state}) do
-    case Thulani.Message.message(message) do
-      {:ok, content} -> Api.create_message!(message.channel_id, content)
-      :ignore -> nil
-    end
+  def handle_event({
+        :MESSAGE_CREATE,
+        message = %Message{},
+        _ws_state
+      }) do
+    case Thulani.Message.validate(message) do
+      {:ok, command} ->
+        Logger.debug(%{command: command})
+        PubSub.broadcast!(:thulani_pubsub, "cmd", {:cmd, command, message})
 
-    nil
+      :ignore ->
+        nil
+    end
   end
 
   def handle_event(_event), do: :noop
diff --git a/lib/message.ex b/lib/message.ex
index f04e1e7..60d3aa8 100644
--- a/lib/message.ex
+++ b/lib/message.ex
@@ -7,8 +7,8 @@ alias Nostrum.Api
 defmodule Thulani.Message do
   @prefix Application.compile_env(:thulani, :prefix, "!thulani")
 
-  @spec message(Message.t()) :: {:ok, String.t()} | :ignore
-  def message(%Message{
+  @spec validate(Message.t()) :: {:ok, String.t()} | :ignore
+  def validate(%Message{
         content: @prefix <> rest,
         guild_id: guild_id,
         author: %User{
@@ -19,7 +19,7 @@ defmodule Thulani.Message do
     {:ok, rest}
   end
 
-  def message(%Message{
+  def validate(%Message{
         guild_id: guild_id,
         author: %User{
           username: username,
@@ -39,8 +39,8 @@ defmodule Thulani.Message do
     :ignore
   end
 
-  def message(msg) do
-    Logger.debug(%{message: "unmatched message", msg: msg})
+  def validate(msg) do
+    Logger.debug(%{validate: "unmatched validate", msg: msg})
 
     :ignore
   end
diff --git a/mix.exs b/mix.exs
index 2fb5b1b..c18bc1f 100644
--- a/mix.exs
+++ b/mix.exs
@@ -14,7 +14,7 @@ defmodule Thulani.MixProject do
   def application do
     [
       mod: {Thulani, []},
-      extra_applications: [:logger]
+      extra_applications: [:logger, :crypto]
     ]
   end
 
@@ -25,7 +25,10 @@ defmodule Thulani.MixProject do
       {:algae, "~> 1.2"},
       {:quark, "~> 2.3"},
       {:exceptional, "~> 2.1"},
-      {:ok, "~> 2.3"}
+      {:ok, "~> 2.3"},
+      {:phoenix_pubsub, "~>2.1"},
+      {:uuid, "~> 1.1"},
+      {:rustler, "~> 0.26"}
     ]
   end
 end
diff --git a/mix.lock b/mix.lock
index 03f2879..c486c6d 100644
--- a/mix.lock
+++ b/mix.lock
@@ -15,9 +15,13 @@
   "nostrum": {:hex, :nostrum, "0.6.1", "aaad13e8e8ce8ace1f218685c6824972e7ea4f979e5ba3242a98f22bda52e605", [:mix], [{:certifi, "~> 2.8", [hex: :certifi, repo: "hexpm", optional: false]}, {:gen_stage, "~> 0.11 or ~> 1.0", [hex: :gen_stage, repo: "hexpm", optional: false]}, {:gun, "2.0.1", [hex: :remedy_gun, repo: "hexpm", optional: false]}, {:jason, "~> 1.2", [hex: :jason, repo: "hexpm", optional: false]}, {:kcl, "~> 1.4", [hex: :kcl, repo: "hexpm", optional: false]}, {:mime, "~> 1.6 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}], "hexpm", "27925a47e413766664928fbeb38c9887a7fd23066cdba831d5fd8241072bf76a"},
   "ok": {:hex, :ok, "2.3.0", "0a3d513ec9038504dc5359d44e14fc14ef59179e625563a1a144199cdc3a6d30", [:mix], [], "hexpm", "f0347b3f8f115bf347c704184b33cf084f2943771273f2b98a3707a5fa43c4d5"},
   "operator": {:hex, :operator, "0.2.1", "4572312bbd3e63a5c237bf15c3a7670d568e3651ea744289130780006e70e5f5", [:mix], [], "hexpm", "1990cc6dc651d7fff04636eef06fc64e6bc1da83a1da890c08ca3432e17e267a"},
+  "phoenix_pubsub": {:hex, :phoenix_pubsub, "2.1.1", "ba04e489ef03763bf28a17eb2eaddc2c20c6d217e2150a61e3298b0f4c2012b5", [:mix], [], "hexpm", "81367c6d1eea5878ad726be80808eb5a787a23dee699f96e72b1109c57cdd8d9"},
   "poly1305": {:hex, :poly1305, "1.0.4", "7cdc8961a0a6e00a764835918cdb8ade868044026df8ef5d718708ea6cc06611", [:mix], [{:chacha20, "~> 1.0", [hex: :chacha20, repo: "hexpm", optional: false]}, {:equivalex, "~> 1.0", [hex: :equivalex, repo: "hexpm", optional: false]}], "hexpm", "e14e684661a5195e149b3139db4a1693579d4659d65bba115a307529c47dbc3b"},
   "quark": {:hex, :quark, "2.3.2", "066e0d431440d077684469967f54d732443ea2a48932e0916e974633e8b39c95", [:mix], [], "hexpm", "2f6423779b02afe7e3e4af3cfecfcd94572f2051664d4d8329ffa872d24b10a8"},
+  "rustler": {:hex, :rustler, "0.26.0", "06a2773d453ee3e9109efda643cf2ae633dedea709e2455ac42b83637c9249bf", [:mix], [{:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}, {:toml, "~> 0.6", [hex: :toml, repo: "hexpm", optional: false]}], "hexpm", "42961e9d2083d004d5a53e111ad1f0c347efd9a05cb2eb2ffa1d037cdc74db91"},
   "salsa20": {:hex, :salsa20, "1.0.3", "fb900fc9b26b713a98618f3c6d6b6c35a5514477c6047caca8d03f3a70175ab0", [:mix], [], "hexpm", "91cbfa537f369d074a79f926f36a6c2ac24fba12cbadcb23aa04a759282887fe"},
+  "toml": {:hex, :toml, "0.7.0", "fbcd773caa937d0c7a02c301a1feea25612720ac3fa1ccb8bfd9d30d822911de", [:mix], [], "hexpm", "0690246a2478c1defd100b0c9b89b4ea280a22be9a7b313a8a058a2408a2fa70"},
   "type_class": {:hex, :type_class, "1.2.8", "349db84be8c664e119efaae1a09a44b113bc8e81af1d032f4e3e38feef4fac32", [:mix], [{:exceptional, "~> 2.1", [hex: :exceptional, repo: "hexpm", optional: false]}], "hexpm", "bb93de2cacfd6f0ee43f4616f7a139816a73deba4ae8ee3364bcfa4abe3eef3e"},
+  "uuid": {:hex, :uuid, "1.1.8", "e22fc04499de0de3ed1116b770c7737779f226ceefa0badb3592e64d5cfb4eb9", [:mix], [], "hexpm", "c790593b4c3b601f5dc2378baae7efaf5b3d73c4c6456ba85759905be792f2ac"},
   "witchcraft": {:hex, :witchcraft, "1.0.4", "8733ac0ee769d4d2f73610de5a2b601a4ccbe385d1fca6419280f2511d21d0c9", [:mix], [{:exceptional, "~> 2.1", [hex: :exceptional, repo: "hexpm", optional: false]}, {:operator, "~> 0.2", [hex: :operator, repo: "hexpm", optional: false]}, {:quark, "~> 2.2", [hex: :quark, repo: "hexpm", optional: false]}, {:type_class, "~> 1.2", [hex: :type_class, repo: "hexpm", optional: false]}], "hexpm", "a380f439f1962d2e56cdad874ed7eb4612ddd6ec5ee3c6ad0c5d63e60539e6b0"},
 }
diff --git a/native/thulani_calc/.cargo/config.toml b/native/thulani_calc/.cargo/config.toml
new file mode 100644
index 0000000..20f03f3
--- /dev/null
+++ b/native/thulani_calc/.cargo/config.toml
@@ -0,0 +1,5 @@
+[target.'cfg(target_os = "macos")']
+rustflags = [
+    "-C", "link-arg=-undefined",
+    "-C", "link-arg=dynamic_lookup",
+]
diff --git a/native/thulani_calc/.gitignore b/native/thulani_calc/.gitignore
new file mode 100644
index 0000000..ea8c4bf
--- /dev/null
+++ b/native/thulani_calc/.gitignore
@@ -0,0 +1 @@
+/target
diff --git a/native/thulani_calc/Cargo.lock b/native/thulani_calc/Cargo.lock
new file mode 100644
index 0000000..3504dc8
--- /dev/null
+++ b/native/thulani_calc/Cargo.lock
@@ -0,0 +1,537 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
+version = 3
+
+[[package]]
+name = "aho-corasick"
+version = "0.7.20"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cc936419f96fa211c1b9166887b38e5e40b19958e5b895be7c1f93adec7071ac"
+dependencies = [
+ "memchr",
+]
+
+[[package]]
+name = "approx"
+version = "0.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cab112f0a86d568ea0e627cc1d6be74a1e9cd55214684db5561995f6dad897c6"
+dependencies = [
+ "num-traits",
+]
+
+[[package]]
+name = "autocfg"
+version = "1.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d468802bab17cbc0cc575e9b053f41e72aa36bfa6b7f55e3529ffa43161b97fa"
+
+[[package]]
+name = "block-buffer"
+version = "0.10.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "69cce20737498f97b993470a6e536b8523f0af7892a4f928cceb1ac5e52ebe7e"
+dependencies = [
+ "generic-array",
+]
+
+[[package]]
+name = "bytemuck"
+version = "1.12.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "aaa3a8d9a1ca92e282c96a32d6511b695d7d994d1d102ba85d279f9b2756947f"
+
+[[package]]
+name = "cfg-if"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd"
+
+[[package]]
+name = "cpufeatures"
+version = "0.2.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "28d997bd5e24a5928dd43e46dc529867e207907fe0b239c3477d924f7f2ca320"
+dependencies = [
+ "libc",
+]
+
+[[package]]
+name = "crypto-common"
+version = "0.1.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "1bfb12502f3fc46cca1bb51ac28df9d618d813cdc3d2f25b9fe775a34af26bb3"
+dependencies = [
+ "generic-array",
+ "typenum",
+]
+
+[[package]]
+name = "digest"
+version = "0.10.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "8168378f4e5023e7218c89c891c0fd8ecdb5e5e4f18cb78f38cf245dd021e76f"
+dependencies = [
+ "block-buffer",
+ "crypto-common",
+]
+
+[[package]]
+name = "generic-array"
+version = "0.14.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bff49e947297f3312447abdca79f45f4738097cc82b06e72054d2223f601f1b9"
+dependencies = [
+ "typenum",
+ "version_check",
+]
+
+[[package]]
+name = "getrandom"
+version = "0.2.8"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c05aeb6a22b8f62540c194aac980f2115af067bfe15a0734d7277a768d396b31"
+dependencies = [
+ "cfg-if",
+ "libc",
+ "wasi",
+]
+
+[[package]]
+name = "heck"
+version = "0.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2540771e65fc8cb83cd6e8a237f70c319bd5c29f78ed1084ba5d50eeac86f7f9"
+
+[[package]]
+name = "lazy_static"
+version = "1.4.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e2abad23fbc42b3700f2f279844dc832adb2b2eb069b2df918f455c4e18cc646"
+
+[[package]]
+name = "libc"
+version = "0.2.138"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "db6d7e329c562c5dfab7a46a2afabc8b987ab9a4834c9d1ca04dc54c1546cef8"
+
+[[package]]
+name = "libm"
+version = "0.2.6"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "348108ab3fba42ec82ff6e9564fc4ca0247bdccdc68dd8af9764bbc79c3c8ffb"
+
+[[package]]
+name = "log"
+version = "0.4.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "abb12e687cfb44aa40f41fc3978ef76448f9b6038cad6aef4259d3c095a2382e"
+dependencies = [
+ "cfg-if",
+]
+
+[[package]]
+name = "matrixmultiply"
+version = "0.3.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "add85d4dd35074e6fedc608f8c8f513a3548619a9024b751949ef0e8e45a4d84"
+dependencies = [
+ "rawpointer",
+]
+
+[[package]]
+name = "memchr"
+version = "2.5.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2dffe52ecf27772e601905b7522cb4ef790d2cc203488bbd0e2fe85fcb74566d"
+
+[[package]]
+name = "nalgebra"
+version = "0.29.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d506eb7e08d6329505faa8a3a00a5dcc6de9f76e0c77e4b75763ae3c770831ff"
+dependencies = [
+ "approx",
+ "matrixmultiply",
+ "nalgebra-macros",
+ "num-complex",
+ "num-rational",
+ "num-traits",
+ "rand",
+ "rand_distr",
+ "simba",
+ "typenum",
+]
+
+[[package]]
+name = "nalgebra-macros"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "01fcc0b8149b4632adc89ac3b7b31a12fb6099a0317a4eb2ebff574ef7de7218"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "num-complex"
+version = "0.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "7ae39348c8bc5fbd7f40c727a9925f03517afd2ab27d46702108b6a7e5414c19"
+dependencies = [
+ "num-traits",
+]
+
+[[package]]
+name = "num-integer"
+version = "0.1.45"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "225d3389fb3509a24c93f5c29eb6bde2586b98d9f016636dff58d7c6f7569cd9"
+dependencies = [
+ "autocfg",
+ "num-traits",
+]
+
+[[package]]
+name = "num-rational"
+version = "0.4.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "0638a1c9d0a3c0914158145bc76cff373a75a627e6ecbfb71cbe6f453a5a19b0"
+dependencies = [
+ "autocfg",
+ "num-integer",
+ "num-traits",
+]
+
+[[package]]
+name = "num-traits"
+version = "0.2.15"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "578ede34cf02f8924ab9447f50c28075b4d3e5b269972345e7e0372b38c6cdcd"
+dependencies = [
+ "autocfg",
+ "libm",
+]
+
+[[package]]
+name = "once_cell"
+version = "1.16.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "86f0b0d4bf799edbc74508c1e8bf170ff5f41238e5f8225603ca7caaae2b7860"
+
+[[package]]
+name = "paste"
+version = "1.0.9"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b1de2e551fb905ac83f73f7aedf2f0cb4a0da7e35efa24a202a936269f1f18e1"
+
+[[package]]
+name = "pest"
+version = "2.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cc8bed3549e0f9b0a2a78bf7c0018237a2cdf085eecbbc048e52612438e4e9d0"
+dependencies = [
+ "thiserror",
+ "ucd-trie",
+]
+
+[[package]]
+name = "pest_derive"
+version = "2.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "cdc078600d06ff90d4ed238f0119d84ab5d43dbaad278b0e33a8820293b32344"
+dependencies = [
+ "pest",
+ "pest_generator",
+]
+
+[[package]]
+name = "pest_generator"
+version = "2.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "28a1af60b1c4148bb269006a750cff8e2ea36aff34d2d96cf7be0b14d1bed23c"
+dependencies = [
+ "pest",
+ "pest_meta",
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "pest_meta"
+version = "2.5.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fec8605d59fc2ae0c6c1aefc0c7c7a9769732017c0ce07f7a9cfffa7b4404f20"
+dependencies = [
+ "once_cell",
+ "pest",
+ "sha1",
+]
+
+[[package]]
+name = "ppv-lite86"
+version = "0.2.17"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5b40af805b3121feab8a3c29f04d8ad262fa8e0561883e7653e024ae4479e6de"
+
+[[package]]
+name = "proc-macro2"
+version = "1.0.47"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5ea3d908b0e36316caf9e9e2c4625cdde190a7e6f440d794667ed17a1855e725"
+dependencies = [
+ "unicode-ident",
+]
+
+[[package]]
+name = "quote"
+version = "1.0.21"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bbe448f377a7d6961e30f5955f9b8d106c3f5e449d493ee1b125c1d43c2b5179"
+dependencies = [
+ "proc-macro2",
+]
+
+[[package]]
+name = "rand"
+version = "0.8.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "34af8d1a0e25924bc5b7c43c079c942339d8f0a8b57c39049bef581b46327404"
+dependencies = [
+ "libc",
+ "rand_chacha",
+ "rand_core",
+]
+
+[[package]]
+name = "rand_chacha"
+version = "0.3.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e6c10a63a0fa32252be49d21e7709d4d4baf8d231c2dbce1eaa8141b9b127d88"
+dependencies = [
+ "ppv-lite86",
+ "rand_core",
+]
+
+[[package]]
+name = "rand_core"
+version = "0.6.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ec0be4795e2f6a28069bec0b5ff3e2ac9bafc99e6a9a7dc3547996c5c816922c"
+dependencies = [
+ "getrandom",
+]
+
+[[package]]
+name = "rand_distr"
+version = "0.4.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "32cb0b9bc82b0a0876c2dd994a7e7a2683d3e7390ca40e6886785ef0c7e3ee31"
+dependencies = [
+ "num-traits",
+ "rand",
+]
+
+[[package]]
+name = "rawpointer"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "60a357793950651c4ed0f3f52338f53b2f809f32d83a07f72909fa13e4c6c1e3"
+
+[[package]]
+name = "regex"
+version = "1.7.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "e076559ef8e241f2ae3479e36f97bd5741c0330689e217ad51ce2c76808b868a"
+dependencies = [
+ "aho-corasick",
+ "memchr",
+ "regex-syntax",
+]
+
+[[package]]
+name = "regex-syntax"
+version = "0.6.28"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "456c603be3e8d448b072f410900c09faf164fbce2d480456f50eea6e25f9c848"
+
+[[package]]
+name = "rustler"
+version = "0.26.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "d61e8ddf75de20513455d7b6f17241a595abbb01b53a6340cecc798a1b13422d"
+dependencies = [
+ "lazy_static",
+ "rustler_codegen",
+ "rustler_sys",
+]
+
+[[package]]
+name = "rustler_codegen"
+version = "0.26.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "baa2e45c0165272070f80ce93bcd7dd5407a3c84a1ef73ab9900e00f00ef3d36"
+dependencies = [
+ "heck",
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "rustler_sys"
+version = "2.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3ff26a42e62d538f82913dd34f60105ecfdffbdb25abdc3c3580b0c622285332"
+dependencies = [
+ "regex",
+ "unreachable",
+]
+
+[[package]]
+name = "safe_arch"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "794821e4ccb0d9f979512f9c1973480123f9bd62a90d74ab0f9426fcf8f4a529"
+dependencies = [
+ "bytemuck",
+]
+
+[[package]]
+name = "sha1"
+version = "0.10.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f04293dc80c3993519f2d7f6f511707ee7094fe0c6d3406feb330cdb3540eba3"
+dependencies = [
+ "cfg-if",
+ "cpufeatures",
+ "digest",
+]
+
+[[package]]
+name = "simba"
+version = "0.6.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "f0b7840f121a46d63066ee7a99fc81dcabbc6105e437cae43528cea199b5a05f"
+dependencies = [
+ "approx",
+ "num-complex",
+ "num-traits",
+ "paste",
+ "wide",
+]
+
+[[package]]
+name = "statrs"
+version = "0.16.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "2d08e5e1748192713cc281da8b16924fb46be7b0c2431854eadc785823e5696e"
+dependencies = [
+ "approx",
+ "lazy_static",
+ "nalgebra",
+ "num-traits",
+ "rand",
+]
+
+[[package]]
+name = "syn"
+version = "1.0.105"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "60b9b43d45702de4c839cb9b51d9f529c5dd26a4aff255b42b1ebc03e88ee908"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "unicode-ident",
+]
+
+[[package]]
+name = "thiserror"
+version = "1.0.37"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "10deb33631e3c9018b9baf9dcbbc4f737320d2b576bac10f6aefa048fa407e3e"
+dependencies = [
+ "thiserror-impl",
+]
+
+[[package]]
+name = "thiserror-impl"
+version = "1.0.37"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "982d17546b47146b28f7c22e3d08465f6b8903d0ea13c1660d9d84a6e7adcdbb"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "thulani_calc"
+version = "0.1.0"
+dependencies = [
+ "lazy_static",
+ "log",
+ "pest",
+ "pest_derive",
+ "rand",
+ "rustler",
+ "statrs",
+ "thiserror",
+]
+
+[[package]]
+name = "typenum"
+version = "1.16.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "497961ef93d974e23eb6f433eb5fe1b7930b659f06d12dec6fc44a8f554c0bba"
+
+[[package]]
+name = "ucd-trie"
+version = "0.1.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9e79c4d996edb816c91e4308506774452e55e95c3c9de07b6729e17e15a5ef81"
+
+[[package]]
+name = "unicode-ident"
+version = "1.0.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6ceab39d59e4c9499d4e5a8ee0e2735b891bb7308ac83dfb4e80cad195c9f6f3"
+
+[[package]]
+name = "unreachable"
+version = "1.0.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "382810877fe448991dfc7f0dd6e3ae5d58088fd0ea5e35189655f84e6814fa56"
+dependencies = [
+ "void",
+]
+
+[[package]]
+name = "version_check"
+version = "0.9.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "49874b5167b65d7193b8aba1567f5c7d93d001cafc34600cee003eda787e483f"
+
+[[package]]
+name = "void"
+version = "1.0.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "6a02e4885ed3bc0f2de90ea6dd45ebcbb66dacffe03547fadbb0eeae2770887d"
+
+[[package]]
+name = "wasi"
+version = "0.11.0+wasi-snapshot-preview1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9c8d87e72b64a3b4db28d11ce29237c246188f4f51057d65a7eab63b7987e423"
+
+[[package]]
+name = "wide"
+version = "0.7.5"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ae41ecad2489a1655c8ef8489444b0b113c0a0c795944a3572a0931cf7d2525c"
+dependencies = [
+ "bytemuck",
+ "safe_arch",
+]
diff --git a/native/thulani_calc/Cargo.toml b/native/thulani_calc/Cargo.toml
new file mode 100644
index 0000000..8ba8a75
--- /dev/null
+++ b/native/thulani_calc/Cargo.toml
@@ -0,0 +1,20 @@
+[package]
+name = "thulani_calc"
+version = "0.1.0"
+authors = []
+edition = "2018"
+
+[lib]
+name = "thulani_calc"
+path = "src/lib.rs"
+crate-type = ["cdylib"]
+
+[dependencies]
+rustler = "0.26.0"
+pest = "2.5"
+pest_derive = "2.5"
+lazy_static = "1.4"
+statrs = "0.16"
+thiserror = "1.0"
+rand = "0.8"
+log = "0.4"
diff --git a/native/thulani_calc/README.md b/native/thulani_calc/README.md
new file mode 100644
index 0000000..03e1510
--- /dev/null
+++ b/native/thulani_calc/README.md
@@ -0,0 +1,20 @@
+# NIF for Elixir.Thulani.Calc
+
+## To build the NIF module:
+
+- Your NIF will now build along with your project.
+
+## To load the NIF:
+
+```elixir
+defmodule Thulani.Calc do
+  use Rustler, otp_app: :thulani, crate: "thulani_calc"
+
+  # When your NIF is loaded, it will override this function.
+  def add(_a, _b), do: :erlang.nif_error(:nif_not_loaded)
+end
+```
+
+## Examples
+
+[This](https://github.com/rusterlium/NifIo) is a complete example of a NIF written in Rust.
diff --git a/native/thulani_calc/src/calc.pest b/native/thulani_calc/src/calc.pest
new file mode 100644
index 0000000..07eeddb
--- /dev/null
+++ b/native/thulani_calc/src/calc.pest
@@ -0,0 +1,79 @@
+num = {
+    hex
+    | oct
+    | binary
+    | float
+}
+
+float = @{ int ~ ( "." ~ ASCII_DIGIT*)? ~ (^"e" ~ int)? }
+    int = { "-"? ~ ASCII_DIGIT+ }
+
+hex = @{ "0x" ~ ASCII_HEX_DIGIT+ }
+oct = @{ "0o" ~ ASCII_OCT_DIGIT+ }
+binary = @{ "0b" ~ ASCII_BIN_DIGIT+ }
+
+infix = _{ add | sub | mul | div | modulo }
+    add = { "+" }
+    sub = { "-" }
+    modulo = { "%" | "mod" }
+    mul = { "*" }
+    div = { "/" }
+
+tight_infix = _{ dice | pow }
+	dice = { "d" }
+	pow = { "^" }
+
+trig = _{ sin | cos | tan | asin | acos | atan }
+    sin = { "sin" }
+    cos = { "cos" }
+    tan = { "tan" }
+    asin = { "asin" }
+    acos = { "acos" }
+    atan = { "atan" }
+
+htrig = _{ sinh | cosh | tanh | asinh | acosh | atanh }
+    sinh = { "sinh" }
+    cosh = { "cosh" }
+    tanh = { "tanh" }
+    asinh = { "asinh" }
+    acosh = { "acosh" }
+    atanh = { "atanh" }
+
+unary_prefix = _{ log | sqrt | sgn | htrig | trig | exp | abs | ceil | floor | round }
+    log = { "log" | "ln" }
+    sqrt = { "sqrt" }
+    sgn = { "sgn" }
+    exp = { "exp" }
+    abs = { "abs" }
+    ceil = { "ceil" }
+    floor = { "floor" }
+    round = { "round" }
+
+binary_prefix = _{ min | max | atan2 }
+    min = { "min" }
+    max = { "max" }
+    atan2 = { "atan2" }
+
+suffix = _{ factorial }
+    factorial = { "!" }
+
+term = _{ num | "(" ~ expr ~ ")" }
+
+suffix_expr = { term ~ suffix }
+unary_expr = ${ unary_prefix ~ ws+ ~ outfix_expr }
+binary_expr = ${ binary_prefix ~ ws+ ~ outfix_expr ~ ws+ ~ outfix_expr }
+
+tight = _{ (suffix_expr | term) ~ (tight_infix ~ tight)* }
+
+expr = { outfix_expr ~ (infix ~ outfix_expr)* }
+
+outfix_expr = _{
+    tight |
+    binary_expr |
+    unary_expr
+}
+
+calc = _{ SOI ~ expr ~ EOI }
+
+ws = _{ " " | "\t" | "\n" }
+WHITESPACE = _{ ws }
diff --git a/native/thulani_calc/src/lib.rs b/native/thulani_calc/src/lib.rs
new file mode 100644
index 0000000..75a6b37
--- /dev/null
+++ b/native/thulani_calc/src/lib.rs
@@ -0,0 +1,215 @@
+use log::error;
+use rand::prelude::*;
+use statrs;
+use thiserror::Error;
+use lazy_static::lazy_static;
+use rustler::Encoder;
+
+mod atoms {
+    rustler::atoms! {
+        ok,
+        error,
+        inf,
+        ninf,
+        nan,
+    }
+}
+
+#[rustler::nif]
+pub fn eval<'a>(env: rustler::Env<'a>, args: String) -> Result<rustler::Term<'a>, String> {
+    Calc::eval(&args)
+        .map(|x| match x {
+            f64::INFINITY => atoms::inf().encode(env),
+            f64::NEG_INFINITY => atoms::ninf().encode(env),
+            x if x.is_nan() => atoms::nan().encode(env),
+            x => x.encode(env),
+        })
+        .map_err(|e| e.to_string())
+}
+
+rustler::init!("Elixir.Thulani.Calc", [eval]);
+
+
+#[derive(pest_derive::Parser)]
+#[grammar = "calc.pest"]
+struct Calc;
+
+#[derive(Copy, Clone, Error, Debug, PartialEq, Eq, Hash)]
+pub(crate) enum CalcError {
+    #[error("pest was unable to parse the input")]
+    Pest,
+
+    #[error("invalid number format")]
+    NumberFormat,
+
+    #[error("bad argument count")]
+    ArgCount,
+}
+
+impl Calc {
+    fn eval<S: AsRef<str>>(s: S) -> Result<f64, CalcError> {
+        use pest::{
+            Parser,
+            prec_climber::PrecClimber,
+            iterators::{Pair, Pairs},
+        };
+
+        use self::Rule::*;
+
+        lazy_static! {
+            static ref CLIMBER: PrecClimber<self::Rule> = {
+                use pest::prec_climber::{
+                    Operator,
+                    Assoc::*,
+                };
+
+                PrecClimber::new(vec![
+                    Operator::new(add, Left) | Operator::new(sub, Left) | Operator::new(modulo, Left),
+                    Operator::new(mul, Left) | Operator::new(div, Left),
+                    Operator::new(dice, Left),
+                    Operator::new(pow, Right),
+                ])
+            };
+        }
+
+        let result = Calc::parse(calc, s.as_ref()).map_err(|_| CalcError::Pest)?;
+
+        fn eval_single_pair(pair: Pair<self::Rule>) -> Result<f64, CalcError> {
+            let result = match pair.as_rule() {
+                oct | hex | binary => {
+                    let base = match pair.as_rule() {
+                        hex => 16,
+                        oct => 8,
+                        binary => 2,
+                        _ => unreachable!(),
+                    };
+
+                    u64::from_str_radix(&pair.as_str()[2..], base).map_err(|_| CalcError::NumberFormat)? as f64
+                },
+                float => pair.as_str().parse::<f64>().map_err(|_| CalcError::NumberFormat)?,
+                expr | num => eval_expr(pair.into_inner())?,
+                unary_expr => {
+                    let mut p = pair.into_inner();
+
+                    let op = p.next().ok_or(CalcError::ArgCount)?;
+                    let arg = eval_expr(p)?;
+
+                    match op.as_rule() {
+                        log => arg.ln(),
+                        sqrt => arg.sqrt(),
+                        sgn => arg.signum(),
+
+                        sin => arg.sin(),
+                        cos => arg.cos(),
+                        tan => arg.tan(),
+                        asin => arg.asin(),
+                        acos => arg.acos(),
+                        atan => arg.atan(),
+
+                        sinh => arg.sinh(),
+                        cosh => arg.cosh(),
+                        tanh => arg.tanh(),
+                        asinh => arg.asinh(),
+                        acosh => arg.acosh(),
+                        atanh => arg.atanh(),
+
+                        exp => arg.exp(),
+                        abs => arg.abs(),
+                        ceil => arg.ceil(),
+                        floor => arg.floor(),
+                        round => arg.round(),
+                        _ => unreachable!(),
+                    }
+                },
+                binary_expr => {
+                    let mut p = pair.into_inner();
+
+                    let op = p.next().ok_or(CalcError::ArgCount)?;
+
+                    let arg1 = eval_single_pair(p.next().ok_or(CalcError::ArgCount)?)?;
+                    let arg2 = eval_single_pair(p.next().ok_or(CalcError::ArgCount)?)?;
+
+                    assert!(p.next().is_none());
+
+                    match op.as_rule() {
+                        min => arg1.min(arg2),
+                        max => arg1.max(arg2),
+                        atan2 => arg1.atan2(arg2),
+                        _ => unreachable!(),
+                    }
+                },
+                suffix_expr => {
+                    let mut p = pair.into_inner();
+
+                    let arg = eval_expr(p.next().ok_or(CalcError::ArgCount)?.into_inner())?;
+                    let op = p.next().ok_or(CalcError::ArgCount)?;
+
+                    assert!(p.next().is_none());
+
+                    match op.as_rule() {
+                        factorial => statrs::function::gamma::gamma(arg + 1.),
+                        _ => unreachable!(),
+                    }
+                },
+                _ => unreachable!(),
+            };
+
+            Ok(result)
+        }
+
+        fn eval_expr(p: Pairs<self::Rule>) -> Result<f64, CalcError> {
+            CLIMBER.climb(
+                p,
+                eval_single_pair,
+                |lhs, op, rhs| {
+                    let lhs = lhs?;
+                    let rhs = rhs?;
+
+                    let result = match op.as_rule() {
+                        add => lhs + rhs,
+                        sub => lhs - rhs,
+                        mul => lhs * rhs,
+                        div => lhs / rhs,
+                        pow => lhs.powf(rhs),
+                        dice => {
+                            let dice_count = lhs as usize;
+                            let dice_faces = rhs as usize;
+
+                            let mut rng = thread_rng();
+                            (0..dice_count).map(|_| rng.gen_range(1..=dice_faces)).sum::<usize>() as f64
+                        },
+                        _ => unreachable!(),
+                    };
+
+                    Ok(result)
+                }
+            )
+        }
+
+        eval_expr(result)
+    }
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_calc_basics() {
+        assert_eq!(3., Calc::eval("1 + 2").unwrap());
+        assert_eq!(3.0f64.ln(), Calc::eval("log 3").unwrap());
+        assert!(6. - Calc::eval("3!").unwrap() < 0.0001);
+        assert_eq!(3., Calc::eval("max 3 2").unwrap());
+    }
+
+    #[test]
+    fn test_binary_unary() {
+        assert_eq!(3.0f64.ln(), Calc::eval("max log 3 log 2").unwrap());
+    }
+
+    #[test]
+    fn test_prefix_suffix() {
+        assert!(6. - Calc::eval("abs 3!").unwrap() < 0.0001);
+    }
+}
+