history -> hist

include/api.hrl

@@ -12,7 +12,7 @@
 -spec complete(any(),pid()) -> {complete,any()}.
 -spec amend(pid(),any()) -> {complete,any()}.
 -spec event(pid(),any()) -> {complete,any()}.
--spec history(pid()) -> list(#history{}).
+-spec hist(pid()) -> list(#hist{}).
 
 % find task or document in process
 

include/bpe.hrl

@@ -42,15 +42,15 @@
                         module=[] :: [] | atom()}).
 -record(sequenceFlow, { source=[] :: [] | atom(),
                         target=[] :: [] | atom() }).
--record(history,      { ?ITERATOR(feed),
+-record(hist,         { ?ITERATOR(feed),
                         name=[] :: [] | binary(),
                         task=[] :: atom(),
                         time=[] :: term() }).
 -record(process,      { ?ITERATOR(feed), name=[] :: [] | binary(),
                         roles=[] :: list(),
                         tasks=[] :: list(#task{} | #serviceTask{} | #userTask{} | #receiveTask{}),
                         events=[] :: list(#messageEvent{} | #boundaryEvent{} | #timeoutEvent{}),
-                        history=[] :: [],
+                        hist=[] :: [],
                         flows=[] :: list(#sequenceFlow{}),
                         rules=[] :: [],
                         docs=[] :: list(tuple()),
@@ -67,7 +67,7 @@
 
 -record(complete,     { id=[] :: [] | integer() }).
 -record(proc,         { id=[] :: [] | integer() }).
--record(hist,         { id=[] :: [] | integer() }).
+-record(histo,        { id=[] :: [] | integer() }).
 -record(create,       { proc=[] :: [] | #process{} | binary(),
                         docs=[] :: [] | list(#join_application{} | #max_tour{} | #tour_list{}) }).
 -record(amend,        { id=[] :: [] | integer(),

src/bpe.erl

@@ -9,8 +9,8 @@
 
 load(ProcName) -> {ok,Proc} = kvs:get(process,ProcName), Proc.
 
-cleanup(P) -> [ kvs:remove(history,Id) || #history{id=Id} <- bpe:history(P) ],
-                kvs:delete(feed,{history,P}),
+cleanup(P) -> [ kvs:remove(hist,Id) || #hist{id=Id} <- bpe:hist(P) ],
+                kvs:delete(feed,{hist,P}),
                 kvs:remove(process,P).
 
 start(Proc0, Options) ->
@@ -55,9 +55,9 @@ delete_tasks(Proc, Tasks) ->
     Proc#process { tasks = [ Task || Task <- Proc#process.tasks,
                                 lists:member(Task#task.name,Tasks) ] }.
 
-history(ProcId)   -> history(ProcId,undefined).
-history(ProcId,N) -> case kvs:entries(kvs:get(feed,{history,ProcId}),history,N) of
-                          [] -> [#history{time=(bpe:load(ProcId))#process.started}];
+hist(ProcId)   -> hist(ProcId,undefined).
+hist(ProcId,N) -> case kvs:entries(kvs:get(feed,{hist,ProcId}),hist,N) of
+                          [] -> [#hist{time=(bpe:load(ProcId))#process.started}];
                           Res -> Res end.
 
 source(Name, Proc) ->

src/bpe_app.erl

@@ -18,8 +18,8 @@ start(_StartType, _StartArgs) ->
 stop(_State) -> ok.
 
 worker(#process{id=Id}=P) ->
-    case bpe:history(Id) of
-         [H|_] -> worker_do(calendar:time_difference(H#history.time,calendar:local_time()),P);
+    case bpe:hist(Id) of
+         [H|_] -> worker_do(calendar:time_difference(H#hist.time,calendar:local_time()),P);
             __ -> skip end.
 
 worker_do({Days,Time},P) when Days >= 14 -> skip;

src/bpe_metainfo.erl

@@ -8,7 +8,7 @@
 metainfo() ->
     #schema{name = bpe, tables = [
           #table{name = process, fields=record_info(fields, process)},
-          #table{name = history, fields=record_info(fields, history)}
+          #table{name = hist, fields=record_info(fields, hist)}
 %          #table{name = sequenceFlow, fields=record_info(fields, sequenceFlow)},
 %          #table{name = userTask, fields=record_info(fields, userTask)},
 %          #table{name = serviceTask, fields=record_info(fields, serviceTask)},

src/bpe_n2o.erl

@@ -16,9 +16,9 @@ info(#amend{id=Proc,docs=Docs}=M,R,S) ->
     n2o:info(?MODULE, "amend:~w",[M]),
     {reply,{bert,{io,bpe:amend(Proc,Docs), <<>>}},R,S};
 
-info(#hist{id=Proc}=M,R,S) ->
+info(#histo{id=Proc}=M,R,S) ->
     n2o:info(?MODULE, "hist:~w",[M]),
-    {reply,{bert,{io,bpe:history(Proc), <<>>}},R,S};
+    {reply,{bert,{io,bpe:hist(Proc), <<>>}},R,S};
 
 info(#proc{id=Proc}=M,R,S) ->
     n2o:info(?MODULE, "proc:~w",[M]),

src/bpe_proc.erl

@@ -13,8 +13,8 @@ process_event(Event,Proc) ->
     io:format("Event Targets: ~p",[Targets]),
     {Status,{Reason,Target},ProcState} = bpe_event:handle_event(Event,bpe_task:find_flow(Targets),Proc),
 
-    kvs:add(#history { id = kvs:next_id("history",1),
-                       feed_id = {history,ProcState#process.id},
+    kvs:add(#hist { id = kvs:next_id("hist",1),
+                       feed_id = {hist,ProcState#process.id},
                        name = ProcState#process.name,
                        time = calendar:local_time(),
                        task = { event, element(#messageEvent.name,Event) }}),
@@ -50,8 +50,8 @@ process_flow(Stage,Proc,NoFlow) ->
          {List,_,[]}  -> bpe_task:handle_task(Task,Curr,bpe_task:find_flow(Stage,List),Proc);
          {List,_,_}   -> {reply,{complete,bpe_task:find_flow(Stage,List)},Proc} end,
 
-    kvs:add(#history { id = kvs:next_id("history",1),
-                       feed_id = {history,ProcState#process.id},
+    kvs:add(#hist { id = kvs:next_id("hist",1),
+                       feed_id = {hist,ProcState#process.id},
                        name = ProcState#process.name,
                        time = calendar:local_time(),
                        task = {task, Curr} }),
@@ -112,8 +112,8 @@ handle_info({timer,ping}, State=#process{task=Task,timer=Timer,id=Id,events=Even
     Time2 = calendar:local_time(),
     %kvs:info(?MODULE,"Ping: ~p, Task ~p, Event ~p, Record ~p ~n", [Id,Task,Name,Record]),
 
-    {DD,Diff} = case bpe:history(Id,1) of
-         [#history{time=Time1}] -> calendar:time_difference(Time1,Time2);
+    {DD,Diff} = case bpe:hist(Id,1) of
+         [#hist{time=Time1}] -> calendar:time_difference(Time1,Time2);
           _ -> {immediate,timeout} end,
 
     case {{DD,Diff} < {Days,Pattern}, Record} of