ttrss-co-pilot/tasks/PodcastifyAttachment.cs

using System.Diagnostics;
using ttrss_co_client.ttrss;
using ttrss_co_client.ttrss.datastructures;

namespace ttrss_co_client.tasks
{
    ///<summary>podcast, with attachment that is podcast</summary>
    public class PodcastifyAttachment : Phase1Task
    {
        public override string TaskName => "podcastifyAttachment";
        public override async Task<WorkOrder> ActOn(Headline headline, IEnumerable<Label> labelsWRTArticle)
        {
            Console.WriteLine($"    podcast-is-attachment: {headline.link.ToString()}");
            var myGuid = Guid.NewGuid().ToString();
            var workingFolder = $"{Conf.WorkingDirectory}/{myGuid}";
            var sw = new Stopwatch();
            if(!Path.Exists(workingFolder))
            {
                Directory.CreateDirectory(workingFolder);
            }

            try
            {
                var attachmentLink = headline.attachments.Select(a => a.content_url)?.FirstOrDefault().ToString();
                var extensionUpstream = attachmentLink.Substring(attachmentLink.LastIndexOf('.'));
                var downloadPath = Path.Combine(workingFolder, headline.title) + extensionUpstream;
                var downloader = new HttpClient();
                sw.Start();
                File.WriteAllBytes(downloadPath, await (await downloader.GetAsync(attachmentLink)).Content.ReadAsByteArrayAsync());
                sw.Stop();
                var outputStr = $"{(File.Exists(downloadPath) ? "Success" : "fail")} in {sw.Elapsed}";

                Console.WriteLine($"    {attachmentLink}\n{outputStr}");
                await TtrssClient.SetArticleLabel(labelsWRTArticle.First(l => l.caption?.ToLower() == this.TriggerLabel.ToLower()).id, false, headline.id);
                Console.WriteLine($"    {headline.title}: download trigger label removed");

                var podcastTitle = headline.feed_title;
                var titlingLabel = labelsWRTArticle.FirstOrDefault(l => l.@checked && l.caption?.ToLower().StartsWith(Conf.PodcastTitlePrefix) == true);
                if(titlingLabel != null)
                {
                    await TtrssClient.SetArticleLabel(titlingLabel.id, false, headline.id);
                    Console.WriteLine($"    {headline.title}: podcast titling label removed");
                    podcastTitle = titlingLabel.caption.Substring(Conf.PodcastTitlePrefix.Length);
                }
                Console.WriteLine($"article {headline.id} - podcastifying; {podcastTitle}");
                
                await TtrssClient.UpdateArticleNote($"{headline.note}\n[{DateTime.Now.ToString("o")}] - podcastify attachment (dl): {outputStr}", headline.id);
                if (!File.Exists(downloadPath))
                {
                    return null;
                }
                else
                {
                    Console.WriteLine($"{attachmentLink} downloaded.");

                    var toReturn = new WorkOrder()
                    {
                        articleId = headline.id,
                        Phase2TaskList = new Dictionary<int, string>(),
                        data = new Dictionary<string, string>(),
                        guid = Guid.Parse(myGuid)
                    };
                    toReturn.data["path"] = downloadPath;
                    toReturn.Phase2TaskList[1] = "filemovePublish";
                    toReturn.data["publish-target"] = $"{Conf.OnDoneCopy}/Podcasts/{podcastTitle}/";
                    if(extensionUpstream != ".mp3")
                    {
                        Console.WriteLine($"{headline.title} needs conversion task.");
                        toReturn.Phase2TaskList[0] = "convert";
                        toReturn.data["conversion-target"] = ".mp3";
                    }

                    return toReturn;
                }
            }
            catch (Exception e)
            {
                Console.Error.WriteLine($"fatal error in podcast attachment DL for {headline.link}");
                Console.Error.WriteLine($"{e.ToString()}: {e.Message}.\n{e.StackTrace}");
                await TtrssClient.UpdateArticleNote($"{headline.note}\n[{DateTime.Now.ToString("o")}] - fatal error {e.ToString()}: {e.Message}.\n{e.StackTrace}", headline.id);
                return null;
            }
        }
    }
}