<PackageReference Include="Relativity.Server.Import.SDK" Version="2.9.2" />

KeplerObjectManager

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.Threading.Tasks; namespace kCura.WinEDDS.Service.Replacement { public class KeplerObjectManager : KeplerManager, IObjectManager { [CompilerGenerated] internal sealed class _Closure$__1-0 { public int $VB$Local_caseContextArtifactID; public string $VB$Local_textIdentifier; public int $VB$Local_artifactTypeID; public KeplerObjectManager $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$__1-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$__2-0 { public int $VB$Local_caseContextArtifactID; public int $VB$Local_artifactId; public int $VB$Local_artifactTypeID; public KeplerObjectManager $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$__2-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$__3-0 { public int $VB$Local_caseContextArtifactID; public string $VB$Local_textIdentifier; public int $VB$Local_artifactTypeID; public KeplerObjectManager $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$__3-0 = this; stateMachine.$VB$Local_s = s; stateMachine.$State = -1; stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; } } public KeplerObjectManager(IServiceProxyFactory serviceProxyFactory, IServiceExceptionMapper exceptionMapper, Func<string> correlationIdFunc) : base(serviceProxyFactory, exceptionMapper, correlationIdFunc) { } public DataSet RetrieveArtifactIdOfMappedObject(int caseContextArtifactID, string textIdentifier, int artifactTypeID) { return Execute(delegate(IServiceProxyFactory s) { _Closure$__1-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__1-0.VB$StateMachine___Lambda$__0); _Closure$__1-0 $VB$NonLocal__Closure$__1-; stateMachine.$VB$NonLocal__Closure$__1-0 = $VB$NonLocal__Closure$__1-; stateMachine.$VB$Local_s = s; stateMachine.$State = -1; stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } DataSet IObjectManager.RetrieveArtifactIdOfMappedObject(int caseContextArtifactID, string textIdentifier, int artifactTypeID) { return this.RetrieveArtifactIdOfMappedObject(caseContextArtifactID, textIdentifier, artifactTypeID); } public DataSet RetrieveTextIdentifierOfMappedObject(int caseContextArtifactID, int artifactId, int artifactTypeID) { return Execute(delegate(IServiceProxyFactory s) { _Closure$__2-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__2-0.VB$StateMachine___Lambda$__0); _Closure$__2-0 $VB$NonLocal__Closure$__2-; stateMachine.$VB$NonLocal__Closure$__2-0 = $VB$NonLocal__Closure$__2-; stateMachine.$VB$Local_s = s; stateMachine.$State = -1; stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } DataSet IObjectManager.RetrieveTextIdentifierOfMappedObject(int caseContextArtifactID, int artifactId, int artifactTypeID) { return this.RetrieveTextIdentifierOfMappedObject(caseContextArtifactID, artifactId, artifactTypeID); } public DataSet RetrieveArtifactIdOfMappedParentObject(int caseContextArtifactID, string textIdentifier, int artifactTypeID) { return Execute(delegate(IServiceProxyFactory s) { _Closure$__3-0.VB$StateMachine___Lambda$__0 stateMachine = default(_Closure$__3-0.VB$StateMachine___Lambda$__0); _Closure$__3-0 $VB$NonLocal__Closure$__3-; stateMachine.$VB$NonLocal__Closure$__3-0 = $VB$NonLocal__Closure$__3-; stateMachine.$VB$Local_s = s; stateMachine.$State = -1; stateMachine.$Builder = AsyncTaskMethodBuilder<DataSetWrapper>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } DataSet IObjectManager.RetrieveArtifactIdOfMappedParentObject(int caseContextArtifactID, string textIdentifier, int artifactTypeID) { return this.RetrieveArtifactIdOfMappedParentObject(caseContextArtifactID, textIdentifier, artifactTypeID); } } }