Packages

slurpee

0.0.18
0.0.18 0.0.17 0.0.16 0.0.15 0.0.14 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

A GUI to manage EVM blockchain ingestion

HexDocs

Current section

Files

Jump to
Readme
18 Versions
16 Dependencies
Dependants
Files
Activity
slurpee lib slurpee new_head_handler.ex
Raw

lib/slurpee/new_head_handler.ex 

defmodule Slurpee.NewHeadHandler do

  @type blockchain :: Slurp.Blockchains.Blockchain.id()

  @type block_number :: Slurp.Adapter.block_number()



  @callback handle_new_head(blockchain, block_number) :: no_return



  require Logger



  def handle_new_head(blockchain, block_number) do

    Logger.info("received new head: #{block_number}")



    Phoenix.PubSub.broadcast(

      Slurpee.PubSub,

      "heads:new_head_received",

      {"heads:new_head_received", blockchain.id, block_number}

    )

  end

end