liquid_feedback_frontend
annotate model/event_processed.lua @ 1404:f99e7df399e6
Text case change
| author | bsw |
|---|---|
| date | Mon Aug 13 19:52:00 2018 +0200 (2018-08-13) |
| parents | 32cc544d5a5b |
| children |
| rev | line source |
|---|---|
| bsw/jbe@1309 | 1 EventProcessed = mondelefant.new_class() |
| bsw/jbe@1309 | 2 EventProcessed.table = 'event_processed' |
| bsw/jbe@1309 | 3 |
| bsw/jbe@1309 | 4 function EventProcessed:get_last_id() |
| bsw/jbe@1309 | 5 |
| bsw/jbe@1309 | 6 local event_processed = self:new_selector() |
| bsw/jbe@1309 | 7 :optional_object_mode() |
| bsw/jbe@1309 | 8 :for_update() |
| bsw/jbe@1309 | 9 :exec() |
| bsw/jbe@1309 | 10 |
| bsw/jbe@1309 | 11 local last_event_id = 0 |
| bsw/jbe@1309 | 12 if event_processed then |
| bsw/jbe@1309 | 13 last_event_id = event_processed.event_id |
| bsw/jbe@1309 | 14 end |
| bsw/jbe@1309 | 15 |
| bsw/jbe@1309 | 16 return last_event_id |
| bsw/jbe@1309 | 17 |
| bsw/jbe@1309 | 18 end |
| bsw/jbe@1309 | 19 |
| bsw/jbe@1309 | 20 function EventProcessed:set_last_id(id) |
| bsw/jbe@1309 | 21 db:query{ "INSERT INTO event_processed (event_id) VALUES (?) ON CONFLICT ((1)) DO UPDATE SET event_id = EXCLUDED.event_id", id } |
| bsw/jbe@1309 | 22 end |