asyavee/medusa-store
1
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

fix(medusa): fix missing throw in the store cart create-payment-sessions (#2568)

Browse Source
This commit is contained in:
Adrien de Peretti
2022-11-09 16:47:17 +01:00
committed by GitHub
parent 8069ed5e99
commit 2d095a0ce1
2 changed files with 62 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
.changeset/breezy-candles-know.md Normal file
View File

@@ -0,0 +1,5 @@
---
"@medusajs/medusa": patch
---
fix(medusa): fix missing throw in the store cart create-payment-sessions

115
packages/medusa/src/api/routes/store/carts/create-payment-sessions.ts
View File

@@ -72,67 +72,66 @@ export default async (req, res) => {
res.setHeader("Access-Control-Expose-Headers", "Idempotency-Key")
res.setHeader("Idempotency-Key", idempotencyKey.idempotency_key)
try {
let inProgress = true
let err: unknown = false
let inProgress = true
let err: unknown = false
while (inProgress) {
switch (idempotencyKey.recovery_point) {
case "started": {
await manager
.transaction("SERIALIZABLE", async (transactionManager) => {
idempotencyKey = await idempotencyKeyService
.withTransaction(transactionManager)
.workStage(
idempotencyKey.idempotency_key,
async (stageManager) => {
await cartService
.withTransaction(stageManager)
.setPaymentSessions(id)
const cart = await cartService
.withTransaction(stageManager)
.retrieveWithTotals(id, {
select: defaultStoreCartFields,
relations: defaultStoreCartRelations,
})
return {
response_code: 200,
response_body: { cart },
}
}
)
})
.catch((e) => {
inProgress = false
err = e
})
break
}
case "finished": {
inProgress = false
break
}
default:
await manager.transaction(async (transactionManager) => {
while (inProgress) {
switch (idempotencyKey.recovery_point) {
case "started": {
await manager
.transaction("SERIALIZABLE", async (transactionManager) => {
idempotencyKey = await idempotencyKeyService
.withTransaction(transactionManager)
.update(idempotencyKey.idempotency_key, {
recovery_point: "finished",
response_code: 500,
response_body: { message: "Unknown recovery point" },
})
})
break
}
}
.workStage(
idempotencyKey.idempotency_key,
async (stageManager) => {
await cartService
.withTransaction(stageManager)
.setPaymentSessions(id)
res.status(idempotencyKey.response_code).json(idempotencyKey.response_body)
} catch (e) {
console.log(e)
throw e
const cart = await cartService
.withTransaction(stageManager)
.retrieveWithTotals(id, {
select: defaultStoreCartFields,
relations: defaultStoreCartRelations,
})
return {
response_code: 200,
response_body: { cart },
}
}
)
})
.catch((e) => {
inProgress = false
err = e
})
break
}
case "finished": {
inProgress = false
break
}
default:
await manager.transaction(async (transactionManager) => {
idempotencyKey = await idempotencyKeyService
.withTransaction(transactionManager)
.update(idempotencyKey.idempotency_key, {
recovery_point: "finished",
response_code: 500,
response_body: { message: "Unknown recovery point" },
})
})
break
}
}
if (err) {
throw err
}
res.status(idempotencyKey.response_code).json(idempotencyKey.response_body)
}