Merge pull request #3036 from techAPJ/patch-4

FEATURE: export csv for all the logs
This commit is contained in:
Robin Ward 2014-12-11 14:56:05 -05:00
commit b366ec7f15
18 changed files with 206 additions and 67 deletions

View file

@ -1,3 +1,5 @@
import { outputExportResult } from 'admin/lib/export-result';
export default Ember.ArrayController.extend(Discourse.Presence, {
loading: false,
@ -7,12 +9,16 @@ export default Ember.ArrayController.extend(Discourse.Presence, {
// feeling lazy
window.location.reload();
});
},
exportScreenedEmailList: function(subject) {
Discourse.ExportCsv.exportScreenedEmailList().then(outputExportResult);
}
},
show: function() {
var self = this;
this.set('loading', true);
self.set('loading', true);
Discourse.ScreenedEmail.findAll().then(function(result) {
self.set('model', result);
self.set('loading', false);

View file

@ -1,10 +1,12 @@
import { outputExportResult } from 'admin/lib/export-result';
export default Ember.ArrayController.extend(Discourse.Presence, {
loading: false,
itemController: 'admin-log-screened-ip-address',
show: function() {
var self = this;
this.set('loading', true);
self.set('loading', true);
Discourse.ScreenedIpAddress.findAll().then(function(result) {
self.set('model', result);
self.set('loading', false);
@ -34,6 +36,10 @@ export default Ember.ArrayController.extend(Discourse.Presence, {
});
}
});
},
exportScreenedIpList: function(subject) {
Discourse.ExportCsv.exportScreenedIpList().then(outputExportResult);
}
}
});

View file

@ -1,12 +1,20 @@
import { outputExportResult } from 'admin/lib/export-result';
export default Ember.ArrayController.extend(Discourse.Presence, {
loading: false,
show: function() {
var self = this;
this.set('loading', true);
self.set('loading', true);
Discourse.ScreenedUrl.findAll().then(function(result) {
self.set('model', result);
self.set('loading', false);
});
},
actions: {
exportScreenedUrlList: function(subject) {
Discourse.ExportCsv.exportScreenedUrlList().then(outputExportResult);
}
}
});

View file

@ -6,6 +6,8 @@
@namespace Discourse
@module Discourse
**/
import { outputExportResult } from 'admin/lib/export-result';
export default Ember.ArrayController.extend(Discourse.Presence, {
loading: false,
filters: {},
@ -60,6 +62,10 @@ export default Ember.ArrayController.extend(Discourse.Presence, {
filterBySubject: function(subject) {
this.set('filters.subject', subject);
},
exportStaffActionLogs: function(subject) {
Discourse.ExportCsv.exportStaffActionLogs().then(outputExportResult);
}
}
});

View file

@ -0,0 +1,7 @@
export function outputExportResult(result) {
if (result.success) {
bootbox.alert(I18n.t("admin.export_csv.success"));
} else {
bootbox.alert(I18n.t("admin.export_csv.failed"));
}
}

View file

@ -15,15 +15,42 @@ Discourse.ExportCsv.reopenClass({
@method export_user_list
**/
exportUserList: function() {
return Discourse.ajax("/admin/export_csv/users.json");
return Discourse.ajax("/admin/export_csv/export_entity.json", {data: {entity: 'user'}});
},
/**
Exports screened IPs list
Exports staff action logs
@method export_screened_ips_list
@method export_staff_action_logs
**/
exportScreenedIpsList: function() {
return Discourse.ajax("/admin/export_csv/screened_ips.json");
exportStaffActionLogs: function() {
return Discourse.ajax("/admin/export_csv/export_entity.json", {data: {entity: 'staff_action'}});
},
/**
Exports screened email list
@method export_screened_email_list
**/
exportScreenedEmailList: function() {
return Discourse.ajax("/admin/export_csv/export_entity.json", {data: {entity: 'screened_email'}});
},
/**
Exports screened IP list
@method export_screened_ip_list
**/
exportScreenedIpList: function() {
return Discourse.ajax("/admin/export_csv/export_entity.json", {data: {entity: 'screened_ip'}});
},
/**
Exports screened URL list
@method export_screened_url_list
**/
exportScreenedUrlList: function() {
return Discourse.ajax("/admin/export_csv/export_entity.json", {data: {entity: 'screened_url'}});
}
});

View file

@ -1,15 +0,0 @@
export default Discourse.Route.extend({
actions: {
exportScreenedIps: function() {
Discourse.ExportCsv.exportScreenedIpsList().then(function(result) {
if (result.success) {
bootbox.alert(I18n.t("admin.export_csv.success"));
} else {
bootbox.alert(I18n.t("admin.export_csv.failed"));
}
});
}
}
});

View file

@ -8,9 +8,6 @@
<li><a href="/logs" data-auto-route="true">{{i18n 'admin.logs.logster.title'}}</a></li>
</ul>
</div>
<div class="pull-right">
<button {{action "exportScreenedIps"}} class="btn" title="{{i18n 'admin.export_csv.screened_ips.title'}}">{{fa-icon "download"}}{{i18n 'admin.export_csv.button_text'}}</button>
</div>
</div>
<div class="admin-container">

View file

@ -1,4 +1,8 @@
<p>{{i18n 'admin.logs.screened_emails.description'}}</p>
<p>
{{i18n 'admin.logs.screened_emails.description'}}
<button class="btn pull-right" {{action "exportScreenedEmailList"}} title="{{i18n 'admin.export_csv.button_title.screened_email'}}">{{fa-icon "download"}}{{i18n 'admin.export_csv.button_text'}}</button>
</p>
</br>
{{#loading-spinner condition=loading}}
{{#if model.length}}

View file

@ -1,5 +1,8 @@
<p>{{i18n 'admin.logs.screened_ips.description'}}</p>
<button class="btn pull-right" {{action "rollUp"}} title="{{i18n 'admin.logs.screened_ips.roll_up.title'}}">{{i18n 'admin.logs.screened_ips.roll_up.text'}}</button>
<div class="pull-right">
<button class="btn" {{action "rollUp"}} title="{{i18n 'admin.logs.screened_ips.roll_up.title'}}">{{i18n 'admin.logs.screened_ips.roll_up.text'}}</button>
<button class="btn" {{action "exportScreenedIpList"}} title="{{i18n 'admin.export_csv.button_title.screened_ip'}}">{{fa-icon "download"}}{{i18n 'admin.export_csv.button_text'}}</button>
</div>
{{screened-ip-address-form action="recordAdded"}}
<br/>

View file

@ -1,4 +1,8 @@
<p>{{i18n 'admin.logs.screened_urls.description'}}</p>
<p>
{{i18n 'admin.logs.screened_urls.description'}}
<button class="btn pull-right" {{action "exportScreenedUrlList"}} title="{{i18n 'admin.export_csv.button_title.screened_url'}}">{{fa-icon "download"}}{{i18n 'admin.export_csv.button_text'}}</button>
</p>
</br>
{{#loading-spinner condition=loading}}
{{#if model.length}}

View file

@ -28,6 +28,11 @@
{{/if}}
</div>
<div class="pull-right">
<button class="btn" {{action "exportStaffActionLogs"}} title="{{i18n 'admin.export_csv.button_title.staff_action'}}">{{fa-icon "download"}}{{i18n 'admin.export_csv.button_text'}}</button>
</div>
</br>
<div class="staff-action-logs-instructions" {{bind-attr class=":staff-action-logs-instructions showInstructions::invisible"}}>
{{i18n 'admin.logs.staff_actions.instructions'}}
</div>

View file

@ -13,7 +13,7 @@
</ul>
</div>
<div class="pull-right">
<button {{action "exportUsers"}} class="btn" title="{{i18n 'admin.export_csv.users.title'}}"><i class="fa fa-download"></i>{{i18n 'admin.export_csv.button_text'}}</button>
<button {{action "exportUsers"}} class="btn" title="{{i18n 'admin.export_csv.button_title.user'}}"><i class="fa fa-download"></i>{{i18n 'admin.export_csv.button_text'}}</button>
</div>
</div>

View file

@ -1,4 +1,5 @@
//= require list-view
//= require admin/lib/export-result
//= require admin/models/user-field
//= require admin/controllers/admin-email-skipped
//= require admin/controllers/change-site-customization-details

View file

@ -2,15 +2,10 @@ class Admin::ExportCsvController < Admin::AdminController
skip_before_filter :check_xhr, only: [:show]
def export_user_list
def export_entity
params.require(:entity)
# export csv file in a background thread
Jobs.enqueue(:export_csv_file, entity: 'user', user_id: current_user.id)
render json: success_json
end
def export_screened_ips_list
# export csv file in a background thread
Jobs.enqueue(:export_csv_file, entity: 'screened_ips', user_id: current_user.id)
Jobs.enqueue(:export_csv_file, entity: params[:entity], user_id: current_user.id)
render json: success_json
end

View file

@ -4,10 +4,14 @@ require_dependency 'system_message'
module Jobs
class ExportCsvFile < Jobs::Base
CSV_USER_ATTRS = ['id','name','username','email','title','created_at','trust_level','active','admin','moderator','ip_address']
CSV_USER_STATS = ['topics_entered','posts_read_count','time_read','topic_count','post_count','likes_given','likes_received']
CSV_USER_SSO_ATTRS = ['external_id','external_email', 'external_username', 'external_name', 'external_avatar_url']
SCREENED_IP_ATTRS = ['ip_address','action_type','match_count','last_match_at','created_at']
HEADER_ATTRS_FOR = {}
HEADER_ATTRS_FOR['user'] = ['id','name','username','email','title','created_at','trust_level','active','admin','moderator','ip_address']
HEADER_ATTRS_FOR['user_stats'] = ['topics_entered','posts_read_count','time_read','topic_count','post_count','likes_given','likes_received']
HEADER_ATTRS_FOR['user_sso'] = ['external_id','external_email', 'external_username', 'external_name', 'external_avatar_url']
HEADER_ATTRS_FOR['staff_action'] = ['staff_user','action','subject','created_at','details', 'context']
HEADER_ATTRS_FOR['screened_email'] = ['email','action','match_count','last_match_at','created_at','ip_address']
HEADER_ATTRS_FOR['screened_ip'] = ['ip_address','action','match_count','last_match_at','created_at']
HEADER_ATTRS_FOR['screened_url'] = ['domain','action','match_count','last_match_at','created_at']
sidekiq_options retry: false
attr_accessor :current_user
@ -20,14 +24,12 @@ module Jobs
entity = args[:entity]
@current_user = User.find_by(id: args[:user_id])
export_method = "#{entity}_export".to_sym
data =
if entity == 'user'
user_export
elsif entity == 'screened_ips'
screened_ips_export
if respond_to?(export_method)
send(export_method)
else
raise Discourse::InvalidParameters.new(:entity) if entity.blank?
raise Discourse::InvalidParameters.new(:entity)
end
if data && data.length > 0
@ -50,21 +52,41 @@ module Jobs
end
end
def staff_action_export
staff_action_data = UserHistory.order('id DESC').to_a
staff_action_data.map do |staff_action|
get_staff_action_fields(staff_action)
end
end
def screened_ips_export
screened_ips_data = ScreenedIpAddress.order('id desc').to_a
screened_ips_data.map do |screened_ip|
def screened_email_export
screened_email_data = ScreenedEmail.order('last_match_at desc').to_a
screened_email_data.map do |screened_email|
get_screened_email_fields(screened_email)
end
end
def screened_ip_export
screened_ip_data = ScreenedIpAddress.order('id desc').to_a
screened_ip_data.map do |screened_ip|
get_screened_ip_fields(screened_ip)
end
end
def screened_url_export
screened_url_data = ScreenedUrl.select("domain, sum(match_count) as match_count, max(last_match_at) as last_match_at, min(created_at) as created_at").group(:domain).order('last_match_at DESC').to_a
screened_url_data.map do |screened_url|
get_screened_url_fields(screened_url)
end
end
def get_header(entity)
case entity
when 'user'
header_array = CSV_USER_ATTRS + CSV_USER_STATS
header_array = HEADER_ATTRS_FOR['user'] + HEADER_ATTRS_FOR['user_stats']
if SiteSetting.enable_sso
header_array.concat(CSV_USER_SSO_ATTRS)
header_array.concat(HEADER_ATTRS_FOR['user_sso'])
end
user_custom_fields = UserField.all
if user_custom_fields.present?
@ -73,8 +95,8 @@ module Jobs
end
end
header_array.push("group_names")
when 'screened_ips'
header_array = SCREENED_IP_ATTRS
else
header_array = HEADER_ATTRS_FOR[entity]
end
header_array
@ -94,17 +116,17 @@ module Jobs
def get_user_fields(user)
user_array = []
CSV_USER_ATTRS.each do |attr|
HEADER_ATTRS_FOR['user'].each do |attr|
user_array.push(user.attributes[attr])
end
CSV_USER_STATS.each do |stat|
HEADER_ATTRS_FOR['user_stats'].each do |stat|
user_array.push(user.user_stat.attributes[stat])
end
if SiteSetting.enable_sso
sso = user.single_sign_on_record
CSV_USER_SSO_ATTRS.each do |stat|
HEADER_ATTRS_FOR['user_sso'].each do |stat|
field = sso.attributes[stat] if sso
user_array.push(field)
end
@ -119,16 +141,78 @@ module Jobs
user_array
end
def get_staff_action_fields(staff_action)
staff_action_array = []
HEADER_ATTRS_FOR['staff_action'].each do |attr|
data =
if attr == 'action'
UserHistory.actions.key(staff_action.attributes[attr]).to_s
elsif attr == 'staff_user'
user = User.find_by(id: staff_action.attributes['acting_user_id'])
user.username if !user.nil?
else
staff_action.attributes[attr]
end
staff_action_array.push(data)
end
staff_action_array
end
def get_screened_email_fields(screened_email)
screened_email_array = []
HEADER_ATTRS_FOR['screened_email'].each do |attr|
data =
if attr == 'action'
ScreenedEmail.actions.key(screened_email.attributes['action_type']).to_s
else
screened_email.attributes[attr]
end
screened_email_array.push(data)
end
screened_email_array
end
def get_screened_ip_fields(screened_ip)
screened_ip_array = []
SCREENED_IP_ATTRS.each do |attr|
screened_ip_array.push(screened_ip.attributes[attr])
HEADER_ATTRS_FOR['screened_ip'].each do |attr|
data =
if attr == 'action'
ScreenedIpAddress.actions.key(screened_ip.attributes['action_type']).to_s
else
screened_ip.attributes[attr]
end
screened_ip_array.push(data)
end
screened_ip_array
end
def get_screened_url_fields(screened_url)
screened_url_array = []
HEADER_ATTRS_FOR['screened_url'].each do |attr|
data =
if attr == 'action'
action = ScreenedUrl.actions.key(screened_url.attributes['action_type']).to_s
action = "do nothing" if action.blank?
else
screened_url.attributes[attr]
end
screened_url_array.push(data)
end
screened_url_array
end
def set_file_path
@file_name = "export_#{SecureRandom.hex(4)}.csv"

View file

@ -1688,13 +1688,15 @@ en:
confirm: "Are your sure you want to rollback the database to the previous working state?"
export_csv:
users:
title: "Export full user list in CSV format."
screened_ips:
title: "Export full screened IPs list in CSV format."
success: "Export initiated, you will be notified shortly with progress."
failed: "Export failed. Please check the logs."
button_text: "Export"
button_title:
user: "Export full user list in CSV format."
staff_action: "Export full staff action log in CSV format."
screened_email: "Export full screened email list in CSV format."
screened_ip: "Export full screened IP list in CSV format."
screened_url: "Export full screened URL list in CSV format."
customize:
title: "Customize"

View file

@ -164,8 +164,7 @@ Discourse::Application.routes.draw do
resources :export_csv, constraints: AdminConstraint.new do
collection do
get "users" => "export_csv#export_user_list"
get "screened_ips" => "export_csv#export_screened_ips_list"
get "export_entity" => "export_csv#export_entity"
end
member do
get "" => "export_csv#show", constraints: { id: /[^\/]+/ }