Meta Business SDK Features for Conversions API

 import com.facebook.ads.sdk.APIContext;
import com.facebook.ads.sdk.serverside.*;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;

class CONVERSIONS_API_EVENT_CREATE_BATCH {
  public static final String ACCESS_TOKEN = System.getenv("ACCESS_TOKEN");
  public static final String PIXEL_ID = System.getenv("PIXEL_ID");

  public static void run() throws Exception {
    if (ACCESS_TOKEN == null || PIXEL_ID == null) {
      throw new Exception(String.format("Missing required test config. Got pixel_id: '%s', access_token: '%s'", PIXEL_ID, ACCESS_TOKEN));
    }

    APIContext context = new APIContext(ACCESS_TOKEN);
    context.setLogger(System.out);

    BatchProcessor batchProcessor = new BatchProcessor(2, 3);

    List<EventRequest> eventRequests1 = getEventRequests(context, 4);
    batchProcessor.processEventRequests(eventRequests1);
    System.out.println("processEventRequests - OK.\n");

    List<EventRequest> eventRequests2 = getEventRequests(context, 2);
    Iterator<List<ListenableFuture<EventResponse>>> eventRequestsIterator = batchProcessor.processEventRequestsIterator(eventRequests2);
    while (eventRequestsIterator.hasNext()) {
      List<ListenableFuture<EventResponse>> futures = eventRequestsIterator.next();
      List<EventResponse> eventResponses = Futures
          .allAsList(futures)
          .get();
      System.out.println(eventResponses);
    }
    System.out.println("processEventRequestsIterator - OK.\n");

    EventRequest eventRequest1 = new EventRequest(PIXEL_ID, context);
    List<Event> events1 = getEvents(5);
    batchProcessor.processEvents(eventRequest1, events1);
    System.out.println("processEvents - OK.\n");

    EventRequest eventRequest2 = new EventRequest(PIXEL_ID, context);
    List<Event> events2 = getEvents(5);
    Iterator<List<ListenableFuture<EventResponse>>> eventsIterator = batchProcessor.processEventsIterator(eventRequest2, events2);
    while (eventsIterator.hasNext()) {
      List<ListenableFuture<EventResponse>> futures = eventsIterator.next();
      List<EventResponse> eventResponses = Futures
          .allAsList(futures)
          .get();
      System.out.println(eventResponses);
    }
    System.out.println("processEventsIterator - OK.\n");
  }

  private static List<EventRequest> getEventRequests(APIContext context, int num) {
    List<EventRequest> requests = new ArrayList<>();

    for (int i = 0; i < num; i++) {
      Event pageViewEvent = getEvent(i);

      EventRequest request = new EventRequest(PIXEL_ID, context);
      request.addDataItem(pageViewEvent);
      requests.add(request);
    }
    return requests;
  }

  private static Event getEvent(int num) {
    UserData userData = new UserData()
        .email(String.format("joe%s@eg.com", num))
        .clientIpAddress(clientIpAddress)
        .clientUserAgent(clientUserAgent);

    HashMap<String, String> customProperties = new HashMap<>();
    customProperties.put("item_number", "456");

    CustomData customData = new CustomData()
        .currency("usd")
        .customProperties(customProperties)
        .value(123.45F);

    Event pageViewEvent = new Event();
    pageViewEvent.eventName("Purchase")
        .eventTime(System.currentTimeMillis() / 1000L)
        .userData(userData)
        .customData(customData)
        .eventSourceUrl("http://jaspers-market.com/product/123")
        .actionSource(ActionSource.website);

    return pageViewEvent;
  }

  private static List<Event> getEvents(int num) {
    List<Event> events = new ArrayList<>();
    for (int i = 0; i < num; i++) {
      events.add(getEvent(i));
    }

    return events;
  }

  public static void main(String[] args) {
    try {
      run();
    } catch (Exception e) {
      e.printStackTrace();
      System.out.println(e.toString());
      System.exit(1);
    }
    System.exit(0);
  }
}