67 lines
2.1 KiB
JavaScript
67 lines
2.1 KiB
JavaScript
|
const migrate_name = "wireguard_multi_server";
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Migration to add multi-server support to WireGuard tables
|
||
|
|
*/
|
||
|
|
export async function up(knex) {
|
||
|
|
// First, check if the tables exist
|
||
|
|
const hasInterfaceTable = await knex.schema.hasTable("wg_interface");
|
||
|
|
const hasClientTable = await knex.schema.hasTable("wg_client");
|
||
|
|
|
||
|
|
if (!hasInterfaceTable || !hasClientTable) {
|
||
|
|
throw new Error("Missing wg_interface or wg_client tables. Ensure previous migrations ran.");
|
||
|
|
}
|
||
|
|
|
||
|
|
// 1. Add isolate_clients to wg_interface
|
||
|
|
await knex.schema.alterTable("wg_interface", (table) => {
|
||
|
|
table.boolean("isolate_clients").notNullable().defaultTo(false);
|
||
|
|
});
|
||
|
|
|
||
|
|
// 2. Add interface_id to wg_client
|
||
|
|
await knex.schema.alterTable("wg_client", (table) => {
|
||
|
|
table.integer("interface_id").unsigned().nullable(); // Initially nullable to allow adding
|
||
|
|
});
|
||
|
|
|
||
|
|
// 3. Assign existing clients to the first interface (wg0)
|
||
|
|
const firstInterface = await knex("wg_interface").orderBy("id").first();
|
||
|
|
|
||
|
|
if (firstInterface) {
|
||
|
|
await knex("wg_client").whereNull("interface_id").update({
|
||
|
|
interface_id: firstInterface.id,
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
// 4. Make interface_id not nullable and add foreign key
|
||
|
|
await knex.schema.alterTable("wg_client", (table) => {
|
||
|
|
table.integer("interface_id")
|
||
|
|
.unsigned()
|
||
|
|
.notNullable()
|
||
|
|
.references("id")
|
||
|
|
.inTable("wg_interface")
|
||
|
|
.onDelete("CASCADE")
|
||
|
|
.alter();
|
||
|
|
});
|
||
|
|
|
||
|
|
// 5. Create wg_server_link for server peering
|
||
|
|
await knex.schema.createTable("wg_server_link", (table) => {
|
||
|
|
table.integer("interface_id_1").unsigned().notNullable()
|
||
|
|
.references("id").inTable("wg_interface").onDelete("CASCADE");
|
||
|
|
table.integer("interface_id_2").unsigned().notNullable()
|
||
|
|
.references("id").inTable("wg_interface").onDelete("CASCADE");
|
||
|
|
table.primary(["interface_id_1", "interface_id_2"]);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
export async function down(knex) {
|
||
|
|
await knex.schema.dropTableIfExists("wg_server_link");
|
||
|
|
|
||
|
|
await knex.schema.alterTable("wg_client", (table) => {
|
||
|
|
table.dropForeign("interface_id");
|
||
|
|
table.dropColumn("interface_id");
|
||
|
|
});
|
||
|
|
|
||
|
|
await knex.schema.alterTable("wg_interface", (table) => {
|
||
|
|
table.dropColumn("isolate_clients");
|
||
|
|
});
|
||
|
|
}
|