Add a concurrent connections threshold configuration parameter to Sta…

…rgate applications. This new configuration option will end up controlling the #maximumNumberOfConcurrentConnections parameter in Zinc.
ba-st · Mar 21, 2024 · ffc4382 · ffc4382
1 parent 280164f
commit ffc4382
Show file tree

Hide file tree

Showing 6 changed files with 220 additions and 44 deletions.
diff --git a/source/Stargate-API-Skeleton-Tests/ConcurrentConnectionsTestApplication.class.st b/source/Stargate-API-Skeleton-Tests/ConcurrentConnectionsTestApplication.class.st
@@ -0,0 +1,40 @@
+"
+I'm a testing application used to check the concurrent connections threshold configuration parameter behavior.
+"
+Class {
+	#name : 'ConcurrentConnectionsTestApplication',
+	#superclass : 'StargateApplication',
+	#category : 'Stargate-API-Skeleton-Tests',
+	#package : 'Stargate-API-Skeleton-Tests'
+}
+
+{ #category : 'accessing' }
+ConcurrentConnectionsTestApplication class >> commandName [
+
+	^ 'concurrent-connections-test'
+]
+
+{ #category : 'accessing' }
+ConcurrentConnectionsTestApplication class >> description [
+
+	^'A Test API making the request processing to wait a certain amount of time'
+]
+
+{ #category : 'initialization' }
+ConcurrentConnectionsTestApplication class >> initialize [
+
+	<ignoreForCoverage>
+	self initializeVersion
+]
+
+{ #category : 'private' }
+ConcurrentConnectionsTestApplication class >> projectName [
+
+	^ 'Stargate'
+]
+
+{ #category : 'private - accessing' }
+ConcurrentConnectionsTestApplication >> controllersToInstall [
+
+	^ { DelayedRESTfulController new }
+]
diff --git a/source/Stargate-API-Skeleton-Tests/DelayedRESTfulController.class.st b/source/Stargate-API-Skeleton-Tests/DelayedRESTfulController.class.st
@@ -0,0 +1,46 @@
+"
+I'm a example of a RESTful controller:
+- only implementing GET operations
+- not paginating collections
+- don't using hypermedia
+"
+Class {
+	#name : 'DelayedRESTfulController',
+	#superclass : 'SingleResourceRESTfulController',
+	#instVars : [
+		'requestHandler'
+	],
+	#category : 'Stargate-API-Skeleton-Tests',
+	#package : 'Stargate-API-Skeleton-Tests'
+}
+
+{ #category : 'routes' }
+DelayedRESTfulController >> declareWaitRoute [
+
+	^ RouteSpecification handling: #GET at: self endpoint evaluating: [ :httpRequest :requestContext |
+		  100 milliSeconds wait.
+		  ZnResponse ok: ( ZnEntity text: 'OK' )
+		  ]
+]
+
+{ #category : 'initialization' }
+DelayedRESTfulController >> initialize [
+
+	super initialize.
+	requestHandler := RESTfulRequestHandlerBuilder new
+		                  handling: 'wait';
+		                  createEntityTagHashingEncodedResource;
+		                  build
+]
+
+{ #category : 'private' }
+DelayedRESTfulController >> requestHandler [
+
+	^ requestHandler 
+]
+
+{ #category : 'private' }
+DelayedRESTfulController >> typeIdConstraint [
+
+	^ IsObject
+]
diff --git a/source/Stargate-API-Skeleton-Tests/StargateApplicationStackTraceDumperTest.class.st b/source/Stargate-API-Skeleton-Tests/StargateApplicationStackTraceDumperTest.class.st
@@ -1,23 +1,24 @@
 Class {
-	#name : #StargateApplicationStackTraceDumperTest,
-	#superclass : #TestCase,
-	#category : #'Stargate-API-Skeleton-Tests'
+	#name : 'StargateApplicationStackTraceDumperTest',
+	#superclass : 'TestCase',
+	#category : 'Stargate-API-Skeleton-Tests',
+	#package : 'Stargate-API-Skeleton-Tests'
 }
 
-{ #category : #accessing }
+{ #category : 'accessing' }
 StargateApplicationStackTraceDumperTest class >> defaultTimeLimit [
 
 	^5 minute
 ]
 
-{ #category : #running }
+{ #category : 'running' }
 StargateApplicationStackTraceDumperTest >> setUp [
 
 	super setUp.
 	StargateApplication logsDirectory ensureCreateDirectory
 ]
 
-{ #category : #'tests - application' }
+{ #category : 'tests - application' }
 StargateApplicationStackTraceDumperTest >> testStackTraceDumper [
 
 	| dumper result |