Merge branch 'develop' into 1137/contract_id-work-with-namespace-and-…

…non-namespace

examples/fuel-explorer/fuel-explorer/schema/fuel_explorer.schema.graphql

@@ -358,6 +358,23 @@ type MessageOutReceipt @entity(virtual: true) {
   is_message_out: Boolean!
 }
 
+type MintReceipt @entity(virtual: true) {
+  sub_id: Bytes32!
+  contract_id: ContractId!
+  val: UInt8!
+  pc: UInt8!
+  isr: UInt8!
+}
+
+
+type BurnReceipt @entity(virtual: true) {
+  sub_id: Bytes32!
+  contract_id: ContractId!
+  val: UInt8!
+  pc: UInt8!
+  isr: UInt8!
+}
+
 union Receipt =
     CallReceipt
   | ReturnReceipt
@@ -370,6 +387,8 @@ union Receipt =
   | TransferOutReceipt
   | ScriptResultReceipt
   | MessageOutReceipt
+  | MintReceipt
+  | BurnReceipt
 
 type VariableOutput @entity {
   id: ID!

examples/fuel-explorer/fuel-explorer/src/lib.rs

@@ -714,7 +714,40 @@ impl From<fuel::Receipt> for Receipt {
 
                 Self::from(receipt)
             }
-            fuel::Receipt::Mint { .. } | fuel::Receipt::Burn { .. } => todo!(),
+            fuel::Receipt::Mint {
+                sub_id,
+                contract_id,
+                val,
+                pc,
+                is,
+            } => {
+                let receipt = MintReceipt {
+                    sub_id,
+                    contract_id,
+                    val,
+                    pc,
+                    isr: is,
+                };
+
+                Self::from(receipt)
+            }
+            fuel::Receipt::Burn {
+                sub_id,
+                contract_id,
+                val,
+                pc,
+                is,
+            } => {
+                let receipt = BurnReceipt {
+                    sub_id,
+                    contract_id,
+                    val,
+                    pc,
+                    isr: is,
+                };
+
+                Self::from(receipt)
+            }
         }
     }
 }

packages/fuel-indexer-database/database-types/src/lib.rs

@@ -566,9 +566,6 @@ pub struct IndexerAsset {
     /// Database ID of the indexer.
     pub index_id: i64,
 
-    /// Version associated with this indexer asset.
-    pub version: i32,
-
     /// Digest of the asset's bytes.
     pub digest: String,
 

packages/fuel-indexer-database/postgres/migrations/20230911123600_remove_versions.down.sql

@@ -0,0 +1,4 @@
+-- Active: 1693382282533@@127.0.0.1@5432@postgres
+ALTER TABLE index_asset_registry_manifest ADD COLUMN version integer not null;
+ALTER TABLE index_asset_registry_schema ADD COLUMN version integer not null;
+ALTER TABLE index_asset_registry_wasm ADD COLUMN version integer not null;

packages/fuel-indexer-database/postgres/migrations/20230911123600_remove_versions.up.sql

@@ -0,0 +1,3 @@
+ALTER TABLE index_asset_registry_manifest DROP COLUMN version;
+ALTER TABLE index_asset_registry_schema DROP COLUMN version;
+ALTER TABLE index_asset_registry_wasm DROP COLUMN version;

packages/fuel-indexer-database/postgres/src/lib.rs

@@ -526,27 +526,6 @@ pub async fn all_registered_indexers(
         .collect::<Vec<RegisteredIndexer>>())
 }
 
-#[cfg_attr(feature = "metrics", metrics)]
-pub async fn indexer_asset_version(
-    conn: &mut PoolConnection<Postgres>,
-    index_id: &i64,
-    asset_type: &IndexerAssetType,
-) -> sqlx::Result<i64> {
-    match sqlx::query(&format!(
-        "SELECT COUNT(*)
-        FROM index_asset_registry_{}
-        WHERE index_id = {}",
-        asset_type.as_ref(),
-        index_id,
-    ))
-    .fetch_one(conn)
-    .await
-    {
-        Ok(row) => Ok(row.try_get::<i64, usize>(0).unwrap_or(0)),
-        Err(_e) => Ok(0),
-    }
-}
-
 /// Register a single indexer asset.
 #[cfg_attr(feature = "metrics", metrics)]
 pub async fn register_indexer_asset(
@@ -577,15 +556,10 @@ pub async fn register_indexer_asset(
         return Ok(asset);
     }
 
-    let current_version = indexer_asset_version(conn, &index.id, &asset_type)
-        .await
-        .expect("Failed to get asset version.");
-
     let query = format!(
-        "INSERT INTO index_asset_registry_{} (index_id, bytes, version, digest) VALUES ({}, $1, {}, '{digest}') RETURNING *",
+        "INSERT INTO index_asset_registry_{} (index_id, bytes, digest) VALUES ({}, $1, '{digest}') RETURNING *",
         asset_type.as_ref(),
         index.id,
-        current_version + 1,
     );
 
     let row = sqlx::QueryBuilder::new(query)
@@ -603,22 +577,20 @@ pub async fn register_indexer_asset(
 
     let id = row.get(0);
     let index_id = row.get(1);
-    let version = row.get(2);
-    let digest = row.get(3);
-    let bytes = row.get(4);
+    let digest = row.get(2);
+    let bytes = row.get(3);
 
     Ok(IndexerAsset {
         id,
         index_id,
-        version,
         digest,
         bytes,
     })
 }
 
-/// Return the latest version for a given indexer asset type.
+/// Returns the requested asset for an indexer with the given id.
 #[cfg_attr(feature = "metrics", metrics)]
-pub async fn latest_asset_for_indexer(
+pub async fn indexer_asset(
     conn: &mut PoolConnection<Postgres>,
     index_id: &i64,
     asset_type: IndexerAssetType,
@@ -633,30 +605,26 @@ pub async fn latest_asset_for_indexer(
 
     let id = row.get(0);
     let index_id = row.get(1);
-    let version = row.get(2);
-    let digest = row.get(3);
-    let bytes = row.get(4);
+    let digest = row.get(2);
+    let bytes = row.get(3);
 
     Ok(IndexerAsset {
         id,
         index_id,
-        version,
         digest,
         bytes,
     })
 }
 
-/// Return the latest version for every indexer asset type.
+/// Return every indexer asset type for an indexer with the give id.
 #[cfg_attr(feature = "metrics", metrics)]
-pub async fn latest_assets_for_indexer(
+pub async fn indexer_assets(
     conn: &mut PoolConnection<Postgres>,
     indexer_id: &i64,
 ) -> sqlx::Result<IndexerAssetBundle> {
-    let wasm = latest_asset_for_indexer(conn, indexer_id, IndexerAssetType::Wasm).await?;
-    let schema =
-        latest_asset_for_indexer(conn, indexer_id, IndexerAssetType::Schema).await?;
-    let manifest =
-        latest_asset_for_indexer(conn, indexer_id, IndexerAssetType::Manifest).await?;
+    let wasm = indexer_asset(conn, indexer_id, IndexerAssetType::Wasm).await?;
+    let schema = indexer_asset(conn, indexer_id, IndexerAssetType::Schema).await?;
+    let manifest = indexer_asset(conn, indexer_id, IndexerAssetType::Manifest).await?;
 
     Ok(IndexerAssetBundle {
         wasm,
@@ -705,14 +673,12 @@ pub async fn asset_already_exists(
         Ok(row) => {
             let id = row.get(0);
             let index_id = row.get(1);
-            let version = row.get(2);
-            let digest = row.get(3);
-            let bytes = row.get(4);
+            let digest = row.get(2);
+            let bytes = row.get(3);
 
             Ok(Some(IndexerAsset {
                 id,
                 index_id,
-                version,
                 digest,
                 bytes,
             }))

packages/fuel-indexer-database/src/queries.rs

@@ -230,18 +230,6 @@ pub async fn all_registered_indexers(
     }
 }
 
-pub async fn indexer_asset_version(
-    conn: &mut IndexerConnection,
-    index_id: &i64,
-    asset_type: &IndexerAssetType,
-) -> sqlx::Result<i64> {
-    match conn {
-        IndexerConnection::Postgres(ref mut c) => {
-            postgres::indexer_asset_version(c, index_id, asset_type).await
-        }
-    }
-}
-
 /// Register a single indexer asset.
 pub async fn register_indexer_asset(
     conn: &mut IndexerConnection,
@@ -261,27 +249,27 @@ pub async fn register_indexer_asset(
     }
 }
 
-/// Return the latest version for a given indexer asset type.
-pub async fn latest_asset_for_indexer(
+/// Returns the requested asset for an indexer with the given id.
+pub async fn indexer_asset(
     conn: &mut IndexerConnection,
     index_id: &i64,
     asset_type: IndexerAssetType,
 ) -> sqlx::Result<IndexerAsset> {
     match conn {
         IndexerConnection::Postgres(ref mut c) => {
-            postgres::latest_asset_for_indexer(c, index_id, asset_type).await
+            postgres::indexer_asset(c, index_id, asset_type).await
         }
     }
 }
 
-/// Return the latest version for every indexer asset type.
-pub async fn latest_assets_for_indexer(
+/// Return every indexer asset type for an indexer with the give id.
+pub async fn indexer_assets(
     conn: &mut IndexerConnection,
     index_id: &i64,
 ) -> sqlx::Result<IndexerAssetBundle> {
     match conn {
         IndexerConnection::Postgres(ref mut c) => {
-            postgres::latest_assets_for_indexer(c, index_id).await
+            postgres::indexer_assets(c, index_id).await
         }
     }
 }

packages/fuel-indexer-lib/src/constants.rs

@@ -72,7 +72,7 @@ lazy_static! {
 
     /// Sway ABI types we don't support and won't in the near future.
     pub static ref IGNORED_ABI_JSON_TYPES: HashSet<&'static str> =
-        HashSet::from(["()", "struct Vec"]);
+        HashSet::from(["()"]);
 
     /// Fuel VM receipt-related types.
     pub static ref FUEL_RECEIPT_TYPES: HashSet<&'static str> = HashSet::from([
@@ -209,14 +209,18 @@ lazy_static! {
 
 
     /// ABI types not allowed in the contract ABI.
-    pub static ref DISALLOWED_ABI_JSON_TYPES: HashSet<&'static str> = HashSet::from([]);
+    pub static ref UNSUPPORTED_ABI_JSON_TYPES: HashSet<&'static str> = HashSet::from(["Vec"]);
 
     /// Generic Sway ABI types.
-    pub static ref GENERIC_TYPES: HashSet<&'static str> = HashSet::from([
+    pub static ref IGNORED_GENERIC_METADATA: HashSet<&'static str> = HashSet::from([
         "generic T",
         "raw untyped ptr",
         "struct RawVec",
-        "struct Vec"
+    ]);
+
+    pub static ref GENERIC_STRUCTS: HashSet<&'static str> = HashSet::from([
+        "Vec",
+        "Option"
     ]);
 
     /// Set of Rust primitive types.