rooty/fab-manager
1
0
Fork 0
mirror of https://github.com/LaCasemate/fab-manager.git synced 2024-12-01 12:24:28 +01:00
Code Issues Releases Activity

corrected ProjectIndexerWorker

Browse Source
This commit is contained in:
Sylvain 2020-05-05 12:37:13 +02:00
parent b204b1fbaf
commit 0609f444b0
1 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
app/workers/project_indexer_worker.rb
View File

@ -1,20 +1,23 @@
# frozen_string_literal: true
# Index the projects to ElasticSearch
class ProjectIndexerWorker class ProjectIndexerWorker
include Sidekiq::Worker include Sidekiq::Worker
sidekiq_options queue: 'elasticsearch', retry: true sidekiq_options queue: 'elasticsearch', retry: true
Logger = Sidekiq.logger.level == Logger::DEBUG ? Sidekiq.logger : nil
Client = Elasticsearch::Model.client
def perform(operation, record_id) def perform(operation, record_id)
logger = Sidekiq.logger.level == Logger::DEBUG ? Sidekiq.logger : nil
client = Elasticsearch::Model.client
logger.debug [operation, "ID: #{record_id}"] logger.debug [operation, "ID: #{record_id}"]
case operation.to_s case operation.to_s
when /index/ when /index/
record = Project.find(record_id) record = Project.find(record_id)
Client.index index: Project.index_name, type: Project.document_type, id: record.id, body: record.as_indexed_json client.index index: Project.index_name, type: Project.document_type, id: record.id, body: record.as_indexed_json
when /delete/ when /delete/
Client.delete index: Project.index_name, type: Project.document_type, id: record_id client.delete index: Project.index_name, type: Project.document_type, id: record_id
else raise ArgumentError, "Unknown operation '#{operation}'" else raise ArgumentError, "Unknown operation '#{operation}'"
end end
end end
end end