Merge pull request #10 from Daniel-Ric/feature/2026-01-28/analyze-and-fix-empty-top-creators-response

receipt-payload

Author: Daniel-Ric

src/services/minecraft.service.js

@@ -97,34 +97,68 @@ export function extractReceiptEntitlements(rawReceipt) {
     if (typeof rawReceipt === "string") {
         const trimmed = rawReceipt.trim();
         if (!trimmed) return null;
-        if (trimmed.startsWith("{") || trimmed.startsWith("[")) {
+        const normalized = trimmed.replace(/^(bearer|jwt)\s+/i, "");
+        if (!normalized) return null;
+        if (normalized.startsWith("{") || normalized.startsWith("[")) {
             try {
-                const parsed = JSON.parse(trimmed);
+                const parsed = JSON.parse(normalized);
                 return parsed?.Receipt?.Entitlements || parsed?.receipt?.entitlements || parsed?.entitlements || null;
             } catch {
                 return null;
             }
         }
-        let decoded = null;
-        try {
-            decoded = jwtLib.decode(trimmed);
-        } catch {
-            decoded = null;
-        }
-        const decodedEnts = decoded?.Receipt?.Entitlements || decoded?.receipt?.entitlements || decoded?.entitlements || null;
+        const decoded = jwtLib.decode(normalized, {complete: true, json: true});
+        const payload = decoded?.payload || decoded;
+        const decodedEnts = payload?.Receipt?.Entitlements || payload?.Receipt?.entitlements || payload?.receipt?.entitlements || payload?.Entitlements || payload?.entitlements || null;
         if (Array.isArray(decodedEnts)) return decodedEnts;
-        if (!trimmed.includes(".")) {
+        const receiptValue = payload?.Receipt ?? payload?.receipt ?? null;
+        if (typeof receiptValue === "string") {
             try {
-                const parsed = JSON.parse(Buffer.from(trimmed, "base64").toString("utf8"));
-                return parsed?.Receipt?.Entitlements || parsed?.receipt?.entitlements || parsed?.entitlements || null;
+                const parsed = JSON.parse(receiptValue);
+                return parsed?.Receipt?.Entitlements || parsed?.Receipt?.entitlements || parsed?.receipt?.entitlements || parsed?.Entitlements || parsed?.entitlements || null;
+            } catch {
+                return null;
+            }
+        }
+        if (typeof payload === "string") {
+            try {
+                const parsed = JSON.parse(payload);
+                return parsed?.Receipt?.Entitlements || parsed?.Receipt?.entitlements || parsed?.receipt?.entitlements || parsed?.Entitlements || parsed?.entitlements || null;
+            } catch {
+                return null;
+            }
+        }
+        const parts = normalized.split(".");
+        if (parts.length >= 2) {
+            const payloadPart = parts[1];
+            const base64Payload = payloadPart.replace(/-/g, "+").replace(/_/g, "/");
+            const padLength = base64Payload.length % 4;
+            const padded = padLength ? base64Payload.padEnd(base64Payload.length + (4 - padLength), "=") : base64Payload;
+            try {
+                const parsed = JSON.parse(Buffer.from(padded, "base64").toString("utf8"));
+                return parsed?.Receipt?.Entitlements || parsed?.Receipt?.entitlements || parsed?.receipt?.entitlements || parsed?.Entitlements || parsed?.entitlements || null;
+            } catch {
+                return null;
+            }
+        }
+        if (!normalized.includes(".")) {
+            try {
+                const parsed = JSON.parse(Buffer.from(normalized, "base64").toString("utf8"));
+                return parsed?.Receipt?.Entitlements || parsed?.Receipt?.entitlements || parsed?.receipt?.entitlements || parsed?.Entitlements || parsed?.entitlements || null;
             } catch {
                 return null;
             }
         }
         return null;
     }
     if (typeof rawReceipt === "object") {
-        return rawReceipt?.Receipt?.Entitlements || rawReceipt?.receipt?.entitlements || rawReceipt?.entitlements || null;
+        const direct = rawReceipt?.Receipt?.Entitlements || rawReceipt?.Receipt?.entitlements || rawReceipt?.receipt?.entitlements || rawReceipt?.Entitlements || rawReceipt?.entitlements || null;
+        if (Array.isArray(direct)) return direct;
+        const nested = rawReceipt?.Receipt ?? rawReceipt?.receipt ?? null;
+        if (nested && nested !== rawReceipt) {
+            return extractReceiptEntitlements(nested);
+        }
+        return null;
     }
     return null;
 }

tests/messaging.test.js

@@ -81,6 +81,20 @@ test("extractReceiptEntitlements reads jwt receipt entitlements", () => {
     assert.deepEqual(ents, receiptPayload.Receipt.Entitlements);
 });
 
+test("extractReceiptEntitlements reads jwt with prefix", () => {
+    const receiptPayload = {Receipt: {Entitlements: [{CreatorId: "creator-1b"}]}};
+    const token = jwtLib.sign(receiptPayload, "secret");
+    const ents = extractReceiptEntitlements(`Bearer ${token}`);
+    assert.deepEqual(ents, receiptPayload.Receipt.Entitlements);
+});
+
+test("extractReceiptEntitlements reads jwt with string receipt payload", () => {
+    const receiptPayload = {Entitlements: [{CreatorId: "creator-1c"}]};
+    const token = jwtLib.sign({Receipt: JSON.stringify(receiptPayload)}, "secret");
+    const ents = extractReceiptEntitlements(token);
+    assert.deepEqual(ents, receiptPayload.Entitlements);
+});
+
 test("extractReceiptEntitlements reads json receipt entitlements", () => {
     const receiptPayload = {Receipt: {Entitlements: [{CreatorId: "creator-2"}]}};
     const ents = extractReceiptEntitlements(JSON.stringify(receiptPayload));
@@ -89,7 +103,7 @@ test("extractReceiptEntitlements reads json receipt entitlements", () => {
 
 test("extractReceiptEntitlements reads base64 receipt entitlements", () => {
     const receiptPayload = {Receipt: {Entitlements: [{CreatorId: "creator-3"}]}};
-    const encoded = Buffer.from(JSON.stringify(receiptPayload), "utf8").toString("base64");
+    const encoded = Buffer.from(JSON.stringify(receiptPayload), "utf8").toString("base64").replace(/=+$/, "");
     const ents = extractReceiptEntitlements(encoded);
     assert.deepEqual(ents, receiptPayload.Receipt.Entitlements);
 });
@@ -99,3 +113,10 @@ test("extractReceiptEntitlements reads object receipt entitlements", () => {
     const ents = extractReceiptEntitlements(receiptPayload);
     assert.deepEqual(ents, receiptPayload.Receipt.Entitlements);
 });
+
+test("extractReceiptEntitlements reads nested receipt strings", () => {
+    const receiptPayload = {Receipt: {Entitlements: [{CreatorId: "creator-5"}]}};
+    const token = jwtLib.sign(receiptPayload, "secret");
+    const ents = extractReceiptEntitlements({receipt: token});
+    assert.deepEqual(ents, receiptPayload.Receipt.Entitlements);
+});