Added actors avatars migration to repo.
This commit is contained in:
parent
bed267b0b0
commit
c2fa571aa0
|
@ -0,0 +1,75 @@
|
|||
exports.up = async function(knex) {
|
||||
// restore avatars in table in case of rollback and rerun
|
||||
const avatars = await knex('actors_avatars')
|
||||
.select('actors_avatars.*', 'actors_profiles.actor_id')
|
||||
.leftJoin('actors_profiles', 'actors_profiles.id', 'actors_avatars.profile_id');
|
||||
|
||||
await knex('actors_avatars').delete();
|
||||
|
||||
await knex.schema.alterTable('actors_avatars', (table) => {
|
||||
table.integer('profile_id')
|
||||
.nullable()
|
||||
.alter();
|
||||
|
||||
table.integer('actor_id')
|
||||
.notNullable()
|
||||
.references('id')
|
||||
.inTable('actors');
|
||||
|
||||
table.datetime('created_at')
|
||||
.notNullable()
|
||||
.defaultTo(knex.fn.now());
|
||||
|
||||
table.dropUnique('profile_id');
|
||||
table.unique(['profile_id', 'media_id']);
|
||||
});
|
||||
|
||||
await knex.schema.alterTable('media', (table) => {
|
||||
// actor avatars often retain the same URL when updated, handle URL-deduping in app code
|
||||
table.dropUnique('source');
|
||||
table.string('source_version'); // usually etag
|
||||
});
|
||||
|
||||
await knex.raw('CREATE UNIQUE INDEX unique_main_avatars ON actors_avatars (actor_id) WHERE (profile_id IS NULL);');
|
||||
|
||||
if (avatars.length > 0) {
|
||||
await knex('actors_avatars').insert(avatars);
|
||||
}
|
||||
|
||||
const profiles = await knex('actors_profiles')
|
||||
.select('id', 'actor_id', 'avatar_media_id')
|
||||
.whereNotNull('avatar_media_id');
|
||||
|
||||
await knex('actors_avatars')
|
||||
.insert(profiles.map((profile) => ({
|
||||
actor_id: profile.actor_id,
|
||||
profile_id: profile.id,
|
||||
media_id: profile.avatar_media_id,
|
||||
})))
|
||||
.onConflict()
|
||||
.ignore();
|
||||
};
|
||||
|
||||
exports.down = async function(knex) {
|
||||
// no need to delete all entries, only the ones incompatible with the old scheme
|
||||
await knex('actors_avatars')
|
||||
.whereNull('profile_id')
|
||||
.delete();
|
||||
|
||||
await knex.schema.alterTable('actors_avatars', (table) => {
|
||||
table.integer('profile_id')
|
||||
.notNullable()
|
||||
.alter();
|
||||
|
||||
table.dropColumn('actor_id');
|
||||
table.dropColumn('created_at');
|
||||
|
||||
table.unique('profile_id');
|
||||
table.dropUnique(['profile_id', 'media_id']);
|
||||
});
|
||||
|
||||
await knex.schema.alterTable('media', (table) => {
|
||||
table.dropColumn('source_version');
|
||||
table.unique('source');
|
||||
});
|
||||
};
|
Loading…
Reference in New Issue