Adding webhooks stuff

Author: cjavdev

Gemfile

@@ -64,3 +64,4 @@ gem "stimulus-rails", "~> 0.6.0"
 gem "tailwindcss-rails", "~> 0.4.3"
 gem 'image_processing', '~> 1.2'
 gem 'stripe'
+gem 'resque'

Gemfile.lock

@@ -137,10 +137,13 @@ GEM
     mini_mime (1.1.2)
     mini_portile2 (2.6.1)
     minitest (5.14.4)
+    mono_logger (1.1.1)
     msgpack (1.4.2)
     multi_json (1.15.0)
     multi_xml (0.6.0)
     multipart-post (2.1.1)
+    mustermann (1.1.1)
+      ruby2_keywords (~> 0.0.1)
     nio4r (2.5.8)
     nokogiri (1.12.5)
       mini_portile2 (~> 2.6.1)
@@ -217,9 +220,18 @@ GEM
     rb-fsevent (0.11.0)
     rb-inotify (0.10.1)
       ffi (~> 1.0)
+    redis (4.5.1)
+    redis-namespace (1.8.1)
+      redis (>= 3.0.4)
     responders (3.0.1)
       actionpack (>= 5.0)
       railties (>= 5.0)
+    resque (2.2.0)
+      mono_logger (~> 1.0)
+      multi_json (~> 1.0)
+      redis-namespace (~> 1.6)
+      sinatra (>= 0.9.2)
+      vegas (~> 0.1.2)
     ruby-vips (2.1.4)
       ffi (~> 1.12)
     ruby2_keywords (0.0.5)
@@ -234,6 +246,11 @@ GEM
       sprockets-rails
       tilt
     semantic_range (3.0.0)
+    sinatra (2.1.0)
+      mustermann (~> 1.0)
+      rack (~> 2.2)
+      rack-protection (= 2.1.0)
+      tilt (~> 2.0)
     spring (3.0.0)
     sprockets (4.0.2)
       concurrent-ruby (~> 1.0)
@@ -254,6 +271,8 @@ GEM
     turbolinks-source (5.2.0)
     tzinfo (2.0.4)
       concurrent-ruby (~> 1.0)
+    vegas (0.1.11)
+      rack (>= 1.0.0)
     warden (1.2.9)
       rack (>= 2.0.9)
     web-console (4.1.0)
@@ -291,6 +310,7 @@ DEPENDENCIES
   puma (~> 5.0)
   rack-mini-profiler (~> 2.0)
   rails (~> 7.0.0.alpha2)
+  resque
   sass-rails (>= 6)
   spring
   stimulus-rails (~> 0.6.0)

Rakefile

@@ -2,5 +2,6 @@
 # for example lib/tasks/capistrano.rake, and they will automatically be available to Rake.
 
 require_relative "config/application"
+require 'resque/tasks'
 
 Rails.application.load_tasks

app/controllers/reservations_controller.rb

@@ -4,6 +4,16 @@ class ReservationsController < ApplicationController
   def index
   end
 
+  def cancel
+    @reservation = current_user.reservations.find(params[:id])
+    # make api call to refund payment
+    refund = Stripe::Refund.create({
+      payment_intent: @reservation.stripe_payment_intent_id,
+    })
+    @reservation.update(status: :canceling, stripe_refund_id: refund.id)
+    redirect_to reservation_path(@reservation)
+  end
+
   def create
     @reservation = current_user.reservations.new(reservation_params)
     if @reservation.save
@@ -47,7 +57,7 @@ def create
   end
 
   def show
-
+    @reservation = current_user.reservations.find(params[:id])
   end
 
   private

app/controllers/webhooks_controller.rb

@@ -0,0 +1,12 @@
+class WebhooksController < ApplicationController
+  skip_before_action :verify_authenticity_token
+
+  def create
+    event = Event.create!(
+      request_body: request.raw_post,
+      source: params[:source],
+    )
+    EventJob.perform_later(event)
+    render json: { message: "success" }
+  end
+end

app/helpers/webhooks_helper.rb

@@ -0,0 +1,2 @@
+module WebhooksHelper
+end

app/jobs/event_job.rb

@@ -0,0 +1,50 @@
+class EventJob < ApplicationJob
+  queue_as :default
+
+  def perform(event)
+    case event.source
+    when "stripe"
+      stripe_event = Stripe::Event.construct_from(
+        JSON.parse(event.request_body, symbolize_names: true)
+      )
+      begin
+        handle_stripe(stripe_event)
+        event.update(
+          event_type: stripe_event.type,
+          error_message: '',
+          status: :processed
+        )
+      rescue => e
+        event.update(
+          error_message: e.message,
+          status: :failed
+        )
+      end
+    else
+      event.update(
+        error_message: "Unknown source #{event.source}",
+        status: :failed
+      )
+    end
+  end
+
+  def handle_stripe(event)
+    case event.type
+    when "checkout.session.completed"
+      # do something with the checkout session and the reservation here.
+      checkout_session = event.data.object
+      reservation = Reservation.find_by(session_id: checkout_session.id)
+      if reservation.nil?
+        raise "No reservation found with Checkout Session ID #{checkout_session.id}"
+      end
+      reservation.update(status: :booked, stripe_payment_intent_id: checkout_session.payment_intent)
+    when "charge.refunded"
+      charge = event.data.object
+      reservation = Reservation.find_by(stripe_payment_intent_id: charge.payment_intent)
+      if reservation.nil?
+        raise "No reservation found with Payment Intent ID #{charge.payment_intent}"
+      end
+      reservation.update(status: :cancelled)
+    end
+  end
+end

app/models/event.rb

@@ -0,0 +1,16 @@
+# == Schema Information
+#
+# Table name: events
+#
+#  id            :bigint           not null, primary key
+#  request_body  :text
+#  status        :integer          default("pending")
+#  error_message :text
+#  source        :string
+#  event_type    :string
+#  created_at    :datetime         not null
+#  updated_at    :datetime         not null
+#
+class Event < ApplicationRecord
+  enum status: {pending: 0, processed: 1, failed: 2}
+end

app/models/reservation.rb

@@ -2,16 +2,17 @@
 #
 # Table name: reservations
 #
-#  id         :bigint           not null, primary key
-#  listing_id :bigint           not null
-#  guest_id   :bigint           not null
-#  session_id :string
-#  status     :integer          default(0)
-#  created_at :datetime         not null
-#  updated_at :datetime         not null
+#  id                       :bigint           not null, primary key
+#  listing_id               :bigint           not null
+#  guest_id                 :bigint           not null
+#  session_id               :string
+#  status                   :integer          default("pending")
+#  created_at               :datetime         not null
+#  updated_at               :datetime         not null
+#  stripe_payment_intent_id :string
 #
 class Reservation < ApplicationRecord
   belongs_to :listing
   belongs_to :guest, class_name: 'User'
-  enum status: {pending: 0, booked: 1, cancelled: 2}
+  enum status: {pending: 0, booked: 1, canceling: 3, cancelled: 2}
 end

app/views/reservations/show.html.erb

@@ -1,2 +1,8 @@
-<h1>Reservations#show</h1>
-<p>Find me in app/views/reservations/show.html.erb</p>
+<h1 class="text-2xl mb-4 font-bold"><%= @reservation.listing.title %></h1>
+
+<pre><%= JSON.pretty_generate(@reservation.as_json) %></pre>
+
+<form action="<%= cancel_reservation_path(@reservation) %>" method="post">
+  <input type="hidden" name="authenticity_token" value="<%= form_authenticity_token %>">
+  <input type="submit" value="Cancel">
+</form>

config/application.rb

@@ -12,6 +12,7 @@ class Application < Rails::Application
     config.load_defaults 6.1
 
     Rails.application.default_url_options = { host: 'localhost', port: 3000 }
+    config.active_job.queue_adapter = :resque
 
     # Configuration for the application, engines, and railties goes here.
     #

config/routes.rb

@@ -1,8 +1,14 @@
+require 'resque/server'
 Rails.application.routes.draw do
   root to: 'static_pages#home'
 
   resources :listings, only: [:index, :show]
-  resources :reservations
+  resources :reservations do
+    member do
+      post '/cancel' => 'reservations#cancel'
+    end
+  end
+  post '/webhooks/:source' => 'webhooks#create'
 
   namespace :host do
     resources :listings do
@@ -12,4 +18,12 @@
   end
 
   devise_for :users, controllers: { omniauth_callbacks: 'users/omniauth_callbacks' }
+
+  resque_web_constraint = lambda do |request|
+    current_user = request.env['warden'].user
+    current_user.id == 1
+  end
+  constraints resque_web_constraint do
+    mount Resque::Server, at: '/jobs'
+  end
 end

db/migrate/20211127010215_create_events.rb

@@ -0,0 +1,13 @@
+class CreateEvents < ActiveRecord::Migration[7.0]
+  def change
+    create_table :events do |t|
+      t.text :request_body
+      t.integer :status, default: 0
+      t.text :error_message
+      t.string :source
+      t.string :event_type
+
+      t.timestamps
+    end
+  end
+end

db/migrate/20211127012331_add_stripe_payment_intent_id_to_reservations.rb

@@ -0,0 +1,5 @@
+class AddStripePaymentIntentIdToReservations < ActiveRecord::Migration[7.0]
+  def change
+    add_column :reservations, :stripe_payment_intent_id, :string
+  end
+end

db/migrate/20211127013735_add_stripe_refund_id_to_reservations.rb

@@ -0,0 +1,5 @@
+class AddStripeRefundIdToReservations < ActiveRecord::Migration[7.0]
+  def change
+    add_column :reservations, :stripe_refund_id, :string
+  end
+end

db/schema.rb

@@ -0,0 +1,7 @@
+require "test_helper"
+
+class WebhooksControllerTest < ActionDispatch::IntegrationTest
+  # test "the truth" do
+  #   assert true
+  # end
+end

test/controllers/webhooks_controller_test.rb

@@ -0,0 +1,27 @@
+# == Schema Information
+#
+# Table name: events
+#
+#  id            :bigint           not null, primary key
+#  request_body  :text
+#  status        :integer          default("pending")
+#  error_message :text
+#  source        :string
+#  event_type    :string
+#  created_at    :datetime         not null
+#  updated_at    :datetime         not null
+#
+
+one:
+  request_body: MyText
+  status: 1
+  error_message: MyText
+  source: MyString
+  event_type: MyString
+
+two:
+  request_body: MyText
+  status: 1
+  error_message: MyText
+  source: MyString
+  event_type: MyString

test/fixtures/events.yml

@@ -2,13 +2,14 @@
 #
 # Table name: reservations
 #
-#  id         :bigint           not null, primary key
-#  listing_id :bigint           not null
-#  guest_id   :bigint           not null
-#  session_id :string
-#  status     :integer          default(0)
-#  created_at :datetime         not null
-#  updated_at :datetime         not null
+#  id                       :bigint           not null, primary key
+#  listing_id               :bigint           not null
+#  guest_id                 :bigint           not null
+#  session_id               :string
+#  status                   :integer          default("pending")
+#  created_at               :datetime         not null
+#  updated_at               :datetime         not null
+#  stripe_payment_intent_id :string
 #
 
 one:

test/fixtures/reservations.yml

@@ -0,0 +1,7 @@
+require "test_helper"
+
+class EventJobTest < ActiveJob::TestCase
+  # test "the truth" do
+  #   assert true
+  # end
+end