Rough demo of identity passthrough with Proxy

Author: coderdan

.tool-versions

@@ -1,3 +1,3 @@
-nodejs 19.7.0
-postgres 15.1
-direnv 2.32.2
+nodejs   19.7.0
+postgres 15
+direnv   2.32.2

config/config.json

@@ -1,6 +1,7 @@
 {
   "development": {
-    "password": null,
+    "user": "dan",
+    "password": "12qwaszx",
     "database": "sequelize-example",
     "host": "127.0.0.1",
     "dialect": "postgres",

models/index.js

@@ -9,7 +9,7 @@ const env = process.env.NODE_ENV || 'development';
 const config = require(__dirname + '/../config/config.json')[env];
 const db = {};
 
-const setPort = (config) => !!process.env.STASH_DB_PORT ? { ...config, port: parseInt(process.env.STASH_DB_PORT, 10) } : config;
+const setPort = (config) => !!process.env.TANDEM_PORT ? { ...config, port: parseInt(process.env.TANDEM_PORT, 10) } : config;
 //const setPort = (config) => ({ ...config, port: parseInt(process.env.STASH_DB_PORT, 10) })
 
 let sequelize;

models/patient.js

@@ -21,6 +21,24 @@ module.exports = (sequelize, DataTypes) => {
     allergies: DataTypes.STRING,
     medications: DataTypes.STRING
   }, {
+    hooks: {
+      beforeFind: async (options) => {
+        console.error('beforeFind hook', options);
+        if (options.__identity) {
+          await sequelize.query(
+            // Uncomment this line when using with Proxy
+            '--SET IDENTITY TO ?', {
+              replacements: [options.__identity],
+            }
+          );
+          delete options.__identity;
+        }
+      },
+      beforeFindAfterOptions: (options) => {
+        // __identity is not present because it has been removed in the beforeFind hook
+        console.error('beforeFindAfterOptions hook', options);
+      },
+    },
     sequelize,
     modelName: 'patient',
   });

server.js

@@ -74,7 +74,8 @@ app.get(
 
     const patients = await models.patient.findAll({
       order,
-      where
+      where,
+      __identity: "some-long-token" // Set the JWT here
     });
 
     res.status(200).json(patients);

tandem.toml

@@ -1 +1,12 @@
-log_level = "info"
+# Sample tandem config file
+port = 5442
+database_url = "postgres://dan:@localhost:5432/sequelize-example"
+client_id = "1505033d-d637-4887-b1d2-1c946c30cd0b"
+client_key = "a4627031a16b7065726d75746174696f6e900f0a020b0d060e0c09010500040803076770325f66726f6da16b7065726d75746174696f6e9004010d030f020e050b080a0c090706006570325f746fa16b7065726d75746174696f6e9003090e0b060c00050a0d02040708010f627033a16b7065726d75746174696f6e9821100d05161819181f0804181e0c12181c1718180700111301181a1820181d0a030e02150b0f090614181b"
+#client_id = "1505033d-d637-4887-b1d2-1c946c30cd0b"
+#client_key = "clientkeyhere"
+workspace_id = "R7MMSPNCFRY7ZBNH"
+passthrough = false
+client_access_key = "CSAKLZSXWF5EJPYCBQ3B.YMGSVUMHWZTYJK25BAZ3COCW47OR3LREFP6KUGR3QKBIVIY4"
+log_level           = "debug"
+# socket_path       = "/tmp/tandem.sock"