mirror/fosrl.pangolin
1
0
Fork 0
mirror of https://github.com/fosrl/pangolin.git synced 2025-07-28 22:55:07 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fixes to sqlite migration

Browse source
This commit is contained in:
miloschwartz 2025-07-16 11:47:05 -07:00
parent 021bc073a2
commit d1489a9a78
No known key found for this signature in database
2 changed files with 30 additions and 27 deletions
Download patch file Download diff file Expand all files Collapse all files

2
server/lib/consts.ts
View file

@ -2,7 +2,7 @@ import path from "path";
import { fileURLToPath } from "url"; import { fileURLToPath } from "url";
// This is a placeholder value replaced by the build process // This is a placeholder value replaced by the build process
export const APP_VERSION = "1.6.0"; export const APP_VERSION = "1.7.0";
export const __FILENAME = fileURLToPath(import.meta.url); export const __FILENAME = fileURLToPath(import.meta.url);
export const __DIRNAME = path.dirname(__FILENAME); export const __DIRNAME = path.dirname(__FILENAME);

33
server/setup/scriptsSqlite/1.7.0.ts
View file

@ -16,7 +16,7 @@ export default async function migration() {
CREATE TABLE 'clientSites' ( CREATE TABLE 'clientSites' (
'clientId' integer NOT NULL, 'clientId' integer NOT NULL,
'siteId' integer NOT NULL, 'siteId' integer NOT NULL,
'isRelayed' integer DEFAULT false NOT NULL, 'isRelayed' integer DEFAULT 0 NOT NULL,
FOREIGN KEY ('clientId') REFERENCES 'clients'('id') ON UPDATE no action ON DELETE cascade, FOREIGN KEY ('clientId') REFERENCES 'clients'('id') ON UPDATE no action ON DELETE cascade,
FOREIGN KEY ('siteId') REFERENCES 'sites'('siteId') ON UPDATE no action ON DELETE cascade FOREIGN KEY ('siteId') REFERENCES 'sites'('siteId') ON UPDATE no action ON DELETE cascade
); );
@ -33,7 +33,7 @@ export default async function migration() {
'lastBandwidthUpdate' text, 'lastBandwidthUpdate' text,
'lastPing' text, 'lastPing' text,
'type' text NOT NULL, 'type' text NOT NULL,
'online' integer DEFAULT false NOT NULL, 'online' integer DEFAULT 0 NOT NULL,
'endpoint' text, 'endpoint' text,
'lastHolePunch' integer, 'lastHolePunch' integer,
FOREIGN KEY ('orgId') REFERENCES 'orgs'('orgId') ON UPDATE no action ON DELETE cascade, FOREIGN KEY ('orgId') REFERENCES 'orgs'('orgId') ON UPDATE no action ON DELETE cascade,
@ -98,10 +98,9 @@ export default async function migration() {
); );
`); `);
})(); // <-- executes the transaction immediately
db.pragma("foreign_keys = OFF"); db.pragma("foreign_keys = OFF");
db.transaction(() => {
db.exec(` db.exec(`
CREATE TABLE '__new_sites' ( CREATE TABLE '__new_sites' (
'siteId' integer PRIMARY KEY AUTOINCREMENT NOT NULL, 'siteId' integer PRIMARY KEY AUTOINCREMENT NOT NULL,
@ -115,41 +114,45 @@ export default async function migration() {
'bytesOut' integer DEFAULT 0, 'bytesOut' integer DEFAULT 0,
'lastBandwidthUpdate' text, 'lastBandwidthUpdate' text,
'type' text NOT NULL, 'type' text NOT NULL,
'online' integer DEFAULT false NOT NULL, 'online' integer DEFAULT 0 NOT NULL,
'address' text, 'address' text,
'endpoint' text, 'endpoint' text,
'publicKey' text, 'publicKey' text,
'lastHolePunch' integer, 'lastHolePunch' integer,
'listenPort' integer, 'listenPort' integer,
'dockerSocketEnabled' integer DEFAULT true NOT NULL, 'dockerSocketEnabled' integer DEFAULT 1 NOT NULL,
FOREIGN KEY ('orgId') REFERENCES 'orgs'('orgId') ON UPDATE no action ON DELETE cascade, FOREIGN KEY ('orgId') REFERENCES 'orgs'('orgId') ON UPDATE no action ON DELETE cascade,
FOREIGN KEY ('exitNode') REFERENCES 'exitNodes'('exitNodeId') ON UPDATE no action ON DELETE set null FOREIGN KEY ('exitNode') REFERENCES 'exitNodes'('exitNodeId') ON UPDATE no action ON DELETE set null
); );
INSERT INTO '__new_sites'("siteId", "orgId", "niceId", "exitNode", "name", "pubKey", "subnet", "bytesIn", "bytesOut", "lastBandwidthUpdate", "type", "online", "address", "endpoint", "publicKey", "lastHolePunch", "listenPort", "dockerSocketEnabled") SELECT "siteId", "orgId", "niceId", "exitNode", "name", "pubKey", "subnet", "bytesIn", "bytesOut", "lastBandwidthUpdate", "type", "online", "address", "endpoint", "publicKey", "lastHolePunch", "listenPort", "dockerSocketEnabled" FROM 'sites'; INSERT INTO '__new_sites' (
'siteId', 'orgId', 'niceId', 'exitNode', 'name', 'pubKey', 'subnet', 'bytesIn', 'bytesOut', 'lastBandwidthUpdate', 'type', 'online', 'address', 'endpoint', 'publicKey', 'lastHolePunch', 'listenPort', 'dockerSocketEnabled'
)
SELECT siteId, orgId, niceId, exitNode, name, pubKey, subnet, bytesIn, bytesOut, lastBandwidthUpdate, type, online, NULL, NULL, NULL, NULL, NULL, dockerSocketEnabled
FROM sites;
DROP TABLE 'sites'; DROP TABLE 'sites';
ALTER TABLE '__new_sites' RENAME TO 'sites'; ALTER TABLE '__new_sites' RENAME TO 'sites';
`); `);
})(); // <-- executes the transaction immediately
db.pragma("foreign_keys = ON");
db.transaction(() => { db.pragma("foreign_keys = ON");
db.exec(` db.exec(`
ALTER TABLE 'domains' ADD 'type' text; ALTER TABLE 'domains' ADD 'type' text;
ALTER TABLE 'domains' ADD 'verified' integer DEFAULT false NOT NULL; ALTER TABLE 'domains' ADD 'verified' integer DEFAULT 0 NOT NULL;
ALTER TABLE 'domains' ADD 'failed' integer DEFAULT false NOT NULL; ALTER TABLE 'domains' ADD 'failed' integer DEFAULT 0 NOT NULL;
ALTER TABLE 'domains' ADD 'tries' integer DEFAULT 0 NOT NULL; ALTER TABLE 'domains' ADD 'tries' integer DEFAULT 0 NOT NULL;
ALTER TABLE 'exitNodes' ADD 'maxConnections' integer; ALTER TABLE 'exitNodes' ADD 'maxConnections' integer;
ALTER TABLE 'newt' ADD 'version' text; ALTER TABLE 'newt' ADD 'version' text;
ALTER TABLE 'orgs' ADD 'subnet' text NOT NULL; ALTER TABLE 'orgs' ADD 'subnet' text NOT NULL;
ALTER TABLE 'user' ADD 'twoFactorSetupRequested' integer DEFAULT false; ALTER TABLE 'user' ADD 'twoFactorSetupRequested' integer DEFAULT 0;
ALTER TABLE 'resources' DROP COLUMN 'isBaseDomain'; ALTER TABLE 'resources' DROP COLUMN 'isBaseDomain';
`); `);
})(); // <-- executes the transaction immediately })(); // <-- executes the transaction immediately
console.log(`Migrated database schema`); console.log(`Migrated database schema`);
} catch (e) { } catch (e) {
console.log("Unable to migrate database schema"); console.log("Unable to migrate database schema");
console.log(e); throw e;
} }
console.log(`${version} migration complete`); console.log(`${version} migration complete`);