FIX: Scheduled PM with Data Explorer Results not sending PM (#250)

This PR fixes 2 issues that were picked up by users for the Scheduled Data Explorer Report automation script and a couple of small improvements to better match the format of manual data explorer query results.

The first issue is that within result_to_markdown the colrender contains null values, and we are currently checking length (previously treated as a packed array but it is actually a sparse array). Therefore we can check if the current index of the array is null rather than checking the size of the array.

The second issue addresses the blank query_params field. When the data explorer script does not require any params to be passed in via the automation script then it will have a nil value, however it should be defaulted to {} within the plugin.

To improve formatting the markdown table for PMs is now aligned to left and where values are substituted (for example user_id becomes username) we then include the id within brackets, for example:
user_id becomes username (user_id)
This commit is contained in:
David Battersby 2023-07-04 14:18:56 +08:00 committed by GitHub
parent 7bf6c7d3a3
commit ee308c637c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 38 additions and 4 deletions

View File

@ -17,7 +17,7 @@ module ::DiscourseDataExplorer
row.each_with_index do |col, col_index|
col_name = pg_result.fields[col_index]
related = relations.dig(colrender[col_index].to_sym) if col_index < colrender.size
related = relations.dig(colrender[col_index].to_sym) unless colrender[col_index].nil?
if related.is_a?(ActiveModel::ArraySerializer)
related_row = related.object.find_by(id: col)
@ -30,7 +30,7 @@ module ::DiscourseDataExplorer
if column.nil?
row_data[col_index] = col
else
row_data[col_index] = related_row[column]
row_data[col_index] = "#{related_row[column]} (#{col})"
end
else
row_data[col_index] = col
@ -41,7 +41,7 @@ module ::DiscourseDataExplorer
end
table_headers = pg_result.fields.map { |c| " #{c.gsub("_id", "")} |" }.join
table_body = pg_result.fields.size.times.map { " :-----: |" }.join
table_body = pg_result.fields.size.times.map { " :----- |" }.join
"|#{table_headers}\n|#{table_body}\n#{result_data.join}"
end

View File

@ -100,7 +100,7 @@ after_initialize do
script do |_, fields, automation|
recipients = Array(fields.dig("recipients", "value"))
query_id = fields.dig("query_id", "value")
query_params = fields.dig("query_params", "value")
query_params = fields.dig("query_params", "value") || {}
unless SiteSetting.data_explorer_enabled
Rails.logger.warn "#{DiscourseDataExplorer.plugin_name} - plugin must be enabled to run automation #{automation.id}"

View File

@ -0,0 +1,34 @@
# frozen_string_literal: true
describe DiscourseDataExplorer::ResultToMarkdown do
fab!(:user) { Fabricate(:user) }
fab!(:post) { Fabricate(:post) }
fab!(:query) { DiscourseDataExplorer::Query.find(-1) }
let(:query_params) { [{ from_days_ago: 0 }, { duration_days: 15 }] }
let(:query_result) { DiscourseDataExplorer::DataExplorer.run_query(query, query_params) }
before { SiteSetting.data_explorer_enabled = true }
describe ".convert" do
it "format results as a markdown table with headers and columns" do
result = described_class.convert(query_result[:pg_result])
table = <<~MD
| liker_user | liked_user | count |
| :----- | :----- | :----- |
MD
expect(result).to include(table)
end
it "enriches result data within the table rows" do
PostActionCreator.new(user, post, PostActionType.types[:like]).perform
result = described_class.convert(query_result[:pg_result])
expect(result).to include(
"| #{user.username} (#{user.id}) | #{post.user.username} (#{post.user.id}) | 1 |\n",
)
end
end
end