Merchant API code sample to insert local inventory asynchronously.
Java
// Copyright 2025 Google LLC
//
// 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
//
// https://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.
package shopping.merchant.samples.inventories.v1;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutureCallback;
import com.google.api.core.ApiFutures;
import com.google.api.gax.core.FixedCredentialsProvider;
import com.google.auth.oauth2.GoogleCredentials;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.shopping.merchant.inventories.v1.InsertLocalInventoryRequest;
import com.google.shopping.merchant.inventories.v1.LocalInventory;
import com.google.shopping.merchant.inventories.v1.LocalInventoryAttributes;
import com.google.shopping.merchant.inventories.v1.LocalInventoryAttributes.Availability;
import com.google.shopping.merchant.inventories.v1.LocalInventoryServiceClient;
import com.google.shopping.merchant.inventories.v1.LocalInventoryServiceSettings;
import com.google.shopping.merchant.products.v1.ListProductsRequest;
import com.google.shopping.merchant.products.v1.Product;
import com.google.shopping.merchant.products.v1.ProductsServiceClient;
import com.google.shopping.merchant.products.v1.ProductsServiceClient.ListProductsPagedResponse;
import com.google.shopping.merchant.products.v1.ProductsServiceSettings;
import com.google.shopping.type.Price;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import shopping.merchant.samples.utils.Authenticator;
import shopping.merchant.samples.utils.Config;
/**
* This class demonstrates how to insert Local inventory asynchronously for multiple products. Note,
* this code sample will only work if you already have datasource and products available for local
* products. You can create a datasource for local and products by looking at the DataSources and
* Products samples.
*/
public class InsertLocalInventoryAsyncSample {
/* Gets the names of all the local products for a given merchant center account. */
public static List<String> getLocalProductNames(GoogleCredentials credential, String accountId)
throws IOException {
ProductsServiceSettings productsServiceSettings =
ProductsServiceSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(credential))
.build();
try (ProductsServiceClient productsServiceClient =
ProductsServiceClient.create(productsServiceSettings)) {
ListProductsRequest request =
ListProductsRequest.newBuilder()
// Creates parent to identify the account from which to list all products.
.setParent(String.format("accounts/%s", accountId))
.build();
System.out.println("Sending list products request:");
ListProductsPagedResponse response = productsServiceClient.listProducts(request);
// Iterates over all rows in all pages and prints the datasource in each row.
// Automatically uses the `nextPageToken` if returned to fetch all pages of data
List<String> localProductNames = new ArrayList<String>();
for (Product product : response.iterateAll()) {
// Filters for only local products using the legacyLocal field.
if (product.getLegacyLocal()) {
// The name is returned in the format:
// accounts/{account}/products/{channel}~{contentLanguage}~{feedLabel}~{offerId}
// These will be used to insert local inventory for each product.
localProductNames.add(product.getName());
}
}
return localProductNames;
}
}
public static void insertLocalInventoryAsync(
GoogleCredentials credential, String accountId, String storeCode) throws Exception {
LocalInventoryServiceSettings localInventoryServiceSettings =
LocalInventoryServiceSettings.newBuilder()
.setCredentialsProvider(FixedCredentialsProvider.create(credential))
.build();
try (LocalInventoryServiceClient localInventoryServiceClient =
LocalInventoryServiceClient.create(localInventoryServiceSettings)) {
// In this example, we are simply using the same price for all products.
Price price = Price.newBuilder().setAmountMicros(33_450_000).setCurrencyCode("USD").build();
// Checks that the account has local products.
List<String> localProductNames = getLocalProductNames(credential, accountId);
if (localProductNames.isEmpty()) {
throw new Exception("No local products found for this account.");
}
// Creates requests to update the inventory for each product, set a fixed price and set the
// availability to "out of stock".
List<InsertLocalInventoryRequest> requests =
localProductNames.stream()
.map(
name -> {
return InsertLocalInventoryRequest.newBuilder()
.setParent(name)
.setLocalInventory(
LocalInventory.newBuilder()
.setLocalInventoryAttributes(
LocalInventoryAttributes.newBuilder()
.setAvailability(Availability.OUT_OF_STOCK)
.setPrice(price)
.build())
.setStoreCode(storeCode)
.build())
.build();
})
.collect(Collectors.toList());
// Inserts the local inventory for each product.
System.out.println("Sending InsertLocalInventory requests");
List<ApiFuture<LocalInventory>> futures =
requests.stream()
.map(
request ->
localInventoryServiceClient
.insertLocalInventoryCallable()
.futureCall(request))
.collect(Collectors.toList());
// Callback to handle the responses from the API once they are all returned.
ApiFuture<List<LocalInventory>> responses = ApiFutures.allAsList(futures);
ApiFutures.addCallback(
responses,
new ApiFutureCallback<List<LocalInventory>>() {
@Override
public void onSuccess(List<LocalInventory> results) {
System.out.println("Inserted LocalInventory below");
System.out.println(results);
}
@Override
public void onFailure(Throwable throwable) {
System.err.println(
"An error occurred while inserting local inventory: " + throwable.getMessage());
}
},
MoreExecutors.directExecutor());
} catch (Exception e) {
System.err.println(e.getMessage());
}
}
public static void main(String[] args) throws Exception {
GoogleCredentials credential = new Authenticator().authenticate();
String accountId = Config.load().getAccountId().toString();
// The code uniquely identifying each store.
// This can be found in the Google Business Profile UI, by going to Business Profile Settings ->
// Advanced Settings. The store must have passed verification for this code sample to work.
String storeCode = "yourstorecode";
insertLocalInventoryAsync(credential, accountId, storeCode);
}
}