speatzle/morffix
1
0
Fork 0
Code Issues Pull requests Projects Releases 2 Packages Wiki Activity Actions

Add Library and Transcode Options

Browse source
This commit is contained in:
Samuel Lorch 2024-06-22 21:01:20 +02:00
parent cdc94d551d
commit 249a415cee
12 changed files with 134 additions and 20 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
constants/constants.go
View file

@ -64,6 +64,7 @@ const (
FILE_STATUS_UNKNOWN FileStatus = iota
FILE_STATUS_MISSING
FILE_STATUS_EXISTS
FILE_STATUS_CHANGED
)
func (s FileStatus) String() string {
@ -74,6 +75,8 @@ func (s FileStatus) String() string {
return "Missing"
case FILE_STATUS_EXISTS:
return "Exists"
case FILE_STATUS_CHANGED:
return "Changed"
default:
return fmt.Sprintf("%d", int(s))
}
@ -99,3 +102,27 @@ func (s FileHealth) String() string {
return fmt.Sprintf("%d", int(s))
}
}
type FileTranscode int
const (
FILE_TRANSCODE_UNKNOWN FileTranscode = iota
FILE_TRANSCODE_NONE
FILE_TRANSCODE_FAILED
FILE_TRANSCODE_SUCCESS
)
func (s FileTranscode) String() string {
switch s {
case FILE_TRANSCODE_UNKNOWN:
return "Unknown"
case FILE_TRANSCODE_NONE:
return "None"
case FILE_TRANSCODE_FAILED:
return "Failed"
case FILE_TRANSCODE_SUCCESS:
return "Success"
default:
return fmt.Sprintf("%d", int(s))
}
}

2
migrations/000005_alter_task_table_updated_at.down.sql
View file

@ -1,2 +1,2 @@
ALTER TABLE tasks
DROP updated_at;
DROP IF EXISTS updated_at;

2
migrations/000010_alter_files_table_transcode.down.sql Normal file
View file

@ -0,0 +1,2 @@
ALTER TABLE files
DROP IF EXISTS transcode;

2
migrations/000010_alter_files_table_transcode.up.sql Normal file
View file

@ -0,0 +1,2 @@
ALTER TABLE files
ADD transcode smallint NOT NULL DEFAULT 1;

8
migrations/000011_alter_libraries_table_options.up.down.sql Normal file
View file

@ -0,0 +1,8 @@
ALTER TABLE libraries
DROP IF EXISTS scan_new_queue_health,
DROP IF EXISTS scan_changed_queue_health,
DROP IF EXISTS scan_new_queue_transcode,
DROP IF EXISTS scan_changed_queue_transcode,
DROP IF EXISTS health_ok_queue_transcode,
DROP IF EXISTS transcode_replace,
DROP IF EXISTS transcode_path;

8
migrations/000011_alter_libraries_table_options.up.sql Normal file
View file

@ -0,0 +1,8 @@
ALTER TABLE libraries
ADD scan_new_queue_health boolean NOT NULL DEFAULT false,
ADD scan_changed_queue_health boolean NOT NULL DEFAULT false,
ADD scan_new_queue_transcode boolean NOT NULL DEFAULT false,
ADD scan_changed_queue_transcode boolean NOT NULL DEFAULT false,
ADD health_ok_queue_transcode boolean NOT NULL DEFAULT false,
ADD transcode_replace boolean NOT NULL DEFAULT false,
ADD transcode_path VARCHAR (500) NOT NULL DEFAULT '';

27
server/libraries.go
View file

@ -15,10 +15,17 @@ type LibrariesData struct {
}
type Library struct {
ID string `db:"id"`
Name string `db:"name"`
Path string `db:"path"`
Enable bool `db:"enable"`
ID string `db:"id"`
Name string `db:"name"`
Path string `db:"path"`
Enable bool `db:"enable"`
TranscodeReplace bool `db:"transcode_replace"`
TranscodePath string `db:"transcode_path"`
ScanNewQueueHealth bool `db:"scan_new_queue_health"`
ScanChangedQueueHealth bool `db:"scan_changed_queue_health"`
ScanNewQueueTranscode bool `db:"scan_new_queue_transcode"`
ScanChangedQueueTranscode bool `db:"scan_changed_queue_transcode"`
HealthOkQueueTranscode bool `db:"health_ok_queue_transcode"`
}
func handleLibraries(w http.ResponseWriter, r *http.Request) {
@ -33,7 +40,7 @@ func handleLibraries(w http.ResponseWriter, r *http.Request) {
}
}
rows, err := db.Query(r.Context(), "SELECT id, name, path, enable FROM libraries")
rows, err := db.Query(r.Context(), "SELECT id, name, path, enable, scan_new_queue_health, scan_changed_queue_health, scan_new_queue_transcode, scan_changed_queue_transcode, health_ok_queue_transcode, transcode_replace, transcode_path FROM libraries")
if err != nil {
slog.ErrorContext(r.Context(), "Query Libraries", "err", err)
http.Error(w, "Error Query Libraries: "+err.Error(), http.StatusInternalServerError)
@ -69,9 +76,17 @@ func createLibrary(r *http.Request) error {
name := r.FormValue("name")
path := r.FormValue("path")
enable := r.FormValue("enable") == "on"
transcode_replace := r.FormValue("transcode_replace") == "on"
transcode_path := r.FormValue("transcode_path")
scan_new_queue_health := r.FormValue("scan_new_queue_health") == "on"
scan_changed_queue_health := r.FormValue("scan_changed_queue_health") == "on"
scan_new_queue_transcode := r.FormValue("scan_new_queue_transcode") == "on"
scan_changed_queue_transcode := r.FormValue("scan_changed_queue_transcode") == "on"
health_ok_queue_transcode := r.FormValue("health_ok_queue_transcode") == "on"
slog.Info("Got Library Create", "name", name, "path", path, "enable", enable)
_, err = db.Exec(r.Context(), "INSERT INTO Libraries (name, path, enable) VALUES ($1,$2,$3)", name, path, enable)
_, err = db.Exec(r.Context(), "INSERT INTO Libraries (name, path, enable, scan_new_queue_health, scan_changed_queue_health, scan_new_queue_transcode, scan_changed_queue_transcode, health_ok_queue_transcode, transcode_replace, transcode_path) VALUES ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10)", name, path, enable, scan_new_queue_health, scan_changed_queue_health, scan_new_queue_transcode, scan_changed_queue_transcode, health_ok_queue_transcode, transcode_replace, transcode_path)
if err != nil {
return fmt.Errorf("Inserting Library: %w", err)
}

19
server/library.go
View file

@ -17,13 +17,14 @@ type LibraryData struct {
}
type File struct {
ID int `db:"id"`
Path string `db:"path"`
Size int64 `db:"size"`
Status constants.FileStatus `db:"status"`
Health constants.FileHealth `db:"health"`
MD5 []byte `db:"md5"`
UpdatedAt time.Time `db:"updated_at"`
ID int `db:"id"`
Path string `db:"path"`
Size int64 `db:"size"`
Status constants.FileStatus `db:"status"`
Health constants.FileHealth `db:"health"`
Transcode constants.FileTranscode `db:"transcode"`
MD5 []byte `db:"md5"`
UpdatedAt time.Time `db:"updated_at"`
}
type FileDisplay struct {
@ -32,6 +33,7 @@ type FileDisplay struct {
Size int64
Status string
Health string
Transcode string
MD5 string
UpdatedAt string `db:"updated_at"`
}
@ -65,7 +67,7 @@ func handleLibrary(w http.ResponseWriter, r *http.Request) {
// TODO
}
rows, err := db.Query(r.Context(), "SELECT id, path, size, status, health, md5, updated_at FROM files where library_id = $1", id)
rows, err := db.Query(r.Context(), "SELECT id, path, size, status, health, transcode, md5, updated_at FROM files where library_id = $1", id)
if err != nil {
slog.ErrorContext(r.Context(), "Query Files", "err", err)
http.Error(w, "Error Query Files: "+err.Error(), http.StatusInternalServerError)
@ -85,6 +87,7 @@ func handleLibrary(w http.ResponseWriter, r *http.Request) {
Size: files[i].Size,
Status: files[i].Status.String(),
Health: files[i].Health.String(),
Transcode: files[i].Transcode.String(),
MD5: fmt.Sprintf("%x", files[i].MD5),
UpdatedAt: files[i].UpdatedAt.Format(time.DateTime),
})

2
server/task.go
View file

@ -82,7 +82,7 @@ func handleTasks(w http.ResponseWriter, r *http.Request) {
return
}
rows, err := db.Query(r.Context(), "SELECT id, name, path, enable FROM libraries WHERE enable = $1", true)
rows, err := db.Query(r.Context(), "SELECT id, name, path, enable, scan_new_queue_health, scan_changed_queue_health, scan_new_queue_transcode, scan_changed_queue_transcode, health_ok_queue_transcode, transcode_replace, transcode_path FROM libraries WHERE enable = $1", true)
if err != nil {
slog.ErrorContext(r.Context(), "Query Libraries", "err", err)
http.Error(w, "Error Query Libraries: "+err.Error(), http.StatusInternalServerError)

50
tmpl/libraries.tmpl
View file

@ -3,15 +3,25 @@
<table>
<tr>
<th>ID</th>
<th>Enabled</th>
<th>Name</th>
<th>Path</th>
<th>Enabled</th>
<th>TranscodeReplace</th>
<th>TranscodePath</th>
<th>ScanNewQueueHealth</th>
<th>ScanChangedQueueHealth</th>
<th>ScanNewQueueTranscode</th>
<th>ScanChangedQueueTranscode</th>
<th>HealthOkQueueTranscode</th>
</tr>
{{range $l := .Libraries}}
<tr onclick="window.location='/libraries/{{ $l.ID }}';">
<td>
{{ $l.ID }}
</td>
<td>
{{ $l.Enable }}
</td>
<td>
{{ $l.Name }}
</td>
@ -19,7 +29,25 @@
{{ $l.Path }}
</td>
<td>
{{ $l.Enable }}
{{ $l.TranscodeReplace }}
</td>
<td>
{{ $l.TranscodePath }}
</td>
<td>
{{ $l.ScanNewQueueHealth }}
</td>
<td>
{{ $l.ScanChangedQueueHealth }}
</td>
<td>
{{ $l.ScanNewQueueTranscode }}
</td>
<td>
{{ $l.ScanChangedQueueTranscode }}
</td>
<td>
{{ $l.HealthOkQueueTranscode }}
</td>
</tr>
{{end}}
@ -27,12 +55,26 @@
<h2>New Library</h2>
<form method="POST">
<label>Enable:</label>
<input type="checkbox" name="enable">
<label>Name:</label>
<input type="text" name="name">
<label>Path:</label>
<input type="text" name="path">
<label>Enable:</label>
<input type="checkbox" name="enable">
<label>Transcode Replace:</label>
<input type="checkbox" name="transcode_replace">
<label>Transcode Path:</label>
<input type="text" name="transcode_path">
<label>Queue Heathcheck for new files on Scan:</label>
<input type="checkbox" name="scan_new_queue_health">
<label>Queue Heathcheck for changed files on Scan:</label>
<input type="checkbox" name="scan_changed_queue_health">
<label>Queue Transcode for new files on Scan:</label>
<input type="checkbox" name="scan_new_queue_transcode">
<label>Queue Transcode for changed files on Scan:</label>
<input type="checkbox" name="scan_changed_queue_transcode">
<label>Queue Transcode on Healthcheck Success:</label>
<input type="checkbox" name="health_ok_queue_transcode">
<input type="submit" value="Submit">
</form>
{{template "tail"}}

6
tmpl/library.tmpl
View file

@ -3,6 +3,8 @@
<p>{{if .Library.Enable}}Enabled{{else}}Disabled{{end}}</p>
<h2>Files</h2>
<form method="POST" action="/scan/{{.Library.ID}}">
<label>Full:</label><br />
<input type="checkbox" name="full"><br />
<input value="Scan" type="submit">
</form>
<div class="file-list">
@ -13,6 +15,7 @@
<th>Size</th>
<th>Status</th>
<th>Health</th>
<th>Transcode</th>
<th>MD5</th>
<th>Updated At</th>
</tr>
@ -33,6 +36,9 @@
<td>
{{ $f.Health }}
</td>
<td>
{{ $f.Transcode }}
</td>
<td>
{{ $f.MD5 }}
</td>

1
tmpl/tasks.tmpl
View file

@ -17,6 +17,7 @@
<label for="type">Type</label>
<select id="type" name="type">
<option value="0">Health Check</option>
<option value="1">Transcode</option>
</select>
<input type="submit" value="Submit">
</form>