apneadiving

# User model 
class User < ActiveRecord::Base
  has_many :invitations
end
# Invitation Model
class Invitation < ActiveRecord::Base
  belongs_to :inviter, class_name: 'User'
  def accept
    self.accepted = true
  end

apneadiving

def accept_invitation
  Wf.new
    .chain(user: :user) { AcceptInvitation.new(invitation).call }
    .chain {|outflow| render json: { user: outflow.user } }
    .on_dam do |error_pool|
      render json: { errors: error_pool.full_messages }, status: 422
    end
end

apneadiving

# controller
def accept_invitation
  if invitation.accepted?
    render json: { errors: ['Invitation already accepted'] }, status: 422
  else
    user = User.build_from_invitation(invitation)
    user.save!
    invitation.accept
    invitation.save!
    UserMailer.notify_affiliate_payment(invitation).deliver_later

apneadiving

require 'rubygems'
require 'monadic'

class MonadicService
  def initialize(user_id)
    @user_id = user_id
  end

  def call
    response = HTTParty.get("https://jsonplaceholder.typicode.com/users/#{@user_id}")

apneadiving

class CreateInvoiceNumbers < ActiveRecord::Migration
  def up
    create_table :invoice_numbers do |t|
      t.integer :year, null: false, unique: true
      t.integer :next_number_within_year, null: false, default: 1
    end

    add_index :invoice_numbers, :year, unique: true

    (2016..2045).each do |year|

apneadiving

-- Create tables
CREATE TABLE groups (id serial NOT NULL, name character varying NOT NULL);
CREATE TABLE network_group_members (pid integer, cid integer NOT NULL);

-- Insert the groups
INSERT INTO groups (name) VALUES ('GROUP 1'),('GROUP 2'),('GROUP 3'),('GROUP 4'),('GROUP 5'),('GROUP 6'),('GROUP 7'),('GROUP 8'),('GROUP 9'),('GROUP 10'),('GROUP 11'),('GROUP 12'),('GROUP 13');
-- Build the "Network"
INSERT INTO network_group_members(pid,cid) VALUES (1,2),(1,3),(1,4),(2,5),(5,6),(5,7),(7,8),(3,9),(4,10),(4,11),(11,12),(12,13);

apneadiving

require 'spec_helper'

describe 'thread safe tenants' do
  let(:db_names) { [db1, db2] }

  before do
    Apartment.configure do |config|
      config.excluded_models = ["Company"]
      config.tenant_names = lambda{ Company.pluck(:database) }
      config.use_schemas = false

apneadiving

def trace_calls_on
  scope = {}
  trace = TracePoint.new(:call, :line) do |tp|
    case tp.event
    when :call then puts "#{tp.path}:#{tp.lineno} #{tp.defined_class}::#{tp.method_id} " \
                         "called from #{scope[:path]}:#{scope[:lineno]} #{scope[:class]}::#{scope[:method_id]}"
    when :line then scope = {
                      event: :line,
                      lineno: tp.lineno,
                      path: tp.path,

apneadiving

class Author::Work < AR::Base
  scope :with_text,   -> { where.not(text: nil) }
  scope :started,     -> { where(status: 0) }
  scope :in_progress, -> { started.with_text  }
end

apneadiving

class FormObjectBase
 include ::ActiveModel::Validations

 attr_reader :object, :params

 def initialize(object)
   @object = object
 end

 def assign(params)