package com.infoloop.tianting.service.client;

import com.infoloop.tianting.GeDishSkuByIdsRpcResponse;
import com.infoloop.tianting.GetSkusByIdsRpcRequest;
import com.infoloop.tianting.SingleSkuResponse;
import com.infoloop.tianting.SkuServiceProtoRpcGrpc;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
public class SkuServiceRpcClient {
    private final SkuServiceProtoRpcGrpc.SkuServiceProtoRpcBlockingStub skuServiceProtoRpcBlockingStub;

    public GeDishSkuByIdsRpcResponse getDishSkusByIds(List<Integer> ids) {
        final var request = GetSkusByIdsRpcRequest.newBuilder()
                .addAllIds(ids)
                .setIncludeDeleted(false)
                .build();
        return skuServiceProtoRpcBlockingStub.getDishSkusByIds(request);
    }

    public List<SingleSkuResponse> getSkusByIds(List<Integer> ids) {
        final var request = GetSkusByIdsRpcRequest.newBuilder()
                .addAllIds(ids)
                .setIncludeDeleted(false)
                .build();
        return skuServiceProtoRpcBlockingStub.getSkusByIds(request).getResponseList();
    }
}