[{"_1":2,"_182":-5,"_183":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","95c2b214125f68b24ec9fda4034953728efbbf27","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_158":159,"_179":180,"_181":-5},"handle","dinavinter","name","gigya","path","shared/ds-manager.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":115,"_116":117,"_118":-5,"_119":-5,"_120":33,"_14":121,"_122":-5,"_123":-5,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_141":142,"_157":20},"id","c4c1f54e-1299-11f1-935e-42dde27851f2","createdAt",["D",1772058706545],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","6d45e71e-9df4-45e8-82ab-e09c45bfc5a1","pinnedFileId","019c96ee-0299-75ff-a0e5-06213cee5100","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","b636164b-34c9-4e0c-9d39-dd3dc6f25436","tursoName","tursoHostname","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ycVgxSUNRd1V1VDlqTnNmYUh6MDA0VW1ldlMifQ","org",{"_95":96,"_138":135,"_12":113,"_139":140},"avatar","tier","pro","branch",{"_143":144,"_97":45,"_103":145,"_146":104,"_147":148,"_149":150,"_151":110,"_152":153,"_154":121,"_155":98,"_156":96},"version",32,"c4c50bbc-1299-11f1-935e-42dde27851f2","projectId","forkedBranchId","e15cf164-4214-11f0-b519-76b3cceeab13","forkedBranchVersion",169,"forkedProjectPrivacy","forkedProjectId","e15ca240-4214-11f0-b519-76b3cceeab13","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":160,"_97":161,"_162":163,"_164":165,"_166":145,"_167":168,"_169":117,"_105":170,"_143":33,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"c4cb0f4e-1299-11f1-935e-42dde27851f2","ds-manager.ts","fileId","019c96ee-0299-75ff-a0e5-0c58be42f7b8","parentId","019c96ee-0299-75ff-a0e5-128278076c22","branchId","branchVersion",1,"latest",["D",1772058706545],"fileType","script","content","// 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}","deleted","label",[178,161],"shared","permalink","https://www.val.town/x/dinavinter/gigya/code/shared/ds-manager.ts","extension","actionData","errors"]