feat: implemented event triggers

config.yaml

@@ -1,9 +1,9 @@
 version: 3
-endpoint: http://host.docker.internal:8080
+endpoint: http://localhost:8080
 admin_secret: myadminsecretkey
 metadata_directory: metadata
 migrations_directory: migrations
 seeds_directory: seeds
 actions:
   kind: synchronous
-  handler_webhook_baseurl: http://host.docker.internal:3000
+  handler_webhook_baseurl: http://localhost:3000

metadata/actions.graphql

@@ -1,4 +1,3 @@
-
 type Mutation {
   sendVerificationCode(
     input: SendVerificationInput!

metadata/actions.yaml

@@ -13,7 +13,6 @@ actions:
       forward_client_headers: true
     permissions:
       - role: anonymous
-
 custom_types:
   enums: []
   input_objects:
@@ -22,4 +21,3 @@ custom_types:
   objects:
     - name: VerificationResponse
   scalars: []
-

metadata/databases/safetrust/tables/public_apartments.yaml

@@ -1,14 +1,3 @@
 table:
   name: apartments
   schema: public
-  configuration:
-    custom_root_fields: {}
-    custom_column_names: {}
-  array_relationships:
-    - name: users
-      using:
-        foreign_key_constraint_on:
-          column: owner_id
-          table:
-            schema: public
-            name: users

metadata/databases/safetrust/tables/public_bid_requests.yaml

@@ -1,14 +1,3 @@
 table:
-  schema: public
   name: bid_requests
-  configuration:
-    custom_root_fields: {}
-    custom_column_names: {}
-  array_relationships:
-    - name: status_histories
-      using:
-        foreign_key_constraint_on:
-          column: bid_request_id
-          table:
-            schema: public
-            name: bid_status_histories
+  schema: public

metadata/databases/safetrust/tables/public_bid_status_histories.yaml

@@ -1,7 +1,7 @@
 table:
-  schema: public
   name: bid_status_histories
+  schema: public
 object_relationships:
   - name: bid_request
     using:
-      foreign_key_constraint_on: bid_request_id
+      foreign_key_constraint_on: bid_request_id

metadata/databases/safetrust/tables/public_escrow_api_calls.yaml

@@ -0,0 +1,3 @@
+table:
+  name: escrow_api_calls
+  schema: public

metadata/databases/safetrust/tables/public_escrow_transactions.yaml

@@ -0,0 +1,26 @@
+table:
+  name: escrow_transactions
+  schema: public
+event_triggers:
+  - name: escrow_refund_status_update
+    definition:
+      enable_manual: false
+      update:
+        columns:
+          - refund_status
+    retry_conf:
+      interval_sec: 10
+      num_retries: 0
+      timeout_sec: 60
+    webhook: http://localhost:3000/webhooks/escrow_refund_status_update
+  - name: escrow_status_update
+    definition:
+      enable_manual: false
+      update:
+        columns:
+          - status
+    retry_conf:
+      interval_sec: 10
+      num_retries: 0
+      timeout_sec: 60
+    webhook: http://localhost:3000/webhooks/escrow_status_update

metadata/databases/safetrust/tables/public_escrow_xdr_transactions.yaml

@@ -0,0 +1,3 @@
+table:
+  name: escrow_xdr_transactions
+  schema: public

metadata/databases/safetrust/tables/public_users.yaml

@@ -10,7 +10,12 @@ array_relationships:
           name: user_wallets
           schema: public
 select_permissions:
-  - role: users
+  - role: anonymous
+    permission:
+      columns: []
+      filter: {}
+    comment: ""
+  - role: landlord
     permission:
       columns:
         - country_code
@@ -27,11 +32,6 @@ select_permissions:
         id:
           _eq: X-Hasura-User-Id
     comment: ""
-  - role: anonymous
-    permission:
-      columns: []
-      filter: {}
-    comment: ""
   - role: tenant
     permission:
       columns:
@@ -49,7 +49,7 @@ select_permissions:
         id:
           _eq: X-Hasura-User-Id
     comment: ""
-  - role: landlord
+  - role: users
     permission:
       columns:
         - country_code
@@ -67,7 +67,7 @@ select_permissions:
           _eq: X-Hasura-User-Id
     comment: ""
 update_permissions:
-  - role: users
+  - role: landlord
     permission:
       columns:
         - country_code
@@ -101,7 +101,7 @@ update_permissions:
         id:
           _eq: X-Hasura-User-Id
     comment: ""
-  - role: landlord
+  - role: users
     permission:
       columns:
         - country_code

metadata/databases/safetrust/tables/tables.yaml

@@ -1,13 +1,12 @@
-- '!include public_geography_columns.yaml'
-- '!include public_geometry_columns.yaml'
-- '!include public_spatial_ref_sys.yaml'
-- '!include public_user_wallets.yaml'
-- '!include public_users.yaml'
-- '!include escrow_api_calls.yaml'
-- '!include escrow_transactions.yaml'
-- '!include escrow_xdr_transactions.yaml'
-- '!include public_apartments.yaml'
-- '!include public_apartment_images.yaml'
-- '!include public_bid_requests.yaml'
-- '!include public_bid_status_histories.yaml'
-
+- "!include public_apartment_images.yaml"
+- "!include public_apartments.yaml"
+- "!include public_bid_requests.yaml"
+- "!include public_bid_status_histories.yaml"
+- "!include public_escrow_api_calls.yaml"
+- "!include public_escrow_transactions.yaml"
+- "!include public_escrow_xdr_transactions.yaml"
+- "!include public_geography_columns.yaml"
+- "!include public_geometry_columns.yaml"
+- "!include public_spatial_ref_sys.yaml"
+- "!include public_user_wallets.yaml"
+- "!include public_users.yaml"

storage-service/index.js

@@ -3,7 +3,6 @@ const express = require('express');
 const cors = require('cors');
 const morgan = require('morgan');
 const storageRoutes = require('./routes/storage');
-
 const app = express();
 
 // Middleware
@@ -15,6 +14,8 @@ app.use(cors({
 app.use(morgan('tiny'));
 app.disable('x-powered-by');
 
+
+
 // Routes
 app.use('/storage', storageRoutes);
 

webhook/index.js

@@ -0,0 +1,36 @@
+require('dotenv').config();
+const express = require('express');
+const cors = require('cors');
+const morgan = require('morgan');
+const webhooksRoutes = require('./webhooks');
+
+const app = express();
+
+// Middleware
+app.use(express.json());
+app.use(cors({
+  credentials: true,
+  origin: true,
+}));
+app.use(morgan('tiny'));
+app.disable('x-powered-by');
+
+
+
+// Routes
+app.use('/webhooks', webhooksRoutes);
+
+
+// Error handler
+app.use((err, req, res, next) => {
+  if (err) {
+    console.error(err.message);
+    console.error(err.stack);
+    return res.status(500).json({ error: err.message });
+  }
+});
+
+const port = process.env.PORT || 3000;
+app.listen(port, () => {
+  console.log(`listening on port ${port}`);
+});