Skip to content

Commit 1075737

Browse files
committed
Change naming parameter
1 parent cf7fd60 commit 1075737

File tree

7 files changed

+29
-29
lines changed

7 files changed

+29
-29
lines changed

crates/client/assets/schema.sdl

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1342,7 +1342,7 @@ type Subscription {
13421342
"""
13431343
If true, accept to receive the preconfirmation status
13441344
"""
1345-
allowPreconfirmation: Boolean
1345+
includePreconfirmation: Boolean
13461346
): TransactionStatus!
13471347
"""
13481348
Submits transaction to the `TxPool` and await either success or failure.
@@ -1353,7 +1353,7 @@ type Subscription {
13531353
Compared to the `submitAndAwait`, the stream also contains
13541354
`SubmittedStatus` and potentially preconfirmation as an intermediate state.
13551355
"""
1356-
submitAndAwaitStatus(tx: HexString!, estimatePredicates: Boolean, allowPreconfirmation: Boolean): TransactionStatus!
1356+
submitAndAwaitStatus(tx: HexString!, estimatePredicates: Boolean, includePreconfirmation: Boolean): TransactionStatus!
13571357
contractStorageSlots(contractId: ContractId!): StorageSlot!
13581358
contractStorageBalances(contractId: ContractId!): ContractBalance!
13591359
}
@@ -1395,7 +1395,7 @@ type Transaction {
13951395
outputContract: ContractOutput
13961396
witnesses: [HexString!]
13971397
receiptsRoot: Bytes32
1398-
status(allowPreconfirmation: Boolean): TransactionStatus
1398+
status(includePreconfirmation: Boolean): TransactionStatus
13991399
script: HexString
14001400
scriptData: HexString
14011401
bytecodeWitnessIndex: U16

crates/client/src/client.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -948,7 +948,7 @@ impl FuelClient {
948948
&'a self,
949949
tx: &'a Transaction,
950950
estimate_predicates: Option<bool>,
951-
allow_preconfirmation: Option<bool>,
951+
include_preconfirmation: Option<bool>,
952952
) -> io::Result<impl Stream<Item = io::Result<TransactionStatus>> + 'a> {
953953
use cynic::SubscriptionBuilder;
954954
use schema::tx::SubmitAndAwaitStatusArg;
@@ -957,7 +957,7 @@ impl FuelClient {
957957
SubmitAndAwaitStatusArg {
958958
tx: HexString(Bytes(tx)),
959959
estimate_predicates,
960-
allow_preconfirmation,
960+
include_preconfirmation,
961961
},
962962
);
963963

@@ -1222,15 +1222,15 @@ impl FuelClient {
12221222
pub async fn subscribe_transaction_status_opt<'a>(
12231223
&'a self,
12241224
id: &'a TxId,
1225-
allow_preconfirmation: Option<bool>,
1225+
include_preconfirmation: Option<bool>,
12261226
) -> io::Result<impl Stream<Item = io::Result<TransactionStatus>> + 'a> {
12271227
use cynic::SubscriptionBuilder;
12281228
use schema::tx::StatusChangeSubscriptionArgs;
12291229
let tx_id: TransactionId = (*id).into();
12301230
let s =
12311231
schema::tx::StatusChangeSubscription::build(StatusChangeSubscriptionArgs {
12321232
id: tx_id,
1233-
allow_preconfirmation,
1233+
include_preconfirmation,
12341234
});
12351235

12361236
tracing::debug!("subscribing");

crates/client/src/client/schema/tx.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -476,7 +476,7 @@ pub struct TransactionsByOwnerQuery {
476476
pub struct StatusChangeSubscriptionArgs {
477477
pub id: TransactionId,
478478
#[cynic(skip_serializing_if = "Option::is_none")]
479-
pub allow_preconfirmation: Option<bool>,
479+
pub include_preconfirmation: Option<bool>,
480480
}
481481

482482
#[derive(cynic::QueryFragment, Clone, Debug)]
@@ -486,7 +486,7 @@ pub struct StatusChangeSubscriptionArgs {
486486
variables = "StatusChangeSubscriptionArgs"
487487
)]
488488
pub struct StatusChangeSubscription {
489-
#[arguments(id: $id, allowPreconfirmation: $allow_preconfirmation)]
489+
#[arguments(id: $id, includePreconfirmation: $include_preconfirmation)]
490490
pub status_change: TransactionStatus,
491491
}
492492

@@ -510,7 +510,7 @@ pub struct SubmitAndAwaitStatusArg {
510510
#[cynic(skip_serializing_if = "Option::is_none")]
511511
pub estimate_predicates: Option<bool>,
512512
#[cynic(skip_serializing_if = "Option::is_none")]
513-
pub allow_preconfirmation: Option<bool>,
513+
pub include_preconfirmation: Option<bool>,
514514
}
515515

516516
#[derive(cynic::QueryFragment, Clone, Debug)]
@@ -662,7 +662,7 @@ pub struct SubmitAndAwaitSubscriptionWithTransaction {
662662
variables = "SubmitAndAwaitStatusArg"
663663
)]
664664
pub struct SubmitAndAwaitStatusSubscription {
665-
#[arguments(tx: $tx, estimatePredicates: $estimate_predicates, allowPreconfirmation: $allow_preconfirmation)]
665+
#[arguments(tx: $tx, estimatePredicates: $estimate_predicates, includePreconfirmation: $include_preconfirmation)]
666666
pub submit_and_await_status: TransactionStatus,
667667
}
668668

crates/fuel-core/src/query/subscriptions.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ pub(crate) trait TxnStatusChangeState {
2020
async fn get_tx_status(
2121
&self,
2222
id: Bytes32,
23-
allow_preconfirmation: bool,
23+
include_preconfirmation: bool,
2424
) -> StorageResult<Option<TransactionStatus>>;
2525
}
2626

@@ -29,15 +29,15 @@ pub(crate) async fn transaction_status_change<'a, State>(
2929
state: State,
3030
stream: BoxStream<'a, TxStatusMessage>,
3131
transaction_id: Bytes32,
32-
allow_preconfirmation: bool,
32+
include_preconfirmation: bool,
3333
) -> impl Stream<Item = anyhow::Result<ApiTxStatus>> + 'a
3434
where
3535
State: TxnStatusChangeState + Send + Sync + 'a,
3636
{
3737
// Check the database first to see if the transaction already
3838
// has a status.
3939
let maybe_db_status = state
40-
.get_tx_status(transaction_id, allow_preconfirmation)
40+
.get_tx_status(transaction_id, include_preconfirmation)
4141
.await
4242
.transpose()
4343
.map(TxStatusMessage::from);
@@ -62,7 +62,7 @@ where
6262
match status {
6363
TxStatusMessage::Status(status) => {
6464
let status = ApiTxStatus::new(transaction_id, status);
65-
if !allow_preconfirmation && status.is_preconfirmation() {
65+
if !include_preconfirmation && status.is_preconfirmation() {
6666
futures::future::ready(None)
6767
} else {
6868
futures::future::ready(Some(Ok(status)))

crates/fuel-core/src/schema/tx.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -626,7 +626,7 @@ impl TxStatusSubscription {
626626
ctx: &'a Context<'a>,
627627
#[graphql(desc = "The ID of the transaction")] id: TransactionId,
628628
#[graphql(desc = "If true, accept to receive the preconfirmation status")]
629-
allow_preconfirmation: Option<bool>,
629+
include_preconfirmation: Option<bool>,
630630
) -> anyhow::Result<impl Stream<Item = async_graphql::Result<TransactionStatus>> + 'a>
631631
{
632632
let tx_status_manager = ctx.data_unchecked::<DynTxStatusManager>();
@@ -641,7 +641,7 @@ impl TxStatusSubscription {
641641
status_change_state,
642642
rx,
643643
id.into(),
644-
allow_preconfirmation.unwrap_or(false),
644+
include_preconfirmation.unwrap_or(false),
645645
)
646646
.await
647647
.map_err(async_graphql::Error::from))
@@ -676,15 +676,15 @@ impl TxStatusSubscription {
676676
ctx: &'a Context<'a>,
677677
tx: HexString,
678678
estimate_predicates: Option<bool>,
679-
allow_preconfirmation: Option<bool>,
679+
include_preconfirmation: Option<bool>,
680680
) -> async_graphql::Result<
681681
impl Stream<Item = async_graphql::Result<TransactionStatus>> + 'a,
682682
> {
683683
submit_and_await_status(
684684
ctx,
685685
tx,
686686
estimate_predicates.unwrap_or(false),
687-
allow_preconfirmation.unwrap_or(false),
687+
include_preconfirmation.unwrap_or(false),
688688
)
689689
.await
690690
}
@@ -694,7 +694,7 @@ async fn submit_and_await_status<'a>(
694694
ctx: &'a Context<'a>,
695695
tx: HexString,
696696
estimate_predicates: bool,
697-
allow_preconfirmation: bool,
697+
include_preconfirmation: bool,
698698
) -> async_graphql::Result<
699699
impl Stream<Item = async_graphql::Result<TransactionStatus>> + 'a,
700700
> {
@@ -721,7 +721,7 @@ async fn submit_and_await_status<'a>(
721721
match status {
722722
TxStatusMessage::Status(status) => {
723723
let status = TransactionStatus::new(tx_id, status);
724-
if !allow_preconfirmation && status.is_preconfirmation() {
724+
if !include_preconfirmation && status.is_preconfirmation() {
725725
None
726726
} else {
727727
Some(Ok(status))
@@ -746,13 +746,13 @@ impl<'a> TxnStatusChangeState for StatusChangeState<'a> {
746746
async fn get_tx_status(
747747
&self,
748748
id: Bytes32,
749-
allow_preconfirmation: bool,
749+
include_preconfirmation: bool,
750750
) -> StorageResult<Option<transaction_status::TransactionStatus>> {
751751
get_tx_status(
752752
&id,
753753
self.query.as_ref(),
754754
self.tx_status_manager,
755-
allow_preconfirmation,
755+
include_preconfirmation,
756756
)
757757
.await
758758
}

crates/fuel-core/src/schema/tx/types.rs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -777,7 +777,7 @@ impl Transaction {
777777
async fn status(
778778
&self,
779779
ctx: &Context<'_>,
780-
allow_preconfirmation: Option<bool>,
780+
include_preconfirmation: Option<bool>,
781781
) -> async_graphql::Result<Option<TransactionStatus>> {
782782
let id = self.1;
783783
let query = ctx.read_view()?;
@@ -788,7 +788,7 @@ impl Transaction {
788788
&id,
789789
query.as_ref(),
790790
tx_status_manager,
791-
allow_preconfirmation.unwrap_or(false),
791+
include_preconfirmation.unwrap_or(false),
792792
)
793793
.await
794794
.map(|status| status.map(|status| TransactionStatus::new(id, status)))
@@ -1112,7 +1112,7 @@ pub(crate) async fn get_tx_status(
11121112
id: &fuel_core_types::fuel_types::Bytes32,
11131113
query: &ReadView,
11141114
tx_status_manager: &DynTxStatusManager,
1115-
allow_preconfirmation: bool,
1115+
include_preconfirmation: bool,
11161116
) -> Result<Option<transaction_status::TransactionStatus>, StorageError> {
11171117
let api_result = query
11181118
.tx_status(id)
@@ -1126,7 +1126,7 @@ pub(crate) async fn get_tx_status(
11261126
// Filter out preconfirmation statuses if not allowed. Converting to submitted status
11271127
// because it's the closest to the preconfirmation status.
11281128
// Having `now()` as timestamp isn't ideal but shouldn't cause much inconsistency.
1129-
if !allow_preconfirmation
1129+
if !include_preconfirmation
11301130
&& status.is_preconfirmation()
11311131
&& !status.is_final()
11321132
{

crates/fuel-core/src/service/query.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ impl<'a> TxnStatusChangeState for StatusChangeState<'a> {
103103
async fn get_tx_status(
104104
&self,
105105
id: Bytes32,
106-
allow_preconfirmation: bool,
106+
include_preconfirmation: bool,
107107
) -> StorageResult<Option<TxPoolTxStatus>> {
108108
match self.db.get_tx_status(&id)? {
109109
Some(status) => Ok(Some(status.into())),
@@ -113,7 +113,7 @@ impl<'a> TxnStatusChangeState for StatusChangeState<'a> {
113113
// Filter out preconfirmation statuses if not allowed. Converting to submitted status
114114
// because it's the closest to the preconfirmation status.
115115
// Having `now()` as timestamp isn't ideal but shouldn't cause much inconsistency.
116-
if !allow_preconfirmation
116+
if !include_preconfirmation
117117
&& status.is_preconfirmation()
118118
&& !status.is_final()
119119
{

0 commit comments

Comments
 (0)