From c18703eba2fb951db349a9e50099155bb5f58be2 Mon Sep 17 00:00:00 2001
From: sagit <sagitchu@gmail.com>
Date: Mon, 9 Feb 2026 12:30:40 +0000
Subject: [PATCH] fix(backend): ensure all tables exist on startup via
 schema.sql

Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-opencode)

Co-authored-by: Sisyphus <clio-agent@sisyphuslabs.ai>
---
 .../internal/store/sqlite/repository.go       | 25 +++----------------
 .../internal/store/sqlite/sql/schema.sql      | 23 ++++++++++++++++-
 2 files changed, 25 insertions(+), 23 deletions(-)

diff --git a/go-backend/internal/store/sqlite/repository.go b/go-backend/internal/store/sqlite/repository.go
index e4a49b3..39cab75 100644
--- a/go-backend/internal/store/sqlite/repository.go
+++ b/go-backend/internal/store/sqlite/repository.go
@@ -144,7 +144,7 @@ func Open(path string) (*Repository, error) {
 		return nil, err
 	}
 
-	if err := ensurePeerSchema(db); err != nil {
+	if err := migrateSchema(db); err != nil {
 		_ = db.Close()
 		return nil, err
 	}
@@ -1222,33 +1222,14 @@ func bootstrapSchema(db *sql.DB) error {
 	return nil
 }
 
-func ensurePeerSchema(db *sql.DB) error {
+func migrateSchema(db *sql.DB) error {
 	if db == nil {
 		return errors.New("nil db")
 	}
 
-	_, err := db.Exec(`CREATE TABLE IF NOT EXISTS peer_share (
-		id INTEGER PRIMARY KEY AUTOINCREMENT,
-		name TEXT NOT NULL,
-		node_id INTEGER NOT NULL,
-		token TEXT NOT NULL UNIQUE,
-		max_bandwidth INTEGER DEFAULT 0,
-		expiry_time INTEGER DEFAULT 0,
-		port_range_start INTEGER DEFAULT 0,
-		port_range_end INTEGER DEFAULT 0,
-		current_flow INTEGER DEFAULT 0,
-		is_active INTEGER DEFAULT 1,
-		created_time INTEGER NOT NULL,
-		updated_time INTEGER NOT NULL,
-		allowed_domains TEXT DEFAULT ''
-	)`)
-	if err != nil {
-		return fmt.Errorf("create peer_share: %w", err)
-	}
-
 	// Add allowed_domains column if it doesn't exist (for existing tables)
 	var dummy interface{}
-	err = db.QueryRow("SELECT allowed_domains FROM peer_share LIMIT 1").Scan(&dummy)
+	err := db.QueryRow("SELECT allowed_domains FROM peer_share LIMIT 1").Scan(&dummy)
 	if err != nil {
 		if strings.Contains(err.Error(), "no such column") {
 			_, err = db.Exec("ALTER TABLE peer_share ADD COLUMN allowed_domains TEXT DEFAULT ''")
diff --git a/go-backend/internal/store/sqlite/sql/schema.sql b/go-backend/internal/store/sqlite/sql/schema.sql
index efeca39..bb8a100 100644
--- a/go-backend/internal/store/sqlite/sql/schema.sql
+++ b/go-backend/internal/store/sqlite/sql/schema.sql
@@ -42,7 +42,11 @@ CREATE TABLE IF NOT EXISTS node (
   status INTEGER NOT NULL,
   tcp_listen_addr VARCHAR(100) NOT NULL DEFAULT '[::]',
   udp_listen_addr VARCHAR(100) NOT NULL DEFAULT '[::]',
-  inx INTEGER NOT NULL DEFAULT 0
+  inx INTEGER NOT NULL DEFAULT 0,
+  is_remote INTEGER DEFAULT 0,
+  remote_url TEXT,
+  remote_token TEXT,
+  remote_config TEXT
 );
 
 CREATE TABLE IF NOT EXISTS speed_limit (
@@ -181,3 +185,20 @@ CREATE TABLE IF NOT EXISTS vite_config (
   value VARCHAR(200) NOT NULL,
   time INTEGER NOT NULL
 );
+
+CREATE TABLE IF NOT EXISTS peer_share (
+    id INTEGER PRIMARY KEY AUTOINCREMENT,
+    name TEXT NOT NULL,
+    node_id INTEGER NOT NULL,
+    token TEXT NOT NULL UNIQUE,
+    max_bandwidth INTEGER DEFAULT 0,
+    expiry_time INTEGER DEFAULT 0,
+    port_range_start INTEGER DEFAULT 0,
+    port_range_end INTEGER DEFAULT 0,
+    current_flow INTEGER DEFAULT 0,
+    is_active INTEGER DEFAULT 1,
+    created_time INTEGER NOT NULL,
+    updated_time INTEGER NOT NULL,
+    allowed_domains TEXT DEFAULT ''
+);
+