package tezos-protocol-016-PtMumbai

  1. Overview
  2. Docs
Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Source file alpha_context.ml

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
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
(*****************************************************************************)
(*                                                                           *)
(* Open Source License                                                       *)
(* Copyright (c) 2018 Dynamic Ledger Solutions, Inc. <contact@tezos.com>     *)
(* Copyright (c) 2019-2022 Nomadic Labs <contact@nomadic-labs.com>           *)
(* Copyright (c) 2021-2022 Trili Tech, <contact@trili.tech>                  *)
(*                                                                           *)
(* Permission is hereby granted, free of charge, to any person obtaining a   *)
(* copy of this software and associated documentation files (the "Software"),*)
(* to deal in the Software without restriction, including without limitation *)
(* the rights to use, copy, modify, merge, publish, distribute, sublicense,  *)
(* and/or sell copies of the Software, and to permit persons to whom the     *)
(* Software is furnished to do so, subject to the following conditions:      *)
(*                                                                           *)
(* The above copyright notice and this permission notice shall be included   *)
(* in all copies or substantial portions of the Software.                    *)
(*                                                                           *)
(* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR*)
(* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,  *)
(* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL   *)
(* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER*)
(* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING   *)
(* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER       *)
(* DEALINGS IN THE SOFTWARE.                                                 *)
(*                                                                           *)
(*****************************************************************************)

type t = Raw_context.t

type context = t

module type BASIC_DATA = sig
  type t

  include Compare.S with type t := t

  val encoding : t Data_encoding.t

  val pp : Format.formatter -> t -> unit
end

module Tez = Tez_repr
module Period = Period_repr

module Timestamp = struct
  include Time_repr

  let current = Raw_context.current_timestamp

  let predecessor = Raw_context.predecessor_timestamp
end

module Slot = Slot_repr
module Sc_rollup_repr = Sc_rollup_repr

module Sc_rollup = struct
  module Tick = Sc_rollup_tick_repr
  include Sc_rollup_repr
  module Metadata = Sc_rollup_metadata_repr
  module Dissection_chunk = Sc_rollup_dissection_chunk_repr
  include Sc_rollup_PVM_sig
  module ArithPVM = Sc_rollup_arith
  module Wasm_2_0_0PVM = Sc_rollup_wasm.V2_0_0
  module Inbox_message = Sc_rollup_inbox_message_repr
  module Inbox_merkelized_payload_hashes =
    Sc_rollup_inbox_merkelized_payload_hashes_repr

  module Staker = struct
    include Sc_rollup_repr.Staker
    module Index = Sc_rollup_staker_index_repr
  end

  module Inbox = struct
    include Sc_rollup_inbox_repr
    include Sc_rollup_inbox_storage

    module Internal_for_tests = struct
      include Sc_rollup_inbox_repr.Internal_for_tests
      include Sc_rollup_inbox_storage.Internal_for_tests
    end
  end

  module Proof = Sc_rollup_proof_repr
  module Game = Sc_rollup_game_repr

  module Commitment = struct
    include Sc_rollup_commitment_repr
    include Sc_rollup_commitment_storage
  end

  module Stake_storage = struct
    include Sc_rollup_stake_storage
  end

  module Refutation_storage = Sc_rollup_refutation_storage
  include Sc_rollup_storage
  include Sc_rollups

  module Outbox = struct
    include Sc_rollup_outbox_storage
    module Message = Sc_rollup_outbox_message_repr
  end

  module Errors = Sc_rollup_errors
end

module Dal = struct
  include Dal_slot_repr

  module Slot_index = struct
    include Dal_slot_repr.Index
  end

  module Attestation = struct
    include Dal_attestation_repr
    include Raw_context.Dal
  end

  type slot_id = Dal_slot_repr.Header.id = {
    published_level : Raw_level_repr.t;
    index : Dal_slot_repr.Index.t;
  }

  module Page = struct
    include Dal_slot_repr.Page
  end

  module Slot = struct
    include Dal_slot_repr
    include Dal_slot_storage
    include Raw_context.Dal
  end

  module Slots_history = Dal_slot_repr.History
  module Slots_storage = Dal_slot_storage
end

module Dal_errors = Dal_errors_repr

module Zk_rollup = struct
  include Zk_rollup_repr
  module State = Zk_rollup_state_repr
  module Account = Zk_rollup_account_repr
  module Operation = Zk_rollup_operation_repr
  module Ticket = Zk_rollup_ticket_repr
  module Errors = Zk_rollup_errors
  module Circuit_public_inputs = Zk_rollup_circuit_public_inputs_repr
  module Update = Zk_rollup_update_repr
  include Zk_rollup_storage
end

module Entrypoint = Entrypoint_repr
module Manager_counter = Manager_counter_repr
include Operation_repr

module Operation = struct
  type 'kind t = 'kind operation = {
    shell : Operation.shell_header;
    protocol_data : 'kind protocol_data;
  }

  type packed = packed_operation

  let unsigned_encoding = unsigned_operation_encoding

  include Operation_repr
end

module Block_header = Block_header_repr

module Vote = struct
  include Vote_repr
  include Vote_storage
end

module Block_payload = struct
  include Block_payload_repr
end

module First_level_of_protocol = struct
  let get = Storage.Tenderbake.First_level_of_protocol.get
end

module Ratio = Ratio_repr

module Raw_level = struct
  include Raw_level_repr

  module Internal_for_tests = struct
    let add = add

    let sub = sub
  end
end

module Cycle = Cycle_repr
module Fees = Fees_storage

type public_key = Signature.Public_key.t

type public_key_hash = Signature.Public_key_hash.t

type signature = Signature.t

module Constants = struct
  include Constants_repr
  include Constants_storage
  module Parametric = Constants_parametric_repr

  let round_durations ctxt = Raw_context.round_durations ctxt

  let all ctxt = all_of_parametric (parametric ctxt)
end

module Voting_period = struct
  include Voting_period_repr
  include Voting_period_storage
end

module Round = struct
  include Round_repr
  module Durations = Durations

  type round_durations = Durations.t

  let pp_round_durations = Durations.pp

  let round_durations_encoding = Durations.encoding

  let round_duration = Round_repr.Durations.round_duration

  let update ctxt round = Storage.Block_round.update ctxt round

  let get ctxt = Storage.Block_round.get ctxt
end

module Gas = struct
  include Gas_limit_repr

  type error += Block_quota_exceeded = Raw_context.Block_quota_exceeded

  type error += Operation_quota_exceeded = Raw_context.Operation_quota_exceeded

  let set_limit = Raw_context.set_gas_limit

  let consume_limit_in_block = Raw_context.consume_gas_limit_in_block

  let set_unlimited = Raw_context.set_gas_unlimited

  let consume = Raw_context.consume_gas

  let consume_from available_gas cost =
    match raw_consume available_gas cost with
    | Some remaining_gas -> ok remaining_gas
    | None -> error Operation_quota_exceeded

  let remaining_operation_gas = Raw_context.remaining_operation_gas

  let update_remaining_operation_gas =
    Raw_context.update_remaining_operation_gas

  let reset_block_gas ctxt =
    let gas = Arith.fp @@ Constants.hard_gas_limit_per_block ctxt in
    Raw_context.update_remaining_block_gas ctxt gas

  let level = Raw_context.gas_level

  let consumed = Raw_context.gas_consumed

  let block_level = Raw_context.block_gas_level

  (* Necessary to inject costs for Storage_costs into Gas.cost *)
  let cost_of_repr cost = cost
end

module Script = struct
  include Michelson_v1_primitives
  include Script_repr

  type consume_deserialization_gas = Always | When_needed

  let force_decode_in_context ~consume_deserialization_gas ctxt lexpr =
    let gas_cost =
      match consume_deserialization_gas with
      | Always -> Script_repr.stable_force_decode_cost lexpr
      | When_needed -> Script_repr.force_decode_cost lexpr
    in
    Raw_context.consume_gas ctxt gas_cost >>? fun ctxt ->
    Script_repr.force_decode lexpr >|? fun v -> (v, ctxt)

  let force_bytes_in_context ctxt lexpr =
    Raw_context.consume_gas ctxt (Script_repr.force_bytes_cost lexpr)
    >>? fun ctxt ->
    Script_repr.force_bytes lexpr >|? fun v -> (v, ctxt)

  let consume_decoding_gas available_gas lexpr =
    let gas_cost = Script_repr.stable_force_decode_cost lexpr in
    Gas.consume_from available_gas gas_cost
end

module Level = struct
  include Level_repr
  include Level_storage
end

module Lazy_storage = struct
  module Kind = Lazy_storage_kind
  module IdSet = Kind.IdSet
  include Lazy_storage_diff
end

module Origination_nonce = struct
  let init = Raw_context.init_origination_nonce

  let unset = Raw_context.unset_origination_nonce

  module Internal_for_tests = Origination_nonce
end

module Destination = struct
  include Destination_repr
  include Destination_storage
end

module Contract = struct
  include Contract_repr
  include Contract_storage

  let is_manager_key_revealed = Contract_manager_storage.is_manager_key_revealed

  let check_public_key = Contract_manager_storage.check_public_key

  let reveal_manager_key = Contract_manager_storage.reveal_manager_key

  let get_manager_key = Contract_manager_storage.get_manager_key

  module Delegate = struct
    let find = Contract_delegate_storage.find

    include Delegate_storage.Contract
  end

  module Internal_for_tests = struct
    include Contract_repr
    include Contract_storage
  end
end

module Tx_rollup_level = Tx_rollup_level_repr
module Tx_rollup_commitment_hash = Tx_rollup_commitment_repr.Hash
module Tx_rollup_message_result_hash = Tx_rollup_message_result_hash_repr

module Tx_rollup = struct
  include Tx_rollup_repr
  include Tx_rollup_storage
  module Internal_for_tests = Tx_rollup_repr
end

module Tx_rollup_state = struct
  include Tx_rollup_state_repr
  include Tx_rollup_state_storage

  module Internal_for_tests = struct
    include Tx_rollup_state_repr
    include Tx_rollup_state_repr.Internal_for_tests
  end
end

module Tx_rollup_withdraw = Tx_rollup_withdraw_repr
module Tx_rollup_withdraw_list_hash = Tx_rollup_withdraw_list_hash_repr
module Tx_rollup_message_result = Tx_rollup_message_result_repr

module Tx_rollup_reveal = struct
  include Tx_rollup_reveal_repr
  include Tx_rollup_reveal_storage
end

module Tx_rollup_message = struct
  include Tx_rollup_message_repr

  let make_message msg = (msg, size msg)

  let make_batch string = make_message @@ Batch string

  let make_deposit sender destination ticket_hash amount =
    make_message @@ Deposit {sender; destination; ticket_hash; amount}
end

module Tx_rollup_message_hash = Tx_rollup_message_hash_repr

module Tx_rollup_inbox = struct
  include Tx_rollup_inbox_repr
  include Tx_rollup_inbox_storage
end

module Tx_rollup_commitment = struct
  include Tx_rollup_commitment_repr
  include Tx_rollup_commitment_storage
end

module Tx_rollup_hash = Tx_rollup_hash_builder
module Tx_rollup_errors = Tx_rollup_errors_repr
module Global_constants_storage = Global_constants_storage

module Big_map = struct
  module Big_map = Lazy_storage_kind.Big_map

  module Id = struct
    type t = Big_map.Id.t

    let encoding = Big_map.Id.encoding

    let rpc_arg = Big_map.Id.rpc_arg

    let parse_z = Big_map.Id.parse_z

    let unparse_to_z = Big_map.Id.unparse_to_z
  end

  let fresh ~temporary c = Lazy_storage.fresh Big_map ~temporary c

  let mem c m k = Storage.Big_map.Contents.mem (c, m) k

  let get_opt c m k = Storage.Big_map.Contents.find (c, m) k

  let list_key_values ?offset ?length c m =
    Storage.Big_map.Contents.list_key_values ?offset ?length (c, m)

  let exists c id =
    Raw_context.consume_gas c (Gas_limit_repr.read_bytes_cost 0) >>?= fun c ->
    Storage.Big_map.Key_type.find c id >>=? fun kt ->
    match kt with
    | None -> return (c, None)
    | Some kt ->
        Storage.Big_map.Value_type.get c id >|=? fun kv -> (c, Some (kt, kv))

  type update = Big_map.update = {
    key : Script_repr.expr;
    key_hash : Script_expr_hash.t;
    value : Script_repr.expr option;
  }

  type updates = Big_map.updates

  type alloc = Big_map.alloc = {
    key_type : Script_repr.expr;
    value_type : Script_repr.expr;
  }
end

module Sapling = struct
  module Sapling_state = Lazy_storage_kind.Sapling_state

  module Id = struct
    type t = Sapling_state.Id.t

    let encoding = Sapling_state.Id.encoding

    let rpc_arg = Sapling_state.Id.rpc_arg

    let parse_z = Sapling_state.Id.parse_z

    let unparse_to_z = Sapling_state.Id.unparse_to_z
  end

  include Sapling_repr
  include Sapling_storage
  include Sapling_validator

  let fresh ~temporary c = Lazy_storage.fresh Sapling_state ~temporary c

  type updates = Sapling_state.updates

  type alloc = Sapling_state.alloc = {memo_size : Sapling_repr.Memo_size.t}

  module Legacy = struct
    include Sapling.UTXO.Legacy

    let transaction_get_memo_size transaction =
      match transaction.outputs with
      | [] -> None
      | {ciphertext; _} :: _ ->
          (* Encoding ensures all ciphertexts have the same memo size. *)
          Some (Sapling.Ciphertext.get_memo_size ciphertext)

    let transaction_in_memory_size transaction =
      transaction_in_memory_size (cast transaction)

    let verify_update ctxt state transaction key =
      verify_update ctxt state (cast transaction) key
  end
end

module Bond_id = struct
  include Bond_id_repr
  module Internal_for_tests = Contract_storage
end

module Receipt = Receipt_repr
module Consensus_key = Delegate_consensus_key

module Delegate = struct
  include Delegate_storage
  include Delegate_missed_endorsements_storage
  include Delegate_slashed_deposits_storage
  include Delegate_cycles

  type deposits = Storage.deposits = {
    initial_amount : Tez.t;
    current_amount : Tez.t;
  }

  let last_cycle_before_deactivation =
    Delegate_activation_storage.last_cycle_before_deactivation

  let prepare_stake_distribution = Stake_storage.prepare_stake_distribution

  let check_not_tz4 = Contract_delegate_storage.check_not_tz4

  let delegated_contracts = Contract_delegate_storage.delegated_contracts

  let deactivated = Delegate_activation_storage.is_inactive

  module Consensus_key = Delegate_consensus_key
end

module Stake_distribution = struct
  let snapshot = Stake_storage.snapshot

  let compute_snapshot_index = Delegate_sampler.compute_snapshot_index

  let baking_rights_owner = Delegate_sampler.baking_rights_owner

  let slot_owner = Delegate_sampler.slot_owner
end

module Nonce = Nonce_storage

module Seed = struct
  include Seed_repr
  include Seed_storage
end

module Fitness = struct
  type raw = Fitness.t

  include Fitness_repr
end

module Bootstrap = Bootstrap_storage

module Commitment = struct
  include Commitment_repr
  include Commitment_storage
end

module Migration = Migration_repr

module Consensus = struct
  include Raw_context.Consensus

  let load_endorsement_branch ctxt =
    Storage.Tenderbake.Endorsement_branch.find ctxt >>=? function
    | Some endorsement_branch ->
        Raw_context.Consensus.set_endorsement_branch ctxt endorsement_branch
        |> return
    | None -> return ctxt

  let store_endorsement_branch ctxt branch =
    let ctxt = set_endorsement_branch ctxt branch in
    Storage.Tenderbake.Endorsement_branch.add ctxt branch

  let load_grand_parent_branch ctxt =
    Storage.Tenderbake.Grand_parent_branch.find ctxt >>=? function
    | Some grand_parent_branch ->
        Raw_context.Consensus.set_grand_parent_branch ctxt grand_parent_branch
        |> return
    | None -> return ctxt

  let store_grand_parent_branch ctxt branch =
    let ctxt = set_grand_parent_branch ctxt branch in
    Storage.Tenderbake.Grand_parent_branch.add ctxt branch
end

let prepare_first_block = Init_storage.prepare_first_block

let prepare ctxt ~level ~predecessor_timestamp ~timestamp =
  Init_storage.prepare ctxt ~level ~predecessor_timestamp ~timestamp
  >>=? fun (ctxt, balance_updates, origination_results) ->
  Consensus.load_endorsement_branch ctxt >>=? fun ctxt ->
  Consensus.load_grand_parent_branch ctxt >>=? fun ctxt ->
  return (ctxt, balance_updates, origination_results)

let finalize ?commit_message:message c fitness =
  let context = Raw_context.recover c in
  {
    Updater.context;
    fitness;
    message;
    max_operations_ttl = (Raw_context.constants c).max_operations_time_to_live;
    last_allowed_fork_level =
      Raw_level.to_int32 @@ Level.last_allowed_fork_level c;
  }

let current_context c = Raw_context.recover c

let record_non_consensus_operation_hash =
  Raw_context.record_non_consensus_operation_hash

let non_consensus_operations = Raw_context.non_consensus_operations

let record_dictator_proposal_seen = Raw_context.record_dictator_proposal_seen

let dictator_proposal_seen = Raw_context.dictator_proposal_seen

let activate = Raw_context.activate

let reset_internal_nonce = Raw_context.reset_internal_nonce

let fresh_internal_nonce = Raw_context.fresh_internal_nonce

let record_internal_nonce = Raw_context.record_internal_nonce

let internal_nonce_already_recorded =
  Raw_context.internal_nonce_already_recorded

let description = Raw_context.description

module Parameters = Parameters_repr

module Liquidity_baking = struct
  include Liquidity_baking_repr
  include Liquidity_baking_storage
end

module Ticket_hash = struct
  include Ticket_hash_repr
  include Ticket_hash_builder
end

module Ticket_balance = struct
  include Ticket_storage
end

module Token = Token
module Cache = Cache_repr

module Internal_for_tests = struct
  let to_raw x = x
end
OCaml

Innovation. Community. Security.