-
Notifications
You must be signed in to change notification settings - Fork 3
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Migrate Old Submissions to New Contract+Rates relationship tables (#2382
- Loading branch information
Showing
3 changed files
with
409 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
184 changes: 184 additions & 0 deletions
184
...p-api/src/dataMigrations/migrations/20240422103442_migrate_contract_rate_relationships.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,184 @@ | ||
| import type { PrismaTransactionType } from '../../postgres/prismaTypes' | ||
|
|
||
| export async function migrate( | ||
| client: PrismaTransactionType, | ||
| contractIDs?: string[] | ||
| ): Promise<Error | undefined> { | ||
| // get all the old contract x rate relationships and splat them into the new tables | ||
| try { | ||
| const contracts = await client.contractTable.findMany({ | ||
| where: contractIDs | ||
| ? { | ||
| id: { in: contractIDs }, | ||
| } | ||
| : undefined, | ||
| include: { | ||
| revisions: { | ||
| include: { | ||
| submitInfo: true, | ||
| unlockInfo: true, | ||
| relatedSubmisions: true, | ||
| rateRevisions: { | ||
| orderBy: { | ||
| validAfter: 'asc', | ||
| }, | ||
| include: { | ||
| rateRevision: { | ||
| include: { | ||
| submitInfo: true, | ||
| unlockInfo: true, | ||
| rateDocuments: true, | ||
| rate: true, | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| }, | ||
| orderBy: { | ||
| createdAt: 'asc', | ||
| }, | ||
| }, | ||
| }, | ||
| }) | ||
|
|
||
| const unmigrateRevisions = [] | ||
| for (const contract of contracts) { | ||
| for (const contractRev of contract.revisions) { | ||
| if (contractRev.relatedSubmisions.length > 0) { | ||
| continue | ||
| } | ||
| unmigrateRevisions.push(contractRev) | ||
| } | ||
| } | ||
|
|
||
| for (const contractRev of unmigrateRevisions) { | ||
| const allLinkedRates = contractRev.rateRevisions | ||
|
|
||
| const contractSubmissionTime = contractRev.submitInfo?.updatedAt | ||
|
|
||
| if (contractSubmissionTime) { | ||
| // we're in a submitted contract rev | ||
| let firstRateLinkTime: Date | undefined = undefined | ||
| const concurrentlySubmittedRateLinks = allLinkedRates | ||
| .filter((linkedRate) => { | ||
| if (linkedRate.isRemoval) { | ||
| return false | ||
| } | ||
|
|
||
| const rateSubmissionTime = linkedRate.validAfter | ||
|
|
||
| if (!firstRateLinkTime) { | ||
| firstRateLinkTime = rateSubmissionTime | ||
| return true | ||
| } | ||
|
|
||
| if ( | ||
| Math.abs( | ||
| rateSubmissionTime.getTime() - | ||
| firstRateLinkTime.getTime() | ||
| ) < 1000 | ||
| ) { | ||
| return true | ||
| } else { | ||
| return false | ||
| } | ||
| }) | ||
| .map((rr) => rr.rateRevision) | ||
|
|
||
| // we need to sort by rate created at to make this right, something was wrong with the hack, shocker | ||
| concurrentlySubmittedRateLinks.sort( | ||
| (a, b) => | ||
| a.rate.createdAt.getTime() - b.rate.createdAt.getTime() | ||
| ) | ||
|
|
||
| const concurrentRateIDs = concurrentlySubmittedRateLinks.map( | ||
| (r) => r.rateID | ||
| ) | ||
| const rateIDSet: { [id: string]: boolean } = {} | ||
| for (const rID of concurrentRateIDs) { | ||
| rateIDSet[rID] = true | ||
| } | ||
| if (concurrentRateIDs.length != Object.keys(rateIDSet).length) { | ||
| console.error( | ||
| 'found a collision!', | ||
| contractRev.id, | ||
| concurrentRateIDs | ||
| ) | ||
| throw new Error('found a collision') | ||
| } | ||
|
|
||
| const contractSubmissionID = contractRev.submitInfoID | ||
| if (!contractSubmissionID) { | ||
| throw new Error('Better have an id, we had one above') | ||
| } | ||
|
|
||
| // add contract+submitinfo to related contract submissions | ||
| await client.contractRevisionTable.update({ | ||
| where: { | ||
| id: contractRev.id, | ||
| }, | ||
| data: { | ||
| relatedSubmisions: { | ||
| connect: { | ||
| id: contractSubmissionID, | ||
| }, | ||
| }, | ||
| }, | ||
| include: { | ||
| relatedSubmisions: true, | ||
| }, | ||
| }) | ||
|
|
||
| let ratePosition = 1 | ||
| for (const rateRev of concurrentlySubmittedRateLinks) { | ||
| const oldSubmitInfoID = rateRev.submitInfo?.id | ||
|
|
||
| // set the submitInfo on each rate to be the same ID as the contract’s | ||
| // add rates+submitInfo to related rate submissions | ||
| // add join entries with rate position for contract + update info + rate rev. | ||
| await client.rateRevisionTable.update({ | ||
| where: { | ||
| id: rateRev.id, | ||
| }, | ||
| data: { | ||
| submitInfoID: contractSubmissionID, | ||
| relatedSubmissions: { | ||
| connect: { | ||
| id: contractSubmissionID, | ||
| }, | ||
| }, | ||
| submissionPackages: { | ||
| create: { | ||
| submissionID: contractSubmissionID, | ||
| contractRevisionID: contractRev.id, | ||
| ratePosition: ratePosition, | ||
| }, | ||
| }, | ||
| }, | ||
| }) | ||
|
|
||
| if (!oldSubmitInfoID) { | ||
| throw new Error( | ||
| 'Better have an old submit id, we had one above' | ||
| ) | ||
| } | ||
| if (oldSubmitInfoID !== contractSubmissionID) { | ||
| // ignore updateInfos we've already deleted | ||
| await client.updateInfoTable.deleteMany({ | ||
| where: { | ||
| id: oldSubmitInfoID, | ||
| }, | ||
| }) | ||
| } | ||
|
|
||
| ratePosition++ | ||
| } | ||
| } | ||
| } | ||
| } catch (err) { | ||
| console.error('Prisma Error: ', err) | ||
| return err | ||
| } | ||
|
|
||
| return undefined | ||
| } |
Oops, something went wrong.