#16660

Committed 21 Nov 2024 09:08PM CUT coverage: 12.4%. Remained the same

Build # #16660

Build Type

push

github

Committed by

ramya-stripe

Commit Message

Bump version to 28.2.0-beta.1

Run Details

18860 of 152092 relevant lines covered (12.4%)

0.12 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/com/stripe/examples/ThinEventWebhookHandler.java

package com.stripe.examples;

import com.stripe.StripeClient;
import com.stripe.events.V1BillingMeterErrorReportTriggeredEvent;
import com.stripe.exception.StripeException;
import com.stripe.model.ThinEvent;
import com.stripe.model.billing.Meter;
import com.stripe.model.v2.Event;
import com.sun.net.httpserver.HttpExchange;
import com.sun.net.httpserver.HttpHandler;
import com.sun.net.httpserver.HttpServer;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetSocketAddress;
import java.nio.charset.StandardCharsets;

/**
 * Receive and process thin events like the v1.billing.meter.error_report_triggered event.
 *
 * <p>In this example, we:
 *
 * <ul>
 *   <li>use parseThinEvent to parse the received thin event webhook body
 *   <li>call StripeClient.v2.core.events.retrieve to retrieve the flil event object
 *   <li>if it is a V1BillingMeterErrorReportTriggeredEvent event type, call fetchRelatedObject to
 *       retrieve the Billing Meter object associated with the event.
 * </ul>
 */
public class ThinEventWebhookHandler {
  private static final String API_KEY = System.getenv("STRIPE_API_KEY");
  private static final String WEBHOOK_SECRET = System.getenv("WEBHOOK_SECRET");

  private static final StripeClient client = new StripeClient(API_KEY);

  public static void main(String[] args) throws IOException {

    HttpServer server = HttpServer.create(new InetSocketAddress(4242), 0);
    server.createContext("/webhook", new WebhookHandler());
    server.setExecutor(null);
    server.start();
  }

  static class WebhookHandler implements HttpHandler {

    // For Java 1.8 compatibility
    public static byte[] readAllBytes(InputStream inputStream) throws IOException {
      final int bufLen = 1024;
      byte[] buf = new byte[bufLen];
      int readLen;

      ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

      while ((readLen = inputStream.read(buf, 0, bufLen)) != -1)
        outputStream.write(buf, 0, readLen);

      return outputStream.toByteArray();
    }

    @Override
    public void handle(HttpExchange exchange) throws IOException {
      if ("POST".equals(exchange.getRequestMethod())) {
        InputStream requestBody = exchange.getRequestBody();
        String webhookBody = new String(readAllBytes(requestBody), StandardCharsets.UTF_8);
        String sigHeader = exchange.getRequestHeaders().getFirst("Stripe-Signature");

        try {
          ThinEvent thinEvent = client.parseThinEvent(webhookBody, sigHeader, WEBHOOK_SECRET);

          // Fetch the event data to understand the failure
          Event baseEvent = client.v2().core().events().retrieve(thinEvent.getId());
          if (baseEvent instanceof V1BillingMeterErrorReportTriggeredEvent) {
            V1BillingMeterErrorReportTriggeredEvent event =
                (V1BillingMeterErrorReportTriggeredEvent) baseEvent;
            Meter meter = event.fetchRelatedObject();

            String meterId = meter.getId();
            System.out.println(meterId);

            // Record the failures and alert your team
            // Add your logic here
          }

          exchange.sendResponseHeaders(200, -1);
        } catch (StripeException e) {
          exchange.sendResponseHeaders(400, -1);
        }
      } else {
        exchange.sendResponseHeaders(405, -1);
      }
      exchange.close();
    }
  }
}

1	package com.stripe.examples;
2
3	import com.stripe.StripeClient;
4	import com.stripe.events.V1BillingMeterErrorReportTriggeredEvent;
5	import com.stripe.exception.StripeException;
6	import com.stripe.model.ThinEvent;
7	import com.stripe.model.billing.Meter;
8	import com.stripe.model.v2.Event;
9	import com.sun.net.httpserver.HttpExchange;
10	import com.sun.net.httpserver.HttpHandler;
11	import com.sun.net.httpserver.HttpServer;
12	import java.io.ByteArrayOutputStream;
13	import java.io.IOException;
14	import java.io.InputStream;
15	import java.net.InetSocketAddress;
16	import java.nio.charset.StandardCharsets;
17
18	/**
19	* Receive and process thin events like the v1.billing.meter.error_report_triggered event.
20	*
21	* <p>In this example, we:
22	*
23	* <ul>
24	* <li>use parseThinEvent to parse the received thin event webhook body
25	* <li>call StripeClient.v2.core.events.retrieve to retrieve the flil event object
26	* <li>if it is a V1BillingMeterErrorReportTriggeredEvent event type, call fetchRelatedObject to
27	* retrieve the Billing Meter object associated with the event.
28	* </ul>
29	*/
30	public class ThinEventWebhookHandler {	×
31	private static final String API_KEY = System.getenv("STRIPE_API_KEY");	×
32	private static final String WEBHOOK_SECRET = System.getenv("WEBHOOK_SECRET");	×
33
34	private static final StripeClient client = new StripeClient(API_KEY);	×
35
36	public static void main(String[] args) throws IOException {
37
38	HttpServer server = HttpServer.create(new InetSocketAddress(4242), 0);	×
39	server.createContext("/webhook", new WebhookHandler());	×
40	server.setExecutor(null);	×
41	server.start();	×
42	}	×
43
44	static class WebhookHandler implements HttpHandler {	×
45
46	// For Java 1.8 compatibility
47	public static byte[] readAllBytes(InputStream inputStream) throws IOException {
48	final int bufLen = 1024;	×
49	byte[] buf = new byte[bufLen];	×
50	int readLen;
51
52	ByteArrayOutputStream outputStream = new ByteArrayOutputStream();	×
53
54	while ((readLen = inputStream.read(buf, 0, bufLen)) != -1)	×
55	outputStream.write(buf, 0, readLen);	×
56
57	return outputStream.toByteArray();	×
58	}
59
60	@Override
61	public void handle(HttpExchange exchange) throws IOException {
62	if ("POST".equals(exchange.getRequestMethod())) {	×
63	InputStream requestBody = exchange.getRequestBody();	×
64	String webhookBody = new String(readAllBytes(requestBody), StandardCharsets.UTF_8);	×
65	String sigHeader = exchange.getRequestHeaders().getFirst("Stripe-Signature");	×
66
67	try {
68	ThinEvent thinEvent = client.parseThinEvent(webhookBody, sigHeader, WEBHOOK_SECRET);	×
69
70	// Fetch the event data to understand the failure
71	Event baseEvent = client.v2().core().events().retrieve(thinEvent.getId());	×
72	if (baseEvent instanceof V1BillingMeterErrorReportTriggeredEvent) {	×
73	V1BillingMeterErrorReportTriggeredEvent event =	×
74	(V1BillingMeterErrorReportTriggeredEvent) baseEvent;
75	Meter meter = event.fetchRelatedObject();	×
76
77	String meterId = meter.getId();	×
78	System.out.println(meterId);	×
79
80	// Record the failures and alert your team
81	// Add your logic here
82	}
83
84	exchange.sendResponseHeaders(200, -1);	×
85	} catch (StripeException e) {	×
86	exchange.sendResponseHeaders(400, -1);	×
87	}	×
88	} else {	×
89	exchange.sendResponseHeaders(405, -1);	×
90	}
91	exchange.close();	×
92	}	×
93	}
94	}

stripe / stripe-java / #16660

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous