Initial commit: Wake-on-LAN Manager mit Go und Web-Oberfläche

2025-08-21 13:36:43 +02:00
commit f015e845a9
13 changed files with 1407 additions and 0 deletions
--- a/internal/database/database.go
+++ b/internal/database/database.go
@@ -0,0 +1,127 @@
+package database
+
+import (
+	"database/sql"
+	"log"
+	"medi-wol/internal/models"
+	"time"
+
+	_ "modernc.org/sqlite"
+)
+
+// DB ist die Datenbankverbindung
+type DB struct {
+	*sql.DB
+}
+
+// InitDB initialisiert die Datenbank und erstellt die Tabellen
+func InitDB() (*DB, error) {
+	db, err := sql.Open("sqlite", "./medi-wol.db")
+	if err != nil {
+		return nil, err
+	}
+
+	// Tabelle erstellen
+	createTableSQL := `
+	CREATE TABLE IF NOT EXISTS pcs (
+		id INTEGER PRIMARY KEY AUTOINCREMENT,
+		name TEXT NOT NULL,
+		mac TEXT NOT NULL UNIQUE,
+		created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+		updated_at DATETIME DEFAULT CURRENT_TIMESTAMP
+	);`
+
+	_, err = db.Exec(createTableSQL)
+	if err != nil {
+		return nil, err
+	}
+
+	log.Println("Datenbank erfolgreich initialisiert")
+	return &DB{db}, nil
+}
+
+// GetAllPCs holt alle PCs aus der Datenbank
+func (db *DB) GetAllPCs() ([]models.PC, error) {
+	rows, err := db.Query("SELECT id, name, mac, created_at, updated_at FROM pcs ORDER BY name")
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+
+	var pcs []models.PC
+	for rows.Next() {
+		var pc models.PC
+		err := rows.Scan(&pc.ID, &pc.Name, &pc.MAC, &pc.CreatedAt, &pc.UpdatedAt)
+		if err != nil {
+			return nil, err
+		}
+		pcs = append(pcs, pc)
+	}
+
+	return pcs, nil
+}
+
+// CreatePC erstellt einen neuen PC-Eintrag
+func (db *DB) CreatePC(name, mac string) (*models.PC, error) {
+	now := time.Now()
+	result, err := db.Exec(
+		"INSERT INTO pcs (name, mac, created_at, updated_at) VALUES (?, ?, ?, ?)",
+		name, mac, now, now,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	id, err := result.LastInsertId()
+	if err != nil {
+		return nil, err
+	}
+
+	return &models.PC{
+		ID:        int(id),
+		Name:      name,
+		MAC:       mac,
+		CreatedAt: now,
+		UpdatedAt: now,
+	}, nil
+}
+
+// UpdatePC aktualisiert einen bestehenden PC-Eintrag
+func (db *DB) UpdatePC(id int, name, mac string) (*models.PC, error) {
+	now := time.Now()
+	_, err := db.Exec(
+		"UPDATE pcs SET name = ?, mac = ?, updated_at = ? WHERE id = ?",
+		name, mac, now, id,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	return &models.PC{
+		ID:        id,
+		Name:      name,
+		MAC:       mac,
+		UpdatedAt: now,
+	}, nil
+}
+
+// DeletePC löscht einen PC-Eintrag
+func (db *DB) DeletePC(id int) error {
+	_, err := db.Exec("DELETE FROM pcs WHERE id = ?", id)
+	return err
+}
+
+// GetPCByID holt einen PC anhand der ID
+func (db *DB) GetPCByID(id int) (*models.PC, error) {
+	var pc models.PC
+	err := db.QueryRow(
+		"SELECT id, name, mac, created_at, updated_at FROM pcs WHERE id = ?",
+		id,
+	).Scan(&pc.ID, &pc.Name, &pc.MAC, &pc.CreatedAt, &pc.UpdatedAt)
+
+	if err != nil {
+		return nil, err
+	}
+
+	return &pc, nil
+}