Add locations to IRIS index (#128)

* Add locations to IRIS index

closes railslove/recover-backlog#128

* add proxy configuration for rest-client

* move jimson gem to use on production

* start processes using tunnel

* Revert "start processes using tunnel"

This reverts commit 1a688ed.

Co-authored-by: salimhb <[email protected]>
Co-authored-by: salimhb <[email protected]>

Author: bitboxer

.env

@@ -19,3 +19,4 @@ DEVISE_JWT_SECRET_KEY=9dde7c3cebc4c85e91a6f6e520b683396cd4f0d218671f4f2a398f2b6f
 # STRIPE_TAX_RATE_ID=
 #
 # FRONTEND_URL=
+# IRIS_EPS_URL=

.env.test

@@ -1,2 +1,3 @@
 STRIPE_SUBSCRIPTION_PRICE_ID=test_price
-HAPPY_PDF_API_KEY=HAPPY_KEY
+HAPPY_PDF_API_KEY=HAPPY_KEY
+IRIS_EPS_URL=https://localhost:5556/jsonrpc

Gemfile

@@ -22,6 +22,7 @@ gem 'activestorage-validator'
 gem 'image_processing'
 gem 'paper_trail'
 gem 'protobuf'
+gem 'jimson'
 
 # Emails
 gem 'mailgun-ruby', '~> 1.2'

Gemfile.lock

@@ -93,6 +93,7 @@ GEM
     aws-sigv4 (1.2.3)
       aws-eventstream (~> 1, >= 1.0.2)
     bcrypt (3.1.16)
+    blankslate (3.1.3)
     bootsnap (1.7.5)
       msgpack (~> 1.0)
     builder (3.2.4)
@@ -181,6 +182,11 @@ GEM
     interactor-rails (2.2.1)
       interactor (~> 3.0)
       rails (>= 4.2)
+    jimson (0.13.0)
+      blankslate (>= 3.1.3)
+      multi_json (>= 1.11.2)
+      rack (>= 1.4.5)
+      rest-client (>= 1.7.3)
     jmespath (1.4.0)
     jquery-rails (4.4.0)
       rails-dom-testing (>= 1, < 3)
@@ -226,6 +232,7 @@ GEM
     mini_portile2 (2.5.1)
     minitest (5.14.4)
     msgpack (1.4.2)
+    multi_json (1.15.0)
     multi_xml (0.6.0)
     multipart-post (2.1.1)
     nested_form (0.3.2)
@@ -423,6 +430,7 @@ DEPENDENCIES
   image_processing
   inky-rb
   interactor-rails
+  jimson
   letter_opener
   listen (~> 3.5)
   mailgun-ruby (~> 1.2)

app/jobs/iris_delete_company.rb

@@ -0,0 +1,12 @@
+class IrisDeleteCompany < ApplicationJob
+  queue_as :default
+
+  def perform(company_id)
+    return if ENV["IRIS_EPS_URL"].blank?
+    Jimson::Client.new(
+      ENV["IRIS_EPS_URL"], {id_type: :string}, "ls-1.", {verify_ssl: false}
+    ).deleteLocationFromSearchIndex({
+      locationId: company_id
+    })
+  end
+end

app/jobs/iris_update_company.rb

@@ -0,0 +1,32 @@
+class IrisUpdateCompany < ApplicationJob
+  queue_as :default
+
+  def perform(company_id)
+    return if ENV["IRIS_EPS_URL"].blank?
+
+    company = Company.find(company_id)
+    return unless company
+
+    Jimson::Client.new(
+      ENV["IRIS_EPS_URL"], {id_type: :string}, "ls-1.", {verify_ssl: false}
+    ).postLocationsToSearchIndex({
+      locations: [
+        {
+          id: company.id, 
+          name: company.name, 
+          contact: {
+            officalName: company.name, 
+            representative: company.owner.name, 
+            address: {
+              street: company.street, 
+              city: company.city, 
+              zip: company.zip
+            }, 
+            email: company.owner.email,
+            phone: company.owner.phone
+          }
+        }
+      ]
+    })
+  end
+end

app/models/company.rb

@@ -56,6 +56,14 @@ class Company < ApplicationRecord
     menu_pdf.purge if remove_menu_pdf == '1' and menu_pdf.attached?
   }
 
+  after_commit(on: [:create, :update]) {
+    IrisUpdateCompany.perform_later(self.id)
+  }
+
+  after_commit(on: [:destroy]) {
+    IrisDeleteCompany.perform_later(self.id)
+  }
+
   def menu_pdf_link
     return unless menu_pdf.attached?
 

config/initializers/rest-client.rb

@@ -0,0 +1,3 @@
+require "rest-client"
+
+RestClient.proxy = ENV["QUOTAGUARDSTATIC_URL"] if ENV["QUOTAGUARDSTATIC_URL"].present?

spec/jobs/iris_delete_company_spec.rb

@@ -0,0 +1,12 @@
+require 'rails_helper'
+
+RSpec.describe IrisDeleteCompany, type: :job do
+
+  it "should send a delete request via JSON-RPC" do
+    company = FactoryBot.create(:company)
+    expect_any_instance_of(Jimson::ClientHelper).to receive(:process_call).with(:deleteLocationFromSearchIndex, {
+      locationId: company.id
+    })
+    IrisDeleteCompany.perform_now(company.id)
+  end
+end

spec/jobs/iris_update_company_spec.rb

@@ -0,0 +1,29 @@
+
+require 'rails_helper'
+
+RSpec.describe IrisUpdateCompany, type: :job do
+
+  it "should send a update request via JSON-RPC" do
+    company = FactoryBot.create(:company)
+    expect_any_instance_of(Jimson::ClientHelper).to receive(:process_call).with(:postLocationsToSearchIndex, {
+      locations: [
+        {
+          id: company.id, 
+          name: company.name, 
+          contact: {
+            officalName: company.name, 
+            representative: company.owner.name, 
+            address: {
+              street: company.street, 
+              city: company.city, 
+              zip: company.zip
+            }, 
+            email: company.owner.email,
+            phone: company.owner.phone
+          }
+        }
+      ]
+    })
+    IrisUpdateCompany.perform_now(company.id)
+  end
+end