feat: check if the report entry was muted

pkg/database/database.go

@@ -24,4 +24,5 @@ type Database interface {
 	UpsertMute(mute *types.Mute) error
 	DeleteMute(mute *types.Mute) (bool, error)
 	GetAllMutes() ([]*types.Mute, error)
+	IsMuted(chain, proposalID string) (bool, error)
 }

pkg/database/sqlite.go

@@ -348,3 +348,25 @@ func (d *SqliteDatabase) DeleteMute(mute *types.Mute) (bool, error) {
 
 	return rowsAffected > 0, nil
 }
+
+func (d *SqliteDatabase) IsMuted(chain, proposalID string) (bool, error) {
+	row := d.client.QueryRow(
+		"SELECT COUNT(*) FROM mutes WHERE ((chain IS NULL AND proposal_id IS NULL) OR (chain = $1 AND proposal_id IS NULL) OR (chain IS NULL AND proposal_id = $2) OR (chain = $1 AND proposal_id = $2)) AND expires >= datetime('now')",
+		chain,
+		proposalID,
+	)
+
+	if err := row.Err(); err != nil {
+		d.logger.Error().Err(err).Msg("Could not check if entry was muted")
+		return false, err
+	}
+
+	count := 0
+
+	if err := row.Scan(&count); err != nil {
+		d.logger.Error().Err(err).Msg("Could not scan to check entry was muted")
+		return false, err
+	}
+
+	return count > 0, nil
+}

pkg/database/stub.go

@@ -160,3 +160,7 @@ func (d *StubDatabase) GetAllMutes() ([]*types.Mute, error) {
 func (d *StubDatabase) DeleteMute(mute *types.Mute) (bool, error) {
 	return true, nil
 }
+
+func (d *StubDatabase) IsMuted(chain, proposalID string) (bool, error) {
+	return false, nil
+}

pkg/mutes/manager.go

@@ -20,17 +20,16 @@ func NewMutesManager(logger *zerolog.Logger, database databasePkg.Database) *Man
 	}
 }
 
-func (m *Manager) IsEntryMuted(reportEntry entry.ReportEntry) bool {
+func (m *Manager) IsEntryMuted(reportEntry entry.ReportEntry) (bool, error) {
 	entryConverted, ok := reportEntry.(entry.ReportEntryNotError)
 	if !ok {
-		return false
+		return false, nil
 	}
 
-	_ = entryConverted.GetChain()
-	_ = entryConverted.GetProposal()
+	chain := entryConverted.GetChain()
+	proposal := entryConverted.GetProposal()
 
-	return false
-	// return m.Mutes.IsMuted(chain.Name, proposal.ID)
+	return m.Database.IsMuted(chain.Name, proposal.ID)
 }
 
 func (m *Manager) GetAllMutes() ([]*types.Mute, error) {

pkg/report/dispatcher.go

@@ -71,7 +71,11 @@ func (d *Dispatcher) SendReport(report reportersPkg.Report, ctx context.Context)
 			Msg("Sending report...")
 
 		for _, reportEntry := range report.Entries {
-			if d.MutesManager.IsEntryMuted(reportEntry) {
+			if isMuted, muteErr := d.MutesManager.IsEntryMuted(reportEntry); muteErr != nil {
+				d.Logger.Warn().
+					Err(muteErr).
+					Msg("Error checking whether the proposal was muted.")
+			} else if isMuted {
 				d.Logger.Debug().
 					Str("entry", reportEntry.Name()).
 					Msg("Notifications are muted, not sending.")