feat: add database
This commit is contained in:
parent
8355f30948
commit
a408a38ffb
3 changed files with 97 additions and 47 deletions
|
@ -3,6 +3,7 @@ defmodule Todo.Cache do
|
||||||
|
|
||||||
@impl GenServer
|
@impl GenServer
|
||||||
def init(_init_args) do
|
def init(_init_args) do
|
||||||
|
Todo.Database.start()
|
||||||
{:ok, %{}}
|
{:ok, %{}}
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@ -13,7 +14,7 @@ defmodule Todo.Cache do
|
||||||
{:reply, process, state}
|
{:reply, process, state}
|
||||||
|
|
||||||
:error ->
|
:error ->
|
||||||
new_process = Todo.Server.start()
|
{:ok, new_process} = Todo.Server.start(name)
|
||||||
|
|
||||||
new_state = Map.put(state, name, new_process)
|
new_state = Map.put(state, name, new_process)
|
||||||
|
|
||||||
|
|
51
lib/todo/database.ex
Normal file
51
lib/todo/database.ex
Normal file
|
@ -0,0 +1,51 @@
|
||||||
|
defmodule Todo.Database do
|
||||||
|
use GenServer
|
||||||
|
|
||||||
|
@db_folder "./persist"
|
||||||
|
|
||||||
|
def start do
|
||||||
|
GenServer.start(__MODULE__, nil, name: __MODULE__)
|
||||||
|
end
|
||||||
|
|
||||||
|
def store(key, data) do
|
||||||
|
GenServer.cast(__MODULE__, {:store, key, data})
|
||||||
|
end
|
||||||
|
|
||||||
|
def get(key) do
|
||||||
|
GenServer.call(__MODULE__, {:get, key})
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def init(_) do
|
||||||
|
File.mkdir_p!(@db_folder)
|
||||||
|
|
||||||
|
{:ok, nil}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_cast({:store, key, data}, state) do
|
||||||
|
key
|
||||||
|
|> file_name()
|
||||||
|
|> File.write!(:erlang.term_to_binary(data))
|
||||||
|
|
||||||
|
{:noreply, state}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_call({:get, key}, _, state) do
|
||||||
|
data =
|
||||||
|
case File.read(file_name(key)) do
|
||||||
|
{:ok, contents} ->
|
||||||
|
:erlang.binary_to_term(contents)
|
||||||
|
|
||||||
|
_ ->
|
||||||
|
nil
|
||||||
|
end
|
||||||
|
|
||||||
|
{:reply, data, state}
|
||||||
|
end
|
||||||
|
|
||||||
|
def file_name(key) do
|
||||||
|
Path.join(@db_folder, to_string(key))
|
||||||
|
end
|
||||||
|
end
|
|
@ -1,52 +1,8 @@
|
||||||
defmodule Todo.Server do
|
defmodule Todo.Server do
|
||||||
use GenServer
|
use GenServer
|
||||||
|
|
||||||
@impl GenServer
|
def start(name) do
|
||||||
def init(%_{} = todo_list) do
|
GenServer.start(__MODULE__, name)
|
||||||
{:ok, todo_list}
|
|
||||||
end
|
|
||||||
|
|
||||||
@impl GenServer
|
|
||||||
def init(entries) do
|
|
||||||
{:ok, Todo.List.new(entries)}
|
|
||||||
end
|
|
||||||
|
|
||||||
@impl GenServer
|
|
||||||
def handle_call({:entries, date}, _from, todo_list) do
|
|
||||||
entries = Todo.List.entries(todo_list, date)
|
|
||||||
|
|
||||||
{:reply, entries, todo_list}
|
|
||||||
end
|
|
||||||
|
|
||||||
@impl GenServer
|
|
||||||
def handle_cast({:add, entry}, todo_list) do
|
|
||||||
new_todo_list = Todo.List.add(todo_list, entry)
|
|
||||||
|
|
||||||
{:noreply, new_todo_list}
|
|
||||||
end
|
|
||||||
|
|
||||||
@impl GenServer
|
|
||||||
def handle_cast({:update, id, update_fun}, todo_list) do
|
|
||||||
new_todo_list = Todo.List.update(todo_list, id, update_fun)
|
|
||||||
|
|
||||||
{:noreply, new_todo_list}
|
|
||||||
end
|
|
||||||
|
|
||||||
@impl GenServer
|
|
||||||
def handle_cast({:delete, id}, todo_list) do
|
|
||||||
new_todo_list = Todo.List.delete(todo_list, id)
|
|
||||||
|
|
||||||
{:noreply, new_todo_list}
|
|
||||||
end
|
|
||||||
|
|
||||||
def start(entries \\ [])
|
|
||||||
|
|
||||||
def start(%_{} = todo_list) do
|
|
||||||
GenServer.start(__MODULE__, todo_list)
|
|
||||||
end
|
|
||||||
|
|
||||||
def start(entries) do
|
|
||||||
GenServer.start(__MODULE__, entries)
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def add(pid, entry) do
|
def add(pid, entry) do
|
||||||
|
@ -64,4 +20,46 @@ defmodule Todo.Server do
|
||||||
def delete(pid, id) do
|
def delete(pid, id) do
|
||||||
GenServer.cast(pid, {:delete, id})
|
GenServer.cast(pid, {:delete, id})
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def init(name) do
|
||||||
|
{:ok, {name, nil}, {:continue, :init}}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_continue(:init, {name, nil}) do
|
||||||
|
todo_list = Todo.Database.get(name) || Todo.List.new()
|
||||||
|
{:noreply, {name, todo_list}}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_call({:entries, date}, _from, {name, todo_list}) do
|
||||||
|
entries = Todo.List.entries(todo_list, date)
|
||||||
|
|
||||||
|
{:reply, entries, {name, todo_list}}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_cast({:add, entry}, {name, todo_list}) do
|
||||||
|
new_todo_list = Todo.List.add(todo_list, entry)
|
||||||
|
Todo.Database.store(name, new_todo_list)
|
||||||
|
|
||||||
|
{:noreply, {name, new_todo_list}}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_cast({:update, id, update_fun}, {name, todo_list}) do
|
||||||
|
new_todo_list = Todo.List.update(todo_list, id, update_fun)
|
||||||
|
Todo.Database.store(name, new_todo_list)
|
||||||
|
|
||||||
|
{:noreply, {name, new_todo_list}}
|
||||||
|
end
|
||||||
|
|
||||||
|
@impl GenServer
|
||||||
|
def handle_cast({:delete, id}, {name, todo_list}) do
|
||||||
|
new_todo_list = Todo.List.delete(todo_list, id)
|
||||||
|
Todo.Database.store(name, new_todo_list)
|
||||||
|
|
||||||
|
{:noreply, {name, new_todo_list}}
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in a new issue