WIP in-model serialization

app/models/property.rb

@@ -7,9 +7,11 @@ class Property < ApplicationRecord
   scope :extended, -> { where.not(base_friendly_id: nil) }
 
   has_many :categories_properties, dependent: :destroy, foreign_key: :property_friendly_id, primary_key: :friendly_id
+
   has_many :categories, through: :categories_properties
 
   has_many :properties_property_values, dependent: :destroy
+
   has_many :property_values, through: :properties_property_values, foreign_key: :property_value_friendly_id
 
   belongs_to :base_property,
@@ -23,15 +25,52 @@ class Property < ApplicationRecord
     foreign_key: :base_friendly_id,
     primary_key: :friendly_id
 
-  def property_value_friendly_ids=(ids)
-    self.property_values = PropertyValue.where(friendly_id: ids)
-  end
-
   validates :name, presence: true
   validates :friendly_id, presence: true, uniqueness: true
   validates :handle, presence: true
   validate :property_values_match_base, if: :extended?
 
+  class << self
+    def new_from_data(data)
+      new(row_from_data(data))
+    end
+
+    def insert_all_from_data(data)
+      insert_all(Array(data).map { row_from_data(_1) })
+    end
+
+    def as_json(properties, version:)
+      {
+        "version" => version,
+        "attributes" => properties.map(&:as_json),
+      }
+    end
+
+    def as_txt(properties, version:)
+      header = <<~HEADER
+        # Shopify Product Taxonomy - Attributes: #{version}
+        # Format: {GID} : {Attribute name}
+      HEADER
+      padding = reorder("LENGTH(id) desc").first.gid.size
+      [
+        header,
+        *properties.map { _1.as_txt(padding:) },
+      ].join("\n")
+    end
+
+    private
+
+    def row_from_data(data)
+      {
+        "id" => data["id"],
+        "friendly_id" => data["friendly_id"],
+        "name" => data["name"],
+        "handle" => data["handle"],
+        "base_friendly_id" => data["values_from"],
+      }
+    end
+  end
+
   def gid
     if extended?
       base_property.gid
@@ -48,6 +87,45 @@ def extended?
     !base?
   end
 
+  def property_value_friendly_ids=(friendly_id)
+    self.property_values = PropertyValue.where(friendly_id:)
+  end
+
+  def as_json_for_data
+    {
+      "id" => id,
+      "name" => name,
+      "friendly_id" => friendly_id,
+      "handle" => handle,
+      "values" => property_values.reorder(:id).map(&:as_json_for_data),
+    }
+  end
+
+  def as_json
+    {
+      "id" => gid,
+      "name" => name,
+      "handle" => handle,
+      "extended_attributes" => extended_properties.map do
+        {
+          "name" => _1.name,
+          "handle" => _1.handle,
+        }
+      end,
+      "values" => property_values.map do
+        {
+          "id" => _1.gid,
+          "name" => _1.name,
+          "handle" => _1.handle,
+        }
+      end,
+    }
+  end
+
+  def as_txt(padding: 0)
+    "#{gid.ljust(padding)} : #{name}"
+  end
+
   private
 
   def property_values_match_base

app/models/property_value.rb

@@ -8,21 +8,59 @@ class PropertyValue < ApplicationRecord
     foreign_key: :property_value_friendly_id,
     primary_key: :friendly_id,
     inverse_of: :property_value
+
   has_many :properties, through: :properties_property_values
 
   belongs_to :primary_property,
     class_name: "Property",
     foreign_key: :primary_property_friendly_id,
     primary_key: :friendly_id
 
-  def primary_property_friendly_id=(friendly_id)
-    self.primary_property = Property.find_by(friendly_id:)
-  end
-
   validates :name, presence: true
   validates :friendly_id, presence: true, uniqueness: true
   validates :handle, presence: true, uniqueness: { scope: :primary_property_friendly_id }
 
+  class << self
+    def new_from_data(data)
+      new(row_from_data(data))
+    end
+
+    def insert_all_from_data(data)
+      insert_all(Array(data).map { row_from_data(_1) })
+    end
+
+    def as_json(property_values, version:)
+      {
+        "version" => version,
+        "values" => property_values.map(&:as_json),
+      }
+    end
+
+    def as_txt(property_values, version:)
+      header = <<~HEADER
+        # Shopify Product Taxonomy - Attribute Values: #{version}
+        # Format: {GID} : {Value name} [{Attribute name}]
+      HEADER
+      padding = reorder("LENGTH(id) desc").first.gid.size
+      [
+        header,
+        *property_values.map { _1.as_txt(padding: padding) },
+      ].join("\n")
+    end
+
+    private
+
+    def row_from_data(data)
+      {
+        "id" => data["id"],
+        "name" => data["name"],
+        "handle" => data["handle"],
+        "friendly_id" => data["friendly_id"],
+        "primary_property_friendly_id" => data["friendly_id"].split("__").first,
+      }
+    end
+  end
+
   def gid
     "gid://shopify/TaxonomyValue/#{id}"
   end
@@ -34,4 +72,29 @@ def full_name
       name
     end
   end
+
+  def primary_property_friendly_id=(friendly_id)
+    self.primary_property = Property.find_by(friendly_id:)
+  end
+
+  def as_json_for_data
+    {
+      "id" => id,
+      "name" => name,
+      "friendly_id" => friendly_id,
+      "handle" => handle,
+    }
+  end
+
+  def as_json
+    {
+      "id" => gid,
+      "name" => name,
+      "handle" => handle,
+    }
+  end
+
+  def as_txt(padding: 0)
+    "#{gid.ljust(padding)} : #{full_name}"
+  end
 end

app/serializers/distribution/category_serializer.rb

@@ -10,7 +10,14 @@ def as_json(category)
           "name" => category.name,
           "full_name" => category.full_name,
           "parent_id" => category.parent&.gid,
-          "attributes" => category.properties.map { PropertySerializer.as_simple_json(_1) },
+          "attributes" => category.properties.map do
+            {
+              "id" => _1.gid,
+              "name" => _1.name,
+              "handle" => _1.handle,
+              "extended" => _1.extended?,
+            }
+          end,
           "children" => category.children.map { as_simple_json(_1) },
           "ancestors" => category.ancestors.map { as_simple_json(_1) },
         }