discord-downloader-go/history.go

package main

import (
	"fmt"
	"log"
	"os"
	"strconv"
	"time"

	"github.com/bwmarrin/discordgo"
	"github.com/dustin/go-humanize"
	"github.com/fatih/color"
	"github.com/hako/durafmt"
)

type historyStatus int

const (
	historyStatusWaiting historyStatus = iota
	historyStatusDownloading
	historyStatusAbortRequested
	historyStatusAbortCompleted
	historyStatusErrorReadMessageHistoryPerms
	historyStatusErrorRequesting
	historyStatusCompletedNoMoreMessages
	historyStatusCompletedToBeforeFilter
	historyStatusCompletedToSinceFilter
)

func historyStatusLabel(status historyStatus) string {
	switch status {
	case historyStatusWaiting:
		return "Waiting..."
	case historyStatusDownloading:
		return "Currently Downloading..."
	case historyStatusAbortRequested:
		return "Abort Requested..."
	case historyStatusAbortCompleted:
		return "Aborted..."
	case historyStatusErrorReadMessageHistoryPerms:
		return "ERROR: Cannot Read Message History"
	case historyStatusErrorRequesting:
		return "ERROR: Message Requests Failed"
	case historyStatusCompletedNoMoreMessages:
		return "COMPLETE: No More Messages"
	case historyStatusCompletedToBeforeFilter:
		return "COMPLETE: Exceeded Before Date Filter"
	case historyStatusCompletedToSinceFilter:
		return "COMPLETE: Exceeded Since Date Filter"
	default:
		return "Unknown"
	}
}

type historyJob struct {
	Status                  historyStatus
	OriginUser              string
	OriginChannel           string
	TargetCommandingMessage *discordgo.Message
	TargetChannelID         string
	TargetBefore            string
	TargetSince             string
	DownloadCount           int64
	DownloadSize            int64
	Updated                 time.Time
	Added                   time.Time
}

var (
	historyJobs       map[string]historyJob
	historyProcessing bool
)

func handleHistory(commandingMessage *discordgo.Message, subjectChannelID string, before string, since string) int {
	historyProcessing = true
	defer func() { historyProcessing = false }()
	if job, exists := historyJobs[subjectChannelID]; exists && job.Status != historyStatusWaiting {
		log.Println(lg("History", "", color.RedString, "History job skipped, Status: %s", historyStatusLabel(job.Status)))
		return -1
	}

	var err error

	var totalMessages int64 = 0
	var totalDownloads int64 = 0
	var totalFilesize int64 = 0
	var messageRequestCount int = 0

	var responseMsg *discordgo.Message = &discordgo.Message{}
	responseMsg.ID = ""
	responseMsg.ChannelID = subjectChannelID
	responseMsg.GuildID = ""

	var commander string = "AUTORUN"
	var autorun bool = true
	if commandingMessage != nil { // Only time commandingMessage is nil is Autorun
		commander = getUserIdentifier(*commandingMessage.Author)
		autorun = false
	}
	logPrefix := fmt.Sprintf("%s/%s: ", subjectChannelID, commander)

	// Send Status?
	var sendStatus bool = true
	if (autorun && !config.SendAutoHistoryStatus) || (!autorun && !config.SendHistoryStatus) {
		sendStatus = false
	}

	var channelinfo *discordgo.Channel
	if channelinfo, err = bot.State.Channel(subjectChannelID); err != nil {
		log.Println(lg("History", "", color.HiRedString, logPrefix+"ERROR FETCHING BOT STATE FROM DISCORDGO!!!\t%s", err))
	}

	// Check Read History perms
	if !channelinfo.IsThread() && !hasPerms(subjectChannelID, discordgo.PermissionReadMessageHistory) {
		if job, exists := historyJobs[subjectChannelID]; exists {
			job.Status = historyStatusDownloading
			job.Updated = time.Now()
			historyJobs[subjectChannelID] = job
		}
		log.Println(lg("History", "", color.HiRedString, logPrefix+"BOT DOES NOT HAVE PERMISSION TO READ MESSAGE HISTORY!!!"))
		return -1
	}
	hasPermsToRespond := hasPerms(subjectChannelID, discordgo.PermissionSendMessages)
	if !autorun {
		hasPermsToRespond = hasPerms(commandingMessage.ChannelID, discordgo.PermissionSendMessages)
	}

	// Update Job Status to Downloading
	if job, exists := historyJobs[subjectChannelID]; exists {
		job.Status = historyStatusDownloading
		job.Updated = time.Now()
		historyJobs[subjectChannelID] = job
	}

	//#region Cache Files
	openHistoryCache := func(dirpath string, output *string) {
		if f, err := os.ReadFile(dirpath + string(os.PathSeparator) + subjectChannelID); err == nil {
			*output = string(f)
			if !autorun && config.Debug {
				log.Println(lg("Debug", "History", color.YellowString,
					logPrefix+"Found a cache file, picking up where we left off before %s...", string(f)))
			}
		}
	}
	writeHistoryCache := func(dirpath string, ID string) {
		if err := os.MkdirAll(dirpath, 0755); err != nil {
			log.Println(lg("Debug", "History", color.HiRedString,
				logPrefix+"Error while creating history cache folder \"%s\": %s", dirpath, err))
		}
		f, err := os.OpenFile(dirpath+string(os.PathSeparator)+subjectChannelID, os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0600)
		if err != nil {
			log.Println(lg("Debug", "History", color.RedString,
				logPrefix+"Failed to open cache file:\t%s", err))
		}
		if _, err = f.WriteString(ID); err != nil {
			log.Println(lg("Debug", "History", color.RedString,
				logPrefix+"Failed to write cache file:\t%s", err))
		} else if !autorun && config.Debug {
			log.Println(lg("Debug", "History", color.YellowString,
				logPrefix+"Wrote to cache file."))
		}
		f.Close()
	}
	deleteHistoryCache := func(dirpath string) {
		fp := dirpath + string(os.PathSeparator) + subjectChannelID
		if _, err := os.Stat(fp); err == nil {
			err = os.Remove(fp)
			if err != nil {
				log.Println(lg("Debug", "History", color.HiRedString,
					logPrefix+"Encountered error deleting cache file:\t%s", err))
			} else if commandingMessage != nil && config.Debug {
				log.Println(lg("Debug", "History", color.HiRedString,
					logPrefix+"Deleted cache file."))
			}
		}
	}
	//#endregion

	// Date Range Vars
	var sinceID = since
	var beforeID = before
	var beforeTime time.Time

	//#region Date Range Output
	rangeContent := ""
	if sinceID != "" {
		if isDate(sinceID) {
			sinceID = discordTimestampToSnowflake(sinceID, "2006-01-02")
		}
		if isNumeric(sinceID) {
			rangeContent += fmt.Sprintf("**Since:** `%s`\n", sinceID)
		}
	}
	if beforeID != "" {
		if isDate(beforeID) {
			beforeID = discordTimestampToSnowflake(beforeID, "2006-01-02")
		}
		if isNumeric(beforeID) {
			rangeContent += fmt.Sprintf("**Before:** `%s`\n", beforeID)
		}
	}
	if rangeContent != "" {
		rangeContent += "\n\n"
	}
	//#endregion

	if channelConfig := getSource(responseMsg); channelConfig != emptyConfig {

		// Overwrite Send Status
		if channelConfig.SendAutoHistoryStatus != nil {
			if autorun && !*channelConfig.SendAutoHistoryStatus {
				sendStatus = false
			}
		}
		if channelConfig.SendHistoryStatus != nil {
			if !autorun && !*channelConfig.SendHistoryStatus {
				sendStatus = false
			}
		}

		// Open Cache File?
		openHistoryCache(historyCacheBefore, &beforeID)
		openHistoryCache(historyCacheSince, &sinceID)

		historyStartTime := time.Now()

		guildName := getGuildName(getChannelGuildID(subjectChannelID))
		categoryName := getChannelCategoryName(subjectChannelID)
		channelName := getChannelName(subjectChannelID)
		sourceName := fmt.Sprintf("%s / %s", guildName, channelName)
		msgSourceDisplay := fmt.Sprintf("`Server:` **%s**\n`Channel:` #%s", guildName, channelName)
		if categoryName != "unknown" {
			sourceName = fmt.Sprintf("%s / %s / %s", guildName, categoryName, channelName)
			msgSourceDisplay = fmt.Sprintf("`Server:` **%s**\n`Category:` _%s_\n`Channel:` #%s",
				guildName, categoryName, channelName)
		}

		// Initial Status Message
		if sendStatus {
			if hasPermsToRespond {
				responseMsg, err = replyEmbed(commandingMessage, "Command — History", msgSourceDisplay)
				if err != nil {
					log.Println(lg("History", "", color.HiRedString,
						logPrefix+"Failed to send command embed message:\t%s", err))
				}
			} else {
				log.Println(lg("History", "", color.HiRedString,
					logPrefix+fmtBotSendPerm, commandingMessage.ChannelID))
			}
		}
		log.Println(lg("History", "", color.HiCyanString, logPrefix+"Began checking history for \"%s\"...", sourceName))

		lastMessageID := ""
	MessageRequestingLoop:
		for {
			// Next 100
			if beforeTime != (time.Time{}) {
				messageRequestCount++
				if beforeID != "" {
					writeHistoryCache(historyCacheBefore, beforeID)
				}
				if sinceID != "" {
					writeHistoryCache(historyCacheSince, sinceID)
				}

				// Update Status
				log.Println(lg("History", "", color.CyanString,
					logPrefix+"Requesting more, \t%d downloaded (%s), \t%d processed, \tsearching before %s ago (%s)",
					totalDownloads, humanize.Bytes(uint64(totalFilesize)), totalMessages, durafmt.ParseShort(time.Since(beforeTime)).String(), beforeTime.String()[:10]))
				if sendStatus {
					status := fmt.Sprintf(
						"``%s:`` **%s files downloaded...** `(%s so far, avg %1.1f MB/s)`\n``"+
							"%s messages processed...``\n\n"+
							"%s\n\n"+
							"%s`(%d)` _Processing more messages, please wait..._",
						shortenTime(durafmt.ParseShort(time.Since(historyStartTime)).String()), formatNumber(totalDownloads),
						humanize.Bytes(uint64(totalFilesize)), float64(totalFilesize/humanize.MByte)/time.Since(historyStartTime).Seconds(),
						formatNumber(totalMessages),
						msgSourceDisplay, rangeContent, messageRequestCount)
					if responseMsg == nil {
						log.Println(lg("History", "", color.RedString,
							logPrefix+"Tried to edit status message but it doesn't exist, sending new one."))
						if responseMsg, err = replyEmbed(responseMsg, "Command — History", status); err != nil { // Failed to Edit Status, Send New Message
							log.Println(lg("History", "", color.HiRedString,
								logPrefix+"Failed to send replacement status message:\t%s", err))
						}
					} else {
						if !hasPermsToRespond {
							log.Println(lg("History", "", color.HiRedString,
								logPrefix+fmtBotSendPerm+" - %s", responseMsg.ChannelID, status))
						} else {
							// Edit Status
							if selfbot {
								responseMsg, err = bot.ChannelMessageEdit(responseMsg.ChannelID, responseMsg.ID,
									fmt.Sprintf("**Command — History**\n\n%s", status))
							} else {
								responseMsg, err = bot.ChannelMessageEditComplex(&discordgo.MessageEdit{
									ID:      responseMsg.ID,
									Channel: responseMsg.ChannelID,
									Embed:   buildEmbed(responseMsg.ChannelID, "Command — History", status),
								})
							}
							// Failed to Edit Status
							if err != nil {
								log.Println(lg("History", "", color.HiRedString,
									logPrefix+"Failed to edit status message, sending new one:\t%s", err))
								if responseMsg, err = replyEmbed(responseMsg, "Command — History", status); err != nil { // Failed to Edit Status, Send New Message
									log.Println(lg("History", "", color.HiRedString,
										logPrefix+"Failed to send replacement status message:\t%s", err))
								}
							}
						}
					}
				}

				// Update presence
				timeLastUpdated = time.Now()
				if *channelConfig.PresenceEnabled {
					go updateDiscordPresence()
				}
			}

			// Request More Messages
			msg_rq_cnt := 0
		request_messages:
			msg_rq_cnt++
			if messages, err := bot.ChannelMessages(subjectChannelID, 100, beforeID, sinceID, ""); err != nil {
				// Error requesting messages
				if sendStatus {
					if !hasPermsToRespond {
						log.Println(lg("History", "", color.HiRedString,
							logPrefix+fmtBotSendPerm, responseMsg.ChannelID))
					} else {
						_, err = replyEmbed(responseMsg, "Command — History",
							fmt.Sprintf("Encountered an error requesting messages for %s: %s", subjectChannelID, err.Error()))
						if err != nil {
							log.Println(lg("History", "", color.HiRedString,
								logPrefix+"Failed to send error message:\t%s", err))
						}
					}
				}
				log.Println(lg("History", "", color.HiRedString, logPrefix+"Error requesting messages:\t%s", err))
				if job, exists := historyJobs[subjectChannelID]; exists {
					job.Status = historyStatusErrorRequesting
					job.Updated = time.Now()
					historyJobs[subjectChannelID] = job
				}
				break MessageRequestingLoop
			} else {
				// No More Messages
				if len(messages) <= 0 {
					if msg_rq_cnt > 3 {
						if job, exists := historyJobs[subjectChannelID]; exists {
							job.Status = historyStatusCompletedNoMoreMessages
							job.Updated = time.Now()
							historyJobs[subjectChannelID] = job
						}
						break MessageRequestingLoop
					} else { // retry to make sure no more
						time.Sleep(10 * time.Millisecond)
						goto request_messages
					}
				}

				// Set New Range
				beforeID = messages[len(messages)-1].ID
				beforeTime = messages[len(messages)-1].Timestamp
				sinceID = ""

				// Process Messages
				if channelConfig.HistoryTyping != nil && !autorun {
					if *channelConfig.HistoryTyping && hasPermsToRespond {
						bot.ChannelTyping(commandingMessage.ChannelID)
					}
				}
				for _, message := range messages {
					// Ordered to Cancel
					if historyJobs[subjectChannelID].Status == historyStatusAbortRequested {
						if job, exists := historyJobs[subjectChannelID]; exists {
							job.Status = historyStatusAbortCompleted
							job.Updated = time.Now()
							historyJobs[subjectChannelID] = job
						}
						break MessageRequestingLoop
					}

					lastMessageID = message.ID

					// Check Message Range
					message64, _ := strconv.ParseInt(message.ID, 10, 64)
					if before != "" {
						before64, _ := strconv.ParseInt(before, 10, 64)
						if message64 > before64 {
							if job, exists := historyJobs[subjectChannelID]; exists {
								job.Status = historyStatusCompletedToBeforeFilter
								job.Updated = time.Now()
								historyJobs[subjectChannelID] = job
							}
							break MessageRequestingLoop
						}
					}
					if since != "" {
						since64, _ := strconv.ParseInt(since, 10, 64)
						if message64 < since64 {
							if job, exists := historyJobs[subjectChannelID]; exists {
								job.Status = historyStatusCompletedToSinceFilter
								job.Updated = time.Now()
								historyJobs[subjectChannelID] = job
							}
							break MessageRequestingLoop
						}
					}

					// Process Message
					downloadCount, filesize := handleMessage(message, false, true)
					if downloadCount > 0 {
						totalDownloads += downloadCount
						totalFilesize += filesize
					}
					totalMessages++
				}
			}
		}

		// Cache
		if historyJobs[subjectChannelID].Status == historyStatusCompletedNoMoreMessages {
			deleteHistoryCache(historyCacheBefore)
			writeHistoryCache(historyCacheSince, lastMessageID)
		}

		// Final log
		log.Println(lg("History", "", color.HiGreenString, logPrefix+"Finished history for \"%s\", %s files, %s total",
			sourceName, formatNumber(totalDownloads), humanize.Bytes(uint64(totalFilesize))))
		// Final status update
		if sendStatus {
			status := fmt.Sprintf(
				"``%s:`` **%s total files downloaded!** `%s total, avg %1.1f MB/s`\n"+
					"``%s total messages processed``\n\n"+
					"%s\n\n"+ // msgSourceDisplay^
					"**DONE!** - %s\n"+
					"Ran ``%d`` message history requests\n\n"+
					"%s_Duration was %s_",
				durafmt.ParseShort(time.Since(historyStartTime)).String(), formatNumber(int64(totalDownloads)),
				humanize.Bytes(uint64(totalFilesize)), float64(totalFilesize/humanize.MByte)/time.Since(historyStartTime).Seconds(),
				formatNumber(int64(totalMessages)),
				msgSourceDisplay,
				historyStatusLabel(historyJobs[subjectChannelID].Status),
				messageRequestCount,
				rangeContent, durafmt.Parse(time.Since(historyStartTime)).String(),
			)
			if !hasPermsToRespond {
				log.Println(lg("History", "", color.HiRedString, logPrefix+fmtBotSendPerm, responseMsg.ChannelID))
			} else {
				if responseMsg == nil {
					log.Println(lg("History", "", color.RedString,
						logPrefix+"Tried to edit status message but it doesn't exist, sending new one."))
					if _, err = replyEmbed(responseMsg, "Command — History", status); err != nil { // Failed to Edit Status, Send New Message
						log.Println(lg("History", "", color.HiRedString,
							logPrefix+"Failed to send replacement status message:\t%s", err))
					}
				} else {
					if selfbot {
						responseMsg, err = bot.ChannelMessageEdit(responseMsg.ChannelID, responseMsg.ID,
							fmt.Sprintf("**Command — History**\n\n%s", status))
					} else {
						responseMsg, err = bot.ChannelMessageEditComplex(&discordgo.MessageEdit{
							ID:      responseMsg.ID,
							Channel: responseMsg.ChannelID,
							Embed:   buildEmbed(responseMsg.ChannelID, "Command — History", status),
						})
					}
					// Edit failure
					if err != nil {
						log.Println(lg("History", "", color.RedString,
							logPrefix+"Failed to edit status message, sending new one:\t%s", err))
						if _, err = replyEmbed(responseMsg, "Command — History", status); err != nil {
							log.Println(lg("History", "", color.HiRedString,
								logPrefix+"Failed to send replacement status message:\t%s", err))
						}
					}
				}
			}
		}
	}

	return int(totalDownloads)
}