DEV: Autoload app files (#179)

Author: nattsw

app/controllers/discourse_translator/translator_controller.rb

@@ -0,0 +1,57 @@
+# frozen_string_literal: true
+
+module ::DiscourseTranslator
+  class TranslatorController < ::ApplicationController
+    requires_plugin PLUGIN_NAME
+
+    before_action :ensure_logged_in
+
+    def translate
+      if !current_user.staff?
+        RateLimiter.new(
+          current_user,
+          "translate_post",
+          SiteSetting.max_translations_per_minute,
+          1.minute,
+        ).performed!
+      end
+
+      params.require(:post_id)
+      post = Post.find_by(id: params[:post_id])
+      raise Discourse::InvalidParameters.new(:post_id) if post.blank?
+      guardian.ensure_can_see!(post)
+
+      if !guardian.user_group_allow_translate?
+        raise Discourse::InvalidAccess.new(
+                "not_in_group",
+                SiteSetting.restrict_translation_by_group,
+                custom_message: "not_in_group.user_not_in_group",
+                group: current_user.groups.pluck(:id),
+              )
+      end
+
+      if !guardian.poster_group_allow_translate?(post)
+        raise Discourse::InvalidAccess.new(
+                "not_in_group",
+                SiteSetting.restrict_translation_by_poster_group,
+                custom_message: "not_in_group.poster_not_in_group",
+              )
+      end
+
+      begin
+        title_json = {}
+        detected_lang, translation =
+          "DiscourseTranslator::#{SiteSetting.translator}".constantize.translate(post)
+        if post.is_first_post?
+          _, title_translation =
+            "DiscourseTranslator::#{SiteSetting.translator}".constantize.translate(post.topic)
+          title_json = { title_translation: title_translation }
+        end
+        render json: { translation: translation, detected_lang: detected_lang }.merge(title_json),
+               status: 200
+      rescue ::DiscourseTranslator::TranslatorError => e
+        render_json_error e.message, status: 422
+      end
+    end
+  end
+end

app/jobs/scheduled/detect_posts_language.rb

@@ -0,0 +1,40 @@
+# frozen_string_literal: true
+
+module ::Jobs
+  class DetectPostsLanguage < ::Jobs::Scheduled
+    sidekiq_options retry: false
+    every 5.minutes
+
+    BATCH_SIZE = 100
+    MAX_QUEUE_SIZE = 1000
+
+    def execute(args)
+      return unless SiteSetting.translator_enabled
+
+      post_ids = Discourse.redis.spop(DiscourseTranslator::LANG_DETECT_NEEDED, MAX_QUEUE_SIZE)
+      return if post_ids.blank?
+
+      post_ids.each_slice(BATCH_SIZE) { |batch| process_batch(batch) }
+    end
+
+    private
+
+    def process_batch(post_ids)
+      posts = Post.where(id: post_ids).to_a
+      posts.each do |post|
+        DistributedMutex.synchronize("detect_translation_#{post.id}") do
+          begin
+            translator = "DiscourseTranslator::#{SiteSetting.translator}".constantize
+            translator.detect(post)
+            if !post.custom_fields_clean?
+              post.save_custom_fields
+              post.publish_change_to_clients!(:revised)
+            end
+          rescue ::DiscourseTranslator::ProblemCheckedTranslationError
+            # problem-checked translation errors gracefully
+          end
+        end
+      end
+    end
+  end
+end

services/discourse_translator/amazon.rb renamed to app/services/discourse_translator/amazon.rb

@@ -0,0 +1,7 @@
+# frozen_string_literal: true
+
+DiscourseTranslator::Engine.routes.draw do
+  post "/translate" => "translator#translate", :format => :json
+end
+
+Discourse::Application.routes.draw { mount ::DiscourseTranslator::Engine, at: "/translator" }

services/discourse_translator/base.rb renamed to app/services/discourse_translator/base.rb

@@ -0,0 +1,12 @@
+# frozen_string_literal: true
+module ::DiscourseTranslator
+  class Engine < ::Rails::Engine
+    engine_name PLUGIN_NAME
+    isolate_namespace DiscourseTranslator
+    config.autoload_paths << File.join(config.root, "lib")
+    scheduled_job_dir = "#{config.root}/app/jobs/scheduled"
+    config.to_prepare do
+      Rails.autoloaders.main.eager_load_dir(scheduled_job_dir) if Dir.exist?(scheduled_job_dir)
+    end
+  end
+end