[webhook] Add webhook processing

Author: swashata

src/app/webhook/route.ts

@@ -0,0 +1,35 @@
+import { freemius } from '@/lib/freemius';
+import { deleteEntitlement, renewCreditsFromWebhook, syncEntitlementFromWebhook } from '@/lib/user-entitlement';
+
+const listener = freemius.webhook.createListener();
+
+listener.on(
+    [
+        'license.created',
+        'license.extended',
+        'license.shortened',
+        'license.updated',
+        'license.cancelled',
+        'license.expired',
+        'license.plan.changed',
+    ],
+    async ({ objects: { license } }) => {
+        if (license && license.id) {
+            await syncEntitlementFromWebhook(license.id);
+        }
+    }
+);
+
+listener.on('license.deleted', async ({ data }) => {
+    await deleteEntitlement(data.license_id);
+});
+
+listener.on('license.extended', async ({ data }) => {
+    if (data.is_renewal) {
+        renewCreditsFromWebhook(data.license_id);
+    }
+});
+
+const processor = freemius.webhook.createRequestProcessor(listener);
+
+export { processor as POST };

src/lib/user-entitlement.ts

@@ -72,6 +72,35 @@ export const getFsUser: UserRetriever = async () => {
     return freemius.entitlement.getFsUser(entitlement, email);
 };
 
+export async function syncEntitlementFromWebhook(fsLicenseId: string): Promise<void> {
+    const purchaseInfo = await freemius.purchase.retrievePurchase(fsLicenseId);
+    if (purchaseInfo) {
+        await processPurchaseInfo(purchaseInfo);
+    }
+}
+
+export async function deleteEntitlement(fsLicenseId: string): Promise<void> {
+    await prisma.userFsEntitlement.delete({
+        where: { fsLicenseId: fsLicenseId },
+    });
+}
+
+export async function renewCreditsFromWebhook(fsLicenseId: string): Promise<void> {
+    const purchaseInfo = await freemius.purchase.retrievePurchase(fsLicenseId);
+
+    if (purchaseInfo) {
+        const credits = getCreditsForPurchase(purchaseInfo);
+
+        const entitlement = await prisma.userFsEntitlement.findUnique({
+            where: { fsLicenseId },
+        });
+
+        if (entitlement && credits > 0) {
+            await addCredits(entitlement.userId, credits);
+        }
+    }
+}
+
 //#endregion
 
 // #region Credit & Entitlement Management