From fea5c85fc458a521b3eff9e48cce55f435a4c9f4 Mon Sep 17 00:00:00 2001 From: Max Magorsch Date: Wed, 24 Jun 2020 21:54:58 +0000 Subject: Add an option to recompute the thread references Signed-off-by: Max Magorsch --- pkg/importer/importer.go | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) (limited to 'pkg/importer/importer.go') diff --git a/pkg/importer/importer.go b/pkg/importer/importer.go index 76ba8e7..e83bd9f 100644 --- a/pkg/importer/importer.go +++ b/pkg/importer/importer.go @@ -79,6 +79,20 @@ func IncrementalImport() { fmt.Println("Finished incremental import. Imported " + strconv.Itoa(importedCounter) + " new messages.") } +func RecomputeThreads() { + + fmt.Println("Init thread computation...") + filepath.Walk(config.MailDirPath(), initImport) + + for _, mail := range mails { + insertReferencesToMail(mail.RawReferences, mail.Id, mail.From) + } + + fmt.Println("Finished thread computation.") +} + +// utility methods + func fileIsAlreadyPresent(path string, messages []*models.Message) bool { for _, message := range messages { if strings.Contains(strings.TrimRight(path, ",S"), strings.TrimRight(message.Filename, ",S")){ @@ -86,4 +100,4 @@ func fileIsAlreadyPresent(path string, messages []*models.Message) bool { } } return false -} \ No newline at end of file +} -- cgit v1.2.3-65-gdbad