/
aggregate.ex
69 lines (55 loc) · 1.62 KB
/
aggregate.ex
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
defmodule OnePiece.Commanded.Aggregate do
@moduledoc """
Defines "Aggregate" modules.
"""
@typedoc """
A struct that represents an aggregate.
"""
@type t :: struct()
@type event :: struct()
@doc """
Apply a given event to the aggregate returning the new aggregate state.
## Example
def apply(%MyAggregate{} = aggregate, %MyEvent{} = event) do
aggregate
|> Map.put(:name, event.name)
|> Map.put(:description, event.description)
end
"""
@callback apply(aggregate :: t(), event :: event()) :: t()
@doc """
Convert the module into a `Aggregate` behaviour and a `t:t/0`.
It adds an `apply/2` callback to the module as a fallback, return the aggregate as it is.
## Using
- `OnePiece.Commanded.Entity`
## Usage
defmodule Account do
use OnePiece.Commanded.Aggregate, identifier: :name
embedded_schema do
field :description, :string
end
@impl OnePiece.Commanded.Aggregate
def apply(%Account{} = aggregate, %AccountOpened{} = event) do
aggregate
|> Map.put(:name, event.name)
|> Map.put(:description, event.description)
end
end
"""
@spec __using__(opts :: []) :: any()
defmacro __using__(opts \\ []) do
quote do
use OnePiece.Commanded.Entity, unquote(opts)
@behaviour OnePiece.Commanded.Aggregate
@before_compile OnePiece.Commanded.Aggregate
end
end
defmacro __before_compile__(env) do
quote do
@impl OnePiece.Commanded.Aggregate
def apply(%unquote(env.module){} = aggregate, _event) do
aggregate
end
end
end
end