cards-simulator/unity/Assets/Scripts/Client.cs

using Grpc.Core;
using System.Collections.Generic;
using System.Threading.Tasks;
using UnityEngine;
using Utilities;
public static class Client {
	private static Connection reference;

	public static void Connect(string name, string address = "127.0.0.1:50052") {
		reference = new Connection(name, address);
	}

	public static ref Connection GetConnection() {
		return ref reference;
	}

	public static void CloseConnection() {
		if (reference != null) {
			reference.Close();
			reference = null;
		}
	}

	public class Connection // : MonoBehaviour
	{
		private Game.Connection.ConnectionClient connection;
		private Game.Lobby.LobbyClient lobby_client;
		private Channel channel;
		private string connId;
		private uint? lobby = null;

		private Modifiable<Game.LobbyStatus> lobby_status = null;
		public Connection(string user, string address) {
			channel = new Channel(address, ChannelCredentials.Insecure);
			connection = new Game.Connection.ConnectionClient(channel);
			lobby_client = new Game.Lobby.LobbyClient(channel);
			connId = connection.connect(new Game.Name { Name_ = user }).Id;
		}

		public string Name() {
			return connection.name(new Google.Protobuf.WellKnownTypes.Empty()).Name_;
		}

		public void JoinLobby(string code) {
			lobby = Base32.FromString(code);
			connection.joinLobbyWithCode(new Game.LobbyCode { Code = (uint)lobby }, new Metadata { new Metadata.Entry("client_id", connId) });
		}

		public string CreateLobby(bool isPublic) {
			lobby = connection.createLobby(new Game.LobbyConfig { Public = isPublic }, new Metadata { new Metadata.Entry("client_id", connId) }).Code;
			return Base32.ToString((uint)lobby);
		}

		public string GetLobby() {
			if (lobby != null) {
				return Base32.ToString((uint)lobby);
			} else {
				return null;
			}
		}

		public Game.LobbyStatus LobbyStatus() {
			if (lobby != null) {
				if (lobby_status != null) {
					var hasNew = lobby_client.hasNewStatus(
						new Game.LastStatusTimestamp {
							Time = Google.Protobuf.WellKnownTypes.Timestamp.FromDateTime(lobby_status.GetLastModfication()),
							Lobby = (uint)lobby,
						},
						new Metadata { new Metadata.Entry("client_id", connId) }
						).Value;
					Debug.Log("HasNewStatus: " + hasNew);
					if (hasNew) {
						lobby_status.Set(lobby_client.getStatus(new Google.Protobuf.WellKnownTypes.Empty(), new Metadata { new Metadata.Entry("client_id", connId) }));
					}
					return lobby_status.Get();
				} else {
					Debug.Log("Getting status");
					lobby_status = new Utilities.Modifiable<Game.LobbyStatus>(lobby_client.getStatus(new Google.Protobuf.WellKnownTypes.Empty(), new Metadata { new Metadata.Entry("client_id", connId) }));
					return lobby_status.Get();
				}
			} else {
				return null;
			}
		}

		public List<string> GetUsersInSameLobby() {
			AsyncServerStreamingCall<Game.Name> stream = lobby_client.users(new Google.Protobuf.WellKnownTypes.Empty(), new Metadata { new Metadata.Entry("client_id", connId) });
			List<string> l = new List<string>();

			while (runSync(stream.ResponseStream.MoveNext())) {
				Game.Name g = stream.ResponseStream.Current;
				l.Add(g.Name_);
				// Debug.Log("Received " + feature.ToString());
			}
			// Debug.Log(stream.ResponseStream.Current);
			return l;
		}

		public void LeaveLobby() {
			lobby_status = null;
			lobby_client.leave(new Google.Protobuf.WellKnownTypes.Empty(), new Metadata { new Metadata.Entry("client_id", connId) });
			lobby = null;
		}

		public List<string> GetPublicLobbies() {
			AsyncServerStreamingCall<Game.LobbyCode> stream = connection.getPublicLobbies(new Google.Protobuf.WellKnownTypes.Empty());
			List<string> l = new List<string>();

			while (runSync(stream.ResponseStream.MoveNext())) {
				Game.LobbyCode g = stream.ResponseStream.Current;
				l.Add(Base32.ToString(g.Code));
				// Debug.Log("Received " + feature.ToString());
			}
			// Debug.Log(stream.ResponseStream.Current);
			return l;
		}

		public List<Game.Game> GetGames() {
			AsyncServerStreamingCall<Game.Game> stream = connection.getGames(new Google.Protobuf.WellKnownTypes.Empty());
			List<Game.Game> l = new List<Game.Game>();

			while (runSync(stream.ResponseStream.MoveNext())) {
				Game.Game g = stream.ResponseStream.Current;
				l.Add(g);
				// Debug.Log("Received " + feature.ToString());
			}
			// Debug.Log(stream.ResponseStream.Current);
			return l;
		}

		static T runSync<T>(Task<T> task) {
			task.Wait();
			return task.Result;
		}

		public void Close() {
			connection.disconnect(new Google.Protobuf.WellKnownTypes.Empty(), new Metadata { new Metadata.Entry("client_id", connId) });
			channel.ShutdownAsync().Wait();
		}
	}


}