From 6515b6956010de35602c5087e59732c7a25fa69b Mon Sep 17 00:00:00 2001
From: Muhsin Keloth <muhsinkeramam@gmail.com>
Date: Mon, 23 Aug 2021 22:00:47 +0530
Subject: [PATCH] feat: CSAT for all channels (#2749)

---
 .../dashboard/settings/inbox/Settings.vue     |   4 +-
 app/javascript/survey/api/endPoints.js        |  13 ++
 .../survey/api/specs/endPoints.spec.js        |  38 ++++
 app/javascript/survey/api/survey.js           |  15 ++
 app/javascript/survey/assets/scss/woot.scss   |   1 +
 app/javascript/survey/components/Banner.vue   |  31 ++++
 app/javascript/survey/components/Feedback.vue |  54 ++++++
 app/javascript/survey/components/Rating.vue   |  23 +--
 app/javascript/survey/helpers/axios.js        |   6 +
 app/javascript/survey/i18n/locale/en.json     |   4 +
 app/javascript/survey/views/Response.vue      | 174 +++++++++++++++---
 app/listeners/agent_bot_listener.rb           |   4 +-
 app/listeners/hook_listener.rb                |   4 +-
 app/listeners/webhook_listener.rb             |   4 +-
 app/mailers/conversation_reply_mailer.rb      |   7 +-
 app/models/concerns/message_filter_helpers.rb |  19 ++
 app/models/conversation.rb                    |   4 +
 app/models/message.rb                         |  19 +-
 .../hook_execution_service.rb                 |  13 +-
 config/locales/en.yml                         |   2 +
 .../dialogflow/processor_service.rb           |   1 +
 package.json                                  |   3 +-
 .../hook_execution_service_spec.rb            |   7 +-
 23 files changed, 382 insertions(+), 68 deletions(-)
 create mode 100644 app/javascript/survey/api/endPoints.js
 create mode 100644 app/javascript/survey/api/specs/endPoints.spec.js
 create mode 100644 app/javascript/survey/api/survey.js
 create mode 100644 app/javascript/survey/components/Banner.vue
 create mode 100644 app/javascript/survey/components/Feedback.vue
 create mode 100644 app/javascript/survey/helpers/axios.js
 create mode 100644 app/models/concerns/message_filter_helpers.rb

diff --git a/app/javascript/dashboard/routes/dashboard/settings/inbox/Settings.vue b/app/javascript/dashboard/routes/dashboard/settings/inbox/Settings.vue
index 86ce81978..7cddf006b 100644
--- a/app/javascript/dashboard/routes/dashboard/settings/inbox/Settings.vue
+++ b/app/javascript/dashboard/routes/dashboard/settings/inbox/Settings.vue
@@ -170,7 +170,7 @@
           </p>
         </label>
 
-        <label v-if="isAWebWidgetInbox" class="medium-9 columns">
+        <label class="medium-9 columns">
           {{ $t('INBOX_MGMT.SETTINGS_POPUP.ENABLE_CSAT') }}
           <select v-model="csatSurveyEnabled">
             <option :value="true">
@@ -416,7 +416,7 @@ export default {
         return this.$t('INBOX_MGMT.ADD.WEBSITE_NAME.PLACEHOLDER');
       }
       return this.$t('INBOX_MGMT.ADD.CHANNEL_NAME.PLACEHOLDER');
-    },
+    }
   },
   watch: {
     $route(to) {
diff --git a/app/javascript/survey/api/endPoints.js b/app/javascript/survey/api/endPoints.js
new file mode 100644
index 000000000..a9b9936fd
--- /dev/null
+++ b/app/javascript/survey/api/endPoints.js
@@ -0,0 +1,13 @@
+const updateSurvey = ({ uuid, data }) => ({
+  url: `/public/api/v1/csat_survey/${uuid}`,
+  data,
+});
+
+const getSurvey = ({ uuid }) => ({
+  url: `/public/api/v1/csat_survey/${uuid}`,
+});
+
+export default {
+  getSurvey,
+  updateSurvey,
+};
diff --git a/app/javascript/survey/api/specs/endPoints.spec.js b/app/javascript/survey/api/specs/endPoints.spec.js
new file mode 100644
index 000000000..8633f677f
--- /dev/null
+++ b/app/javascript/survey/api/specs/endPoints.spec.js
@@ -0,0 +1,38 @@
+import endPoints from '../endPoints';
+const uuid = '98c5d7f3-8873-4262-b101-d56425ff7ee1';
+
+describe('#getSurvey', () => {
+  it('should returns correct payload', () => {
+    expect(
+      endPoints.getSurvey({
+        uuid,
+      })
+    ).toEqual({
+      url: `/public/api/v1/csat_survey/98c5d7f3-8873-4262-b101-d56425ff7ee1`,
+    });
+  });
+});
+
+describe('#updateSurvey', () => {
+  it('should returns correct payload', () => {
+    const data = {
+      message: {
+        submitted_values: {
+          csat_survey_response: {
+            rating: 4,
+            feedback_message: 'amazing',
+          },
+        },
+      },
+    };
+    expect(
+      endPoints.updateSurvey({
+        uuid,
+        data,
+      })
+    ).toEqual({
+      url: `/public/api/v1/csat_survey/98c5d7f3-8873-4262-b101-d56425ff7ee1`,
+      data,
+    });
+  });
+});
diff --git a/app/javascript/survey/api/survey.js b/app/javascript/survey/api/survey.js
new file mode 100644
index 000000000..46fa6ec7f
--- /dev/null
+++ b/app/javascript/survey/api/survey.js
@@ -0,0 +1,15 @@
+import endPoints from 'survey/api/endPoints';
+import { API } from 'survey/helpers/axios';
+
+const getSurveyDetails = async ({ uuid }) => {
+  const urlData = endPoints.getSurvey({ uuid });
+  const result = await API.get(urlData.url, { params: urlData.params });
+  return result;
+};
+
+const updateSurvey = async ({ uuid, data }) => {
+  const urlData = endPoints.updateSurvey({ data, uuid });
+  await API.put(urlData.url, { ...urlData.data });
+};
+
+export { getSurveyDetails, updateSurvey };
diff --git a/app/javascript/survey/assets/scss/woot.scss b/app/javascript/survey/assets/scss/woot.scss
index 5c7a4a213..d7e7f5497 100755
--- a/app/javascript/survey/assets/scss/woot.scss
+++ b/app/javascript/survey/assets/scss/woot.scss
@@ -7,6 +7,7 @@
 @import 'widget/assets/scss/mixins';
 @import 'widget/assets/scss/forms';
 @import 'shared/assets/fonts/widget_fonts';
+@import '~shared/assets/stylesheets/ionicons';
 
 html,
 body {
diff --git a/app/javascript/survey/components/Banner.vue b/app/javascript/survey/components/Banner.vue
new file mode 100644
index 000000000..b178b6797
--- /dev/null
+++ b/app/javascript/survey/components/Banner.vue
@@ -0,0 +1,31 @@
+<template>
+  <div class="flex items-center">
+    <i
+      v-if="showSuccess"
+      class="ion-checkmark-circled text-3xl text-green-500 mr-1"
+    />
+    <i v-if="showError" class="ion-android-alert text-3xl text-red-600 mr-1" />
+    <label class="text-base font-medium text-black-800 mt-4 mb-4">
+      {{ message }}
+    </label>
+  </div>
+</template>
+
+<script>
+export default {
+  props: {
+    showSuccess: {
+      type: Boolean,
+      default: false,
+    },
+    showError: {
+      type: Boolean,
+      default: false,
+    },
+    message: {
+      type: String,
+      required: true,
+    },
+  },
+};
+</script>
diff --git a/app/javascript/survey/components/Feedback.vue b/app/javascript/survey/components/Feedback.vue
new file mode 100644
index 000000000..194233e28
--- /dev/null
+++ b/app/javascript/survey/components/Feedback.vue
@@ -0,0 +1,54 @@
+<template>
+  <div>
+    <label class="text-base font-medium text-black-800">
+      {{ $t('SURVEY.FEEDBACK.LABEL') }}
+    </label>
+    <text-area
+      v-model="feedback"
+      class="my-5"
+      :placeholder="$t('SURVEY.FEEDBACK.PLACEHOLDER')"
+    />
+    <div class="flex items-center font-medium float-right">
+      <custom-button @click="onClick">
+        <spinner v-if="feedback" class="p-0" />
+        {{ $t('SURVEY.FEEDBACK.BUTTON_TEXT') }}
+      </custom-button>
+    </div>
+  </div>
+</template>
+
+<script>
+import CustomButton from 'shared/components/Button';
+import TextArea from 'shared/components/TextArea.vue';
+import Spinner from 'shared/components/Spinner';
+
+export default {
+  name: 'Feedback',
+  components: {
+    CustomButton,
+    TextArea,
+    Spinner,
+  },
+  props: {
+    isUpdating: {
+      type: Boolean,
+      default: null,
+    },
+    isButtonDisabled: {
+      type: Boolean,
+      default: null,
+    },
+  },
+  data() {
+    return {
+      feedback: '',
+    };
+  },
+
+  methods: {
+    onClick() {
+      this.$emit('sendFeedback', this.feedback);
+    },
+  },
+};
+</script>
diff --git a/app/javascript/survey/components/Rating.vue b/app/javascript/survey/components/Rating.vue
index 22f7d2cb7..689efcf72 100644
--- a/app/javascript/survey/components/Rating.vue
+++ b/app/javascript/survey/components/Rating.vue
@@ -5,7 +5,7 @@
         v-for="rating in ratings"
         :key="rating.key"
         :class="buttonClass(rating)"
-        @click="selectRating(rating)"
+        @click="onClick(rating)"
       >
         {{ rating.emoji }}
       </button>
@@ -18,35 +18,28 @@ import { CSAT_RATINGS } from 'shared/constants/messages';
 
 export default {
   props: {
-    messageContentAttributes: {
-      type: Object,
-      default: () => {},
+    selectedRating: {
+      type: Number,
+      default: null,
     },
   },
   data() {
     return {
-      email: '',
       ratings: CSAT_RATINGS,
-      selectedRating: null,
     };
   },
-  computed: {
-    isRatingSubmitted() {
-      return this.messageContentAttributes?.csat_survey_response?.rating;
-    },
-  },
 
   methods: {
     buttonClass(rating) {
       return [
         { selected: rating.value === this.selectedRating },
-        { disabled: this.isRatingSubmitted },
-        { hover: this.isRatingSubmitted },
+        { disabled: !!this.selectedRating },
+        { hover: !!this.selectedRating },
         'emoji-button shadow-none text-4xl outline-none mr-8',
       ];
     },
-    selectRating(rating) {
-      this.selectedRating = rating.value;
+    onClick(rating) {
+      this.$emit('selectRating', rating.value);
     },
   },
 };
diff --git a/app/javascript/survey/helpers/axios.js b/app/javascript/survey/helpers/axios.js
new file mode 100644
index 000000000..6d13c2184
--- /dev/null
+++ b/app/javascript/survey/helpers/axios.js
@@ -0,0 +1,6 @@
+import axios from 'axios';
+import { APP_BASE_URL } from 'widget/helpers/constants';
+
+export const API = axios.create({
+  baseURL: APP_BASE_URL,
+});
diff --git a/app/javascript/survey/i18n/locale/en.json b/app/javascript/survey/i18n/locale/en.json
index 72107e5be..dc2ed14e1 100644
--- a/app/javascript/survey/i18n/locale/en.json
+++ b/app/javascript/survey/i18n/locale/en.json
@@ -9,6 +9,10 @@
       "LABEL": "Do you have any thoughts you'd like to share?",
       "PLACEHOLDER": "Your feedback (optional)",
       "BUTTON_TEXT": "Submit feedback"
+    },
+    "API": {
+      "SUCCESS_MESSAGE": "Survey updated successfully",
+      "ERROR_MESSAGE": "Could not connect to Woot Server, Please try again later"
     }
   },
   "POWERED_BY": "Powered by Chatwoot"
diff --git a/app/javascript/survey/views/Response.vue b/app/javascript/survey/views/Response.vue
index ff4d95fff..4fc5b15cb 100644
--- a/app/javascript/survey/views/Response.vue
+++ b/app/javascript/survey/views/Response.vue
@@ -1,29 +1,43 @@
 <template>
   <div
+    v-if="isLoading"
+    class="flex flex-1 items-center h-full bg-black-25 justify-center"
+  >
+    <spinner size="" />
+  </div>
+  <div
+    v-else
     class="w-full h-full flex flex-col flex-no-wrap overflow-hidden bg-white"
   >
     <div class="flex flex-1 overflow-auto">
       <div class="max-w-screen-sm w-full my-0 m-auto px-8 py-12">
-        <img src="/brand-assets/logo.svg" alt="Chatwoot logo" class="logo" />
+        <img :src="logo" alt="Chatwoot logo" class="logo" @error="imgUrlAlt" />
         <p class="text-black-700 text-lg leading-relaxed mt-4 mb-4">
-          {{ $t('SURVEY.DESCRIPTION') }}
+          {{ surveyDescription }}
         </p>
-        <label class="text-base font-medium text-black-800">
+        <banner
+          v-if="shouldShowBanner"
+          :show-success="shouldShowSuccessMesage"
+          :show-error="shouldShowErrorMesage"
+          :message="message"
+        />
+        <label
+          v-if="!isRatingSubmitted"
+          class="text-base font-medium text-black-800 mt-4 mb-4"
+        >
           {{ $t('SURVEY.RATING.LABEL') }}
         </label>
-        <rating />
-        <label class="text-base font-medium text-black-800">
-          {{ $t('SURVEY.FEEDBACK.LABEL') }}
-        </label>
-        <text-area
-          v-model="message"
-          class="my-5"
-          :placeholder="$t('SURVEY.FEEDBACK.PLACEHOLDER')"
+        <rating
+          :selected-rating="selectedRating"
+          @selectRating="selectRating"
+        />
+        <feedback
+          v-if="enableFeedbackForm"
+          :is-updating="isUpdating"
+          :is-button-disabled="isButtonDisabled"
+          :selected-rating="selectedRating"
+          @sendFeedback="sendFeedback"
         />
-        <custom-button class="font-medium float-right">
-          <spinner v-if="isSubmitted" class="p-0" />
-          {{ $t('SURVEY.FEEDBACK.BUTTON_TEXT') }}
-        </custom-button>
       </div>
     </div>
     <div class="footer-wrap flex-shrink-0 w-full flex flex-col relative">
@@ -33,26 +47,138 @@
 </template>
 
 <script>
-import Branding from 'shared/components/Branding.vue';
-import Rating from 'survey/components/Rating.vue';
-import CustomButton from 'shared/components/Button';
-import TextArea from 'shared/components/TextArea.vue';
+import Branding from 'shared/components/Branding';
+import Spinner from 'shared/components/Spinner';
+import Rating from 'survey/components/Rating';
+import Feedback from 'survey/components/Feedback';
+import Banner from 'survey/components/Banner';
 import configMixin from 'shared/mixins/configMixin';
+import { getSurveyDetails, updateSurvey } from 'survey/api/survey';
+import alertMixin from 'shared/mixins/alertMixin';
+const BRAND_LOGO = '/brand-assets/logo.svg';
 export default {
   name: 'Home',
   components: {
     Branding,
     Rating,
-    CustomButton,
-    TextArea,
+    Spinner,
+    Banner,
+    Feedback,
   },
-  mixins: [configMixin],
+  mixins: [alertMixin, configMixin],
+  props: {
+    showHomePage: {
+      type: Boolean,
+      default: false,
+    },
+  },
+
   data() {
     return {
-      message: '',
-      isSubmitted: false,
+      surveyDetails: null,
+      isLoading: false,
+      errorMessage: null,
+      selectedRating: null,
+      feedbackMessage: '',
+      isUpdating: false,
+      logo: '',
     };
   },
+  computed: {
+    surveyId() {
+      const pageURL = window.location.href;
+      return pageURL.substr(pageURL.lastIndexOf('/') + 1);
+    },
+    isRatingSubmitted() {
+      return this.surveyDetails && this.surveyDetails.rating;
+    },
+    isFeedbackSubmitted() {
+      return this.surveyDetails && this.surveyDetails.feedback_message;
+    },
+    isButtonDisabled() {
+      return !(this.selectedRating && this.feedback);
+    },
+    shouldShowBanner() {
+      return this.isRatingSubmitted || this.errorMessage;
+    },
+    enableFeedbackForm() {
+      return !this.isFeedbackSubmitted && this.isRatingSubmitted;
+    },
+    shouldShowErrorMesage() {
+      return !!this.errorMessage;
+    },
+    shouldShowSuccessMesage() {
+      return !!this.isRatingSubmitted;
+    },
+    message() {
+      if (this.errorMessage) {
+        return this.errorMessage;
+      }
+      return this.$t('SURVEY.RATING.SUCCESS_MESSAGE');
+    },
+    surveyDescription() {
+      return this.isRatingSubmitted ? '' : this.$t('SURVEY.DESCRIPTION');
+    },
+  },
+  async mounted() {
+    this.getSurveyDetails();
+  },
+  methods: {
+    selectRating(rating) {
+      this.selectedRating = rating;
+      this.updateSurveyDetails();
+    },
+    sendFeedback(message) {
+      this.feedbackMessage = message;
+      this.updateSurveyDetails();
+    },
+    imgUrlAlt() {
+      this.logo = BRAND_LOGO;
+    },
+    async getSurveyDetails() {
+      this.isLoading = true;
+      try {
+        const result = await getSurveyDetails({ uuid: this.surveyId });
+        this.logo = result.data.inbox_avatar_url;
+        this.surveyDetails = result?.data?.csat_survey_response;
+        this.selectedRating = this.surveyDetails?.rating;
+        this.feedbackMessage = this.surveyDetails?.feedback_message || '';
+      } catch (error) {
+        const errorMessage = error?.response?.data?.message;
+        this.errorMessage = errorMessage || this.$t('SURVEY.API.ERROR_MESSAGE');
+      } finally {
+        this.isLoading = false;
+      }
+    },
+    async updateSurveyDetails() {
+      this.isUpdating = true;
+      try {
+        const data = {
+          message: {
+            submitted_values: {
+              csat_survey_response: {
+                rating: this.selectedRating,
+                feedback_message: this.feedbackMessage,
+              },
+            },
+          },
+        };
+        await updateSurvey({
+          uuid: this.surveyId,
+          data,
+        });
+        this.surveyDetails = {
+          rating: this.selectedRating,
+          feedback_message: this.feedbackMessage,
+        };
+      } catch (error) {
+        const errorMessage = error?.response?.data?.message;
+        this.errorMessage = errorMessage || this.$t('SURVEY.API.ERROR_MESSAGE');
+      } finally {
+        this.isUpdating = false;
+      }
+    },
+  },
 };
 </script>
 
diff --git a/app/listeners/agent_bot_listener.rb b/app/listeners/agent_bot_listener.rb
index b4b9cc8a3..c697bcf65 100644
--- a/app/listeners/agent_bot_listener.rb
+++ b/app/listeners/agent_bot_listener.rb
@@ -26,7 +26,7 @@ class AgentBotListener < BaseListener
   def message_created(event)
     message = extract_message_and_account(event)[0]
     inbox = message.inbox
-    return unless message.reportable? && inbox.agent_bot_inbox.present?
+    return unless message.webhook_sendable? && inbox.agent_bot_inbox.present?
     return unless inbox.agent_bot_inbox.active?
 
     agent_bot = inbox.agent_bot_inbox.agent_bot
@@ -38,7 +38,7 @@ class AgentBotListener < BaseListener
   def message_updated(event)
     message = extract_message_and_account(event)[0]
     inbox = message.inbox
-    return unless message.reportable? && inbox.agent_bot_inbox.present?
+    return unless message.webhook_sendable? && inbox.agent_bot_inbox.present?
     return unless inbox.agent_bot_inbox.active?
 
     agent_bot = inbox.agent_bot_inbox.agent_bot
diff --git a/app/listeners/hook_listener.rb b/app/listeners/hook_listener.rb
index a98de860a..92099d21a 100644
--- a/app/listeners/hook_listener.rb
+++ b/app/listeners/hook_listener.rb
@@ -1,7 +1,7 @@
 class HookListener < BaseListener
   def message_created(event)
     message = extract_message_and_account(event)[0]
-    return unless message.reportable?
+    return unless message.webhook_sendable?
 
     message.account.hooks.each do |hook|
       HookJob.perform_later(hook, event.name, message: message)
@@ -10,7 +10,7 @@ class HookListener < BaseListener
 
   def message_updated(event)
     message = extract_message_and_account(event)[0]
-    return unless message.reportable?
+    return unless message.webhook_sendable?
 
     message.account.hooks.each do |hook|
       HookJob.perform_later(hook, event.name, message: message)
diff --git a/app/listeners/webhook_listener.rb b/app/listeners/webhook_listener.rb
index f688d7763..6463f29b6 100644
--- a/app/listeners/webhook_listener.rb
+++ b/app/listeners/webhook_listener.rb
@@ -26,7 +26,7 @@ class WebhookListener < BaseListener
     message = extract_message_and_account(event)[0]
     inbox = message.inbox
 
-    return unless message.reportable?
+    return unless message.webhook_sendable?
 
     payload = message.webhook_data.merge(event: __method__.to_s)
     deliver_webhook_payloads(payload, inbox)
@@ -36,7 +36,7 @@ class WebhookListener < BaseListener
     message = extract_message_and_account(event)[0]
     inbox = message.inbox
 
-    return unless message.reportable?
+    return unless message.webhook_sendable?
 
     payload = message.webhook_data.merge(event: __method__.to_s)
     deliver_webhook_payloads(payload, inbox)
diff --git a/app/mailers/conversation_reply_mailer.rb b/app/mailers/conversation_reply_mailer.rb
index ea21cbb2d..b9e439e2b 100644
--- a/app/mailers/conversation_reply_mailer.rb
+++ b/app/mailers/conversation_reply_mailer.rb
@@ -11,7 +11,7 @@ class ConversationReplyMailer < ApplicationMailer
     recap_messages = @conversation.messages.chat.where('created_at < ?', message_queued_time).last(10)
     new_messages = @conversation.messages.chat.where('created_at >= ?', message_queued_time)
     @messages = recap_messages + new_messages
-    @messages = @messages.select(&:reportable?)
+    @messages = @messages.select(&:email_reply_summarizable?)
 
     mail({
            to: @contact&.email,
@@ -29,7 +29,8 @@ class ConversationReplyMailer < ApplicationMailer
     init_conversation_attributes(conversation)
     return if conversation_already_viewed?
 
-    @messages = @conversation.messages.chat.outgoing.where('created_at >= ?', message_queued_time)
+    @messages = @conversation.messages.chat.where(message_type: [:outgoing, :template]).where('created_at >= ?', message_queued_time)
+    @messages = @messages.reject { |m| m.template? && !m.input_csat? }
     return false if @messages.count.zero?
 
     mail({
@@ -47,7 +48,7 @@ class ConversationReplyMailer < ApplicationMailer
 
     init_conversation_attributes(conversation)
 
-    @messages = @conversation.messages.chat.select(&:reportable?)
+    @messages = @conversation.messages.chat.select(&:conversation_transcriptable?)
 
     mail({
            to: to_email,
diff --git a/app/models/concerns/message_filter_helpers.rb b/app/models/concerns/message_filter_helpers.rb
new file mode 100644
index 000000000..08b0f5660
--- /dev/null
+++ b/app/models/concerns/message_filter_helpers.rb
@@ -0,0 +1,19 @@
+module MessageFilterHelpers
+  extend ActiveSupport::Concern
+
+  def reportable?
+    incoming? || outgoing?
+  end
+
+  def webhook_sendable?
+    incoming? || outgoing?
+  end
+
+  def conversation_transcriptable?
+    incoming? || outgoing?
+  end
+
+  def email_reply_summarizable?
+    incoming? || outgoing? || input_csat?
+  end
+end
diff --git a/app/models/conversation.rb b/app/models/conversation.rb
index eaf47885b..f5d4f9680 100644
--- a/app/models/conversation.rb
+++ b/app/models/conversation.rb
@@ -142,6 +142,10 @@ class Conversation < ApplicationRecord
     true
   end
 
+  def tweet?
+    inbox.inbox_type == 'Twitter' && additional_attributes['type'] == 'tweet'
+  end
+
   private
 
   def ensure_snooze_until_reset
diff --git a/app/models/message.rb b/app/models/message.rb
index 740e0c91c..d731bf488 100644
--- a/app/models/message.rb
+++ b/app/models/message.rb
@@ -29,6 +29,7 @@
 #
 
 class Message < ApplicationRecord
+  include MessageFilterHelpers
   NUMBER_OF_PERMITTED_ATTACHMENTS = 15
 
   validates :account_id, presence: true
@@ -81,9 +82,6 @@ class Message < ApplicationRecord
   has_many :attachments, dependent: :destroy, autosave: true, before_add: :validate_attachments_limit
   has_one :csat_survey_response, dependent: :destroy
 
-  after_create :reopen_conversation,
-               :notify_via_mail
-
   after_create_commit :execute_after_create_commit_callbacks
 
   after_update_commit :dispatch_update_event
@@ -109,10 +107,6 @@ class Message < ApplicationRecord
     data
   end
 
-  def reportable?
-    incoming? || outgoing?
-  end
-
   def webhook_data
     {
       id: id,
@@ -130,10 +124,19 @@ class Message < ApplicationRecord
     }
   end
 
+  def content
+    # move this to a presenter
+    return self[:content] if !input_csat? || inbox.web_widget?
+
+    I18n.t('conversations.survey.response', link: "#{ENV['FRONTEND_URL']}/survey/responses/#{conversation.uuid}")
+  end
+
   private
 
   def execute_after_create_commit_callbacks
     # rails issue with order of active record callbacks being executed https://github.com/rails/rails/issues/20911
+    reopen_conversation
+    notify_via_mail
     set_conversation_activity
     dispatch_create_events
     send_reply
@@ -175,7 +178,7 @@ class Message < ApplicationRecord
   end
 
   def email_notifiable_message?
-    return false unless outgoing?
+    return false unless outgoing? || input_csat?
     return false if private?
 
     true
diff --git a/app/services/message_templates/hook_execution_service.rb b/app/services/message_templates/hook_execution_service.rb
index ee116f462..73ab0cb64 100644
--- a/app/services/message_templates/hook_execution_service.rb
+++ b/app/services/message_templates/hook_execution_service.rb
@@ -46,17 +46,18 @@ class MessageTemplates::HookExecutionService
     contact.email
   end
 
-  def csat_enabled_inbox?
-    # for now csat only available in web widget channel
-    return unless inbox.web_widget?
-    return unless inbox.csat_survey_enabled?
+  def csat_enabled_conversation?
+    return false unless conversation.resolved?
+    # should not sent since the link will be public
+    return false if conversation.tweet?
+    return false unless inbox.csat_survey_enabled?
 
     true
   end
 
   def should_send_csat_survey?
-    return unless conversation.resolved?
-    return unless csat_enabled_inbox?
+    return unless csat_enabled_conversation?
+
     # only send CSAT once in a conversation
     return if conversation.messages.where(content_type: :input_csat).present?
 
diff --git a/config/locales/en.yml b/config/locales/en.yml
index 4ef8178d4..061d3055e 100644
--- a/config/locales/en.yml
+++ b/config/locales/en.yml
@@ -87,6 +87,8 @@ en:
     reply:
       email_subject: "New messages on this conversation"
       transcript_subject: "Conversation Transcript"
+    survey:
+      response: "Please rate this conversation, %{link}"
 
   integration_apps:
     slack:
diff --git a/lib/integrations/dialogflow/processor_service.rb b/lib/integrations/dialogflow/processor_service.rb
index 4c490d6b4..32359813a 100644
--- a/lib/integrations/dialogflow/processor_service.rb
+++ b/lib/integrations/dialogflow/processor_service.rb
@@ -20,6 +20,7 @@ class Integrations::Dialogflow::ProcessorService
   end
 
   def processable_message?(message)
+    # TODO: change from reportable and create a dedicated method for this?
     return unless message.reportable?
     return if message.outgoing? && !processable_outgoing_message?(message)
 
diff --git a/package.json b/package.json
index 851d17e1b..9f852c530 100644
--- a/package.json
+++ b/package.json
@@ -12,7 +12,8 @@
     "start:dev": "foreman start -f ./Procfile.dev",
     "start:dev-overmind": "overmind start -f ./Procfile.dev",
     "storybook": "start-storybook -p 6006",
-    "build-storybook": "build-storybook"
+    "build-storybook": "build-storybook",
+    "ruby:prettier":"bundle exec rubocop -a"
   },
   "dependencies": {
     "@braid/vue-formulate": "^2.5.2",
diff --git a/spec/services/message_templates/hook_execution_service_spec.rb b/spec/services/message_templates/hook_execution_service_spec.rb
index 0c20f643d..299213584 100644
--- a/spec/services/message_templates/hook_execution_service_spec.rb
+++ b/spec/services/message_templates/hook_execution_service_spec.rb
@@ -114,9 +114,10 @@ describe ::MessageTemplates::HookExecutionService do
       expect(csat_survey).not_to have_received(:perform)
     end
 
-    it 'will not call ::MessageTemplates::Template::CsatSurvey if its not a website widget' do
-      api_channel = create(:channel_api)
-      conversation = create(:conversation, inbox: create(:inbox, channel: api_channel))
+    it 'will not call ::MessageTemplates::Template::CsatSurvey if its a tweet conversation' do
+      twitter_channel = create(:channel_twitter_profile)
+      twitter_inbox = create(:inbox, channel: twitter_channel)
+      conversation = create(:conversation, inbox: twitter_inbox, additional_attributes: { type: 'tweet' })
       conversation.inbox.update(csat_survey_enabled: true)
 
       conversation.resolved!