6237307473

Committed 19 Sep 2023 04:02PM UTC coverage: 57.015% (-0.4%) from 57.44%

Build # 6237307473

Build Type

push

github

Committed by

web-flow

Commit Message

Feature/rc4 (#1570)

* Syntax tidying
* Dependency updates
* Event handling singletons (ThrowImmediately and co)

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: James A Sutherland <>
Co-authored-by: James Friel <jfriel001@dundee.ac.uk>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

Run Details

10734 of 20259 branches covered (0.0%)

Branch coverage included in aggregate %.

5922 of 5922 new or added lines in 565 files covered. (100.0%)

30687 of 52390 relevant lines covered (58.57%)

7361.8 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/Rdmp.Core/DataLoad/Modules/DataProvider/ShareDefinitionImporter.cs

// Copyright (c) The University of Dundee 2018-2019
// This file is part of the Research Data Management Platform (RDMP).
// RDMP is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
// RDMP is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
// You should have received a copy of the GNU General Public License along with RDMP. If not, see <https://www.gnu.org/licenses/>.

using System.IO;
using FAnsi.Discovery;
using Rdmp.Core.Curation;
using Rdmp.Core.Curation.Data.ImportExport;
using Rdmp.Core.DataFlowPipeline;
using Rdmp.Core.DataLoad.Engine.DataProvider;
using Rdmp.Core.DataLoad.Engine.Job;
using Rdmp.Core.ReusableLibraryCode.Checks;
using Rdmp.Core.ReusableLibraryCode.Progress;

namespace Rdmp.Core.DataLoad.Modules.DataProvider;

/// <summary>
/// Data Provider Process Task for DLE which will look for *.sd files and import them into RDMP
/// </summary>
public class ShareDefinitionImporter : IPluginDataProvider
{
    public void LoadCompletedSoDispose(ExitCodeType exitCode, IDataLoadEventListener postLoadEventsListener)
    {
    }

    public void Check(ICheckNotifier notifier)
    {
    }

    public void Initialize(ILoadDirectory directory, DiscoveredDatabase dbInfo)
    {
    }

    public ExitCodeType Fetch(IDataLoadJob job, GracefulCancellationToken cancellationToken)
    {
        var imported = 0;
        try
        {
            var shareManager = new ShareManager(job.RepositoryLocator);

            foreach (var shareDefinitionFile in job.LoadDirectory.ForLoading.EnumerateFiles("*.sd"))
            {
                job.OnNotify(this, new NotifyEventArgs(ProgressEventType.Information,
                    $"Found '{shareDefinitionFile.Name}'"));
                using (var stream = File.Open(shareDefinitionFile.FullName, FileMode.Open))
                {
                    shareManager.ImportSharedObject(stream);
                }

                imported++;
                job.OnNotify(this, new NotifyEventArgs(ProgressEventType.Information,
                    $"Imported '{shareDefinitionFile.Name}' Successfully"));
            }
        }
        catch (SharingException ex)
        {
            job.OnNotify(this,
                new NotifyEventArgs(ProgressEventType.Warning, "Error occurred importing ShareDefinitions", ex));
        }

        job.OnNotify(this, new NotifyEventArgs(
            imported == 0 ? ProgressEventType.Warning : ProgressEventType.Information,
            $"Imported {imported} ShareDefinition files"));

        return ExitCodeType.Success;
    }
}

1	// Copyright (c) The University of Dundee 2018-2019
2	// This file is part of the Research Data Management Platform (RDMP).
3	// RDMP is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version.
4	// RDMP is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.
5	// You should have received a copy of the GNU General Public License along with RDMP. If not, see <https://www.gnu.org/licenses/>.
6
7	using System.IO;
8	using FAnsi.Discovery;
9	using Rdmp.Core.Curation;
10	using Rdmp.Core.Curation.Data.ImportExport;
11	using Rdmp.Core.DataFlowPipeline;
12	using Rdmp.Core.DataLoad.Engine.DataProvider;
13	using Rdmp.Core.DataLoad.Engine.Job;
14	using Rdmp.Core.ReusableLibraryCode.Checks;
15	using Rdmp.Core.ReusableLibraryCode.Progress;
16
17	namespace Rdmp.Core.DataLoad.Modules.DataProvider;
18
19	/// <summary>
20	/// Data Provider Process Task for DLE which will look for *.sd files and import them into RDMP
21	/// </summary>
22	public class ShareDefinitionImporter : IPluginDataProvider
23	{
24	public void LoadCompletedSoDispose(ExitCodeType exitCode, IDataLoadEventListener postLoadEventsListener)
25	{
26	}	×
27
28	public void Check(ICheckNotifier notifier)
29	{
30	}	×
31
32	public void Initialize(ILoadDirectory directory, DiscoveredDatabase dbInfo)
33	{
34	}	×
35
36	public ExitCodeType Fetch(IDataLoadJob job, GracefulCancellationToken cancellationToken)
37	{
38	var imported = 0;	×
39	try
40	{
41	var shareManager = new ShareManager(job.RepositoryLocator);	×
42
43	foreach (var shareDefinitionFile in job.LoadDirectory.ForLoading.EnumerateFiles("*.sd"))	×
44	{
45	job.OnNotify(this, new NotifyEventArgs(ProgressEventType.Information,	×
46	$"Found '{shareDefinitionFile.Name}'"));	×
47	using (var stream = File.Open(shareDefinitionFile.FullName, FileMode.Open))	×
48	{
49	shareManager.ImportSharedObject(stream);	×
50	}	×
51
52	imported++;	×
53	job.OnNotify(this, new NotifyEventArgs(ProgressEventType.Information,	×
54	$"Imported '{shareDefinitionFile.Name}' Successfully"));	×
55	}
56	}	×
57	catch (SharingException ex)	×
58	{
59	job.OnNotify(this,	×
60	new NotifyEventArgs(ProgressEventType.Warning, "Error occurred importing ShareDefinitions", ex));	×
61	}	×
62
63	job.OnNotify(this, new NotifyEventArgs(	×
64	imported == 0 ? ProgressEventType.Warning : ProgressEventType.Information,	×
65	$"Imported {imported} ShareDefinition files"));	×
66
67	return ExitCodeType.Success;	×
68	}
69	}

HicServices / RDMP / 6237307473

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous