amend robot: finish archives

core/BusinessLogic/Repositories/DataObjects/ArchiveLineStati.cs

@@ -0,0 +1,11 @@
+using DFM.Entities;
+using DFM.Entities.Enums;
+
+namespace DFM.BusinessLogic.Repositories.DataObjects
+{
+	internal class ArchiveLineStati
+	{
+		public Archive Archive { get; set; }
+		public ImportStatus LineStati { get; set; }
+	}
+}

core/BusinessLogic/Repositories/LineRepository.cs

@@ -1,7 +1,21 @@
-using DFM.Entities;
+using System.Collections.Generic;
+using DFM.BusinessLogic.Repositories.DataObjects;
+using DFM.Entities;
+using DFM.Entities.Enums;
 
 namespace DFM.BusinessLogic.Repositories;
 
 internal class LineRepository : Repo<Line>
 {
+	public IList<ArchiveLineStati> GetArchivesPending()
+	{
+		return NewQuery()
+			.Where(l => l.Status != ImportStatus.Pending)
+			.LeftJoin(l => l.Archive)
+			.Where(l => l.Archive.Status == ImportStatus.Pending)
+			.TransformResult<ArchiveLineStati>()
+			.GroupBy(l => l.Archive, als => als.Archive)
+			.Max(l => l.Status, als => als.LineStati)
+			.List;
+	}
 }

core/BusinessLogic/Services/RobotService.cs

@@ -612,7 +612,21 @@ private Category getCategoryOrThrow(String name, User user)
 
 		public void FinishArchives()
 		{
-			throw new NotImplementedException();
+			if (!parent.Current.IsRobot)
+				throw Error.Uninvited.Throw();
+
+			var archivesLineStati = repos.Line.GetArchivesPending();
+
+			foreach (var archiveLineStati in archivesLineStati)
+			{
+				var archive = archiveLineStati.Archive;
+				archive.Status = archiveLineStati.LineStati;
+
+				inTransaction("FinishArchives", () =>
+				{
+					repos.Archive.SaveOrUpdate(archive);
+				});
+			}
 		}
 	}
 }

core/Tests/BusinessLogic/Steps/_D.RobotStep.cs

@@ -871,7 +871,11 @@ public void ThenTheLinesWillBeDequeued()
 		[Given(@"robot made move from imported")]
 		public void GivenRobotMadeMoveFromImported()
 		{
-			robotRunMakeMoves();
+			try
+			{
+				robotRunMakeMoves();
+			}
+			catch (AggregateException) { }
 		}
 
 		[When(@"finish imported archives")]