{
+ if (node) {
+ templateCardRefs.current[tmpl.eventSlug] = node;
+ } else {
+ delete templateCardRefs.current[tmpl.eventSlug];
+ }
+ }}
+ className={`rounded-xl bg-white border shadow-sm overflow-hidden transition-all duration-300 ${
+ highlightedEventSlug === tmpl.eventSlug
+ ? 'border-primary-blue ring-2 ring-indigo-200 animate-pulse'
+ : 'border-gray-200'
+ }`}
+ >
diff --git a/server/fdk.js b/server/fdk.js
index bd517f3..941ba55 100644
--- a/server/fdk.js
+++ b/server/fdk.js
@@ -2,6 +2,7 @@ require('dotenv').config();
const { setupFdk } = require('@gofynd/fdk-extension-javascript/express');
const { MemoryStorage } = require('@gofynd/fdk-extension-javascript/express/storage');
+const { createFdkStorage } = require('./postgresFdkStorage');
function normalizeEnvText(value) {
return typeof value === 'string' ? value.trim() : '';
@@ -22,11 +23,21 @@ function createFdkExtension() {
const apiSecret = normalizeEnvText(process.env.EXTENSION_API_SECRET);
const baseUrl = normalizeEnvText(process.env.EXTENSION_BASE_URL || process.env.EXTENSION_URL);
const cluster = normalizeEnvText(process.env.EXTENSION_CLUSTER_URL) || 'https://api.fynd.com';
+ const storageConnectionString = normalizeEnvText(process.env.FDK_STORAGE_CONNECTION_STRING);
if (!apiKey || !apiSecret || !baseUrl) {
return null;
}
+ const storage = createFdkStorage({
+ prefixKey: 'sms_extension_',
+ connectionString: storageConnectionString,
+ }) || new MemoryStorage('sms_extension_');
+
+ if (!storageConnectionString) {
+ console.warn('[FDK] FDK_STORAGE_CONNECTION_STRING is not set; falling back to in-memory session storage.');
+ }
+
try {
return setupFdk({
api_key: apiKey,
@@ -41,7 +52,7 @@ function createFdkExtension() {
console.log(`[FDK] uninstall callback received for company ${companyId || 'unknown'}`);
},
},
- storage: new MemoryStorage('sms_extension_'),
+ storage,
access_mode: 'offline',
});
} catch (error) {
diff --git a/server/package-lock.json b/server/package-lock.json
index 3970eb3..49fc4aa 100644
--- a/server/package-lock.json
+++ b/server/package-lock.json
@@ -17,6 +17,7 @@
"express": "^4.18.2",
"multer": "^1.4.5-lts.1",
"openai": "^4.28.0",
+ "pg": "^8.20.0",
"uuid": "^13.0.0"
},
"devDependencies": {
@@ -1668,6 +1669,96 @@
"integrity": "sha512-RA1GjUVMnvYFxuqovrEqZoxxW5NUZqbwKtYz/Tt7nXerk0LbLblQmrsgdeOxV5SFHf0UDggjS/bSeOZwt1pmEQ==",
"license": "MIT"
},
+ "node_modules/pg": {
+ "version": "8.20.0",
+ "resolved": "https://registry.npmjs.org/pg/-/pg-8.20.0.tgz",
+ "integrity": "sha512-ldhMxz2r8fl/6QkXnBD3CR9/xg694oT6DZQ2s6c/RI28OjtSOpxnPrUCGOBJ46RCUxcWdx3p6kw/xnDHjKvaRA==",
+ "license": "MIT",
+ "peer": true,
+ "dependencies": {
+ "pg-connection-string": "^2.12.0",
+ "pg-pool": "^3.13.0",
+ "pg-protocol": "^1.13.0",
+ "pg-types": "2.2.0",
+ "pgpass": "1.0.5"
+ },
+ "engines": {
+ "node": ">= 16.0.0"
+ },
+ "optionalDependencies": {
+ "pg-cloudflare": "^1.3.0"
+ },
+ "peerDependencies": {
+ "pg-native": ">=3.0.1"
+ },
+ "peerDependenciesMeta": {
+ "pg-native": {
+ "optional": true
+ }
+ }
+ },
+ "node_modules/pg-cloudflare": {
+ "version": "1.3.0",
+ "resolved": "https://registry.npmjs.org/pg-cloudflare/-/pg-cloudflare-1.3.0.tgz",
+ "integrity": "sha512-6lswVVSztmHiRtD6I8hw4qP/nDm1EJbKMRhf3HCYaqud7frGysPv7FYJ5noZQdhQtN2xJnimfMtvQq21pdbzyQ==",
+ "license": "MIT",
+ "optional": true
+ },
+ "node_modules/pg-connection-string": {
+ "version": "2.12.0",
+ "resolved": "https://registry.npmjs.org/pg-connection-string/-/pg-connection-string-2.12.0.tgz",
+ "integrity": "sha512-U7qg+bpswf3Cs5xLzRqbXbQl85ng0mfSV/J0nnA31MCLgvEaAo7CIhmeyrmJpOr7o+zm0rXK+hNnT5l9RHkCkQ==",
+ "license": "MIT"
+ },
+ "node_modules/pg-int8": {
+ "version": "1.0.1",
+ "resolved": "https://registry.npmjs.org/pg-int8/-/pg-int8-1.0.1.tgz",
+ "integrity": "sha512-WCtabS6t3c8SkpDBUlb1kjOs7l66xsGdKpIPZsg4wR+B3+u9UAum2odSsF9tnvxg80h4ZxLWMy4pRjOsFIqQpw==",
+ "license": "ISC",
+ "engines": {
+ "node": ">=4.0.0"
+ }
+ },
+ "node_modules/pg-pool": {
+ "version": "3.13.0",
+ "resolved": "https://registry.npmjs.org/pg-pool/-/pg-pool-3.13.0.tgz",
+ "integrity": "sha512-gB+R+Xud1gLFuRD/QgOIgGOBE2KCQPaPwkzBBGC9oG69pHTkhQeIuejVIk3/cnDyX39av2AxomQiyPT13WKHQA==",
+ "license": "MIT",
+ "peerDependencies": {
+ "pg": ">=8.0"
+ }
+ },
+ "node_modules/pg-protocol": {
+ "version": "1.13.0",
+ "resolved": "https://registry.npmjs.org/pg-protocol/-/pg-protocol-1.13.0.tgz",
+ "integrity": "sha512-zzdvXfS6v89r6v7OcFCHfHlyG/wvry1ALxZo4LqgUoy7W9xhBDMaqOuMiF3qEV45VqsN6rdlcehHrfDtlCPc8w==",
+ "license": "MIT"
+ },
+ "node_modules/pg-types": {
+ "version": "2.2.0",
+ "resolved": "https://registry.npmjs.org/pg-types/-/pg-types-2.2.0.tgz",
+ "integrity": "sha512-qTAAlrEsl8s4OiEQY69wDvcMIdQN6wdz5ojQiOy6YRMuynxenON0O5oCpJI6lshc6scgAY8qvJ2On/p+CXY0GA==",
+ "license": "MIT",
+ "dependencies": {
+ "pg-int8": "1.0.1",
+ "postgres-array": "~2.0.0",
+ "postgres-bytea": "~1.0.0",
+ "postgres-date": "~1.0.4",
+ "postgres-interval": "^1.1.0"
+ },
+ "engines": {
+ "node": ">=4"
+ }
+ },
+ "node_modules/pgpass": {
+ "version": "1.0.5",
+ "resolved": "https://registry.npmjs.org/pgpass/-/pgpass-1.0.5.tgz",
+ "integrity": "sha512-FdW9r/jQZhSeohs1Z3sI1yxFQNFvMcnmfuj4WBMUTxOrAyLMaTcE1aAMBiTlbMNaXvBCQuVi0R7hd8udDSP7ug==",
+ "license": "MIT",
+ "dependencies": {
+ "split2": "^4.1.0"
+ }
+ },
"node_modules/picomatch": {
"version": "2.3.2",
"resolved": "https://registry.npmjs.org/picomatch/-/picomatch-2.3.2.tgz",
@@ -1681,6 +1772,45 @@
"url": "https://github.com/sponsors/jonschlinkert"
}
},
+ "node_modules/postgres-array": {
+ "version": "2.0.0",
+ "resolved": "https://registry.npmjs.org/postgres-array/-/postgres-array-2.0.0.tgz",
+ "integrity": "sha512-VpZrUqU5A69eQyW2c5CA1jtLecCsN2U/bD6VilrFDWq5+5UIEVO7nazS3TEcHf1zuPYO/sqGvUvW62g86RXZuA==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=4"
+ }
+ },
+ "node_modules/postgres-bytea": {
+ "version": "1.0.1",
+ "resolved": "https://registry.npmjs.org/postgres-bytea/-/postgres-bytea-1.0.1.tgz",
+ "integrity": "sha512-5+5HqXnsZPE65IJZSMkZtURARZelel2oXUEO8rH83VS/hxH5vv1uHquPg5wZs8yMAfdv971IU+kcPUczi7NVBQ==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=0.10.0"
+ }
+ },
+ "node_modules/postgres-date": {
+ "version": "1.0.7",
+ "resolved": "https://registry.npmjs.org/postgres-date/-/postgres-date-1.0.7.tgz",
+ "integrity": "sha512-suDmjLVQg78nMK2UZ454hAG+OAW+HQPZ6n++TNDUX+L0+uUlLywnoxJKDou51Zm+zTCjrCl0Nq6J9C5hP9vK/Q==",
+ "license": "MIT",
+ "engines": {
+ "node": ">=0.10.0"
+ }
+ },
+ "node_modules/postgres-interval": {
+ "version": "1.2.0",
+ "resolved": "https://registry.npmjs.org/postgres-interval/-/postgres-interval-1.2.0.tgz",
+ "integrity": "sha512-9ZhXKM/rw350N1ovuWHbGxnGh/SNJ4cnxHiM0rxE4VN41wsg8P8zWn9hv/buK00RP4WvlOyr/RBDiptyxVbkZQ==",
+ "license": "MIT",
+ "dependencies": {
+ "xtend": "^4.0.0"
+ },
+ "engines": {
+ "node": ">=0.10.0"
+ }
+ },
"node_modules/process-nextick-args": {
"version": "2.0.1",
"resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-2.0.1.tgz",
@@ -2007,6 +2137,15 @@
"node": ">=6"
}
},
+ "node_modules/split2": {
+ "version": "4.2.0",
+ "resolved": "https://registry.npmjs.org/split2/-/split2-4.2.0.tgz",
+ "integrity": "sha512-UcjcJOWknrNkF6PLX83qcHM6KHgVKNkV62Y8a5uYDVv9ydGQVwAHMKqHdJje1VTWpljG0WYpCDhrCdAOYH4TWg==",
+ "license": "ISC",
+ "engines": {
+ "node": ">= 10.x"
+ }
+ },
"node_modules/stack-trace": {
"version": "0.0.10",
"resolved": "https://registry.npmjs.org/stack-trace/-/stack-trace-0.0.10.tgz",
diff --git a/server/package.json b/server/package.json
index 2b11c4d..daab0b2 100644
--- a/server/package.json
+++ b/server/package.json
@@ -17,6 +17,7 @@
"express": "^4.18.2",
"multer": "^1.4.5-lts.1",
"openai": "^4.28.0",
+ "pg": "^8.20.0",
"uuid": "^13.0.0"
},
"devDependencies": {
diff --git a/server/postgresFdkStorage.js b/server/postgresFdkStorage.js
new file mode 100644
index 0000000..2b7dd80
--- /dev/null
+++ b/server/postgresFdkStorage.js
@@ -0,0 +1,149 @@
+const { Pool } = require('pg');
+const BaseStorage = require('@gofynd/fdk-extension-javascript/express/storage/base_storage');
+
+const DEFAULT_TABLE_NAME = 'fdk session storage';
+
+function normalizeEnvText(value) {
+ return typeof value === 'string' ? value.trim() : '';
+}
+
+function quoteIdentifier(identifier) {
+ return `"${String(identifier).replace(/"/g, '""')}"`;
+}
+
+function shouldUseSsl(connectionString) {
+ const normalized = normalizeEnvText(connectionString).toLowerCase();
+ if (!normalized) return false;
+ if (normalized.includes('sslmode=disable')) return false;
+ if (normalized.includes('sslmode=require')) return true;
+ return !normalized.includes('localhost') && !normalized.includes('127.0.0.1');
+}
+
+function getPool(connectionString) {
+ if (!globalThis.__smsExtensionFdkStoragePool) {
+ globalThis.__smsExtensionFdkStoragePool = new Pool({
+ connectionString,
+ max: 3,
+ idleTimeoutMillis: 30000,
+ ssl: shouldUseSsl(connectionString) ? { rejectUnauthorized: false } : undefined,
+ });
+ }
+
+ return globalThis.__smsExtensionFdkStoragePool;
+}
+
+function serializeValue(value) {
+ return JSON.stringify(value);
+}
+
+function parseValue(rawValue) {
+ if (!rawValue) return null;
+ if (typeof rawValue === 'object') return rawValue;
+
+ try {
+ return JSON.parse(rawValue);
+ } catch {
+ return null;
+ }
+}
+
+class PostgresFdkStorage extends BaseStorage {
+ constructor({ prefixKey, connectionString, tableName = DEFAULT_TABLE_NAME }) {
+ super(prefixKey);
+
+ if (!normalizeEnvText(connectionString)) {
+ throw new Error('FDK_STORAGE_CONNECTION_STRING is required for Postgres FDK storage');
+ }
+
+ this.pool = getPool(connectionString);
+ this.tableIdentifier = quoteIdentifier(tableName);
+ }
+
+ buildKey(key) {
+ return `${this.prefixKey}${key}`;
+ }
+
+ async get(key) {
+ const storageKey = this.buildKey(key);
+ const { rows } = await this.pool.query(
+ `SELECT value, expires_at
+ FROM ${this.tableIdentifier}
+ WHERE storage_key = $1
+ ORDER BY updated_at DESC NULLS LAST, created_at DESC NULLS LAST, id DESC
+ LIMIT 1`,
+ [storageKey]
+ );
+
+ const row = rows[0];
+ if (!row) return null;
+
+ const expiresAt = row.expires_at ? new Date(row.expires_at) : null;
+ if (expiresAt && expiresAt.getTime() <= Date.now()) {
+ await this.del(key);
+ return null;
+ }
+
+ return parseValue(row.value);
+ }
+
+ async set(key, value) {
+ await this.writeRecord(key, value, null);
+ return 'OK';
+ }
+
+ async setex(key, value, ttl) {
+ const expiresAt = Number.isFinite(ttl)
+ ? new Date(Date.now() + ttl * 1000)
+ : null;
+
+ await this.writeRecord(key, value, expiresAt);
+ return 'OK';
+ }
+
+ async del(key) {
+ const storageKey = this.buildKey(key);
+ await this.pool.query(
+ `DELETE FROM ${this.tableIdentifier}
+ WHERE storage_key = $1`,
+ [storageKey]
+ );
+ }
+
+ async writeRecord(key, value, expiresAt) {
+ const storageKey = this.buildKey(key);
+ const serializedValue = serializeValue(value);
+
+ const updateResult = await this.pool.query(
+ `UPDATE ${this.tableIdentifier}
+ SET value = $2,
+ expires_at = $3,
+ updated_at = NOW()
+ WHERE storage_key = $1`,
+ [storageKey, serializedValue, expiresAt]
+ );
+
+ if (updateResult.rowCount > 0) return;
+
+ await this.pool.query(
+ `INSERT INTO ${this.tableIdentifier} (storage_key, value, expires_at)
+ VALUES ($1, $2, $3)`,
+ [storageKey, serializedValue, expiresAt]
+ );
+ }
+}
+
+function createFdkStorage({ prefixKey, connectionString }) {
+ if (!normalizeEnvText(connectionString)) return null;
+
+ return new PostgresFdkStorage({
+ prefixKey,
+ connectionString,
+ tableName: DEFAULT_TABLE_NAME,
+ });
+}
+
+module.exports = {
+ DEFAULT_TABLE_NAME,
+ PostgresFdkStorage,
+ createFdkStorage,
+};