Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-04-23 12:08:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Use simple-grpc for PaymentsGrpcService

Browse Source
This commit is contained in:
Jon Chambers
2026-02-24 13:12:01 -05:00
committed by Jon Chambers
parent b43e63c6f0
commit eedc4e23fe
1 changed files with 5 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
service/src/main/java/org/whispersystems/textsecuregcm/grpc/PaymentsGrpcService.java
View File

@@ -7,7 +7,6 @@ package org.whispersystems.textsecuregcm.grpc;
import static java.util.Objects.requireNonNull; import static java.util.Objects.requireNonNull;
import io.grpc.Status;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@@ -16,13 +15,12 @@ import javax.annotation.Nonnull;
import org.apache.commons.lang3.tuple.Pair; import org.apache.commons.lang3.tuple.Pair;
import org.signal.chat.payments.GetCurrencyConversionsRequest; import org.signal.chat.payments.GetCurrencyConversionsRequest;
import org.signal.chat.payments.GetCurrencyConversionsResponse; import org.signal.chat.payments.GetCurrencyConversionsResponse;
import org.signal.chat.payments.ReactorPaymentsGrpc; import org.signal.chat.payments.SimplePaymentsGrpc;
import org.whispersystems.textsecuregcm.auth.grpc.AuthenticationUtil; import org.whispersystems.textsecuregcm.auth.grpc.AuthenticationUtil;
import org.whispersystems.textsecuregcm.currency.CurrencyConversionManager; import org.whispersystems.textsecuregcm.currency.CurrencyConversionManager;
import org.whispersystems.textsecuregcm.entities.CurrencyConversionEntityList; import org.whispersystems.textsecuregcm.entities.CurrencyConversionEntityList;
import reactor.core.publisher.Mono;
public class PaymentsGrpcService extends ReactorPaymentsGrpc.PaymentsImplBase { public class PaymentsGrpcService extends SimplePaymentsGrpc.PaymentsImplBase {
private final CurrencyConversionManager currencyManager; private final CurrencyConversionManager currencyManager;
@@ -32,7 +30,7 @@ public class PaymentsGrpcService extends ReactorPaymentsGrpc.PaymentsImplBase {
} }
@Override @Override
public Mono<GetCurrencyConversionsResponse> getCurrencyConversions(final GetCurrencyConversionsRequest request) { public GetCurrencyConversionsResponse getCurrencyConversions(final GetCurrencyConversionsRequest request) {
AuthenticationUtil.requireAuthenticatedDevice(); AuthenticationUtil.requireAuthenticatedDevice();
final CurrencyConversionEntityList currencyConversionEntityList = currencyManager final CurrencyConversionEntityList currencyConversionEntityList = currencyManager
@@ -48,9 +46,9 @@ public class PaymentsGrpcService extends ReactorPaymentsGrpc.PaymentsImplBase {
.build()) .build())
.toList(); .toList();
return Mono.just(GetCurrencyConversionsResponse.newBuilder() return GetCurrencyConversionsResponse.newBuilder()
.addAllCurrencies(currencyConversionEntities).setTimestamp(currencyConversionEntityList.getTimestamp()) .addAllCurrencies(currencyConversionEntities).setTimestamp(currencyConversionEntityList.getTimestamp())
.build()); .build();
} }
@Nonnull @Nonnull