Merge pull request #129 from traP-jp/fix-break-condition

メッセージ取得のforループの終了条件に、実際に返ってきたメッセージ数を使うようにした

server/traqmessage/collect.go

@@ -39,21 +39,23 @@ func (m *MessagePoller) Run() {
 		checkpointMutex.Lock()
 
 		now := time.Now()
-		var collectedMessageCount int64
+		var collectedMessageCount int
 		for i := 0; ; i += 100 {
 			messages, err := collectMessages(lastCheckpoint, now, i)
 			if err != nil {
 				slog.Error(fmt.Sprintf("Failled to polling messages: %v", err))
 				break
 			}
 
-			slog.Info(fmt.Sprintf("Collect %d messages", messages.TotalHits))
-			collectedMessageCount += messages.TotalHits
+			tmpMessageCount := len(messages.Hits)
+
+			slog.Info(fmt.Sprintf("Collect %d messages", tmpMessageCount))
+			collectedMessageCount += tmpMessageCount
 
 			// 取得したメッセージを使っての処理の呼び出し
 			m.processor.enqueue(&messages.Hits)
 
-			if messages.TotalHits < 100 {
+			if tmpMessageCount < 100 {
 				break
 			}
 		}