Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
103 changes: 75 additions & 28 deletions apps/backend/src/donationItems/donationItems.service.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import { FoodType } from './types';
import { BadRequestException, NotFoundException } from '@nestjs/common';
import { testDataSource } from '../config/typeormTestDataSource';
import { CreateDonationItemDto } from './dtos/create-donation-items.dto';
import { ConfirmDonationItemDetailsDto } from './dtos/confirm-donation-item-details.dto';
import { UpdateDonationItemDetailsDto } from './dtos/update-donation-item-details.dto';

jest.setTimeout(60000);

Expand Down Expand Up @@ -297,8 +297,8 @@ describe('DonationItemsService', () => {
});
});

describe('confirmItemDetails', () => {
const makeDto = (itemId: number): ConfirmDonationItemDetailsDto => ({
describe('updateItemDetails', () => {
const makeDto = (itemId: number): UpdateDonationItemDetailsDto => ({
itemId,
ozPerItem: 5.0,
estimatedValue: 10.0,
Expand Down Expand Up @@ -339,7 +339,7 @@ describe('DonationItemsService', () => {
const donationId = await insertMatchedDonation();
await expect(
testDataSource.transaction((tm) =>
service.confirmItemDetails(donationId, [makeDto(99999)], tm),
service.updateItemDetails(donationId, [makeDto(99999)], tm),
),
).rejects.toThrow(new NotFoundException('Donation item 99999 not found'));
});
Expand All @@ -349,7 +349,7 @@ describe('DonationItemsService', () => {
// Item 1 belongs to donation 1, not the new donation
await expect(
testDataSource.transaction((tm) =>
service.confirmItemDetails(donationId, [makeDto(1)], tm),
service.updateItemDetails(donationId, [makeDto(1)], tm),
),
).rejects.toThrow(
new BadRequestException(
Expand All @@ -358,38 +358,19 @@ describe('DonationItemsService', () => {
);
});

it('throws BadRequestException when an item in the body is already confirmed', async () => {
const donationId = await insertMatchedDonation();
const itemId = await insertDonationItem(donationId, 10, 10);
await testDataSource.query(
`UPDATE donation_items SET details_confirmed = true WHERE item_id = $1`,
[itemId],
);

await expect(
testDataSource.transaction((tm) =>
service.confirmItemDetails(donationId, [makeDto(itemId)], tm),
),
).rejects.toThrow(
new BadRequestException(
`Donation item ${itemId} has already been confirmed`,
),
);
});

it('updates fields and sets detailsConfirmed to true for a single item', async () => {
const donationId = await insertMatchedDonation();
const itemId = await insertDonationItem(donationId, 10, 5);

const dto: ConfirmDonationItemDetailsDto = {
const dto: UpdateDonationItemDetailsDto = {
itemId,
ozPerItem: 8.5,
estimatedValue: 12.0,
foodRescue: false,
};

await testDataSource.transaction((tm) =>
service.confirmItemDetails(donationId, [dto], tm),
service.updateItemDetails(donationId, [dto], tm),
);

const item = await testDataSource
Expand All @@ -407,7 +388,7 @@ describe('DonationItemsService', () => {
const itemId2 = await insertDonationItem(donationId, 20, 10);

await testDataSource.transaction((tm) =>
service.confirmItemDetails(
service.updateItemDetails(
donationId,
[
{
Expand Down Expand Up @@ -452,7 +433,7 @@ describe('DonationItemsService', () => {
// Second dto references item 1 which belongs to donation 1, not ours
await expect(
testDataSource.transaction((tm) =>
service.confirmItemDetails(
service.updateItemDetails(
donationId,
[makeDto(itemId), makeDto(1)],
tm,
Expand All @@ -470,5 +451,71 @@ describe('DonationItemsService', () => {
expect(item?.detailsConfirmed).toBe(false);
expect(item?.ozPerItem).toBeNull();
});

it('returns false and does not confirm when only some fields are provided', async () => {
const donationId = await insertMatchedDonation();
const itemId = await insertDonationItem(donationId, 10, 5);

const result = await testDataSource.transaction((tm) =>
service.updateItemDetails(donationId, [{ itemId, ozPerItem: 8.5 }], tm),
);

expect(result).toBe(false);
const item = await testDataSource
.getRepository(DonationItem)
.findOneBy({ itemId });
expect(Number(item?.ozPerItem)).toBe(8.5);
expect(item?.estimatedValue).toBeNull();
expect(item?.detailsConfirmed).toBe(false);
});

it('confirms item on a second call that supplies the remaining fields', async () => {
const donationId = await insertMatchedDonation();
const itemId = await insertDonationItem(donationId, 10, 5);

const firstResult = await testDataSource.transaction((tm) =>
service.updateItemDetails(donationId, [{ itemId, ozPerItem: 8.5 }], tm),
);
expect(firstResult).toBe(false);

const secondResult = await testDataSource.transaction((tm) =>
service.updateItemDetails(
donationId,
[{ itemId, estimatedValue: 12.0, foodRescue: true }],
tm,
),
);
expect(secondResult).toBe(true);

const item = await testDataSource
.getRepository(DonationItem)
.findOneBy({ itemId });
expect(Number(item?.ozPerItem)).toBe(8.5);
expect(Number(item?.estimatedValue)).toBe(12.0);
expect(item?.foodRescue).toBe(true);
expect(item?.detailsConfirmed).toBe(true);
});

it('allows updating an already-confirmed item without throwing', async () => {
const donationId = await insertMatchedDonation();
const itemId = await insertDonationItem(donationId, 10, 5);
await testDataSource.query(
`UPDATE donation_items
SET details_confirmed = true, oz_per_item = 5.0, estimated_value = 10.0
WHERE item_id = $1`,
[itemId],
);

const result = await testDataSource.transaction((tm) =>
service.updateItemDetails(donationId, [{ itemId, ozPerItem: 9.0 }], tm),
);

expect(result).toBe(true);
const item = await testDataSource
.getRepository(DonationItem)
.findOneBy({ itemId });
expect(Number(item?.ozPerItem)).toBe(9.0);
expect(item?.detailsConfirmed).toBe(true);
});
});
});
51 changes: 36 additions & 15 deletions apps/backend/src/donationItems/donationItems.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,8 @@ import { DonationItem } from './donationItems.entity';
import { validateId } from '../utils/validation.utils';
import { FoodType } from './types';
import { Donation } from '../donations/donations.entity';
import { DonationStatus } from '../donations/types';
import { CreateDonationItemDto } from './dtos/create-donation-items.dto';
import { ConfirmDonationItemDetailsDto } from './dtos/confirm-donation-item-details.dto';
import { UpdateDonationItemDetailsDto } from './dtos/update-donation-item-details.dto';

@Injectable()
export class DonationItemsService {
Expand Down Expand Up @@ -103,14 +102,16 @@ export class DonationItemsService {
return this.repo.save(donationItem);
}

async confirmItemDetails(
async updateItemDetails(
donationId: number,
body: ConfirmDonationItemDetailsDto[],
body: UpdateDonationItemDetailsDto[],
transactionManager: EntityManager,
): Promise<void> {
): Promise<boolean> {
const donationItemTransactionRepo =
transactionManager.getRepository(DonationItem);

let confirmedDetailsForAnItem = false;

for (const dto of body) {
const item = await donationItemTransactionRepo.findOneBy({
itemId: dto.itemId,
Expand All @@ -126,19 +127,39 @@ export class DonationItemsService {
);
}

if (item.detailsConfirmed) {
throw new BadRequestException(
`Donation item ${dto.itemId} has already been confirmed`,
);
const updateData: Partial<DonationItem> = {};
if (dto.ozPerItem !== undefined) updateData.ozPerItem = dto.ozPerItem;
if (dto.estimatedValue !== undefined)
updateData.estimatedValue = dto.estimatedValue;
if (dto.foodRescue !== undefined) updateData.foodRescue = dto.foodRescue;

// If included in DTO, keep it, otherwise use whatever is in the DB (could be null)
const resultingOzPerItem =
updateData.ozPerItem !== undefined
? updateData.ozPerItem
: item.ozPerItem;
const resultingEstimatedValue =
updateData.estimatedValue !== undefined
? updateData.estimatedValue
: item.estimatedValue;
const resultingFoodRescue =
updateData.foodRescue !== undefined
? updateData.foodRescue
: item.foodRescue;

if (
resultingOzPerItem != null &&
resultingEstimatedValue != null &&
resultingFoodRescue != null
) {
updateData.detailsConfirmed = true;
confirmedDetailsForAnItem = true;
}

await donationItemTransactionRepo.update(dto.itemId, {
ozPerItem: dto.ozPerItem,
estimatedValue: dto.estimatedValue,
foodRescue: dto.foodRescue,
detailsConfirmed: true,
});
await donationItemTransactionRepo.update(dto.itemId, updateData);
}

return confirmedDetailsForAnItem;
}

async createMultiple(
Expand Down
Original file line number Diff line number Diff line change
@@ -1,23 +1,26 @@
import { IsNumber, Min, IsBoolean, IsInt } from 'class-validator';
import { IsNumber, Min, IsBoolean, IsInt, IsOptional } from 'class-validator';

export class ConfirmDonationItemDetailsDto {
export class UpdateDonationItemDetailsDto {
@IsInt()
itemId!: number;

@IsOptional()
@IsNumber(
{ maxDecimalPlaces: 2 },
{ message: 'Oz per item must have at most 2 decimal places' },
)
@Min(0.01, { message: 'Oz per item must be at least 0.01' })
ozPerItem!: number;
ozPerItem?: number;

@IsOptional()
@IsNumber(
{ maxDecimalPlaces: 2 },
{ message: 'Estimated value must have at most 2 decimal places' },
)
@Min(0.01, { message: 'Estimated value must be at least 0.01' })
estimatedValue!: number;
estimatedValue?: number;

@IsOptional()
@IsBoolean()
foodRescue!: boolean;
foodRescue?: boolean;
}
12 changes: 6 additions & 6 deletions apps/backend/src/donations/donations.controller.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import { Donation } from './donations.entity';
import { CreateDonationDto } from './dtos/create-donation.dto';
import { CreateDonationItemDto } from '../donationItems/dtos/create-donation-items.dto';
import { DonationStatus, RecurrenceEnum } from './types';
import { ConfirmDonationItemDetailsDto } from '../donationItems/dtos/confirm-donation-item-details.dto';
import { UpdateDonationItemDetailsDto } from '../donationItems/dtos/update-donation-item-details.dto';
import { DonationItem } from '../donationItems/donationItems.entity';
import { ReplaceDonationItemsDto } from '../donationItems/dtos/create-donation-items.dto';
import { FoodType } from '../donationItems/types';
Expand Down Expand Up @@ -135,9 +135,9 @@ describe('DonationsController', () => {
});

describe('PATCH /:donationId/item-details', () => {
it('calls confirmDonationItemDetails with the correct donationId and body, returns result', async () => {
it('calls updateDonationItemDetails with the correct donationId and body, returns result', async () => {
const donationId = 1;
const body: ConfirmDonationItemDetailsDto[] = [
const body: UpdateDonationItemDetailsDto[] = [
{
itemId: 1,
ozPerItem: 5.0,
Expand All @@ -152,18 +152,18 @@ describe('DonationsController', () => {
},
];

mockDonationService.confirmDonationItemDetails.mockResolvedValueOnce(
mockDonationService.updateDonationItemDetails.mockResolvedValueOnce(
donation1 as Donation,
);

const result = await controller.confirmDonationItemDetails(
const result = await controller.updateDonationItemDetails(
donationId,
body,
);

expect(result).toEqual(donation1);
expect(
mockDonationService.confirmDonationItemDetails,
mockDonationService.updateDonationItemDetails,
).toHaveBeenCalledWith(donationId, body);
});
});
Expand Down
10 changes: 5 additions & 5 deletions apps/backend/src/donations/donations.controller.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ import { Donation } from './donations.entity';
import { DonationService } from './donations.service';
import { RecurrenceEnum } from './types';
import { CreateDonationDto } from './dtos/create-donation.dto';
import { ConfirmDonationItemDetailsDto } from '../donationItems/dtos/confirm-donation-item-details.dto';
import { UpdateDonationItemDetailsDto } from '../donationItems/dtos/update-donation-item-details.dto';
import { FoodType } from '../donationItems/types';
import { ReplaceDonationItemsDto } from '../donationItems/dtos/create-donation-items.dto';

Expand Down Expand Up @@ -103,12 +103,12 @@ export class DonationsController {
}

@Patch('/:donationId/item-details')
async confirmDonationItemDetails(
async updateDonationItemDetails(
@Param('donationId', ParseIntPipe) donationId: number,
@Body(new ParseArrayPipe({ items: ConfirmDonationItemDetailsDto }))
body: ConfirmDonationItemDetailsDto[],
@Body(new ParseArrayPipe({ items: UpdateDonationItemDetailsDto }))
body: UpdateDonationItemDetailsDto[],
): Promise<Donation> {
return this.donationService.confirmDonationItemDetails(donationId, body);
return this.donationService.updateDonationItemDetails(donationId, body);
}

@Put('/:donationId/items')
Expand Down
Loading
Loading