nock typespecs

.formatter.exs

@@ -1,4 +1,5 @@
 # Used by "mix format"
 [
-  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"],
+  line_length: 78
 ]

hoon/anoma.hoon

@@ -0,0 +1,79 @@
+::  Simple demo Nock standard library.
+!.
+=~  %909
+~%  %k.909  ~  ~
+::  layer 0: version stub (+3)
+|%
+++  anoma  +
+--
+::  layer 1: basic arithmetic (+1)
+~%  %one  +  ~
+|%
+++  dec  ::  +342
+  ~/  %dec
+  |=  a=@
+  ?<  =(0 a)
+  =|  b=@
+  |-  ^-  @
+  ?:  =(a +(b))  b
+  $(b +(b))
+++  add  ::  +20
+  ~/  %add
+  |=  [a=@ b=@]
+  ^-  @
+  ?:  =(0 a)  b
+  $(a (dec a), b +(b))
+++  sub  ::  +47
+  ~/  %sub
+  |=  [a=@ b=@]
+  ^-  @
+  ?:  =(0 b)  a
+  $(a (dec a), b (dec b))
+++  lth  ::  +343
+  ~/  %lth
+  |=  [a=@ b=@]
+  ^-  ?
+  ?&  !=(a b)
+      |-
+      ?|  =(0 a)
+          ?&  !=(0 b)
+              $(a (dec a), b (dec b))
+  ==  ==  ==
+++  lte  ::  +84
+  ~/  %lte
+  |=  [a=@ b=@]
+  ^-  ?
+  |(=(a b) (lth a b))
+++  gth  ::  +43
+  ~/  %gth
+  |=  [a=@ b=@]
+  ^-  ?
+  !(lte a b)
+++  gte  ::  +22
+  ~/  %gte
+  |=  [a=@ b=@]
+  ^-  ?
+  !(lth a b)
+++  mul  ::  +4
+  ~/  %mul
+  |:  [a=`@`1 b=`@`1]
+  =|  c=@
+  |-  ^-  @
+  ?:  =(0 a)  c
+  $(a (dec a), c (add b c))
+++  div  ::  +170
+  ~/  %div
+  |:  [a=`@`1 b=`@`1]
+  ?<  =(0 b)
+  =|  c=@
+  |-  ^-  @
+  ?:  (lth a b)  c
+  $(a (sub a b), c +(c))
+++  mod  ::  +46
+  ~/  %mod
+  |:  [a=`@`1 b=`@`1]
+  ^-  @
+  ?<  =(0 b)
+  (sub a (mul b (div a b)))
+--
+==

lib/anoma/block.ex

@@ -48,7 +48,8 @@ defmodule Anoma.Block do
   """
   @spec create(
           Base.t(),
-          Serializer.public_key() | {Serializer.public_key(), Serializer.private_key()},
+          Serializer.public_key()
+          | {Serializer.public_key(), Serializer.private_key()},
           non_neg_integer()
         ) :: t()
 
@@ -71,7 +72,8 @@ defmodule Anoma.Block do
   end
 
   # create data which can easily be signed
-  @spec signable(Base.t(), Serializer.public_key(), non_neg_integer()) :: binary()
+  @spec signable(Base.t(), Serializer.public_key(), non_neg_integer()) ::
+          binary()
   defp signable(block, pub_key, round) do
     Serializer.serialize({Base.digest(block), round, pub_key})
   end
@@ -86,11 +88,18 @@ defmodule Anoma.Block do
 
   @spec encode(t()) :: tuple()
   def encode(block) do
-    {__MODULE__, block.id, block.block, block.round, block.pub_key, block.signature}
+    {__MODULE__, block.id, block.block, block.round, block.pub_key,
+     block.signature}
   end
 
   def decode({__MODULE__, id, block, round, pub_key, sig}) do
-    %Block{id: id, block: block, round: round, pub_key: pub_key, signature: sig}
+    %Block{
+      id: id,
+      block: block,
+      round: round,
+      pub_key: pub_key,
+      signature: sig
+    }
   end
 
   @doc """
@@ -123,7 +132,10 @@ defmodule Anoma.Block do
   def create_table(table_key, rocks?) do
     resp =
       if rocks? do
-        :mnesia.create_table(table_key, attributes: attributes(), rocksdb_copies: [node()])
+        :mnesia.create_table(table_key,
+          attributes: attributes(),
+          rocksdb_copies: [node()]
+        )
       else
         :mnesia.create_table(table_key, attributes: attributes())
       end

lib/anoma/logic.ex

@@ -82,7 +82,14 @@ defmodule Anoma.Logic do
   # These are the known ops, not the full set.
   # these are what will be compiled
 
-  @type compiled_op() :: Lt.t() | Branch.t() | Neg.t() | Mul.t() | Add.t() | Inc.t() | number()
+  @type compiled_op() ::
+          Lt.t()
+          | Branch.t()
+          | Neg.t()
+          | Mul.t()
+          | Add.t()
+          | Inc.t()
+          | number()
 
   @typedoc """
 

lib/anoma/node/executor/communicator.ex

@@ -29,15 +29,20 @@ defmodule Anoma.Node.Executor.Communicator do
   end
 
   def start_link(arg) do
-    GenServer.start_link(__MODULE__, arg, Utility.name(arg, &Utility.com_name/1))
+    GenServer.start_link(
+      __MODULE__,
+      arg,
+      Utility.name(arg, &Utility.com_name/1)
+    )
   end
 
   ############################################################
   #                      Public RPC API                      #
   ############################################################
 
   # Transactions
-  @spec new_transactions(pid(), Enumerable.t(PartialTx.t())) :: Primary.response()
+  @spec new_transactions(pid(), Enumerable.t(PartialTx.t())) ::
+          Primary.response()
   def new_transactions(communicator, transactions) do
     GenServer.call(communicator, {:transactions, transactions})
   end
@@ -56,7 +61,8 @@ defmodule Anoma.Node.Executor.Communicator do
   ############################################################
 
   # make this more interesting later
-  @spec broadcast_transactions(t(), Enumerable.t(PartialTx.t())) :: Primary.response()
+  @spec broadcast_transactions(t(), Enumerable.t(PartialTx.t())) ::
+          Primary.response()
   defp broadcast_transactions(agent, trans) do
     Primary.new_transactions(agent.primary, trans)
   end

lib/anoma/node/executor/primary.ex

@@ -38,7 +38,8 @@ defmodule Anoma.Node.Executor.Primary do
     GenServer.call(primary, :dump_state)
   end
 
-  @spec new_transactions(GenServer.server(), Enumerable.t(PartialTx.t())) :: response()
+  @spec new_transactions(GenServer.server(), Enumerable.t(PartialTx.t())) ::
+          response()
   def new_transactions(primary, transactions) do
     GenServer.call(primary, {:transactions, transactions})
   end

lib/anoma/node/intent/communicator.ex

@@ -21,7 +21,11 @@ defmodule Anoma.Node.Intent.Communicator do
   end
 
   def start_link(arg) do
-    GenServer.start_link(__MODULE__, arg, Utility.name(arg, &Utility.com_name/1))
+    GenServer.start_link(
+      __MODULE__,
+      arg,
+      Utility.name(arg, &Utility.com_name/1)
+    )
   end
 
   ############################################################
@@ -98,7 +102,10 @@ defmodule Anoma.Node.Intent.Communicator do
 
   @spec broadcast_intent(t(), Intent.t()) :: :ok
   defp broadcast_intent(com, intent) do
-    Utility.broadcast(MapSet.put(com.subscribers, com.pool), {:new_intent, intent})
+    Utility.broadcast(
+      MapSet.put(com.subscribers, com.pool),
+      {:new_intent, intent}
+    )
   end
 
   @spec broadcast_intents(t(), GenServer.server()) :: :ok

lib/anoma/partialtx.ex

@@ -23,13 +23,18 @@
 
   @spec add_output(t(), Resource.t()) :: t()
   def add_output(partial, output) do
-    %PartialTx{partial | outputs: update_resource_set(partial.outputs, output)}
+    %PartialTx{
+      partial
+      | outputs: update_resource_set(partial.outputs, output)
+    }
   end
 
   @spec balanced(t()) :: boolean()
   def balanced(%PartialTx{inputs: inputs, outputs: outputs}) do
     inputs
-    |> Map.merge(outputs, fn _k, i, o -> add_quantities(i) - add_quantities(o) end)
+    |> Map.merge(outputs, fn _k, i, o ->
+      add_quantities(i) - add_quantities(o)
+    end)
     |> Enum.all?(fn {_k, v} -> v == 0 end)
   end
 
@@ -90,7 +95,7 @@
   # Helpers
   ######################################################################
 
   @doc """
   I update the resource set with the new resource
 
 
@@ -118,8 +123,11 @@
   end
 
   @spec sub_quantities(Resource.t(), Resource.t()) :: Resource.t()
   defp sub_quantities(resource_1, resource_2) do
-    %Resource{resource_1 | quantity: resource_1.quantity - resource_2.quantity}
+    %Resource{
+      resource_1
+      | quantity: resource_1.quantity - resource_2.quantity
+    }
   end
 end