feat: binary storage db

cli/src/commands/new.rs

@@ -170,6 +170,7 @@ pub fn handle_new_command(
             postgres: if postgres_enabled {
                 Some(PostgresDetails {
                     enabled: true,
+                    binary_storage: None,
                     drop_each_run: None,
                     relationships: None,
                     indexes: None,

core/src/database/postgres/generate.rs

@@ -43,6 +43,7 @@ fn generate_event_table_sql_with_comments(
     abi_inputs: &[EventInfo],
     contract_name: &str,
     schema_name: &str,
+    binary_mode: bool,
     apply_full_name_comment_for_events: Vec<String>,
 ) -> String {
     abi_inputs
@@ -53,7 +54,15 @@ fn generate_event_table_sql_with_comments(
             let event_columns = if event_info.inputs.is_empty() {
                 "".to_string()
             } else {
-                generate_columns_with_data_types(&event_info.inputs).join(", ") + ","
+                if binary_mode {
+                    generate_columns_with_data_types(&event_info.inputs)
+                        .iter()
+                        .map(|column| format!("{} BYTEA", column))
+                        .collect::<Vec<_>>()
+                        .join(", ")
+                } else {
+                    generate_columns_with_data_types(&event_info.inputs).join(", ")
+                }
             };
 
             let create_table_sql = format!(
@@ -160,6 +169,7 @@ pub fn generate_tables_for_indexer_sql(
     project_path: &Path,
     indexer: &Indexer,
     disable_event_tables: bool,
+    binary_mode: bool,
 ) -> Result<Code, GenerateTablesForIndexerSqlError> {
     let mut sql = "CREATE SCHEMA IF NOT EXISTS rindexer_internal;".to_string();
 
@@ -185,6 +195,7 @@ pub fn generate_tables_for_indexer_sql(
                 &event_names,
                 &contract.name,
                 &schema_name,
+                binary_mode,
                 event_matching_name_on_other,
             ));
         }

core/src/database/postgres/setup.rs

@@ -31,7 +31,7 @@ pub async fn setup_postgres(
     let client = PostgresClient::new().await?;
 
     let disable_event_tables = manifest.storage.postgres_disable_create_tables();
-
+    let binary_mode = manifest.storage.binary_storage();
     if manifest.storage.postgres_drop_each_run() {
         info!(
             "`drop_each_run` enabled so dropping all data for {} before starting",
@@ -41,6 +41,9 @@ pub async fn setup_postgres(
         client.batch_execute(sql.as_str()).await?;
         info!("Dropped all data for {}", manifest.name);
     }
+    if manifest.storage.binary_storage() {
+        info!("storing data in bytes")
+    }
 
     if !disable_event_tables {
         info!("Creating tables for {}", manifest.name);
@@ -51,6 +54,7 @@ pub async fn setup_postgres(
         project_path,
         &manifest.to_indexer(),
         disable_event_tables,
+        binary_mode,
     )?;
     debug!("{}", sql);
     client.batch_execute(sql.as_str()).await?;