1 EventProcessed = mondelefant.new_class()

2 EventProcessed.table = 'event_processed'

3

4 function EventProcessed:get_last_id()

5

6 local event_processed = self:new_selector()

7 :optional_object_mode()

8 :for_update()

9 :exec()

10

11 local last_event_id = 0

12 if event_processed then

13 last_event_id = event_processed.event_id

14 end

15

16 return last_event_id

17

18 end

19

20 function EventProcessed:set_last_id(id)

21 db:query{ "INSERT INTO event_processed (event_id) VALUES (?) ON CONFLICT ((1)) DO UPDATE SET event_id = EXCLUDED.event_id", id }

22 end