Merge remote-tracking branch 'upstream/main' into LuizDMM/issue9011

onyedikachi-david · onyedikachi-david · commit c2bdf9e257c6 · 2025-09-04T09:52:16.000Z
diff --git a/packages/pieces/community/stripe/package.json b/packages/pieces/community/stripe/package.json
@@ -1,4 +1,4 @@
 {
   "name": "@activepieces/piece-stripe",
-  "version": "0.5.13"
+  "version": "0.5.14"
 }
diff --git a/packages/pieces/community/stripe/src/lib/trigger/new-subscription.ts b/packages/pieces/community/stripe/src/lib/trigger/new-subscription.ts
@@ -2,6 +2,8 @@ import { createTrigger } from '@activepieces/pieces-framework';
 import { TriggerStrategy } from '@activepieces/pieces-framework';
 import { stripeCommon } from '../common';
 import { stripeAuth } from '../..';
+import { httpClient, HttpMethod } from '@activepieces/pieces-common';
+import { isEmpty } from '@activepieces/shared';
 
 export const stripeNewSubscription = createTrigger({
   auth: stripeAuth,
@@ -167,6 +169,23 @@ export const stripeNewSubscription = createTrigger({
       await stripeCommon.unsubscribeWebhook(response.webhookId, context.auth);
     }
   },
+  async test(context) {
+    const response = await httpClient.sendRequest<{ data: { id: string }[] }>({
+      method: HttpMethod.GET,
+      url: 'https://api.stripe.com/v1/subscriptions',
+      headers: {
+        Authorization: 'Bearer ' + context.auth,
+        'Content-Type': 'application/x-www-form-urlencoded',
+      },
+      queryParams: {
+        limit: '5',
+      },
+    });
+
+    if (isEmpty(response.body) || isEmpty(response.body.data)) return [];
+
+    return response.body.data;
+  },
   async run(context) {
     const payloadBody = context.payload.body as PayloadBody;
     return [payloadBody.data.object];

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@activepieces/piece-stripe",`
`3`		`- "version": "0.5.13"`
	`3`	`+ "version": "0.5.14"`
`4`	`4`	`}`