6772312ea7
The primary license of the project is changing to: AGPL-3.0-or-later WITH Web-Template-Output-Additional-Permission-3.0-or-later with some specific files to be licensed under the one of two licenses: CC0-1.0 LGPL-3.0-or-later This commit is one of the many steps to relicense the entire codebase. Documentation granting permission for this relicensing (from all past contributors who hold copyrights) is on file with Software Freedom Conservancy, Inc.
213 lines
7.4 KiB
Ruby
213 lines
7.4 KiB
Ruby
# License: AGPL-3.0-or-later WITH Web-Template-Output-Additional-Permission-3.0-or-later
|
|
require 'qx'
|
|
require 'active_support/core_ext'
|
|
require 'format/currency'
|
|
require 'format/date'
|
|
|
|
module InsertActivities
|
|
|
|
def self.insert_cols
|
|
["action_type", "public", "created_at", "updated_at", "supporter_id", "attachment_type", "attachment_id", "nonprofit_id", "date", "json_data", "kind"]
|
|
end
|
|
|
|
# These line up with the above columns
|
|
def self.defaults
|
|
now = Time.current
|
|
["'created' AS action_type", "'f' AS public", "'#{now}'", "'#{now}'"]
|
|
end
|
|
|
|
def self.create(data)
|
|
Qx.insert_into(:activities)
|
|
.values(data)
|
|
.ts
|
|
.returning('*')
|
|
.execute
|
|
end
|
|
|
|
def self.for_recurring_donations(payment_ids)
|
|
insert_recurring_donations_expr
|
|
.and_where("payments.id IN ($ids)", ids: payment_ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_recurring_donations_expr
|
|
Qx.insert_into(:activities, insert_cols)
|
|
.select(defaults.concat([
|
|
"payments.supporter_id",
|
|
"'Payment' AS attachment_type",
|
|
"payments.id AS attachment_id",
|
|
"payments.nonprofit_id",
|
|
"payments.date",
|
|
"json_build_object('gross_amount', payments.gross_amount, 'start_date', donations.created_at, 'designation', donations.designation, 'dedication', donations.dedication, 'interval', recurring_donations.interval, 'time_unit', recurring_donations.time_unit)",
|
|
"'RecurringDonation' AS kind"
|
|
]))
|
|
.from(:payments)
|
|
.join(:donations, "donations.id=payments.donation_id")
|
|
.add_join(:recurring_donations, "recurring_donations.donation_id=donations.id")
|
|
.where("payments.kind='RecurringDonation'")
|
|
end
|
|
|
|
def self.for_one_time_donations(payment_ids)
|
|
insert_one_time_donations_expr
|
|
.and_where("payments.id IN ($ids)", ids: payment_ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_one_time_donations_expr
|
|
Qx.insert_into(:activities, insert_cols)
|
|
.select(defaults.concat([
|
|
"payments.supporter_id",
|
|
"'Payment' AS attachment_type",
|
|
"payments.id AS attachment_id",
|
|
"payments.nonprofit_id",
|
|
"payments.date",
|
|
"json_build_object('gross_amount', payments.gross_amount, 'designation', donations.designation, 'dedication', donations.dedication)",
|
|
"'Donation' AS kind"
|
|
]))
|
|
.from(:payments)
|
|
.join(:donations, "donations.id=payments.donation_id")
|
|
.where("payments.kind='Donation'")
|
|
end
|
|
|
|
def self.for_tickets(ticket_ids)
|
|
insert_tickets_expr
|
|
.and_where("tickets.id IN ($ids)", ids: ticket_ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_tickets_expr
|
|
Qx.insert_into(:activities, insert_cols)
|
|
.select(defaults.concat([
|
|
"tickets.supporter_id",
|
|
"'Ticket' AS attachment_type",
|
|
"tickets.id AS attachment_id",
|
|
"event.nonprofit_id",
|
|
"tickets.created_at AS date",
|
|
"json_build_object('gross_amount', coalesce(payment.gross_amount, 0), 'event_name', event.name, 'event_id', event.id, 'quantity', tickets.quantity)",
|
|
"'Ticket' AS kind"
|
|
]))
|
|
.from(:tickets)
|
|
.join("payments AS payment", "payment.id=tickets.payment_id")
|
|
.add_join("events AS event", "event.id=tickets.event_id")
|
|
end
|
|
|
|
def self.for_refunds(payment_ids)
|
|
insert_refunds_expr
|
|
.and_where("payments.id IN ($ids)", ids: payment_ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_refunds_expr
|
|
Qx.insert_into(:activities, insert_cols.concat(["user_id"]))
|
|
.select(defaults.concat([
|
|
"payments.supporter_id",
|
|
"'Payment' AS attachment_type",
|
|
"payments.id AS attachment_id",
|
|
"payments.nonprofit_id",
|
|
"payments.date",
|
|
"json_build_object('gross_amount', payments.gross_amount, 'reason', refunds.reason, 'user_email', users.email)",
|
|
"'Refund' AS kind",
|
|
"users.id AS user_id"
|
|
]))
|
|
.from(:payments)
|
|
.join(:refunds, "refunds.payment_id=payments.id")
|
|
.left_join(:users, "refunds.user_id=users.id")
|
|
.where("payments.kind='Refund'")
|
|
end
|
|
|
|
def self.for_disputes(payment_ids)
|
|
insert_disputes_expr
|
|
.and_where("payments.id IN ($ids)", ids: payment_ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_disputes_expr
|
|
Qx.insert_into(:activities, insert_cols)
|
|
.select(defaults.concat([
|
|
"payments.supporter_id",
|
|
"'Payment' AS attachment_type",
|
|
"payments.id AS attachment_id",
|
|
"payments.nonprofit_id",
|
|
"payments.date",
|
|
"json_build_object('gross_amount', payments.gross_amount, 'reason', disputes.reason, 'original_kind', other_payment.kind, 'original_date', other_payment.date)",
|
|
"'Dispute' AS kind"
|
|
]))
|
|
.from(:payments)
|
|
.join(:disputes, "disputes.payment_id=payments.id")
|
|
.add_join(:charges, "disputes.charge_id=charges.id")
|
|
.add_join("payments AS other_payment", "other_payment.id=charges.payment_id")
|
|
.where("payments.kind='Dispute'")
|
|
end
|
|
|
|
def self.for_supporter_emails(ids)
|
|
insert_supporter_emails_expr
|
|
.and_where("supporter_emails.id IN ($ids)", ids: ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_supporter_emails_expr
|
|
Qx.insert_into(:activities, insert_cols.concat(["user_id"]))
|
|
.select(defaults.concat([
|
|
"supporter_emails.supporter_id",
|
|
"'SupporterEmail' AS attachment_type",
|
|
"supporter_emails.id AS attachment_id",
|
|
"supporter_emails.nonprofit_id",
|
|
"supporter_emails.created_at AS date",
|
|
"json_build_object('gmail_thread_id', supporter_emails.gmail_thread_id, 'subject', supporter_emails.subject, 'from', supporter_emails.from)",
|
|
"'SupporterEmail' AS kind",
|
|
"users.id AS user_id"
|
|
]))
|
|
.from(:supporter_emails)
|
|
.left_join(:users, "users.id=supporter_emails.user_id")
|
|
end
|
|
|
|
def self.for_supporter_notes(ids)
|
|
insert_supporter_notes_expr
|
|
.and_where("supporter_notes.id IN ($ids)", ids: ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_supporter_notes_expr
|
|
Qx.insert_into(:activities, insert_cols.concat(["user_id"]))
|
|
.select(defaults.concat([
|
|
"supporter_notes.supporter_id",
|
|
"'SupporterEmail' AS attachment_type",
|
|
"supporter_notes.id AS attachment_id",
|
|
"supporters.nonprofit_id",
|
|
"supporter_notes.created_at AS date",
|
|
"json_build_object('content', supporter_notes.content, 'user_email', users.email)",
|
|
"'SupporterNote' AS kind",
|
|
"users.id AS user_id"
|
|
]))
|
|
.from(:supporter_notes)
|
|
.join("supporters", "supporters.id=supporter_notes.supporter_id")
|
|
.add_left_join(:users, "users.id=supporter_notes.user_id")
|
|
end
|
|
|
|
def self.for_offsite_donations(payment_ids)
|
|
insert_offsite_donations_expr
|
|
.and_where("payments.id IN ($ids)", ids: payment_ids)
|
|
.execute
|
|
end
|
|
|
|
def self.insert_offsite_donations_expr
|
|
Qx.insert_into(:activities, insert_cols.concat(["user_id"]))
|
|
.select(defaults.concat([
|
|
"payments.supporter_id",
|
|
"'Payment' AS attachment_type",
|
|
"payments.id AS attachment_id",
|
|
"payments.nonprofit_id",
|
|
"payments.date",
|
|
"json_build_object('gross_amount', payments.gross_amount, 'designation', donations.designation, 'user_email', users.email)",
|
|
"'OffsitePayment' AS kind",
|
|
"users.id AS user_id"
|
|
]))
|
|
.from(:payments)
|
|
.where("payments.kind = 'OffsitePayment'")
|
|
.join(:offsite_payments, "offsite_payments.payment_id=payments.id")
|
|
.add_join(:donations, "payments.donation_id=donations.id")
|
|
.add_left_join(:users, "users.id=offsite_payments.user_id")
|
|
end
|
|
|
|
|
|
end
|