tiktok-dl/workflows/downloadHashtag.go

53 lines
1.3 KiB
Go
Raw Normal View History

package workflows
import (
2020-03-22 02:10:24 +02:00
"fmt"
"strings"
2020-04-12 03:22:00 +03:00
client "github.com/pikami/tiktok-dl/client"
config "github.com/pikami/tiktok-dl/models/config"
res "github.com/pikami/tiktok-dl/resources"
2020-04-12 03:22:00 +03:00
utils "github.com/pikami/tiktok-dl/utils"
fileio "github.com/pikami/tiktok-dl/utils/fileio"
log "github.com/pikami/tiktok-dl/utils/log"
)
// CanUseDownloadHashtag - Test's if this workflow can be used for parameter
func CanUseDownloadHashtag(url string) bool {
2020-02-25 01:01:10 +02:00
match := strings.Contains(url, "/tag/")
return match
}
// DownloadHashtag - Download videos marked with given hashtag
func DownloadHashtag(url string) {
2020-02-25 21:16:57 +02:00
uploads, err := client.GetHashtagUploads(url)
if err != nil {
OnWorkflowFail(err, url)
2020-02-25 21:16:57 +02:00
return
}
2020-03-22 02:10:24 +02:00
uploads = utils.RemoveArchivedItems(uploads)
2020-02-25 01:01:10 +02:00
uploadCount := len(uploads)
2020-03-22 02:10:24 +02:00
2020-02-25 01:01:10 +02:00
hashtag := utils.GetHashtagFromURL(url)
downloadDir := fmt.Sprintf("%s/%s", config.Config.OutputPath, hashtag)
2020-03-22 00:22:08 +02:00
fileio.InitOutputDirectory(downloadDir)
2020-02-25 01:01:10 +02:00
for index, upload := range uploads {
downloadVideo(upload, downloadDir)
log.Logf(res.Downloaded, index+1, uploadCount)
2020-02-25 01:01:10 +02:00
}
2020-03-22 02:10:24 +02:00
log.Log()
}
2020-03-22 02:10:24 +02:00
// GetHashtagJSON - Prints scraped info from hashtag
func GetHashtagJSON(url string) {
uploads, err := client.GetHashtagUploadsJSON(url)
2020-02-25 21:16:57 +02:00
if err != nil {
OnWorkflowFail(err, url)
2020-02-25 21:16:57 +02:00
return
}
2020-02-25 01:01:10 +02:00
fmt.Printf("%s", uploads)
}