\n \n {fieldName.replace(/([A-Z])/g, ' $1').trim()}\n {isRequired && *}\n \n {inputElement}\n {fieldConfig.format && (\n

Format: {fieldConfig.format}

\n )}\n

\n );\n };\n\n return (\n

\n {isImport ? 'Import New Account' : `Edit Account ${account?.UID}`}\n

\n\n

\n {/* UID field for import */}\n {isImport && (\n

Account Identifier

\n \n UID (optional - will be generated if not provided)\n \n \n

\n )}\n\n {/* Profile Fields */}\n {schema?.profileSchema?.fields && (\n

Profile Information

\n {Object.entries(schema.profileSchema.fields).map(([fieldName, fieldConfig]) =>\n renderField(fieldName, fieldConfig, 'profile', account?.profile?.[fieldName])\n )}\n

\n )}\n\n {/* Common Profile Fields (if no schema) */}\n {!schema?.profileSchema?.fields && (\n

Profile Information

\n \n First Name\n \n \n

\n \n Last Name\n \n \n

\n \n Email\n \n \n

\n )}\n\n {/* Data Fields */}\n {schema?.dataSchema?.fields && (\n

Custom Data

\n {Object.entries(schema.dataSchema.fields).map(([fieldName, fieldConfig]) =>\n renderField(fieldName, fieldConfig, 'data', account?.data?.[fieldName])\n )}\n

\n )}\n\n {/* Custom Data Fields (if account has data but no schema) */}\n {!schema?.dataSchema?.fields && account?.data && Object.keys(account.data).length > 0 && (\n

Custom Data

\n {Object.entries(account.data).map(([fieldName, value]) => (\n

\n \n {fieldName}\n \n \n

\n ))}\n

\n )}\n\n {/* Add Custom Data Field */}\n

Add Custom Data Field

\n \n Field Name\n \n \n

\n \n Field Value (JSON format)\n \n \n

\n \n Add Field\n \n

\n\n {/* Form Actions */}\n

\n \n Cancel\n \n \n {isImport ? 'Import Account' : 'Update Account'}\n \n

\n\n {/* JavaScript for dynamic field addition and form submission */}\n \n \n \n \n \n

{children}

\n \n \n );\n}",[],[166,184,215],[166,184],{"_105":224,"_97":225,"_167":226,"_169":168,"_170":148,"_171":227,"_173":119,"_107":228,"_102":229,"_175":230,"_177":231,"_178":22,"_179":-5,"_180":232,"_100":233},"86648b8c-13c9-11f1-844b-42dde27851f2","index.tsx","019c96ee-0298-70c4-b317-5b6ab0bbace3",237,["D",1772189168914],4,"http","/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport {\n readFile,\n serveFile,\n} from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { AccountForm } from \"./components/AccountForm.tsx\";\nimport { AccountSearch } from \"./components/AccountSearch.tsx\";\nimport { AccountViewer } from \"./components/AccountViewer.tsx\";\nimport { Layout } from \"./components/Layout.tsx\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Gigya API Configuration\nconst GIGYA_DOMAIN = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\nconst GIGYA_API_KEY = Deno.env.get(\"GIGYA_API_KEY\") || \"\";\nconst GIGYA_APP_KEY = Deno.env.get(\"GIGYA_APP_KEY\") || \"\";\nconst GIGYA_APP_SECRET = Deno.env.get(\"GIGYA_APP_SECRET\") || \"\";\n\nif (!GIGYA_API_KEY || !GIGYA_APP_KEY || !GIGYA_APP_SECRET) {\n console.warn(\n \"Missing Gigya environment variables. Some features may not work.\",\n );\n}\n\n// Direct Gigya API functions\nasync function makeGigyaRequest(\n endpoint: string,\n params: Record,\n): Promise {\n const url = `https://${GIGYA_DOMAIN}/${endpoint}?httpStatusCodes=true`;\n\n const body = new URLSearchParams({\n apiKey: GIGYA_API_KEY,\n userKey: GIGYA_APP_KEY,\n secret: GIGYA_APP_SECRET,\n ...params,\n });\n\n const response = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body,\n });\n\n if (!response.ok) {\n const text = await response.text();\n throw new Error(`HTTP ${response.status}: ${text}`);\n }\n\n const result = await response.json();\n\n if (result.errorCode !== 0) {\n throw new Error(\n `Gigya API Error ${result.errorCode}: ${\n result.errorMessage || \"Unknown error\"\n }`,\n );\n }\n\n return result;\n}\n\nasync function getAccountInfo(uid: string, include?: string) {\n try {\n const response = await makeGigyaRequest(\"accounts.getAccountInfo\", {\n UID: uid,\n include: include ||\n \"profile,data,communications,groups,loginIDs,lastLogin,lastLoginLocation,registrationTimestamp,verified,verifiedTimestamp,oldestDataUpdated,oldestDataUpdatedTimestamp\",\n });\n return response;\n } catch (error) {\n console.error(`Error fetching account info for UID ${uid}:`, error);\n return null;\n }\n}\n\nasync function setAccountInfo(uid: string, accountData: {\n profile?: any;\n data?: any;\n communications?: any;\n}) {\n try {\n const params: Record = { UID: uid };\n\n if (accountData.profile) {\n params.profile = JSON.stringify(accountData.profile);\n }\n\n if (accountData.data) {\n params.data = JSON.stringify(accountData.data);\n }\n\n if (accountData.communications) {\n params.communications = JSON.stringify(accountData.communications);\n }\n\n const response = await makeGigyaRequest(\"accounts.setAccountInfo\", params);\n return response;\n } catch (error) {\n console.error(`Error updating account ${uid}:`, error);\n throw error;\n }\n}\n\nasync function importAccount(accountData: {\n profile?: any;\n loginIDs?: any;\n password?: any;\n data?: any;\n UID?: string;\n}) {\n try {\n const params: Record = {};\n\n if (accountData.profile) {\n params.profile = JSON.stringify(accountData.profile);\n }\n\n if (accountData.loginIDs) {\n params.loginIDs = JSON.stringify(accountData.loginIDs);\n }\n\n if (accountData.password) {\n params.password = JSON.stringify(accountData.password);\n }\n\n if (accountData.data) {\n params.data = JSON.stringify(accountData.data);\n }\n\n if (accountData.UID) {\n params.UID = accountData.UID;\n }\n\n const response = await makeGigyaRequest(\n \"accounts.importFullAccount\",\n params,\n );\n return response;\n } catch (error) {\n console.error(\"Error importing account:\", error);\n throw error;\n }\n}\n\nasync function getSchema() {\n try {\n const response = await makeGigyaRequest(\"accounts.getSchema\", {});\n return response;\n } catch (error) {\n console.error(\"Error fetching account schema:\", error);\n return null;\n }\n}\n\nasync function setSchema(schemaData: {\n profileSchema?: any;\n dataSchema?: any;\n}) {\n try {\n const params: Record = {};\n\n if (schemaData.profileSchema) {\n params.profileSchema = JSON.stringify(schemaData.profileSchema);\n }\n\n if (schemaData.dataSchema) {\n params.dataSchema = JSON.stringify(schemaData.dataSchema);\n }\n\n await makeGigyaRequest(\"accounts.setSchema\", params);\n } catch (error) {\n console.error(\"Error setting account schema:\", error);\n throw error;\n }\n}\n\n// Serve static files\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", (c) => serveFile(c.req.path, import.meta.url));\n\n// Main page - Account search and viewer\napp.get(\"/\", async (c) => {\n try {\n const uid = c.req.query(\"uid\");\n const select = c.req.query(\"select\") || \"*\";\n const filter = c.req.query(\"filter\");\n const page = parseInt(c.req.query(\"page\") || \"1\");\n const limit = parseInt(c.req.query(\"limit\") || \"50\");\n\n // Get account schema\n const schema = await getSchema();\n const searchQuery = filter ? `WHERE ${filter}` : \"\";\n const selectQuery = select ? select : \"*\";\n const query = `select ${selectQuery} from accounts ${searchQuery} limit ${\n Math.min(limit, 100)\n }`;\n console.log(\n \"Searching with query:\",\n `select ${selectQuery} from accounts ${searchQuery} limit ${\n Math.min(limit, 100)\n }`,\n );\n\n const { results: accounts, totalCount } = await makeGigyaRequest(\n \"accounts.search\",\n {\n query: query,\n openCursor: true,\n },\n );\n\n return c.html(\n \n

Account Viewer

\n \n Import Account\n \n

\n\n \n\n {/* Search Results */}\n {accounts.length > 0 && (\n

\n Search Results ({totalCount}{\" \"}\n {totalCount === 1 ? \"account\" : \"accounts\"} found)\n

\n {totalCount > limit && (\n

\n Showing {Math.min(limit, accounts.length)} of {totalCount}\n {\" \"}\n results\n

\n )}\n

\n\n {accounts.map((account, index) => (\n \n ))}\n\n {/* Pagination */}\n {totalCount > limit && (\n

\n Page {page} of {Math.ceil(totalCount / limit)}\n

\n {page > 1 && (\n \n Previous\n \n )}\n {page < Math.ceil(totalCount / limit) && (\n \n Next\n \n )}\n

\n )}\n

\n )}\n\n {/* No results message */}\n {(uid || query || filter) && accounts.length === 0 && (\n

\n \n \n \n

\n No accounts found\n

\n No accounts match your search criteria. Try adjusting your\n search terms or using different criteria.\n

\n \n Clear Search\n \n

\n )}\n

\n ,\n );\n } catch (error) {\n return c.html(\n \n

\n Error: {error.message}\n

\n ,\n );\n }\n});\n\n// Edit account form\napp.get(\"/edit/:uid\", async (c) => {\n try {\n const uid = c.req.param(\"uid\");\n\n const [schema, account] = await Promise.all([\n getSchema(),\n getAccountInfo(uid),\n ]);\n\n if (!account) {\n return c.html(\n \n

\n Account not found\n

\n ,\n );\n }\n\n return c.html(\n \n

\n \n ← Back\n \n

Edit Account

\n \n

\n ,\n );\n } catch (error) {\n return c.html(\n \n

\n Error: {error.message}\n

\n ,\n );\n }\n});\n\n// Import account form\napp.get(\"/import\", async (c) => {\n try {\n const schema = await getSchema();\n\n return c.html(\n \n

\n \n ← Back\n \n

Import New Account

\n \n

\n ,\n );\n } catch (error) {\n return c.html(\n \n

\n Error: {error.message}\n

\n ,\n );\n }\n});\n\n// API Routes\n\n// Get account info\napp.get(\"/api/account/:uid\", async (c) => {\n try {\n const uid = c.req.param(\"uid\");\n const account = await getAccountInfo(uid);\n\n if (!account) {\n return c.json({ success: false, error: \"Account not found\" }, 404);\n }\n\n return c.json({ success: true, data: account });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Search accounts\napp.get(\"/api/search\", async (c) => {\n try {\n const query = c.req.query(\"q\") || \"\";\n const filter = c.req.query(\"filter\") || \"\";\n const select = c.req.query(\"select\") || \"\";\n const page = parseInt(c.req.query(\"page\") || \"1\");\n const limit = parseInt(c.req.query(\"limit\") || \"50\");\n\n const result = await searchAccountsWithFilter(\n query,\n filter,\n select,\n page,\n limit,\n );\n\n return c.json({ success: true, data: result });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Update account\napp.put(\"/api/account/:uid\", async (c) => {\n try {\n const uid = c.req.param(\"uid\");\n const body = await c.req.json();\n\n const result = await setAccountInfo(uid, body);\n return c.json({ success: true, data: result });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Import account\napp.post(\"/api/account/import\", async (c) => {\n try {\n const body = await c.req.json();\n const result = await importAccount(body);\n return c.json({ success: true, data: result });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Get schema\napp.get(\"/api/schema\", async (c) => {\n try {\n const schema = await getSchema();\n return c.json({ success: true, data: schema });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Update schema\napp.put(\"/api/schema\", async (c) => {\n try {\n const body = await c.req.json();\n await setSchema(body);\n return c.json({ success: true });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Health check\napp.get(\"/api/health\", (c) => {\n return c.json({\n success: true,\n timestamp: new Date().toISOString(),\n service: \"Gigya Account Viewer\",\n });\n});\n\n// Proxy to group manager\napp.all(\"/groupmanager/*\", async (c) => {\n const groupManagerBase =\n \"https://dinavinter--4115639612fa11f190a542dde27851f2.web.val.run\";\n const url = new URL(c.req.url);\n const proxiedPath = url.pathname.replace(\"/groupmanager\", \"\") || \"/\";\n const targetUrl = groupManagerBase + proxiedPath + (url.search || \"\");\n const req = new Request(targetUrl, {\n method: c.req.method,\n headers: c.req.raw.headers,\n body: c.req.raw.body,\n });\n return fetch(req);\n});\napp.get(\"/groupmanager\", async (c) => {\n const groupManagerBase =\n \"https://dinavinter--4115639612fa11f190a542dde27851f2.web.val.run\";\n return fetch(new Request(groupManagerBase + \"/\", { method: \"GET\" }));\n});\n\nexport default app.fetch;",[],[166,225],[166],{"_105":236,"_97":237,"_167":238,"_169":-5,"_170":148,"_171":239,"_173":119,"_107":240,"_102":172,"_175":176,"_177":-5,"_178":22,"_179":-5,"_180":241,"_100":271},"08b593dc-129a-11f1-8bc0-42dde27851f2","docs","06bb7484-129a-11f1-b0c0-42dde27851f2",15,["D",1772058820543],[242,252,261],{"_105":243,"_97":244,"_167":245,"_169":238,"_170":148,"_171":246,"_173":119,"_107":247,"_102":172,"_175":248,"_177":249,"_178":22,"_179":-5,"_180":250,"_100":251},"10311e24-129a-11f1-b3d7-42dde27851f2","accounts.yaml","019c96ee-0299-75ff-a0e5-202da08fb451",17,["D",1772058833096],"file","openapi: 3.0.3\ninfo:\n title: SAP Customer Data Cloud - Account API\n version: 1.0.0\n description: OpenAPI spec for Account Info, Account Update, Account Import, Schema\n configuration, and Account Search\nservers:\n- url: https://cdcs-api.example.com\npaths:\n /accounts.getAccountInfo:\n get:\n summary: Get Account Info\n parameters:\n - in: query\n name: UID\n schema:\n type: string\n required: true\n description: Unique user ID\n responses:\n '200':\n description: Account object\n content:\n application/json:\n schema:\n $ref: '#/components/schemas/Account'\n /accounts.setAccountInfo:\n post:\n summary: Update Account Info\n requestBody:\n required: true\n content:\n application/x-www-form-urlencoded:\n schema:\n type: object\n properties:\n profile:\n type: string\n communications:\n type: string\n data:\n type: string\n example:\n profile: '{\"firstName\":\"John\",\"lastName\":\"Doe\"}'\n communications: '{\"Marketing_Email\":{\"status\":\"optIn\"}}'\n data: '{\"customField\":\"value\"}'\n responses:\n '200':\n description: Update successful\n '400':\n description: Invalid input\n /accounts.importFullAccount:\n post:\n summary: Import a user account\n description: Imports a new user account with provided profile, login IDs, and\n password hash\n requestBody:\n required: true\n content:\n application/x-www-form-urlencoded:\n schema:\n type: object\n properties:\n profile:\n type: string\n loginIDs:\n type: string\n password:\n type: string\n UID:\n type: string\n example:\n profile: '{\"firstName\":\"Alice\",\"lastName\":\"Smith\"}'\n loginIDs: '{\"email\":\"alice@example.com\"}'\n password: '{\"hash\":\"abc123\",\"hashSettings\":{\"algorithm\":\"sha256\"}}'\n UID: user-001\n responses:\n '200':\n description: Account imported successfully\n '400':\n description: Invalid input\n /accounts.getSchema:\n get:\n summary: Retrieve schema configuration\n responses:\n '200':\n description: Schema definition\n content:\n application/json:\n schema:\n $ref: '#/components/schemas/Schema'\n /accounts.setSchema:\n post:\n summary: Update schema definition\n requestBody:\n required: true\n content:\n application/x-www-form-urlencoded:\n schema:\n type: object\n properties:\n schema:\n type: string\n example:\n schema: '{\"fields\":{\"firstName\":{\"type\":\"string\",\"required\":true}}}'\n responses:\n '200':\n description: Schema updated\n /accounts.search:\n get:\n summary: Search Accounts\n description: Search for accounts using parameters such as email or UID.\n parameters:\n - in: query\n name: email\n schema:\n type: string\n format: email\n required: false\n description: Email address to search for\n - in: query\n name: UID\n schema:\n type: string\n required: false\n description: Specific UID to search\n - in: query\n name: query\n schema:\n type: string\n required: false\n description: Free-form query string\n responses:\n '200':\n description: List of matching accounts\n content:\n application/json:\n schema:\n type: array\n items:\n $ref: '#/components/schemas/Account'\n '400':\n description: Invalid query parameters\ncomponents:\n schemas:\n Account:\n type: object\n properties:\n UID:\n type: string\n isActive:\n type: boolean\n profile:\n $ref: '#/components/schemas/Profile'\n communications:\n $ref: '#/components/schemas/Communications'\n groups:\n type: array\n items:\n type: object\n properties:\n orgId:\n type: string\n roles:\n type: array\n items:\n type: string\n status:\n type: string\n Profile:\n type: object\n properties:\n firstName:\n type: string\n lastName:\n type: string\n email:\n type: string\n format: email\n Communications:\n type: object\n additionalProperties:\n type: object\n properties:\n status:\n type: string\n optIn:\n type: object\n additionalProperties:\n type: string\n Schema:\n type: object\n properties:\n fields:\n type: object\n additionalProperties:\n type: object\n properties:\n type:\n type: string\n required:\n type: boolean\n writeAccess:\n type: string\n allowNull:\n type: boolean\n format:\n type: string\n encrypt:\n type: string",[],[237,244],{"_105":253,"_97":254,"_167":255,"_169":238,"_170":148,"_171":256,"_173":119,"_107":257,"_102":172,"_175":248,"_177":258,"_178":22,"_179":-5,"_180":259,"_100":260},"0cbb6c68-129a-11f1-8bc0-42dde27851f2","ds.md","019c96ee-0299-75ff-a0e5-3df48d3804b9",16,["D",1772058827289],"# SAP Customer Data Cloud\n\nGenerated on: 2025-06-09 18:21:06 GMT+\n\nSAP Customer Data Cloud | SHIP\n\nPublic\n\nOriginal content: https://help.sap.com/docs/SAP_CUSTOMER_DATA_CLOUD/8b8d6fffe113457094a17701f63e3d6a?locale=en-\n\nUS&state=PRODUCTION&version=SHIP\n\n### Warning\n\nThis document has been generated from SAP Help Portal and is an incomplete version of the official SAP product documentation.\n\nThe information included in custom documentation may not reect the arrangement of topics in SAP Help Portal, and may be\n\nmissing important aspects and/or correlations to other topics. For this reason, it is not for production use.\n\nFor more information, please visit https://help.sap.com/docs/disclaimer.\n\n\n## Data Store REST\n\nSAP Customer Data Cloud's Data Store (DS) API consists of the methods listed below.\n\n```\nds.delete REST\n```\n```\nds.deleteSchemaFields REST\n```\n```\nds.get REST\n```\n```\nds.getSchema REST\nds.getTypes REST\n```\n```\nds.search REST\n```\n```\nds.setSchema REST\nds.store REST\n```\n## ds.delete REST\n\n## Description\n\nDeletes object data or an entire object from Gigya's Data Store.\n\n## Request URL\n\n#### https://ds./ds.delete\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your SAP\nCustomer Data Cloud Customer Engagement Executive or email support@gigya-inc.com.\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your Gigya\nCustomer Engagement Executive or email support@gigya-inc.com.\n```\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\nRequired Name Type Description\n```\n```\noid string The ID of the object to delete.\n```\n```\ntype string A string indicating the type of the\nobject.\n```\n```\nelds string A comma separated list of elds\nto delete. Acceptable values for\nthis parameter:\n```\n```\nData eld names,\nspecifying the the\ncomplete path, i.e.\nalbum.photo.photoTitle_t\n```\n```\nPartial eld names (elds\nthat contain only a part\nof the path to sub-\nobjects, i.e. album.photo)\n```\n- indicate to retrieve\neverything below that\npath.\n\n```\n\"*\" - indicates to retrieve\nthe entire stored object.\n```\n```\nUID string If the object is associate with a\nuser, then the ID of the user\nshould be specied and forms a\ncompound key together with the\noid.\n```\n```\n* If you call this method through\nan external OAuth2 SDK, then\nthe UID may be passed implicitly\nwithin the access_token.\n```\n```\nformat string Determines the format of the\nresponse.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to\npass data through the current\nmethod and return it,\nunchanged, within the response.\n```\n```\nignoreInterruptions Boolean This may be used in some cases\nto suppress logic applied by the\nWeb SDK, such as automatic\nopening of screens (e.g., in a\nregistration completion\n```\n\n```\nRequired Name Type Description\n```\n```\nscenario). This parameter may\nnot be used with REST APIs.\n```\n```\nhttpStatusCodes Boolean The default value of this\nparameter is false, which means\nthat the HTTP status code in\nSAP Customer Data Cloud's\nresponse is always 200 (OK),\neven if an error occurs. The error\ncode and message is given within\nthe response data (see below). If\nthis parameter is set to true, the\nHTTP status code in SAP\nCustomer Data Cloud's response\nwould reect an error, if one\noccurred.\n```\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n## Sample Requests\n\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and A\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\nshort textual description of an error,\nassociated with the errorCode, for logging\npurposes. This eld will appear in the\nresponse only in case of an error.should not\nbe relied upon by your implementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n### Response Example\n\n## ds.deleteSchemaFields REST\n\n## Description\n\nDeletes a eld from a specied Gigya Data Store schema type.\n\nOnce a eld is deleted:\n\n```\nYou cannot save data to that eld, nor retrieve data that was saved to that eld.\n```\n```\nYou cannot recreate a eld of the same name in the schema.\n```\nThis parameter or feature is part of our Early Adopters Program. To nd out if you are eligible for participation, contact your SAP\n\nCustomer Data Cloud Customer Engagement Executive or contact us at SAP Support.\n\n##### {\n\n```\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\nA short textua\"callId\": \"31ba039fb8d340ceb2f43d52c89bf187\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package, contact your SAP\nCustomer Data Cloud Customer Engagement Executive or contact us at SAP Support.\n```\n\n## Request URL\n\n#### https://ds./ds.deleteSchemaFields\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\nRequired Name Type Description\n```\n```\ntype string The schema type dened in the\nData Store from which to delete\nelds.\n```\n```\ndataSchema array The elds to delete from the\nspecied Data Store type. For\nexample:\n```\n```\nformat string Determines the format of the\nresponse.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to\npass data through the current\nmethod and return it,\nunchanged, within the\nresponse.\n```\n```\nignoreInterruptions Boolean This may be used in some cases\nto suppress logic applied by the\nWeb SDK, such as automatic\nopening of screens (e.g., in a\nregistration completion\nscenario). This parameter may\nnot be used with REST APIs.\n```\n```\nhttpStatusCodes Boolean The default value of this\nparameter is false, which means\nthat the HTTP status code in\nSAP Customer Data Cloud's\nresponse is always 200 (OK),\neven if an error occurs. The\n```\n```\n[\"field1\",\"field2\"]\n```\n\n```\nRequired Name Type Description\n```\n```\nerror code and message is given\nwithin the response data (see\nbelow). If this parameter is set\nto true, the HTTP status code in\nSAP Customer Data Cloud's\nresponse would reect an error,\nif one occurred.\n```\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n## Sample Requests\n\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n### Response Example\n\n## ds.get REST\n\n## Description\n\nRetrieves an object's or the specied datum from Gigya's Data Store.\n\n## Request URL\n\n#### https://ds./ds.get\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n##### {\n\n```\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"31ba039fb8d340ceb2f43d52c89bf187\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your Gigya\nCustomer Engagement Executive or email support@gigya-inc.com.\n```\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\nRequired Name Type Description\n```\n```\noid string The ID of the object to retrieve.\n```\n```\ntype string A string indicating the type of the\nobject, equivalent to a name\nclassifying objects as being of\nthe same type; used in searches\nand when applying schemas.\n```\n```\nelds string A comma separated list of elds\nto retrieve. Acceptable values for\nthis parameter:\n```\n```\nData eld names,\nspecifying the the\ncomplete path, i.e.\nalbum.photo.photoTitle_t\n```\n```\nPartial eld names (elds\nthat contain only a part\nof the path to sub-\nobjects, i.e. album.photo)\n```\n- indicate to retrieve\neverything below that\npath.\n\n```\n\"*\" - indicates to retrieve\nthe entire stored object.\n```\n```\nUID string If the object is associate with a\nuser, then the ID of the user\nshould be specied and forms a\ncompound key together with the\noid.\n```\n```\n* If you call this method through\nan external OAuth2 SDK, then\nthe UID may be passed implicitly\nwithin the access_token.\n```\n```\nformat string Determines the format of the\nresponse.\n```\n```\njson (default)\n```\n\n```\nRequired Name Type Description\n```\n```\ncontext string/JSON This parameter may be used to\npass data through the current\nmethod and return it,\nunchanged, within the response.\n```\n```\nignoreInterruptions Boolean This may be used in some cases\nto suppress logic applied by the\nWeb SDK, such as automatic\nopening of screens (e.g., in a\nregistration completion\nscenario). This parameter may\nnot be used with REST APIs.\n```\n```\nhttpStatusCodes Boolean The default value of this\nparameter is false, which means\nthat the HTTP status code in\nSAP Customer Data Cloud's\nresponse is always 200 (OK),\neven if an error occurs. The error\ncode and message is given within\nthe response data (see below). If\nthis parameter is set to true, the\nHTTP status code in SAP\nCustomer Data Cloud's response\nwould reect an error, if one\noccurred.\n```\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Sample Requests\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\ndata JSON object The object data retrieved from Gigya's Data\nStore.\n```\n```\noid string The ID of the object\n```\n```\nUID string If the object is associate with a user, then\nthe ID of the user.\n```\n```\nlastUpdated long The time of the latest change in this object,\nin Java time (number of milliseconds since\nJan. 1st 1970).\n```\n```\nlastUpdatedTime string The time of the latest change in this object,\nin ISO 8601 format.\n```\n```\ncreated long The time of this object's creation, in Java\ntime (number of milliseconds since Jan. 1st\n1970).\n```\n```\ncreatedTime string The time of this object's creation, in ISO\n8601 format.\n```\n### Response Example\n\n##### {\n\n```\n\"data\": {\n\"BloodType\": \"A\",\n\"Dislikes\": \"Evil\",\n\"EyeColor\": \"Brown\",\n\"HairColor\": \"Brown\",\n\"Height\": \"179 cms\",\n\"Likes\": \"Justice\",\n\"Occupation\": \"QA\",\n\"Weight\": \"94.1 kgs\"\n},\n\"oid\": \"8b8972c3b3114db2a0acdfa2617693bf\",\n```\n\n## ds.getSchema REST\n\n## Description\n\nThis method retrieves the schema of a specied data type in Gigya's Data Store (DS).\n\n## Request URL\n\n#### https://ds./ds.getSchema\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\nRequired Name Type Description\n```\n```\ntype string A string indicating the type of\nthe object, equivalent to a\nschema name. To see all the\n```\n```\n\"lastUpdatedTime\": \"2012-08-08T12:16:24Z\",\n\"lastUpdated\": 1344428184385,\n\"createdTime\": \"2012-08-08T12:16:24Z\",\n\"created\": 1344428184385,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"d02ada709b494be18d47cab5a23c3470\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```\n###  Note\n\n```\nFor security reasons this method is not available for client-side SDKs, only for server-side SDKs.\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your Gigya\nCustomer Engagement Executive or email support@gigya-inc.com.\n```\n\nRequired Name Type Description\n\n```\ntypes currently dened in the\nschema, use ds.getTypes or the\nSchema Editor.\n```\n```\nlter string Species what parts of the\nschema to return, can be one of\nthe following options:\n```\n```\nfull - (default) return the\ncomplete schema\nincluding implicit elds\nand dynamic elds.\n```\n```\nexplicitOnly - return\nonly the parts of the\nschema that were\nexplicitly set by the\npartner using a\nsetSchema call.\n```\n```\nclientOnly - return only\nthe elds in the schema\nthat allow client access.\nFor those elds return\nonly the type and\nformat and required\nproperties (see the\nformat denition of the\nschema object).\n```\n```\nformat string Determines the format of the\nresponse.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to\npass data through the current\nmethod and return it,\nunchanged, within the\nresponse.\n```\n```\nignoreInterruptions Boolean This may be used in some cases\nto suppress logic applied by the\nWeb SDK, such as automatic\nopening of screens (e.g., in a\nregistration completion\nscenario). This parameter may\nnot be used with REST APIs.\n```\n```\nhttpStatusCodes Boolean The default value of this\nparameter is false, which means\nthat the HTTP status code in\nSAP Customer Data Cloud's\nresponse is always 200 (OK),\neven if an error occurs. The\nerror code and message is given\nwithin the response data (see\nbelow). If this parameter is set\nto true, the HTTP status code in\n```\n\n```\nRequired Name Type Description\n```\n```\nSAP Customer Data Cloud's\nresponse would reect an error,\nif one occurred.\n```\n```\nincludeDynamicSchema Boolean Deprecated. When it is explicitly\nset to false it should be\ninterpreted as\nschemaType=explicit.\n```\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n## Sample Requests\n\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nschema JSON object A JSON object that details the schema\nstructure. See the format denition of the\nschema object.\n```\n### Response Example\n\n## ds.getTypes REST\n\n## Description\n\nThis method retrieves the schema data types dened in Gigya's Data Store (DS).\n\n##### {\n\n```\n\"schema\": {\n\"fields\": {\n\"customField1\": {\n\"type\": \"integer\"\n},\n\"customField2\": {\n\"type\": \"string\"\n},\n\"customField3\": {\n\"type\": \"string\"\n}\n},\n\"dynamicSchema\": false\n},\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"0d8382a314ac4329a53add3067e863d9\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```\n###  Note\n\n\n## Request URL\n\n#### https://ds./ds.getTypes\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n```\nFor security reasons this method is not available for client-side SDKs, only for server-side SDKs.\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your Gigya\nCustomer Engagement Executive or email support@gigya-inc.com.\n```\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Sample Requests\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\ntypes array A list of the types which make up this DS\nschema.\n```\n### Response Example\n\n## ds.search REST\n\n## Description\n\nSearches and retrieves data from Gigya's Data Store (DS) using an SQL-like query. For security reasons this method is not\n\navailable for client side SDKs, only for server side SDKs. SQL queries are converted into Gigya's proprietary query language. SQL\n\ninjection attacks are not possible because queries are both created by the customer and then converted by Gigya.\n\nA short delay is possible between the writing of account data to the data base and its availability in queries.\n\n##### {\n\n```\n\"types\": [\n\"myType\"\n],\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"f293e7d275fa4656b6bf197d90027ae2\",\n\"time\": \"2017-08-17T07:32:49.229Z\"\n}\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your Gigya\n\nCustomer Engagement Executive or email support@gigya-inc.com.\n\n## Query Syntax Specication\n\nGigya queries use the same syntax rules as SQL, however not all standard SQL key words are available.\n\n```\nWhen querying for string values, value must be wrapped in double quotes. e.g., SELECT * FROM data.music WHERE guitar\n= \"Fender\".\n```\n```\nWhen querying for Integer (and other non-textual elds) values, value must not be wrapped in quotes. e.g., SELECT * FROM\ndata.userAccounts WHERE age = 42.\n```\n```\nUnsupported SQL syntax in the query string (e.g., HAVING) will produce an error.\n```\n```\nThe query string clauses must be ordered in the following way*:\n```\n```\n. Select clause\n```\n```\n. From clause\n```\n```\n. Where clause\n```\n```\n. Filter clause\n```\n```\n. Group By clause\n```\n```\n. Order By clause\n```\n```\n. Start clause Or/And Limit clause\n```\n```\nDeleted objects do not appear in queries.\n```\n```\nEncrypted elds are decrypted during searches but comparison operators (>, >=, <, <=) and regex expressions are not\navailable on these elds. The Contains keyword can be used for case-insensitive searches on encrypted elds but does not\nsupport partial strings.\n```\n```\nExample queries and responses can be viewed at DS.search Examples.\n```\nselect - The \"select\" statement accepts a comma separated list of elds or objects to retrieve. Acceptable values for this\n\nstatement are:\n\n```\nField names, specifying the complete path, i.e. data.album.photo.photoTitle_t. Specifying partial elds names (data.album)\nwill return all the elds in the path.\n```\n```\nObject names, specifying an object name, i.e. user_likes will return all the elds in the user_likes object.\n```\n```\nPartial eld names (elds that contain only a part of the path to sub-objects, i.e. data.album) - will retrieve everything below\nthat path.\n```\n```\n* - will retrieve every eld in the schema.\n```\n```\ncount(*) - Returns the number of objects for a particular object type in the data store. The result is given in the response as\na single value inside the \"data\" eld.\n```\n```\nas - create an alias (temporary title) for the returned object or eld. 'Select data.track.title as song...' will return a eld\ncalled track.song containing the values of data.track.title. Example:\n```\n```\n// Query\nSELECT data.music.trackName AS Track\n// Result\n{\"results\": [\n{\"track\": {\"song\": \"I will follow\"} },\n{\"track\": {\"song\": \"Into the Heart\"} },\n{\"track\": {\"song\": \"The Ocean\"} },\n{\"track\": {\"song\": \"A Day Without Me\"} },\n{\"track\": {\"song\": \"Shadows and Trees\"} }\n],\n\"objectsCount\": 5,\n\"totalCount\": 1840,\n\"statusCode\": 200,\n```\n\n```\nsum(), min(), max(), avg(), sum_of_squares(), variance(), std() - Mathematical functions, must all be performed on the\nsame numeric eld. Fields with null values will be ignored.\n```\n```\nThe name of the eld on which the function is to be performed must be entered in the brackets. For example: 'Select\nmin(track) from data.music'.\n```\n```\nsum - provides a total for the eld in the brackets.\n```\n```\nmin/max - minimum/maximum value for the eld. If no values are found, min will return \"innity\" and max will\nreturn \"-innity\".\n```\n```\navg - average value of the eld.\n```\n```\nvariance - the extent that the eld's values vary.\n```\n```\nstd - standard deviation, the likelihood that values vary.\n```\nfrom - Name of the data source. Only one data source is supported. Queries on objects in the Data Store (DS.search) must specify\n\nthe object \"type\" classic ation as dened in the DS.store method.\n\nwhere - The \"where\" clause denes conditions for selecting items from the collection. Supported operators:\n\n```\n> , >=, <, <= , = , != - the left operand must be a data eld name (with a proper suffix letter) and the right operand must be a\nconstant of the same type as the eld. For example: \"where track.# >= 18 \".\n```\n```\nOnly = and != can be used with encrypted elds.\n```\n```\nand , or\n```\n```\ncontains, not contains - may be used only on text (string) elds and arrays.\n```\n```\nText (string) elds - support standard full text search capabilities. Contains is not case-sensitive. The left operand\nmust be a text eld name and the right operand must be a constant string. You can search for a specic word within\nthe string, for example: WHERE data.about_t CONTAINS \"music\". Underscores are treated as separators between\nwords. Contains cannot be used to locate words within encrypted elds (you must enter the full string) and is case\ninsensitive.\n```\n```\nArrays - the left operand must be an array eld name and the right operand must be a constant of the same type as\nthe array values. The array eld name must have a suffix denoting the type of the arrays values. For example:\nWHERE data.hobbies_s CONTAINS \"swimming\".\n```\n```\nin() - only retrieve items if the eld contains one of the list values. For example: 'select * from data.music where\ntrack.album_artist in (\"Elvis\", \"Beatles\", \"Santana\")' will return tracks recorded by the specied artists.\n```\n```\nis null , is not null\n```\n```\nnot\n```\n```\nregex ('') - denes a search term using regex formatting. Regex patterns cannot be used on encrypted elds.\n```\norder by - The \"order by\" clause species a list of elds by which to sort the result objects.\n\nlimit - Using the \"LIMIT\" clause, you may specify the maximum number of returned result objects. If not specied, the default is\n\n300. The maximum number of results that will be returned is 10000 ; setting a limit higher than 10000 will have no affect on\n\nnumber of results. If the search is sent with openCursor = true, LIMIT will set the batch size. LIMIT must be the last item in the\n\nquery.\n\n```\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"2222\"\n}\n```\n###  Note\n\n```\nYou can only search words that are part of a sentence, you cannot search for parts of a word.\n```\n\nstart - The \"start\" clause (not an SQL standard clause) may be used for paging. The clause species the start index from which to\n\nreturn result objects.\n\nThe 'select - from - where - order by' query creates an (internal) indexed list of objects. By using the start & limit clauses, you will\n\nreceive a subset of this list, starting with the start index and ending with start+limit index.\n\n### Query Optimization\n\nBelow are a few points to note regarding query optimization:\n\n```\n. Query execution is based on clause position and is executed from left to right.\n```\n```\n. Place clauses that have the greatest impact on records returned at the beginning of your SQL statement. For example, to\nretrieve a list of male users over the age of 25:\n```\n```\nThis is because lt ering rst by gender automatically reduces the result set by half, so the server only needs to run the next\nlt er on half of the overall population.\n```\n```\n. A NOT clause (NOT or !) is executed on a single statement immediately to it's right, after analyzing the statement. A single\nstatement can hold several conditions inside parentheses.\n```\n```\n. Date ranges are calculated much more efficiently using a timestamp eld rather than a date eld.\n```\n```\n. Use of regex is computationally intensive and can signicantly increase response time.\n```\n```\n. AND clauses take precedence over OR clauses (i.e., AND clauses are executed before OR clauses).\n```\n```\n. Use parentheses to modify default precedence (e.g., to execute an OR operation before an AND operation).\n```\n### Pagination\n\nWhen running long queries (>5,000 records returned), it's best practice to paginate your results using cursors. If you do not use\n\ncursors, results are limited to a total of 5,000 records per query (not just per page).\n\nTo use cursors, during the rst request, pass query= and openCursor=true. The response will include the\n\nnextCursorId eld, containing a cursor ID to be used in the next request. On subsequent requests, pass cursorId= and do not submit the query again. The absence of the nextCursorId eld in a response indicates the end of the\n\nresult set.\n\nWhen using openCursor, you cannot use 'START'.\n\n###  Note\n\n```\nWhen implementing paging, there is no guarantee that there will be no duplications or that recently added data will show up in\nthe query results.\n```\n###  Note\n\n```\nAlways prefer accessing data objects directly using their IDs (with ds.get) rather than using search, whenever possible.\nAccessing data objects directly using their OIDs is faster and optimal for run-time.\n```\n```\nAfter data is published to the DS, building the indexes is done asynchronously for performance reasons, and may take\nup to one second to complete.\n```\n```\nPlease note, when using a cursor, the number of results in a batch (limit) is not guaranteed.\n```\n```\nWhen querying for large numbers of results (>500) it is Best Practice to use the openCursor and then the cursorId with\nthe nextCursorId value rather than attempting to page through results using timestamps of the user records.\n```\n```\nSELECT * FROM data.userAccounts where gender=\"male\" AND age > 25\n```\n\n## Request URL\n\n#### https://ds./ds.search\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\nRequired Name Type Description\n```\n```\nquery string A SQL-like query specifying the\ndata to retrieve. Please refer to\nthe Query language\nspecication section above.\n```\n```\nquerySig string An HMAC_SHA1 signature\nproving that the search call is in\nfact coming from your client\napplication, in order to prevent\nfraud. Follow the instructions in\nConstructing a Signature using\nthe following base-string: query\n+ \"_\" + expTime. When using\ncursors, this parameter should\nonly be sent with the initial\nrequest and omitted from\nsubsequent requests.\n```\n```\nThis parameter is required only\nwhen calling the search method\nfrom client side (i.e., Mobile\nSDKs)\n```\n```\nexpTime string The GMT time when the\nquerySig parameter should\nexpire. The expected format is\nthe Unix time format (i.e., the\nnumber of seconds since Jan.\n1st 1970). Gigya checks the time\nwhen the search request is\nreceived. If the time succeeds\nexpTime, the request is\nconsidered forged.\n```\n\nRequired Name Type Description\n\n```\nThis parameter is required only\nwhen calling the search method\nfrom client side (i.e., Mobile\nSDKs)\n```\n```\nopenCursor Boolean When set to true, the search\nresponse will include, in\naddition to the rst page,\nanother eld named\nnextCursorId, which is used to\nfetch the next batch of results.\nThis parameter should only be\nused on the rst request and\nlater should be removed from\nthe request. When openCursor\nis true, the Limit clause sets the\nnumber of results returned in\nthe batch.\n```\n```\ncursorId string The cursor ID that contains the\nnextCursorId value received in\nthe rst search call. Note: You\ncannot pass both cursorId and\nquery on the same request -\ncursorId brings the next page\nfor the search for which it was\nopened. Also, the time between\nsearch requests using a\ncursorId must not exceed 5\nminutes.\n```\n```\ntimeout integer The timeout for the request (in\nmilliseconds). Default value is\n20000 (20 seconds). Maximum\n```\n###  Note\n\n```\nYou cannot use a cursor if\nyou have a 'group by' or\nwhen using 'start'.\n```\n###  Note\n\n```\nEach request should contain\na different cursorId obtained\nfrom the response of the\nprevious request (not the\nrst) using the nextCursorId\neld. The exception to this\nrule is when a request fails\nor when a particular result\nset needs to be resent; in\nthis case, resend the same\ncursorID (as long as it has\nnot expired) to receive its\nassociated result set.\n```\n\n```\nRequired Name Type Description\n```\n```\nallowed value is 60000 (60\nseconds).\n```\n```\nformat string Determines the format of the\nresponse.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to\npass data through the current\nmethod and return it,\nunchanged, within the\nresponse.\n```\n```\nignoreInterruptions Boolean This may be used in some cases\nto suppress logic applied by the\nWeb SDK, such as automatic\nopening of screens (e.g., in a\nregistration completion\nscenario). This parameter may\nnot be used with REST APIs.\n```\n```\nhttpStatusCodes Boolean The default value of this\nparameter is false, which means\nthat the HTTP status code in\nSAP Customer Data Cloud's\nresponse is always 200 (OK),\neven if an error occurs. The\nerror code and message is given\nwithin the response data (see\nbelow). If this parameter is set\nto true, the HTTP status code in\nSAP Customer Data Cloud's\nresponse would reect an error,\nif one occurred.\n```\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n\n## Sample Requests\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\ndata Array An array of data objects retrieved from the\nDS.\n```\n```\nobjectsCount integer The number of objects returned in the\n\"data\" array.\n```\n```\ntotalCount integer The total number of object that satisfy the\nquery in the DB. This is useful for knowing\nhow many objects are in the DB, when\nfetching limited amount using the \"limit\"\nparameter.\n```\n```\nnextCursorId string Used to fetch the next batch of results. This\nparameter is not returned on the last batch\nof results, its absence means that the result\nset is nished.\n```\n### Response Example\n\n##### {\n\n```\n\"results\": [{\n\"oid\": \"050\",\n\"lastUpdated\": 1344151787611,\n\"lastUpdatedTime\": \"2012-08-05T07:29:47Z\",\n\"created\": 1344151532974,\n\"createdTime\": \"2012-08-05T07:25:32Z\",\n\"data\": {\n\"FN\": 7,\n\"Fn\": 7,\n```\n\n\"field1\": 7,\n\"field2\": 7,\n\"field3\": 7,\n\"field4\": \"7\",\n\"field5\": \"7\",\n\"field6\": \"7\",\n\"field7\": \"7\",\n\"field8\": \"7\",\n\"field10\": \"d1_0\",\n\"field11\": \"d1_0\",\n\"field12\": \"d1_0\",\n\"field13\": \"d1_0\",\n\"fn\": 7\n}},\n{\n\"oid\": \"1c675e20f7724c93b9ca82aa7b206b41\",\n\"lastUpdated\": 1344172297960,\n\"lastUpdatedTime\": \"2012-08-05T13:11:37Z\",\n\"created\": 1344172297960,\n\"createdTime\": \"2012-08-05T13:11:37Z\",\n\"data\": {\n\"BloodType\": \"A\",\n\"Dislikes\": \"Evil\",\n\"EyeColor\": \"Brown\",\n\"HairColor\": \"Brown\",\n\"Height\": \"179 cms\",\n\"Likes\": \"Justice\",\n\"Occupation\": \"QA\",\n\"Weight\": \"94.1 kgs\"\n}},\n{\n\"UID\": \"_gid_t6BWv8yeJG6QZyq7Wtav1Q==\",\n\"oid\": \"51b5d8e72c664520a27c7020ff2f1494\",\n\"lastUpdated\": 1344414722808,\n\"lastUpdatedTime\": \"2012-08-08T08:32:02Z\",\n\"created\": 1344414722808,\n\"createdTime\": \"2012-08-08T08:32:02Z\",\n\"data\": {\n\"BloodType\": \"A\",\n\"Dislikes\": \"Evil\",\n\"EyeColor\": \"Brown\",\n\"HairColor\": \"Brown\",\n\"Height\": \"179 cms\",\n\"Likes\": \"Justice\",\n\"Occupation\": \"QA\",\n\"Weight\": \"94.1 kgs\"\n}},\n{\n\"oid\": \"677cc8b3437b40959b9b1288add0a2ec\",\n\"lastUpdated\": 1344172153286,\n\"lastUpdatedTime\": \"2012-08-05T13:09:13Z\",\n\"created\": 1344172153286,\n\"createdTime\": \"2012-08-05T13:09:13Z\",\n\"data\": {\n\"BloodType\": \"A\",\n\"Dislikes\": \"Evil\",\n\"EyeColor\": \"Brown\",\n\"HairColor\": \"Brown\",\n\"Height\": \"179 cms\",\n\"Likes\": \"Justice\",\n\"Occupation\": \"QA\",\n\"Weight\": \"94.1 kgs\"\n}},\n{\n\"oid\": \"8b8972c3b3114db2a0acdfa2617693bf\",\n\"lastUpdated\": 1344428184385,\n\"lastUpdatedTime\": \"2012-08-08T12:16:24Z\",\n\"created\": 1344428184385,\n\"createdTime\": \"2012-08-08T12:16:24Z\",\n\"data\": {\n\"BloodType\": \"A\",\n\"Dislikes\": \"Evil\",\n\"EyeColor\": \"Brown\",\n\"HairColor\": \"Brown\",\n\n\n## More Information\n\nds.search Examples\n\n## ds.search Examples REST\n\n## Description\n\nThis page shows examples using the ds.search REST API.\n\n## Examples\n\n```\n. Examples of searching objects by UID:\n```\n```\n1.1 First associate an object to a UID using ds.store:\n```\n```\n1.2 Search objects by UID:\n```\n```\n\"Height\": \"179 cms\",\n\"Likes\": \"Justice\",\n\"Occupation\": \"QA\",\n\"Weight\": \"94.1 kgs\"\n}},\n{\n\"oid\": \"super1\",\n\"lastUpdated\": 1344172332701,\n\"lastUpdatedTime\": \"2012-08-05T13:12:12Z\",\n\"created\": 1344172332701,\n\"createdTime\": \"2012-08-05T13:12:12Z\",\n\"data\": {\n\"BloodType\": \"A\",\n\"Dislikes\": \"Evil\",\n\"EyeColor\": \"Brown\",\n\"HairColor\": \"Brown\",\n\"Height\": \"179 cms\",\n\"Likes\": \"Justice\",\n\"Occupation\": \"QA\",\n\"Weight\": \"94.1 kgs\"\n}}],\n\"objectsCount\": 9,\n\"totalCount\": 9,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"fb5e8b258afc4016ad454cc9fd1d64ec\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```\n```\nds.store({\ndata:{bands:{rock:'zeppelin', jazz:'coltrain'}},\ntype:'music',\noid:'auto',\nUID='_gid_PJwNlJ5N11BLPAXIls8ty6mDdjQD6XzMT2+N/zrztsM='\n});\n```\n```\nSELECT * FROM music WHERE UID='_gid_PJwNlJ5N11BLPAXIls8ty6mDdjQD6XzMT2+N/zrztsM='\n```\n\n```\n1.3 Response to the query:\n```\n. Example of a count of objects:\n\n```\nResponse to the query:\n```\n. Example of a query using limit and start. The query lists 3 elds in a music object where the musician is \"U2\". The query is\nlimited to 5 results, starting with the 100th valid user.\n\n```\nResponse to the query:\n```\n. Example of a query using as. The query lists 3 elds in a music object where the musician is \"U2\". The query will return 5\nresults, starting with the 100th valid user.\n\n```\nResponse to the query:\n```\n##### {\n\n```\n\"results\": [\n{\n\"data\": {\n\"bands\": {\n\"jazz\": \"coltrain\",\n\"rock\": \"zeppelin\"\n}\n},\n\"lastUpdated\": 1419426021590,\n\"created\": 1419426021590,\n\"lastUpdatedTime\": \"2014-12-24T13:00:21Z\",\n\"createdTime\": \"2014-12-24T13:00:21Z\",\n\"UID\": \"_gid_PJwNlJ5N11BLPAXIls8ty6mDdjQD6XzMT2+N/zrztsM=\",\n\"oid\": \"3dfaa6836ac64711837cb98e3893007a\"\n}\n],\n\"objectsCount\": 1,\n\"totalCount\": 1,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"d126af8d2d21446d867fa67f61cef832\"\n}\n```\n```\nSELECT COUNT(*) FROM music\n```\n```\n{\"results\": [{ \"count(*)\": 1527}],\n\"objectsCount\": 1,\n\"totalCount\": 1527,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"11111\"}\n```\n```\nSELECT music.trackName, music.album, music.format FROM music WHERE music.musician=\"U2\" LIMIT\n```\n```\n{\"results\": [\n{\"music\": {\"trackName\": \"I will follow\", \"format\": \"mp3\"} },\n{\"music\": {\"trackName\": \"Into the Heart\", \"album\": \"Boy\", \"format\": \"mp3\" } },\n{\"music\": {\"trackName\": \"The Ocean\", \"album\": \"Boy\" } },\n{\"music\": {\"trackName\": \"A Day Without Me\", \"album\": \"Boy\", \"format\": \"mp3\" } },\n{\"music\": {\"trackName\": \"Shadowns and Tall Trees\", \"album\": \"Boy\", \"format\": \"mp3\" } } ],\n\"objectsCount\": 5,\n\"totalCount\": 1840,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"2222\" }\n```\n```\nSELECT music.trackName AS Track, music.album AS Disk, music.format AS Extension FROM music WH\n```\n\n```\nResponse to the query:\n```\n. Example of a query using contains. This query counts pictures of \"Madrid\":\n\n```\nResponse to the query\n```\n. Example of a query using regex. This query searches for photos starting with the letter \"A\".\n\n```\nResponse to the query:\n```\n```\n{\"results\": [\n{\"music\": {\"Track\": \"I will follow\", \"Extension\": \"mp3\" } },\n{\"music\": {\"Track\": \"Into the Heart\", \"Disk\": \"Boy\", \"Extension\": \"mp3\" } },\n{\"music\": {\"Track\": \"The Ocean\", \"Disk\": \"Boy\" } },\n{\"music\": {\"Track\": \"A Day Without Me\", \"Disk\": \"Boy\", \"Extension\": \"mp3\" } },\n{\"music\": {\"Track\": \"Shadows and Trees\",\"Disk\": \"Boy\", \"Extension\": \"mp3\" } } ],\n\"objectsCount\": 5,\n\"totalCount\": 1840,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"2222\" }\n```\n```\n{\"results\": [\n{\"music\": {\"Track\": \"I will follow\", \"Extension\": \"mp3\" } },\n{\"music\": {\"Track\": \"Into the Heart\", \"Disk\": \"Boy\", \"Extension\": \"mp3\" } },\n{\"music\": {\"Track\": \"The Ocean\", \"Disk\": \"Boy\" } },\n{\"music\": {\"Track\": \"A Day Without Me\", \"Disk\": \"Boy\", \"Extension\": \"mp3\" } },\n{\"music\": {\"Track\": \"Shadows and Trees\",\"Disk\": \"Boy\", \"Extension\": \"mp3\" } } ],\n\"objectsCount\": 5,\n\"totalCount\": 1840,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"2222\" }\n```\n```\nSELECT COUNT(*) FROM album WHERE album.photo.title CONTAINS \"Madrid\"\n```\n```\n{ \"results\": [ { \"count(*)\": 28 } ],\n\"objectsCount\": 1,\n\"totalCount\": 28,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"3333\" }\n```\n```\nSELECT album.photo.title FROM album WHERE album.photo.title = regex('A.*')\n```\n##### {\n\n```\n\"results\": [{\n\"album\": {\n\"photo\": {\n\"title:\"At the party\",\n\"title\": \"At the sea\",\n\"industry\": \"Computer Software\" }\n}\n}, {\n\"profile\": {\n\"name\": \"Andy Goslan\",\n\"religion\": \"Atea\",\n\"industry\": \"Computer Software\" }\n}\n],\n\"objectsCount\": 2,\n\"totalCount\": 2,\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n```\n\n## ds.setSchema REST\n\n## Description\n\nThis method allows specifying a schema for a data type in Gigya's Data Store (DS). The schema sets eld names, data types,\n\nformatting and encryption as well as client side access restrictions. Data object schemas act as meta-data, guiding Gigya how to\n\nhandle the data in the specied elds.\n\n```\nDepending on schema setting, other elds can be added to the storage outside the schema, Gigya will add them as is\nwithout special treatment.\n```\n```\nField deletion: a eld in the Data object schema is eligible for deletion if no data has been saved to it. To delete a eld in the\nschema call ds.deleteSchemaFields.\n```\n```\nChanges to schema are incremental, when setting the schema for part of the elds, the properties of the omitted elds\nremain unchanged.\n```\n```\nUnless specied otherwise, schema dened elds are only accessible from the server.\n```\n## Request URL\n\n#### https://ds./ds.setSchema\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\n\"callId\": \"1234567\"\n}\n```\n###  Note\n\n```\nFor security reasons this method is not available for client side SDKs, only for server side SDKs.\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide.\n```\n```\nThe DS is a premium platform that requires separate activation. If the DS is not part of your site package contact your Gigya\nCustomer Engagement Executive or email support@gigya-inc.com.\n```\n\n```\nRequired Name Type Description\n```\n```\ntype string A string indicating the type of\nthe object, equivalent to a\nschema name. The objective of\nthis eld is to classify objects as\nsharing the same schema.\n```\n```\ndataSchema JSON object A JSON object dening the\nschema to be set. See the\nformat denition of the Schema\nObject, below.\n```\n```\nformat string Determines the format of the\nresponse.\n```\n```\njson (default)\n```\n```\nhttpStatusCodes Boolean The default value of this\nparameter is false, which means\nthat the HTTP status code in\nSAP Customer Data Cloud's\nresponse is always 200 (OK),\neven if an error occurs. The\nerror code and message is given\nwithin the response data (see\nbelow). If this parameter is set\nto true, the HTTP status code in\nSAP Customer Data Cloud's\nresponse would reect an error,\nif one occurred.\n```\n## Authorization Parameters\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Schema Object\n\n```\nField Type Description\n```\n```\nelds JSON object This object denes properties per data\nelds. The object contains eld names and\ntheir corresponding list of properties (see\nthe example below). The eld name should\nbe the full path name with dots, i.e.\n\"work.address\".\n```\n```\nThe properties in option are:\n```\n```\ntype - Denes the data type of this\neld. The supported values are\n\"integer\", \"oat\", \"boolean\",\n\"string\", \"date\", \"long\", \"text\" and\n\"binary\".\n```\n```\nWhen the 'type' property is not\nspecied the type will be deduced\nfrom the eld name extension or\nautomatically according to the\ncontent of the rst item. When\ndening a 'binary' eld type, it is not\ninferred from the data must be\ndeclared explicitly through the\n'type' parameter.\n```\n```\nPlease note that eld's type cannot\nbe changed after it contains data.\n```\n```\nwriteAccess - Species whether to\nallow unsigned requests to write\ninto this eld. The supported values\nare:\n```\n```\n\"serverOnly\" (default ) -\nOnly signed requests\ncoming from the server are\nallowed.\n```\n```\n\"clientCreate\" - Unsigned\nrequests coming from the\nclient are allowed to write\ninto this eld, only if it\nwasn't set before.\n```\n```\n\"clientModify\" - Unsigned\nrequests coming from the\nclient are allowed to write\ninto this eld and modify\nexisting values.\n```\n```\nformat - Allows assigning a regular\nexpression that denes the format\nof this data eld. Gigya will verify\nthat data set in this data eld\nmatches the format. If the data set\nin this eld doesn't match the\nformat, Gigya will not set the data\n```\n\nField Type Description\n\n```\nand will return an error. The best\npractice is to validate the data\nformat on your client application.\nThe format property accepts a\nstring of the form: \"regex('')\". The\nregex syntax can be found in:\nRegular Expression Language\nReference.\n```\n```\nlanguages - An array of strings\ncontaining languages with which a\ntext eld is compatible, in addition\nto the default languages. A\nmaximum of four such languages\nare supported. The values passed in\nthis property are added to the\nexisting languages in the eld, and if\nthe total number exceeds four\nlanguages, the operation fails.\n```\n```\nencrypt - May be applied to string,\nbasic-string. Passing a value of\n'AES' (the encryption standard\napplied) sets the eld to encrypted.\nWhen string elds are encrypted,\nyou may use them in a search (e.g.\nusing accounts.search) only by\npassing an exact match (such as x =\n\"ABCDE\"), and not partial matches\n(x CONTAINS \"ABC\"). String search\nvalues are case sensitive.\n```\n```\nIf you set the encrypt\nproperty on a eld that\nalready contains data, the\nexisting data will remain un-\nencrypted. Only new data\nwill be encrypted.\n```\n```\nOnce a eld is set to\nencrypt, it cannot be\nundone.\n```\n```\nTo encrypt a eld that is not\nstring or basic-string, use\nthe\nencryptedNonSearchable\nparameter instead\n```\n```\nTo delete a eld from the schema, you\nmust ensure that data has never been\nsaved to it (even if said data has been\ndeleted), it has no dened type, and then\n```\n###  Note\n\n```\nThe only language currently\nsupported for this functionality\nis Japanese.\n```\n\n```\nField Type Description\n```\n```\nset it to null (see \"eld6\" in the example\nbelow). Saving data to a eld automatically\nassigns a type.\n```\n```\nSetting a eld's properties to null will reset\nthe writeAccess property to \"serverOnly\"\n(without deleting the eld), if the eld\ncontains/contained data and/or has a type\nsetting.\n```\n```\ndynamicSchema Boolean Species whether the schema is strict or\ndynamic. The default value of this\nparameter is true i.e. dynamic schema. In a\ndynamic schema you may add new elds\nthat are not dened in the schema to the\nDS. The new elds are automatically added\nto the dynamic schema. In a strict schema\nyou can only write into elds that are\nalready dened in the schema.\n```\n## Schema Object Example\n\n## Sample Requests\n\n##### {\n\n```\nfields: {\n\"field1\": {\nwriteAccess:\"clientCreate\",\nformat:\"regex('/^[a-z0-9_-]{3,16}$/')\"\n},\n\"field4\": {\ntype:\"float\"\n},\n\"field5\": {\ntype:\"string\",\nencrypt:\"AES\"\n},\n\"field6\": null,\n\"field7\": {\ntype:\"text\",\nlanguages:[\"ja\"]\n}\n},\ndynamicSchema: false\n}\n```\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n### Response Example\n\n## ds.store REST\n\n## Description\n\nStores an object data in SAP Customer Data Cloud's Data Store (DS). The Data Store is only available for use with fully registered\n\naccounts.\n\n## Request URL\n\n#### https://ds./ds.store\n\nWhere is:\n\n#### us1.gigya.com - For the US data center.\n\n##### {\n\n```\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"31ba039fb8d340ceb2f43d52c89bf187\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```\n###  Note\n\n```\nIf you plan on integrating the DS, we highly recommend reading the Data Store Guide. The DS is part of the Customer Identity\npremium package that requires separate activation. If the DS is not part of your site package contact your SAP Customer Data\nCloud Customer Engagement Executive or email support@gigya-inc.com.\n```\n\n#### eu1.gigya.com - For the European data center.\n\n#### au1.gigya.com - For the Australian data center.\n\n#### eu2.gigya.com - For the European Azure data center.\n\n#### cn1.sapcdm.cn - For the Chinese data center.\n\n#### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n## Parameters\n\n```\nRequired Name Type Description\n```\n```\ndata JSON object Species the data to store. The data object\nshould be specied as a JSON object\ncomplying with the following restrictions:\n```\n```\nA maximum size of 512K of data.\n```\n```\nUser dened eld names must\nbegin with a character and may\ncontain characters, digits and\nunderscores.\n```\n```\nWe highly recommend that you give\nevery eld a type specication by\nappending the type to the eld\nname in the following manner: \"_\".\nValid types are:\n```\n```\ni - an integer number (may\ncontain 64bit long values\nas well), allows exact\nmatching or range\nsearches.\n```\n```\nf - a oating point number,\nallows exact matching or\nrange searches.\n```\n```\ns - a string only allows\nexact matching.\n```\n```\nt - a full text search eld,\nallows for partial searching\nbased on keywords.\n```\n```\nb - Boolean.\n```\n```\nd - a date eld, allows exact\nmatching or range\nsearches. The valid date\nformats are:\n```\n```\nStandard ISO time\nformat (like \"2011-\n07-\n14T11:42:32.123+3\",\nmay be specied\n```\n\nRequired Name Type Description\n\n```\nwithout a time at all\nor without a time\nzone)\n```\n```\n\"YYYY-MM-DD\nHH:MM:SS\"\n```\n```\nWhen the eld type is not specied\nexplicitly we will try to auto detect\nit. Fields that fail auto detection will\nbe considered strings.\n```\n```\nFor example:\n```\n```\n{ rstName_s : \"david\", birthDate_d : \"1978-\n07-22\", about_t : \"I love tracking,...\",\nacademicDegree : { university_s:\n\"Berkeley\", degree_s: \"MBA\",\ndepartment_s: \"Business\", courses : [{...},\n{...},...] }, hobbies_s: [\"running\", \"music\",\n\"movies\"]}\n```\n```\nImportant\n```\n```\nWhen saving data as a nested eld, it is\nimportant to save the object in the format\nbelow:\n```\n```\nand not as:\n```\n```\nDS always returns an object as it was\nsubmitted, this is different than other SAP\nCustomer Data Cloud schemas, which\nexpand nested objects automatically.\n```\n```\ntype string A string indicating the type of the object,\nequivalent to a name classifying objects as\nbeing of the same type; used in searches\nand when applying schemas.\n```\n###  Note\n\n```\nWhen dening a 'binary' eld\ntype, it is not inferred from the\ndata, and must be set explicitly\nusing the 'setSchema' method.\n```\n```\n// Correct\n{\n'a': {\n'b': 'value'\n}\n}\n```\n```\n// Incorrect\n{\na.b:'value'\n}\n```\n\n```\nRequired Name Type Description\n```\n```\noid string A unique object identier. If this parameter\nis set with the \"auto\" value, SAP Customer\nData Cloud will generate a unique ID for the\nobject.\n```\n```\nUID string A unique ID of a user. Setting this\nparameter associates the data object with\nthe specied user. The identier of this\nobject is the compound of oid and UID.\n```\n```\nupdateBehavior string This parameter denes how to handle\nconicting updates. The parameter may\nreceive one of the following values:\n```\n```\n\"arrayPush\" (default) - will cause\narrays data provided with this API\ncall to be appended to existing\narrays data in the DB.\n```\n```\n\"arraySet\" - will replace the content\nof existing arrays data in the DB\nwith the values of arrays data\nprovided with this API call.\n```\n```\n\"replace\" - will cause the entire\nobject data in the DB to be\nreplaced with the new data\nprovided with this call.\n```\n```\nformat string Determines the format of the response.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to pass data\nthrough the current method and return it,\nunchanged, within the response.\n```\n```\nignoreInterruptions Boolean This may be used in some cases to\nsuppress logic applied by the Web SDK,\nsuch as automatic opening of screens (e.g.,\nin a registration completion scenario). This\nparameter may not be used with REST\nAPIs.\n```\n```\nhttpStatusCodes Boolean The default value of this parameter is false,\nwhich means that the HTTP status code in\nSAP Customer Data Cloud's response is\nalways 200 (OK), even if an error occurs.\nThe error code and message is given within\nthe response data (see below). If this\nparameter is set to true, the HTTP status\ncode in SAP Customer Data Cloud's\nresponse would reect an error, if one\noccurred.\n```\n## Authorization Parameters\n\n\nEach REST API request must contain identication and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n```\naccounts.login\n```\n```\nsocialize.login\n```\n```\naccounts.notifyLogin\n```\n```\nsocialize.notifyLogin\n```\n```\naccounts.nalizeRegistration\n```\n```\naccounts.linkAccounts\n```\nPlease refer to the Authorization Parameters section for details.\n\n## Sample Requests\n\n###  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n## Response Data\n\n```\nField Type Description\n```\n```\napiVersion integer Denes the API version that returned the\nresponse and may not always be returned.\n```\n```\ncallId string Unique identier of the transaction, for\ndebugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0'\nindicates success, any other number\nindicates failure. For a complete list of error\ncodes, see the Error Codes table.\n```\n```\nerrorDetails string This eld will appear in the response only in\ncase of an error and will contain the\nexception info, if available.\n```\n```\nerrorMessage string A short textual description of an error,\nassociated with the errorCode, for logging\npurposes. This eld will appear in the\nresponse only in case of an error.\n```\n```\nCopyright Disclaimer Privacy Statement Legal Disclosure Trademark Terms of Use\n```\n\n```\nField Type Description\n```\n```\nfullEventName string The full name of the event that triggered\nthe response. This is an internally used\nparameter that is not always returned and\nshould not be relied upon by your\nimplementation.\n```\n```\ntime string The time of the response represented in\nISO 8601 format: yyyy-mm-dd-\nThh:MM:ss.SSSZ (for example, 2021-03-\n05T06:11:31.513Z)\n```\n```\nstatusCode integer The HTTP response code of the operation.\nCode '200' indicates success.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only\nreturned for backward compatibility.\n```\n```\noid string The object's unique identier. The value is\neither the oid parameter that you specied\nin the API call or a unique string generated\nby SAP Customer Data Cloud (if you have\nset the parameter to be \"auto\").\n```\n### Response Example\n\n##### {\n\n```\n\"oid\": \"8b8972c3b3114db2a0acdfa2617693bf\",\n\"statusCode\": 200,\n\"errorCode\": 0,\n\"statusReason\": \"OK\",\n\"callId\": \"bcb794e7b8ca41b1b3baf99e7bc1c86a\",\n\"time\": \"2015-03-22T11:42:25.943Z\"\n}\n```",[],[237,254],{"_105":262,"_97":263,"_167":264,"_169":238,"_170":148,"_171":265,"_173":119,"_107":266,"_102":267,"_175":248,"_177":268,"_178":22,"_179":-5,"_180":269,"_100":270},"fa4d6be4-129e-11f1-ac32-42dde27851f2","groups.md","63a65396-129d-11f1-917c-42dde27851f2",26,["D",1772060943847],3,"## accounts.groups.finalizeInvitation REST\n\nThis API finalizes the group invitation by adding the user to the group.\n\n### Request URL\n\n##### https://accounts./accounts.groups.finalizeInvitation\n\nWhere is:\n\n##### us1.gigya.com - For the US data center.\n\n##### eu1.gigya.com - For the European data center.\n\n##### au1.gigya.com - For the Australian data center.\n\n##### eu2.gigya.com - For the European Azure data center.\n\n##### cn1.sapcdm.cn - For the Chinese data center.\n\n##### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n### Parameters\n\n###### {\n\n```\n\"callId\": \"26254b038410468bb5a3a344134fd88b\",\n\"errorCode\": 0,\n\"apiVersion\": 2,\n\"statusCode\": 200,\n\"statusReason\": \"OK\",\n\"time\": \"2018-12-11T12:52:24.250Z\"\n}\n```\n####  Note\n\n```\nPrior to calling this API, make sure to set the “invitation URL” by calling accounts.groups.setSiteConfig REST.\n```\n####  Note\n\n```\nCertain APIs are not supported on all data centers. The specific API documentation will define if there are any data center\nrestrictions for the API.\n```\n\n```\nRequired Name Type Description\n```\n```\ntoken string The invitation token.\n```\n```\nuid string The user ID assigned to the group invitation.\n```\n```\nThe uid or login_token are required.\n```\n```\nlogin_token string The login token for the user assigned to the group invitation.\n```\n```\nThe uid or login_token are required.\n```\n```\nformat string Determines the format of the response.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to pass data through the current method and return it,\nunchanged, within the response.\n```\n```\nhttpStatusCodes Boolean The default value of this parameter is false, which means that the HTTP status code in\nSAP Customer Data Cloud's response is always 200 (OK), even if an error occurs. The\nerror code and message is given within the response data (see below). If this parameter is\nset to true, the HTTP status code in SAP Customer Data Cloud's response would reflect an\nerror, if one occurred.\n```\n### Authorization Parameters\n\nEach REST API request must contain identification and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n##### accounts.login\n\n##### socialize.login\n\n##### accounts.notifyLogin\n\n##### socialize.notifyLogin\n\n##### accounts.finalizeRegistration\n\n##### accounts.linkAccounts\n\nPlease refer to the Authorization Parameters section for details.\n\n### Sample Requests\n\n####  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n### Response Data\n\n```\nName Type Description\n```\n```\napiVersion integer Defines the API version that returned the response and may not always be available.\n```\n```\ncallId string Unique identifier of the transaction, for debugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0' indicates success, any other number indicates failure. For a\ncomplete list of error codes, see the Error Codes table.\n```\n```\nerrorDetails string This field will appear in the response only in case of an error and will contain the exception info, if available.\n```\n```\nerrorMessage string A short textual description of an error, associated with the errorCode, for logging purposes. This field will\nappear in the response only in case of an error.\n```\n```\nfullEventName string The full name of the event that triggered the response. This is an internally used parameter that is not always\nreturned and should not be relied upon by your implementation.\n```\n```\ntime string The time of the response represented in ISO 8601 format, i.e., yyyy-mm-dd-Thh:MM:ss.SSSZ or 2021-03-\n05T06:11:31.513Z\n```\n```\nstatusCode integer The HTTP response code of the operation. Code '200' indicates success.\n```\n```\nThis property is deprecated and only returned for backward compatibility.\n```\n\n```\nName Type Description\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only returned for backward compatibility.\n```\n```\nmodel string The group's model.\n```\n```\ngroupId string The group's ID.\n```\n### Response Example\n\n## accounts.groups.getAllMemberGroups REST\n\nReturns the user's groups.\n\n### Request URL\n\n##### https://accounts./accounts.groups.getAllMemberGroups\n\nWhere is:\n\n##### us1.gigya.com - For the US data center.\n\n##### eu1.gigya.com - For the European data center.\n\n##### au1.gigya.com - For the Australian data center.\n\n##### eu2.gigya.com - For the European Azure data center.\n\n##### cn1.sapcdm.cn - For the Chinese data center.\n\n##### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n### Parameters\n\n###### {\n\n```\n\"callId\": \"17e71c8375614cd1bfe55a4e0122c049\",\n\"errorCode\": 0,\n\"apiVersion\": 2,\n\"statusCode\": 200,\n\"statusReason\": \"OK\",\n\"time\": \"2022-06-14T15:10:44.042Z\",\n\"model\": \"Family\",\n\"groupId\": \"Gur\"\n}\n```\n####  Note\n\n```\nCertain APIs are not supported on all data centers. The specific API documentation will define if there are any data center\nrestrictions for the API.\n```\n\n```\nRequired Name Type Description\n```\n```\nUID string The SAP Customer Data Cloud UID of the user.\n```\n```\nThe UID is optional if you pass the login token otherwise it is required.\n```\n```\nformat string Determines the format of the response.\n```\n```\njson (default)\n```\n```\ncontext string/JSON This parameter may be used to pass data through the current method and return it,\nunchanged, within the response.\n```\n```\nhttpStatusCodes Boolean The default value of this parameter is false, which means that the HTTP status code in\nSAP Customer Data Cloud's response is always 200 (OK), even if an error occurs. The\nerror code and message is given within the response data (see below). If this parameter is\nset to true, the HTTP status code in SAP Customer Data Cloud's response would reflect an\nerror, if one occurred.\n```\n### Authorization Parameters\n\nEach REST API request must contain identification and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n##### accounts.login\n\n##### socialize.login\n\n##### accounts.notifyLogin\n\n##### socialize.notifyLogin\n\n##### accounts.finalizeRegistration\n\n##### accounts.linkAccounts\n\nPlease refer to the Authorization Parameters section for details.\n\n### Sample Requests\n\n####  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n### Response Data\n\n```\nName Type Description\n```\n```\napiVersion integer Defines the API version that returned the response and may not always be available.\n```\n```\ncallId string Unique identifier of the transaction, for debugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0' indicates success, any other number indicates failure. For a complete\nlist of error codes, see the Error Codes table.\n```\n```\nerrorDetails string This field will appear in the response only in case of an error and will contain the exception info, if available.\n```\n```\nerrorMessage string A short textual description of an error, associated with the errorCode, for logging purposes. This field will\nappear in the response only in case of an error.\n```\n```\ntime string The time of the response represented in ISO 8601 format, i.e., yyyy-mm-dd-Thh:MM:ss.SSSZ or 2021-03-\n05T06:11:31.513Z\n```\n```\nstatusCode integer The HTTP response code of the operation. Code '200' indicates success.\n```\n```\nThis property is deprecated and only returned for backward compatibility.\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only returned for backward compatibility.\n```\n\n```\nName Type Description\n```\n```\nresults array An array of groups the user is a member of, with the user's membership details.\n```\n### Response Example\n\n## accounts.groups.getAllModels REST\n\nThis API returns all existing models for the requested API key.\n\n### Request URL\n\n##### https://accounts./accounts.groups.getAllModels\n\nWhere is:\n\n##### us1.gigya.com - For the US data center.\n\n##### eu1.gigya.com - For the European data center.\n\n##### au1.gigya.com - For the Australian data center.\n\n##### eu2.gigya.com - For the European Azure data center.\n\n##### cn1.sapcdm.cn - For the Chinese data center.\n\n##### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n###### {\n\n```\n\"callId\": \"b42093126efa4c0fb8f9651a570a928c\",\n\"errorCode\": 0,\n\"apiVersion\": 2,\n\"statusCode\": 200,\n\"statusReason\": \"OK\",\n\"time\": \"2022-08-17T13:57:05.305Z\",,\n\"results\": [\n{\n\"groupId\": \"123\",\n\"model\": \"OrgModel111\",\n```\n```\n\"relationshipData\": {},\n\"memberSince\": \"2022-08-16T14:54:04.486Z\",\n\"lastUpdated\": \"2022-08-16T14:54:04.486Z\",\n\"memberSinceTimestamp\": 1660661644486,\n\"lastUpdatedTimestamp\": 1660661644486,\n\"permissions\": \"groupRead,groupWrite,groupDelete\",\n\"groupData\": {\n\"zipcode\": \"123456\",\n\"country\": \"Israel\",\n\"membersLimit\": 300,\n\"city\": \"Tel Aviv\",\n\"streetaddress\": \"street1\",\n\"source\": \"IMPORT\",\n\"state\": \"Israel\",\n\"type\": \"CUSTOMER\"\n}\n}\n]\n}\n```\n\n### Parameters\n\n```\nRequired Name Type Description\n```\n```\nincludeEmailTemplates boolean This parameter is optional, if true the model's groupInviteConfig data is included in the\nresponse.\n```\n### Authorization Parameters\n\nEach REST API request must contain identification and authorization parameters.\n\nSome REST APIs may function without these authorization parameters, however, when that occurs, these calls are treated as\n\nclient-side calls and all client-side rate limits will apply. In order to not reach client-side IP rate limits that may impact your\n\nimplementation when using server-to-server REST calls, it is Recommended Best Practice to always use an application key and\n\nsecret or a bearer token when sending requests. A non-exhaustive list of REST APIs that this may apply to are as follows:\n\n##### accounts.login\n\n##### socialize.login\n\n##### accounts.notifyLogin\n\n##### socialize.notifyLogin\n\n##### accounts.finalizeRegistration\n\n##### accounts.linkAccounts\n\nPlease refer to the Authorization Parameters section for details.\n\n### Sample Requests\n\n####  Note\n\n```\nCertain APIs are not supported on all data centers. The specific API documentation will define if there are any data center\nrestrictions for the API.\n```\n####  Note\n\n```\nFor details on the group invitation flow, see the Group Invitation section on the Email\nTemplates page.\n```\n####  Note\n\n```\nAs of January 31, 2023, you may no longer use a Partner Secret as a valid authentication method for requests to SAP Customer\nData Cloud servers.\n```\n\n### Response Data\n\n```\nName Type Description\n```\n```\napiVersion integer Defines the API version that returned the response and may not always be returned.\n```\n```\ncallId string Unique identifier of the transaction, for debugging purposes.\n```\n```\nerrorCode integer The result code of the operation. Code '0' indicates success, any other number indicates failure. For a\ncomplete list of error codes, see the Error Codes table.\n```\n```\nerrorDetails string This field will appear in the response only in case of an error and will contain the exception info, if available.\n```\n```\nerrorMessage string A short textual description of an error, associated with the errorCode, for logging purposes. This field will\nappear in the response only in case of an error.\n```\n```\nfullEventName string The full name of the event that triggered the response. This is an internally used parameter that is not always\nreturned and should not be relied upon by your implementation.\n```\n```\ntime string The time of the response represented in ISO 8601 format, i.e., yyyy-mm-dd-Thh:MM:ss.SSSZ or 2021-03-\n05T06:11:31.513Z\n```\n```\nstatusCode integer The HTTP response code of the operation. Code '200' indicates success.\n```\n```\nThis property is deprecated and only returned for backward compatibility.\n```\n\n```\nName Type Description\n```\n```\nstatusReason string A brief explanation of the status code.\n```\n```\nThis property is deprecated and only returned for backward compatibility.\n```\n```\nmodels array An array containing all the existing models for the requested API key.\n```\n```\nmodel - Model name\n```\n```\nselfProvisioning - If true the group based on this model can be created by users, otherwise users can\nnot create a new group based on this model.\n```\n```\ngroupInviteConfig - The group invitation configuration details. The configuration details will be\nreturned if includeEmailTemplates is set to true in the parameters.\n```\n### Response Example\n\n###### {\n\n```\n\"callId\": \"dbc9910f05a246878d128c50773e180b\",\n\"errorCode\": 0,\n\"apiVersion\": 2,\n\"statusCode\": 200,\n\"statusReason\": \"OK\",\n\"time\": \"2022-06-20T09:22:18.362Z\",\n\"models\": [\n{\n\"model\": \"Model 2\",\n\"selfProvisioning\": false,\ngroupInviteConfig: {\n\"landingPage\": \"http://localhost/melodi\",\n\"expiration\": 300,\n\"defaultLang\": \"en\",\n\"emailTemplates\": {\n\"en\": \"/accounts.groups.getGroupInfo\n\nWhere is:\n\n##### us1.gigya.com - For the US data center.\n\n##### eu1.gigya.com - For the European data center.\n\n##### au1.gigya.com - For the Australian data center.\n\n##### eu2.gigya.com - For the European Azure data center.\n\n##### cn1.sapcdm.cn - For the Chinese data center.\n\n##### global.gigya.com - For all Global site groups.\n\nIf you are not sure of your site's data center, see Finding Your Data Center.\n\n### Parameters\n\n```\nRequired Name Type Description\n```\n```\nmodel string The model this group is based upon.\n```\n```\ngroupId string The groupId of the group to return.\n```\n### Authorization Parameters\n\nEach REST API request must contain identification and authorization parameters.\n\n###### ]\n\n###### }",[],[237,263],[237],{"_105":273,"_97":274,"_167":275,"_169":-5,"_170":148,"_171":172,"_173":119,"_107":276,"_102":33,"_175":176,"_177":-5,"_178":22,"_179":-5,"_180":277,"_100":321},"c4cb0d5a-1299-11f1-935e-42dde27851f2","dsviewer","019c96ee-0299-75ff-a0e5-0acfa7a4e1a6",["D",1772058706545],[278,315],{"_105":279,"_97":184,"_167":280,"_169":275,"_170":148,"_171":172,"_173":119,"_107":281,"_102":33,"_175":176,"_177":-5,"_178":22,"_179":-5,"_180":282,"_100":314},"c4cae1ae-1299-11f1-935e-42dde27851f2","019c96ee-0299-75ff-a0e5-01618671f6df",["D",1772058706545],[283,291,299,306],{"_105":284,"_97":285,"_167":286,"_169":280,"_170":148,"_171":172,"_173":119,"_107":287,"_102":33,"_175":193,"_177":288,"_178":22,"_179":-5,"_180":289,"_100":290},"c4ca6120-1299-11f1-935e-42dde27851f2","DSViewer.tsx","019c96ee-0298-70c4-b317-63db012e7190",["D",1772058706545],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\ninterface DSViewerProps {\n type: string;\n data: any[];\n schema: any;\n totalCount: number;\n currentPage: number;\n limit: number;\n search: string;\n}\n\nfunction formatValue(value: any, maxLength: number = 100): { display: string; full?: string } {\n if (value === null || value === undefined) {\n return { display: \"null\" };\n }\n \n if (typeof value === \"object\") {\n const jsonStr = JSON.stringify(value, null, 2);\n if (jsonStr.length > maxLength) {\n return {\n display: `${jsonStr.substring(0, maxLength)}...`,\n full: jsonStr\n };\n }\n return { display: jsonStr };\n }\n \n const str = String(value);\n if (str.length > maxLength) {\n return {\n display: `${str.substring(0, maxLength)}...`,\n full: str\n };\n }\n \n return { display: str };\n}\n\nfunction getFieldsFromData(data: any[]): string[] {\n const fields = new Set();\n \n // Always include metadata fields\n fields.add(\"oid\");\n fields.add(\"created\");\n fields.add(\"lastUpdated\");\n \n // Extract fields from data objects\n data.forEach(item => {\n if (item.data && typeof item.data === \"object\") {\n Object.keys(item.data).forEach(key => fields.add(`data.${key}`));\n }\n if (item.UID) fields.add(\"UID\");\n });\n \n return Array.from(fields).sort();\n}\n\nfunction getNestedValue(obj: any, path: string): any {\n return path.split('.').reduce((current, key) => {\n return current && current[key] !== undefined ? current[key] : null;\n }, obj);\n}\n\nexport function DSViewer({ type, data, schema, totalCount, currentPage, limit, search }: DSViewerProps) {\n const fields = getFieldsFromData(data);\n const totalPages = Math.ceil(totalCount / limit);\n \n return (\n

{type} Data

\n Showing {data.length} of {totalCount} items\n {search && ` (filtered by \"${search}\")`}\n

\n \n {/* Pagination */}\n {totalPages > 1 && (\n

\n {currentPage > 1 && (\n \n Previous\n \n )}\n \n \n Page {currentPage} of {totalPages}\n \n \n {currentPage < totalPages && (\n \n Next\n \n )}\n

\n )}\n

\n\n {data.length === 0 ? (\n

No data found

\n {search ? `No items match \"${search}\"` : `No items in ${type}`}\n

\n ) : (\n

\n \n \n \n {fields.map(field => (\n \n ))}\n \n \n \n \n {data.map((item, index) => (\n \n {fields.map(field => {\n const value = getNestedValue(item, field);\n const formatted = formatValue(value);\n \n return (\n \n );\n })}\n \n \n ))}\n \n

\n {field}\n	Actions
\n {formatted.full ? (\n \n {formatted.display}\n \n ) : (\n {formatted.display}\n )}\n	\n \n \n Edit\n \n \n Delete\n \n \n

\n )}\n\n {/* Schema Information */}\n {schema && (\n

\n View Schema Information\n

\n {JSON.stringify(schema, null, 2)}\n

\n )}\n

\n );\n}",[],[274,184,285],{"_105":292,"_97":293,"_167":294,"_169":280,"_170":148,"_171":172,"_173":119,"_107":295,"_102":33,"_175":193,"_177":296,"_178":22,"_179":-5,"_180":297,"_100":298},"c4ca82b8-1299-11f1-935e-42dde27851f2","DataForm.tsx","019c96ee-0298-70c4-b317-667bc5e64a6b",["D",1772058706545],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\ninterface DataFormProps {\n type: string;\n schema: any;\n data?: any;\n}\n\nfunction getFieldType(fieldName: string, fieldSchema: any): string {\n if (fieldSchema?.type) {\n switch (fieldSchema.type) {\n case \"integer\":\n case \"long\":\n return \"number\";\n case \"float\":\n return \"number\";\n case \"boolean\":\n return \"checkbox\";\n case \"date\":\n return \"datetime-local\";\n case \"text\":\n case \"string\":\n default:\n return \"text\";\n }\n }\n \n // Infer from field name suffix\n if (fieldName.endsWith(\"_i\") || fieldName.endsWith(\"_l\")) return \"number\";\n if (fieldName.endsWith(\"_f\")) return \"number\";\n if (fieldName.endsWith(\"_b\")) return \"checkbox\";\n if (fieldName.endsWith(\"_d\")) return \"datetime-local\";\n \n return \"text\";\n}\n\nfunction getFieldValue(data: any, fieldPath: string): any {\n if (!data) return \"\";\n \n const parts = fieldPath.split(\".\");\n let value = data;\n \n for (const part of parts) {\n if (value && typeof value === \"object\" && part in value) {\n value = value[part];\n } else {\n return \"\";\n }\n }\n \n return value || \"\";\n}\n\nfunction renderField(fieldName: string, fieldSchema: any, value: any, isEdit: boolean): any {\n const fieldType = getFieldType(fieldName, fieldSchema);\n const isRequired = fieldSchema?.required || false;\n const isReadonly = fieldSchema?.writeAccess === \"serverOnly\";\n \n const commonProps = {\n name: fieldName,\n id: fieldName,\n required: isRequired,\n readonly: isReadonly,\n class: `w-full px-3 py-2 border border-gray-300 rounded-md focus:outline-none focus:ring-2 focus:ring-blue-500 ${\n isReadonly ? \"bg-gray-100\" : \"\"\n }`\n };\n\n if (fieldType === \"checkbox\") {\n return (\n \n );\n }\n\n if (fieldType === \"number\") {\n return (\n \n );\n }\n\n if (fieldType === \"datetime-local\") {\n // Convert various date formats to datetime-local format\n let dateValue = \"\";\n if (value) {\n try {\n const date = new Date(value);\n if (!isNaN(date.getTime())) {\n dateValue = date.toISOString().slice(0, 16);\n }\n } catch (e) {\n // Invalid date, leave empty\n }\n }\n \n return (\n \n );\n }\n\n // For complex objects or long text, use textarea\n if (typeof value === \"object\" || (typeof value === \"string\" && value.length > 100)) {\n const displayValue = typeof value === \"object\" ? JSON.stringify(value, null, 2) : value;\n \n return (\n \n );\n }\n\n return (\n \n );\n}\n\nexport function DataForm({ type, schema, data }: DataFormProps) {\n const isEdit = Boolean(data);\n const fields = schema?.fields || {};\n \n // Get all field names from schema and existing data\n const allFields = new Set();\n \n // Add schema fields\n Object.keys(fields).forEach(field => allFields.add(field));\n \n // Add fields from existing data\n if (data?.data) {\n Object.keys(data.data).forEach(field => allFields.add(`data.${field}`));\n }\n \n const fieldList = Array.from(allFields).sort();\n \n return (\n

\n \n

\n {/* Metadata fields for editing */}\n {isEdit && (\n

Metadata (Read-only)

\n OID: {data.oid}\n

\n Created: {data.createdTime || \"N/A\"}\n

\n Last Updated: {data.lastUpdatedTime || \"N/A\"}\n

\n {data.UID && (\n

\n UID: {data.UID}\n

\n )}\n

\n )}\n\n {/* Data fields */}\n

\n {isEdit ? \"Edit\" : \"Create\"} {type} Data\n

\n \n {fieldList.length === 0 ? (\n

No schema defined for this type

\n You can still create data - fields will be auto-detected\n

\n \n Raw JSON Data\n \n \n

\n ) : (\n

\n {fieldList.map(fieldName => {\n const fieldSchema = fields[fieldName] || {};\n const value = getFieldValue(data, fieldName);\n \n return (\n

\n \n {fieldName}\n {fieldSchema.required && *}\n {fieldSchema.writeAccess === \"serverOnly\" && (\n (read-only)\n )}\n \n {renderField(fieldName, fieldSchema, value, isEdit)}\n {fieldSchema.format && (\n

\n Format: {fieldSchema.format}\n

\n )}\n

\n );\n })}\n

\n )}\n

\n\n {/* Actions */}\n

\n \n Cancel\n \n \n {isEdit ? \"Update\" : \"Create\"}\n \n

\n \n\n {/* Schema Information */}\n {schema && Object.keys(fields).length > 0 && (\n

\n View Schema Details\n

\n {JSON.stringify(schema, null, 2)}\n

\n )}\n

\n );\n}",[],[274,184,293],{"_105":300,"_97":215,"_167":301,"_169":280,"_170":148,"_171":172,"_173":119,"_107":302,"_102":33,"_175":193,"_177":303,"_178":22,"_179":-5,"_180":304,"_100":305},"c4cab440-1299-11f1-935e-42dde27851f2","019c96ee-0299-75ff-a0e4-f87af32ee320",["D",1772058706545],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\ninterface LayoutProps {\n title: string;\n children: any;\n}\n\nexport function Layout({ title, children }: LayoutProps) {\n return (\n \n \n \n \n {title}\n \n \n \n \n \n \n

\n {children}\n

\n \n \n \n );\n}",[],[274,184,215],{"_105":307,"_97":308,"_167":309,"_169":280,"_170":148,"_171":172,"_173":119,"_107":310,"_102":33,"_175":193,"_177":311,"_178":22,"_179":-5,"_180":312,"_100":313},"c4cad344-1299-11f1-935e-42dde27851f2","TypeSelector.tsx","019c96ee-0299-75ff-a0e4-fd88c285267d",["D",1772058706545],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\ninterface TypeSelectorProps {\n types: string[];\n selectedType?: string;\n search?: string;\n}\n\nexport function TypeSelector({ types, selectedType, search }: TypeSelectorProps) {\n return (\n

Select Data Type

\n \n

\n {types.map((type) => (\n \n

{type}

\n Click to view data\n

\n \n ))}\n

\n\n {types.length === 0 && (\n

No data types found

\n Make sure your Gigya DS credentials are configured correctly.\n

\n )}\n\n {selectedType && (\n

\n )}\n

\n );\n}",[],[274,184,308],[274,184],{"_105":316,"_97":225,"_167":117,"_169":275,"_170":148,"_171":172,"_173":119,"_107":317,"_102":33,"_175":230,"_177":318,"_178":22,"_179":-5,"_180":319,"_100":320},"c4cae32a-1299-11f1-935e-42dde27851f2",["D",1772058706545],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { DSManager } from \"../shared/ds-manager.ts\";\nimport { DataForm } from \"./components/DataForm.tsx\";\nimport { DSViewer } from \"./components/DSViewer.tsx\";\nimport { Layout } from \"./components/Layout.tsx\";\nimport { TypeSelector } from \"./components/TypeSelector.tsx\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n throw err;\n});\n\n// Initialize DS Manager\nconst dsManager = new DSManager();\n\n// Serve static files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Main page - Type selector and data viewer\napp.get(\"/\", async (c) => {\n try {\n const selectedType = c.req.query(\"type\");\n const page = parseInt(c.req.query(\"page\") || \"1\");\n const limit = parseInt(c.req.query(\"limit\") || \"50\");\n const search = c.req.query(\"search\") || \"\";\n\n // Get all available types\n const types = await dsManager.getTypes();\n\n let data = null;\n let schema = null;\n let totalCount = 0;\n\n if (selectedType) {\n // Get schema for the selected type\n schema = await dsManager.getSchema(selectedType);\n\n // Get data for the selected type\n const result = await dsManager.searchData(selectedType, search, page, limit);\n data = result.data;\n totalCount = result.totalCount;\n }\n\n return c.html(\n \n

DS Store Viewer

\n {selectedType && (\n \n Create New {selectedType}\n \n )}\n

\n\n \n\n {selectedType && data && (\n \n )}\n

\n ,\n );\n } catch (error) {\n return c.html(\n \n

\n Error: {error.message}\n

\n ,\n );\n }\n});\n\n// Create data form\napp.get(\"/create\", async (c) => {\n try {\n const type = c.req.query(\"type\");\n if (!type) {\n return c.redirect(\"/\");\n }\n\n const schema = await dsManager.getSchema(type);\n\n return c.html(\n \n

\n ← Back\n

Create New {type}

\n \n

\n ,\n );\n } catch (error) {\n return c.html(\n \n

\n Error: {error.message}\n

\n ,\n );\n }\n});\n\n// Edit data form\napp.get(\"/edit/:type/:id\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const id = c.req.param(\"id\");\n\n const [schema, item] = await Promise.all([\n dsManager.getSchema(type),\n dsManager.getItem(type, id),\n ]);\n\n if (!item) {\n return c.html(\n \n

\n Item not found\n

\n ,\n );\n }\n\n return c.html(\n \n

\n ← Back\n

Edit {type}

\n \n

\n ,\n );\n } catch (error) {\n return c.html(\n \n

\n Error: {error.message}\n

\n ,\n );\n }\n});\n\n// API Routes\n\n// Get all types\napp.get(\"/api/types\", async (c) => {\n try {\n const types = await dsManager.getTypes();\n return c.json({ success: true, data: types });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Get schema for a type\napp.get(\"/api/schema/:type\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const schema = await dsManager.getSchema(type);\n return c.json({ success: true, data: schema });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Search data\napp.get(\"/api/data/:type\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const search = c.req.query(\"search\") || \"\";\n const page = parseInt(c.req.query(\"page\") || \"1\");\n const limit = parseInt(c.req.query(\"limit\") || \"50\");\n\n const result = await dsManager.searchData(type, search, page, limit);\n return c.json({ success: true, data: result });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Get single item\napp.get(\"/api/data/:type/:id\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const id = c.req.param(\"id\");\n const item = await dsManager.getItem(type, id);\n\n if (!item) {\n return c.json({ success: false, error: \"Item not found\" }, 404);\n }\n\n return c.json({ success: true, data: item });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Create item\napp.post(\"/api/data/:type\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const body = await c.req.json();\n const item = await dsManager.createItem(type, body);\n return c.json({ success: true, data: item });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Update item\napp.put(\"/api/data/:type/:id\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const id = c.req.param(\"id\");\n const body = await c.req.json();\n const item = await dsManager.updateItem(type, id, body);\n return c.json({ success: true, data: item });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Delete item\napp.delete(\"/api/data/:type/:id\", async (c) => {\n try {\n const type = c.req.param(\"type\");\n const id = c.req.param(\"id\");\n await dsManager.deleteItem(type, id);\n return c.json({ success: true });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Execute custom query\napp.post(\"/api/query\", async (c) => {\n try {\n const { query } = await c.req.json();\n const result = await dsManager.executeQuery(query);\n return c.json({ success: true, data: result });\n } catch (error) {\n return c.json({ success: false, error: error.message }, 500);\n }\n});\n\n// Health check\napp.get(\"/api/health\", (c) => {\n return c.json({\n success: true,\n timestamp: new Date().toISOString(),\n service: \"Generic DS Store Viewer\",\n });\n});\n\nexport default app.fetch;",[],[274,225],[274],{"_105":323,"_97":324,"_167":325,"_169":-5,"_170":148,"_171":326,"_173":119,"_107":327,"_102":33,"_175":176,"_177":-5,"_178":22,"_179":-5,"_180":328,"_100":408},"eb8003be-12f9-11f1-a162-42dde27851f2","groupmanager","eb80049a-12f9-11f1-a162-42dde27851f2",29,["D",1772100003231],[329,338,349,360,369,378,389,398],{"_105":330,"_97":331,"_167":332,"_169":325,"_170":148,"_171":333,"_173":119,"_107":334,"_102":33,"_175":248,"_177":335,"_178":22,"_179":-5,"_180":336,"_100":337},"42add8d4-1302-11f1-9f55-42dde27851f2","app.js","42add988-1302-11f1-9f55-42dde27851f2",44,["D",1772103585464],"const state = {\n users: [], selectedUIDs: new Set(), groups: [],\n selectedAction: null, actionParams: {}, currentStep: 1, results: null,\n};\n\nconst ACTIONS = [\n {\n id: \"addToGroup\", label: \"Add to Group\", icon: \"👥\",\n desc: \"Assign selected users to a Gigya group\",\n params: [\n { key: \"groupID\", label: \"Group\", type: \"group_select\", required: true },\n { key: \"roleSetID\", label: \"Role Set ID (optional)\", type: \"text\", placeholder: \"e.g. member\" },\n { key: \"data\", label: \"Membership Data (JSON)\", type: \"json\", placeholder: '{\"tier\":\"gold\"}' },\n ],\n },\n {\n id: \"removeFromGroup\", label: \"Remove from Group\", icon: \"🚫\",\n desc: \"Remove selected users from a group\",\n params: [\n { key: \"groupID\", label: \"Group\", type: \"group_select\", required: true },\n ],\n },\n {\n id: \"updateRelationship\", label: \"Update Relationship\", icon: \"🔗\",\n desc: \"Modify group relationship / membership data\",\n params: [\n { key: \"groupID\", label: \"Group\", type: \"group_select\", required: true },\n { key: \"relationshipData\", label: \"Relationship Data (JSON)\", type: \"json\", placeholder: '{\"role\":\"admin\",\"tier\":\"vip\"}' },\n ],\n },\n {\n id: \"sendInvitation\", label: \"Send Invitation\", icon: \"✉️\",\n desc: \"accounts.groups.invitation.send — invite users to a group by email\",\n params: [\n { key: \"groupId\", label: \"Group\", type: \"group_select\", required: true },\n { key: \"model\", label: \"Model ID\", type: \"text\", required: true, placeholder: \"e.g. playground-access\" },\n { key: \"type\", label: \"Invitation Type\", type: \"select\", required: true, options: [\"emailLink\"], default: \"emailLink\" },\n { key: \"channel\", label: \"Email Channel Override\", type: \"text\", placeholder: \"Leave blank — uses each user's profile.email\" },\n { key: \"memberInfo\", label: \"Member Info (JSON)\", type: \"json\", placeholder: '{\"firstName\":\"Jane\",\"lastName\":\"Doe\"}' },\n { key: \"adminInfo\", label: \"Admin / Inviter Info (JSON)\", type: \"json\", placeholder: '{\"firstName\":\"Admin\",\"lastName\":\"User\"}' },\n { key: \"language\", label: \"Language\", type: \"text\", placeholder: \"en\", default: \"en\" },\n { key: \"relationship\", label: \"Relationship Data (JSON)\", type: \"json\", placeholder: '{\"emailDomain\":\"sap.com\"}' },\n { key: \"permissions\", label: \"Permissions (comma-sep)\", type: \"text\", placeholder: \"groupRead,groupWrite,membersInvite,membersRemove\" },\n ],\n },\n {\n id: \"setAccountData\", label: \"Update Account Data\", icon: \"📝\",\n desc: \"Bulk-update custom data / profile fields\",\n params: [\n { key: \"data\", label: \"Data Fields (JSON)\", type: \"json\", placeholder: '{\"newsletter\":true,\"tier\":\"premium\"}' },\n { key: \"profile\", label: \"Profile Fields (JSON, optional)\", type: \"json\", placeholder: '{\"age\":30}' },\n ],\n },\n {\n id: \"sendEmail\", label: \"Send OTP / Email\", icon: \"📧\",\n desc: \"Trigger an OTP email for selected users\",\n params: [\n { key: \"lang\", label: \"Language\", type: \"text\", placeholder: \"en\", default: \"en\" },\n ],\n },\n];\n\nwindow.addEventListener(\"DOMContentLoaded\", () => { renderActionGrid(); fetchGroups(); });\n\nasync function fetchGroups() {\n const res = await fetch(\"./api/groups\");\n const d = await res.json();\n state.groups = d.groups || [];\n}\n\nfunction setFilter(f) { document.getElementById(\"filter-input\").value = f; }\n\n// ── Step 1 ─────────────────────────────────────────────────────\nasync function searchUsers() {\n const filter = document.getElementById(\"filter-input\").value.trim();\n const limit = document.getElementById(\"limit-input\").value;\n const spin = document.getElementById(\"search-spin\");\n const btn = document.getElementById(\"btn-search\");\n spin.classList.remove(\"hidden\"); btn.disabled = true;\n try {\n const params = new URLSearchParams({ limit });\n if (filter) params.set(\"filter\", filter);\n const res = await fetch(\"./api/users?\" + params);\n const d = await res.json();\n if (!d.success) throw new Error(d.error);\n state.users = d.users;\n state.selectedUIDs = new Set(d.users.map(u => u.UID));\n renderUsersTable(); updateSelectedCount();\n activateStep(2); updateProgress(2);\n } catch(e) { alert(\"Search failed: \" + e.message); }\n finally { spin.classList.add(\"hidden\"); btn.disabled = false; }\n}\n\n// ── Step 2 ─────────────────────────────────────────────────────\nfunction renderUsersTable() {\n const container = document.getElementById(\"users-table\");\n document.getElementById(\"user-count-badge\").textContent = state.users.length + \" users found\";\n if (!state.users.length) {\n container.innerHTML = '

No users found.

';\n return;\n }\n const rows = state.users.map(function(u) {\n const name = [u.profile && u.profile.firstName, u.profile && u.profile.lastName].filter(Boolean).join(\" \") || \"—\";\n const email = (u.profile && u.profile.email) || \"—\";\n const grps = ((u.groups && u.groups.groups) || []).map(function(g) { return g.groupID || g.id; }).join(\", \") || \"none\";\n const chkAttr = state.selectedUIDs.has(u.UID) ? \"checked\" : \"\";\n const selectedClass = state.selectedUIDs.has(u.UID) ? \"selected\" : \"\";\n const uidShort = (u.UID || \"\").slice(0,16);\n return (\n '' +\n '' +\n '

' + name + '

' + email + '

' +\n '' + uidShort + '…' +\n '' + grps + '' +\n '' +\n '' +\n '' +\n '

' + JSON.stringify(u, null, 2) + '

' +\n ''\n );\n }).join(\"\");\n\n container.innerHTML =\n '' +\n '' +\n '' +\n '' +\n '' +\n '' +\n '' +\n '' +\n '' +\n '' +\n '' + rows + '' +\n '

	Name / Email	UID	Groups

';\n\n document.getElementById(\"btn-next-2\").disabled = state.selectedUIDs.size === 0;\n}\n\nfunction toggleDetail(uid) {\n const el = document.getElementById(\"detail-\" + uid);\n if (el) el.classList.toggle(\"hidden\");\n}\n\nfunction toggleUser(uid, checked) {\n checked ? state.selectedUIDs.add(uid) : state.selectedUIDs.delete(uid);\n const row = document.getElementById(\"row-\" + uid);\n if (row) row.classList.toggle(\"selected\", checked);\n updateSelectedCount();\n document.getElementById(\"btn-next-2\").disabled = state.selectedUIDs.size === 0;\n}\n\nfunction selectAll(checked) {\n state.users.forEach(function(u) {\n checked ? state.selectedUIDs.add(u.UID) : state.selectedUIDs.delete(u.UID);\n const row = document.getElementById(\"row-\" + u.UID);\n if (row) {\n row.classList.toggle(\"selected\", checked);\n const cb = row.querySelector(\"input[type=checkbox]\");\n if (cb) cb.checked = checked;\n }\n });\n const mc = document.getElementById(\"select-all-cb\");\n if (mc) mc.checked = checked;\n updateSelectedCount();\n document.getElementById(\"btn-next-2\").disabled = state.selectedUIDs.size === 0;\n}\n\nfunction updateSelectedCount() {\n const el = document.getElementById(\"selected-count\");\n if (el) el.textContent = state.selectedUIDs.size + \" selected\";\n}\n\nfunction goToStep3() { if (state.selectedUIDs.size === 0) return; activateStep(3); updateProgress(3); }\n\n// ── Step 3 ─────────────────────────────────────────────────────\nfunction renderActionGrid() {\n document.getElementById(\"action-grid\").innerHTML = ACTIONS.map(function(a) {\n return (\n '

' +\n '

' + a.icon + '

' +\n '

' + a.label + '

' +\n '

' + a.desc + '

' +\n '

'\n );\n }).join(\"\");\n}\n\nfunction selectAction(id) {\n state.selectedAction = id;\n document.querySelectorAll(\".action-card\").forEach(function(el) { el.classList.remove(\"selected\"); });\n const card = document.getElementById(\"ac-\" + id);\n if (card) card.classList.add(\"selected\");\n document.getElementById(\"btn-next-3\").disabled = false;\n}\n\nfunction goToStep4() { if (!state.selectedAction) return; renderParamsForm(); activateStep(4); updateProgress(4); }\n\n// ── Step 4 ─────────────────────────────────────────────────────\nfunction renderParamsForm() {\n const action = ACTIONS.find(function(a) { return a.id === state.selectedAction; });\n const form = document.getElementById(\"params-form\");\n if (!action) return;\n\n let header =\n '

' +\n '' + action.icon + ' ' + action.label + ' — ' + action.desc +\n '

';\n\n if (action.id === \"sendInvitation\") {\n const selectedUsers = state.users.filter(function(u) { return state.selectedUIDs.has(u.UID); });\n const emailRows = selectedUsers.slice(0, 5).map(function(u) {\n const em = (u.profile && u.profile.email) ? u.profile.email : '⚠ no email';\n return '

' +\n '' + (u.UID || \"\").slice(0, 14) + '…' +\n '' + em + '' +\n '

';\n }).join(\"\");\n const more = selectedUsers.length > 5\n ? '

…and ' + (selectedUsers.length - 5) + ' more

'\n : \"\";\n header +=\n '

' +\n '📧 Per-user email routing — invitation sent to each user\\'s profile.email unless you set \"Email Channel Override\".
' +\n '

' + emailRows + more + '

' +\n '

';\n }\n\n form.innerHTML = header + action.params.map(renderParamField).join(\"\");\n}\n\nfunction renderParamField(p) {\n const base = \"w-full px-3 py-2 border border-gray-300 rounded-lg focus:outline-none focus:ring-2 focus:ring-indigo-500 text-sm\";\n const req = p.required ? ' *' : '';\n const label = '' + p.label + req + '';\n\n if (p.type === \"group_select\") {\n const opts = state.groups.length\n ? state.groups.map(function(g) {\n return '';\n }).join(\"\")\n : '';\n return '

' + label +\n '

';\n }\n if (p.type === \"select\") {\n const opts = (p.options || []).map(function(o) {\n return '';\n }).join(\"\");\n return '

' + label +\n '

';\n }\n if (p.type === \"checkbox\") {\n const chk = p.default !== false ? \"checked\" : \"\";\n return '

' +\n '' + p.label + req + '' +\n '' +\n '

';\n }\n if (p.type === \"json\") {\n const def = p.default ? JSON.stringify(p.default) : \"\";\n return '

' + label +\n '' +\n '

Enter valid JSON

';\n }\n if (p.type === \"textarea\") {\n return '

' + label +\n '

';\n }\n return '

' + label +\n '

';\n}\n\nfunction updateParam(key, value) { state.actionParams[key] = value; }\nfunction updateParamJSON(key, raw) {\n try { state.actionParams[key] = JSON.parse(raw); }\n catch(e) { state.actionParams[key] = raw; }\n}\n\nfunction goToStep5() {\n const action = ACTIONS.find(function(a) { return a.id === state.selectedAction; });\n if (action) {\n action.params.forEach(function(p) {\n const el = document.getElementById(\"param-\" + p.key);\n if (!el) return;\n if (p.type === \"checkbox\") updateParam(p.key, el.checked);\n else if (p.type === \"json\") updateParamJSON(p.key, el.value);\n else updateParam(p.key, el.value);\n });\n }\n if (state.selectedAction === \"sendInvitation\") {\n const emailMap = {};\n state.users.forEach(function(u) { if (u.UID && u.profile && u.profile.email) emailMap[u.UID] = u.profile.email; });\n state.actionParams._userEmails = emailMap;\n }\n renderExecutionSummary(); activateStep(5); updateProgress(5);\n}\n\n// ── Step 5 ─────────────────────────────────────────────────────\nfunction renderExecutionSummary() {\n const action = ACTIONS.find(function(a) { return a.id === state.selectedAction; });\n const el = document.getElementById(\"execution-summary\");\n const uids = Array.from(state.selectedUIDs);\n\n let channelPreview = \"\";\n if (state.selectedAction === \"sendInvitation\") {\n const emailMap = state.actionParams._userEmails || {};\n const override = state.actionParams.channel;\n const chRows = uids.slice(0, 5).map(function(uid) {\n const ch = override || emailMap[uid] || \"⚠️ no email\";\n return '

' +\n '' + uid.slice(0,14) + '…' +\n '' + ch + '' +\n '

';\n }).join(\"\");\n const more = uids.length > 5 ? '

…+' + (uids.length - 5) + ' more

' : \"\";\n const overrideNote = override ? \" (override: \" + override + \")\" : \" (from profile.email)\";\n channelPreview =\n '

' +\n '📬 Resolved channels' + overrideNote + ':' +\n '

' + chRows + more + '

' +\n '

';\n }\n\n const paramsDisplay = {};\n Object.keys(state.actionParams).forEach(function(k) { if (k !== \"_userEmails\") paramsDisplay[k] = state.actionParams[k]; });\n\n const uidPreview = uids.slice(0,3).map(function(u) { return u.slice(0,8); }).join(\", \") + (uids.length > 3 ? \" +\" + (uids.length-3) + \" more\" : \"\");\n\n el.innerHTML =\n '

' +\n '

Users

' +\n '

' + uids.length + '

' +\n '

' + uidPreview + '

' +\n '

Action

' +\n '

' + (action ? action.icon : \"\") + '

' +\n '

' + (action ? action.label : \"\") + '

' +\n '

Parameters

' +\n '

' + JSON.stringify(paramsDisplay, null, 2) + '

' +\n '

' +\n channelPreview;\n\n document.getElementById(\"execution-results\").classList.add(\"hidden\");\n document.getElementById(\"execution-controls\").classList.remove(\"hidden\");\n}\n\nasync function executeAction() {\n const btn = document.getElementById(\"btn-execute\");\n const spin = document.getElementById(\"exec-spin\");\n btn.disabled = true; spin.classList.remove(\"hidden\");\n try {\n const res = await fetch(\"./api/bulk\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ action: state.selectedAction, uids: Array.from(state.selectedUIDs), params: state.actionParams }),\n });\n const d = await res.json();\n state.results = d;\n renderResults(d);\n } catch(e) { renderResults({ success: false, error: e.message, results: [] }); }\n finally { btn.disabled = false; spin.classList.add(\"hidden\"); }\n}\n\nfunction renderResults(d) {\n const el = document.getElementById(\"execution-results\");\n document.getElementById(\"execution-controls\").classList.add(\"hidden\");\n el.classList.remove(\"hidden\");\n\n if (!d.success && !d.results) {\n el.innerHTML = '

Execution failed: ' + d.error + '

';\n return;\n }\n\n const summary = d.summary || {};\n const results = d.results || [];\n const pct = summary.total ? Math.round((summary.success / summary.total) * 100) : 0;\n\n const rows = results.map(function(r) {\n return (\n '

' +\n '' + (r.success ? \"✅\" : \"❌\") + '' +\n '

' +\n '

' + r.uid + '

' +\n (r.error ? '

' + r.error + '

' : '') +\n '

' +\n '' + (r.success ? \"OK\" : \"FAIL\") + '' +\n '

'\n );\n }).join(\"\");\n\n const summaryBg = summary.failed === 0 ? \"bg-green-50 border-green-200\" : \"bg-yellow-50 border-yellow-200\";\n el.innerHTML =\n '

' +\n '

' +\n '' + (summary.failed === 0 ? \"🎉\" : \"⚠️\") + '' +\n '

' +\n '

Execution complete

' +\n '

' + (summary.success||0) + ' succeeded / ' + (summary.failed||0) + ' failed / ' + (summary.total||0) + ' total (' + pct + '%)

' +\n '

' + rows + '

' +\n '

' +\n '' +\n '' +\n '

';\n}\n\nfunction copyResults() {\n navigator.clipboard.writeText(JSON.stringify(state.results, null, 2));\n alert(\"Copied to clipboard!\");\n}\n\nfunction resetAll() {\n state.users = []; state.selectedUIDs = new Set(); state.selectedAction = null;\n state.actionParams = {}; state.results = null;\n goToStep(1);\n document.getElementById(\"filter-input\").value = \"\";\n document.getElementById(\"users-table\").innerHTML = '

Search users first to preview results here.

';\n document.getElementById(\"user-count-badge\").textContent = \"\";\n document.getElementById(\"selected-count\").textContent = \"0 selected\";\n}\n\n// ── Navigation ─────────────────────────────────────────────────\nfunction activateStep(n) {\n for (let i = 1; i <= 5; i++) {\n const el = document.getElementById(\"step-\" + i);\n if (el) { el.classList.toggle(\"step-inactive\", i > n); el.classList.toggle(\"step-active\", i <= n); }\n }\n state.currentStep = n;\n}\n\nfunction goToStep(n) {\n activateStep(n); updateProgress(n);\n const el = document.getElementById(\"step-\" + n);\n if (el) el.scrollIntoView({ behavior: \"smooth\", block: \"start\" });\n}\n\nfunction updateProgress(n) {\n const labels = [\"\", \"Define criteria\", \"Preview users\", \"Choose action\", \"Configure params\", \"Execute\"];\n for (let i = 1; i <= 5; i++) {\n const el = document.getElementById(\"prog-\" + i);\n if (!el) continue;\n el.className = \"step-num \" + (i < n ? \"done\" : i === n ? \"active\" : \"idle\");\n el.textContent = i < n ? \"✓\" : String(i);\n }\n for (let i = 1; i <= 4; i++) {\n const line = document.getElementById(\"prog-line-\" + i);\n if (line) line.style.background = i < n ? \"#22c55e\" : \"#e5e7eb\";\n }\n document.getElementById(\"prog-label\").textContent = \"Step \" + n + \": \" + labels[n];\n}\n",[],[324,331],{"_105":339,"_97":340,"_167":341,"_169":325,"_170":148,"_171":342,"_173":119,"_107":343,"_102":344,"_175":345,"_177":346,"_178":22,"_179":-5,"_180":347,"_100":348},"f67981e0-13bd-11f1-8ae0-42dde27851f2","extension-worker.ts","10e4abf0-132c-11f1-957a-42dde27851f2",215,["D",1772184202977],6,"interval","// Worker: processes pending memberAdded events from the webhook_events queue\n// Runs on interval, picks up pending events, calls setAccountInfo\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\nconst GIGYA_DOMAIN = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\nconst GIGYA_API_KEY = \"4_D-cRx_0ZlqVrnpJi6o5-4Q\"; //Deno.env.get(\"GIGYA_API_KEY\") || \"\";\nconst GIGYA_APP_KEY = Deno.env.get(\"GIGYA_APP_KEY\") || \"\";\nconst GIGYA_APP_SECRET = Deno.env.get(\"GIGYA_APP_SECRET\") || \"\";\n\nconst BATCH_SIZE = 20; // max events to process per run\n\n// ── Gigya API helper ───────────────────────────────────────────\nasync function makeGigyaRequest(\n endpoint: string,\n params: Record,\n): Promise {\n const url = `https://${GIGYA_DOMAIN}/${endpoint}?httpStatusCodes=true`;\n const body = new URLSearchParams({\n apiKey: GIGYA_API_KEY,\n userKey: GIGYA_APP_KEY,\n secret: GIGYA_APP_SECRET,\n ...params,\n });\n const response = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body,\n });\n if (!response.ok) {\n const text = await response.text();\n throw new Error(`HTTP ${response.status}: ${text}`);\n }\n const result = await response.json();\n if (result.errorCode !== 0) {\n throw new Error(\n `Gigya API Error ${result.errorCode}: ${\n result.errorMessage || \"Unknown error\"\n }`,\n );\n }\n return result;\n}\n\n// ── Get current account data.access ────────────────────────────\nasync function getAccountAccess(uid: string): Promise {\n try {\n const result = await makeGigyaRequest(\"accounts.getAccountInfo\", {\n UID: uid,\n include: \"data\",\n });\n const access = result?.data?.access;\n if (!access) return [];\n if (Array.isArray(access)) return access.map(String);\n return [String(access)];\n } catch (e) {\n console.warn(`Failed to get account info for ${uid}:`, e.message);\n return [];\n }\n}\n\n// ── Set account data.access ────────────────────────────────────\nasync function setAccountAccess(uid: string, access: string[]): Promise {\n return makeGigyaRequest(\"accounts.setAccountInfo\", {\n UID: uid,\n data: JSON.stringify({ access }),\n });\n}\n\n// ── Process a single event ─────────────────────────────────────\nasync function processEvent(event: {\n id: number;\n uid: string;\n group_id: string;\n}): Promise {\n const { id, uid, group_id } = event;\n console.log(\"user\", uid, \"to\", group_id);\n try {\n // Mark as processing\n await sqlite.execute({\n sql: \"UPDATE webhook_events SET status = 'processing' WHERE id = ?\",\n args: [id],\n });\n\n // Get current access, append group if missing\n const currentAccess = await getAccountAccess(uid);\n if (!currentAccess.includes(group_id)) {\n currentAccess.push(group_id);\n // Set updated access\n await setAccountAccess(uid, currentAccess);\n }\n\n // Mark done\n await sqlite.execute({\n sql:\n \"UPDATE webhook_events SET status = 'done', processed_at = datetime('now') WHERE id = ?\",\n args: [id],\n });\n\n console.log(`✅ ${uid}: data.access = [${currentAccess.join(\", \")}]`);\n } catch (e: any) {\n // Mark as error with message\n await sqlite.execute({\n sql:\n \"UPDATE webhook_events SET status = 'error', error = ?, processed_at = datetime('now') WHERE id = ?\",\n args: [e.message, id],\n });\n\n console.error(`❌ Event ${id} (${uid}, group: ${group_id}): ${e.message}`);\n }\n}\n\n// ── Main: poll and process pending events ──────────────────────\nexport default async function () {\n // Ensure table exists (in case worker runs before any webhook POST)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS webhook_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n event_id TEXT UNIQUE,\n event_type TEXT NOT NULL,\n uid TEXT NOT NULL,\n group_id TEXT NOT NULL,\n model TEXT,\n payload TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n error TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n processed_at TEXT\n )\n `);\n\n // Reset any stuck 'processing' events (from previous crashed runs)\n await sqlite.execute(\n \"UPDATE webhook_events SET status = 'pending' WHERE status = 'processing'\",\n );\n\n // Fetch pending events\n const result = await sqlite.execute({\n sql:\n \"SELECT id, uid, group_id FROM webhook_events WHERE status = 'pending' ORDER BY created_at ASC LIMIT ?\",\n args: [BATCH_SIZE],\n });\n\n const pending = result.rows as Array<\n { id: number; uid: string; group_id: string }\n >;\n\n if (pending.length === 0) {\n return;\n }\n\n console.log(`🔄 Processing ${pending.length} pending event(s)...`);\n\n let ok = 0;\n let fail = 0;\n\n for (const event of pending) {\n try {\n await processEvent(event);\n ok++;\n } catch {\n fail++;\n }\n }\n\n console.log(`✅ Done: ${ok} succeeded, ${fail} failed`);\n}",[],[324,340],{"_105":350,"_97":351,"_167":352,"_169":325,"_170":148,"_171":353,"_173":119,"_107":354,"_102":355,"_175":230,"_177":356,"_178":22,"_179":357,"_180":358,"_100":359},"0376b4e0-132c-11f1-adfb-42dde27851f2","extension.ts","b7875ffc-1327-11f1-b9fc-42dde27851f2",112,["D",1772121518259],9,"// Webhook extension: listens for memberAdded events\n// Saves events to SQLite queue, returns OK immediately\n// Processing happens separately in extension-worker.ts\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\n\nconst GIGYA_DOMAIN = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\nconst GIGYA_API_KEY = \"4_D-cRx_0ZlqVrnpJi6o5-4Q\"; //Deno.env.get(\"GIGYA_API_KEY\") || \"\";\n\n// ── Ensure events table exists ─────────────────────────────────\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS webhook_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n event_id TEXT UNIQUE,\n event_type TEXT NOT NULL,\n uid TEXT NOT NULL,\n group_id TEXT NOT NULL,\n model TEXT,\n payload TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending',\n error TEXT,\n created_at TEXT NOT NULL DEFAULT (datetime('now')),\n processed_at TEXT\n )\n`);\n\nawait sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_webhook_events_status ON webhook_events(status)\n`);\n\n// ── JWT Verification ───────────────────────────────────────────\n\nlet cachedJwks: { keys: JWK[]; fetchedAt: number } | null = null;\nconst JWKS_CACHE_TTL = 60 * 60 * 1000; // 1 hour\n\ninterface JWK {\n kty: string;\n n: string;\n e: string;\n kid: string;\n alg?: string;\n use?: string;\n}\n\nasync function fetchJwks(forceRefresh = false): Promise {\n if (\n !forceRefresh\n && cachedJwks\n && Date.now() - cachedJwks.fetchedAt < JWKS_CACHE_TTL\n ) {\n return cachedJwks.keys;\n }\n\n const url = `https://${GIGYA_DOMAIN}/accounts.getJWTPublicKey?apiKey=${GIGYA_API_KEY}&V2=true`;\n console.log(\"Fetching JWKS from:\", url);\n\n const response = await fetch(url);\n if (!response.ok) {\n throw new Error(`Failed to fetch JWKS: HTTP ${response.status}`);\n }\n\n const data = await response.json();\n if (data.errorCode && data.errorCode !== 0) {\n throw new Error(`Gigya JWKS error ${data.errorCode}: ${data.errorMessage}`);\n }\n\n const keys: JWK[] = data.keys || [];\n if (keys.length === 0) {\n throw new Error(\"No public keys returned from Gigya JWKS endpoint\");\n }\n\n cachedJwks = { keys, fetchedAt: Date.now() };\n console.log(`Cached ${keys.length} JWKS public key(s)`);\n return keys;\n}\n\nfunction base64urlDecode(input: string): Uint8Array {\n let base64 = input.replace(/-/g, \"+\").replace(/_/g, \"/\");\n while (base64.length % 4 !== 0) base64 += \"=\";\n const binary = atob(base64);\n const bytes = new Uint8Array(binary.length);\n for (let i = 0; i < binary.length; i++) bytes[i] = binary.charCodeAt(i);\n return bytes;\n}\n\nasync function importRsaPublicKey(jwk: JWK): Promise {\n return crypto.subtle.importKey(\n \"jwk\",\n { kty: \"RSA\", n: jwk.n, e: jwk.e, alg: \"RS256\", ext: true },\n { name: \"RSASSA-PKCS1-v1_5\", hash: \"SHA-256\" },\n false,\n [\"verify\"],\n );\n}\n\nasync function verifyGigyaJwt(\n token: string,\n): Promise<{ verified: boolean; payload?: any; error?: string }> {\n try {\n const parts = token.split(\".\");\n if (parts.length !== 3) {\n return { verified: false, error: \"Invalid JWT format (expected 3 parts)\" };\n }\n\n const [headerB64, payloadB64, signatureB64] = parts;\n const header = JSON.parse(new TextDecoder().decode(base64urlDecode(headerB64)));\n\n if (header.alg !== \"RS256\") {\n return { verified: false, error: `Unsupported algorithm: ${header.alg}` };\n }\n\n let keys = await fetchJwks();\n let jwk = keys.find((k) => k.kid === header.kid);\n\n if (!jwk) {\n console.log(`Kid \"${header.kid}\" not found in cached JWKS, refreshing...`);\n keys = await fetchJwks(true);\n jwk = keys.find((k) => k.kid === header.kid);\n }\n\n if (!jwk) {\n return { verified: false, error: `No matching public key for kid: ${header.kid}` };\n }\n\n const cryptoKey = await importRsaPublicKey(jwk);\n const signingInput = new TextEncoder().encode(`${headerB64}.${payloadB64}`);\n const signature = base64urlDecode(signatureB64);\n\n const valid = await crypto.subtle.verify(\n \"RSASSA-PKCS1-v1_5\",\n cryptoKey,\n signature,\n signingInput,\n );\n\n if (!valid) {\n return { verified: false, error: \"JWT signature verification failed\" };\n }\n\n const payload = JSON.parse(new TextDecoder().decode(base64urlDecode(payloadB64)));\n\n if (payload.exp && payload.exp < Math.floor(Date.now() / 1000)) {\n return { verified: false, error: \"JWT has expired\" };\n }\n\n if (payload.apiKey && payload.apiKey !== GIGYA_API_KEY) {\n return { verified: false, error: `JWT apiKey mismatch: expected ${GIGYA_API_KEY}, got ${payload.apiKey}` };\n }\n\n console.log(\"✅ JWT verified, kid:\", header.kid);\n return { verified: true, payload };\n } catch (e: any) {\n return { verified: false, error: `JWT verification error: ${e.message}` };\n }\n}\n\nfunction extractJwt(req: Request): string | null {\n return req.headers.get(\"x-gigya-sig-jwt\") || null;\n}\n\n// ── Store events to SQLite queue ───────────────────────────────\nasync function enqueueEvents(events: any[]): Promise<{ queued: number; duplicates: number }> {\n let queued = 0;\n let duplicates = 0;\n\n for (const event of events) {\n try {\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO webhook_events (event_id, event_type, uid, group_id, model, payload)\n VALUES (?, ?, ?, ?, ?, ?)`,\n args: [\n event.id || crypto.randomUUID(),\n event.type,\n event.data.uid,\n event.data.GroupId,\n event.data.Model || null,\n JSON.stringify(event),\n ],\n });\n queued++;\n } catch (e: any) {\n if (e.message?.includes(\"UNIQUE\")) {\n duplicates++;\n } else {\n console.error(\"Failed to enqueue event:\", e.message);\n }\n }\n }\n\n return { queued, duplicates };\n}\n\n// ── HTTP handler (webhook endpoint) ────────────────────────────\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n\n // GET /events — list queued events\n if (req.method === \"GET\" && url.pathname.endsWith(\"/events\")) {\n const status = url.searchParams.get(\"status\") || \"all\";\n const limit = Math.min(parseInt(url.searchParams.get(\"limit\") || \"50\"), 200);\n\n const query = status === \"all\"\n ? { sql: \"SELECT * FROM webhook_events ORDER BY created_at DESC LIMIT ?\", args: [limit] }\n : { sql: \"SELECT * FROM webhook_events WHERE status = ? ORDER BY created_at DESC LIMIT ?\", args: [status, limit] };\n\n const result = await sqlite.execute(query);\n return Response.json({ ok: true, count: result.rows.length, events: result.rows });\n }\n\n // GET / — health check\n if (req.method === \"GET\") {\n const pending = await sqlite.execute(\"SELECT COUNT(*) as count FROM webhook_events WHERE status = 'pending'\");\n const processed = await sqlite.execute(\"SELECT COUNT(*) as count FROM webhook_events WHERE status = 'done'\");\n const failed = await sqlite.execute(\"SELECT COUNT(*) as count FROM webhook_events WHERE status = 'error'\");\n\n return Response.json({\n ok: true,\n description: \"Webhook listener for memberAdded events. POST webhook payloads here.\",\n handler: \"On memberAdded → queue → worker → accounts.setAccountInfo({ data: { access: [groupId] } })\",\n jwtVerification: \"enabled (x-gigya-sig-jwt header)\",\n queue: {\n pending: pending.rows[0]?.count ?? 0,\n processed: processed.rows[0]?.count ?? 0,\n failed: failed.rows[0]?.count ?? 0,\n },\n });\n }\n\n // POST: verify JWT → enqueue events → return OK\n if (req.method === \"POST\") {\n // ── Verify JWT ─────────────────────────────────────────────\n const jwt = extractJwt(req);\n if (!jwt) {\n console.warn(\"⚠️ Webhook received without JWT signature header\");\n return Response.json(\n { ok: false, error: \"Missing JWT signature header (x-gigya-sig-jwt)\" },\n { status: 401 },\n );\n }\n\n const jwtResult = await verifyGigyaJwt(jwt);\n if (!jwtResult.verified) {\n console.error(\"❌ JWT verification failed:\", jwtResult.error);\n return Response.json(\n { ok: false, error: `JWT verification failed: ${jwtResult.error}` },\n { status: 401 },\n );\n }\n\n console.log(\"🔐 JWT verified\");\n\n // ── Parse body ─────────────────────────────────────────────\n const text = await req.text();\n let payload: { events: any[] };\n try {\n payload = JSON.parse(text);\n } catch {\n return Response.json({ ok: false, error: \"Invalid JSON\" }, { status: 400 });\n }\n\n if (!payload.events || !Array.isArray(payload.events)) {\n return Response.json({ ok: false, error: \"Missing events array\" }, { status: 400 });\n }\n\n // ── Filter memberAdded events and enqueue ──────────────────\n const memberAddedEvents = payload.events.filter(\n (e: any) => e.type === \"memberAdded\" && e.data?.uid && e.data?.GroupId,\n );\n\n if (memberAddedEvents.length === 0) {\n return Response.json({ ok: true, queued: 0, skipped: payload.events.length });\n }\n\n const { queued, duplicates } = await enqueueEvents(memberAddedEvents);\n console.log(`📥 Enqueued ${queued} events (${duplicates} duplicates skipped)`);\n\n // Return OK immediately — worker will process\n return Response.json({ ok: true, queued, duplicates });\n }\n\n return Response.json({ error: \"Method not allowed\" }, { status: 405 });\n}\n","build-new-member-wh",[],[324,351],{"_105":361,"_97":362,"_167":363,"_169":325,"_170":148,"_171":364,"_173":119,"_107":365,"_102":33,"_175":230,"_177":366,"_178":22,"_179":-5,"_180":367,"_100":368},"336ee388-1305-11f1-ba29-42dde27851f2","index-copy.tsx","336ee43c-1305-11f1-ba29-42dde27851f2",47,["D",1772104848345],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\n\nconst app = new Hono();\napp.onError((err, c) => { throw err; });\n\nconst GIGYA_DOMAIN = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\nconst GIGYA_API_KEY = Deno.env.get(\"GIGYA_API_KEY\") || \"\";\nconst GIGYA_APP_KEY = Deno.env.get(\"GIGYA_APP_KEY\") || \"\";\nconst GIGYA_APP_SECRET = Deno.env.get(\"GIGYA_APP_SECRET\") || \"\";\n\nasync function makeGigyaRequest(endpoint: string, params: Record): Promise {\n const url = `https://${GIGYA_DOMAIN}/${endpoint}?httpStatusCodes=true`;\n const body = new URLSearchParams({ apiKey: GIGYA_API_KEY, userKey: GIGYA_APP_KEY, secret: GIGYA_APP_SECRET, ...params });\n const response = await fetch(url, { method: \"POST\", headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" }, body });\n if (!response.ok) { const text = await response.text(); throw new Error(`HTTP ${response.status}: ${text}`); }\n const result = await response.json();\n if (result.errorCode !== 0) throw new Error(`Gigya API Error ${result.errorCode}: ${result.errorMessage || \"Unknown error\"}`);\n return result;\n}\n\n// ── Search users ───────────────────────────────────────────────\napp.get(\"/api/users\", async (c) => {\n try {\n const filter = c.req.query(\"filter\") || \"\";\n const limit = Math.min(parseInt(c.req.query(\"limit\") || \"50\"), 100);\n const query = filter\n ? `SELECT UID,profile.firstName,profile.lastName,profile.email,data,groups FROM accounts WHERE ${filter} LIMIT ${limit}`\n : `SELECT UID,profile.firstName,profile.lastName,profile.email,data,groups FROM accounts LIMIT ${limit}`;\n const result = await makeGigyaRequest(\"accounts.search\", { query, openCursor: true });\n return c.json({ success: true, users: result.results || [], totalCount: result.totalCount || 0 });\n } catch (e: any) { return c.json({ success: false, error: e.message }, 500); }\n});\n\n// ── Get groups ─────────────────────────────────────────────────\napp.get(\"/api/groups\", async (c) => {\n try {\n const result = await makeGigyaRequest(\"accounts.groups.search\", { query: \"select * from groups\", model: \"playground-access\" });\n return c.json({ success: true, groups: result?.results || [] });\n } catch (e: any) { return c.json({ success: false, error: e.message, groups: [] }, 200); }\n});\n\n// ── Bulk actions ───────────────────────────────────────────────\napp.post(\"/api/bulk\", async (c) => {\n try {\n const body = await c.req.json() as { action: string; uids: string[]; params: Record };\n const { action, uids, params } = body;\n if (!uids || uids.length === 0) return c.json({ success: false, error: \"No users selected\" }, 400);\n\n const results: Array<{ uid: string; success: boolean; error?: string; data?: any }> = [];\n\n for (const uid of uids) {\n try {\n let data: any = null;\n switch (action) {\n case \"addToGroup\": {\n data = await makeGigyaRequest(\"accounts.groups.addMember\", {\n UID: uid,\n groupID: params.groupID,\n ...(params.roleSetID ? { roleSetID: params.roleSetID } : {}),\n ...(params.data ? { data: JSON.stringify(params.data) } : {}),\n });\n break;\n }\n case \"removeFromGroup\": {\n data = await makeGigyaRequest(\"accounts.groups.removeMember\", { UID: uid, groupID: params.groupID });\n break;\n }\n case \"updateRelationship\": {\n data = await makeGigyaRequest(\"accounts.groups.setMemberData\", {\n UID: uid,\n groupID: params.groupID,\n data: JSON.stringify(params.relationshipData || {}),\n });\n break;\n }\n case \"sendInvitation\": {\n // Resolve the per-user email: _userEmails map (built from previewed users) or\n // the override channel field, otherwise empty.\n const userEmail = (params._userEmails || {})[uid] || params.channel || \"\";\n\n const inviteApiParams: Record = {\n groupId: params.groupId,\n model: params.model || \"\",\n type: params.type || \"emailLink\",\n channel: userEmail,\n };\n if (params.memberInfo) {\n inviteApiParams.memberInfo = typeof params.memberInfo === \"string\"\n ? params.memberInfo : JSON.stringify(params.memberInfo);\n }\n if (params.adminInfo) {\n inviteApiParams.adminInfo = typeof params.adminInfo === \"string\"\n ? params.adminInfo : JSON.stringify(params.adminInfo);\n }\n if (params.language) inviteApiParams.language = params.language;\n if (params.relationship) {\n inviteApiParams.relationship = typeof params.relationship === \"string\"\n ? params.relationship : JSON.stringify(params.relationship);\n }\n if (params.permissions) inviteApiParams.permissions = params.permissions;\n\n data = await makeGigyaRequest(\"accounts.groups.invitation.send\", inviteApiParams);\n break;\n }\n case \"setAccountData\": {\n const setParams: Record = { UID: uid };\n if (params.data) setParams.data = JSON.stringify(params.data);\n if (params.profile) setParams.profile = JSON.stringify(params.profile);\n data = await makeGigyaRequest(\"accounts.setAccountInfo\", setParams);\n break;\n }\n case \"sendEmail\": {\n data = await makeGigyaRequest(\"accounts.otp.sendCode\", { UID: uid, lang: params.lang || \"en\" });\n break;\n }\n default:\n throw new Error(`Unknown action: ${action}`);\n }\n results.push({ uid, success: true, data });\n } catch (e: any) {\n results.push({ uid, success: false, error: e.message });\n }\n }\n\n const successCount = results.filter((r) => r.success).length;\n const failCount = results.filter((r) => !r.success).length;\n return c.json({ success: true, results, summary: { total: uids.length, success: successCount, failed: failCount } });\n } catch (e: any) { return c.json({ success: false, error: e.message }, 500); }\n});\n\n// ── Main UI ────────────────────────────────────────────────────\napp.get(\"/\", (c) => {\n const html = String.raw`\n\n\n \n \n Group Management\n \n \n\n\n\n\n\n

Group Management

Define criteria → Preview users → Choose action → Configure → Execute

\n\n \n

Step 1: Define criteria

\n\n \n

Define User Criteria

\n Filter Expression\n \n

Leave empty to match all accounts. Uses Gigya SQL query syntax.

\n Limit\n \n

\n \n

\n Quick filters:\n \n \n \n \n

\n\n \n

Preview & Select Users

\n \n

\n \n |\n \n |\n 0 selected\n

Search users first to preview results here.

\n \n

\n\n \n

Choose Action

\n \n \n

\n\n \n

Configure Parameters

\n \n \n

\n\n \n

Review & Execute

\n \n \n

\n\n\n\n`;\n return c.html(html);\n});\n\nexport default app.fetch;",[],[324,362],{"_105":370,"_97":225,"_167":371,"_169":325,"_170":148,"_171":372,"_173":119,"_107":373,"_102":374,"_175":230,"_177":375,"_178":22,"_179":-5,"_180":376,"_100":377},"13267580-1307-11f1-a6d6-42dde27851f2","41156396-12fa-11f1-90a5-42dde27851f2",59,["D",1772105653202],24,"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\n\nconst app = new Hono();\napp.onError((err, c) => {\n throw err;\n});\n\nconst GIGYA_DOMAIN = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\nconst GIGYA_API_KEY = \"4_D-cRx_0ZlqVrnpJi6o5-4Q\"; //Deno.env.get(\"GIGYA_API_KEY\") || \"\";\nconst GIGYA_APP_KEY = Deno.env.get(\"GIGYA_APP_KEY\") || \"\";\nconst GIGYA_APP_SECRET = Deno.env.get(\"GIGYA_APP_SECRET\") || \"\";\n\n// ── Gigya API helper ───────────────────────────────────────────\nasync function makeGigyaRequest(\n endpoint: string,\n params: Record,\n): Promise {\n const url = `https://${GIGYA_DOMAIN}/${endpoint}?httpStatusCodes=true`;\n const body = new URLSearchParams({\n apiKey: GIGYA_API_KEY,\n userKey: GIGYA_APP_KEY,\n secret: GIGYA_APP_SECRET,\n ...params,\n });\n const response = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body,\n });\n if (!response.ok) {\n const text = await response.text();\n throw new Error(`HTTP ${response.status}: ${text}`);\n }\n const result = await response.json();\n if (result.errorCode !== 0) {\n throw new Error(\n `Gigya API Error ${result.errorCode}: ${\n result.errorMessage || \"Unknown error\"\n }`,\n );\n }\n return result;\n}\n\n// ── Action definitions ─────────────────────────────────────────\nconst ACTIONS = [\n {\n id: \"addToGroup\",\n label: \"Add to Group\",\n icon: \"👥\",\n desc: \"Assign selected users to a Gigya group\",\n params: [\n { key: \"groupID\", label: \"Group\", type: \"group_select\", required: true },\n {\n key: \"roleSetID\",\n label: \"Role Set ID (optional)\",\n type: \"text\",\n placeholder: \"e.g. member\",\n },\n {\n key: \"data\",\n label: \"Membership Data (JSON)\",\n type: \"json\",\n placeholder: '{\"tier\":\"gold\"}',\n },\n ],\n },\n {\n id: \"removeFromGroup\",\n label: \"Remove from Group\",\n icon: \"🚫\",\n desc: \"Remove selected users from a group\",\n params: [\n { key: \"groupID\", label: \"Group\", type: \"group_select\", required: true },\n ],\n },\n {\n id: \"updateRelationship\",\n label: \"Update Relationship\",\n icon: \"🔗\",\n desc: \"Modify group relationship / membership data\",\n params: [\n { key: \"groupID\", label: \"Group\", type: \"group_select\", required: true },\n {\n key: \"relationshipData\",\n label: \"Relationship Data (JSON)\",\n type: \"json\",\n placeholder: '{\"role\":\"admin\",\"tier\":\"vip\"}',\n },\n ],\n },\n {\n id: \"sendInvitation\",\n label: \"Send Invitation\",\n icon: \"✉️\",\n desc: \"accounts.groups.invitation.send — invite users to a group by email\",\n params: [\n { key: \"groupId\", label: \"Group\", type: \"group_select\", required: true },\n {\n key: \"model\",\n label: \"Model ID\",\n type: \"text\",\n required: true,\n placeholder: \"e.g. playground-access\",\n },\n {\n key: \"type\",\n label: \"Invitation Type\",\n type: \"select\",\n required: true,\n options: [\"emailLink\"],\n default: \"emailLink\",\n },\n {\n key: \"channel\",\n label: \"Email Channel Override\",\n type: \"text\",\n placeholder: \"Leave blank — uses each user's profile.email\",\n },\n {\n key: \"memberInfo\",\n label: \"Member Info (JSON)\",\n type: \"json\",\n placeholder: '{\"firstName\":\"Jane\",\"lastName\":\"Doe\"}',\n },\n {\n key: \"adminInfo\",\n label: \"Admin / Inviter Info (JSON)\",\n type: \"json\",\n placeholder: '{\"firstName\":\"Admin\",\"lastName\":\"User\"}',\n },\n {\n key: \"language\",\n label: \"Language\",\n type: \"text\",\n placeholder: \"en\",\n default: \"en\",\n },\n {\n key: \"relationship\",\n label: \"Relationship Data (JSON)\",\n type: \"json\",\n placeholder: '{\"emailDomain\":\"sap.com\"}',\n },\n {\n key: \"permissions\",\n label: \"Permissions (comma-sep)\",\n type: \"text\",\n placeholder: \"groupRead,groupWrite,membersInvite,membersRemove\",\n },\n ],\n },\n {\n id: \"setAccountData\",\n label: \"Update Account Data\",\n icon: \"📝\",\n desc: \"Bulk-update custom data / profile fields\",\n params: [\n {\n key: \"data\",\n label: \"Data Fields (JSON)\",\n type: \"json\",\n placeholder: '{\"newsletter\":true,\"tier\":\"premium\"}',\n },\n {\n key: \"profile\",\n label: \"Profile Fields (JSON, optional)\",\n type: \"json\",\n placeholder: '{\"age\":30}',\n },\n ],\n },\n {\n id: \"sendEmail\",\n label: \"Send OTP / Email\",\n icon: \"📧\",\n desc: \"Trigger an OTP email for selected users\",\n params: [\n {\n key: \"lang\",\n label: \"Language\",\n type: \"text\",\n placeholder: \"en\",\n default: \"en\",\n },\n ],\n },\n] as const;\n\ntype ActionId = typeof ACTIONS[number][\"id\"];\n\n// ── Shared CSS ─────────────────────────────────────────────────\nconst STYLES = `\n .step-inactive{opacity:.4;pointer-events:none}\n .tag{display:inline-flex;align-items:center;gap:4px;background:#e0e7ff;color:#3730a3;border-radius:9999px;padding:2px 10px;font-size:12px;font-weight:600}\n .badge-success{background:#dcfce7;color:#166534}\n .badge-error{background:#fee2e2;color:#991b1b}\n .result-row-ok{border-left:3px solid #22c55e}\n .result-row-err{border-left:3px solid #ef4444}\n .spin{animation:spin 1s linear infinite}\n @keyframes spin{to{transform:rotate(360deg)}}\n .user-row.selected{background:#eff6ff}\n .user-row{transition:background .1s}\n .user-row:hover{background:#f8fafc}\n .action-card{cursor:pointer;border:2px solid #e5e7eb;border-radius:12px;padding:16px;transition:all .15s}\n .action-card:hover{border-color:#6366f1;background:#f5f3ff}\n .action-card.selected{border-color:#6366f1;background:#eef2ff}\n .step-header{display:flex;align-items:center;gap:12px;margin-bottom:16px}\n .step-num{width:32px;height:32px;border-radius:9999px;display:flex;align-items:center;justify-content:center;font-weight:700;font-size:14px}\n .step-num.done{background:#22c55e;color:#fff}\n .step-num.active{background:#6366f1;color:#fff}\n .step-num.idle{background:#e5e7eb;color:#9ca3af}\n .inv-note{background:#f0fdf4;border:1px solid #bbf7d0;border-radius:8px;padding:10px 14px;font-size:12px;color:#166534;margin-bottom:12px}\n .htmx-indicator{display:none}\n .htmx-request .htmx-indicator{display:inline-block}\n .htmx-request.htmx-indicator{display:inline-block}\n`;\n\n// ── Progress bar component ─────────────────────────────────────\nfunction ProgressBar({ step }: { step: number }) {\n const labels = [\n \"\",\n \"Define criteria\",\n \"Preview users\",\n \"Choose action\",\n \"Configure params\",\n \"Execute\",\n ];\n return (\n

\n {[1, 2, 3, 4, 5].map((i) => (\n <>\n \n {i < step ? \"✓\" : String(i)}\n

\n {i < 5 && (\n \n )}\n \n ))}\n

Step {step}: {labels[step]}

\n );\n}\n\n// ── Spinner SVG ────────────────────────────────────────────────\nfunction Spinner() {\n return (\n \n );\n}\n\n// ── Field renderer ─────────────────────────────────────────────\nfunction ParamField({ p, groups }: { p: any; groups: any[] }) {\n const base =\n \"w-full px-3 py-2 border border-gray-300 rounded-lg focus:outline-none focus:ring-2 focus:ring-indigo-500 text-sm\";\n const req = p.required ? * : null;\n\n const label = (\n \n {p.label}\n {req}\n \n );\n\n if (p.type === \"group_select\") {\n return (\n

\n {label}\n \n

\n );\n }\n\n if (p.type === \"select\") {\n return (\n

\n {label}\n \n

\n );\n }\n\n if (p.type === \"checkbox\") {\n return (\n

\n \n {p.label}\n {req}\n \n \n

\n );\n }\n\n if (p.type === \"json\" || p.type === \"textarea\") {\n return (\n

\n {label}\n \n {p.default ? JSON.stringify(p.default) : \"\"}\n \n {p.type === \"json\" && (\n

Enter valid JSON

\n )}\n

\n );\n }\n\n return (\n

\n {label}\n \n

\n );\n}\n\n// ══════════════════════════════════════════════════════════════\n// GET / — Shell page\n// ══════════════════════════════════════════════════════════════\napp.get(\"/\", (c) => {\n return c.html(\n \n \n \n \n Group Management\n \n \n \n\n \n \n \n \n

\n {children}\n

\n \n \n );\n}\n\n// ── Progress stepper ───────────────────────────────────────────\nfunction Stepper({ step }: { step: 1 | 2 | 3 }) {\n const steps = [\"Configure\", \"Preview\", \"Send\"];\n return (\n

\n {steps.map((label, idx) => {\n const n = idx + 1;\n const cls = n < step\n ? \"dot-done\"\n : n === step\n ? \"dot-active\"\n : \"dot-idle\";\n return (\n <>\n

{n < step ? \"✓\" : String(n)}

\n \n {label}\n \n {n < steps.length && (\n \n )}\n \n );\n })}\n

\n );\n}\n\n// ══════════════════════════════════════════════════════════════\n// GET / — Step 1: Configure invitation\n// ══════════════════════════════════════════════════════════════\napp.get(\"/\", async (c) => {\n const groups = await makeGigyaRequest(\"accounts.groups.getAllMemberGroups\", {\n oauth_token: getOAuthToken(c),\n });\n return c.html(\n \n

Send Invitations

\n Invite people to a group — works for non-existing users too\n

\n\n \n\n {/* Step 1 card */}\n

Configure Invitation

\n Fill in group, template, and email addresses\n

\n\n \n {/* ── Group & model ── */}\n {/* model is encoded as data-model on each option; JS-free auto-fill via hx-on:change */}\n

\n \n Group *\n \n \n \n {groups.length\n ? groups.map((g: any) => (\n \n ))\n : (\n \n )}\n \n

\n \n Model ID *\n \n \n

\n Auto-filled when you select a group, or enter manually\n

\n\n {/* ── Invitation type & language ── */}\n

\n Invitation Type\n \n

\n Language\n \n

\n\n {/* ── Console note ── */}\n

\n ℹ️\n

\n Landing page{\" \"}\n must be configured in the Gigya Console for your invitation model.\n Go to{\" \"}\n \n Customer Data Cloud → Groups → Invitation Models → [your model]\n → Landing Page\n . Once set in the console it is used automatically — you do\n not pass it at runtime.\n

\n\n {/* ── Permissions ── */}\n

\n \n Permissions{\" \"}\n \n (comma-separated)\n \n \n \n

\n\n

\n\n {/* ── Email addresses — single or list ── */}\n

Email Addresses

\n Enter one email or paste a list (one per line, or\n comma/space-separated)\n

\n\n {/* Mode toggle */}\n

\n \n Single email\n \n \n Bulk list\n \n

\n\n {/* Single */}\n

\n \n

\n\n {/* Bulk */}\n

\n \n

\n One per line, or comma/space separated. Duplicates and invalid\n addresses are filtered out.\n

\n\n

\n\n {/* ── Optional JSON fields ── */}\n

\n ▸ Optional: memberInfo / adminInfo / relationship (JSON)\n

\n Member Info (JSON)\n \n

\n Admin Info (JSON)\n \n

\n Relationship (JSON)\n \n

\n\n

\n \n

\n\n {/* Step 2 – preview (locked until form submitted) */}\n

Preview Recipients

Review parsed addresses before sending

\n Fill in step 1 and click \"Preview recipients\".\n

\n\n {/* Step 3 – results (locked until send) */}\n

Results

Delivery status per recipient

\n Results will appear here after sending.\n

\n ,\n );\n});\n\n// ══════════════════════════════════════════════════════════════\n// POST /preview — Parse emails, show preview table (Step 2)\n// ══════════════════════════════════════════════════════════════\napp.post(\"/preview\", async (c) => {\n const form = await c.req.formData();\n const singleEmail = (form.get(\"single_email\") as string || \"\").trim();\n const bulkEmails = (form.get(\"bulk_emails\") as string || \"\").trim();\n\n // Gather raw email strings\n const raw = bulkEmails\n ? bulkEmails.split(/[\\n,\\s]+/).map((s) => s.trim()).filter(Boolean)\n : singleEmail\n ? [singleEmail]\n : [];\n\n // Deduplicate & validate\n const seen = new Set();\n const valid: string[] = [];\n const invalid: string[] = [];\n\n const EMAIL_RE = /^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/;\n for (const e of raw) {\n const lower = e.toLowerCase();\n if (seen.has(lower)) continue;\n seen.add(lower);\n if (EMAIL_RE.test(e)) valid.push(e);\n else invalid.push(e);\n }\n\n if (valid.length === 0 && invalid.length === 0) {\n return c.html(\n

\n ⚠️ No email addresses provided. Enter at least one email above.\n

,\n );\n }\n\n // Collect all other form fields (pass-through to send step)\n const fields: Record = {};\n for (const [k, v] of form.entries()) {\n if (k === \"single_email\" || k === \"bulk_emails\") continue;\n fields[k] = v as string;\n }\n const hiddenFields = Object.entries(fields).map(([k, v]) => (\n \n ));\n\n return c.html(\n <>\n {/* OOB: activate step-2 card */}\n

Preview Recipients

\n {valid.length} valid · {invalid.length} invalid ·{\" \"}\n {valid.length + invalid.length} total parsed\n

\n \n

\n {/* placeholder for primary target */}\n \n ,\n );\n});\n\n// ── Preview table component ────────────────────────────────────\nfunction PreviewTable({\n valid,\n invalid,\n hiddenFields,\n}: {\n valid: string[];\n invalid: string[];\n hiddenFields: any;\n}) {\n return (\n <>\n {/* Valid */}\n {valid.length > 0 && (\n

\n \n ✅ Valid addresses ({valid.length})\n \n

\n \n \n \n \n \n \n \n \n \n {valid.map((email, i) => (\n \n \n \n \n \n ))}\n \n

#	Email	Status
{i + 1}	{email}	\n will send\n

\n )}\n\n {/* Invalid */}\n {invalid.length > 0 && (\n

\n \n ❌ Invalid / skipped ({invalid.length})\n \n

\n \n \n \n \n \n \n \n \n \n {invalid.map((e, i) => (\n \n \n \n \n \n ))}\n \n

#	Value	Reason
{i + 1}	{e}	Not a valid email

\n )}\n\n {valid.length === 0\n ? (\n

\n No valid email addresses — fix the addresses above and try again.\n

\n )\n : (\n \n {hiddenFields}\n {valid.map((email) => (\n \n ))}\n

\n Ready to send {valid.length}{\" \"}\n invitation{valid.length !== 1 ? \"s\" : \"\"}\n {invalid.length > 0 && ` (${invalid.length} skipped)`}.\n

\n \n

\n \n )}\n \n );\n}\n\n// ══════════════════════════════════════════════════════════════\n// POST /send — Send invitations, stream results (Step 3)\n// ══════════════════════════════════════════════════════════════\napp.post(\"/send\", async (c) => {\n const form = await c.req.formData();\n const emails = form.getAll(\"email\") as string[];\n const groupId = (form.get(\"groupId\") as string || \"\").trim();\n const model = (form.get(\"model\") as string || \"\").trim();\n const type = (form.get(\"type\") as string) || \"emailLink\";\n const lang = (form.get(\"language\") as string) || \"en\";\n const perms = (form.get(\"permissions\") as string || \"\").trim();\n\n // Optional JSON fields\n const parseJsonField = (key: string): any | undefined => {\n const raw = (form.get(key) as string || \"\").trim();\n if (!raw) return undefined;\n try {\n return JSON.parse(raw);\n } catch {\n return raw;\n }\n };\n const memberInfo = parseJsonField(\"memberInfo\");\n const adminInfo = parseJsonField(\"adminInfo\");\n const relationship = parseJsonField(\"relationship\");\n\n if (!emails.length) {\n return c.html(\n

\n No emails provided.\n

,\n );\n }\n\n type InvResult = {\n email: string;\n status: \"ok\" | \"fail\";\n invitationId?: string;\n error?: string;\n };\n const results: InvResult[] = [];\n\n for (const email of emails) {\n const invParams: Record = {\n groupId,\n model,\n type,\n channel: email,\n language: lang,\n };\n if (perms) invParams.permissions = perms;\n if (memberInfo) {\n invParams.memberInfo = typeof memberInfo === \"string\"\n ? memberInfo\n : JSON.stringify(memberInfo);\n }\n if (adminInfo) {\n invParams.adminInfo = typeof adminInfo === \"string\"\n ? adminInfo\n : JSON.stringify(adminInfo);\n }\n if (relationship) {\n invParams.relationship = typeof relationship === \"string\"\n ? relationship\n : JSON.stringify(relationship);\n }\n\n try {\n const r = await makeGigyaRequest(\n \"accounts.groups.invitation.send\",\n { ...invParams, oauth_token: getOAuthToken(c) },\n );\n results.push({\n email,\n status: \"ok\",\n invitationId: r.invitationId || r.id,\n });\n } catch (e: any) {\n // Try to extract a clean Gigya errorDetails from the raw message\n let errMsg = e.message as string;\n try {\n const jsonStart = errMsg.indexOf(\"{\");\n if (jsonStart !== -1) {\n const parsed = JSON.parse(errMsg.slice(jsonStart));\n errMsg = parsed.errorDetails || parsed.errorMessage || errMsg;\n }\n } catch { /* keep raw */ }\n results.push({ email, status: \"fail\", error: errMsg });\n }\n }\n\n const ok = results.filter((r) => r.status === \"ok\").length;\n const fail = results.filter((r) => r.status === \"fail\").length;\n const pct = results.length ? Math.round((ok / results.length) * 100) : 0;\n\n return c.html(\n <>\n {/* OOB: mark step-2 done, activate step-3 */}\n

✓

Preview Recipients

{results.length} processed

\n\n {/* Step-3 results inline */}\n \n ,\n );\n});\n\n// ── Results panel ──────────────────────────────────────────────\nfunction ResultsPanel({\n results,\n ok,\n fail,\n pct,\n}: {\n results: Array<\n {\n email: string;\n status: \"ok\" | \"fail\";\n invitationId?: string;\n error?: string;\n }\n >;\n ok: number;\n fail: number;\n pct: number;\n}) {\n return (\n

\n {/* Summary banner */}\n \n {fail === 0 ? \"🎉\" : \"⚠️\"}\n

\n {fail === 0 ? \"All invitations sent!\" : \"Completed with errors\"}\n

\n {ok} sent · {fail} failed · {results.length} total\n

{pct}%

\n\n {/* Per-email rows */}\n

\n \n \n \n \n \n \n \n \n \n \n {results.map((r, i) => (\n \n \n \n \n \n \n ))}\n \n

#	Email	Invitation ID	Status
{i + 1}	{r.email}	\n {r.invitationId \|\|\n (r.error\n ? {r.error}\n : \"—\")}\n	\n \n {r.status === \"ok\" ? \"✓ sent\" : \"✗ failed\"}\n \n

\n\n {/* Actions */}\n

\n ← Back to Group Manager\n Send more invitations\n

\n );\n}\n\nexport default app.fetch;","build-invitations",[],[324,380],{"_105":390,"_97":391,"_167":392,"_169":325,"_170":148,"_171":393,"_173":119,"_107":394,"_102":374,"_175":230,"_177":395,"_178":22,"_179":-5,"_180":396,"_100":397},"ad12e894-1326-11f1-ac47-42dde27851f2","invitation.tsx","10520be4-1307-11f1-ba16-42dde27851f2",101,["D",1772119225843],"/** @jsxImportSource https://esm.sh/hono@4.0.0/jsx */\n\nimport { Hono } from \"https://esm.sh/hono@4.0.0\";\n\nconst app = new Hono();\napp.onError((err, c) => {\n throw err;\n});\n\nconst GIGYA_DOMAIN = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\nconst GIGYA_API_KEY = \"4_D-cRx_0ZlqVrnpJi6o5-4Q\"; //Deno.env.get(\"GIGYA_API_KEY\") || \"\";\nconst GIGYA_APP_KEY = Deno.env.get(\"GIGYA_APP_KEY\") || \"\";\nconst GIGYA_APP_SECRET = Deno.env.get(\"GIGYA_APP_SECRET\") || \"\";\n\n// ── Gigya API helper ───────────────────────────────────────────\nasync function makeGigyaRequest(\n endpoint: string,\n params: Record,\n): Promise {\n const url = `https://${GIGYA_DOMAIN}/${endpoint}?httpStatusCodes=true`;\n const body = new URLSearchParams({\n apiKey: GIGYA_API_KEY,\n userKey: GIGYA_APP_KEY,\n secret: GIGYA_APP_SECRET,\n ...params,\n });\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body,\n });\n if (!res.ok) throw new Error(`HTTP ${res.status}: ${await res.text()}`);\n const json = await res.json();\n if (json.errorCode !== 0) {\n throw new Error(\n `Gigya ${json.errorCode}: ${json.errorMessage || \"Unknown error\"}`,\n );\n }\n return json;\n}\n\nasync function fetchGroups(): Promise {\n try {\n // model is always required; search without field restriction so we get all fields\n const r = await makeGigyaRequest(\"accounts.groups.search\", {\n query: \"select * from groups\",\n model: \"playground-access\",\n });\n return r?.results || [];\n } catch {\n return [];\n }\n}\n\n// Normalise group record — Gigya returns groupId (lowercase d)\nfunction groupId(g: any): string {\n return g.groupId || g.groupID || g.id || \"\";\n}\nfunction groupLabel(g: any): string {\n return g.name || groupId(g);\n}\n\n// ── Shared CSS ─────────────────────────────────────────────────\nconst STYLES = `\n .card{background:#fff;border-radius:12px;border:1px solid #e5e7eb;padding:24px;margin-bottom:20px;box-shadow:0 1px 3px rgba(0,0,0,.06)}\n .field-label{display:block;font-size:.875rem;font-weight:500;color:#374151;margin-bottom:4px}\n .field-hint{font-size:.75rem;color:#9ca3af;margin-top:3px}\n .input{width:100%;padding:8px 12px;border:1px solid #d1d5db;border-radius:8px;font-size:.875rem;outline:none;box-sizing:border-box;transition:border-color .15s}\n .input:focus{border-color:#6366f1;box-shadow:0 0 0 3px rgba(99,102,241,.1)}\n .input.mono{font-family:monospace}\n .btn{display:inline-flex;align-items:center;gap:8px;padding:8px 20px;border-radius:8px;font-weight:600;font-size:.875rem;cursor:pointer;border:none;transition:all .15s}\n .btn-primary{background:#6366f1;color:#fff}\n .btn-primary:hover{background:#4f46e5}\n .btn-danger{background:#dc2626;color:#fff}\n .btn-danger:hover{background:#b91c1c}\n .btn-ghost{background:transparent;color:#6b7280;border:1px solid #e5e7eb}\n .btn-ghost:hover{background:#f9fafb;color:#111827}\n .btn-secondary{background:#059669;color:#fff}\n .btn-secondary:hover{background:#047857}\n .tag{display:inline-flex;align-items:center;gap:4px;background:#e0e7ff;color:#3730a3;border-radius:9999px;padding:2px 10px;font-size:12px;font-weight:600}\n .badge-ok{background:#dcfce7;color:#166534}\n .badge-fail{background:#fee2e2;color:#991b1b}\n .badge-skip{background:#fef9c3;color:#854d0e}\n .row-ok{border-left:3px solid #22c55e}\n .row-fail{border-left:3px solid #ef4444}\n .row-skip{border-left:3px solid #eab308}\n .email-pill{display:inline-flex;align-items:center;gap:6px;background:#eef2ff;border:1px solid #c7d2fe;border-radius:9999px;padding:3px 10px;font-size:.75rem;color:#3730a3;margin:2px}\n .email-pill-invalid{background:#fef2f2;border-color:#fecaca;color:#991b1b}\n .section-title{font-size:1.125rem;font-weight:700;color:#111827;margin:0}\n .section-sub{font-size:.875rem;color:#6b7280;margin:4px 0 0}\n .divider{border:none;border-top:1px solid #f3f4f6;margin:20px 0}\n .spin{animation:spin 1s linear infinite}\n @keyframes spin{to{transform:rotate(360deg)}}\n .htmx-indicator{display:none}\n .htmx-request .htmx-indicator{display:inline-flex}\n .htmx-request.htmx-indicator{display:inline-flex}\n .progress-bar{height:6px;background:#e5e7eb;border-radius:9999px;overflow:hidden;margin-top:8px}\n .progress-fill{height:100%;background:#22c55e;border-radius:9999px;transition:width .3s}\n .step-dot{width:28px;height:28px;border-radius:9999px;display:flex;align-items:center;justify-content:center;font-weight:700;font-size:13px;flex-shrink:0}\n .dot-done{background:#22c55e;color:#fff}\n .dot-active{background:#6366f1;color:#fff}\n .dot-idle{background:#e5e7eb;color:#9ca3af}\n .step-lock{opacity:.4;pointer-events:none}\n .preview-table{width:100%;font-size:.8rem;border-collapse:collapse}\n .preview-table th{text-align:left;padding:6px 10px;background:#f9fafb;font-size:.7rem;text-transform:uppercase;color:#6b7280;border-bottom:1px solid #e5e7eb}\n .preview-table td{padding:6px 10px;border-bottom:1px solid #f3f4f6;vertical-align:middle}\n .preview-table tr:last-child td{border-bottom:none}\n .mode-tab{padding:8px 18px;border-radius:8px;font-size:.875rem;font-weight:500;cursor:pointer;border:2px solid transparent;transition:all .15s}\n .mode-tab.active{border-color:#6366f1;background:#eef2ff;color:#4338ca}\n .mode-tab:not(.active){color:#6b7280}\n .mode-tab:not(.active):hover{background:#f9fafb}\n .link-result-box{background:#f0fdf4;border:1px solid #bbf7d0;border-radius:10px;padding:16px;margin-top:12px}\n .link-url{display:flex;align-items:center;gap:8px;background:#fff;border:1px solid #d1d5db;border-radius:8px;padding:10px 14px;font-family:monospace;font-size:.82rem;word-break:break-all;cursor:text;user-select:all}\n .copy-btn{background:#6366f1;color:#fff;border:none;border-radius:6px;padding:6px 14px;font-size:.8rem;font-weight:600;cursor:pointer;white-space:nowrap;flex-shrink:0;transition:all .15s}\n .copy-btn:hover{background:#4f46e5}\n .or-divider{display:flex;align-items:center;gap:12px;margin:24px 0;color:#9ca3af;font-size:.8rem;font-weight:500}\n .or-divider::before,.or-divider::after{content:'';flex:1;height:1px;background:#e5e7eb}\n`;\n\n// ── Spinner ────────────────────────────────────────────────────\nfunction Spinner({ id }: { id?: string }) {\n return (\n \n \n \n \n );\n}\n\n// ── Shell layout ───────────────────────────────────────────────\nfunction Layout({ title, children }: { title: string; children: any }) {\n return (\n \n \n \n \n {title}\n \n \n \n\n Engagement Layer\n\n\n\n \n \n \n \n `);\n});\napp.get(\"/callback\", async (c) => {\n const searchParams = new URLSearchParams(c.req.query());\n console.log(searchParams);\n\n return c.html(`\n\n \n \n \n \n \n \n\n Engagement Layer\n\n\n\n \n \n \n `);\n});\n\napp.post(\"/invitation\", async (c) => {\n const searchParams = new URLSearchParams(c.req.query());\n const code = searchParams.get(\"code\");\n const token = searchParams.get(\"gig_i_vToken\");\n const invitationId = searchParams.get(\"invitationId\");\n console.log(code, token, invitationId);\n\n const res = await fetch(\n \"https://accounts.eu1.gigya.com/accounts.auth.group.invite.email.login\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"form-urlencoded\",\n },\n body: new URLSearchParams({\n vToken: token,\n code,\n targetEnv: \"rest\",\n }),\n },\n );\n\n const response = await res.json();\n console.log(response);\n //gigya.accounts.socialLogin({provider:\"oidc-accountssapdev\", redirectURL:\"https://playground.dev-eu10.build.cloud.sap/shelluimain/index.html\", authFlow:\"redirectURL\", loginMode:\"addConnection\"})\n\n const initAddConnection = await fetch(\n `https://accounts.eu1.gigya.com/accounts.initAddConnection?x_provider=oidc-accountssapdev&redirect_uri=https://build-login.val.run/callback?invitationId=${invitationId}`,\n );\n\n return c.redirect(initAddConnection.headers.get(\"location\"));\n});\n\napp.get(\"on-login\", async (c) => {\n return c.redirect(\n \"https://playground.dev-eu10.build.cloud.sap/shelluimain/index.html\",\n );\n});\n\napp.get(\"/state\", async (c) => {\n // return c.text(`${authState} \\nauthState();`)\n return c.text(\n ` \n import { AuthState } from 'https://esm.sh/@gigya/wc@0.0.2/store/auth';\n for await (const state of AuthState()) {\n console.log(\"auth state\", state);\n if (state === 'authenticated') {\n document.body.dispatchEvent(new CustomEvent('onLogin', { bubbles: true }));\n console.log(\"onLogin event dispatched\");\n }\n }`,\n 200,\n {\n \"Content-Type\": \"text/javascript\",\n },\n );\n});\n\napp.get(\"/invitation\", async (c) => {\n return await c.html(`\n\n\n\n \n \n \n \n \n \n Engagement Layer\n\n\n\n \n

\n \n SAP Engagement Layer\n Early Access\n

\n\n \n\n \n \n \n \n\n \n \n

\n\n

\n\n \n

\n \n

You're all set!

\n Access to the SAP Engagement Layer Playground has been granted.\n

\n\n \n

\n Ready to explore\n

\n\n \n

\n \n \n Open Playground\n \n

\n\n \n

\n Need help?\n Contact support\n

\n\n

\n \n\n \n\n\n`);\n});\n\nexport default app.fetch;","build-login",[],[324,400],[324],{"_105":410,"_97":411,"_167":412,"_169":-5,"_170":148,"_171":172,"_173":119,"_107":413,"_102":33,"_175":176,"_177":-5,"_178":22,"_179":-5,"_180":414,"_100":423},"c4cb3d3e-1299-11f1-935e-42dde27851f2","shared","019c96ee-0299-75ff-a0e5-128278076c22",["D",1772058706545],[415],{"_105":416,"_97":417,"_167":418,"_169":412,"_170":148,"_171":172,"_173":119,"_107":419,"_102":33,"_175":193,"_177":420,"_178":22,"_179":-5,"_180":421,"_100":422},"c4cb0f4e-1299-11f1-935e-42dde27851f2","ds-manager.ts","019c96ee-0299-75ff-a0e5-0c58be42f7b8",["D",1772058706545],"// Generic Gigya DS Manager\n// Handles all interactions with Gigya Data Store APIs\n\nexport interface GigyaResponse {\n errorCode: number;\n errorMessage?: string;\n callId?: string;\n time?: string;\n statusCode?: number;\n statusReason?: string;\n}\n\nexport interface DSSearchResponse extends GigyaResponse {\n results?: Array<{\n oid: string;\n data: any;\n lastUpdated?: number;\n lastUpdatedTime?: string;\n created?: number;\n createdTime?: string;\n UID?: string;\n }>;\n objectsCount?: number;\n totalCount?: number;\n nextCursorId?: string;\n}\n\nexport interface DSGetResponse extends GigyaResponse {\n data?: any;\n oid?: string;\n UID?: string;\n lastUpdated?: number;\n lastUpdatedTime?: string;\n created?: number;\n createdTime?: string;\n}\n\nexport interface DSStoreResponse extends GigyaResponse {\n oid?: string;\n}\n\nexport interface DSSchemaResponse extends GigyaResponse {\n schema?: {\n fields?: Record;\n dynamicSchema?: boolean;\n };\n}\n\nexport interface DSTypesResponse extends GigyaResponse {\n types?: string[];\n}\n\nexport class DSManager {\n private domain: string;\n private apiKey: string;\n private appKey: string;\n private appSecret: string;\n\n constructor() {\n // Get credentials from environment variables\n this.domain = Deno.env.get(\"GIGYA_DOMAIN\") || \"accounts.eu1.gigya.com\";\n this.apiKey = Deno.env.get(\"GIGYA_API_KEY\") || \"\";\n this.appKey = Deno.env.get(\"GIGYA_APP_KEY\") || \"\";\n this.appSecret = Deno.env.get(\"GIGYA_APP_SECRET\") || \"\";\n\n if (!this.apiKey || !this.appKey || !this.appSecret) {\n console.warn(\"Missing Gigya environment variables. Some features may not work.\");\n }\n }\n\n private async makeRequest(endpoint: string, params: Record): Promise {\n const url = `https://${this.domain}/${endpoint}?httpStatusCodes=true`;\n\n const body = new URLSearchParams({\n apiKey: this.apiKey,\n userKey: this.appKey,\n secret: this.appSecret,\n ...params,\n });\n\n const response = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body,\n });\n\n if (!response.ok) {\n const text = await response.text();\n throw new Error(`HTTP ${response.status}: ${text}`);\n }\n\n const result = await response.json();\n \n if (result.errorCode !== 0) {\n throw new Error(`Gigya API Error ${result.errorCode}: ${result.errorMessage || 'Unknown error'}`);\n }\n\n return result;\n }\n\n // Get all available data types\n async getTypes(): Promise {\n try {\n const response: DSTypesResponse = await this.makeRequest(\"ds.getTypes\", {});\n return response.types || [];\n } catch (error) {\n console.error(\"Error fetching types:\", error);\n return [];\n }\n }\n\n // Get schema for a specific type\n async getSchema(type: string): Promise {\n try {\n const response: DSSchemaResponse = await this.makeRequest(\"ds.getSchema\", {\n type,\n filter: \"full\"\n });\n return response.schema || null;\n } catch (error) {\n console.error(`Error fetching schema for type ${type}:`, error);\n return null;\n }\n }\n\n // Search data with pagination and filtering\n async searchData(\n type: string, \n searchTerm: string = \"\", \n page: number = 1, \n limit: number = 50\n ): Promise<{ data: any[], totalCount: number, objectsCount: number }> {\n try {\n let query = `SELECT * FROM ${type}`;\n \n // Add search conditions if provided\n if (searchTerm.trim()) {\n // Try to search in common text fields\n const searchConditions = [\n `data CONTAINS \"${searchTerm}\"`,\n `oid CONTAINS \"${searchTerm}\"`\n ];\n query += ` WHERE (${searchConditions.join(\" OR \")})`;\n }\n \n // Add pagination\n const start = (page - 1) * limit;\n query += ` LIMIT ${limit}`;\n if (start > 0) {\n query += ` START ${start}`;\n }\n\n const response: DSSearchResponse = await this.makeRequest(\"ds.search\", {\n query\n });\n\n return {\n data: response.results || [],\n totalCount: response.totalCount || 0,\n objectsCount: response.objectsCount || 0\n };\n } catch (error) {\n console.error(`Error searching data for type ${type}:`, error);\n return { data: [], totalCount: 0, objectsCount: 0 };\n }\n }\n\n // Get a single item by type and ID\n async getItem(type: string, oid: string): Promise {\n try {\n const response: DSGetResponse = await this.makeRequest(\"ds.get\", {\n type,\n oid,\n fields: \"*\"\n });\n\n if (response.data) {\n return {\n oid: response.oid,\n data: response.data,\n lastUpdated: response.lastUpdated,\n lastUpdatedTime: response.lastUpdatedTime,\n created: response.created,\n createdTime: response.createdTime,\n UID: response.UID\n };\n }\n \n return null;\n } catch (error) {\n console.error(`Error fetching item ${oid} of type ${type}:`, error);\n return null;\n }\n }\n\n // Create a new item\n async createItem(type: string, data: any): Promise {\n try {\n const response: DSStoreResponse = await this.makeRequest(\"ds.store\", {\n type,\n data: JSON.stringify(data),\n oid: \"auto\"\n });\n\n return {\n oid: response.oid,\n data\n };\n } catch (error) {\n console.error(`Error creating item of type ${type}:`, error);\n throw error;\n }\n }\n\n // Update an existing item\n async updateItem(type: string, oid: string, data: any): Promise {\n try {\n const response: DSStoreResponse = await this.makeRequest(\"ds.store\", {\n type,\n oid,\n data: JSON.stringify(data),\n updateBehavior: \"replace\"\n });\n\n return {\n oid,\n data\n };\n } catch (error) {\n console.error(`Error updating item ${oid} of type ${type}:`, error);\n throw error;\n }\n }\n\n // Delete an item\n async deleteItem(type: string, oid: string): Promise {\n try {\n await this.makeRequest(\"ds.delete\", {\n type,\n oid,\n fields: \"*\"\n });\n } catch (error) {\n console.error(`Error deleting item ${oid} of type ${type}:`, error);\n throw error;\n }\n }\n\n // Execute a custom query\n async executeQuery(query: string): Promise {\n try {\n const response: DSSearchResponse = await this.makeRequest(\"ds.search\", {\n query\n });\n\n return {\n results: response.results || [],\n totalCount: response.totalCount || 0,\n objectsCount: response.objectsCount || 0\n };\n } catch (error) {\n console.error(\"Error executing custom query:\", error);\n throw error;\n }\n }\n\n // Set schema for a type\n async setSchema(type: string, schema: any): Promise {\n try {\n await this.makeRequest(\"ds.setSchema\", {\n type,\n dataSchema: JSON.stringify(schema)\n });\n } catch (error) {\n console.error(`Error setting schema for type ${type}:`, error);\n throw error;\n }\n }\n\n // Delete schema fields\n async deleteSchemaFields(type: string, fields: string[]): Promise {\n try {\n await this.makeRequest(\"ds.deleteSchemaFields\", {\n type,\n dataSchema: JSON.stringify(fields)\n });\n } catch (error) {\n console.error(`Error deleting schema fields for type ${type}:`, error);\n throw error;\n }\n }\n}",[],[411,417],[411],{"_105":425,"_97":101,"_167":426,"_169":-5,"_170":148,"_171":427,"_173":119,"_107":428,"_102":429,"_175":193,"_177":430,"_178":22,"_179":-5,"_180":431,"_100":432},"e277eb5c-13c0-11f1-a776-42dde27851f2","3f72f564-13c0-11f1-89a0-42dde27851f2",228,["D",1772185457914],12,"import {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n data:{\n access:string | string[] |undefined\n }\n};\n\n\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile,data from accounts limit 1000 \",\n apiKey: Deno.env.get(\"GIGYA_API_KEY\")!,\n userKey: Deno.env.get(\"GIGYA_APP_KEY\")!,\n secret: Deno.env.get(\"GIGY_APP_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data?.access && accounts.groups.length\n}",[],[101],{"_105":434,"_97":435,"_167":436,"_169":-5,"_170":148,"_171":172,"_173":119,"_107":437,"_102":33,"_175":193,"_177":74,"_178":22,"_179":-5,"_180":438,"_100":439},"c4cf6580-1299-11f1-935e-42dde27851f2","main.tsx","019c96ee-0299-75ff-a0e5-420f45304b65",["D",1772058706545],[],[435],{"_105":441,"_97":442,"_167":443,"_169":-5,"_170":148,"_171":444,"_173":119,"_107":445,"_102":33,"_175":193,"_177":74,"_178":22,"_179":-5,"_180":446,"_100":447},"ada4f7b0-1327-11f1-a0f0-42dde27851f2","new-file-4084.ts","ada4f850-1327-11f1-a0f0-42dde27851f2",102,["D",1772119656294],[],[442],"files",[164,182,188,197,205,213,223,235,242,252,261,272,278,283,291,299,306,315,322,329,338,349,360,369,378,389,398,409,415,424,433,440],"counts",{"_452":33,"_453":172,"_454":33,"_455":456,"_460":461},"pulls","branches","forks","envVars",{"_457":458,"_459":33},"count",5,"emptyCount","connections",{"_457":33,"_462":33},"unfilledCount","contents",[],{"_105":425,"_97":101,"_167":426,"_169":-5,"_170":148,"_171":427,"_173":119,"_107":466,"_102":429,"_175":193,"_177":430,"_178":22,"_179":-5,"_100":467},["D",1772185457914],[101],"upstreamProject",{"_105":157,"_97":470,"_113":-5,"_114":-5,"_111":155,"_23":471},"os",{"_95":96,"_138":139},"upstreamBranch",{"_105":151,"_107":474,"_475":476,"_97":45,"_149":157,"_102":153,"_150":-5,"_152":-5,"_477":478,"_109":-5,"_161":22,"_111":155,"_160":96,"_16":123,"_159":470},["D",1749131789618],"updatedAt",["D",1762014309157],"lockfileKey","1764098888052-esm.town_v_dinavinter_os@169-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_95":96,"_97":98,"_99":45,"_100":101,"_103":485,"_248":490,"_493":494,"_561":562,"_577":-7,"_578":33,"_579":22},{"_105":106,"_97":98,"_107":486,"_109":-5,"_110":22,"_111":112,"_113":-5,"_114":-5,"_14":115,"_116":117,"_118":119,"_120":-5,"_121":-5,"_122":33,"_16":123,"_124":125,"_126":127,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":487,"_140":488,"_145":489,"_161":22},["D",1772058706545],{"_95":96,"_138":139},{"_95":96,"_142":139,"_14":115,"_143":144},{"_102":147,"_97":45,"_105":148,"_149":106,"_150":151,"_152":153,"_154":155,"_156":157,"_158":123,"_159":98,"_160":96},{"_105":425,"_97":101,"_167":426,"_169":-5,"_170":148,"_171":427,"_173":119,"_107":491,"_102":429,"_175":193,"_177":430,"_178":22,"_179":-5,"_100":492},["D",1772185457914],[101],"history",[495,497,503,509,514,520,526,531,536,541,546,552,556],{"_105":425,"_170":148,"_167":426,"_97":101,"_177":430,"_175":193,"_102":429,"_169":-5,"_107":496,"_171":427,"_179":-5},["D",1772185457914],{"_105":498,"_170":148,"_167":426,"_97":101,"_177":499,"_175":193,"_102":500,"_169":-5,"_107":501,"_171":502,"_179":-5},"dda955a2-13c0-11f1-9fa8-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n data:{\n access:string | string[] |undefined\n }\n};\n\n\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile,data from accounts limit 1000 \",\n apiKey: Deno.env.get(\"GIGYA_API_KEY\")!,\n userKey: Deno.env.get(\"GIGYA_APP_KEY\")!,\n secret: Deno.env.get(\"GIGY_APP_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data?.access && accounts.groups.length\n}",11,["D",1772185449860],227,{"_105":504,"_170":148,"_167":426,"_97":101,"_177":505,"_175":193,"_102":506,"_169":-5,"_107":507,"_171":508,"_179":-5},"d4efedd6-13c0-11f1-a776-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n data:{\n access:\n }\n};\n\n\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile,data from accounts limit 1000 \",\n apiKey: Deno.env.get(\"GIGYA_API_KEY\")!,\n userKey: Deno.env.get(\"GIGYA_APP_KEY\")!,\n secret: Deno.env.get(\"GIGY_APP_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data?.access && accounts.groups.length\n}",10,["D",1772185435219],226,{"_105":510,"_170":148,"_167":426,"_97":101,"_177":511,"_175":193,"_102":355,"_169":-5,"_107":512,"_171":513,"_179":-5},"ccff00da-13c0-11f1-8245-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile,data from accounts limit 1000 \",\n apiKey: Deno.env.get(\"GIGYA_API_KEY\")!,\n userKey: Deno.env.get(\"GIGYA_APP_KEY\")!,\n secret: Deno.env.get(\"GIGY_APP_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data?.access && accounts.groups.length\n}",["D",1772185421896],225,{"_105":515,"_170":148,"_167":426,"_97":101,"_177":516,"_175":193,"_102":517,"_169":-5,"_107":518,"_171":519,"_179":-5},"b67b6682-13c0-11f1-878f-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data?.access && accounts.groups.length\n}",8,["D",1772185384122],224,{"_105":521,"_170":148,"_167":426,"_97":101,"_177":522,"_175":193,"_102":523,"_169":-5,"_107":524,"_171":525,"_179":-5},"b4b6e65a-13c0-11f1-9cd5-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data.access && accounts.groups.length\n}",7,["D",1772185381162],223,{"_105":527,"_170":148,"_167":426,"_97":101,"_177":528,"_175":193,"_102":344,"_169":-5,"_107":529,"_171":530,"_179":-5},"a59c5e66-13c0-11f1-930c-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n return !account.data.access\n}",["D",1772185355819],222,{"_105":532,"_170":148,"_167":426,"_97":101,"_177":533,"_175":193,"_102":458,"_169":-5,"_107":534,"_171":535,"_179":-5},"8df8298e-13c0-11f1-9c63-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@build.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n const { status, retry: attempts, started }: Partial =\n trace.get(account.UID) || {};\n function retry() {\n return status === \"error\" && attempts < 3;\n }\n\n function dropped(duration?: Temporal.Duration) {\n const droppedDuration = Temporal.Duration.from(duration || { minutes: 1 });\n return status === \"started\" || status === \"creating\" &&\n Temporal.Now.instant().subtract(droppedDuration)\n .epochMilliseconds >\n Temporal.Instant.from(started).epochMilliseconds;\n }\n\n function pending() {\n return !status;\n }\n\n function done() {\n console.log(account?.profile?.photoURL);\n return account?.profile?.photoURL?.startsWith(\"https://cdns.gigya.com\");\n }\n function ready() {\n return !!account?.UID &&\n !!account?.profile?.nickname;\n }\n\n return ready() && !done() && (pending() || retry() || dropped()) &&\n account?.profile?.nickname != \"Taylor Swift\";\n}",["D",1772185316162],221,{"_105":537,"_170":148,"_167":426,"_97":101,"_177":538,"_175":193,"_102":229,"_169":-5,"_107":539,"_171":540,"_179":-5},"8402bc6e-13c0-11f1-a4ce-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@aiam.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\nconst photoDoc = getOrCreateDoc(\"@aiam.cache\");\nconst photoCache = photoDoc.getMap(\"hero\");\nconst trace = getOrCreateDoc(\"@aiam.trace\").getMap(\"hero\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n await updateAccount(account);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n \n\n \nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n const { status, retry: attempts, started }: Partial =\n trace.get(account.UID) || {};\n function retry() {\n return status === \"error\" && attempts < 3;\n }\n\n function dropped(duration?: Temporal.Duration) {\n const droppedDuration = Temporal.Duration.from(duration || { minutes: 1 });\n return status === \"started\" || status === \"creating\" &&\n Temporal.Now.instant().subtract(droppedDuration)\n .epochMilliseconds >\n Temporal.Instant.from(started).epochMilliseconds;\n }\n\n function pending() {\n return !status;\n }\n\n function done() {\n console.log(account?.profile?.photoURL);\n return account?.profile?.photoURL?.startsWith(\"https://cdns.gigya.com\");\n }\n function ready() {\n return !!account?.UID &&\n !!account?.profile?.nickname;\n }\n\n return ready() && !done() && (pending() || retry() || dropped()) &&\n account?.profile?.nickname != \"Taylor Swift\";\n}",["D",1772185299451],220,{"_105":542,"_170":148,"_167":426,"_97":101,"_177":543,"_175":193,"_102":267,"_169":-5,"_107":544,"_171":545,"_179":-5},"66b0446a-13c0-11f1-87d3-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@aiam.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\nconst photoDoc = getOrCreateDoc(\"@aiam.cache\");\nconst photoCache = photoDoc.getMap(\"hero\");\nconst trace = getOrCreateDoc(\"@aiam.trace\").getMap(\"hero\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n // await generateHeroImage(account.UID, account.profile?.nickname!);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n async function generateHeroImage(\n uid: string,\n heroName: string,\n ): Promise {\n if (heroName === \"Null Pointer\") {\n console.log(\"using cache for\", heroName);\n await setUserPhotoFromUrl(\n uid,\n \"https://cdns.gigya.com/photos/649684986711/556c68b906224c7597687c1dcd8be955/orig\",\n );\n return;\n }\n if (\n photoCache?.has(heroName) &&\n photoCache?.get(heroName)?.startsWith(\"https://\")\n ) {\n console.log(\"using cache for\", heroName);\n const imgUrl = photoCache?.get(heroName);\n await setUserPhotoFromUrl(uid, imgUrl!);\n return;\n }\n\n const { image } = await generateImage({\n model: azure.imageModel(\"dall-e-3\"),\n prompt:\n `you are a comics expert generate a hero image for the hero \"${heroName}\"`,\n size: \"1024x1024\",\n });\n\n const resizedImage = await resize(image.uint8Array, {\n width: 300,\n height: 300,\n });\n\n const blob = new Blob([resizedImage], { type: \"image/png\" });\n const smallImage = encodeBase64(await blob.arrayBuffer());\n\n await setUserProfiePicture(uid, smallImage);\n }\n\n async function setUserProfiePicture(uid: string, base64Image: string) {\n const params: any = {\n apiKey: Deno.env.get(\"API_KEY\")!,\n uid: uid,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n publish: \"true\",\n photoBytes: base64Image,\n };\n const url = new URLSearchParams(params);\n\n const response = await fetch(\n \"https://accounts.eu1.gigya.com/accounts.setProfilePhoto?httpStatusCodes=true\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: url.toString(),\n },\n );\n\n if (!response.ok) {\n console.error(\"fail to import image url\", response.statusText);\n const text = await response.text();\n console.error(text);\n throw new Error(response.statusText + \" \" + text);\n }\n\n const json = await response.json();\n console.log(json);\n }\n\n async function setUserPhotoFromUrl(uid: string, url: string) {\n const response = await fetch(\n \"https://accounts.eu1.gigya.com/accounts.importProfilePhoto?httpStatusCodes=true\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n apiKey: Deno.env.get(\"API_KEY\")!,\n \"uid\": uid,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n \"publish\": \"true\",\n \"url\": url,\n }),\n },\n );\n if (!response.ok) {\n console.error(\"fail to import image url\", response.statusText);\n const text = await response.text();\n console.error(text);\n throw new Error(response.statusText + \" \" + text);\n }\n\n const json = await response.json();\n console.log(json);\n }\n}\n\nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n const { status, retry: attempts, started }: Partial =\n trace.get(account.UID) || {};\n function retry() {\n return status === \"error\" && attempts < 3;\n }\n\n function dropped(duration?: Temporal.Duration) {\n const droppedDuration = Temporal.Duration.from(duration || { minutes: 1 });\n return status === \"started\" || status === \"creating\" &&\n Temporal.Now.instant().subtract(droppedDuration)\n .epochMilliseconds >\n Temporal.Instant.from(started).epochMilliseconds;\n }\n\n function pending() {\n return !status;\n }\n\n function done() {\n console.log(account?.profile?.photoURL);\n return account?.profile?.photoURL?.startsWith(\"https://cdns.gigya.com\");\n }\n function ready() {\n return !!account?.UID &&\n !!account?.profile?.nickname;\n }\n\n return ready() && !done() && (pending() || retry() || dropped()) &&\n account?.profile?.nickname != \"Taylor Swift\";\n}",["D",1772185250253],219,{"_105":547,"_170":148,"_167":426,"_97":101,"_177":548,"_175":193,"_102":549,"_169":-5,"_107":550,"_171":551,"_179":-5},"5dea8912-13c0-11f1-a61c-42dde27851f2","import { resize } from \"https://deno.land/x/deno_image/mod.ts\";\nimport {\n filterAsync,\n yArrayIterator,\n yMapIterate,\n} from \"https://esm.sh/@cxai/stream\";\nimport { Temporal } from \"https://esm.sh/@js-temporal/polyfill\";\nimport onlyOnce from \"https://esm.town/v/dinavinter/dcom/async/o\";\nimport { getOrCreateDoc } from \"https://esm.town/v/dinavinter/doc\";\nimport { encodeBase64 } from \"jsr:@std/encoding/base64\";\nimport { azure } from \"npm:@ai-sdk/azure\";\nimport {\n experimental_generateImage as generateImage,\n generateText,\n} from \"npm:ai\";\nimport { type QueueItem } from \"../async/o\";\n\ntype Account = {\n UID: string;\n profile: {\n email: string;\n firstName: string;\n lastName: string;\n nickname?: string;\n photoURL?: string;\n };\n};\n\ntype NewHerorParams = {\n name: string;\n};\nconst accountsDoc = getOrCreateDoc(\"@aiam.accounts\");\nconst accountsMap = accountsDoc?.getMap(\"account\");\nconst photoDoc = getOrCreateDoc(\"@aiam.cache\");\nconst photoCache = photoDoc.getMap(\"hero\");\nconst trace = getOrCreateDoc(\"@aiam.trace\").getMap(\"hero\");\n\nexport default async function (interval: Interval) {\n const updatePicture = (account: Account) => shouldProcessItem(account);\n\n const accounts = await searchAccounts();\n\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n\n async function generateFromAccounts() {\n const accounts = await searchAccounts();\n console.log(\n \"Updating hero images from search\",\n accounts.filter(shouldProcessItem).length,\n );\n for (const account of accounts.filter(shouldProcessItem)) {\n await handleAccount(account);\n }\n }\n setInterval(generateFromAccounts, 10_000);\n\n console.log(\"listen to new events\", accountsMap.size);\n for await (\n const [key, account] of filterAsync(\n yMapIterate(accountsMap),\n shouldProcessItem,\n )\n ) {\n await handleAccount(account);\n }\n\n async function handleAccount(account: Account) {\n try {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"started\",\n started: Temporal.Now.instant().toString(),\n });\n console.log(`Generating hero image for ${account.profile?.nickname}`);\n // await generateHeroImage(account.UID, account.profile?.nickname!);\n console.log(`Generated hero image for ${account.profile?.nickname}`);\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"done\",\n completed: Temporal.Now.instant().toString(),\n });\n } catch (e) {\n trace.set(account.UID, {\n ...trace.get(account.UID),\n status: \"error\",\n error: {\n message: \"message\" in e ? e.message : e,\n stack: \"stack\" in e ? e.stack : undefined,\n name: \"name\" in e ? e.name : undefined,\n time: Temporal.Now.instant().toString(),\n },\n failed: Temporal.Now.instant().toString(),\n retry: (trace.get(account.UID)?.retry || 0) + 1,\n });\n }\n }\n\n photoCache.set(\n \"Null Pointer\",\n \"https://cdns.gigya.com/photos/649684986711/556c68b906224c7597687c1dcd8be955/orig\",\n );\n\n async function generateHeroImage(\n uid: string,\n heroName: string,\n ): Promise {\n if (heroName === \"Null Pointer\") {\n console.log(\"using cache for\", heroName);\n await setUserPhotoFromUrl(\n uid,\n \"https://cdns.gigya.com/photos/649684986711/556c68b906224c7597687c1dcd8be955/orig\",\n );\n return;\n }\n if (\n photoCache?.has(heroName) &&\n photoCache?.get(heroName)?.startsWith(\"https://\")\n ) {\n console.log(\"using cache for\", heroName);\n const imgUrl = photoCache?.get(heroName);\n await setUserPhotoFromUrl(uid, imgUrl!);\n return;\n }\n\n const { image } = await generateImage({\n model: azure.imageModel(\"dall-e-3\"),\n prompt:\n `you are a comics expert generate a hero image for the hero \"${heroName}\"`,\n size: \"1024x1024\",\n });\n\n const resizedImage = await resize(image.uint8Array, {\n width: 300,\n height: 300,\n });\n\n const blob = new Blob([resizedImage], { type: \"image/png\" });\n const smallImage = encodeBase64(await blob.arrayBuffer());\n\n await setUserProfiePicture(uid, smallImage);\n }\n\n async function setUserProfiePicture(uid: string, base64Image: string) {\n const params: any = {\n apiKey: Deno.env.get(\"API_KEY\")!,\n uid: uid,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n publish: \"true\",\n photoBytes: base64Image,\n };\n const url = new URLSearchParams(params);\n\n const response = await fetch(\n \"https://accounts.eu1.gigya.com/accounts.setProfilePhoto?httpStatusCodes=true\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: url.toString(),\n },\n );\n\n if (!response.ok) {\n console.error(\"fail to import image url\", response.statusText);\n const text = await response.text();\n console.error(text);\n throw new Error(response.statusText + \" \" + text);\n }\n\n const json = await response.json();\n console.log(json);\n }\n\n async function setUserPhotoFromUrl(uid: string, url: string) {\n const response = await fetch(\n \"https://accounts.eu1.gigya.com/accounts.importProfilePhoto?httpStatusCodes=true\",\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n apiKey: Deno.env.get(\"API_KEY\")!,\n \"uid\": uid,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n \"publish\": \"true\",\n \"url\": url,\n }),\n },\n );\n if (!response.ok) {\n console.error(\"fail to import image url\", response.statusText);\n const text = await response.text();\n console.error(text);\n throw new Error(response.statusText + \" \" + text);\n }\n\n const json = await response.json();\n console.log(json);\n }\n}\n\nasync function searchAccounts() {\n const response = await fetch(\n `https://accounts.eu1.gigya.com/accounts.search?httpStatusCodes=true`,\n {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Origin\": \"https://accounts.eu1.gigya.com\",\n },\n body: new URLSearchParams({\n \"query\": \"select UID,profile from accounts limit 1000 \",\n apiKey: Deno.env.get(\"API_KEY\")!,\n userKey: Deno.env.get(\"CLIENT_ID\")!,\n secret: Deno.env.get(\"CLIENT_SECRET\")!,\n }),\n },\n );\n if (!response.ok) {\n console.error(response.statusText);\n console.error(await response.text());\n throw new Error(response.statusText);\n }\n const json = await response.json();\n const accounts = json.results;\n return accounts;\n}\n\nfunction shouldProcessItem(account: Account): boolean {\n const { status, retry: attempts, started }: Partial =\n trace.get(account.UID) || {};\n function retry() {\n return status === \"error\" && attempts < 3;\n }\n\n function dropped(duration?: Temporal.Duration) {\n const droppedDuration = Temporal.Duration.from(duration || { minutes: 1 });\n return status === \"started\" || status === \"creating\" &&\n Temporal.Now.instant().subtract(droppedDuration)\n .epochMilliseconds >\n Temporal.Instant.from(started).epochMilliseconds;\n }\n\n function pending() {\n return !status;\n }\n\n function done() {\n console.log(account?.profile?.photoURL);\n return account?.profile?.photoURL?.startsWith(\"https://cdns.gigya.com\");\n }\n function ready() {\n return !!account?.UID &&\n !!account?.profile?.nickname;\n }\n\n return ready() && !done() && (pending() || retry() || dropped()) &&\n account?.profile?.nickname != \"Taylor Swift\";\n}",2,["D",1772185235536],218,{"_105":553,"_170":148,"_167":426,"_97":101,"_177":74,"_175":193,"_102":172,"_169":-5,"_107":554,"_171":555,"_179":-5},"4244c9f2-13c0-11f1-96c7-42dde27851f2",["D",1772185189152],217,{"_105":557,"_170":148,"_167":426,"_97":558,"_177":74,"_175":193,"_102":33,"_169":-5,"_107":559,"_171":560,"_179":-5},"3f72f4a6-13c0-11f1-89a0-42dde27851f2","new-file-1314.ts",["D",1772185184424],216,"versions",[563,565,566,567,568,569,570,571,572,573,574,575,576],{"_248":495,"_564":497},"previous",{"_248":497,"_564":503},{"_248":503,"_564":509},{"_248":509,"_564":514},{"_248":514,"_564":520},{"_248":520,"_564":526},{"_248":526,"_564":531},{"_248":531,"_564":536},{"_248":536,"_564":541},{"_248":541,"_564":546},{"_248":546,"_564":552},{"_248":552,"_564":556},{"_248":556,"_564":-5},"versionNumber","page","hasNext","actionData","errors"]

\n {isImport ? 'Import New Account' : `Edit Account ${account?.UID}`}\n

Account Identifier

Profile Information

Profile Information

Custom Data

Custom Data

Add Custom Data Field

Account Viewer

\n Search Results ({totalCount}{\" \"}\n {totalCount === 1 ? \"account\" : \"accounts\"} found)\n

\n No accounts found\n

Edit Account

Import New Account

{type} Data

Metadata (Read-only)

\n {isEdit ? \"Edit\" : \"Create\"} {type} Data\n

Select Data Type

DS Store Viewer

Create New {type}

Edit {type}

Group Management

Define User Criteria

Preview & Select Users

Choose Action

Configure Parameters

Review & Execute

Send Invitations

\n SAP Engagement Layer\n

You're invited!

You're all set!

dinavinter

gigya

History for cron.ts