Merge pull request #175 from velour/limittldr

tldr: change history to be in order; clamp to 24h

plugins/tldr/tldr.go

@@ -119,34 +119,40 @@ func (p *TLDRPlugin) message(kind bot.Kind, message msg.Message, args ...interfa
 		return true
 	}
 
-	if shouldKeepMessage(lowercaseMessage) {
-		currentHistorySize := len(p.history)
-		maxHistorySize := p.bot.Config().GetInt("TLDR.HistorySize", 1000)
 	hist := history{
 		body:      lowercaseMessage,
 		user:      message.User.Name,
 		timestamp: time.Now(),
 	}
-		if currentHistorySize < maxHistorySize {
+	p.addHistory(hist)
-			p.history = append(p.history, hist)
-			p.index = 0
-		} else {
-			if currentHistorySize > maxHistorySize {
-				// We could resize this but we want to prune the oldest stuff, and
-				// I don't care to do this correctly so might as well not do it at all
-			}
 
-			if p.index >= currentHistorySize {
-				p.index = 0
-			}
-
-			p.history[p.index] = hist
-			p.index++
-		}
-	}
 	return false
 }
 
+func (p *TLDRPlugin) addHistory(hist history) {
+	p.history = append(p.history, hist)
+	sz := len(p.history)
+	max := p.bot.Config().GetInt("TLDR.HistorySize", 1000)
+	keepHrs := time.Duration(p.bot.Config().GetInt("TLDR.KeepHours", 24))
+	// Clamp the size of the history
+	if sz > max {
+		p.history = p.history[len(p.history)-max:]
+	}
+	// Remove old entries
+	yesterday := time.Now().Add(-keepHrs * time.Hour)
+	begin := 0
+	for i, m := range p.history {
+		if !m.timestamp.Before(yesterday) {
+			begin = i - 1 // should keep this message
+			if begin < 0 {
+				begin = 0
+			}
+			break
+		}
+	}
+	p.history = p.history[begin:]
+}
+
 func (p *TLDRPlugin) getTopics() []string {
 	hist := []string{}
 	for _, h := range p.history {
@@ -155,28 +161,12 @@ func (p *TLDRPlugin) getTopics() []string {
 	return hist
 }
 
-func (p *TLDRPlugin) pruneHistory() {
-	out := []history{}
-	yesterday := time.Now().Add(-24 * time.Hour)
-	for _, h := range p.history {
-		if yesterday.Before(h.timestamp) {
-			out = append(out, h)
-		}
-	}
-	p.history = out
-	p.index = len(out)
-}
-
 // Help responds to help requests. Every plugin must implement a help function.
 func (p *TLDRPlugin) help(kind bot.Kind, message msg.Message, args ...interface{}) bool {
 	p.bot.Send(bot.Message, message.Channel, "tl;dr")
 	return true
 }
 
-func shouldKeepMessage(message string) bool {
-	return true
-}
-
 func min(slice []float64) (float64, int) {
 	minVal := 1.
 	minIndex := -1

plugins/tldr/tldr_test.go

@@ -2,8 +2,10 @@ package tldr
 
 import (
 	"os"
+	"strconv"
 	"strings"
 	"testing"
+	"time"
 
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
@@ -61,3 +63,38 @@ func TestDoubleUp(t *testing.T) {
 	assert.Len(t, mb.Messages, 2)
 	assert.Contains(t, mb.Messages[1], "Slow down, cowboy.")
 }
+
+func TestAddHistoryLimitsMessages(t *testing.T) {
+	c, _ := setup(t)
+	max := 1000
+	c.bot.Config().Set("TLDR.HistorySize", strconv.Itoa(max))
+	c.bot.Config().Set("TLDR.KeepHours", "24")
+	t0 := time.Now().Add(-24 * time.Hour)
+	for i := 0; i < max*2; i++ {
+		hist := history{
+			body:      "test",
+			user:      "tester",
+			timestamp: t0.Add(time.Duration(i) * time.Second),
+		}
+		c.addHistory(hist)
+	}
+	assert.Len(t, c.history, max)
+}
+
+func TestAddHistoryLimitsDays(t *testing.T) {
+	c, _ := setup(t)
+	hrs := 24
+	expected := 24
+	c.bot.Config().Set("TLDR.HistorySize", "100")
+	c.bot.Config().Set("TLDR.KeepHours", strconv.Itoa(hrs))
+	t0 := time.Now().Add(-time.Duration(hrs*2) * time.Hour)
+	for i := 0; i < 48; i++ {
+		hist := history{
+			body:      "test",
+			user:      "tester",
+			timestamp: t0.Add(time.Duration(i) * time.Hour),
+		}
+		c.addHistory(hist)
+	}
+	assert.Len(t, c.history, expected, "%d != %d", len(c.history), expected)
+}