await client
.$transaction(
async (tx) =>
await Promise.all(
records.map(([reference, quantity, _]) =>
tx.part.upsert({
where: { reference },
update: {
quantity: parseInt(quantity),
history: {
create: { date: file.date, quantity: parseInt(quantity) },
},
},
create: {
reference,
quantity: parseInt(quantity),
supplier: { connect: { id: info.id } },
history: {
create: { date: file.date, quantity: parseInt(quantity) },
},
},
})
)
),
{
timeout: 300000,
}
)
.catch((err) => {
console.error(err)
})
await client
.$transaction(
async (tx) =>
await Promise.all(
records.map(([reference, quantity, _]) =>
tx.part.upsert({
where: { reference },
update: {
quantity: parseInt(quantity),
history: {
create: { date: file.date, quantity: parseInt(quantity) },
},
},
create: {
reference,
quantity: parseInt(quantity),
supplier: { connect: { id: info.id } },
history: {
create: { date: file.date, quantity: parseInt(quantity) },
},
},
})
)
),
{
timeout: 300000,
}
)
.catch((err) => {
console.error(err)
})