TTDL-17 Added option to output failed items to file

This commit is contained in:
Pijus Kamandulis
2020-04-09 18:10:33 +03:00
parent 92006d864f
commit af59659f41
9 changed files with 57 additions and 25 deletions

20
workflows/common.go Normal file
View File

@@ -0,0 +1,20 @@
package workflows
import (
config "../models/config"
res "../resources"
fileio "../utils/fileio"
log "../utils/log"
)
// OnWorkflowFail - Funtion called when workflow fails
func OnWorkflowFail(err error, workItem string) {
failLogFilePath := config.Config.FailLogFilePath
if failLogFilePath != "" {
fileio.AppendToFile(workItem, failLogFilePath)
}
log.LogErr(res.Error, err.Error())
log.LogErr(res.FailedOnItem, workItem)
}

View File

@@ -6,7 +6,6 @@ import (
client "../client"
config "../models/config"
res "../resources"
utils "../utils"
fileio "../utils/fileio"
log "../utils/log"
@@ -22,7 +21,7 @@ func CanUseDownloadHashtag(url string) bool {
func DownloadHashtag(url string) {
uploads, err := client.GetHashtagUploads(url)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, url)
return
}
@@ -45,7 +44,7 @@ func DownloadHashtag(url string) {
func GetHashtagJSON(url string) {
uploads, err := client.GetHashtagUploadsJSON(url)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, url)
return
}
fmt.Printf("%s", uploads)

View File

@@ -6,7 +6,6 @@ import (
client "../client"
config "../models/config"
res "../resources"
utils "../utils"
fileio "../utils/fileio"
log "../utils/log"
@@ -22,7 +21,7 @@ func CanUseDownloadMusic(url string) bool {
func DownloadMusic(url string) {
uploads, err := client.GetMusicUploads(url)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, url)
return
}
@@ -44,7 +43,7 @@ func DownloadMusic(url string) {
func GetMusicJSON(url string) {
uploads, err := client.GetMusicUploadsJSON(url)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, url)
return
}
fmt.Printf("%s", uploads)

View File

@@ -1,10 +1,10 @@
package workflows
import (
client "../client"
res "../resources"
log "../utils/log"
"regexp"
client "../client"
log "../utils/log"
)
// CanUseDownloadShareLink - Check's if DownloadShareLink can be used
@@ -19,7 +19,7 @@ func DownloadShareLink(url string) {
finalURL, err := client.GetRedirectUrl(url)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, url)
return
}

View File

@@ -7,7 +7,6 @@ import (
client "../client"
config "../models/config"
res "../resources"
utils "../utils"
fileio "../utils/fileio"
log "../utils/log"
@@ -24,7 +23,7 @@ func CanUseDownloadUser(url string) bool {
func DownloadUser(username string) {
uploads, err := client.GetUserUploads(username)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, username)
return
}
@@ -46,7 +45,7 @@ func DownloadUser(username string) {
func GetUserVideosJSON(username string) {
uploads, err := client.GetUserUploadsJSON(username)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, username)
return
}
fmt.Printf("%s", uploads)

View File

@@ -7,7 +7,6 @@ import (
client "../client"
models "../models"
config "../models/config"
res "../resources"
utils "../utils"
fileio "../utils/fileio"
log "../utils/log"
@@ -24,7 +23,7 @@ func DownloadSingleVideo(url string) {
username := utils.GetUsernameFromString(url)
upload, err := client.GetVideoDetails(url)
if err != nil {
log.LogErr(res.ErrorCouldNotGetUserUploads, err.Error())
OnWorkflowFail(err, url)
return
}