57 lines
1.5 KiB
Ruby
57 lines
1.5 KiB
Ruby
require_relative './base_job'
|
|
require 'resque-metrics'
|
|
require_relative '../cartodb/metrics'
|
|
|
|
module Resque
|
|
module UserDBJobs
|
|
module UserDBMaintenance
|
|
module LinkGhostTables
|
|
extend ::Resque::Metrics
|
|
@queue = :user_dbs
|
|
|
|
def self.perform(user_id)
|
|
Carto::GhostTablesManager.new(user_id).link_ghost_tables_synchronously
|
|
rescue => e
|
|
CartoDB.notify_exception(e)
|
|
raise e
|
|
end
|
|
end
|
|
|
|
module LinkGhostTablesByUsername
|
|
extend ::Resque::Metrics
|
|
@queue = :user_dbs
|
|
|
|
def self.perform(username)
|
|
user = Carto::User.find_by_username!(username)
|
|
Carto::GhostTablesManager.new(user.id).link_ghost_tables_synchronously
|
|
rescue StandardError => e
|
|
CartoDB.notify_exception(e)
|
|
raise e
|
|
end
|
|
end
|
|
|
|
module AutoIndexTable
|
|
@queue = :user_dbs
|
|
|
|
def self.perform(user_table_id)
|
|
user_table = Carto::UserTable.where(id: user_table_id).first
|
|
Carto::UserTableIndexService.new(user_table).update_auto_indices if user_table
|
|
rescue => e
|
|
CartoDB::Logger.error(message: 'Error auto-indexing table', exception: e, user_table_id: user_table_id)
|
|
end
|
|
end
|
|
end
|
|
|
|
module CommonData
|
|
module LoadCommonData
|
|
@queue = :user_dbs
|
|
|
|
def self.perform(user_id, visualizations_api_url)
|
|
user = ::User.where(id: user_id).first
|
|
user.load_common_data(visualizations_api_url) if user.should_load_common_data?
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|