repo.rb

require 'bundler'
Bundler.setup

require 'sequel'

DB = Sequel.connect('sqlite::memory')

DB.create_table(:users) do
  primary_key(:id)
  String :name, null: false
  String :data, null: false
end

require 'rom'
require 'rom-repository'

require 'json'
require 'rom-sql'

EncodeJSON = ROM::SQL::Types::String.constructor { |x| JSON.generate(x) }
DecodeJSON = ROM::SQL::Types::Hash.constructor do |value|
  case value
    when String then
      JSON.parse(value)
    else
      value
  end
end

rom = ROM.container(:sql, DB) { |config|
  config.relation(:users) {
    schema(:users, infer: true) {
      attribute :data, EncodeJSON.meta(read: DecodeJSON)

      config.commands(:users) {
        define(:create) {
          result(:one)
        }
      }
    }

  }
}


class UserRepo < ROM::Repository[:users]
  def find(id)
    users.where(id: id).one!
  end
end

users = UserRepo.new(rom)

puts user = rom.command(:users).create[name: 'Hello World', data: {username: 'kwando'}]
puts rom.relation(:users).where(id: user.fetch(:id))

puts users.find(user.fetch(:id)).data.inspect