defmodule BazVenueAdapterOpenSea.SubscribeVenueWebSocket do
  @type venue :: Baz.Venues.Venue.t()
  @type slugs :: String.t()
  @type result :: term

  @spec subscribe_venue_web_socket(venue, slugs) :: result
  def subscribe_venue_web_socket(venue, slugs) do
    venue_web_socket = Baz.VenueWebSockets.filter_and_order(where: [venue: venue.name]) |> List.first()
    BazVenueAdapterOpenSea.WebSocket.subscribe_collection_events(venue_web_socket.pid, slugs)
  end
end