add inflate API

Author: zoedberg

bindings/c-ffi/src/lib.rs

@@ -157,6 +157,26 @@ pub extern "C" fn rgblib_go_online(
     go_online(wallet, skip_consistency_check, electrum_url).into()
 }
 
+#[unsafe(no_mangle)]
+pub extern "C" fn rgblib_inflate(
+    wallet: &COpaqueStruct,
+    online: &COpaqueStruct,
+    asset_id: *const c_char,
+    inflation_amounts: *const c_char,
+    fee_rate: *const c_char,
+    min_confirmations: *const c_char,
+) -> CResultString {
+    inflate(
+        wallet,
+        online,
+        asset_id,
+        inflation_amounts,
+        fee_rate,
+        min_confirmations,
+    )
+    .into()
+}
+
 #[unsafe(no_mangle)]
 pub extern "C" fn rgblib_issue_asset_cfa(
     wallet: &COpaqueStruct,

bindings/c-ffi/src/utils.rs

@@ -290,6 +290,30 @@ pub(crate) fn go_online(
     Ok(wallet.go_online(skip_consistency_check, ptr_to_string(electrum_url))?)
 }
 
+pub(crate) fn inflate(
+    wallet: &COpaqueStruct,
+    online: &COpaqueStruct,
+    asset_id: *const c_char,
+    inflation_amounts: *const c_char,
+    fee_rate: *const c_char,
+    min_confirmations: *const c_char,
+) -> Result<String, Error> {
+    let wallet = Wallet::from_opaque(wallet)?;
+    let online = Online::from_opaque(online)?;
+    let asset_id = ptr_to_string(asset_id);
+    let inflation_amounts = convert_strings_array(inflation_amounts)?;
+    let fee_rate = ptr_to_num(fee_rate)?;
+    let min_confirmations = ptr_to_num(min_confirmations)?;
+    let res = wallet.inflate(
+        (*online).clone(),
+        asset_id,
+        inflation_amounts,
+        fee_rate,
+        min_confirmations,
+    )?;
+    Ok(serde_json::to_string(&res)?)
+}
+
 pub(crate) fn issue_asset_cfa(
     wallet: &COpaqueStruct,
     name: *const c_char,

bindings/uniffi/src/lib.rs

@@ -13,12 +13,12 @@ use rgb_lib::{
         Address as RgbLibAddress, AssetCFA, AssetIFA, AssetNIA, AssetUDA, Assets,
         AssignmentsCollection, Balance, BlockTime, BtcBalance, DatabaseType, EmbeddedMedia,
         Invoice as RgbLibInvoice, InvoiceData as RgbLibInvoiceData, Media, Metadata, Online,
-        Outpoint, ProofOfReserves, ReceiveData, Recipient as RgbLibRecipient,
+        OperationResult, Outpoint, ProofOfReserves, ReceiveData, Recipient as RgbLibRecipient,
         RecipientInfo as RgbLibRecipientInfo, RefreshFilter, RefreshTransferStatus,
-        RefreshedTransfer, RgbAllocation as RgbLibRgbAllocation, SendResult, Token, TokenLight,
-        Transaction, TransactionType, Transfer as RgbLibTransfer, TransferKind,
-        TransferTransportEndpoint, TransportEndpoint as RgbLibTransportEndpoint,
-        Unspent as RgbLibUnspent, Utxo, Wallet as RgbLibWallet, WalletData, WitnessData,
+        RefreshedTransfer, RgbAllocation as RgbLibRgbAllocation, Token, TokenLight, Transaction,
+        TransactionType, Transfer as RgbLibTransfer, TransferKind, TransferTransportEndpoint,
+        TransportEndpoint as RgbLibTransportEndpoint, Unspent as RgbLibUnspent, Utxo,
+        Wallet as RgbLibWallet, WalletData, WitnessData,
     },
 };
 
@@ -521,6 +521,48 @@ impl Wallet {
             .go_online(skip_consistency_check, indexer_url)
     }
 
+    fn inflate(
+        &self,
+        online: Online,
+        asset_id: String,
+        inflation_amounts: Vec<u64>,
+        fee_rate: u64,
+        min_confirmations: u8,
+    ) -> Result<OperationResult, RgbLibError> {
+        self._get_wallet().inflate(
+            online,
+            asset_id,
+            inflation_amounts,
+            fee_rate,
+            min_confirmations,
+        )
+    }
+
+    fn inflate_begin(
+        &self,
+        online: Online,
+        asset_id: String,
+        inflation_amounts: Vec<u64>,
+        fee_rate: u64,
+        min_confirmations: u8,
+    ) -> Result<String, RgbLibError> {
+        self._get_wallet().inflate_begin(
+            online,
+            asset_id,
+            inflation_amounts,
+            fee_rate,
+            min_confirmations,
+        )
+    }
+
+    fn inflate_end(
+        &self,
+        online: Online,
+        signed_psbt: String,
+    ) -> Result<OperationResult, RgbLibError> {
+        self._get_wallet().inflate_end(online, signed_psbt)
+    }
+
     fn issue_asset_nia(
         &self,
         ticker: String,
@@ -636,7 +678,7 @@ impl Wallet {
         fee_rate: u64,
         min_confirmations: u8,
         skip_sync: bool,
-    ) -> Result<SendResult, RgbLibError> {
+    ) -> Result<OperationResult, RgbLibError> {
         self._get_wallet().send(
             online,
             _convert_recipient_map(recipient_map),
@@ -669,7 +711,7 @@ impl Wallet {
         online: Online,
         signed_psbt: String,
         skip_sync: bool,
-    ) -> Result<SendResult, RgbLibError> {
+    ) -> Result<OperationResult, RgbLibError> {
         self._get_wallet().send_end(online, signed_psbt, skip_sync)
     }
 

bindings/uniffi/src/rgb-lib.udl

@@ -69,6 +69,7 @@ interface RgbLibError {
   MinFeeNotMet(string txid);
   Network(string details);
   NoConsignment();
+  NoInflationAmounts();
   NoIssuanceAmounts();
   NoSupportedSchemas();
   NoValidTransportEndpoint();
@@ -83,6 +84,7 @@ interface RgbLibError {
   UnknownRgbSchema(string schema_id);
   UnknownTransfer(string txid);
   UnsupportedBackupVersion(string version);
+  UnsupportedInflation(AssetSchema asset_schema);
   UnsupportedLayer1(string layer_1);
   UnsupportedSchema(AssetSchema asset_schema);
   UnsupportedTransportType();
@@ -139,7 +141,6 @@ dictionary AssetUDA {
   string name;
   string? details;
   u8 precision;
-  u64 issued_supply;
   i64 timestamp;
   i64 added_at;
   Balance balance;
@@ -166,7 +167,9 @@ dictionary AssetIFA {
   string name;
   string? details;
   u8 precision;
-  u64 issued_supply;
+  u64 initial_supply;
+  u64 max_supply;
+  u64 known_circulating_supply;
   i64 timestamp;
   i64 added_at;
   Balance balance;
@@ -321,7 +324,9 @@ dictionary Token {
 [Remote]
 dictionary Metadata {
   AssetSchema asset_schema;
-  u64 issued_supply;
+  u64 initial_supply;
+  u64 max_supply;
+  u64 known_circulating_supply;
   i64 timestamp;
   string name;
   u8 precision;
@@ -349,7 +354,7 @@ dictionary WitnessData {
 };
 
 [Remote]
-dictionary SendResult {
+dictionary OperationResult {
   string txid;
   i32 batch_transfer_idx;
 };
@@ -398,6 +403,7 @@ enum TransferKind {
   "ReceiveBlind",
   "ReceiveWitness",
   "Send",
+  "Inflation",
 };
 
 [Remote]
@@ -561,6 +567,19 @@ interface Wallet {
   [Throws=RgbLibError]
   Online go_online(boolean skip_consistency_check, string indexer_url);
 
+  [Throws=RgbLibError]
+  OperationResult inflate(
+    Online online, string asset_id, sequence<u64> inflation_amounts,
+    u64 fee_rate, u8 min_confirmations);
+
+  [Throws=RgbLibError]
+  string inflate_begin(
+    Online online, string asset_id, sequence<u64> inflation_amounts,
+    u64 fee_rate, u8 min_confirmations);
+
+  [Throws=RgbLibError]
+  OperationResult inflate_end(Online online, string signed_psbt);
+
   [Throws=RgbLibError]
   AssetNIA issue_asset_nia(
     string ticker, string name, u8 precision, sequence<u64> amounts);
@@ -599,7 +618,7 @@ interface Wallet {
     boolean skip_sync);
 
   [Throws=RgbLibError]
-  SendResult send(
+  OperationResult send(
     Online online, record<DOMString, sequence<Recipient>> recipient_map,
     boolean donation, u64 fee_rate, u8 min_confirmations, boolean skip_sync);
 
@@ -609,7 +628,7 @@ interface Wallet {
     boolean donation, u64 fee_rate, u8 min_confirmations);
 
   [Throws=RgbLibError]
-  SendResult send_end(Online online, string signed_psbt, boolean skip_sync);
+  OperationResult send_end(Online online, string signed_psbt, boolean skip_sync);
 
   [Throws=RgbLibError]
   string send_btc(

migration/src/lib.rs

@@ -1,12 +1,16 @@
 pub use sea_orm_migration::prelude::*;
 
 mod m20230608_071249_init_db;
+mod m20251017_074408_asset_update;
 
 pub struct Migrator;
 
 #[async_trait::async_trait]
 impl MigratorTrait for Migrator {
     fn migrations() -> Vec<Box<dyn MigrationTrait>> {
-        vec![Box::new(m20230608_071249_init_db::Migration)]
+        vec![
+            Box::new(m20230608_071249_init_db::Migration),
+            Box::new(m20251017_074408_asset_update::Migration),
+        ]
     }
 }

migration/src/m20251017_074408_asset_update.rs

@@ -0,0 +1,82 @@
+use sea_orm_migration::prelude::*;
+
+#[derive(DeriveMigrationName)]
+pub struct Migration;
+
+#[async_trait::async_trait]
+impl MigrationTrait for Migration {
+    async fn up(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Asset::Table)
+                    .rename_column(Asset::IssuedSupply, Asset::InitialSupply)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Asset::Table)
+                    .add_column(ColumnDef::new(Asset::MaxSupply).string().null())
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Asset::Table)
+                    .add_column(
+                        ColumnDef::new(Asset::KnownCirculatingSupply)
+                            .string()
+                            .null(),
+                    )
+                    .to_owned(),
+            )
+            .await?;
+
+        Ok(())
+    }
+
+    async fn down(&self, manager: &SchemaManager) -> Result<(), DbErr> {
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Asset::Table)
+                    .rename_column(Asset::InitialSupply, Asset::IssuedSupply)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Asset::Table)
+                    .drop_column(Asset::MaxSupply)
+                    .to_owned(),
+            )
+            .await?;
+
+        manager
+            .alter_table(
+                Table::alter()
+                    .table(Asset::Table)
+                    .drop_column(Asset::KnownCirculatingSupply)
+                    .to_owned(),
+            )
+            .await?;
+
+        Ok(())
+    }
+}
+
+#[derive(DeriveIden)]
+pub enum Asset {
+    Table,
+    IssuedSupply,
+    InitialSupply,
+    MaxSupply,
+    KnownCirculatingSupply,
+}

src/database/entities/asset.rs

@@ -21,11 +21,13 @@ pub struct Model {
     pub schema: AssetSchema,
     pub added_at: i64,
     pub details: Option<String>,
-    pub issued_supply: String,
+    pub initial_supply: String,
     pub name: String,
     pub precision: u8,
     pub ticker: Option<String>,
     pub timestamp: i64,
+    pub max_supply: Option<String>,
+    pub known_circulating_supply: Option<String>,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DeriveColumn)]
@@ -36,11 +38,13 @@ pub enum Column {
     Schema,
     AddedAt,
     Details,
-    IssuedSupply,
+    InitialSupply,
     Name,
     Precision,
     Ticker,
     Timestamp,
+    MaxSupply,
+    KnownCirculatingSupply,
 }
 
 #[derive(Copy, Clone, Debug, EnumIter, DerivePrimaryKey)]
@@ -72,11 +76,13 @@ impl ColumnTrait for Column {
             Self::Schema => ColumnType::SmallInteger.def(),
             Self::AddedAt => ColumnType::BigInteger.def(),
             Self::Details => ColumnType::String(StringLen::None).def().null(),
-            Self::IssuedSupply => ColumnType::String(StringLen::None).def(),
+            Self::InitialSupply => ColumnType::String(StringLen::None).def(),
             Self::Name => ColumnType::String(StringLen::None).def(),
             Self::Precision => ColumnType::SmallInteger.def(),
             Self::Ticker => ColumnType::String(StringLen::None).def().null(),
             Self::Timestamp => ColumnType::BigInteger.def(),
+            Self::MaxSupply => ColumnType::String(StringLen::None).def().null(),
+            Self::KnownCirculatingSupply => ColumnType::String(StringLen::None).def().null(),
         }
     }
 }