package functions;

import com.google.cloud.functions.CloudEventsFunction;
import com.google.events.cloud.audit.v1.LogEntryData;
import com.google.protobuf.InvalidProtocolBufferException;
import com.google.protobuf.util.JsonFormat;
import io.cloudevents.CloudEvent;
import java.nio.charset.StandardCharsets;
import java.util.logging.Logger;

public class HelloProto implements CloudEventsFunction {
  private static final Logger LOGGER = Logger.getLogger(HelloProto.class.getName());

  @Override
  public void accept(CloudEvent event) throws InvalidProtocolBufferException {
    if (event.getData() != null) {
      // Extract JSON from CloudEvent
      String json = new String(event.getData().toBytes(), StandardCharsets.UTF_8);
      // Convert data to LogEntryData object
      LogEntryData.Builder builder = LogEntryData.newBuilder();
      JsonFormat.parser().merge(json, builder);
      LogEntryData data = builder.build();
      
      // Extract specific data from LogEntryData object
      LOGGER.info("### CloudEvent Data ###");
      LOGGER.info(data.getLogName());
      LOGGER.info(data.getProtoPayload().getAuthenticationInfo().getPrincipalEmail());
    }
  }
}