Nodejs counters and lists

examples/nodejs-simple/gameserver-counts-and-lists.yaml

@@ -0,0 +1,46 @@
+---
+# Copyright 2020 Google LLC All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+apiVersion: agones.dev/v1
+kind: GameServer
+metadata:
+  generateName: simple-game-server-
+spec:
+  ports:
+    - name: default
+      portPolicy: Dynamic
+      containerPort: 7654
+  counters:
+    games:
+      count: 1
+      capacity: 10
+  lists:
+    rooms:
+      capacity: 5
+      values:
+        - room1
+        - room2
+  template:
+    spec:
+      containers:
+        - name: simple-game-server
+          image: us-docker.pkg.dev/agones-images/examples/simple-game-server:0.27
+          resources:
+            requests:
+              memory: 64Mi
+              cpu: 20m
+            limits:
+              memory: 64Mi
+              cpu: 20m
+

examples/nodejs-simple/src/index.js

@@ -18,7 +18,7 @@ const {setTimeout} = require('timers/promises');
 const DEFAULT_TIMEOUT = 60;
 const MAX_TIMEOUT = 2147483;
 
-const connect = async (timeout, enableAlpha) => {
+const connect = async (timeout, enableAlpha, enableCountsAndLists) => {
 	let agonesSDK = new AgonesSDK();
 
 	let lifetimeInterval;
@@ -56,32 +56,37 @@ const connect = async (timeout, enableAlpha) => {
 			process.exit(0);
 		});
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Setting a label');
 		await agonesSDK.setLabel('test-label', 'test-value');
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Setting an annotation');
 		await agonesSDK.setAnnotation('test-annotation', 'test value');
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Marking server as ready...');
 		await agonesSDK.ready();
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Allocating');
 		await agonesSDK.allocate();
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Reserving for 10 seconds');
 		await agonesSDK.reserve(10);
-		await setTimeout(20000);
+		await setTimeout(15000);
 
 		if (enableAlpha) {
 			console.log('Running alpha suite');
 			await runAlphaSuite(agonesSDK);
 		}
 
+		if (enableCountsAndLists) {
+			console.log('Running counts and lists suite');
+			await runCountAndListsSuite(agonesSDK);
+		}
+
 		if (timeout === 0) {
 			do {
 				await setTimeout(MAX_TIMEOUT);
@@ -93,12 +98,12 @@ const connect = async (timeout, enableAlpha) => {
 		console.log('Shutting down...');
 		agonesSDK.shutdown();
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Closing connection to SDK server');
 		clearInterval(healthInterval);
 		agonesSDK.close();
 
-		await setTimeout(10000);
+		await setTimeout(5000);
 		console.log('Exiting');
 		clearInterval(lifetimeInterval);
 
@@ -113,58 +118,126 @@ const connect = async (timeout, enableAlpha) => {
 };
 
 const runAlphaSuite = async (agonesSDK) => {
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Setting capacity');
 	await agonesSDK.alpha.setPlayerCapacity(64);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Getting capacity');
 	let result = await agonesSDK.alpha.getPlayerCapacity();
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Connecting a player');
 	result = await agonesSDK.alpha.playerConnect('firstPlayerID');
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Connecting a duplicate player');
 	result = await agonesSDK.alpha.playerConnect('firstPlayerID');
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Connecting another player');
 	await agonesSDK.alpha.playerConnect('secondPlayerID');
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Getting player count');
 	result = await agonesSDK.alpha.getPlayerCount();
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Finding if firstPlayerID connected');
 	result = await agonesSDK.alpha.isPlayerConnected('firstPlayerID');
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Getting connected players');
 	result = await agonesSDK.alpha.getConnectedPlayers();
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Disconnecting a player');
 	result = await agonesSDK.alpha.playerDisconnect('firstPlayerID');
 	console.log(`result: ${result}`);
 
-	await setTimeout(10000);
+	await setTimeout(5000);
 	console.log('Disconnecting the same player');
 	result = await agonesSDK.alpha.playerDisconnect('firstPlayerID');
 	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Setting counter capacity');
+	result = await agonesSDK.alpha.setCounterCapacity('testCounter', 10);
+	console.log(`result: ${result}`);
+};
+
+const runCountAndListsSuite = async (agonesSDK) => {
+	let result;
+
+	await setTimeout(5000);
+	console.log('Getting counter count');
+	result = await agonesSDK.alpha.getCounterCount('games');
+	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Incrementing counter');
+	await agonesSDK.alpha.incrementCounter('games', 1);
+
+	await setTimeout(5000);
+	console.log('Decrementing counter');
+	await agonesSDK.alpha.decrementCounter('games', 1);
+
+	await setTimeout(5000);
+	console.log('Setting counter count');
+	await agonesSDK.alpha.setCounterCount('games', 2);
+
+	await setTimeout(5000);
+	console.log('Getting counter capacity');
+	result = await agonesSDK.alpha.getCounterCapacity('games');
+	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Setting counter capacity');
+	await agonesSDK.alpha.setCounterCapacity('games', 200);
+
+	await setTimeout(5000);
+	console.log('Getting list capacity');
+	result = await agonesSDK.alpha.getListCapacity('rooms');
+	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Setting list capacity');
+	await agonesSDK.alpha.setListCapacity('rooms', 10);
+
+	await setTimeout(5000);
+	console.log('Getting list contains');
+	result = await agonesSDK.alpha.listContains('rooms', 'room1');
+	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Getting list length');
+	result = await agonesSDK.alpha.getListLength('rooms');
+	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Getting list values');
+	result = await agonesSDK.alpha.getListValues('rooms');
+	console.log(`result: ${result}`);
+
+	await setTimeout(5000);
+	console.log('Appending list value');
+	await agonesSDK.alpha.appendListValue('rooms', 'room3');
+
+	await setTimeout(5000);
+	console.log('Deleting list value');
+	await agonesSDK.alpha.deleteListValue('rooms', 'room3');
 };
 
 let args = process.argv.slice(2);
 let timeout = DEFAULT_TIMEOUT;
 let enableAlpha = false;
+let enableCountsAndLists = false;
 
 for (let arg of args) {
 	let [argName, argValue] = arg.split('=');
@@ -173,7 +246,8 @@ for (let arg of args) {
 
 Options:
 	--timeout=...\t\tshutdown timeout in seconds. Use 0 to never shut down
-	--alpha\t\t\tenable alpha features`);
+	--alpha\t\t\tenable alpha features
+	--countsandlists\tenable counts and lists features`);
 		return;
 	}
 	if (argName === '--timeout') {
@@ -194,6 +268,11 @@ Options:
 		console.log('Enabling alpha features!');
 		enableAlpha = true;
 	}
+
+	if (argName === '--countsandlists') {
+		console.log('Enabling counts and lists features!');
+		enableCountsAndLists = true;
+	}
 }
 
-connect(timeout, enableAlpha);
+connect(timeout, enableAlpha, enableCountsAndLists);