Skip to content

Commit

Permalink
feat(google-open-match-sdk): regenerate java sdk
Browse files Browse the repository at this point in the history
  • Loading branch information
jeremylvln committed Nov 13, 2023
1 parent 929c652 commit e700916
Show file tree
Hide file tree
Showing 119 changed files with 5,016 additions and 5,545 deletions.
1 change: 1 addition & 0 deletions packages/google-agones-sdk/bindings/java/build.gradle.kts
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
dependencies {
api("com.google.protobuf:protobuf-java:3.25.0")
implementation("com.google.api.grpc:proto-google-common-protos:2.28.0")
implementation("io.grpc:grpc-protobuf:1.59.0")
implementation("io.grpc:grpc-services:1.59.0")
implementation("io.grpc:grpc-stub:1.59.0")
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
package dev.agones;

import dev.agones.dev.sdk.GameServer;
package com.agones.dev.sdk;

import java.util.List;
import java.util.concurrent.CompletableFuture;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,13 +1,8 @@
package dev.agones;
package com.agones.dev.sdk;

import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import dev.agones.dev.sdk.Duration;
import dev.agones.dev.sdk.Empty;
import dev.agones.dev.sdk.GameServer;
import dev.agones.dev.sdk.SDKGrpc;;
import dev.agones.dev.sdk.alpha.*;
import io.grpc.ManagedChannel;
import io.grpc.ManagedChannelBuilder;
import io.grpc.stub.StreamObserver;
Expand Down Expand Up @@ -139,49 +134,49 @@ public static AgonesSDK createFromEnvironment() {
}

public final class AlphaImpl implements AgonesSDK.Alpha {
private static final dev.agones.dev.sdk.alpha.Empty EMPTY_PAYLOAD = dev.agones.dev.sdk.alpha.Empty.getDefaultInstance();
private static final com.agones.dev.sdk.alpha.Empty EMPTY_PAYLOAD = com.agones.dev.sdk.alpha.Empty.getDefaultInstance();

private final dev.agones.dev.sdk.alpha.SDKGrpc.SDKFutureStub asyncStub = dev.agones.dev.sdk.alpha.SDKGrpc.newFutureStub(channel);
private final com.agones.dev.sdk.alpha.SDKGrpc.SDKFutureStub asyncStub = com.agones.dev.sdk.alpha.SDKGrpc.newFutureStub(channel);

@Override
public CompletableFuture<Boolean> notifyPlayerConnected(String id) {
return wrapGrpcFuture(this.asyncStub.playerConnect(this.createPlayerId(id))).thenApply(Bool::getBool);
return wrapGrpcFuture(this.asyncStub.playerConnect(this.createPlayerId(id))).thenApply(com.agones.dev.sdk.alpha.Bool::getBool);
}

@Override
public CompletableFuture<Boolean> notifyPlayerDisconnected(String id) {
return wrapGrpcFuture(this.asyncStub.playerConnect(this.createPlayerId(id))).thenApply(Bool::getBool);
return wrapGrpcFuture(this.asyncStub.playerConnect(this.createPlayerId(id))).thenApply(com.agones.dev.sdk.alpha.Bool::getBool);
}

@Override
public CompletableFuture<Void> setPlayerCapacity(long capacity) {
return wrapGrpcFuture(
this.asyncStub.setPlayerCapacity(Count.newBuilder().setCount(capacity).build())
this.asyncStub.setPlayerCapacity(com.agones.dev.sdk.alpha.Count.newBuilder().setCount(capacity).build())
).thenAccept((reply) -> {});
}

@Override
public CompletableFuture<Long> getPlayerCapacity() {
return wrapGrpcFuture(this.asyncStub.getPlayerCapacity(EMPTY_PAYLOAD)).thenApply(Count::getCount);
return wrapGrpcFuture(this.asyncStub.getPlayerCapacity(EMPTY_PAYLOAD)).thenApply(com.agones.dev.sdk.alpha.Count::getCount);
}

@Override
public CompletableFuture<Long> getPlayerCount() {
return wrapGrpcFuture(this.asyncStub.getPlayerCount(EMPTY_PAYLOAD)).thenApply(Count::getCount);
return wrapGrpcFuture(this.asyncStub.getPlayerCount(EMPTY_PAYLOAD)).thenApply(com.agones.dev.sdk.alpha.Count::getCount);
}

@Override
public CompletableFuture<Boolean> isPlayerConnected(String id) {
return wrapGrpcFuture(this.asyncStub.isPlayerConnected(this.createPlayerId(id))).thenApply(Bool::getBool);
return wrapGrpcFuture(this.asyncStub.isPlayerConnected(this.createPlayerId(id))).thenApply(com.agones.dev.sdk.alpha.Bool::getBool);
}

@Override
public CompletableFuture<List<String>> getConnectedPlayers() {
return wrapGrpcFuture(this.asyncStub.getConnectedPlayers(EMPTY_PAYLOAD)).thenApply(PlayerIDList::getListList);
return wrapGrpcFuture(this.asyncStub.getConnectedPlayers(EMPTY_PAYLOAD)).thenApply(com.agones.dev.sdk.alpha.PlayerIDList::getListList);
}

private PlayerID createPlayerId(String id) {
return PlayerID.newBuilder().setPlayerID(id).build();
private com.agones.dev.sdk.alpha.PlayerID createPlayerId(String id) {
return com.agones.dev.sdk.alpha.PlayerID.newBuilder().setPlayerID(id).build();
}
}
}
Loading

0 comments on commit e700916

Please sign in to comment.