-
Notifications
You must be signed in to change notification settings - Fork 12
/
schema.go
612 lines (577 loc) · 32.3 KB
/
schema.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
package transform
import (
"time"
"github.com/guregu/null"
"github.com/guregu/null/zero"
"github.com/lib/pq"
"github.com/stellar/go/xdr"
)
// LedgerOutput is a representation of a ledger that aligns with the BigQuery table history_ledgers
type LedgerOutput struct {
Sequence uint32 `json:"sequence"` // sequence number of the ledger
LedgerHash string `json:"ledger_hash"`
PreviousLedgerHash string `json:"previous_ledger_hash"`
LedgerHeader string `json:"ledger_header"` // base 64 encoding of the ledger header
TransactionCount int32 `json:"transaction_count"`
OperationCount int32 `json:"operation_count"` // counts only operations that were a part of successful transactions
SuccessfulTransactionCount int32 `json:"successful_transaction_count"`
FailedTransactionCount int32 `json:"failed_transaction_count"`
TxSetOperationCount string `json:"tx_set_operation_count"` // counts all operations, even those that are part of failed transactions
ClosedAt time.Time `json:"closed_at"` // UTC timestamp
TotalCoins int64 `json:"total_coins"`
FeePool int64 `json:"fee_pool"`
BaseFee uint32 `json:"base_fee"`
BaseReserve uint32 `json:"base_reserve"`
MaxTxSetSize uint32 `json:"max_tx_set_size"`
ProtocolVersion uint32 `json:"protocol_version"`
LedgerID int64 `json:"id"`
SorobanFeeWrite1Kb int64 `json:"soroban_fee_write_1kb"`
}
// TransactionOutput is a representation of a transaction that aligns with the BigQuery table history_transactions
type TransactionOutput struct {
TransactionHash string `json:"transaction_hash"`
LedgerSequence uint32 `json:"ledger_sequence"`
Account string `json:"account"`
AccountMuxed string `json:"account_muxed,omitempty"`
AccountSequence int64 `json:"account_sequence"`
MaxFee uint32 `json:"max_fee"`
FeeCharged int64 `json:"fee_charged"`
OperationCount int32 `json:"operation_count"`
TxEnvelope string `json:"tx_envelope"`
TxResult string `json:"tx_result"`
TxMeta string `json:"tx_meta"`
TxFeeMeta string `json:"tx_fee_meta"`
CreatedAt time.Time `json:"created_at"`
MemoType string `json:"memo_type"`
Memo string `json:"memo"`
TimeBounds string `json:"time_bounds"`
Successful bool `json:"successful"`
TransactionID int64 `json:"id"`
FeeAccount string `json:"fee_account,omitempty"`
FeeAccountMuxed string `json:"fee_account_muxed,omitempty"`
InnerTransactionHash string `json:"inner_transaction_hash,omitempty"`
NewMaxFee uint32 `json:"new_max_fee,omitempty"`
LedgerBounds string `json:"ledger_bounds"`
MinAccountSequence null.Int `json:"min_account_sequence"`
MinAccountSequenceAge null.Int `json:"min_account_sequence_age"`
MinAccountSequenceLedgerGap null.Int `json:"min_account_sequence_ledger_gap"`
ExtraSigners pq.StringArray `json:"extra_signers"`
ClosedAt time.Time `json:"closed_at"`
ResourceFee int64 `json:"resource_fee"`
SorobanResourcesInstructions uint32 `json:"soroban_resources_instructions"`
SorobanResourcesReadBytes uint32 `json:"soroban_resources_read_bytes"`
SorobanResourcesWriteBytes uint32 `json:"soroban_resources_write_bytes"`
TransactionResultCode string `json:"transaction_result_code"`
InclusionFeeBid int64 `json:"inclusion_fee_bid"`
InclusionFeeCharged int64 `json:"inclusion_fee_charged"`
ResourceFeeRefund int64 `json:"resource_fee_refund"`
TotalNonRefundableResourceFeeCharged int64 `json:"non_refundable_resource_fee_charged"`
TotalRefundableResourceFeeCharged int64 `json:"refundable_resource_fee_charged"`
RentFeeCharged int64 `json:"rent_fee_charged"`
}
type LedgerTransactionOutput struct {
LedgerSequence uint32 `json:"ledger_sequence"`
TxEnvelope string `json:"tx_envelope"`
TxResult string `json:"tx_result"`
TxMeta string `json:"tx_meta"`
TxFeeMeta string `json:"tx_fee_meta"`
TxLedgerHistory string `json:"tx_ledger_history"`
ClosedAt time.Time `json:"closed_at"`
}
// AccountOutput is a representation of an account that aligns with the BigQuery table accounts
type AccountOutput struct {
AccountID string `json:"account_id"` // account address
Balance float64 `json:"balance"`
BuyingLiabilities float64 `json:"buying_liabilities"`
SellingLiabilities float64 `json:"selling_liabilities"`
SequenceNumber int64 `json:"sequence_number"`
SequenceLedger zero.Int `json:"sequence_ledger"`
SequenceTime zero.Int `json:"sequence_time"`
NumSubentries uint32 `json:"num_subentries"`
InflationDestination string `json:"inflation_destination"`
Flags uint32 `json:"flags"`
HomeDomain string `json:"home_domain"`
MasterWeight int32 `json:"master_weight"`
ThresholdLow int32 `json:"threshold_low"`
ThresholdMedium int32 `json:"threshold_medium"`
ThresholdHigh int32 `json:"threshold_high"`
Sponsor null.String `json:"sponsor"`
NumSponsored uint32 `json:"num_sponsored"`
NumSponsoring uint32 `json:"num_sponsoring"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// AccountSignerOutput is a representation of an account signer that aligns with the BigQuery table account_signers
type AccountSignerOutput struct {
AccountID string `json:"account_id"`
Signer string `json:"signer"`
Weight int32 `json:"weight"`
Sponsor null.String `json:"sponsor"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// OperationOutput is a representation of an operation that aligns with the BigQuery table history_operations
type OperationOutput struct {
SourceAccount string `json:"source_account"`
SourceAccountMuxed string `json:"source_account_muxed,omitempty"`
Type int32 `json:"type"`
TypeString string `json:"type_string"`
OperationDetails map[string]interface{} `json:"details"` //Details is a JSON object that varies based on operation type
TransactionID int64 `json:"transaction_id"`
OperationID int64 `json:"id"`
ClosedAt time.Time `json:"closed_at"`
OperationResultCode string `json:"operation_result_code"`
OperationTraceCode string `json:"operation_trace_code"`
}
// ClaimableBalanceOutput is a representation of a claimable balances that aligns with the BigQuery table claimable_balances
type ClaimableBalanceOutput struct {
BalanceID string `json:"balance_id"`
Claimants []Claimant `json:"claimants"`
AssetCode string `json:"asset_code"`
AssetIssuer string `json:"asset_issuer"`
AssetType string `json:"asset_type"`
AssetID int64 `json:"asset_id"`
AssetAmount float64 `json:"asset_amount"`
Sponsor null.String `json:"sponsor"`
Flags uint32 `json:"flags"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// Claimants
type Claimant struct {
Destination string `json:"destination"`
Predicate xdr.ClaimPredicate `json:"predicate"`
}
// Price represents the price of an asset as a fraction
type Price struct {
Numerator int32 `json:"n"`
Denominator int32 `json:"d"`
}
// Path is a representation of an asset without an ID that forms part of a path in a path payment
type Path struct {
AssetCode string `json:"asset_code"`
AssetIssuer string `json:"asset_issuer"`
AssetType string `json:"asset_type"`
}
// LiquidityPoolAsset represents the asset pairs in a liquidity pool
type LiquidityPoolAsset struct {
AssetAType string
AssetACode string
AssetAIssuer string
AssetAAmount float64
AssetBType string
AssetBCode string
AssetBIssuer string
AssetBAmount float64
}
// PoolOutput is a representation of a liquidity pool that aligns with the Bigquery table liquidity_pools
type PoolOutput struct {
PoolID string `json:"liquidity_pool_id"`
PoolType string `json:"type"`
PoolFee uint32 `json:"fee"`
TrustlineCount uint64 `json:"trustline_count"`
PoolShareCount float64 `json:"pool_share_count"`
AssetAType string `json:"asset_a_type"`
AssetACode string `json:"asset_a_code"`
AssetAIssuer string `json:"asset_a_issuer"`
AssetAReserve float64 `json:"asset_a_amount"`
AssetAID int64 `json:"asset_a_id"`
AssetBType string `json:"asset_b_type"`
AssetBCode string `json:"asset_b_code"`
AssetBIssuer string `json:"asset_b_issuer"`
AssetBReserve float64 `json:"asset_b_amount"`
AssetBID int64 `json:"asset_b_id"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// AssetOutput is a representation of an asset that aligns with the BigQuery table history_assets
type AssetOutput struct {
AssetCode string `json:"asset_code"`
AssetIssuer string `json:"asset_issuer"`
AssetType string `json:"asset_type"`
AssetID uint64 `json:"id"`
ID int64 `json:"asset_id"`
}
// TrustlineOutput is a representation of a trustline that aligns with the BigQuery table trust_lines
type TrustlineOutput struct {
LedgerKey string `json:"ledger_key"`
AccountID string `json:"account_id"`
AssetCode string `json:"asset_code"`
AssetIssuer string `json:"asset_issuer"`
AssetType int32 `json:"asset_type"`
AssetID int64 `json:"asset_id"`
Balance float64 `json:"balance"`
TrustlineLimit int64 `json:"trust_line_limit"`
LiquidityPoolID string `json:"liquidity_pool_id"`
BuyingLiabilities float64 `json:"buying_liabilities"`
SellingLiabilities float64 `json:"selling_liabilities"`
Flags uint32 `json:"flags"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Sponsor null.String `json:"sponsor"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// OfferOutput is a representation of an offer that aligns with the BigQuery table offers
type OfferOutput struct {
SellerID string `json:"seller_id"` // Account address of the seller
OfferID int64 `json:"offer_id"`
SellingAssetType string `json:"selling_asset_type"`
SellingAssetCode string `json:"selling_asset_code"`
SellingAssetIssuer string `json:"selling_asset_issuer"`
SellingAssetID int64 `json:"selling_asset_id"`
BuyingAssetType string `json:"buying_asset_type"`
BuyingAssetCode string `json:"buying_asset_code"`
BuyingAssetIssuer string `json:"buying_asset_issuer"`
BuyingAssetID int64 `json:"buying_asset_id"`
Amount float64 `json:"amount"`
PriceN int32 `json:"pricen"`
PriceD int32 `json:"priced"`
Price float64 `json:"price"`
Flags uint32 `json:"flags"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
Sponsor null.String `json:"sponsor"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// TradeOutput is a representation of a trade that aligns with the BigQuery table history_trades
type TradeOutput struct {
Order int32 `json:"order"`
LedgerClosedAt time.Time `json:"ledger_closed_at"`
SellingAccountAddress string `json:"selling_account_address"`
SellingAssetCode string `json:"selling_asset_code"`
SellingAssetIssuer string `json:"selling_asset_issuer"`
SellingAssetType string `json:"selling_asset_type"`
SellingAssetID int64 `json:"selling_asset_id"`
SellingAmount float64 `json:"selling_amount"`
BuyingAccountAddress string `json:"buying_account_address"`
BuyingAssetCode string `json:"buying_asset_code"`
BuyingAssetIssuer string `json:"buying_asset_issuer"`
BuyingAssetType string `json:"buying_asset_type"`
BuyingAssetID int64 `json:"buying_asset_id"`
BuyingAmount float64 `json:"buying_amount"`
PriceN int64 `json:"price_n"`
PriceD int64 `json:"price_d"`
SellingOfferID null.Int `json:"selling_offer_id"`
BuyingOfferID null.Int `json:"buying_offer_id"`
SellingLiquidityPoolID null.String `json:"selling_liquidity_pool_id"`
LiquidityPoolFee null.Int `json:"liquidity_pool_fee"`
HistoryOperationID int64 `json:"history_operation_id"`
TradeType int32 `json:"trade_type"`
RoundingSlippage null.Int `json:"rounding_slippage"`
SellerIsExact null.Bool `json:"seller_is_exact"`
}
// DimAccount is a representation of an account that aligns with the BigQuery table dim_accounts
type DimAccount struct {
ID uint64 `json:"account_id"`
Address string `json:"address"`
}
// DimOffer is a representation of an account that aligns with the BigQuery table dim_offers
type DimOffer struct {
HorizonID int64 `json:"horizon_offer_id"`
DimOfferID uint64 `json:"dim_offer_id"`
MarketID uint64 `json:"market_id"`
MakerID uint64 `json:"maker_id"`
Action string `json:"action"`
BaseAmount float64 `json:"base_amount"`
CounterAmount float64 `json:"counter_amount"`
Price float64 `json:"price"`
}
// FactOfferEvent is a representation of an offer event that aligns with the BigQuery table fact_offer_events
type FactOfferEvent struct {
LedgerSeq uint32 `json:"ledger_id"`
OfferInstanceID uint64 `json:"offer_instance_id"`
}
// DimMarket is a representation of an account that aligns with the BigQuery table dim_markets
type DimMarket struct {
ID uint64 `json:"market_id"`
BaseCode string `json:"base_code"`
BaseIssuer string `json:"base_issuer"`
CounterCode string `json:"counter_code"`
CounterIssuer string `json:"counter_issuer"`
}
// NormalizedOfferOutput ties together the information for dim_markets, dim_offers, dim_accounts, and fact_offer-events
type NormalizedOfferOutput struct {
Market DimMarket
Offer DimOffer
Account DimAccount
Event FactOfferEvent
}
type SponsorshipOutput struct {
Operation xdr.Operation
OperationIndex uint32
}
// EffectOutput is a representation of an operation that aligns with the BigQuery table history_effects
type EffectOutput struct {
Address string `json:"address"`
AddressMuxed null.String `json:"address_muxed,omitempty"`
OperationID int64 `json:"operation_id"`
Details map[string]interface{} `json:"details"`
Type int32 `json:"type"`
TypeString string `json:"type_string"`
LedgerClosed time.Time `json:"closed_at"`
}
// EffectType is the numeric type for an effect
type EffectType int
const (
EffectAccountCreated EffectType = 0
EffectAccountRemoved EffectType = 1
EffectAccountCredited EffectType = 2
EffectAccountDebited EffectType = 3
EffectAccountThresholdsUpdated EffectType = 4
EffectAccountHomeDomainUpdated EffectType = 5
EffectAccountFlagsUpdated EffectType = 6
EffectAccountInflationDestinationUpdated EffectType = 7
EffectSignerCreated EffectType = 10
EffectSignerRemoved EffectType = 11
EffectSignerUpdated EffectType = 12
EffectTrustlineCreated EffectType = 20
EffectTrustlineRemoved EffectType = 21
EffectTrustlineUpdated EffectType = 22
EffectTrustlineFlagsUpdated EffectType = 26
EffectOfferCreated EffectType = 30
EffectOfferRemoved EffectType = 31
EffectOfferUpdated EffectType = 32
EffectTrade EffectType = 33
EffectDataCreated EffectType = 40
EffectDataRemoved EffectType = 41
EffectDataUpdated EffectType = 42
EffectSequenceBumped EffectType = 43
EffectClaimableBalanceCreated EffectType = 50
EffectClaimableBalanceClaimantCreated EffectType = 51
EffectClaimableBalanceClaimed EffectType = 52
EffectAccountSponsorshipCreated EffectType = 60
EffectAccountSponsorshipUpdated EffectType = 61
EffectAccountSponsorshipRemoved EffectType = 62
EffectTrustlineSponsorshipCreated EffectType = 63
EffectTrustlineSponsorshipUpdated EffectType = 64
EffectTrustlineSponsorshipRemoved EffectType = 65
EffectDataSponsorshipCreated EffectType = 66
EffectDataSponsorshipUpdated EffectType = 67
EffectDataSponsorshipRemoved EffectType = 68
EffectClaimableBalanceSponsorshipCreated EffectType = 69
EffectClaimableBalanceSponsorshipUpdated EffectType = 70
EffectClaimableBalanceSponsorshipRemoved EffectType = 71
EffectSignerSponsorshipCreated EffectType = 72
EffectSignerSponsorshipUpdated EffectType = 73
EffectSignerSponsorshipRemoved EffectType = 74
EffectClaimableBalanceClawedBack EffectType = 80
EffectLiquidityPoolDeposited EffectType = 90
EffectLiquidityPoolWithdrew EffectType = 91
EffectLiquidityPoolTrade EffectType = 92
EffectLiquidityPoolCreated EffectType = 93
EffectLiquidityPoolRemoved EffectType = 94
EffectLiquidityPoolRevoked EffectType = 95
EffectContractCredited EffectType = 96
EffectContractDebited EffectType = 97
EffectExtendFootprintTtl EffectType = 98
EffectRestoreFootprint EffectType = 99
)
// EffectTypeNames stores a map of effect type ID and names
var EffectTypeNames = map[EffectType]string{
EffectAccountCreated: "account_created",
EffectAccountRemoved: "account_removed",
EffectAccountCredited: "account_credited",
EffectAccountDebited: "account_debited",
EffectAccountThresholdsUpdated: "account_thresholds_updated",
EffectAccountHomeDomainUpdated: "account_home_domain_updated",
EffectAccountFlagsUpdated: "account_flags_updated",
EffectAccountInflationDestinationUpdated: "account_inflation_destination_updated",
EffectSignerCreated: "signer_created",
EffectSignerRemoved: "signer_removed",
EffectSignerUpdated: "signer_updated",
EffectTrustlineCreated: "trustline_created",
EffectTrustlineRemoved: "trustline_removed",
EffectTrustlineUpdated: "trustline_updated",
EffectTrustlineFlagsUpdated: "trustline_flags_updated",
EffectOfferCreated: "offer_created",
EffectOfferRemoved: "offer_removed",
EffectOfferUpdated: "offer_updated",
EffectTrade: "trade",
EffectDataCreated: "data_created",
EffectDataRemoved: "data_removed",
EffectDataUpdated: "data_updated",
EffectSequenceBumped: "sequence_bumped",
EffectClaimableBalanceCreated: "claimable_balance_created",
EffectClaimableBalanceClaimed: "claimable_balance_claimed",
EffectClaimableBalanceClaimantCreated: "claimable_balance_claimant_created",
EffectAccountSponsorshipCreated: "account_sponsorship_created",
EffectAccountSponsorshipUpdated: "account_sponsorship_updated",
EffectAccountSponsorshipRemoved: "account_sponsorship_removed",
EffectTrustlineSponsorshipCreated: "trustline_sponsorship_created",
EffectTrustlineSponsorshipUpdated: "trustline_sponsorship_updated",
EffectTrustlineSponsorshipRemoved: "trustline_sponsorship_removed",
EffectDataSponsorshipCreated: "data_sponsorship_created",
EffectDataSponsorshipUpdated: "data_sponsorship_updated",
EffectDataSponsorshipRemoved: "data_sponsorship_removed",
EffectClaimableBalanceSponsorshipCreated: "claimable_balance_sponsorship_created",
EffectClaimableBalanceSponsorshipUpdated: "claimable_balance_sponsorship_updated",
EffectClaimableBalanceSponsorshipRemoved: "claimable_balance_sponsorship_removed",
EffectSignerSponsorshipCreated: "signer_sponsorship_created",
EffectSignerSponsorshipUpdated: "signer_sponsorship_updated",
EffectSignerSponsorshipRemoved: "signer_sponsorship_removed",
EffectClaimableBalanceClawedBack: "claimable_balance_clawed_back",
EffectLiquidityPoolDeposited: "liquidity_pool_deposited",
EffectLiquidityPoolWithdrew: "liquidity_pool_withdrew",
EffectLiquidityPoolTrade: "liquidity_pool_trade",
EffectLiquidityPoolCreated: "liquidity_pool_created",
EffectLiquidityPoolRemoved: "liquidity_pool_removed",
EffectLiquidityPoolRevoked: "liquidity_pool_revoked",
EffectContractCredited: "contract_credited",
EffectContractDebited: "contract_debited",
EffectExtendFootprintTtl: "extend_footprint_ttl",
EffectRestoreFootprint: "restore_footprint",
}
// TradeEffectDetails is a struct of data from `effects.DetailsString`
// when the effect type is trade
type TradeEffectDetails struct {
Seller string `json:"seller"`
SellerMuxed string `json:"seller_muxed,omitempty"`
SellerMuxedID uint64 `json:"seller_muxed_id,omitempty"`
OfferID int64 `json:"offer_id"`
SoldAmount string `json:"sold_amount"`
SoldAssetType string `json:"sold_asset_type"`
SoldAssetCode string `json:"sold_asset_code,omitempty"`
SoldAssetIssuer string `json:"sold_asset_issuer,omitempty"`
BoughtAmount string `json:"bought_amount"`
BoughtAssetType string `json:"bought_asset_type"`
BoughtAssetCode string `json:"bought_asset_code,omitempty"`
BoughtAssetIssuer string `json:"bought_asset_issuer,omitempty"`
}
// TestTransaction transaction meta
type TestTransaction struct {
Index uint32
EnvelopeXDR string
ResultXDR string
FeeChangesXDR string
MetaXDR string
Hash string
}
// ContractDataOutput is a representation of contract data that aligns with the Bigquery table soroban_contract_data
type ContractDataOutput struct {
ContractId string `json:"contract_id"`
ContractKeyType string `json:"contract_key_type"`
ContractDurability string `json:"contract_durability"`
ContractDataAssetCode string `json:"asset_code"`
ContractDataAssetIssuer string `json:"asset_issuer"`
ContractDataAssetType string `json:"asset_type"`
ContractDataBalanceHolder string `json:"balance_holder"`
ContractDataBalance string `json:"balance"` // balance is a string because it is go type big.Int
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
LedgerKeyHash string `json:"ledger_key_hash"`
}
// ContractCodeOutput is a representation of contract code that aligns with the Bigquery table soroban_contract_code
type ContractCodeOutput struct {
ContractCodeHash string `json:"contract_code_hash"`
ContractCodeExtV int32 `json:"contract_code_ext_v"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
LedgerKeyHash string `json:"ledger_key_hash"`
//ContractCodeCode string `json:"contract_code"`
NInstructions uint32 `json:"n_instructions"`
NFunctions uint32 `json:"n_functions"`
NGlobals uint32 `json:"n_globals"`
NTableEntries uint32 `json:"n_table_entries"`
NTypes uint32 `json:"n_types"`
NDataSegments uint32 `json:"n_data_segments"`
NElemSegments uint32 `json:"n_elem_segments"`
NImports uint32 `json:"n_imports"`
NExports uint32 `json:"n_exports"`
NDataSegmentBytes uint32 `json:"n_data_segment_bytes"`
}
// ConfigSettingOutput is a representation of soroban config settings that aligns with the Bigquery table config_settings
type ConfigSettingOutput struct {
ConfigSettingId int32 `json:"config_setting_id"`
ContractMaxSizeBytes uint32 `json:"contract_max_size_bytes"`
LedgerMaxInstructions int64 `json:"ledger_max_instructions"`
TxMaxInstructions int64 `json:"tx_max_instructions"`
FeeRatePerInstructionsIncrement int64 `json:"fee_rate_per_instructions_increment"`
TxMemoryLimit uint32 `json:"tx_memory_limit"`
LedgerMaxReadLedgerEntries uint32 `json:"ledger_max_read_ledger_entries"`
LedgerMaxReadBytes uint32 `json:"ledger_max_read_bytes"`
LedgerMaxWriteLedgerEntries uint32 `json:"ledger_max_write_ledger_entries"`
LedgerMaxWriteBytes uint32 `json:"ledger_max_write_bytes"`
TxMaxReadLedgerEntries uint32 `json:"tx_max_read_ledger_entries"`
TxMaxReadBytes uint32 `json:"tx_max_read_bytes"`
TxMaxWriteLedgerEntries uint32 `json:"tx_max_write_ledger_entries"`
TxMaxWriteBytes uint32 `json:"tx_max_write_bytes"`
FeeReadLedgerEntry int64 `json:"fee_read_ledger_entry"`
FeeWriteLedgerEntry int64 `json:"fee_write_ledger_entry"`
FeeRead1Kb int64 `json:"fee_read_1kb"`
BucketListTargetSizeBytes int64 `json:"bucket_list_target_size_bytes"`
WriteFee1KbBucketListLow int64 `json:"write_fee_1kb_bucket_list_low"`
WriteFee1KbBucketListHigh int64 `json:"write_fee_1kb_bucket_list_high"`
BucketListWriteFeeGrowthFactor uint32 `json:"bucket_list_write_fee_growth_factor"`
FeeHistorical1Kb int64 `json:"fee_historical_1kb"`
TxMaxContractEventsSizeBytes uint32 `json:"tx_max_contract_events_size_bytes"`
FeeContractEvents1Kb int64 `json:"fee_contract_events_1kb"`
LedgerMaxTxsSizeBytes uint32 `json:"ledger_max_txs_size_bytes"`
TxMaxSizeBytes uint32 `json:"tx_max_size_bytes"`
FeeTxSize1Kb int64 `json:"fee_tx_size_1kb"`
ContractCostParamsCpuInsns []map[string]string `json:"contract_cost_params_cpu_insns"`
ContractCostParamsMemBytes []map[string]string `json:"contract_cost_params_mem_bytes"`
ContractDataKeySizeBytes uint32 `json:"contract_data_key_size_bytes"`
ContractDataEntrySizeBytes uint32 `json:"contract_data_entry_size_bytes"`
MaxEntryTtl uint32 `json:"max_entry_ttl"`
MinTemporaryTtl uint32 `json:"min_temporary_ttl"`
MinPersistentTtl uint32 `json:"min_persistent_ttl"`
AutoBumpLedgers uint32 `json:"auto_bump_ledgers"`
PersistentRentRateDenominator int64 `json:"persistent_rent_rate_denominator"`
TempRentRateDenominator int64 `json:"temp_rent_rate_denominator"`
MaxEntriesToArchive uint32 `json:"max_entries_to_archive"`
BucketListSizeWindowSampleSize uint32 `json:"bucket_list_size_window_sample_size"`
EvictionScanSize uint64 `json:"eviction_scan_size"`
StartingEvictionScanLevel uint32 `json:"starting_eviction_scan_level"`
LedgerMaxTxCount uint32 `json:"ledger_max_tx_count"`
BucketListSizeWindow []uint64 `json:"bucket_list_size_window"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// TtlOutput is a representation of soroban ttl that aligns with the Bigquery table ttls
type TtlOutput struct {
KeyHash string `json:"key_hash"` // key_hash is contract_code_hash or contract_id
LiveUntilLedgerSeq uint32 `json:"live_until_ledger_seq"`
LastModifiedLedger uint32 `json:"last_modified_ledger"`
LedgerEntryChange uint32 `json:"ledger_entry_change"`
Deleted bool `json:"deleted"`
ClosedAt time.Time `json:"closed_at"`
LedgerSequence uint32 `json:"ledger_sequence"`
}
// DiagnosticEventOutput is a representation of soroban diagnostic events that currently are not stored in a BQ table
type DiagnosticEventOutput struct {
TransactionHash string `json:"transaction_hash"`
LedgerSequence uint32 `json:"ledger_sequence"`
TransactionID int64 `json:"transaction_id"`
ClosedAt time.Time `json:"closed_at"`
InSuccessfulContractCall bool `json:"in_successful_contract_call"`
ExtV int32 `json:"ext_v"`
ContractId string `json:"contract_id"`
Type string `json:"type"`
BodyV int32 `json:"body_v"`
Body string `json:"body"`
}