diff --git a/indexer/entity/src/block.rs b/indexer/entity/src/block.rs index 54a092d7..b149fe02 100644 --- a/indexer/entity/src/block.rs +++ b/indexer/entity/src/block.rs @@ -12,7 +12,7 @@ pub struct Model { pub height: i32, pub epoch: i32, pub slot: i32, - pub payload: Vec, + pub payload: Option>, } #[derive(Copy, Clone, Debug, DeriveRelation, EnumIter)] diff --git a/indexer/migration/src/m20230223_000015_modify_block_table.rs b/indexer/migration/src/m20230223_000015_modify_block_table.rs index a831ffed..1454685b 100644 --- a/indexer/migration/src/m20230223_000015_modify_block_table.rs +++ b/indexer/migration/src/m20230223_000015_modify_block_table.rs @@ -17,7 +17,7 @@ impl MigrationTrait for Migration { .alter_table( Table::alter() .table(Entity) - .add_column(ColumnDef::new(Column::Payload).binary().not_null()) + .add_column(ColumnDef::new(Column::Payload).binary()) .to_owned(), ) .await diff --git a/indexer/tasks/src/byron/byron_block.rs b/indexer/tasks/src/byron/byron_block.rs index de83c81c..e79b3cf1 100644 --- a/indexer/tasks/src/byron/byron_block.rs +++ b/indexer/tasks/src/byron/byron_block.rs @@ -49,7 +49,7 @@ async fn handle_block( height: Set(block.1.number() as i32), epoch: Set(block.1.header().as_byron().unwrap().consensus_data.0.epoch as i32), slot: Set(block.1.slot() as i32), - payload: Set(block_payload), + payload: Set(Some(block_payload)), ..Default::default() }; diff --git a/indexer/tasks/src/genesis/genesis_block.rs b/indexer/tasks/src/genesis/genesis_block.rs index d4f2001e..a0dcd221 100644 --- a/indexer/tasks/src/genesis/genesis_block.rs +++ b/indexer/tasks/src/genesis/genesis_block.rs @@ -44,7 +44,7 @@ async fn handle_block( height: Set(0), epoch: Set(0), slot: Set(0), - payload: Set(block_payload), + payload: Set(Some(block_payload)), ..Default::default() }; diff --git a/indexer/tasks/src/multiera/multiera_block.rs b/indexer/tasks/src/multiera/multiera_block.rs index 7cd4e502..4acebbad 100644 --- a/indexer/tasks/src/multiera/multiera_block.rs +++ b/indexer/tasks/src/multiera/multiera_block.rs @@ -51,7 +51,7 @@ async fn handle_block( height: Set(block.1.number() as i32), epoch: Set(block.2.epoch.unwrap() as i32), slot: Set(block.1.slot() as i32), - payload: Set(block_payload), + payload: Set(Some(block_payload)), ..Default::default() }; block.insert(db_tx).await