refactor: call OBP-API on v5.1.0 or newer across the app stack

apps/api-manager/dynamic_endpoint_plan_doc.md

@@ -40,32 +40,32 @@ A Dynamic Endpoint is a Swagger/OpenAPI doc that OBP ingests. Each operation in
 ## Relevant OBP endpoints (reference)
 
 ### Dynamic Endpoint (existing UI)
-- `POST /obp/v4.0.0/management/dynamic-endpoints` — role `CanCreateDynamicEndpoint`
-- `GET /obp/v4.0.0/management/dynamic-endpoints` — role `CanGetDynamicEndpoints`
-- `GET /obp/v4.0.0/management/dynamic-endpoints/{id}`
-- `DELETE /obp/v4.0.0/management/dynamic-endpoints/{id}` — role `CanDeleteDynamicEndpoint`
-- `PUT /obp/v4.0.0/management/dynamic-endpoints/{id}/host` — role `CanUpdateDynamicEndpoint`
+- `POST /obp/v5.1.0/management/dynamic-endpoints` — role `CanCreateDynamicEndpoint`
+- `GET /obp/v5.1.0/management/dynamic-endpoints` — role `CanGetDynamicEndpoints`
+- `GET /obp/v5.1.0/management/dynamic-endpoints/{id}`
+- `DELETE /obp/v5.1.0/management/dynamic-endpoints/{id}` — role `CanDeleteDynamicEndpoint`
+- `PUT /obp/v5.1.0/management/dynamic-endpoints/{id}/host` — role `CanUpdateDynamicEndpoint`
 - Bank-level equivalents under `/management/banks/{bank_id}/dynamic-endpoints/...`
 
 ### Method Routing
-- `POST /obp/v3.1.0/management/method_routings` — role `CanCreateMethodRouting`
-- `GET /obp/v3.1.0/management/method_routings`
-- `PUT /obp/v3.1.0/management/method_routings/{id}`
-- `DELETE /obp/v3.1.0/management/method_routings/{id}`
+- `POST /obp/v5.1.0/management/method_routings` — role `CanCreateMethodRouting`
+- `GET /obp/v5.1.0/management/method_routings`
+- `PUT /obp/v5.1.0/management/method_routings/{id}`
+- `DELETE /obp/v5.1.0/management/method_routings/{id}`
 - Helper: `GET /obp/v6.0.0/system/connector-method-names`
 - Fields: `method_name`, `connector_name`, `is_bank_id_exact_match`, `bank_id_pattern?`, `parameters[]`
 
 ### JSON Schema Validation (per operation_id)
-- `POST /obp/v4.0.0/management/json-schema-validations/{OPERATION_ID}` — role `CanCreateJsonSchemaValidation`
-- `GET /obp/v4.0.0/management/json-schema-validations/{OPERATION_ID}`
-- `PUT /obp/v4.0.0/management/json-schema-validations/{OPERATION_ID}`
-- `DELETE /obp/v4.0.0/management/json-schema-validations/{OPERATION_ID}`
-- `GET /obp/v4.0.0/management/json-schema-validations` — list all
-- `GET /obp/v4.0.0/endpoints/json-schema-validations` — public, no auth (useful for read-only preview)
+- `POST /obp/v5.1.0/management/json-schema-validations/{OPERATION_ID}` — role `CanCreateJsonSchemaValidation`
+- `GET /obp/v5.1.0/management/json-schema-validations/{OPERATION_ID}`
+- `PUT /obp/v5.1.0/management/json-schema-validations/{OPERATION_ID}`
+- `DELETE /obp/v5.1.0/management/json-schema-validations/{OPERATION_ID}`
+- `GET /obp/v5.1.0/management/json-schema-validations` — list all
+- `GET /obp/v5.1.0/endpoints/json-schema-validations` — public, no auth (useful for read-only preview)
 - Request body: a JSON Schema doc (draft-07 is the OBP example).
 
 ### Endpoint Mapping (for `host: dynamic_entity`)
-- `POST /obp/v4.0.0/management/endpoint-mappings` — role `CanCreateEndpointMapping`
+- `POST /obp/v5.1.0/management/endpoint-mappings` — role `CanCreateEndpointMapping`
 - plus GET/PUT/DELETE + bank-level equivalents
 
 ### Role names (to surface on the UI)

apps/api-manager/src/lib/components/DynamicEndpointOperationsTable.svelte

@@ -62,8 +62,8 @@
   // Endpoint-mapping CRUD base: bank-level when bankId is set, otherwise system.
   const mappingsBase = $derived(
     bankId
-      ? `/proxy/obp/v4.0.0/management/banks/${encodeURIComponent(bankId)}/endpoint-mappings`
-      : `/proxy/obp/v4.0.0/management/endpoint-mappings`,
+      ? `/proxy/obp/v5.1.0/management/banks/${encodeURIComponent(bankId)}/endpoint-mappings`
+      : `/proxy/obp/v5.1.0/management/endpoint-mappings`,
   );
 
   // Dynamic endpoints are served under /obp/dynamic-endpoint/ (no API version, no /banks/ segment
@@ -445,7 +445,7 @@
 
     try {
       const response = await fetch(
-        `/proxy/obp/v4.0.0/management/json-schema-validations/${encodeURIComponent(op.operationId)}`,
+        `/proxy/obp/v5.1.0/management/json-schema-validations/${encodeURIComponent(op.operationId)}`,
         {
           method,
           headers: { "Content-Type": "application/json" },
@@ -479,7 +479,7 @@
 
     try {
       const response = await fetch(
-        `/proxy/obp/v4.0.0/management/json-schema-validations/${encodeURIComponent(op.operationId)}`,
+        `/proxy/obp/v5.1.0/management/json-schema-validations/${encodeURIComponent(op.operationId)}`,
         { method: "DELETE", credentials: "include" },
       );
 

apps/api-manager/src/lib/components/DynamicResourceDocForm.svelte

@@ -548,7 +548,7 @@
     submitError = null;
     try {
       const response = await fetch(
-        "/proxy/obp/v4.0.0/management/dynamic-resource-docs/endpoint-code",
+        "/proxy/obp/v5.1.0/management/dynamic-resource-docs/endpoint-code",
         {
           method: "POST",
           headers: { "Content-Type": "application/json" },

apps/api-manager/src/lib/components/UserSearchPickerWidget.svelte

@@ -123,7 +123,7 @@
     try {
       let url: string;
       if (type === "email") {
-        url = `/proxy/obp/v4.0.0/users/email/${encodeURIComponent(trimmed)}/terminator`;
+        url = `/proxy/obp/v5.1.0/users/email/${encodeURIComponent(trimmed)}/terminator`;
       } else if (type === "userid") {
         url = `/proxy/obp/v6.0.0/users/user-id/${encodeURIComponent(trimmed)}`;
       } else {

apps/api-manager/src/lib/server/activeConnector.ts

@@ -32,7 +32,7 @@ const logger = createLogger("ActiveConnector");
 
 const CACHE_DURATION = 5 * 60 * 1000; // 5 minutes: the prop only changes on a restart, routings can change
 const CONFIG_PROPS_PATH = "/obp/v6.0.0/management/config-props";
-const METHOD_ROUTINGS_PATH = "/obp/v3.1.0/management/method_routings";
+const METHOD_ROUTINGS_PATH = "/obp/v5.1.0/management/method_routings";
 
 /** The connector star falls back to when no Method Routing matches a method. */
 export const STAR_FALLBACK_CONNECTOR = "mapped";

apps/api-manager/src/lib/server/glossaryCache.ts

@@ -21,14 +21,14 @@ import { env } from "$env/dynamic/private";
 
 const logger = createLogger("GlossaryCache");
 
-/** One item of GET /obp/v4.0.0/api/glossary. */
+/** One item of GET /obp/v5.1.0/api/glossary. */
 export interface GlossaryItem {
   title: string;
   description: { markdown: string; html: string };
 }
 
 const CACHE_DURATION = 30 * 60 * 1000; // 30 minutes: the glossary only changes on an OBP-API deploy
-const GLOSSARY_PATH = "/obp/v4.0.0/api/glossary";
+const GLOSSARY_PATH = "/obp/v5.1.0/api/glossary";
 const DEFAULT_EXPLORER_URL = "https://apiexplorer-ii-sandbox.openbankproject.com";
 
 let items: GlossaryItem[] = [];

apps/api-manager/src/lib/services/jsonSchemaValidations.ts

@@ -39,7 +39,7 @@ export interface OperationChoice {
   summary: string;
 }
 
-const BASE = "/proxy/obp/v4.0.0/management/json-schema-validations";
+const BASE = "/proxy/obp/v5.1.0/management/json-schema-validations";
 
 export const EXAMPLE_SCHEMA = `{
   "$schema": "http://json-schema.org/draft-07/schema",

apps/api-manager/src/routes/(protected)/account-access/accounts/[bank_id]/[account_id]/[view_id]/+page.svelte

@@ -437,7 +437,7 @@
 
     try {
       const res = await trackedFetch(
-        `/proxy/obp/v3.1.0/banks/${encodeURIComponent(bankId)}/accounts/${encodeURIComponent(accountId)}/products/${encodeURIComponent(productCode)}/attribute`,
+        `/proxy/obp/v5.1.0/banks/${encodeURIComponent(bankId)}/accounts/${encodeURIComponent(accountId)}/products/${encodeURIComponent(productCode)}/attribute`,
         {
           method: "POST",
           headers: { "Content-Type": "application/json" },

apps/api-manager/src/routes/(protected)/account-access/accounts/[bank_id]/[account_id]/[view_id]/counterparties/[counterparty_id]/+page.svelte

@@ -92,7 +92,7 @@
     error = null;
     try {
       const res = await trackedFetch(
-        `/proxy/obp/v4.0.0/banks/${encodeURIComponent(bankId)}/accounts/${encodeURIComponent(accountId)}/${encodeURIComponent(viewId)}/counterparties/${encodeURIComponent(counterpartyId)}`
+        `/proxy/obp/v5.1.0/banks/${encodeURIComponent(bankId)}/accounts/${encodeURIComponent(accountId)}/${encodeURIComponent(viewId)}/counterparties/${encodeURIComponent(counterpartyId)}`
       );
       if (!res.ok) {
         const data = await res.json().catch(() => ({}));

apps/api-manager/src/routes/(protected)/customers/[bank_id]/[customer_id]/+page.svelte

@@ -148,7 +148,7 @@
 
     try {
       const res = await trackedFetch(
-        `/proxy/obp/v4.0.0/banks/${encodeURIComponent(bankId)}/customers/${encodeURIComponent(customerId)}/attribute`,
+        `/proxy/obp/v5.1.0/banks/${encodeURIComponent(bankId)}/customers/${encodeURIComponent(customerId)}/attribute`,
         {
           method: "POST",
           headers: { "Content-Type": "application/json" },

apps/api-manager/src/routes/(protected)/customers/graph/+page.svelte

@@ -146,7 +146,7 @@
 
     try {
       const res = await trackedFetch(
-        `/proxy/obp/v4.0.0/banks/${encodeURIComponent(bankId)}/user_customer_links/customers/${encodeURIComponent(customerId)}`,
+        `/proxy/obp/v5.1.0/banks/${encodeURIComponent(bankId)}/user_customer_links/customers/${encodeURIComponent(customerId)}`,
       );
       if (!res.ok) {
         const errData = await res.json().catch(() => ({}));

apps/api-manager/src/routes/(protected)/dynamic-endpoints/bank/[bank_id]/[id]/+page.server.ts

@@ -60,7 +60,7 @@ export const load: PageServerLoad = async ({ params, locals }) => {
     let validations: Array<{ operation_id: string; json_schema: any }> = [];
     try {
       const resp = await obp_requests.get(
-        `/obp/v4.0.0/management/json-schema-validations`,
+        `/obp/v5.1.0/management/json-schema-validations`,
         accessToken,
       );
       validations = resp?.json_schema_validations || [];
@@ -78,7 +78,7 @@ export const load: PageServerLoad = async ({ params, locals }) => {
     }> = [];
     try {
       const resp = await obp_requests.get(
-        `/obp/v4.0.0/management/banks/${bank_id}/endpoint-mappings`,
+        `/obp/v5.1.0/management/banks/${bank_id}/endpoint-mappings`,
         accessToken,
       );
       mappings = resp?.["endpoint-mappings"] || [];

apps/api-manager/src/routes/(protected)/dynamic-endpoints/system/[id]/+page.server.ts

@@ -56,7 +56,7 @@ export const load: PageServerLoad = async ({ params, locals }) => {
     let validations: Array<{ operation_id: string; json_schema: any }> = [];
     try {
       const resp = await obp_requests.get(
-        `/obp/v4.0.0/management/json-schema-validations`,
+        `/obp/v5.1.0/management/json-schema-validations`,
         accessToken,
       );
       validations = resp?.json_schema_validations || [];
@@ -76,7 +76,7 @@ export const load: PageServerLoad = async ({ params, locals }) => {
     }> = [];
     try {
       const resp = await obp_requests.get(
-        `/obp/v4.0.0/management/endpoint-mappings`,
+        `/obp/v5.1.0/management/endpoint-mappings`,
         accessToken,
       );
       mappings = resp?.["endpoint-mappings"] || [];

apps/api-manager/src/routes/(protected)/dynamic-entity-webhooks/[bank_id]/[dynamic_entity_id]/[webhook_id]/+page.svelte

@@ -157,7 +157,7 @@
         <dt class="text-gray-500 dark:text-gray-400">Signing</dt>
         <dd class="text-xs text-gray-900 dark:text-gray-100">
           {#if w.signature_status === "signed"}
-            Signed: each request carries OBP-Signature, verifiable with the key at /obp/v3.1.0/certs.
+            Signed: each request carries OBP-Signature, verifiable with the key at /obp/v5.1.0/certs.
           {:else}
             Not signed on this instance (it has no stable server key). Requests carry OBP-Signature-Status: not_configured.
           {/if}

apps/api-manager/src/routes/(protected)/dynamic-resource-docs/system/+page.server.ts

@@ -39,7 +39,7 @@ export const load: PageServerLoad = async ({ locals }) => {
 
   try {
     const resp = await obp_requests.get(
-      `/obp/v4.0.0/management/dynamic-resource-docs`,
+      `/obp/v5.1.0/management/dynamic-resource-docs`,
       accessToken,
     );
     const docs = resp?.["dynamic-resource-docs"] || [];

apps/api-manager/src/routes/(protected)/dynamic-resource-docs/system/+page.svelte

@@ -69,7 +69,7 @@
     successMessage = null;
     try {
       const response = await fetch(
-        `/proxy/obp/v4.0.0/management/dynamic-resource-docs/${encodeURIComponent(id)}`,
+        `/proxy/obp/v5.1.0/management/dynamic-resource-docs/${encodeURIComponent(id)}`,
         { method: "DELETE", credentials: "include" },
       );
       if (!response.ok) {

apps/api-manager/src/routes/(protected)/dynamic-resource-docs/system/[id]/+page.server.ts

@@ -103,7 +103,7 @@ export const load: PageServerLoad = async ({ params, locals }) => {
 
   try {
     const doc = await obp_requests.get(
-      `/obp/v4.0.0/management/dynamic-resource-docs/${encodeURIComponent(id)}`,
+      `/obp/v5.1.0/management/dynamic-resource-docs/${encodeURIComponent(id)}`,
       accessToken,
     );
     if (!doc) {

apps/api-manager/src/routes/(protected)/dynamic-resource-docs/system/[id]/+page.svelte

@@ -67,7 +67,7 @@
     if (!docId) throw new Error("Missing doc id");
     successMessage = null;
     const response = await fetch(
-      `/proxy/obp/v4.0.0/management/dynamic-resource-docs/${encodeURIComponent(docId)}`,
+      `/proxy/obp/v5.1.0/management/dynamic-resource-docs/${encodeURIComponent(docId)}`,
       {
         method: "PUT",
         headers: { "Content-Type": "application/json" },
@@ -140,7 +140,7 @@
     isDeleting = true;
     try {
       const response = await fetch(
-        `/proxy/obp/v4.0.0/management/dynamic-resource-docs/${encodeURIComponent(docId)}`,
+        `/proxy/obp/v5.1.0/management/dynamic-resource-docs/${encodeURIComponent(docId)}`,
         { method: "DELETE", credentials: "include" },
       );
       if (!response.ok) {

apps/api-manager/src/routes/(protected)/dynamic-resource-docs/system/create/+page.svelte

@@ -58,7 +58,7 @@
 
   async function handleSubmit(values: DynamicResourceDocFormValues) {
     const response = await fetch(
-      `/proxy/obp/v4.0.0/management/dynamic-resource-docs`,
+      `/proxy/obp/v5.1.0/management/dynamic-resource-docs`,
       {
         method: "POST",
         headers: { "Content-Type": "application/json" },

apps/api-manager/src/routes/(protected)/json-schema-validations/+page.server.ts

@@ -34,7 +34,7 @@ export const load: PageServerLoad = async ({ locals }) => {
   let validations: JsonSchemaValidation[] = [];
   let loadError: string | null = null;
   try {
-    const resp = await obp_requests.get("/obp/v4.0.0/management/json-schema-validations", token);
+    const resp = await obp_requests.get("/obp/v5.1.0/management/json-schema-validations", token);
     validations = resp?.json_schema_validations ?? [];
   } catch (e) {
     logger.error("Could not load JSON Schema Validations:", e);

apps/api-manager/src/routes/(protected)/json-schema-validations/[operation_id]/+page.server.ts

@@ -31,7 +31,7 @@ export const load: PageServerLoad = async ({ locals, params }) => {
   const operationId = params.operation_id;
   let validation: any;
   try {
-    validation = await obp_requests.get(`/obp/v4.0.0/management/json-schema-validations/${encodeURIComponent(operationId)}`, token);
+    validation = await obp_requests.get(`/obp/v5.1.0/management/json-schema-validations/${encodeURIComponent(operationId)}`, token);
   } catch (e) {
     throw error(404, `No JSON Schema Validation for ${operationId}: ${e instanceof Error ? e.message : String(e)}`);
   }

apps/api-manager/src/routes/(protected)/mandates/+page.svelte

@@ -201,7 +201,7 @@
     try {
       // First get accounts for this customer
       const accountsRes = await trackedFetch(
-        `/proxy/obp/v4.0.0/customers/${encodeURIComponent(customerId)}/accounts-minimal`
+        `/proxy/obp/v5.1.0/customers/${encodeURIComponent(customerId)}/accounts-minimal`
       );
       if (!accountsRes.ok) {
         const data = await accountsRes.json().catch(() => ({}));

apps/api-manager/src/routes/(protected)/message-docs/[connector]/+page.server.ts

@@ -34,9 +34,9 @@ const logger = createLogger("MessageDocsPage");
 
 /** The endpoints behind this page, linked to their resource docs in the API Explorer. */
 const ENDPOINTS = [
-  { operation_id: "OBPv2.2.0-getMessageDocs", verb: "GET", path: "/obp/v2.2.0/message-docs/CONNECTOR" },
+  { operation_id: "OBPv2.2.0-getMessageDocs", verb: "GET", path: "/obp/v5.1.0/message-docs/CONNECTOR" },
   { operation_id: "OBPv6.0.0-getMessageDocsJsonSchema", verb: "GET", path: "/obp/v6.0.0/message-docs/CONNECTOR/json-schema" },
-  { operation_id: "OBPv3.1.0-getMessageDocsSwagger", verb: "GET", path: "/obp/v3.1.0/message-docs/CONNECTOR/swagger2.0" },
+  { operation_id: "OBPv3.1.0-getMessageDocsSwagger", verb: "GET", path: "/obp/v5.1.0/message-docs/CONNECTOR/swagger2.0" },
 ];
 
 export const load: PageServerLoad = async ({ locals, params, url }) => {

apps/api-manager/src/routes/(protected)/message-docs/[connector]/[process]/+page.server.ts

@@ -27,7 +27,7 @@ import {
 import { explorerResourceDocUrl } from "$lib/server/glossaryCache";
 
 const ENDPOINTS = [
-  { operation_id: "OBPv2.2.0-getMessageDocs", verb: "GET", path: "/obp/v2.2.0/message-docs/CONNECTOR" },
+  { operation_id: "OBPv2.2.0-getMessageDocs", verb: "GET", path: "/obp/v5.1.0/message-docs/CONNECTOR" },
 ];
 
 export const load: PageServerLoad = async ({ locals, params }) => {

apps/api-manager/src/routes/(protected)/products/financial/[bank_id]/[product_code]/+page.svelte

@@ -67,7 +67,7 @@
     try {
       const [productResponse, tagsResponse] = await Promise.all([
         trackedFetch(
-          `/proxy/obp/v4.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}`,
+          `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(productCode)}`,
         ),
         trackedFetch(
           `/proxy/obp/v6.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}/tags`,

apps/api-manager/src/routes/(protected)/products/financial/[bank_id]/[product_code]/edit/+page.svelte

@@ -79,7 +79,7 @@
     try {
       const [productResponse, tagsResponse] = await Promise.all([
         trackedFetch(
-          `/proxy/obp/v4.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}`,
+          `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(productCode)}`,
         ),
         trackedFetch(
           `/proxy/obp/v6.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}/tags`,
@@ -157,7 +157,7 @@
     isSubmitting = true;
     try {
       const response = await trackedFetch(
-        `/proxy/obp/v5.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}`,
+        `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(productCode)}`,
         {
           method: "PUT",
           headers: { "Content-Type": "application/json" },
@@ -195,7 +195,7 @@
           let attrResponse: Response;
           if (attr.product_attribute_id) {
             attrResponse = await trackedFetch(
-              `/proxy/obp/v4.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}/attributes/${attr.product_attribute_id}`,
+              `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(productCode)}/attributes/${attr.product_attribute_id}`,
               {
                 method: "PUT",
                 headers: { "Content-Type": "application/json" },
@@ -209,7 +209,7 @@
             );
           } else {
             attrResponse = await trackedFetch(
-              `/proxy/obp/v4.0.0/banks/${bankId}/products/${encodeURIComponent(productCode)}/attribute`,
+              `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(productCode)}/attribute`,
               {
                 method: "POST",
                 headers: { "Content-Type": "application/json" },

apps/api-manager/src/routes/(protected)/products/financial/create/+page.svelte

@@ -54,7 +54,7 @@
 
   async function putProduct(bankId: string, code: string) {
     const response = await trackedFetch(
-      `/proxy/obp/v5.0.0/banks/${bankId}/products/${encodeURIComponent(code)}`,
+      `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(code)}`,
       {
         method: "PUT",
         headers: { "Content-Type": "application/json" },
@@ -99,7 +99,7 @@
 
   async function postAttribute(bankId: string, code: string, attr: CustomAttribute) {
     const response = await trackedFetch(
-      `/proxy/obp/v4.0.0/banks/${bankId}/products/${encodeURIComponent(code)}/attribute`,
+      `/proxy/obp/v5.1.0/banks/${bankId}/products/${encodeURIComponent(code)}/attribute`,
       {
         method: "POST",
         headers: { "Content-Type": "application/json" },

apps/api-manager/src/routes/(protected)/user-invitations/+page.svelte

@@ -62,7 +62,7 @@
 
     try {
       const response = await trackedFetch(
-        `/proxy/obp/v4.0.0/banks/${encodeURIComponent(selectedBankId)}/user-invitations`,
+        `/proxy/obp/v5.1.0/banks/${encodeURIComponent(selectedBankId)}/user-invitations`,
       );
 
       if (!response.ok) {

apps/api-manager/src/routes/(protected)/user/entitlements/+page.server.ts

@@ -67,7 +67,7 @@ export async function load({ locals }) {
         try {
             const consumer = await obp_requests.get('/obp/v6.0.0/consumers/current', accessToken);
             if (!consumer?.consumer_id) return null;
-            const scopesResponse = await obp_requests.get(`/obp/v4.0.0/consumers/${consumer.consumer_id}/scopes`, accessToken);
+            const scopesResponse = await obp_requests.get(`/obp/v5.1.0/consumers/${consumer.consumer_id}/scopes`, accessToken);
             return {
                 consumer_id: consumer.consumer_id,
                 app_name: consumer.app_name || '',