   ## 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
 

      load_tag!(test_tag)
      Logger.info("PeerAssets.Repo: initialized (reload_interval: " <> Integer.to_string(reload_interval) <> ")")
      reload_assets(1)
      {:ok, %{block_cnt: 0, connected: true}}
    rescue
      _ ->
        if log, do: Logger.warn("PeerAssets.Repo: Failed to establish rpc connection. Will retry every second.")

        :timer.sleep(1000)
        init(:retry, false)
    end
  end

  defp reload_assets(timeout) do
