State attestations

Author: RogerPodacter

app/models/eth_block.rb

@@ -10,6 +10,8 @@ class BlockNotReadyToImportError < StandardError; end
   has_many :ethscription_ownership_versions, foreign_key: :block_number, primary_key: :block_number,
     inverse_of: :eth_block
 
+  before_validation :generate_attestation_hash, if: -> { imported_at.present? }
+    
   def self.genesis_blocks
     blocks = if ENV.fetch('ETHEREUM_NETWORK') == "eth-mainnet"
       [1608625, 3369985, 3981254, 5873780, 8205613, 9046950,
@@ -238,4 +240,46 @@ def as_json(options = {})
       )
     ).with_indifferent_access
   end
+  
+  def generate_attestation_hash
+    hash = Digest::SHA256.new
+    
+    parent_state_hash = EthBlock.where(block_number: block_number - 1).
+      limit(1).pluck(:state_hash).first
+    
+    hash << (parent_state_hash || "NULL")
+    hash << hashable_attributes(self.class).map { |attr| send(attr) }.
+      map { |record| record.nil? ? 'NULL' : record }.join
+
+    associations_to_hash.each do |association|
+      hashable_attributes = quoted_hashable_attributes(association.klass)
+      records = association_scope(association).pluck(*hashable_attributes)
+
+      records.map! { |record| record.nil? ? 'NULL' : record }
+      hash << records.join
+    end
+
+    self.state_hash = "0x" + hash.hexdigest
+    self.parent_state_hash = parent_state_hash
+  end
+
+  def association_scope(association)
+    association.klass.oldest_first.where(block_number: block_number)
+  end
+
+  def associations_to_hash
+    self.class.reflect_on_all_associations(:has_many)
+  end
+
+  def hashable_attributes(klass)
+    klass.columns_hash.reject do |k, v|
+      v.type == :datetime || ['id'].include?(k)
+    end.keys.sort
+  end
+
+  def quoted_hashable_attributes(klass)
+    hashable_attributes(klass).map do |attr|
+      Arel.sql("encode(digest(#{klass.connection.quote_column_name(attr)}::text, 'sha256'), 'hex')")
+    end
+  end
 end

app/models/eth_transaction.rb

@@ -1,15 +1,19 @@
 
 class EthTransaction < ApplicationRecord
   belongs_to :eth_block, foreign_key: :block_number, primary_key: :block_number, optional: true,
-    inverse_of: :eth_transaction
+    inverse_of: :eth_block
   has_one :ethscription, foreign_key: :transaction_hash, primary_key: :transaction_hash,
-    inverse_of: :eth_transaction, dependent: :destroy
-
+    inverse_of: :eth_transaction, inverse_of: :eth_transaction
   has_many :ethscription_transfers, foreign_key: :transaction_hash,
-    primary_key: :transaction_hash, dependent: :destroy, inverse_of: :eth_transaction
+    primary_key: :transaction_hash, inverse_of: :eth_transaction
+  has_many :ethscription_ownership_versions, foreign_key: :transaction_hash,
+    primary_key: :transaction_hash, inverse_of: :eth_transaction
 
   attr_accessor :transfer_index
 
+  scope :newest_first, -> { order(block_number: :desc, transaction_index: :desc) }
+  scope :oldest_first, -> { order(block_number: :asc, transaction_index: :asc) }
+  
   def self.event_signature(event_name)
     "0x" + Digest::Keccak256.hexdigest(event_name)
   end

app/models/ethscription.rb

@@ -46,7 +46,7 @@ def parsed_data_uri
   end
 
   def content_sha
-    Digest::SHA256.hexdigest(content_uri)
+    "0x" + Digest::SHA256.hexdigest(content_uri)
   end
 
   def esip6

app/models/ethscription_ownership_version.rb

@@ -15,4 +15,10 @@ class EthscriptionOwnershipVersion < ApplicationRecord
     transaction_index: :desc,
     transfer_index: :desc
   )}
+  
+  scope :oldest_first, -> { order(
+    block_number: :asc,
+    transaction_index: :asc,
+    transfer_index: :asc
+  )}
 end

app/models/ethscription_transfer.rb

@@ -8,6 +8,18 @@ class EthscriptionTransfer < ApplicationRecord
 
   after_create :create_ownership_version!, :notify_eth_transaction
 
+  scope :newest_first, -> { order(
+    block_number: :desc,
+    transaction_index: :desc,
+    transfer_index: :desc
+  )}
+  
+  scope :oldest_first, -> { order(
+    block_number: :asc,
+    transaction_index: :asc,
+    transfer_index: :asc
+  )}
+  
   def notify_eth_transaction
     if eth_transaction.transfer_index.nil?
       raise "Need eth_transaction.transfer_index"

db/migrate/20231216161930_create_eth_blocks.rb

@@ -8,6 +8,8 @@ def change
       t.string :blockhash, null: false
       t.string :parent_blockhash, null: false
       t.datetime :imported_at
+      t.string :state_hash
+      t.string :parent_state_hash
 
       t.boolean :is_genesis_block, null: false
 
@@ -20,6 +22,8 @@ def change
 
       t.check_constraint "blockhash ~ '^0x[a-f0-9]{64}$'"
       t.check_constraint "parent_blockhash ~ '^0x[a-f0-9]{64}$'"
+      t.check_constraint "state_hash ~ '^0x[a-f0-9]{64}$'"
+      t.check_constraint "parent_state_hash ~ '^0x[a-f0-9]{64}$'"
 
       t.timestamps
     end
@@ -49,6 +53,29 @@ def change
           FOR EACH ROW EXECUTE FUNCTION check_block_order();
         SQL
 
+        execute <<~SQL
+          CREATE OR REPLACE FUNCTION check_block_order_on_update()
+          RETURNS TRIGGER AS $$
+          BEGIN
+            IF NEW.imported_at IS NOT NULL AND NEW.state_hash IS NULL THEN
+              RAISE EXCEPTION 'state_hash must be set when imported_at is set';
+            END IF;
+          
+            IF NEW.is_genesis_block = false AND 
+              NEW.parent_state_hash <> (SELECT state_hash FROM eth_blocks WHERE block_number = NEW.block_number - 1 AND imported_at IS NOT NULL) THEN
+              RAISE EXCEPTION 'Parent state hash does not match the state hash of the previous block';
+            END IF;
+          
+            RETURN NEW;
+          END;
+          $$ LANGUAGE plpgsql;
+          
+          CREATE TRIGGER trigger_check_block_order_on_update
+          BEFORE UPDATE OF imported_at ON eth_blocks
+          FOR EACH ROW WHEN (NEW.imported_at IS NOT NULL)
+          EXECUTE FUNCTION check_block_order_on_update();
+        SQL
+        
         execute <<-SQL
           CREATE OR REPLACE FUNCTION delete_later_blocks()
           RETURNS TRIGGER AS $$

db/migrate/20231216163233_create_eth_transactions.rb

@@ -29,8 +29,8 @@ def change
 
       t.check_constraint "transaction_hash ~ '^0x[a-f0-9]{64}$'"
       t.check_constraint "from_address ~ '^0x[a-f0-9]{40}$'"
-      t.check_constraint "to_address IS NULL OR to_address ~ '^0x[a-f0-9]{40}$'"
-      t.check_constraint "created_contract_address IS NULL OR created_contract_address ~ '^0x[a-f0-9]{40}$'"
+      t.check_constraint "to_address ~ '^0x[a-f0-9]{40}$'"
+      t.check_constraint "created_contract_address ~ '^0x[a-f0-9]{40}$'"
 
       t.foreign_key :eth_blocks, column: :block_number, primary_key: :block_number, on_delete: :cascade
 

db/migrate/20231216164707_create_ethscriptions.rb

@@ -44,7 +44,7 @@ def change
       t.index :transaction_index
       t.index :esip6
 
-      t.check_constraint "content_sha ~ '^[a-f0-9]{64}$'"
+      t.check_constraint "content_sha ~ '^0x[a-f0-9]{64}$'"
       t.check_constraint "transaction_hash ~ '^0x[a-f0-9]{64}$'"
       t.check_constraint "creator ~ '^0x[a-f0-9]{40}$'"
       t.check_constraint "current_owner ~ '^0x[a-f0-9]{40}$'"

db/migrate/20231216215348_create_ethscription_ownership_versions.rb

@@ -13,6 +13,7 @@ def change
 
       t.index :ethscription_transaction_hash
       t.index :transaction_hash
+      t.index :block_number
       t.index [:transaction_hash, :transfer_index], unique: true
       t.index [:block_number, :transaction_index, :transfer_index], unique: true
       t.index [:ethscription_transaction_hash, :block_number, :transaction_index, :transfer_index], unique: true

db/structure.sql

@@ -64,12 +64,34 @@ CREATE FUNCTION public.check_block_order() RETURNS trigger
               NEW.parent_blockhash <> (SELECT blockhash FROM eth_blocks WHERE block_number = NEW.block_number - 1) THEN
               RAISE EXCEPTION 'Parent block hash does not match the parent''s block hash';
             END IF;
-
+            
             RETURN NEW;
           END;
           $$;
 
 
+--
+-- Name: check_block_order_on_update(); Type: FUNCTION; Schema: public; Owner: -
+--
+
+CREATE FUNCTION public.check_block_order_on_update() RETURNS trigger
+    LANGUAGE plpgsql
+    AS $$
+BEGIN
+  IF NEW.imported_at IS NOT NULL AND NEW.state_hash IS NULL THEN
+    RAISE EXCEPTION 'state_hash must be set when imported_at is set';
+  END IF;
+
+  IF NEW.is_genesis_block = false AND 
+    NEW.parent_state_hash <> (SELECT state_hash FROM eth_blocks WHERE block_number = NEW.block_number - 1 AND imported_at IS NOT NULL) THEN
+    RAISE EXCEPTION 'Parent state hash does not match the state hash of the previous block';
+  END IF;
+
+  RETURN NEW;
+END;
+$$;
+
+
 --
 -- Name: check_ethscription_order_and_sequence(); Type: FUNCTION; Schema: public; Owner: -
 --
@@ -208,10 +230,14 @@ CREATE TABLE public.eth_blocks (
     blockhash character varying NOT NULL,
     parent_blockhash character varying NOT NULL,
     imported_at timestamp(6) without time zone,
+    state_hash character varying,
+    parent_state_hash character varying,
     is_genesis_block boolean NOT NULL,
     created_at timestamp(6) without time zone NOT NULL,
     updated_at timestamp(6) without time zone NOT NULL,
     CONSTRAINT chk_rails_1c105acdac CHECK (((parent_blockhash)::text ~ '^0x[a-f0-9]{64}$'::text)),
+    CONSTRAINT chk_rails_319237323b CHECK (((state_hash)::text ~ '^0x[a-f0-9]{64}$'::text)),
+    CONSTRAINT chk_rails_7126b7c9d3 CHECK (((parent_state_hash)::text ~ '^0x[a-f0-9]{64}$'::text)),
     CONSTRAINT chk_rails_7e9881ece2 CHECK (((blockhash)::text ~ '^0x[a-f0-9]{64}$'::text))
 );
 
@@ -257,10 +283,10 @@ CREATE TABLE public.eth_transactions (
     value numeric NOT NULL,
     created_at timestamp(6) without time zone NOT NULL,
     updated_at timestamp(6) without time zone NOT NULL,
-    CONSTRAINT chk_rails_51be5c1aa9 CHECK (((to_address IS NULL) OR ((to_address)::text ~ '^0x[a-f0-9]{40}$'::text))),
-    CONSTRAINT chk_rails_93b41d08e7 CHECK (((created_contract_address IS NULL) OR ((created_contract_address)::text ~ '^0x[a-f0-9]{40}$'::text))),
+    CONSTRAINT chk_rails_37ed5d6017 CHECK (((to_address)::text ~ '^0x[a-f0-9]{40}$'::text)),
     CONSTRAINT chk_rails_9cdbd3b1ad CHECK (((transaction_hash)::text ~ '^0x[a-f0-9]{64}$'::text)),
     CONSTRAINT chk_rails_a4d3f41974 CHECK (((from_address)::text ~ '^0x[a-f0-9]{40}$'::text)),
+    CONSTRAINT chk_rails_d460e80110 CHECK (((created_contract_address)::text ~ '^0x[a-f0-9]{40}$'::text)),
     CONSTRAINT contract_to_check CHECK ((((created_contract_address IS NULL) AND (to_address IS NOT NULL)) OR ((created_contract_address IS NOT NULL) AND (to_address IS NULL)))),
     CONSTRAINT status_check CHECK ((((block_number <= 4370000) AND (status IS NULL)) OR ((block_number > 4370000) AND (status = 1))))
 );
@@ -400,10 +426,10 @@ CREATE TABLE public.ethscriptions (
     created_at timestamp(6) without time zone NOT NULL,
     updated_at timestamp(6) without time zone NOT NULL,
     CONSTRAINT chk_rails_52497428f2 CHECK (((previous_owner)::text ~ '^0x[a-f0-9]{40}$'::text)),
+    CONSTRAINT chk_rails_528fcbfbaa CHECK (((content_sha)::text ~ '^0x[a-f0-9]{64}$'::text)),
     CONSTRAINT chk_rails_6f8922831e CHECK (((current_owner)::text ~ '^0x[a-f0-9]{40}$'::text)),
     CONSTRAINT chk_rails_84591e2730 CHECK (((transaction_hash)::text ~ '^0x[a-f0-9]{64}$'::text)),
     CONSTRAINT chk_rails_b577b97822 CHECK (((creator)::text ~ '^0x[a-f0-9]{40}$'::text)),
-    CONSTRAINT chk_rails_d741e3044d CHECK (((content_sha)::text ~ '^[a-f0-9]{64}$'::text)),
     CONSTRAINT chk_rails_df21fdbe02 CHECK (((initial_owner)::text ~ '^0x[a-f0-9]{40}$'::text))
 );
 
@@ -696,6 +722,13 @@ CREATE INDEX index_eth_transactions_on_to_address ON public.eth_transactions USI
 CREATE UNIQUE INDEX index_eth_transactions_on_transaction_hash ON public.eth_transactions USING btree (transaction_hash);
 
 
+--
+-- Name: index_ethscription_ownership_versions_on_block_number; Type: INDEX; Schema: public; Owner: -
+--
+
+CREATE INDEX index_ethscription_ownership_versions_on_block_number ON public.ethscription_ownership_versions USING btree (block_number);
+
+
 --
 -- Name: index_ethscription_ownership_versions_on_transaction_hash; Type: INDEX; Schema: public; Owner: -
 --
@@ -857,6 +890,13 @@ CREATE TRIGGER check_block_imported_at_trigger BEFORE UPDATE OF imported_at ON p
 CREATE TRIGGER trigger_check_block_order BEFORE INSERT ON public.eth_blocks FOR EACH ROW EXECUTE FUNCTION public.check_block_order();
 
 
+--
+-- Name: eth_blocks trigger_check_block_order_on_update; Type: TRIGGER; Schema: public; Owner: -
+--
+
+CREATE TRIGGER trigger_check_block_order_on_update BEFORE UPDATE OF imported_at ON public.eth_blocks FOR EACH ROW WHEN ((new.imported_at IS NOT NULL)) EXECUTE FUNCTION public.check_block_order_on_update();
+
+
 --
 -- Name: ethscriptions trigger_check_ethscription_order_and_sequence; Type: TRIGGER; Schema: public; Owner: -
 --