Add schema to the data contracts

packages/api/src/controllers/DataContractsController.js

@@ -19,7 +19,7 @@ class DataContractsController {
         const {identifier} = request.params
 
         const rows = await this.knex('data_contracts')
-            .select('data_contracts.identifier as identifier')
+            .select('data_contracts.identifier as identifier', 'data_contracts.schema as schema')
             .where('data_contracts.identifier', identifier);
 
         const [row] = rows
@@ -28,7 +28,7 @@ class DataContractsController {
             response.status(404).send({message: 'not found'})
         }
 
-        response.send({identifier: row.identifier});
+        response.send({identifier: row.identifier, schema: row.schema});
     }
 }
 

packages/frontend/src/index.js

@@ -17,7 +17,6 @@ import TransactionRoute, {
     loader as transactionLoader,
 } from "./routes/transaction/transaction.route";
 import DataContractRoute, {loader as dataContractLoader} from "./routes/dataContract/data.contract.route";
-import TransactionsRoute from "./routes/transactions/tranactions.route";
 
 const router = createBrowserRouter([
     {
@@ -50,10 +49,6 @@ const router = createBrowserRouter([
                 element: <DataContractRoute/>,
                 loader: dataContractLoader,
             },
-            {
-                path: "transactions",
-                element: <TransactionsRoute/>,
-            },
         ]
     }
 ]);

packages/frontend/src/routes/dataContract/data.contract.route.js

@@ -1,6 +1,7 @@
 import React from 'react';
 import {useLoaderData} from "react-router-dom";
 import * as Api from "../../util/Api";
+import './data_contract.css'
 
 export async function loader({params}) {
     const {identifier} = params
@@ -12,9 +13,12 @@ function DataContractRoute() {
 
     return (
         <div className="container">
-            <div className={""}>
+            <div className={"data_contract_identifier"}>
                 Identifier: {dataContract.identifier}
             </div>
+            <div className={"data_contract_schema"}>
+                {JSON.stringify(dataContract.schema, null, 2)}
+            </div>
         </div>
     );
 }

packages/frontend/src/routes/dataContract/data_contract.css

@@ -0,0 +1,14 @@
+.data_contract_identifier {
+    margin-top: 20px;
+    background-color: #9a3a3a;
+    padding: 10px;
+}
+
+.data_contract_schema {
+    margin-top: 20px;
+    background-color: #9a5c3a;
+    padding: 10px;
+    white-space: break-spaces;
+    height: 80%;
+}
+

packages/indexer/Cargo.toml

@@ -20,5 +20,5 @@ refinery = { version = "0.8.10", features = ["postgres"] }
 sha256 = "1.4.0"
 dotenv = "0.15.0"
 chrono = { version = "0.4.31", features = ["serde", "rustc-serialize"] }
-tokio-postgres = { version="0.7.10", features=["with-chrono-0_4"] }
+tokio-postgres = { version="0.7.10", features=["with-chrono-0_4", "with-serde_json-1"] }
 time = { version="0.3.29", features=["serde"] }

packages/indexer/migrations/V11__add_schema_jsonb_to_data_contracts.sql

@@ -0,0 +1,2 @@
+ALTER TABLE data_contracts
+ADD COLUMN "schema" jsonb not null;

packages/indexer/src/processor/psql/dao/mod.rs

@@ -1,3 +1,4 @@
+use std::collections::BTreeMap;
 use std::env;
 use std::time::SystemTime;
 use deadpool_postgres::{Config, Manager, ManagerConfig, Pool, PoolError, RecyclingMethod, Runtime, tokio_postgres, Transaction};
@@ -10,6 +11,9 @@ use crate::models::{TDBlock, TDBlockHeader};
 use sha256::{digest, try_digest};
 use base64::{Engine as _, engine::{general_purpose}};
 use chrono::{DateTime, Utc};
+use dpp::platform_value::Value;
+use tokio_postgres::types::{Format, IsNull, ToSql, Type};
+use tokio_postgres::types::private::BytesMut;
 use crate::entities::block_header::BlockHeader;
 
 pub struct PostgresDAO {
@@ -52,11 +56,14 @@ impl PostgresDAO {
         let id = state_transition.data_contract().id();
         let id_str = id.to_string(Encoding::Base58);
 
-        let query = "INSERT INTO data_contracts(identifier) VALUES ($1);";
+        let schema = state_transition.data_contract().document_schemas().clone();
+        let schema_decoded = serde_json::to_value(schema).unwrap();
+
+        let query = "INSERT INTO data_contracts(identifier, schema) VALUES ($1, $2);";
 
         let client = self.connection_pool.get().await.unwrap();
         let stmt = client.prepare_cached(query).await.unwrap();
-        client.query(&stmt, &[&id_str]).await.unwrap();
+        client.query(&stmt, &[&id_str, &schema_decoded]).await.unwrap();
     }
 
     pub async fn get_latest_block(&self) -> i32 {
@@ -94,4 +101,3 @@ impl PostgresDAO {
         return block_id;
     }
 }
-