mark as read and chat a message when done

Configuration.cs

@@ -10,6 +10,7 @@ namespace ttrss_co_client
         public string PodcastTitlePrefix { get; set; }
         public string OnDoneCopy { get; set; }
         public string WorkingDirectory { get; set; } = "./working/";
+        public string ChatScript { get; set; }
         public IEnumerable<FeedAction> feedActions { get; set; }
         public class FeedAction
         {

Program.cs

@@ -116,6 +116,8 @@ namespace ttrss_co_client
                 phase2TaskConcretions.Add(concretion);
             }
 
+            ChatMessage.ChatScript = conf.ChatScript;
+
             while (remainingWork.Count > 0)
             {
                 //todo: solve the halting problem
@@ -134,6 +136,7 @@ namespace ttrss_co_client
                     if (appropriatePhase2Task != null)
                     {
                         wo.Phase2TaskList.Remove(wo.Phase2TaskList.Keys.Min());
+                        Console.WriteLine("launching phase 2 task: " + taskName);
                         Phase2Tasks.Add(appropriatePhase2Task.ActOn(wo));
                     }
                     else
@@ -148,18 +151,19 @@ namespace ttrss_co_client
                 foreach (var lingeringTask in Phase2Tasks)
                 {
                     var wo = await lingeringTask;
+                    var wop = Path.Combine(conf.WorkingDirectory, wo.Item2.guid.ToString(), "workorder.json");
+                    File.WriteAllText(wop, JsonConvert.SerializeObject(wo.Item2));
                     //if you tell me it's done, or you need to continue now.... I believe you.
-                    //TODO: be smart enough to override?
                     switch (wo.Item1)
                     {
                         case Phase2Task.TaskStatus.Done:
+                            File.Delete(wop);
                             Directory.Delete(Path.Combine(conf.WorkingDirectory, wo.Item2.guid.ToString()));
                             break;
                         case Phase2Task.TaskStatus.ContinueNow:
                             remainingWork.Add(wo.Item2);
                             break;
                         case Phase2Task.TaskStatus.TryLater:
-                            File.WriteAllText(Path.Combine(conf.WorkingDirectory, wo.Item2.guid.ToString(), "workorder.json"), JsonConvert.SerializeObject(wo.Item2));
                             break;
                     }
                 }

sample-appsettings.json

@@ -5,16 +5,17 @@
     "podcastTitlePrefix": "[podcast title] - ",
     "onDoneCopy":"./",
     "workingDirectory":"working/",
-    "feedActions": 
+    "chatScript": "miscChat.sh",
+    "feedActions":
     [
         {
             "triggerlabelCaption":"dl plz",
             "command":"dl"
-        }, 
+        },
         {
             "triggerlabelCaption":"podcastify-yt plz",
             "command":"podcastifyYT"
-        }, 
+        },
         {
             "triggerlabelCaption":"podcastify-attachment plz",
             "command":"podcastifyAttachment"

tasks/ChatMessage.cs

@@ -0,0 +1,22 @@
+namespace ttrss_co_client.tasks;
+
+using System.Linq;
+using System.Diagnostics;
+using ttrss_co_client.ttrss;
+using ttrss_co_client.ttrss.datastructures;
+using System.Threading.Tasks;
+using System;
+
+public class ChatMessage : Phase2Task
+{
+    public static string ChatScript { get; set; }
+    public override string TaskName => "chatmessage";
+
+    public override async Task<Tuple<TaskStatus, WorkOrder>> ActOn(WorkOrder workOrder)
+    {
+        await Process.Start(ChatScript,
+            workOrder.data["chatmessage"] + (await TtrssClient.GetArticles(workOrder.articleId)).First().feed_title
+            ).WaitForExitAsync();
+        return new Tuple<TaskStatus, WorkOrder>(TaskStatus.Done, workOrder);
+    }
+}

tasks/MarkRead.cs

@@ -0,0 +1,19 @@
+namespace ttrss_co_client.tasks;
+
+using System.Linq;
+using System.Diagnostics;
+using ttrss_co_client.ttrss;
+using ttrss_co_client.ttrss.datastructures;
+using System.Threading.Tasks;
+using System;
+
+public class MarkRead : Phase2Task
+{
+    public override string TaskName => "markread";
+
+    public override async Task<Tuple<TaskStatus, WorkOrder>> ActOn(WorkOrder workOrder)
+    {
+        await TtrssClient.UpdateArticleField(ApiClient.UPDATEFIELD.unread, ApiClient.UPDATEMODE.SetFalse, workOrder.articleId);
+        return new Tuple<TaskStatus, WorkOrder>(TaskStatus.ContinueNow, workOrder);
+    }
+}

tasks/PodcastifyAttachment.cs

@@ -43,7 +43,7 @@ namespace ttrss_co_client.tasks
                     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))
                 {
@@ -70,6 +70,11 @@ namespace ttrss_co_client.tasks
                         toReturn.data["conversion-target"] = ".mp3";
                     }
 
+                    toReturn.Phase2TaskList[2] = "markread";
+
+                    toReturn.Phase2TaskList[3] = "chatmessage";
+                    toReturn.data["chatmessage"] = "new podcast from ";
+
                     return toReturn;
                 }
             }

tasks/PodcastifyYT.cs

@@ -11,7 +11,7 @@ namespace ttrss_co_client.tasks
         public override async Task<WorkOrder> ActOn(Headline headline, IEnumerable<Label> labelsWRTArticle)
         {
             Console.WriteLine($"    YT podcastify: {headline.link.ToString()}");
-            
+
             var myGuid = Guid.NewGuid().ToString();
             var toReturn = new WorkOrder()
             {
@@ -29,7 +29,7 @@ namespace ttrss_co_client.tasks
                 await TtrssClient.SetArticleLabel(titlingLabel.id, false, headline.id);
             }
             Console.WriteLine($"article {headline.id} - yt podcastifying; {podcastTitle}");
-            
+
             toReturn.Phase2TaskList[0] = "yt-dlp";
             toReturn.data["ytdlp-link"] = headline.link.ToString();
 
@@ -44,6 +44,12 @@ namespace ttrss_co_client.tasks
             toReturn.Phase2TaskList[3] = "filemovePublish";
             toReturn.data["publish-target"] = $"{Conf.OnDoneCopy}/Podcasts/{podcastTitle}/";
 
+
+            toReturn.Phase2TaskList[4] = "markread";
+
+            toReturn.Phase2TaskList[5] = "chatmessage";
+            toReturn.data["chatmessage"] = "new podcast (via YT) from ";
+
             await TtrssClient.SetArticleLabel(labelsWRTArticle.First(l => l.caption?.ToLower() == this.TriggerLabel.ToLower()).id, false, headline.id);
             Console.WriteLine($"    {headline.title}: download trigger label removed");
 

tasks/Publish.cs

@@ -26,7 +26,7 @@ namespace ttrss_co_client.tasks
             File.Move(workOrder.data["path"], outputFilename, true);
             var article = (await TtrssClient.GetArticles(workOrder.articleId))?.FirstOrDefault();
             await TtrssClient.UpdateArticleNote($"{article.note}\n[{DateTime.Now.ToString("o")}] - copied", article.id);
-            return new Tuple<TaskStatus, WorkOrder>(TaskStatus.Done, workOrder);
+            return new Tuple<TaskStatus, WorkOrder>(TaskStatus.ContinueNow, workOrder);
         }
     }
-} 
+}

tasks/Sponsorblock.cs

@@ -9,7 +9,6 @@ using ttrss_co_client.ttrss.datastructures;
 
 namespace ttrss_co_client.tasks
 {
-    ///<summary>Move to output</summary>
     public class Sponsorblock : Phase2Task
     {
         public override string TaskName => "sponsorblock";
@@ -67,7 +66,7 @@ namespace ttrss_co_client.tasks
                 var extension = workOrder.data["path"].Substring(workOrder.data["path"].LastIndexOf('.'));
                 var intermediatePathBase = workOrder.data["path"].Substring(0, workOrder.data["path"].LastIndexOf('.'));
                 var conversionProcesses = new List<Tuple<Process, Tuple<int, string>>>();
-                        
+
                 foreach(var junkSegment in segments.OrderBy(s => s.segment[0]))
                 {
                     contentSegments.Add(new Tuple<double, double>(previousEdge, junkSegment.segment[0]));
@@ -113,7 +112,7 @@ namespace ttrss_co_client.tasks
 
                 Console.WriteLine($"[{DateTime.Now.ToString("o")}] intermediate content segments stitched. Deleting originals.");
                 foreach(var intermediate in intermediates.Values)
-                {                
+                {
                     File.Delete(intermediate);
                 }
                 #endregion

tasks/StandardDL.cs

@@ -11,7 +11,7 @@ namespace ttrss_co_client.tasks
         public override async Task<WorkOrder> ActOn(Headline headline, IEnumerable<Label> labelsWRTArticle)
         {
             Console.WriteLine($"    standard download: {headline.link.ToString()}");
-            
+
             var myGuid = Guid.NewGuid().ToString();
             var toReturn = new WorkOrder()
             {
@@ -20,7 +20,7 @@ namespace ttrss_co_client.tasks
                 data = new Dictionary<string, string>(),
                 guid = Guid.Parse(myGuid)
             };
-            
+
             toReturn.Phase2TaskList[0] = "yt-dlp";
             toReturn.data["ytdlp-link"] = headline.link.ToString();
 
@@ -35,6 +35,11 @@ namespace ttrss_co_client.tasks
             toReturn.Phase2TaskList[3] = "filemovePublish";
             toReturn.data["publish-target"] = $"{Conf.OnDoneCopy}/recent episodes/";
 
+            toReturn.Phase2TaskList[4] = "markread";
+
+            toReturn.Phase2TaskList[5] = "chatmessage";
+            toReturn.data["chatmessage"] = "new video from ";
+
             await TtrssClient.SetArticleLabel(labelsWRTArticle.First(l => l.caption?.ToLower() == this.TriggerLabel.ToLower()).id, false, headline.id);
             Console.WriteLine($"    {headline.title}: download trigger label removed");