bsw/jbe@1309: EventProcessed = mondelefant.new_class()
bsw/jbe@1309: EventProcessed.table = 'event_processed'
bsw/jbe@1309: 
bsw/jbe@1309: function EventProcessed:get_last_id()
bsw/jbe@1309:   
bsw/jbe@1309:   local event_processed = self:new_selector()
bsw/jbe@1309:     :optional_object_mode()
bsw/jbe@1309:     :for_update()
bsw/jbe@1309:     :exec()
bsw/jbe@1309:     
bsw/jbe@1309:   local last_event_id = 0
bsw/jbe@1309:   if event_processed then
bsw/jbe@1309:     last_event_id = event_processed.event_id
bsw/jbe@1309:   end
bsw/jbe@1309:   
bsw/jbe@1309:   return last_event_id
bsw/jbe@1309:   
bsw/jbe@1309: end
bsw/jbe@1309: 
bsw/jbe@1309: function EventProcessed:set_last_id(id)
bsw/jbe@1309:   db:query{ "INSERT INTO event_processed (event_id) VALUES (?) ON CONFLICT ((1)) DO UPDATE SET event_id = EXCLUDED.event_id", id }
bsw/jbe@1309: end