feat: Update job monitoring to use diracX functions

Author: Robin VAN DE MERGHEL

src/DIRAC/WorkloadManagementSystem/FutureClient/JobMonitoringClient.py

@@ -8,7 +8,7 @@ def fetch(self, parameters, jobIDs):
         with DiracXClient() as api:
             jobs = api.jobs.search(
                 parameters=["JobID"] + parameters,
-                search=[{"parameter": "JobID", "operator": "in", "values": jobIDs}],
+                search=[{"parameter": "JobID", "operator": "in", "values": jobIDs}],  # type: ignore
             )
             return {j["JobID"]: {param: j[param] for param in parameters} for j in jobs}
 
@@ -20,6 +20,66 @@ def getJobsMinorStatus(self, jobIDs):
     def getJobsStates(self, jobIDs):
         return self.fetch(["Status", "MinorStatus", "ApplicationStatus"], jobIDs)
 
+    @convertToReturnValue
+    def getJobsApplicationStatus(self, jobIDs):
+        return self.fetch(["ApplicationStatus"], jobIDs)
+
     @convertToReturnValue
     def getJobsSites(self, jobIDs):
         return self.fetch(["Site"], jobIDs)
+
+    @convertToReturnValue
+    def getJobsStatus(self, jobIDs):
+        return self.fetch(["Status"], jobIDs)
+
+    @convertToReturnValue
+    def getJobParameters(self, jobIDs):
+        # if isinstance(jobIDs, int):
+        #     jobIDs = [jobIDs]
+
+        # with DiracXClient() as api:
+        #     result = {}
+
+        #     for jobID in jobIDs:
+        #         return api.jobs.get_job_parameters(
+        #             job_id=jobID
+        #         )
+        # Need a coffee to understand DIRAC code...
+        pass
+
+    @convertToReturnValue
+    def getInputData(self, jobIDs):
+        with DiracXClient() as api:
+            # It's a mess
+            if isinstance(jobIDs, int):
+                jobIDs = [jobIDs]
+            elif isinstance(jobIDs, str):
+                jobIDs = [int(jobIDs)]
+            elif isinstance(jobIDs, list):
+                if isinstance(jobIDs[0], str):
+                    jobIDs = [int(jobID) for jobID in jobIDs]
+
+            reqDict = {}
+
+            for jobID in jobIDs:
+                reqDict[jobID] = api.jobs.get_input_data(jobID)  # type: ignore
+
+            def cleanLFN(data):
+                lfn = data["LFN"]
+                if lfn.lower().startswith("lfn:"):
+                    return lfn[4:]
+                return lfn
+
+            # WARNING /!\: Old code is super bizarre.
+            # It can return list as well as dict...
+            # By default, it's better to return a dict.
+
+            return_dict = {}
+            for data in reqDict:
+                job_id = data["JobID"]
+                if not job_id in return_dict:
+                    return_dict[job_id] = []
+
+                return_dict[job_id].append(cleanLFN(data))
+
+            return return_dict