( cur: PgSchema, prev: PgSchema, )
| 407 | }; |
| 408 | |
| 409 | export const preparePgPush = async ( |
| 410 | cur: PgSchema, |
| 411 | prev: PgSchema, |
| 412 | ) => { |
| 413 | const validatedPrev = pgSchema.parse(prev); |
| 414 | const validatedCur = pgSchema.parse(cur); |
| 415 | |
| 416 | const squashedPrev = squashPgScheme(validatedPrev, 'push'); |
| 417 | const squashedCur = squashPgScheme(validatedCur, 'push'); |
| 418 | |
| 419 | const { sqlStatements, statements, _meta } = await applyPgSnapshotsDiff( |
| 420 | squashedPrev, |
| 421 | squashedCur, |
| 422 | schemasResolver, |
| 423 | enumsResolver, |
| 424 | sequencesResolver, |
| 425 | policyResolver, |
| 426 | indPolicyResolver, |
| 427 | roleResolver, |
| 428 | tablesResolver, |
| 429 | columnsResolver, |
| 430 | viewsResolver, |
| 431 | validatedPrev, |
| 432 | validatedCur, |
| 433 | 'push', |
| 434 | ); |
| 435 | |
| 436 | return { sqlStatements, statements, squashedPrev, squashedCur }; |
| 437 | }; |
| 438 | |
| 439 | // Not needed for now |
| 440 | function mysqlSchemaSuggestions( |
no test coverage detected