   ## Server Callbacks
 
   def init(:ok) do
+    # init the asset storage agent
+    Agent.start_link(fn ->
+      %{
+        block_cnt: 0,
+        PAprod: [],
+        PAtest: []
+       }
+    end, name: __MODULE__)
+    # init the Repo
     init(:retry, true)
   end
 

  end

  ## Private

  defp tag_loaded?(tag) do
    case :rpc

          unless Map.get(state, :connected), do: Logger.info("PeerAssets.Repo: rpc connection re-established")
          state = state |> Map.put(:connected, true)
          cond do
            retrieve(:block_cnt) == block_cnt ->
              state # no changes
            true ->
              # Parse
              prod_assets = load_assets!(prod_tag)
              test_assets = load_assets!(test_tag)
              # Store
              block_cnt |> store(:block_cnt)
              prod_assets |> store(:PAprod)
              test_assets |> store(:PAtest)
          end
        {:error, _} ->
          # TODO: log error
