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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
-module(bnt_bounty).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% TYPES %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
-type id() :: ataxia_id:type().
-type job() :: {atom(), atom(), list(any())}.
-record
(
bounty,
{
deadline :: ataxia_time:type(),
user :: ataxia_security:user(),
job :: job()
}
).
-type type() :: #bounty{}.
-export_type([type/0, id/0]).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% EXPORTS %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
-export
(
[
generate/4,
resolve/0
]
).
-export
(
[
get_deadline/1,
get_user/1,
get_job/1
]
).
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% LOCAL FUNCTIONS %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%% EXPORTED FUNCTIONS %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
-spec generate
(
ataxia_security:user(),
ataxia_time:type(),
ataxia_time:type(),
job()
)
-> {'ok', ataxia_id:type()}.
generate (User, NotBefore, Deadline, Job) ->
Janitor = ataxia_security:janitor(),
JanitorOnly = ataxia_security:allow_only(Janitor),
JanitorAndUser = ataxia_security:add_access(User, JanitorOnly),
Bounty =
#bounty
{
deadline = Deadline,
user = User,
job = Job
},
{ok, BountyID} =
ataxia_client:add
(
bounty_db,
JanitorAndUser,
JanitorAndUser,
ataxia_lock:locked(User, NotBefore),
Bounty
),
{ok, BountyID}.
-spec resolve () -> type().
resolve () ->
Lock = ataxia_lock:locked(ataxia_security:admin(), ataxia_time:now()),
{ok, Bounty, BountyID} =
ataxia_client:update_and_fetch_any
(
bounty_db,
ataxia_security:janitor(),
ataxic:update_lock(ataxic:constant(Lock)),
ataxic:constant(true)
),
{Module, Function, Params} = Bounty#bounty.job,
erlang:apply(Module, Function, [BountyID|Params]).
-spec get_deadline (type()) -> ataxia_time:type().
get_deadline (Bounty) -> Bounty#bounty.deadline.
-spec get_user (type()) -> ataxia_security:user().
get_user (Bounty) -> Bounty#bounty.user.
-spec get_job (type()) -> job().
get_job (Bounty) -> Bounty#bounty.job.
|
