@@ -159,19 +159,7 @@ public override async Task StartContainersForScenarioRun(String scenarioName)
159159 Boolean . TryParse ( IsSecureEventStoreEnvVar , out Boolean isSecure ) ;
160160 this . IsSecureEventStore = isSecure ;
161161 }
162-
163- //var dir = "/home/runner/work/TransactionProcessor/TransactionProcessor/TransactionProcessor.IntegrationTests/bin/Debug/net6.0/";
164- //var g = Directory.GetDirectories(dir);
165- //foreach (String s in g) {
166- // this.Logger.LogInformation($"[{s}]");
167- //}
168- //dir = "/home/runner/work/TransactionProcessor/TransactionProcessor/TransactionProcessor.IntegrationTests/bin/Debug/net6.0/projections/contin/";
169- //g = Directory.GetDirectories(dir);
170- //foreach (String s in g)
171- //{
172- // this.Logger.LogInformation($"[{s}]");
173- //}
174-
162+
175163 this . HostTraceFolder = FdOs . IsWindows ( ) ? $ "C:\\ home\\ txnproc\\ trace\\ { scenarioName } " : $ "//home//txnproc//trace//{ scenarioName } ";
176164 this . SqlServerDetails = ( Setup . SqlServerContainerName , Setup . SqlUserName , Setup . SqlPassword ) ;
177165 Logging . Enabled ( ) ;
@@ -416,74 +404,7 @@ protected virtual async Task LoadAdditionalEventStoreProjections(Int32 eventStor
416404
417405 this . Logger . LogInformation ( "Loaded additional projections" ) ;
418406 }
419-
420- protected override async Task LoadEventStoreProjections ( Int32 eventStoreHttpPort , Boolean isSecureEventStore = false )
421- {
422- //Start our Continous Projections - we might decide to do this at a different stage, but now lets try here
423- String projectionsFolder = "projections/continuous" ;
424-
425- IPAddress [ ] ipAddresses = Dns . GetHostAddresses ( "127.0.0.1" ) ;
426-
427- if ( ! String . IsNullOrWhiteSpace ( projectionsFolder ) )
428- {
429- DirectoryInfo di = new DirectoryInfo ( projectionsFolder ) ;
430-
431- if ( di . Exists )
432- {
433- FileInfo [ ] files = di . GetFiles ( ) ;
434-
435- EventStoreProjectionManagementClient projectionClient =
436- new EventStoreProjectionManagementClient ( this . ConfigureEventStoreSettings ( eventStoreHttpPort , isSecureEventStore ) ) ;
437- List < String > projectionNames = new List < String > ( ) ;
438-
439- foreach ( FileInfo file in files )
440- {
441- String projection = await DockerHelper . RemoveProjectionTestSetup ( file ) ;
442- String projectionName = file . Name . Replace ( ".js" , String . Empty ) ;
443-
444- try
445- {
446- this . Logger . LogInformation ( $ "Creating projection [{ projectionName } ] from file [{ file . FullName } ]") ;
447- await projectionClient . CreateContinuousAsync ( projectionName , projection , trackEmittedStreams : true ) . ConfigureAwait ( false ) ;
448-
449- projectionNames . Add ( projectionName ) ;
450- }
451- catch ( Exception e )
452- {
453- this . Logger . LogError ( new Exception ( $ "Projection [{ projectionName } ] error", e ) ) ;
454- }
455- }
456-
457- // Now check the create status of each
458- foreach ( String projectionName in projectionNames )
459- {
460- try
461- {
462- ProjectionDetails projectionDetails = await projectionClient . GetStatusAsync ( projectionName ) ;
463-
464- if ( projectionDetails . Status == "Running" )
465- {
466- this . Logger . LogInformation ( $ "Projection [{ projectionName } ] is Running") ;
467- }
468- else
469- {
470- this . Logger . LogWarning ( $ "Projection [{ projectionName } ] is { projectionDetails . Status } ") ;
471- }
472- }
473- catch ( Exception e )
474- {
475- this . Logger . LogError ( new Exception ( $ "Error getting Projection [{ projectionName } ] status", e ) ) ;
476- }
477- }
478- }
479- else {
480- this . Logger . LogWarning ( $ "Folder [{ di . Name } ] not found") ;
481- }
482- }
483-
484- this . Logger . LogInformation ( "Loaded projections" ) ;
485- }
486-
407+
487408 /// <summary>
488409 /// Stops the containers for scenario run.
489410 /// </summary>
0 commit comments