remove listener url and it's data

yalla-coop · Sep 18, 2023 · 4450834 · 4450834
1 parent fdaa2e6
commit 4450834
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 29 deletions.
diff --git a/web/database/users/schema.sql b/web/database/users/schema.sql
@@ -3,8 +3,6 @@ DROP TABLE IF EXISTS users;
 CREATE TABLE IF NOT EXISTS users (
  "id" SERIAL PRIMARY KEY,
   user_id TEXT NOT NULL UNIQUE,
-  listener_url TEXT,
-  shop TEXT,
   name TEXT,
   status BOOLEAN NOT NULL DEFAULT FALSE,
   "created_at" TIMESTAMP NOT NULL DEFAULT NOW(),

diff --git a/web/frontend/pages/HubUsers.jsx b/web/frontend/pages/HubUsers.jsx
@@ -101,10 +101,6 @@ export default function HubUsers() {
           <strong>User Id:</strong>
           {user.userId}
         </p>
-        <p>
-          <strong>Listener URL:</strong>
-          {user.listenerUrl}
-        </p>
       </div>
 
       <Button

diff --git a/web/middleware/checkUserAccessPermissions.js b/web/middleware/checkUserAccessPermissions.js
@@ -6,14 +6,7 @@ const clientSecret = process.env.OIDC_CLIENT_SECRET;
 const issuerURL = process.env.OIDC_ISSUER;
 
 const checkUserAccessPermissions = async (req, res, next) => {
-  const {
-    userId,
-    accessToken,
-    shop: hubShopName = '',
-    listenerUrl = ''
-  } = req.body;
-
-  console.log('req.body--- from check user access permission :::', req.body);
+  const { userId, accessToken } = req.body;
 
   if (!userId) {
     return res.status(403).json({
@@ -48,8 +41,8 @@ const checkUserAccessPermissions = async (req, res, next) => {
     if (!user || user.rows.length === 0) {
       // insert this user into the database with status false
       await query(
-        'INSERT INTO users (user_id, status, name, shop, listener_url) VALUES ($1,$2,$3,$4,$5)',
-        [userId, false, userName, hubShopName, listenerUrl]
+        'INSERT INTO users (user_id, status, name) VALUES ($1,$2,$3)',
+        [userId, false, userName]
       );
 
       return res.status(403).json({

diff --git a/web/webhooks/product-update.js b/web/webhooks/product-update.js
@@ -22,19 +22,6 @@ export const productUpdateListener = async (product, webhookId, topic) => {
       return 'Webhook already exists';
     }
 
-    // const sql = 'SELECT * from users WHERE status = true';
-    // const result = await query(sql);
-    // const listeners = result.rows;
-    // const promises = listeners.map(async (listener) => {
-    //   const { shop: listenerShop, listenerUrl } = listener;
-    //   await axios.post(listenerUrl, {
-    //     shopName: listenerShop,
-    //     product
-    //   });
-    // });
-
-    // await Promise.allSettled(promises);
-
     const insertWebhookQuery =
       'INSERT INTO webhooks (id, topic, data) VALUES ($1, $2, $3)';