Holger Hans Peter Freyther | 4a62bb0 | 2018-02-25 21:17:30 +0000 | [diff] [blame] | 1 | json = require("json") |
| 2 | socket = require("socket") |
| 3 | socket.unix = require("socket.unix") |
| 4 | |
| 5 | local g_c = socket.unix.dgram() |
| 6 | local g_ms = nil |
| 7 | |
| 8 | local mod = {} |
| 9 | |
| 10 | -- Register the MS instance with the system |
| 11 | function mod.register(ms, path) |
| 12 | g_ms = ms |
| 13 | |
Holger Hans Peter Freyther | 05895a9 | 2018-06-17 19:31:46 +0100 | [diff] [blame] | 14 | osmo.unix_passcred(g_c:getfd()) |
Holger Hans Peter Freyther | 4a62bb0 | 2018-02-25 21:17:30 +0000 | [diff] [blame] | 15 | g_c:connect(path) |
| 16 | |
| 17 | local event = {} |
| 18 | event['ms'] = g_ms |
| 19 | event['type'] = 'register' |
| 20 | g_c:send(json.encode(event)) |
| 21 | end |
| 22 | |
| 23 | -- Send an event |
| 24 | function mod.send(data) |
| 25 | local event = {} |
| 26 | event['ms'] = g_ms |
| 27 | event['type'] = 'event' |
| 28 | event['data'] = data |
| 29 | g_c:send(json.encode(event)) |
| 30 | end |
| 31 | |
| 32 | return mod |