commit 1dae963c42d827f338590dbb091345b6ea5ecd30 · hauleth.dev/esl_hn

+2

config/dev.exs

···

       11
       11
        
           "TQ20YLfpm8CWUZ0wvMVvXwKLjOdxb6//anr3iafpvW15LKlsoMez2OFUTifz0gxs",

     

       12
       12
        
         watchers: []

     

       13
       13
        
       

     

       14
       14
       +
       config :esl_hn, refresh: :timer.seconds(5)

     

       15
       15
       +
       

     

       14
       16
        
       # ## SSL Support

     

       15
       17
        
       #

     

       16
       18
        
       # In order to use HTTPS in development, a self-signed

+3 -3

config/runtime.exs

···

       15
       15
        
         config :esl_hn, EslHnWeb.Endpoint, server: true

     

       16
       16
        
       end

     

       17
       17
        
       

     

       18
       18
       -
       config :esl_hn,

     

       19
       19
       -
         refresh: CR.duration("ESL_HN_REFRESH", {:minutes, 5})

     

       20
       20
       -
       

     

       21
       18
        
       if config_env() == :prod do

     

       19
       19
       +
         config :esl_hn,

     

       20
       20
       +
           refresh: CR.duration("ESL_HN_REFRESH", {:minutes, 5})

     

       21
       21
       +
       

     

       22
       22
        
         secret_key_base =

     

       23
       23
        
           System.get_env("SECRET_KEY_BASE") ||

     

       24
       24
        
             raise """

+4

lib/esl_hn/cache.ex

···

       1
       1
        
       defmodule EslHn.Cache do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Simple cache implementation using ETS tables

     

       4
       4
       +
         """

     

       5
       5
       +
       

     

       2
       6
        
         use GenServer

     

       3
       7
        
       

     

       4
       8
        
         def start_link(opts) do

+4

lib/esl_hn/hn.ex

···

       1
       1
        
       defmodule EslHn.Hn do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Simple HTTP client for Hacker News API

     

       4
       4
       +
         """

     

       5
       5
       +
       

     

       2
       6
        
         alias EslHn.Hn.Story

     

       3
       7
        
       

     

       4
       8
        
         # TODO: Is there a way to limit amount of returned entries in query?

+6

lib/esl_hn/hn/story.ex

···

       1
       1
        
       defmodule EslHn.Hn.Story do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Schema for describing Hacker News stories

     

       4
       4
       +
       

     

       5
       5
       +
         Not all fields for it are currently used.

     

       6
       6
       +
         """

     

       7
       7
       +
       

     

       2
       8
        
         use Ecto.Schema

     

       3
       9
        
       

     

       4
       10
        
         import Ecto.Changeset

+3

lib/esl_hn/refresher.ex

···

       1
       1
        
       defmodule EslHn.Refresher do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Module defining process that is responsible for refreshing cached data

     

       4
       4
       +
         """

     

       2
       5
        
         use GenServer

     

       3
       6
        
       

     

       4
       7
        
         alias EslHn.Hn

+4

lib/esl_hn_web/api/controller.ex

···

       1
       1
        
       defmodule EslHnWeb.API.Controller do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Controller for serving HN top stories cache

     

       4
       4
       +
         """

     

       5
       5
       +
       

     

       2
       6
        
         use EslHnWeb, :controller

     

       3
       7
        
       

     

       4
       8
        
         def index(conn, params) do

+4

lib/esl_hn_web/api/json.ex

···

       1
       1
        
       defmodule EslHnWeb.API.JSON do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Simple JSON view into Hacker New stories

     

       4
       4
       +
         """

     

       5
       5
       +
       

     

       2
       6
        
         def index(attrs) do

     

       3
       7
        
           Enum.map(attrs.items, &one/1)

     

       4
       8
        
         end

+10 -5

lib/esl_hn_web/api/socket.ex

···

       1
       1
        
       defmodule EslHnWeb.API.Socket do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         WebSocket API for serving top stories news

     

       4
       4
       +
         """

     

       5
       5
       +
       

     

       2
       6
        
         @behaviour Phoenix.Socket.Transport

     

       7
       7
       +
       

     

       8
       8
       +
         alias EslHnWeb.API.JSON, as: View

     

       3
       9
        
       

     

       4
       10
        
         @impl true

     

       5
       11
        
         def child_spec(_opts), do: :ignore

     
···

       19
       25
        
         end

     

       20
       26
        
       

     

       21
       27
        
         @impl true

     

       22
       22
       -
         def handle_in({message, opts}, state) do

     

       23
       23
       -
           dbg({message, opts})

     

       24
       24
       -
       

     

       28
       28
       +
         def handle_in({_message, _opts}, state) do

     

       29
       29
       +
           # Ignore all incoming messages

     

       25
       30
        
           {:ok, state}

     

       26
       31
        
         end

     

       27
       32
        
       

     

       28
       33
        
         @impl true

     

       29
       34
        
         def handle_info(:do_init, state) do

     

       30
       35
        
           stories = EslHn.all(1, 50)

     

       31
       31
       -
           data = EslHnWeb.API.JSON.index(%{items: stories})

     

       36
       36
       +
           data = View.index(%{items: stories})

     

       32
       37
        
       

     

       33
       38
        
           {:push, {:text, JSON.encode_to_iodata!(data)}, state}

     

       34
       39
        
         end

     

       35
       40
        
       

     

       36
       41
        
         def handle_info({:new_stories, stories}, state) do

     

       37
       37
       -
           data = EslHnWeb.API.JSON.index(%{items: stories})

     

       42
       42
       +
           data = View.index(%{items: stories})

     

       38
       43
        
       

     

       39
       44
        
           {:push, {:text, JSON.encode_to_iodata!(data)}, state}

     

       40
       45
        
         end

+4

test/support/data.ex

···

       1
       1
        
       defmodule EslHn.Test.Data do

     

       2
       2
       +
         @moduledoc """

     

       3
       3
       +
         Additional `StreamData` generators used during testing

     

       4
       4
       +
         """

     

       5
       5
       +
       

     

       2
       6
        
         use ExUnitProperties

     

       3
       7
        
       

     

       4
       8
        
         alias EslHn.Hn.Story