Add metaobject statements to migrator

Author: gianlukk994

lib/shopify_toolkit/migrator.rb

@@ -6,6 +6,7 @@
 class ShopifyToolkit::Migrator # :nodoc:
   include ShopifyToolkit::AdminClient
   include ShopifyToolkit::MetafieldStatements
+  include ShopifyToolkit::MetaobjectStatements
 
   singleton_class.attr_accessor :migrations_paths
   self.migrations_paths = ["config/shopify/migrate"]
@@ -40,9 +41,9 @@ def executed_migrations
   def down
     # For now we'll just rollback the last one
     executed_migrations.last(1).each do |migration|
-      migration.migrate(:down)
-      migrated_versions.delete(migration.version)
-    end
+        migration.migrate(:down)
+        migrated_versions.delete(migration.version)
+      end
   ensure
     update_metafield
   end
@@ -83,9 +84,9 @@ def read_or_create_metafield
     key = :migrations
 
     value = query(
-      "query ShopMetafield($namespace: String!, $key: String!) {shop {metafield(namespace: $namespace, key: $key) {value}}}",
+        "query ShopMetafield($namespace: String!, $key: String!) {shop {metafield(namespace: $namespace, key: $key) {value}}}",
       namespace:, key:,
-    ).dig("shop", "metafield", "value")
+      ).dig("shop", "metafield", "value")
 
     if value.nil?
       create_metafield :shop, key, :json, namespace:, name: "Migrations metadata"
@@ -111,33 +112,33 @@ def parse_migration_filename(filename)
 
   def load_migrations
     migrations = migration_files.map do |file|
-      version, name, scope = parse_migration_filename(file)
-      raise "missing version #{file}" unless version
-      raise "missing name #{file}" unless name
-      version = version.to_i
-      name = name.camelize
+        version, name, scope = parse_migration_filename(file)
+        raise "missing version #{file}" unless version
+        raise "missing name #{file}" unless name
+        version = version.to_i
+        name = name.camelize
 
-      MigrationProxy.new(name, version, file, scope)
-    end
+        MigrationProxy.new(name, version, file, scope)
+      end
 
     migrations.sort_by(&:version)
   end
 
   # MigrationProxy is used to defer loading of the actual migration classes
   # until they are needed
   MigrationProxy = Struct.new(:name, :version, :filename, :scope) do
-    def initialize(name, version, filename, scope)
-      super
-      @migration = nil
-    end
+      def initialize(name, version, filename, scope)
+        super
+        @migration = nil
+      end
 
-    def basename
-      File.basename(filename)
-    end
+      def basename
+        File.basename(filename)
+      end
 
     delegate :migrate, :up, :down, :announce, :say, :say_with_time, to: :migration
 
-    private
+      private
       def migration
         @migration ||= load_migration
       end
@@ -148,5 +149,5 @@ def load_migration
         load(File.expand_path(filename))
         name.constantize.new(name, version)
       end
-  end
+    end
 end