|
| 1 | +package notifications_test |
| 2 | + |
| 3 | +import ( |
| 4 | + "encoding/json" |
| 5 | + "github.com/icinga/icinga-notifications/pkg/plugin" |
| 6 | + "github.com/icinga/icinga-testing/utils/eventually" |
| 7 | + "github.com/jmoiron/sqlx" |
| 8 | + "github.com/stretchr/testify/require" |
| 9 | + "golang.org/x/sys/unix" |
| 10 | + "os" |
| 11 | + "testing" |
| 12 | + "time" |
| 13 | +) |
| 14 | + |
| 15 | +// TestNotificationRoundTrip instructs an Icinga 2 node to send a notification back for further inspection. |
| 16 | +func TestNotificationRoundTrip(t *testing.T) { |
| 17 | + fileChFifo := "./tmp/file-fifo" |
| 18 | + require.NoError(t, unix.Mkfifo(fileChFifo, 0666), "mkfifo(3)") |
| 19 | + |
| 20 | + rdb := getDatabase(t) |
| 21 | + notifications := it.IcingaNotificationsInstanceT(t, rdb) |
| 22 | + icinga := it.Icinga2NodeT(t, "master") |
| 23 | + icinga.EnableIcingaNotifications(notifications) |
| 24 | + require.NoError(t, icinga.Reload(), "icinga.Reload()") |
| 25 | + |
| 26 | + db, err := sqlx.Open(rdb.Driver(), rdb.DSN()) |
| 27 | + require.NoError(t, err, "SQL database open") |
| 28 | + defer func() { require.NoError(t, db.Close(), "db.Close") }() |
| 29 | + |
| 30 | + t.Run("configure channel in database", func(t *testing.T) { |
| 31 | + eventually.Require(t, func(t require.TestingT) { |
| 32 | + var channelCount int |
| 33 | + err := db.QueryRow(`SELECT COUNT(*) FROM available_channel_type WHERE type = 'file'`).Scan(&channelCount) |
| 34 | + require.NoError(t, err, "SQL SELECT FROM available_channel_type query") |
| 35 | + require.Equal(t, channelCount, 1, "file type missing from available_channel_type") |
| 36 | + }, 10*time.Second, time.Second) |
| 37 | + |
| 38 | + _, err := db.Exec(` |
| 39 | + INSERT INTO channel (id, name, type, config) |
| 40 | + VALUES (1, 'file-fifo', 'file', '{"path":"\/shared\/file-fifo"}'); |
| 41 | +
|
| 42 | + INSERT INTO contact (id, full_name, username, default_channel_id, color) |
| 43 | + VALUES (1, 'icingaadmin', 'icingaadmin', 1, '#000000'); |
| 44 | +
|
| 45 | + INSERT INTO rule (id, name, is_active) VALUES (1, 'file-fifo', 'y'); |
| 46 | + INSERT INTO rule_escalation (id, rule_id, position) VALUES (1, 1, 1); |
| 47 | + INSERT INTO rule_escalation_recipient (id, rule_escalation_id, contact_id, channel_id) VALUES (1, 1, 1, 1);`) |
| 48 | + require.NoError(t, err, "populating tables failed") |
| 49 | + }) |
| 50 | + |
| 51 | + t.Run("create icinga objects", func(t *testing.T) { |
| 52 | + client := icinga.ApiClient() |
| 53 | + client.CreateObject(t, "checkcommands", "failure-check", map[string]any{ |
| 54 | + "templates": []any{"plugin-check-command"}, |
| 55 | + "attrs": map[string]any{"command": []string{"/bin/false"}}, |
| 56 | + }) |
| 57 | + client.CreateHost(t, "test-host", map[string]any{ |
| 58 | + "attrs": map[string]any{"check_command": "failure-check"}, |
| 59 | + }) |
| 60 | + client.CreateService(t, "test-host", "test-service", map[string]any{ |
| 61 | + "attrs": map[string]any{"check_command": "failure-check"}, |
| 62 | + }) |
| 63 | + }) |
| 64 | + |
| 65 | + t.Run("read notification back from channel", func(t *testing.T) { |
| 66 | + f, err := os.Open(fileChFifo) |
| 67 | + require.NoErrorf(t, err, "opening %s for reading", fileChFifo) |
| 68 | + defer f.Close() |
| 69 | + |
| 70 | + notificationReqCh := make(chan *plugin.NotificationRequest) |
| 71 | + go func() { |
| 72 | + var req plugin.NotificationRequest |
| 73 | + require.NoError(t, json.NewDecoder(f).Decode(&req), "JSON decoding") |
| 74 | + notificationReqCh <- &req |
| 75 | + }() |
| 76 | + |
| 77 | + select { |
| 78 | + case req := <-notificationReqCh: |
| 79 | + require.Contains(t, req.Object.Name, "test-", "name must contain test prefix") |
| 80 | + |
| 81 | + case <-time.After(5 * time.Minute): |
| 82 | + require.Fail(t, "no notification was received") |
| 83 | + } |
| 84 | + }) |
| 85 | +} |
0 commit comments