KeplerFolderManager
using kCura.EDDS.WebAPI.FolderManagerBase;
using kCura.WinEDDS.Mapping;
using Relativity.DataExchange.Service;
using Relativity.DataTransfer.Legacy.SDK.ImportExport.V1.Models;
using System;
using System.Data;
using System.Runtime.CompilerServices;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
namespace kCura.WinEDDS.Service.Replacement
{
public class KeplerFolderManager : KeplerManager, IFolderManager
{
[CompilerGenerated]
internal sealed class _Closure$__10-0
{
public int $VB$Local_caseContextArtifactID;
public int $VB$Local_rootArtifactID;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<DataSetWrapper> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__10-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
[CompilerGenerated]
internal sealed class _Closure$__4-0
{
public int $VB$Local_caseContextArtifactID;
public int $VB$Local_folderArtifactID;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<Folder> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__4-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<Folder>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
[CompilerGenerated]
internal sealed class _Closure$__5-0
{
public int $VB$Local_caseContextArtifactID;
public int $VB$Local_parentArtifactID;
public string $VB$Local_name;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<int> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__5-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<int>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
[CompilerGenerated]
internal sealed class _Closure$__6-0
{
public string $VB$Local_name;
public int $VB$Local_caseContextArtifactID;
public int $VB$Local_parentArtifactID;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<int> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__6-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<int>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
[CompilerGenerated]
internal sealed class _Closure$__7-0
{
public int $VB$Local_caseContextArtifactID;
public int $VB$Local_rootFolderID;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<bool> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__7-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<bool>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
[CompilerGenerated]
internal sealed class _Closure$__8-0
{
public int $VB$Local_caseContextArtifactID;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<DataSetWrapper> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__8-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
[CompilerGenerated]
internal sealed class _Closure$__9-0
{
public int $VB$Local_caseContextArtifactID;
public int $VB$Local_lastFolderID;
public KeplerFolderManager $VB$Me;
[AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))]
internal Task<DataSetWrapper> _Lambda$__0(IServiceProxyFactory s)
{
VB$StateMachine___Lambda$__0 stateMachine = default(VB$StateMachine___Lambda$__0);
stateMachine.$VB$NonLocal__Closure$__9-0 = this;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
}
}
private int _folderCreationCount;
public int CreationCount => _folderCreationCount;
public KeplerFolderManager(IServiceProxyFactory serviceProxyFactory, IServiceExceptionMapper exceptionMapper, Func<string> correlationIdFunc)
: base(serviceProxyFactory, exceptionMapper, correlationIdFunc)
{
_folderCreationCount = 0;
}
public Folder Read(int caseContextArtifactID, int folderArtifactID)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__4-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__4-0.VB$StateMachine___Lambda$__0);
_Closure$__4-0 $VB$NonLocal__Closure$__4-;
stateMachine.$VB$NonLocal__Closure$__4-0 = $VB$NonLocal__Closure$__4-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<Folder>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
Folder IFolderManager.Read(int caseContextArtifactID, int folderArtifactID)
{
return this.Read(caseContextArtifactID, folderArtifactID);
}
public int ReadID(int caseContextArtifactID, int parentArtifactID, string name)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__5-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__5-0.VB$StateMachine___Lambda$__0);
_Closure$__5-0 $VB$NonLocal__Closure$__5-;
stateMachine.$VB$NonLocal__Closure$__5-0 = $VB$NonLocal__Closure$__5-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<int>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
int IFolderManager.ReadID(int caseContextArtifactID, int parentArtifactID, string name)
{
return this.ReadID(caseContextArtifactID, parentArtifactID, name);
}
int IHierarchicArtifactManager.Read(int caseContextArtifactID, int parentArtifactID, string name)
{
return this.ReadID(caseContextArtifactID, parentArtifactID, name);
}
public int Create(int caseContextArtifactID, int parentArtifactID, string name)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__6-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__6-0.VB$StateMachine___Lambda$__0);
_Closure$__6-0 $VB$NonLocal__Closure$__6-;
stateMachine.$VB$NonLocal__Closure$__6-0 = $VB$NonLocal__Closure$__6-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<int>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
int IFolderManager.Create(int caseContextArtifactID, int parentArtifactID, string name)
{
return this.Create(caseContextArtifactID, parentArtifactID, name);
}
int IHierarchicArtifactManager.Create(int caseContextArtifactID, int parentArtifactID, string name)
{
return this.Create(caseContextArtifactID, parentArtifactID, name);
}
public bool Exists(int caseContextArtifactID, int rootFolderID)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__7-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__7-0.VB$StateMachine___Lambda$__0);
_Closure$__7-0 $VB$NonLocal__Closure$__7-;
stateMachine.$VB$NonLocal__Closure$__7-0 = $VB$NonLocal__Closure$__7-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<bool>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
bool IFolderManager.Exists(int caseContextArtifactID, int rootFolderID)
{
return this.Exists(caseContextArtifactID, rootFolderID);
}
public DataSet RetrieveIntitialChunk(int caseContextArtifactID)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__8-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__8-0.VB$StateMachine___Lambda$__0);
_Closure$__8-0 $VB$NonLocal__Closure$__8-;
stateMachine.$VB$NonLocal__Closure$__8-0 = $VB$NonLocal__Closure$__8-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
DataSet IFolderManager.RetrieveIntitialChunk(int caseContextArtifactID)
{
return this.RetrieveIntitialChunk(caseContextArtifactID);
}
public DataSet RetrieveNextChunk(int caseContextArtifactID, int lastFolderID)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__9-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__9-0.VB$StateMachine___Lambda$__0);
_Closure$__9-0 $VB$NonLocal__Closure$__9-;
stateMachine.$VB$NonLocal__Closure$__9-0 = $VB$NonLocal__Closure$__9-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
DataSet IFolderManager.RetrieveNextChunk(int caseContextArtifactID, int lastFolderID)
{
return this.RetrieveNextChunk(caseContextArtifactID, lastFolderID);
}
public DataSet RetrieveArtifacts(int caseContextArtifactID, int rootArtifactID)
{
return Execute(delegate(IServiceProxyFactory s) {
_Closure$__10-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__10-0.VB$StateMachine___Lambda$__0);
_Closure$__10-0 $VB$NonLocal__Closure$__10-;
stateMachine.$VB$NonLocal__Closure$__10-0 = $VB$NonLocal__Closure$__10-;
stateMachine.$VB$Local_s = s;
stateMachine.$State = -1;
stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create();
stateMachine.$Builder.Start(ref stateMachine);
return stateMachine.$Builder.Task;
});
}
DataSet IFolderManager.RetrieveArtifacts(int caseContextArtifactID, int rootArtifactID)
{
return this.RetrieveArtifacts(caseContextArtifactID, rootArtifactID);
}
DataSet IHierarchicArtifactManager.RetrieveArtifacts(int caseContextArtifactID, int rootArtifactID)
{
return this.RetrieveArtifacts(caseContextArtifactID, rootArtifactID);
}
private string GetExportFriendlyFolderName(string input)
{
return Regex.Replace(input, "[\\*\\\\\\/\\:\\?\\<\\>\\\"\\|\\$]+", " ").Trim();
}
}
}