mirror of
https://github.com/we-promise/sure.git
synced 2026-07-12 12:55:20 +00:00
313 lines
9.5 KiB
Ruby
313 lines
9.5 KiB
Ruby
require "test_helper"
|
|
|
|
class TransfersControllerTest < ActionDispatch::IntegrationTest
|
|
setup do
|
|
sign_in users(:family_admin)
|
|
end
|
|
|
|
test "should get new" do
|
|
get new_transfer_url
|
|
assert_response :success
|
|
end
|
|
|
|
test "can create transfers" do
|
|
assert_difference "Transfer.count", 1 do
|
|
post transfers_url, params: {
|
|
transfer: {
|
|
from_account_id: accounts(:depository).id,
|
|
to_account_id: accounts(:credit_card).id,
|
|
date: Date.current,
|
|
amount: 100,
|
|
name: "Test Transfer"
|
|
}
|
|
}
|
|
assert_enqueued_with job: SyncJob
|
|
end
|
|
end
|
|
|
|
test "can create transfer with custom exchange rate" do
|
|
usd_account = accounts(:depository)
|
|
eur_account = users(:family_admin).family.accounts.create!(
|
|
name: "EUR Account",
|
|
balance: 1000,
|
|
currency: "EUR",
|
|
accountable: Depository.new
|
|
)
|
|
|
|
assert_equal "USD", usd_account.currency
|
|
assert_equal "EUR", eur_account.currency
|
|
|
|
assert_difference "Transfer.count", 1 do
|
|
post transfers_url, params: {
|
|
transfer: {
|
|
from_account_id: usd_account.id,
|
|
to_account_id: eur_account.id,
|
|
date: Date.current,
|
|
amount: 100,
|
|
exchange_rate: 0.92
|
|
}
|
|
}
|
|
end
|
|
|
|
transfer = Transfer.where(
|
|
"outflow_transaction_id IN (?) AND inflow_transaction_id IN (?)",
|
|
usd_account.transactions.pluck(:id),
|
|
eur_account.transactions.pluck(:id)
|
|
).last
|
|
assert_not_nil transfer
|
|
assert_equal "USD", transfer.outflow_transaction.entry.currency
|
|
assert_equal "EUR", transfer.inflow_transaction.entry.currency
|
|
assert_equal 100, transfer.outflow_transaction.entry.amount
|
|
assert_in_delta(-92, transfer.inflow_transaction.entry.amount, 0.01)
|
|
end
|
|
|
|
test "exchange_rate endpoint returns 400 when from currency is missing" do
|
|
get exchange_rate_url, params: {
|
|
to: "USD"
|
|
}
|
|
|
|
assert_response :bad_request
|
|
json_response = JSON.parse(response.body)
|
|
assert_equal "from and to currencies are required", json_response["error"]
|
|
end
|
|
|
|
test "exchange_rate endpoint returns 400 when to currency is missing" do
|
|
get exchange_rate_url, params: {
|
|
from: "EUR"
|
|
}
|
|
|
|
assert_response :bad_request
|
|
json_response = JSON.parse(response.body)
|
|
assert_equal "from and to currencies are required", json_response["error"]
|
|
end
|
|
|
|
test "exchange_rate endpoint returns 400 on invalid date format" do
|
|
get exchange_rate_url, params: {
|
|
from: "EUR",
|
|
to: "USD",
|
|
date: "not-a-date"
|
|
}
|
|
|
|
assert_response :bad_request
|
|
json_response = JSON.parse(response.body)
|
|
assert_equal "Invalid date format", json_response["error"]
|
|
end
|
|
|
|
test "exchange_rate endpoint returns rate for different currencies" do
|
|
ExchangeRate.expects(:find_or_fetch_rate)
|
|
.with(from: "USD", to: "EUR", date: Date.current)
|
|
.returns(OpenStruct.new(rate: 0.92))
|
|
|
|
get exchange_rate_url, params: {
|
|
from: "USD",
|
|
to: "EUR",
|
|
date: Date.current.to_s
|
|
}
|
|
|
|
assert_response :success
|
|
json_response = JSON.parse(response.body)
|
|
assert_equal 0.92, json_response["rate"]
|
|
end
|
|
|
|
test "exchange_rate endpoint returns error when exchange rate unavailable" do
|
|
ExchangeRate.expects(:find_or_fetch_rate)
|
|
.with(from: "USD", to: "EUR", date: Date.current)
|
|
.returns(nil)
|
|
|
|
get exchange_rate_url, params: {
|
|
from: "USD",
|
|
to: "EUR",
|
|
date: Date.current.to_s
|
|
}
|
|
|
|
assert_response :not_found
|
|
json_response = JSON.parse(response.body)
|
|
assert_equal "Exchange rate not found", json_response["error"]
|
|
end
|
|
|
|
test "cannot create transfer when exchange rate unavailable and no custom rate provided" do
|
|
usd_account = accounts(:depository)
|
|
eur_account = users(:family_admin).family.accounts.create!(
|
|
name: "EUR Account",
|
|
balance: 1000,
|
|
currency: "EUR",
|
|
accountable: Depository.new
|
|
)
|
|
|
|
ExchangeRate.stubs(:find_or_fetch_rate).returns(nil)
|
|
|
|
assert_no_difference "Transfer.count" do
|
|
post transfers_url, params: {
|
|
transfer: {
|
|
from_account_id: usd_account.id,
|
|
to_account_id: eur_account.id,
|
|
date: Date.current,
|
|
amount: 100
|
|
}
|
|
}
|
|
end
|
|
|
|
assert_response :unprocessable_entity
|
|
end
|
|
|
|
test "can create transfer with source fee" do
|
|
assert_difference "Transfer.count", 1 do
|
|
post transfers_url, params: {
|
|
transfer: {
|
|
from_account_id: accounts(:depository).id,
|
|
to_account_id: accounts(:credit_card).id,
|
|
date: Date.current,
|
|
amount: 100,
|
|
source_fee_amount: 3
|
|
}
|
|
}
|
|
end
|
|
|
|
transfer = Transfer.last
|
|
assert_equal 3, transfer.source_fee_amount
|
|
assert_equal 0, transfer.destination_fee_amount
|
|
# Outflow should be amount + source_fee = 100 + 3 = 103
|
|
assert_equal 103, transfer.outflow_transaction.entry.amount
|
|
# Inflow should be -(amount - destination_fee) = -(100 - 0) = -100
|
|
assert_equal(-100, transfer.inflow_transaction.entry.amount)
|
|
end
|
|
|
|
test "can create transfer with destination fee" do
|
|
assert_difference "Transfer.count", 1 do
|
|
post transfers_url, params: {
|
|
transfer: {
|
|
from_account_id: accounts(:depository).id,
|
|
to_account_id: accounts(:credit_card).id,
|
|
date: Date.current,
|
|
amount: 100,
|
|
destination_fee_amount: 3
|
|
}
|
|
}
|
|
end
|
|
|
|
transfer = Transfer.last
|
|
assert_equal 0, transfer.source_fee_amount
|
|
assert_equal 3, transfer.destination_fee_amount
|
|
# Outflow should be amount + source_fee = 100 + 0 = 100
|
|
assert_equal 100, transfer.outflow_transaction.entry.amount
|
|
# Inflow should be -(amount - destination_fee) = -(100 - 3) = -97
|
|
assert_equal(-97, transfer.inflow_transaction.entry.amount)
|
|
end
|
|
|
|
test "can create transfer with both source and destination fees" do
|
|
assert_difference "Transfer.count", 1 do
|
|
post transfers_url, params: {
|
|
transfer: {
|
|
from_account_id: accounts(:depository).id,
|
|
to_account_id: accounts(:credit_card).id,
|
|
date: Date.current,
|
|
amount: 100,
|
|
source_fee_amount: 2,
|
|
destination_fee_amount: 3
|
|
}
|
|
}
|
|
end
|
|
|
|
transfer = Transfer.last
|
|
assert_equal 2, transfer.source_fee_amount
|
|
assert_equal 3, transfer.destination_fee_amount
|
|
# Outflow = 100 + 2 = 102
|
|
assert_equal 102, transfer.outflow_transaction.entry.amount
|
|
# Inflow = -(100 - 3) = -97
|
|
assert_equal(-97, transfer.inflow_transaction.entry.amount)
|
|
end
|
|
|
|
test "exchange_rate endpoint returns same_currency for matching currencies" do
|
|
get exchange_rate_url, params: {
|
|
from: "USD",
|
|
to: "USD"
|
|
}
|
|
|
|
assert_response :success
|
|
json_response = JSON.parse(response.body)
|
|
assert_equal true, json_response["same_currency"]
|
|
assert_equal 1.0, json_response["rate"]
|
|
end
|
|
|
|
test "soft deletes transfer" do
|
|
assert_difference -> { Transfer.count }, -1 do
|
|
delete transfer_url(transfers(:one))
|
|
end
|
|
end
|
|
|
|
test "can add notes to transfer" do
|
|
transfer = transfers(:one)
|
|
assert_nil transfer.notes
|
|
|
|
patch transfer_url(transfer), params: { transfer: { notes: "Test notes" } }
|
|
|
|
assert_redirected_to transactions_url
|
|
assert_equal "Transfer updated", flash[:notice]
|
|
assert_equal "Test notes", transfer.reload.notes
|
|
end
|
|
|
|
test "handles rejection without FrozenError" do
|
|
transfer = transfers(:one)
|
|
|
|
assert_difference "Transfer.count", -1 do
|
|
patch transfer_url(transfer), params: {
|
|
transfer: {
|
|
status: "rejected"
|
|
}
|
|
}
|
|
end
|
|
|
|
assert_redirected_to transactions_url
|
|
assert_equal "Transfer updated", flash[:notice]
|
|
|
|
# Verify the transfer was actually destroyed
|
|
assert_raises(ActiveRecord::RecordNotFound) do
|
|
transfer.reload
|
|
end
|
|
end
|
|
|
|
test "mark_as_recurring creates a recurring transfer" do
|
|
transfer = transfers(:one)
|
|
family = users(:family_admin).family
|
|
family.recurring_transactions.destroy_all
|
|
|
|
assert_difference -> { RecurringTransaction.where(family: family).count }, +1 do
|
|
post mark_as_recurring_transfer_url(transfer)
|
|
end
|
|
|
|
rt = RecurringTransaction.where(family: family).last
|
|
assert rt.transfer?
|
|
assert_equal transfer.outflow_transaction.entry.account, rt.account
|
|
assert_equal transfer.inflow_transaction.entry.account, rt.destination_account
|
|
assert rt.manual?
|
|
assert_equal I18n.t("recurring_transactions.transfer_marked_as_recurring"), flash[:notice]
|
|
assert_redirected_to transactions_path
|
|
end
|
|
|
|
test "mark_as_recurring is idempotent: second call flashes already-exists" do
|
|
transfer = transfers(:one)
|
|
family = users(:family_admin).family
|
|
family.recurring_transactions.destroy_all
|
|
|
|
post mark_as_recurring_transfer_url(transfer)
|
|
assert_equal I18n.t("recurring_transactions.transfer_marked_as_recurring"), flash[:notice]
|
|
|
|
assert_no_difference -> { RecurringTransaction.where(family: family).count } do
|
|
post mark_as_recurring_transfer_url(transfer)
|
|
end
|
|
assert_equal I18n.t("recurring_transactions.transfer_already_exists"), flash[:alert]
|
|
end
|
|
|
|
test "mark_as_recurring is rejected when recurring_transactions_disabled" do
|
|
transfer = transfers(:one)
|
|
family = users(:family_admin).family
|
|
family.update!(recurring_transactions_disabled: true)
|
|
family.recurring_transactions.destroy_all
|
|
|
|
assert_no_difference -> { RecurringTransaction.where(family: family).count } do
|
|
post mark_as_recurring_transfer_url(transfer)
|
|
end
|
|
assert_equal I18n.t("recurring_transactions.transfer_feature_disabled"), flash[:alert]
|
|
end
|
|
end
|