commit 5dc8616ee2e3462f5779f32a5f7f1f2f3c3c35b8 · hauleth.dev/esl_hn

+1

lib/esl_hn/application.ex

···

       8
       8
        
           children = [

     

       9
       9
        
             EslHnWeb.Telemetry,

     

       10
       10
        
             {Phoenix.PubSub, name: EslHn.PubSub},

     

       11
       11
       +
             {EslHn.Cache, name: EslHn},

     

       11
       12
        
             EslHnWeb.Endpoint

     

       12
       13
        
           ]

     

       13
       14

+22 -1

lib/esl_hn/cache.ex

···

       9
       9
        
           end

     

       10
       10
        
         end

     

       11
       11
        
       

     

       12
       12
       -
         def read(tid, key) do

     

       12
       12
       +
         def fetch(tid, key) do

     

       13
       13
        
           case :ets.lookup(tid, key) do

     

       14
       14
        
             [{^key, data}] -> {:ok, data}

     

       15
       15
        
             _ -> :error

     

       16
       16
        
           end

     

       17
       17
        
         end

     

       18
       18
        
       

     

       19
       19
       +
         def get(tid, key, default \\ nil) do

     

       20
       20
       +
           case fetch(tid, key) do

     

       21
       21
       +
             {:ok, val} -> val

     

       22
       22
       +
             :error -> default

     

       23
       23
       +
           end

     

       24
       24
       +
         end

     

       25
       25
       +
       

     

       19
       26
        
         def write(tid, key, data) do

     

       20
       27
        
           true = :ets.insert(tid, {key, data})

     

       28
       28
       +
       

     

       29
       29
       +
           :ok

     

       30
       30
       +
         end

     

       31
       31
       +
       

     

       32
       32
       +
         def write_all(tid, data) do

     

       33
       33
       +
           true = :ets.insert(tid, data)

     

       34
       34
       +
       

     

       35
       35
       +
           :ok

     

       36
       36
       +
         end

     

       37
       37
       +
       

     

       38
       38
       +
         def prune(tid, id), do: :ets.delete(tid, id)

     

       39
       39
       +
       

     

       40
       40
       +
         def prune_all(tid, ids) do

     

       41
       41
       +
           for id <- ids, do: :ets.delete(tid, id)

     

       21
       42
        
       

     

       22
       43
        
           :ok

     

       23
       44
        
         end

+3 -3

test/esl_hn/cache_test.exs

···

       12
       12
        
       

     

       13
       13
        
             check all(key <- term(), data <- term()) do

     

       14
       14
        
               assert :ok == @subject.write(tid, key, data)

     

       15
       15
       -
               assert {:ok, data} == @subject.read(tid, key)

     

       15
       15
       +
               assert {:ok, data} == @subject.fetch(tid, key)

     

       16
       16
        
             end

     

       17
       17
        
           end

     

       18
       18
        
       

     

       19
       19
        
           test "fetching non existent key result in error" do

     

       20
       20
        
             assert {:ok, _pid, tid} = start_supervised(@subject)

     

       21
       21
        
       

     

       22
       22
       -
             assert :error == @subject.read(tid, :non_existent)

     

       22
       22
       +
             assert :error == @subject.fetch(tid, :non_existent)

     

       23
       23
        
           end

     

       24
       24
        
         end

     

       25
       25
        
       

     
···

       30
       30
        
       

     

       31
       31
        
             check all(key <- term(), data <- term()) do

     

       32
       32
        
               assert :ok == @subject.write(name, key, data)

     

       33
       33
       -
               assert {:ok, data} == @subject.read(name, key)

     

       33
       33
       +
               assert {:ok, data} == @subject.fetch(name, key)

     

       34
       34
        
             end

     

       35
       35
        
           end

     

       36
       36
        
         end