feat: Custom Features

.circleci/config.yml

@@ -7,7 +7,7 @@ defaults: &defaults
   working_directory: ~/build
   docker:
     # specify the version you desire here
-    - image: cimg/ruby:3.2.2-browsers
+    - image: cimg/ruby:3.2.4-browsers
 
     # Specify service dependencies here if necessary
     # CircleCI maintains a library of pre-built images

.devcontainer/docker-compose.yml

@@ -12,7 +12,7 @@ services:
       args:
         VARIANT: "ubuntu-22.04"
         NODE_VERSION: "20.9.0"
-        RUBY_VERSION: "3.2.2"
+        RUBY_VERSION: "3.2.4"
         # On Linux, you may need to update USER_UID and USER_GID below if not your local UID is not 1000.
         USER_UID: "1000"
         USER_GID: "1000"
@@ -25,7 +25,7 @@ services:
       args:
         VARIANT: "ubuntu-22.04"
         NODE_VERSION: "20.9.0"
-        RUBY_VERSION: "3.2.2"
+        RUBY_VERSION: "3.2.4"
         # On Linux, you may need to update USER_UID and USER_GID below if not your local UID is not 1000.
         USER_UID: "1000"
         USER_GID: "1000"

.github/workflows/deploy_check.yml

@@ -3,8 +3,9 @@
 ## deployment url will be of the form chatwoot-pr-<pr_number>.herokuapp.com
 name: Deploy Check
 
-on:
-  pull_request:
+# disable for DT
+# on:
+#   pull_request:
 
 jobs:
   deployment_check:

.github/workflows/run_foss_spec.yml

@@ -46,13 +46,23 @@ jobs:
         ref: ${{ github.event.pull_request.head.ref }}
         repository: ${{ github.event.pull_request.head.repo.full_name }}
 
+    - name: install parquet libraries
+      run: |
+        sudo apt update
+        sudo apt install -y -V ca-certificates lsb-release wget
+        wget https://apache.jfrog.io/artifactory/arrow/$(lsb_release --id --short | tr 'A-Z' 'a-z')/apache-arrow-apt-source-latest-$(lsb_release --codename --short).deb
+        sudo apt install -y -V ./apache-arrow-apt-source-latest-$(lsb_release --codename --short).deb
+        sudo apt update
+        sudo apt-get install -y  libarrow-dev libarrow-glib-dev libparquet-glib-dev libgirepository-1.0-1 libgirepository1.0-dev
+        sudo sed -i -e 's/-std=c++11//g' /usr/lib/x86_64-linux-gnu/pkgconfig/re2.pc
+
     - uses: ruby/setup-ruby@v1
       with:
         bundler-cache: true # runs 'bundle install' and caches installed gems automatically
 
     - uses: actions/setup-node@v4
       with:
-        node-version: 20
+        node-version: 21
         cache: yarn
 
     - name: yarn

.github/workflows/run_response_bot_spec.yml

@@ -44,14 +44,24 @@ jobs:
       with:
         ref: ${{ github.event.pull_request.head.ref }}
         repository: ${{ github.event.pull_request.head.repo.full_name }}
+
+    - name: install parquet libraries
+      run: |
+        sudo apt update
+        sudo apt install -y -V ca-certificates lsb-release wget
+        wget https://apache.jfrog.io/artifactory/arrow/$(lsb_release --id --short | tr 'A-Z' 'a-z')/apache-arrow-apt-source-latest-$(lsb_release --codename --short).deb
+        sudo apt install -y -V ./apache-arrow-apt-source-latest-$(lsb_release --codename --short).deb
+        sudo apt update
+        sudo apt-get install -y  libarrow-dev libarrow-glib-dev libparquet-glib-dev libgirepository-1.0-1 libgirepository1.0-dev
+        sudo sed -i -e 's/-std=c++11//g' /usr/lib/x86_64-linux-gnu/pkgconfig/re2.pc
 
     - uses: ruby/setup-ruby@v1
       with:
         bundler-cache: true # runs 'bundle install' and caches installed gems automatically
 
     - uses: actions/setup-node@v4
       with:
-        node-version: 20
+        node-version: 21
         cache: yarn
 
     - name: yarn

.ruby-version

@@ -1 +1 @@
-3.2.2
+3.2.4

Gemfile

@@ -1,6 +1,6 @@
 source 'https://rubygems.org'
 
-ruby '3.2.2'
+ruby '3.2.4'
 
 ##-- base gems for rails --##
 gem 'rack-cors', '2.0.0', require: 'rack/cors'
@@ -175,6 +175,10 @@ gem 'pgvector'
 # Convert Website HTML to Markdown
 gem 'reverse_markdown'
 
+gem 'gobject-introspection'
+gem 'red-arrow'
+gem 'red-parquet'
+
 ### Gems required only in specific deployment environments ###
 ##############################################################
 

Gemfile.lock

@@ -174,6 +174,7 @@ GEM
     crack (0.4.5)
       rexml
     crass (1.0.6)
+    csv (3.3.0)
     csv-safe (3.2.1)
     cypress-on-rails (1.16.0)
       rack
@@ -227,6 +228,7 @@ GEM
     et-orbi (1.2.7)
       tzinfo
     execjs (2.8.1)
+    extpp (0.1.1)
     facebook-messenger (2.0.1)
       httparty (~> 0.13, >= 0.13.7)
       rack (>= 1.4.5)
@@ -260,6 +262,7 @@ GEM
     ffi-compiler (1.0.1)
       ffi (>= 1.0.0)
       rake
+    fiddle (1.1.2)
     flag_shih_tzu (0.3.23)
     foreman (0.87.2)
     fugit (1.9.0)
@@ -274,11 +277,19 @@ GEM
       googleauth (~> 1.0)
       grpc (~> 1.36)
     geocoder (1.8.1)
+    gio2 (4.2.2)
+      fiddle
+      gobject-introspection (= 4.2.2)
     gli (2.21.1)
+    glib2 (4.2.2)
+      native-package-installer (>= 1.0.3)
+      pkg-config (>= 1.3.5)
     globalid (1.2.1)
       activesupport (>= 6.1)
     gmail_xoauth (0.4.3)
       oauth (>= 0.3.6)
+    gobject-introspection (4.2.2)
+      glib2 (= 4.2.2)
     google-apis-core (0.11.0)
       addressable (~> 2.5, >= 2.5.1)
       googleauth (>= 0.16.2, < 2.a)
@@ -468,6 +479,7 @@ GEM
     multi_json (1.15.0)
     multi_xml (0.6.0)
     multipart-post (2.3.0)
+    native-package-installer (1.1.9)
     neighbor (0.2.3)
       activerecord (>= 5.2)
     net-http (0.4.1)
@@ -538,6 +550,7 @@ GEM
       activerecord (>= 5.2)
       activesupport (>= 5.2)
     pgvector (0.1.1)
+    pkg-config (1.5.6)
     procore-sift (1.0.0)
       activerecord (>= 6.1)
     pry (0.14.2)
@@ -602,6 +615,15 @@ GEM
     rb-fsevent (0.11.2)
     rb-inotify (0.10.1)
       ffi (~> 1.0)
+    red-arrow (16.1.0)
+      bigdecimal (>= 3.1.0)
+      csv
+      extpp (>= 0.1.1)
+      gio2 (>= 3.5.0)
+      native-package-installer
+      pkg-config
+    red-parquet (16.1.0)
+      red-arrow (= 16.1.0)
     redis (5.0.6)
       redis-client (>= 0.9.0)
     redis-client (0.22.1)
@@ -873,6 +895,7 @@ DEPENDENCIES
   foreman
   geocoder
   gmail_xoauth
+  gobject-introspection
   google-cloud-dialogflow-v2
   google-cloud-storage
   google-cloud-translate-v3
@@ -917,6 +940,8 @@ DEPENDENCIES
   rack-mini-profiler (>= 3.2.0)
   rack-timeout
   rails (~> 7.0.8.1)
+  red-arrow
+  red-parquet
   redis
   redis-namespace
   responders (>= 3.1.1)
@@ -960,7 +985,7 @@ DEPENDENCIES
   working_hours
 
 RUBY VERSION
-   ruby 3.2.2p185
+   ruby 3.2.4p170
 
 BUNDLED WITH
-   2.4.6
+   2.5.14

app.json

@@ -3,7 +3,7 @@
   "description": "Chatwoot is a customer support tool for instant messaging channels",
   "website": "https://www.chatwoot.com/",
   "repository": "https://github.com/chatwoot/chatwoot",
-  "logo": "https://app.chatwoot.com/brand-assets/logo_thumbnail.svg",
+  "logo": "https://app.chatwoot.com/brand-assets/logo_thumbnail.png",
   "keywords": [
     "live chat",
     "customer support",

app/builders/csat_surveys/response_builder.rb

@@ -20,9 +20,26 @@ def process_csat_response(conversation, rating, feedback_message)
       message_id: message.id, account_id: message.account_id, conversation_id: message.conversation_id,
       contact_id: conversation.contact_id, assigned_agent: conversation.assignee
     )
+
+    update_message_content_attributes
+    csat_survey_response.csat_template_id = csat_template_question.csat_template_id
+    csat_survey_response.csat_template_question_id = csat_template_question.id
     csat_survey_response.rating = rating
     csat_survey_response.feedback_message = feedback_message
     csat_survey_response.save!
     csat_survey_response
   end
+
+  def csat_template_question
+    @csat_template_question ||= (message.csat_template_question || CsatTemplateQuestion.load_by_content(message.content))
+  end
+
+  def update_message_content_attributes
+    return if (attrs = message.content_attributes[:submitted_values]).blank?
+
+    attrs['csat_template_question_id'] = csat_template_question&.id
+    # rubocop:disable Rails/SkipsModelValidations
+    message.update_column(:content_attributes, attrs)
+    # rubocop:enable Rails/SkipsModelValidations
+  end
 end

app/builders/notification_builder.rb

@@ -17,6 +17,7 @@ def user_subscribed_to_notification?
     return false if notification_setting.blank?
 
     return true if notification_setting.public_send("email_#{notification_type}?")
+    return false unless primary_actor.inbox.push_notification_enabled?
     return true if notification_setting.public_send("push_#{notification_type}?")
 
     false

app/builders/smart_action_builder.rb

@@ -0,0 +1,46 @@
+class SmartActionBuilder
+  attr_accessor :errors
+
+  def initialize(conversation, params)
+    @conversation = conversation
+    @params = params
+    @errors = []
+  end
+
+  def perform
+    validate_params
+    return if @errors.present?
+
+    build_smart_action
+  rescue StandardError => e
+    @errors << e.message
+    nil
+  end
+
+  private
+
+  def validate_params
+    return if @params.present?
+
+    @errors << 'Missing parameters'
+  end
+
+  def build_smart_action
+    @smart_action = @conversation.smart_actions.create(smart_action_params)
+  end
+
+  def smart_action_params
+    @params.permit(
+      :name,
+      :label,
+      :description,
+      :event,
+      :intent_type,
+      :message_id,
+      :to,
+      :from,
+      :link,
+      :content
+    )
+  end
+end

app/controllers/api/v1/accounts/agents_controller.rb

@@ -20,11 +20,13 @@ def create
     )
 
     @agent = builder.perform
+    update_teams_and_inboxes
   end
 
   def update
     @agent.update!(agent_params.slice(:name).compact)
     @agent.current_account_user.update!(agent_params.slice(:role, :availability, :auto_offline).compact)
+    update_teams_and_inboxes
   end
 
   def destroy
@@ -59,6 +61,11 @@ def bulk_create
 
   private
 
+  def update_teams_and_inboxes
+    @agent.teams = Team.where(id: team_ids) if team_ids.present?
+    @agent.inboxes = Inbox.where(id: inbox_ids) if inbox_ids.present?
+  end
+
   def check_authorization
     super(User)
   end
@@ -75,6 +82,14 @@ def new_agent_params
     params.require(:agent).permit(:email, :name, :role, :availability, :auto_offline)
   end
 
+  def team_ids
+    params[:team_ids] || []
+  end
+
+  def inbox_ids
+    params[:inbox_ids] || []
+  end
+
   def agents
     @agents ||= Current.account.users.order_by_full_name.includes(:account_users, { avatar_attachment: [:blob] })
   end

app/controllers/api/v1/accounts/articles_controller.rb

@@ -7,8 +7,9 @@ class Api::V1::Accounts::ArticlesController < Api::V1::Accounts::BaseController
   def index
     @portal_articles = @portal.articles
     @all_articles = @portal_articles.search(list_params)
-    @articles_count = @all_articles.count
+    @all_articles = @all_articles.published unless Current.user.administrator?
 
+    @articles_count = @all_articles.count
     @articles = if list_params[:category_slug].present?
                   @all_articles.order_by_position.page(@current_page)
                 else

app/controllers/api/v1/accounts/contacts_controller.rb

@@ -12,9 +12,9 @@ class Api::V1::Accounts::ContactsController < Api::V1::Accounts::BaseController
   RESULTS_PER_PAGE = 15
 
   before_action :check_authorization
-  before_action :set_current_page, only: [:index, :active, :search, :filter]
+  before_action :set_current_page, only: [:index, :active, :search, :filter, :phone_search, :email_search]
   before_action :fetch_contact, only: [:show, :update, :destroy, :avatar, :contactable_inboxes, :destroy_custom_attributes]
-  before_action :set_include_contact_inboxes, only: [:index, :search, :filter]
+  before_action :set_include_contact_inboxes, only: [:index, :search, :filter, :phone_search, :email_search]
 
   def index
     @contacts_count = resolved_contacts.count
@@ -33,6 +33,21 @@ def search
     @contacts = fetch_contacts(contacts)
   end
 
+  def phone_search
+    render json: { error: 'Specify search string with parameter q' }, status: :unprocessable_entity if params[:q].blank? && return
+
+    contacts = resolved_contacts.where(phone_number: params[:q].strip)
+    render json: { found: contacts.exists?, search_key: params[:q] }
+  end
+
+  def email_search
+    render json: { error: 'Specify search string with parameter q' }, status: :unprocessable_entity if params[:q].blank? && return
+
+    contacts = resolved_contacts.where(email: params[:q].strip)
+    @contacts_count = contacts.count
+    @contacts = fetch_contacts(contacts)
+  end
+
   def import
     render json: { error: I18n.t('errors.contacts.import.failed') }, status: :unprocessable_entity and return if params[:import_file].blank?