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

KeplerProductionManager

using kCura.EDDS.WebAPI.ProductionManagerBase; using kCura.WinEDDS.Mapping; using kCura.WinEDDS.Service.Export; 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 KeplerProductionManager : KeplerManager, IProductionManager { [CompilerGenerated] internal sealed class _Closure$__1-0 { public int $VB$Local_contextArtifactID; public int $VB$Local_productionArtifactID; public KeplerProductionManager $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$__1-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$__2-0 { public int $VB$Local_contextArtifactID; public int $VB$Local_productionArtifactID; public KeplerProductionManager $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$__2-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$__3-0 { public int $VB$Local_caseContextArtifactID; public int $VB$Local_productionArtifactID; public KeplerProductionManager $VB$Me; [AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))] internal Task<ProductionInfo> _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<ProductionInfo>.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_productionIds; public int[] $VB$Local_documentIds; public KeplerProductionManager $VB$Me; [AsyncStateMachine(typeof(VB$StateMachine___Lambda$__0))] internal Task<object[][]> _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<object[][]>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; } } [CompilerGenerated] internal sealed class _Closure$__5-0 { public int $VB$Local_caseContextArtifactID; public KeplerProductionManager $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$__5-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$__6-0 { public int $VB$Local_caseContextArtifactID; public KeplerProductionManager $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$__6-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 KeplerProductionManager(IServiceProxyFactory serviceProxyFactory, IServiceExceptionMapper exceptionMapper, Func<string> correlationIdFunc) : base(serviceProxyFactory, exceptionMapper, correlationIdFunc) { } public void DoPostImportProcessing(int contextArtifactID, int productionArtifactID) { 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<bool>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } void IProductionManager.DoPostImportProcessing(int contextArtifactID, int productionArtifactID) { this.DoPostImportProcessing(contextArtifactID, productionArtifactID); } public void DoPreImportProcessing(int contextArtifactID, int productionArtifactID) { 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<bool>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } void IProductionManager.DoPreImportProcessing(int contextArtifactID, int productionArtifactID) { this.DoPreImportProcessing(contextArtifactID, productionArtifactID); } public ProductionInfo Read(int caseContextArtifactID, int productionArtifactID) { 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<ProductionInfo>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } ProductionInfo IProductionManager.Read(int caseContextArtifactID, int productionArtifactID) { return this.Read(caseContextArtifactID, productionArtifactID); } ProductionInfo kCura.WinEDDS.Service.Export.IProductionManager.Read(int caseContextArtifactID, int productionArtifactID) { return this.Read(caseContextArtifactID, productionArtifactID); } public object[][] RetrieveBatesByProductionAndDocument(int caseContextArtifactID, int[] productionIds, int[] documentIds) { 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<object[][]>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } object[][] IProductionManager.RetrieveBatesByProductionAndDocument(int caseContextArtifactID, int[] productionIds, int[] documentIds) { return this.RetrieveBatesByProductionAndDocument(caseContextArtifactID, productionIds, documentIds); } object[][] kCura.WinEDDS.Service.Export.IProductionManager.RetrieveBatesByProductionAndDocument(int caseContextArtifactID, int[] productionIds, int[] documentIds) { return this.RetrieveBatesByProductionAndDocument(caseContextArtifactID, productionIds, documentIds); } public DataSet RetrieveProducedByContextArtifactID(int caseContextArtifactID) { 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<DataSetWrapper>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } DataSet IProductionManager.RetrieveProducedByContextArtifactID(int caseContextArtifactID) { return this.RetrieveProducedByContextArtifactID(caseContextArtifactID); } DataSet kCura.WinEDDS.Service.Export.IProductionManager.RetrieveProducedByContextArtifactID(int caseContextArtifactID) { return this.RetrieveProducedByContextArtifactID(caseContextArtifactID); } public DataSet RetrieveImportEligibleByContextArtifactID(int caseContextArtifactID) { 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<DataSetWrapper>.Create(); stateMachine.$Builder.Start(ref stateMachine); return stateMachine.$Builder.Task; }); } DataSet IProductionManager.RetrieveImportEligibleByContextArtifactID(int caseContextArtifactID) { return this.RetrieveImportEligibleByContextArtifactID(caseContextArtifactID); } DataSet kCura.WinEDDS.Service.Export.IProductionManager.RetrieveImportEligibleByContextArtifactID(int caseContextArtifactID) { return this.RetrieveImportEligibleByContextArtifactID(caseContextArtifactID); } } }