Update drone CI upload backend program

reduce node_modules size to only 18M

reduce js file bundle to 20%

.drone.yml

@@ -0,0 +1,34 @@
+kind: pipeline
+type: docker
+name: default
+
+clone:
+  depth: 1
+
+steps:
+  - name: frontend-web
+    image: node:19
+    commands:
+      - cd web
+      - npm install
+      - npm run build
+
+  - name: backend
+    image: golang:1.19
+    commands:
+      - go build -v .
+    environment:
+      CGO_ENABLED: 0
+      GOPROXY: goproxy.cn
+
+  - name: upload
+    image: plugins/s3-sync
+    settings:
+      bucket: msw-artifacts-public
+      region: ap-southeast-1
+      access_key:
+        from_secret: access_key
+      secret_key:
+        from_secret: secret_key
+      source: msw-open-music
+      target: /msw-open-music/${DRONE_COMMIT}/

Makefile

@@ -4,7 +4,7 @@ web:
 	cd web && npm run build
 
 linux:
-	go build -v -ldflags '-linkmode=external -extldflags=-static' -tags sqlite_omit_load_extension,netgo
+	CGO_ENABLED=0 go build -v -ldflags '-extldflags=-static'
 
 windows:
 	CC=x86_64-w64-mingw32-gcc CGO_ENABLED=1 GOOS=windows GOARCH=amd64 go build -v

config.json

@@ -1,7 +1,7 @@
 {
   "api": {
     "secret": "CHANGE_YOUR_SECRET_HERE",
-    "database_name": "music.sqlite3",
+    "database_name": "postgres://postgres:woshimima@localhost/postgres?sslmode=disable",
     "single_thread": true,
     "addr": ":8080",
     "ffmpeg_threads": 1,

go.mod

@@ -4,7 +4,7 @@ go 1.18
 
 require (
 	github.com/gorilla/sessions v1.2.1
-	github.com/mattn/go-sqlite3 v1.14.14
+	github.com/lib/pq v1.10.7
 	golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d
 )
 

go.sum

@@ -2,7 +2,7 @@ github.com/gorilla/securecookie v1.1.1 h1:miw7JPhV+b/lAHSXz4qd/nN9jRiAFV5FwjeKyC
 github.com/gorilla/securecookie v1.1.1/go.mod h1:ra0sb63/xPlUeL+yeDciTfxMRAA+MP+HVt/4epWDjd4=
 github.com/gorilla/sessions v1.2.1 h1:DHd3rPN5lE3Ts3D8rKkQ8x/0kqfeNmBAaiSi+o7FsgI=
 github.com/gorilla/sessions v1.2.1/go.mod h1:dk2InVEVJ0sfLlnXv9EAgkf6ecYs/i80K/zI+bUmuGM=
-github.com/mattn/go-sqlite3 v1.14.14 h1:qZgc/Rwetq+MtyE18WhzjokPD93dNqLGNT3QJuLvBGw=
-github.com/mattn/go-sqlite3 v1.14.14/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
+github.com/lib/pq v1.10.7 h1:p7ZhMD+KsSRozJr34udlUrhboJwWAgCg34+/ZZNvZZw=
+github.com/lib/pq v1.10.7/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
 golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d h1:sK3txAijHtOK88l68nt020reeT1ZdKLIYetKl95FzVY=
 golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d/go.mod h1:IxCIyHEi3zRg3s0A5j5BB6A9Jmi73HwBIUl50j+osU4=

main.go

@@ -1,8 +1,10 @@
 package main
 
 import (
+	"embed"
 	"encoding/json"
 	"flag"
+	"io/fs"
 	"log"
 	"msw-open-music/pkg/api"
 	"msw-open-music/pkg/commonconfig"
@@ -15,11 +17,21 @@ func init() {
 	flag.StringVar(&ConfigFilePath, "config", "config.json", "backend config file path")
 }
 
+//go:embed web/build
+var WEBFILES embed.FS
+
 func main() {
 	var err error
 	flag.Parse()
 
-	config := commonconfig.Config{}
+	WEBFS, err := fs.Sub(WEBFILES, "web/build")
+	if err != nil {
+		log.Fatal(err)
+	}
+
+	config := commonconfig.Config{
+		WEBFS: WEBFS,
+	}
 	configFile, err := os.Open(ConfigFilePath)
 	if err != nil {
 		log.Fatal(err)

pkg/api/api.go

@@ -1,11 +1,12 @@
 package api
 
 import (
-	"github.com/gorilla/sessions"
 	"msw-open-music/pkg/commonconfig"
 	"msw-open-music/pkg/database"
 	"msw-open-music/pkg/tmpfs"
 	"net/http"
+
+	"github.com/gorilla/sessions"
 )
 
 type API struct {
@@ -59,6 +60,7 @@ func NewAPI(config commonconfig.Config) (*API, error) {
 	apiMux.HandleFunc("/get_file_info", api.HandleGetFileInfo)
 	apiMux.HandleFunc("/get_file_ffprobe_info", api.HandleGetFileFfprobeInfo)
 	apiMux.HandleFunc("/get_file_stream_direct", api.HandleGetFileStreamDirect)
+	apiMux.HandleFunc("/get_file_avatar", api.HandelGetFileAvatar)
 	apiMux.HandleFunc("/prepare_file_stream_direct", api.HandlePrepareFileStreamDirect)
 	apiMux.HandleFunc("/delete_file", api.HandleDeleteFile)
 	apiMux.HandleFunc("/update_filename", api.HandleUpdateFilename)
@@ -71,7 +73,7 @@ func NewAPI(config commonconfig.Config) (*API, error) {
 	// user
 	apiMux.HandleFunc("/login", api.HandleLogin)
 	apiMux.HandleFunc("/register", api.HandleRegister)
-	apiMux.HandleFunc("/logout", api.LoginAsAnonymous)
+	apiMux.HandleFunc("/logout", api.HandleLoginAsAnonymous)
 	apiMux.HandleFunc("/get_user_info", api.HandleGetUserInfo)
 	apiMux.HandleFunc("/get_users", api.HandleGetUsers)
 	apiMux.HandleFunc("/update_user_active", api.HandleUpdateUserActive)
@@ -95,12 +97,14 @@ func NewAPI(config commonconfig.Config) (*API, error) {
 	apiMux.HandleFunc("/update_review", api.HandleUpdateReview)
 	apiMux.HandleFunc("/delete_review", api.HandleDeleteReview)
 	apiMux.HandleFunc("/get_reviews_by_user", api.HandleGetReviewsByUser)
+	// statistic
+	apiMux.HandleFunc("/record_playback", api.HandleRecordPlayback)
 	// database
 	apiMux.HandleFunc("/walk", api.HandleWalk)
 	apiMux.HandleFunc("/reset", api.HandleReset)
 
 	mux.Handle("/api/v1/", http.StripPrefix("/api/v1", api.PermissionMiddleware(apiMux)))
-	mux.Handle("/", http.StripPrefix("/", http.FileServer(http.Dir("web/build"))))
+	mux.Handle("/", http.StripPrefix("/", http.FileServer(http.FS(config.WEBFS))))
 
 	return api, nil
 }

pkg/api/handle_avatar.go

@@ -0,0 +1,108 @@
+package api
+
+import (
+	"bytes"
+	"errors"
+	"io"
+	"log"
+	"msw-open-music/pkg/database"
+	"net/http"
+	"os"
+	"os/exec"
+	"path"
+	"strconv"
+	"strings"
+)
+
+func (api *API) HandelGetFileAvatar(w http.ResponseWriter, r *http.Request) {
+	var err error
+	q := r.URL.Query()
+	ids := q["id"]
+	if len(ids) == 0 {
+		err = errors.New(`parameter "id" can't be empty`)
+		api.HandleError(w, r, err)
+		return
+	}
+	id, err := strconv.Atoi(ids[0])
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	file, err := api.Db.GetFile(int64(id))
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	path, err := file.Path()
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	log.Println("[api] Get avatar of file", path)
+	buff := make([]byte, 0)
+	cache := bytes.NewBuffer(buff)
+	cmd := exec.Command("ffmpeg", "-i", path, "-c:v", "libwebp_anim", "-update", "1", "-frames:v", "1", "-f", "image2pipe", "-")
+	cmd.Stdout = cache
+
+	err = cmd.Run()
+	if err != nil {
+		api.HandleGetAlternativeFileAvatar(w, r, file)
+		return
+	}
+
+	w.Header().Set("Content-Type", "image/webp")
+	io.Copy(w, cache)
+}
+
+func (api *API) HandleGetAlternativeFileAvatar(w http.ResponseWriter, r *http.Request, f *database.File) {
+	var err error
+	dir, err := f.Dir()
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	log.Println("[api] Get alternative avatar in dir", dir)
+	files, err := os.ReadDir(dir)
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	avatar, err := findAvatarFile(files)
+	avatarPath := path.Join(dir, avatar)
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	cmd := exec.Command("ffmpeg", "-i", avatarPath, "-c:v", "libwebp_anim", "-f", "image2pipe", "-")
+	cmd.Stdout = w
+	w.Header().Set("Content-Type", "image/webp")
+
+	err = cmd.Run()
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+}
+
+func findAvatarFile(files []os.DirEntry) (string, error) {
+	for _, file := range files {
+		if isAvatarType(file.Name()) {
+			return file.Name(), nil
+		}
+	}
+	return "", errors.New("Cannot find avatar file")
+}
+
+var avatarFileTypes = []string{
+	".jpg",
+	".png",
+}
+
+func isAvatarType(filename string) bool {
+	for _, t := range avatarFileTypes {
+		if strings.HasSuffix(strings.ToLower(filename), t) {
+			return true
+		}
+	}
+	return false
+}

pkg/api/handle_stat.go

@@ -0,0 +1,51 @@
+package api
+
+import (
+	"encoding/json"
+	"log"
+	"msw-open-music/pkg/database"
+	"net/http"
+	"time"
+)
+
+type RecordPlaybackRequest struct {
+	Playback database.Playback `json:"playback"`
+}
+
+func (api *API) HandleRecordPlayback(w http.ResponseWriter, r *http.Request) {
+	recordPlaybackRequest := &RecordPlaybackRequest{}
+	err := json.NewDecoder(r.Body).Decode(recordPlaybackRequest)
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+
+	recordPlaybackRequest.Playback.Time = time.Now()
+	recordPlaybackRequest.Playback.UserID, err = api.GetUserID(w, r)
+	if err != nil {
+		if err == ErrNotLoggedIn {
+			user, err := api.Db.LoginAsAnonymous()
+			if err != nil {
+				api.HandleError(w, r, err)
+				return
+			}
+			recordPlaybackRequest.Playback.UserID = user.ID
+		} else {
+			api.HandleError(w, r, err)
+			return
+		}
+	}
+
+	log.Println("[api] Record playback history",
+		recordPlaybackRequest.Playback.UserID,
+		recordPlaybackRequest.Playback.FileID,
+		recordPlaybackRequest.Playback.Duration,
+		recordPlaybackRequest.Playback.Method)
+
+	err = api.Db.RecordPlayback(recordPlaybackRequest.Playback)
+	if err != nil {
+		api.HandleError(w, r, err)
+		return
+	}
+	api.HandleOK(w, r)
+}

pkg/api/handle_user.go

@@ -17,23 +17,8 @@ type LoginResponse struct {
 	User *database.User `json:"user"`
 }
 
-func (api *API) LoginAsAnonymous(w http.ResponseWriter, r *http.Request) {
-	user, err := api.Db.LoginAsAnonymous()
-	if err != nil {
-		api.HandleError(w, r, err)
-		return
-	}
-
-	session, _ := api.store.Get(r, api.defaultSessionName)
-
-	// save session
-	session.Values["userId"] = user.ID
-	err = session.Save(r, w)
-	if err != nil {
-		api.HandleError(w, r, err)
-		return
-	}
-
+func (api *API) HandleLoginAsAnonymous(w http.ResponseWriter, r *http.Request) {
+	user, err := api.LoginAsAnonymous(w, r)
 	resp := &LoginResponse{
 		User: user,
 	}
@@ -45,6 +30,25 @@ func (api *API) LoginAsAnonymous(w http.ResponseWriter, r *http.Request) {
 	}
 }
 
+func (api *API) LoginAsAnonymous(w http.ResponseWriter, r *http.Request) (*database.User, error) {
+	user, err := api.Db.LoginAsAnonymous()
+	if err != nil {
+		return nil, err
+	}
+
+	session, _ := api.store.Get(r, api.defaultSessionName)
+
+	// save session
+	session.Values["userId"] = user.ID
+	err = session.Save(r, w)
+	if err != nil {
+		return nil, err
+	}
+
+	// return user
+	return user, nil
+}
+
 func (api *API) HandleLogin(w http.ResponseWriter, r *http.Request) {
 	var user *database.User
 	var err error

pkg/commonconfig/config.go

@@ -1,8 +1,11 @@
 package commonconfig
 
+import "io/fs"
+
 type Config struct {
 	APIConfig   APIConfig   `json:"api"`
 	TmpfsConfig TmpfsConfig `json:"tmpfs"`
+	WEBFS       fs.FS
 }
 
 type APIConfig struct {

pkg/database/database.go

@@ -4,7 +4,7 @@ import (
 	"database/sql"
 	"sync"
 
-	_ "github.com/mattn/go-sqlite3"
+	_ "github.com/lib/pq"
 )
 
 type Database struct {
@@ -41,7 +41,7 @@ func NewDatabase(dbName string, singleThread bool) (*Database, error) {
 	var err error
 
 	// open database
-	sqlConn, err := sql.Open("sqlite3", dbName)
+	sqlConn, err := sql.Open("postgres", dbName)
 	if err != nil {
 		return nil, err
 	}

pkg/database/method.go

@@ -168,6 +168,7 @@ func (database *Database) Walk(root string, pattern []string, tagIDs []int64, us
 	insertFileStmt := tx.Stmt(database.stmt.insertFile)
 	putTagOnFileStmt := tx.Stmt(database.stmt.putTagOnFile)
 	findFolderStmt := tx.Stmt(database.stmt.findFolder)
+	findFileStmt := tx.Stmt(database.stmt.findFile)
 
 	err = filepath.Walk(root, func(path string, info os.FileInfo, err error) error {
 		if err != nil {
@@ -194,22 +195,41 @@ func (database *Database) Walk(root string, pattern []string, tagIDs []int64, us
 		folder, filename := filepath.Split(path)
 		err = findFolderStmt.QueryRow(folder).Scan(&folderID)
 		if err != nil {
-			result, err := insertFolderStmt.Exec(folder, filepath.Base(folder))
+			result, err := insertFolderStmt.Query(folder, filepath.Base(folder))
 			if err != nil {
 				return err
 			}
-			folderID, err = result.LastInsertId()
+			for result.Next() {
+				err = result.Scan(&folderID)
+				if err != nil {
+					return err
+				}
+			}
+		}
+
+		// try find file id
+		var fileID int64
+		result, err := findFileStmt.Query(folderID, filename)
+		if err != nil {
+			return err
+		}
+		for result.Next() {
+			err = result.Scan(&fileID)
 			if err != nil {
 				return err
 			}
 		}
-		result, err := insertFileStmt.Exec(folderID, filename, filename, info.Size())
+
+		// insert new file
+		result, err = insertFileStmt.Query(folderID, filename, filename, info.Size())
 		if err != nil {
 			return err
 		}
-		fileID, err := result.LastInsertId()
-		if err != nil {
-			return err
+		for result.Next() {
+			err = result.Scan(&fileID)
+			if err != nil {
+				return err
+			}
 		}
 
 		for _, tag := range tags {

pkg/database/method_playback.go

@@ -0,0 +1,7 @@
+package database
+
+func (database *Database) RecordPlayback(playback Playback) error {
+	_, err := database.stmt.recordPlaybackStmt.Exec(
+		playback.UserID, playback.FileID, playback.Time, playback.Method, playback.Duration)
+	return err
+}

pkg/database/method_tag.go

@@ -6,11 +6,17 @@ func (database *Database) InsertTag(tag *Tag) (int64, error) {
 	database.singleThreadLock.Lock()
 	defer database.singleThreadLock.Unlock()
 
-	result, err := database.stmt.insertTag.Exec(tag.Name, tag.Description, tag.CreatedByUserId)
+	result, err := database.stmt.insertTag.Query(tag.Name, tag.Description, tag.CreatedByUserId)
 	if err != nil {
 		return 0, err
 	}
-	id, err := result.LastInsertId()
+	var id int64
+	for result.Next() {
+		err = result.Scan(&id)
+		if err != nil {
+			return 0, err
+		}
+	}
 	if err != nil {
 		return 0, err
 	}

pkg/database/sql_stmt.go

@@ -2,25 +2,26 @@ package database
 
 import (
 	"database/sql"
+	"log"
 )
 
 var initFilesTableQuery = `CREATE TABLE IF NOT EXISTS files (
-	id INTEGER PRIMARY KEY,
-	folder_id INTEGER NOT NULL,
+	id SERIAL PRIMARY KEY,
+	folder_id INTEGER NOT NULL REFERENCES folders(id),
 	realname TEXT NOT NULL,
 	filename TEXT NOT NULL,
 	filesize INTEGER NOT NULL,
-	FOREIGN KEY(folder_id) REFERENCES folders(id)
+	UNIQUE (folder_id, realname)
 );`
 
 var initFoldersTableQuery = `CREATE TABLE IF NOT EXISTS folders (
-	id INTEGER PRIMARY KEY,
-	folder TEXT NOT NULL,
+	id SERIAL PRIMARY KEY,
+	folder TEXT NOT NULL UNIQUE,
 	foldername TEXT NOT NULL
 );`
 
 var initFeedbacksTableQuery = `CREATE TABLE IF NOT EXISTS feedbacks (
-	id INTEGER PRIMARY KEY,
+	id SERIAL PRIMARY KEY,
 	time INTEGER NOT NULL,
 	content TEXT NOT NULL,
 	user_id INTEGER NOT NULL,
@@ -29,107 +30,101 @@ var initFeedbacksTableQuery = `CREATE TABLE IF NOT EXISTS feedbacks (
 
 // User table schema definition
 // role: 0 - Anonymous User, 1 - Admin, 2 - User
+// postgres avatar references problem
 var initUsersTableQuery = `CREATE TABLE IF NOT EXISTS users (
-	id INTEGER PRIMARY KEY AUTOINCREMENT,
+	id SERIAL PRIMARY KEY,
 	username TEXT NOT NULL UNIQUE,
 	password TEXT NOT NULL,
 	role INTEGER NOT NULL,
 	active BOOLEAN NOT NULL,
-	avatar_id INTEGER NOT NULL,
-	FOREIGN KEY(avatar_id) REFERENCES avatars(id)
+	avatar_id INTEGER NOT NULL DEFAULT 0
 );`
 
 var initAvatarsTableQuery = `CREATE TABLE IF NOT EXISTS avatars (
-	id INTEGER PRIMARY KEY,
+	id SERIAL PRIMARY KEY,
 	avatarname TEXT NOT NULL,
-	avatar BLOB NOT NULL
+	avatar BYTEA NOT NULL
 );`
 
 var initTagsTableQuery = `CREATE TABLE IF NOT EXISTS tags (
-	id INTEGER PRIMARY KEY AUTOINCREMENT,
+	id SERIAL PRIMARY KEY,
 	name TEXT NOT NULL UNIQUE,
 	description TEXT NOT NULL,
-	created_by_user_id INTEGER NOT NULL,
-	FOREIGN KEY(created_by_user_id) REFERENCES users(id)
+	created_by_user_id INTEGER NOT NULL REFERENCES users(id)
 );`
 
 var initFileHasTagTableQuery = `CREATE TABLE IF NOT EXISTS file_has_tag (
-	file_id INTEGER NOT NULL,
-	tag_id INTEGER NOT NULL,
-	user_id INTEGER NOT NULL,
-	PRIMARY KEY (file_id, tag_id),
-	FOREIGN KEY(user_id) REFERENCES users(id)
-	FOREIGN KEY (file_id) REFERENCES files(id),
-	FOREIGN KEY (tag_id) REFERENCES tags(id)
+	file_id INTEGER NOT NULL REFERENCES files(id),
+	tag_id INTEGER NOT NULL REFERENCES tags(id),
+	user_id INTEGER NOT NULL REFERENCES users(id),
+	PRIMARY KEY (file_id, tag_id)
 );`
 
 var initLikesTableQuery = `CREATE TABLE IF NOT EXISTS likes (
-	user_id INTEGER NOT NULL,
-	file_id INTEGER NOT NULL,
-	PRIMARY KEY (user_id, file_id),
-	FOREIGN KEY (user_id) REFERENCES users(id),
-	FOREIGN KEY (file_id) REFERENCES files(id)
+	user_id INTEGER NOT NULL REFERENCES users(id),
+	file_id INTEGER NOT NULL REFERENCES files(id),
+	PRIMARY KEY (user_id, file_id)
 );`
 
 var initReviewsTableQuery = `CREATE TABLE IF NOT EXISTS reviews (
-	id INTEGER PRIMARY KEY,
-	user_id INTEGER NOT NULL,
-	file_id INTEGER NOT NULL,
+	id SERIAL PRIMARY KEY,
+	user_id INTEGER NOT NULL REFERENCES users(id),
+	file_id INTEGER NOT NULL REFERENCES files(id),
 	created_at INTEGER NOT NULL,
 	updated_at INTEGER NOT NULL DEFAULT 0,
-	content TEXT NOT NULL,
-	FOREIGN KEY (user_id) REFERENCES users(id),
-	FOREIGN KEY (file_id) REFERENCES files(id)
+	content TEXT NOT NULL
 );`
 
 var initPlaybacksTableQuery = `CREATE TABLE IF NOT EXISTS playbacks (
-	id INTEGER PRIMARY KEY,
-	user_id INTEGER NOT NULL,
-	file_id INTEGER NOT NULL,
-	time INTEGER NOT NULL,
-	mothod INTEGER NOT NULL,
-	FOREIGN KEY (user_id) REFERENCES users(id),
-	FOREIGN KEY (file_id) REFERENCES files(id)
+	id SERIAL PRIMARY KEY,
+	user_id INTEGER NOT NULL REFERENCES users(id),
+	file_id INTEGER NOT NULL REFERENCES files(id),
+	time TIMESTAMP NOT NULL,
+	method INTEGER NOT NULL,
+	duration INTERVAL NOT NULL
 );`
 
 var initLogsTableQuery = `CREATE TABLE IF NOT EXISTS logs (
-	id INTEGER PRIMARY KEY,
+	id SERIAL PRIMARY KEY,
 	time INTEGER NOT NULL,
 	message TEXT NOT NULL,
-	user_id INTEGER NOT NULL,
-	FOREIGN KEY (user_id) REFERENCES users(id)
+	user_id INTEGER NOT NULL REFERENCES users(id)
 );`
 
 var initTmpfsTableQuery = `CREATE TABLE IF NOT EXISTS tmpfs (
-	id INTEGER PRIMARY KEY,
+	id SERIAL PRIMARY KEY,
 	path TEXT NOT NULL,
 	size INTEGER NOT NULL,
-	file_id INTEGER NOT NULL,
+	file_id INTEGER NOT NULL REFERENCES files(id),
 	ffmpeg_config TEXT NOT NULL,
 	created_time INTEGER NOT NULL,
-	accessed_time INTEGER NOT NULL,
-	FOREIGN KEY (file_id) REFERENCES files(id)
+	accessed_time INTEGER NOT NULL
 );`
 
 var insertFolderQuery = `INSERT INTO folders (folder, foldername)
-VALUES (?, ?);`
+VALUES ($1, $2)
+ON CONFLICT DO NOTHING
+RETURNING id;
+;`
 
-var findFolderQuery = `SELECT id FROM folders WHERE folder = ? LIMIT 1;`
+var findFolderQuery = `SELECT id FROM folders WHERE folder = $1 LIMIT 1;`
 
-var findFileQuery = `SELECT id FROM files WHERE folder_id = ? AND realname = ? LIMIT 1;`
+var findFileQuery = `SELECT id FROM files WHERE folder_id = $1 AND realname = $2 LIMIT 1;`
 
 var insertFileQuery = `INSERT INTO files (folder_id, realname, filename, filesize)
-VALUES (?, ?, ?, ?);`
+VALUES ($1, $2, $3, $4)
+ON CONFLICT DO NOTHING
+RETURNING id;`
 
 var searchFilesQuery = `SELECT
 files.id, files.folder_id, files.filename, folders.foldername, files.filesize
 FROM files
 JOIN folders ON files.folder_id = folders.id
-WHERE filename LIKE ?
+WHERE filename ILIKE $1
 ORDER BY folders.foldername, files.filename
-LIMIT ? OFFSET ?;`
+LIMIT $2 OFFSET $3;`
 
-var getFolderQuery = `SELECT folder FROM folders WHERE id = ? LIMIT 1;`
+var getFolderQuery = `SELECT folder FROM folders WHERE id = $1 LIMIT 1;`
 
 var dropFilesQuery = `DROP TABLE files;`
 
@@ -139,42 +134,42 @@ var getFileQuery = `SELECT
 files.id, files.folder_id, files.realname, files.filename, folders.foldername, files.filesize
 FROM files
 JOIN folders ON files.folder_id = folders.id
-WHERE files.id = ?
+WHERE files.id = $1
 LIMIT 1;`
 
 var searchFoldersQuery = `SELECT
 id, folder, foldername
 FROM folders
-WHERE foldername LIKE ?
+WHERE foldername ILIKE $1
 ORDER BY foldername
-LIMIT ? OFFSET ?;`
+LIMIT $2 OFFSET $3;`
 
 var getFilesInFolderQuery = `SELECT
 files.id, files.filename, files.filesize, folders.foldername, folders.folder
 FROM files
 JOIN folders ON files.folder_id = folders.id
-WHERE folder_id = ?
+WHERE folder_id = $1
 ORDER BY files.filename
-LIMIT ? OFFSET ?;`
+LIMIT $2 OFFSET $3;`
 
 var getRandomFilesQuery = `SELECT
 files.id, files.folder_id, files.filename, folders.foldername, files.filesize
 FROM files
 JOIN folders ON files.folder_id = folders.id
 ORDER BY RANDOM()
-LIMIT ?;`
+LIMIT $1;`
 
 var getRandomFilesWithTagQuery = `SELECT
 files.id, files.folder_id, files.filename, folders.foldername, files.filesize
 FROM file_has_tag
 JOIN files ON file_has_tag.file_id = files.id
 JOIN folders ON files.folder_id = folders.id
-WHERE file_has_tag.tag_id = ?
+WHERE file_has_tag.tag_id = $1
 ORDER BY RANDOM()
-LIMIT ?;`
+LIMIT $2;`
 
 var insertFeedbackQuery = `INSERT INTO feedbacks (time, content, user_id, header)
-VALUES (?, ?, ?, ?);`
+VALUES ($1, $2, $3, $4);`
 
 var getFeedbacksQuery = `SELECT
 feedbacks.id, feedbacks.time, feedbacks.content, feedbacks.header,
@@ -184,39 +179,39 @@ JOIN users ON feedbacks.user_id = users.id
 ORDER BY feedbacks.time
 ;`
 
-var deleteFeedbackQuery = `DELETE FROM feedbacks WHERE id = ?;`
+var deleteFeedbackQuery = `DELETE FROM feedbacks WHERE id = $1;`
 
 var insertUserQuery = `INSERT INTO users (username, password, role, active, avatar_id)
-VALUES (?, ?, ?, ?, ?);`
+VALUES ($1, $2, $3, $4, $5);`
 
 var countUserQuery = `SELECT count(*) FROM users;`
 
 var countAdminQuery = `SELECT count(*) FROM users WHERE role= 1;`
 
-var getUserQuery = `SELECT id, username, password, role, active, avatar_id FROM users WHERE username = ? LIMIT 1;`
+var getUserQuery = `SELECT id, username, password, role, active, avatar_id FROM users WHERE username = $1 LIMIT 1;`
 
 var getUsersQuery = `SELECT id, username, role, active, avatar_id FROM users;`
 
-var getUserByIdQuery = `SELECT id, username, role, active, avatar_id FROM users WHERE id = ? LIMIT 1;`
+var getUserByIdQuery = `SELECT id, username, role, active, avatar_id FROM users WHERE id = $1 LIMIT 1;`
 
-var updateUserActiveQuery = `UPDATE users SET active = ? WHERE id = ?;`
+var updateUserActiveQuery = `UPDATE users SET active = $1 WHERE id = $2;`
 
-var updateUsernameQuery = `UPDATE users SET username = ? WHERE id = ?;`
+var updateUsernameQuery = `UPDATE users SET username = $1 WHERE id = $2;`
 
-var updateUserPasswordQuery = `UPDATE users SET password = ? WHERE id = ?;`
+var updateUserPasswordQuery = `UPDATE users SET password = $1 WHERE id = $2;`
 
 var getAnonymousUserQuery = `SELECT id, username, role, avatar_id FROM users WHERE role = 0 LIMIT 1;`
 
-var insertTagQuery = `INSERT INTO tags (name, description, created_by_user_id) VALUES (?, ?, ?);`
+var insertTagQuery = `INSERT INTO tags (name, description, created_by_user_id) VALUES ($1, $2, $3) RETURNING id;`
 
-var deleteTagQuery = `DELETE FROM tags WHERE id = ?;`
+var deleteTagQuery = `DELETE FROM tags WHERE id = $1;`
 
 var getTagQuery = `SELECT
 tags.id, tags.name, tags.description,
 users.id, users.username, users.role, users.avatar_id
 FROM tags
 JOIN users ON tags.created_by_user_id = users.id
-WHERE tags.id = ? LIMIT 1;`
+WHERE tags.id = $1 LIMIT 1;`
 
 var getTagsQuery = `SELECT
 tags.id, tags.name, tags.description,
@@ -226,26 +221,27 @@ JOIN users ON tags.created_by_user_id = users.id
 ORDER BY tags.name
 ;`
 
-var updateTagQuery = `UPDATE tags SET name = ?, description = ? WHERE id = ?;`
+var updateTagQuery = `UPDATE tags SET name = $1, description = $2 WHERE id = $3;`
 
-var putTagOnFileQuery = `INSERT OR IGNORE INTO file_has_tag (tag_id, file_id, user_id) VALUES (?, ?, ?);`
+// postgres INSERT IGNORE
+var putTagOnFileQuery = `INSERT INTO file_has_tag (tag_id, file_id, user_id) VALUES ($1, $2, $3) ON CONFLICT DO NOTHING;`
 
 var getTagsOnFileQuery = `SELECT
 tags.id, tags.name, tags.description, tags.created_by_user_id
 FROM file_has_tag
 JOIN tags ON file_has_tag.tag_id = tags.id
-WHERE file_has_tag.file_id = ?
+WHERE file_has_tag.file_id = $1
 ORDER BY tags.name
 ;`
 
-var deleteTagOnFileQuery = `DELETE FROM file_has_tag WHERE tag_id = ? AND file_id = ?;`
+var deleteTagOnFileQuery = `DELETE FROM file_has_tag WHERE tag_id = $1 AND file_id = $2;`
 
-var deleteTagReferenceInFileHasTagQuery = `DELETE FROM file_has_tag WHERE tag_id = ?;`
+var deleteTagReferenceInFileHasTagQuery = `DELETE FROM file_has_tag WHERE tag_id = $1;`
 
-var updateFoldernameQuery = `UPDATE folders SET foldername = ? WHERE id = ?;`
+var updateFoldernameQuery = `UPDATE folders SET foldername = $1 WHERE id = $2;`
 
 var insertReviewQuery = `INSERT INTO reviews (user_id, file_id, created_at, content)
-VALUES (?, ?, ?, ?);`
+VALUES ($1, $2, $3, $4);`
 
 var getReviewsOnFileQuery = `SELECT
 reviews.id, reviews.created_at, reviews.updated_at, reviews.content,
@@ -254,15 +250,15 @@ files.id, files.filename
 FROM reviews
 JOIN users ON reviews.user_id = users.id
 JOIN files ON reviews.file_id = files.id
-WHERE reviews.file_id = ?
+WHERE reviews.file_id = $1
 ORDER BY reviews.created_at
 ;`
 
-var getReviewQuery = `SELECT id, file_id, user_id, created_at, updated_at, content FROM reviews WHERE id = ? LIMIT 1;`
+var getReviewQuery = `SELECT id, file_id, user_id, created_at, updated_at, content FROM reviews WHERE id = $1 LIMIT 1;`
 
-var updateReviewQuery = `UPDATE reviews SET content = ?, updated_at = ? WHERE id = ?;`
+var updateReviewQuery = `UPDATE reviews SET content = $1, updated_at = $2 WHERE id = $3;`
 
-var deleteReviewQuery = `DELETE FROM reviews WHERE id = ?;`
+var deleteReviewQuery = `DELETE FROM reviews WHERE id = $1;`
 
 var getReviewsByUserQuery = `SELECT
 reviews.id, reviews.created_at, reviews.updated_at, reviews.content,
@@ -271,19 +267,21 @@ files.id, files.filename
 FROM reviews
 JOIN users ON reviews.user_id = users.id
 JOIN files ON reviews.file_id = files.id
-WHERE reviews.user_id = ?
+WHERE reviews.user_id = $1
 ORDER BY reviews.created_at
 ;`
 
-var deleteFileQuery = `DELETE FROM files WHERE id = ?;`
+var deleteFileQuery = `DELETE FROM files WHERE id = $1;`
 
-var deleteFileReferenceInFileHasTagQuery = `DELETE FROM file_has_tag WHERE file_id = ?;`
+var deleteFileReferenceInFileHasTagQuery = `DELETE FROM file_has_tag WHERE file_id = $1;`
 
-var deleteFileReferenceInReviewsQuery = `DELETE FROM reviews WHERE file_id = ?;`
+var deleteFileReferenceInReviewsQuery = `DELETE FROM reviews WHERE file_id = $1;`
 
-var updateFilenameQuery = `UPDATE files SET filename = ? WHERE id = ?;`
+var updateFilenameQuery = `UPDATE files SET filename = $1 WHERE id = $2;`
 
-var resetFilenameQuery = `UPDATE files SET filename = realname WHERE id = ?;`
+var resetFilenameQuery = `UPDATE files SET filename = realname WHERE id = $1;`
+
+var recordPlaybackQuery = `INSERT INTO playbacks (user_id, file_id, time, method, duration) VALUES ($1, $2, $3, $4, $5);`
 
 type Stmt struct {
 	initFilesTable                  *sql.Stmt
@@ -345,6 +343,7 @@ type Stmt struct {
 	deleteFileReferenceInReviews    *sql.Stmt
 	updateFilename                  *sql.Stmt
 	resetFilename                   *sql.Stmt
+	recordPlaybackStmt              *sql.Stmt
 }
 
 func NewPreparedStatement(sqlConn *sql.DB) (*Stmt, error) {
@@ -352,26 +351,22 @@ func NewPreparedStatement(sqlConn *sql.DB) (*Stmt, error) {
 
 	stmt := &Stmt{}
 
-	// init files table
-	stmt.initFilesTable, err = sqlConn.Prepare(initFilesTableQuery)
-	if err != nil {
-		return nil, err
-	}
-
 	// init folders table
 	stmt.initFoldersTable, err = sqlConn.Prepare(initFoldersTableQuery)
 	if err != nil {
 		return nil, err
 	}
-
-	// init feedbacks tables
-	stmt.initFeedbacksTable, err = sqlConn.Prepare(initFeedbacksTableQuery)
+	_, err = stmt.initFoldersTable.Exec()
 	if err != nil {
 		return nil, err
 	}
 
-	// init users table
-	stmt.initUsersTable, err = sqlConn.Prepare(initUsersTableQuery)
+	// init files table
+	stmt.initFilesTable, err = sqlConn.Prepare(initFilesTableQuery)
+	if err != nil {
+		return nil, err
+	}
+	_, err = stmt.initFilesTable.Exec()
 	if err != nil {
 		return nil, err
 	}
@@ -381,99 +376,103 @@ func NewPreparedStatement(sqlConn *sql.DB) (*Stmt, error) {
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initAvatarsTable.Exec()
+	if err != nil {
+		return nil, err
+	}
+
+	// init users table
+	stmt.initUsersTable, err = sqlConn.Prepare(initUsersTableQuery)
+	if err != nil {
+		return nil, err
+	}
+	_, err = stmt.initUsersTable.Exec()
+	if err != nil {
+		return nil, err
+	}
+
+	// init feedbacks tables
+	stmt.initFeedbacksTable, err = sqlConn.Prepare(initFeedbacksTableQuery)
+	if err != nil {
+		return nil, err
+	}
+	_, err = stmt.initFeedbacksTable.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init tags table
 	stmt.initTagsTable, err = sqlConn.Prepare(initTagsTableQuery)
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initTagsTable.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init file_has_tag table
 	stmt.initFileHasTag, err = sqlConn.Prepare(initFileHasTagTableQuery)
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initFileHasTag.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init likes table
 	stmt.initLikesTable, err = sqlConn.Prepare(initLikesTableQuery)
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initLikesTable.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init reviews table
 	stmt.initReviewsTable, err = sqlConn.Prepare(initReviewsTableQuery)
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initReviewsTable.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init playbacks table
 	stmt.initPlaybacksTable, err = sqlConn.Prepare(initPlaybacksTableQuery)
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initPlaybacksTable.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init logs table
 	stmt.initLogsTable, err = sqlConn.Prepare(initLogsTableQuery)
 	if err != nil {
 		return nil, err
 	}
+	_, err = stmt.initLogsTable.Exec()
+	if err != nil {
+		return nil, err
+	}
 
 	// init tmpfs table
 	stmt.initTmpfsTable, err = sqlConn.Prepare(initTmpfsTableQuery)
 	if err != nil {
 		return nil, err
 	}
-
-	// run init statement
-	_, err = stmt.initFilesTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initFoldersTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initFeedbacksTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initUsersTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initAvatarsTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initTagsTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initFileHasTag.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initLikesTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initReviewsTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initPlaybacksTable.Exec()
-	if err != nil {
-		return nil, err
-	}
-	_, err = stmt.initLogsTable.Exec()
-	if err != nil {
-		return nil, err
-	}
 	_, err = stmt.initTmpfsTable.Exec()
 	if err != nil {
 		return nil, err
 	}
 
+	log.Println("Init tables finished")
+
 	// init insert folder statement
 	stmt.insertFolder, err = sqlConn.Prepare(insertFolderQuery)
 	if err != nil {
@@ -772,5 +771,12 @@ func NewPreparedStatement(sqlConn *sql.DB) (*Stmt, error) {
 		return nil, err
 	}
 
+	stmt.recordPlaybackStmt, err = sqlConn.Prepare(recordPlaybackQuery)
+	if err != nil {
+		return nil, err
+	}
+
+	log.Println("Init statements finished")
+
 	return stmt, err
 }

pkg/database/struct.go

@@ -2,16 +2,18 @@ package database
 
 import (
 	"path/filepath"
+	"time"
 )
 
 type File struct {
-	Db         *Database `json:"-"`
-	ID         int64     `json:"id"`
-	Folder_id  int64     `json:"folder_id"`
-	Foldername string    `json:"foldername"`
-	Realname   string    `json:"-"`
-	Filename   string    `json:"filename"`
-	Filesize   int64     `json:"filesize"`
+	Db          *Database `json:"-"`
+	ID          int64     `json:"id"`
+	Folder_id   int64     `json:"folder_id"`
+	Foldername  string    `json:"foldername"`
+	Realname    string    `json:"-"`
+	Filename    string    `json:"filename"`
+	Filesize    int64     `json:"filesize"`
+	folderCache *Folder
 }
 
 type Folder struct {
@@ -58,6 +60,15 @@ type Feedback struct {
 	Time    int64  `json:"time"`
 }
 
+type Playback struct {
+	ID       int64         `json:"id"`
+	UserID   int64         `json:"user_id"`
+	FileID   int64         `json:"file_id"`
+	Time     time.Time     `json:"time"`
+	Method   int64         `json:"method"`
+	Duration time.Duration `json:"Duration"`
+}
+
 var (
 	RoleAnonymous = int64(0)
 	RoleAdmin     = int64(1)
@@ -65,9 +76,23 @@ var (
 )
 
 func (f *File) Path() (string, error) {
-	folder, err := f.Db.GetFolder(f.Folder_id)
+	var err error
+	if f.folderCache == nil {
+		f.folderCache, err = f.Db.GetFolder(f.Folder_id)
+	}
 	if err != nil {
 		return "", err
 	}
-	return filepath.Join(folder.Folder, f.Realname), nil
+	return filepath.Join(f.folderCache.Folder, f.Realname), nil
+}
+
+func (f *File) Dir() (string, error) {
+	var err error
+	if f.folderCache == nil {
+		f.folderCache, err = f.Db.GetFolder(f.Folder_id)
+	}
+	if err != nil {
+		return "", err
+	}
+	return f.folderCache.Folder, nil
 }

web/README.md

@@ -1,70 +1,9 @@
-# Getting Started with Create React App
+# MSW Open Music Web Frontend
 
-This project was bootstrapped with [Create React App](https://github.com/facebook/create-react-app).
+This is a React single page application. And use Preact instead of React to achieve a smaller file size.
 
-## Available Scripts
+`node_modules` only has 19M. We uses esbuild and shell scripts and build only takes a milliseconds!
 
-In the project directory, you can run:
+## How to build
 
-### `npm start`
-
-Runs the app in the development mode.\
-Open [http://localhost:3000](http://localhost:3000) to view it in the browser.
-
-The page will reload if you make edits.\
-You will also see any lint errors in the console.
-
-### `npm test`
-
-Launches the test runner in the interactive watch mode.\
-See the section about [running tests](https://facebook.github.io/create-react-app/docs/running-tests) for more information.
-
-### `npm run build`
-
-Builds the app for production to the `build` folder.\
-It correctly bundles React in production mode and optimizes the build for the best performance.
-
-The build is minified and the filenames include the hashes.\
-Your app is ready to be deployed!
-
-See the section about [deployment](https://facebook.github.io/create-react-app/docs/deployment) for more information.
-
-### `npm run eject`
-
-**Note: this is a one-way operation. Once you `eject`, you can’t go back!**
-
-If you aren’t satisfied with the build tool and configuration choices, you can `eject` at any time. This command will remove the single build dependency from your project.
-
-Instead, it will copy all the configuration files and the transitive dependencies (webpack, Babel, ESLint, etc) right into your project so you have full control over them. All of the commands except `eject` will still work, but they will point to the copied scripts so you can tweak them. At this point you’re on your own.
-
-You don’t have to ever use `eject`. The curated feature set is suitable for small and middle deployments, and you shouldn’t feel obligated to use this feature. However we understand that this tool wouldn’t be useful if you couldn’t customize it when you are ready for it.
-
-## Learn More
-
-You can learn more in the [Create React App documentation](https://facebook.github.io/create-react-app/docs/getting-started).
-
-To learn React, check out the [React documentation](https://reactjs.org/).
-
-### Code Splitting
-
-This section has moved here: [https://facebook.github.io/create-react-app/docs/code-splitting](https://facebook.github.io/create-react-app/docs/code-splitting)
-
-### Analyzing the Bundle Size
-
-This section has moved here: [https://facebook.github.io/create-react-app/docs/analyzing-the-bundle-size](https://facebook.github.io/create-react-app/docs/analyzing-the-bundle-size)
-
-### Making a Progressive Web App
-
-This section has moved here: [https://facebook.github.io/create-react-app/docs/making-a-progressive-web-app](https://facebook.github.io/create-react-app/docs/making-a-progressive-web-app)
-
-### Advanced Configuration
-
-This section has moved here: [https://facebook.github.io/create-react-app/docs/advanced-configuration](https://facebook.github.io/create-react-app/docs/advanced-configuration)
-
-### Deployment
-
-This section has moved here: [https://facebook.github.io/create-react-app/docs/deployment](https://facebook.github.io/create-react-app/docs/deployment)
-
-### `npm run build` fails to minify
-
-This section has moved here: [https://facebook.github.io/create-react-app/docs/troubleshooting#npm-run-build-fails-to-minify](https://facebook.github.io/create-react-app/docs/troubleshooting#npm-run-build-fails-to-minify)
+Simple run `./build.sh`, then all output files are under `./build/` directory.

web/build.js

@@ -0,0 +1,20 @@
+const fs = require("fs");
+const esbuild = require("esbuild");
+
+(async () => {
+  fs.rmSync("build", { recursive: true, force: true });
+  fs.cpSync("public", "build", { recursive: true });
+
+  const result = await esbuild.build({
+    entryPoints: ["src/index.jsx"],
+    bundle: true,
+    outfile: "build/msw-open-music.js",
+    sourcemap: true,
+    minify: true,
+    metafile: true,
+  });
+
+  const text = await esbuild.analyzeMetafile(result.metafile);
+  console.log(text);
+  console.log("Build done, output files udner ./build directory");
+})();

web/package.json

@@ -3,42 +3,12 @@
   "version": "1.2.0",
   "private": true,
   "dependencies": {
-    "@testing-library/jest-dom": "^5.15.0",
-    "@testing-library/react": "^11.2.7",
-    "@testing-library/user-event": "^12.8.3",
-    "react": "^17.0.2",
-    "react-dom": "^17.0.2",
-    "react-router": "^6.3.0",
-    "react-router-dom": "^6.3.0",
-    "react-scripts": "^4.0.3",
-    "water.css": "^2.1.1",
-    "web-vitals": "^1.1.2"
+    "@preact/compat": "^17.1.2",
+    "esbuild": "^0.15.17",
+    "react-router-dom": "^6.4.4",
+    "water.css": "^2.1.1"
   },
   "scripts": {
-    "start": "react-scripts start",
-    "build": "react-scripts build",
-    "test": "react-scripts test",
-    "eject": "react-scripts eject"
-  },
-  "eslintConfig": {
-    "extends": [
-      "react-app",
-      "react-app/jest"
-    ]
-  },
-  "browserslist": {
-    "production": [
-      ">0.2%",
-      "not dead",
-      "not op_mini all"
-    ],
-    "development": [
-      "last 1 chrome version",
-      "last 1 firefox version",
-      "last 1 safari version"
-    ]
-  },
-  "devDependencies": {
-    "@types/react": "^17.0.34"
+    "build": "node build.js"
   }
 }

web/public/index.html

@@ -2,40 +2,18 @@
 <html lang="en">
   <head>
     <meta charset="utf-8" />
-    <link rel="icon" href="%PUBLIC_URL%/favicon.png" />
+    <link rel="icon" href="./favicon.png" />
     <meta name="viewport" content="width=device-width, initial-scale=1" />
     <meta name="description" content="Personal music streaming platform" />
-    <link rel="apple-touch-icon" href="%PUBLIC_URL%/favicon.png" />
-    <!--
-      manifest.json provides metadata used when your web app is installed on a
-      user's mobile device or desktop. See https://developers.google.com/web/fundamentals/web-app-manifest/
-    -->
-    <link rel="manifest" href="%PUBLIC_URL%/manifest.json" />
-    <!--
-      Notice the use of %PUBLIC_URL% in the tags above.
-      It will be replaced with the URL of the `public` folder during the build.
-      Only files inside the `public` folder can be referenced from the HTML.
-
-      Unlike "/favicon.ico" or "favicon.ico", "%PUBLIC_URL%/favicon.ico" will
-      work correctly both with client-side routing and a non-root public URL.
-      Learn how to configure a non-root public URL by running `npm run build`.
-    -->
-    <!-- Add to homescreen for Chrome on Android -->
+    <link rel="apple-touch-icon" href="./favicon.png" />
+    <link rel="manifest" href="./manifest.json" />
+    <link rel="stylesheet" href="./msw-open-music.css" />
     <meta name="mobile-web-app-capable" content="yes" />
     <title>MSW Open Music</title>
   </head>
   <body>
     <noscript>You need to enable JavaScript to run this app.</noscript>
     <div id="root"></div>
-    <!--
-      This HTML file is a template.
-      If you open it directly in the browser, you will see an empty page.
-
-      You can add webfonts, meta tags, or analytics to this file.
-      The build step will place the bundled scripts into the <body> tag.
-
-      To begin the development, run `npm start` or `yarn start`.
-      To create a production bundle, use `npm run build` or `yarn build`.
-    -->
+    <script type="module" src="./msw-open-music.js"></script>
   </body>
 </html>

web/src/App.css

@@ -1,13 +1,8 @@
-html {
-  font-size: 1em;
-}
-body {
-  margin: auto;
-  margin-top: 1rem;
-}
 .base {
   display: grid;
   grid-row-gap: 1em;
+  max-width: 800px;
+  width: 100%;
 }
 .header {
   color: white;
@@ -40,54 +35,10 @@ body {
   color: rgb(229, 232, 245);
   padding: 1em;
 }
-a.unset {
-  color: unset;
-  text-decoration: unset;
-}
-a.active {
-  color: deeppink;
-  background-color: lightgray;
-  border-radius: 0.39em 0.39em 0 0;
-}
 .audio-player {
   height: 39px;
   width: 100%;
 }
-td.clickable {
-  cursor: pointer;
-}
-div.clickable {
-  cursor: pointer;
-}
-div.page {
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-}
-div.search_toolbar {
-  display: flex;
-  flex-direction: row;
-  flex-wrap: wrap;
-  justify-content: flex-end;
-  width: 100%;
-}
-div.feedback {
-  display: flex;
-  flex-direction: row;
-  flex-wrap: wrap;
-}
-button.refresh {
-  width: 100%;
-}
-td,
-th {
-  padding-bottom: 0.5em;
-  padding-top: 0.5em;
-}
-dialog {
-  border: solid;
-}
 .player-options {
   display: flex;
 }

web/src/App.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { HashRouter as Router, Routes, Route, NavLink } from "react-router-dom";
 import "./App.css";
 
@@ -27,6 +28,27 @@ function App() {
   const [user, setUser] = useState({});
   const [langCode, setLangCode] = useState("en_US");
 
+  useEffect(() => {
+    if (playingFile.id === undefined) {
+      return;
+    }
+    const html = document.getElementsByTagName("html")[0];
+    const retStyle = html.style;
+    const bodyRetStyle = document.body.style
+    html.style = `
+      backdrop-filter: blur(10px);
+      background-size: cover;
+      background-attachment: fixed;
+      background-position: center;
+      background-image: url("/api/v1/get_file_avatar?id=${playingFile.id}");
+    `;
+    document.body.style.opacity = 0.88;
+    return () => {
+      html.style = retStyle;
+      document.body.style = bodyRetStyle;
+    };
+  }, [playingFile.id]);
+
   // select language
   useEffect(() => {
     const browserCode = window.navigator.language;
@@ -40,7 +62,7 @@ function App() {
       }
     }
     // fallback to english
-    setLangCode('en-US');
+    setLangCode("en-US");
   }, []);
 
   return (

web/src/component/AudioPlayer.jsx

@@ -1,9 +1,10 @@
-import { useEffect, useState } from "react";
-import { useNavigate } from "react-router";
-import { CalcReadableFilesizeDetail } from "./Common";
+import * as React from 'react';
+import {useEffect, useState} from "react";
+import {useNavigate} from "react-router";
+import {CalcReadableFilesizeDetail} from "./Common";
 import FfmpegConfig from "./FfmpegConfig";
 import FileDialog from "./FileDialog";
-import { Tr } from "../translate";
+import {Tr} from "../translate";
 
 function AudioPlayer(props) {
   // props.playingFile
@@ -21,25 +22,50 @@ function AudioPlayer(props) {
   const [isPreparing, setIsPreparing] = useState(false);
   const [timerCount, setTimerCount] = useState(0);
   const [timerID, setTimerID] = useState(null);
+  const [beginPlayTime, setBeginPlayTime] = useState(null);
+  const [lastID, setLastID] = useState(null);
+
+  const recordPlaybackHistory = async (file_id, method) => {
+    if (file_id === null) {
+      return
+    }
+    const player = document.getElementById('dom-player')
+    const endPlayTime = new Date()
+    let duration = parseInt((endPlayTime - beginPlayTime) / 1000)
+    const maxDuration = parseInt(player.duration)
+    // treat 85% of duration as finished
+    if (duration / maxDuration >= 0.85) {
+      method = 1
+    }
+    duration = duration < maxDuration ? duration : maxDuration
+    setBeginPlayTime(endPlayTime)
+    await fetch('/api/v1/record_playback', {
+      method: "POST",
+      headers: {
+        "Content-Type": "application/json",
+      },
+      body: JSON.stringify({
+        playback: {
+          file_id,
+          method,
+          duration,
+        },
+      })
+    })
+  }
 
   // init mediaSession API
   useEffect(() => {
-    navigator.mediaSession.setActionHandler("stop", () => {
-      props.setPlayingFile({});
-    });
+    if (navigator.mediaSession) {
+      navigator.mediaSession.setActionHandler("stop", () => {
+        props.setPlayingFile({});
+      });
+    }
   }, []);
 
-  useEffect(() => {
-    // media session related staff
-    navigator.mediaSession.metadata = new window.MediaMetadata({
-      title: props.playingFile.filename,
-      album: props.playingFile.foldername,
-      artwork: [{ src: "/favicon.png", type: "image/png" }],
-    });
-    // no playing file
+  const updatePlayMode = () => {
     if (props.playingFile.id === undefined) {
-      setPlayingURL("");
-      return;
+      return
     }
     if (raw) {
       console.log("Play raw file");
@@ -50,7 +76,7 @@ function AudioPlayer(props) {
         setIsPreparing(true);
         fetch("/api/v1/prepare_file_stream_direct", {
           method: "POST",
-          headers: { "Content-Type": "application/json" },
+          headers: {"Content-Type": "application/json"},
           body: JSON.stringify({
             id: props.playingFile.id,
             config_name: selectedFfmpegConfig.name,
@@ -75,7 +101,39 @@ function AudioPlayer(props) {
         );
       }
     }
-  }, [props.playingFile.id, raw, prepare, selectedFfmpegConfig]);
+  }
+
+  useEffect(() => {
+    // media session related staff
+    if (navigator.mediaSession) {
+      navigator.mediaSession.metadata = new window.MediaMetadata({
+        title: props.playingFile.filename,
+        album: props.playingFile.foldername,
+        artwork: [{src: "/favicon.png", type: "image/png"}],
+      });
+    }
+    // no playing file
+    if (props.playingFile.id === undefined) {
+      // 3 music stopped
+      recordPlaybackHistory(lastID, 3)
+      setPlayingURL("");
+      return;
+    }
+    // crrently playing file, record interupt
+    if (playingURL) {
+      // 2 music changed
+      recordPlaybackHistory(lastID, 2)
+    }
+    setLastID(props.playingFile.id)
+    // have playingFile, record begin time
+    setBeginPlayTime(new Date())
+    updatePlayMode()
+  }, [props.playingFile.id]);
+
+
+  useEffect(() => {
+    updatePlayMode()
+  }, [raw, prepare, selectedFfmpegConfig])
 
   let navigate = useNavigate();
 
@@ -191,16 +249,26 @@ function AudioPlayer(props) {
         id="dom-player"
         controls
         autoPlay
-        loop={loop}
         className="audio-player"
         src={playingURL}
+        onEnded={async () => {
+          const player = document.getElementById('dom-player')
+          if (loop) {
+            player.play()
+          }
+          // 1 music finished
+          recordPlaybackHistory(props.playingFile.id, 1)
+        }}
+        onPlay={async () => {
+          setBeginPlayTime(new Date());
+        }}
       ></audio>
 
       <FfmpegConfig
         selectedFfmpegConfig={selectedFfmpegConfig}
         setSelectedFfmpegConfig={setSelectedFfmpegConfig}
       />
-    </footer>
+    </footer >
   );
 }
 

web/src/component/Database.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect, useContext } from "react";
 import { Tr, tr, langCodeContext } from "../translate";
 

web/src/component/EditReview.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useContext, useEffect, useState } from "react";
 import { useParams, useNavigate } from "react-router";
 import { tr, Tr, langCodeContext } from "../translate";

web/src/component/EditTag.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect, useContext } from "react";
 import { useParams, useNavigate } from "react-router";
 import { tr, Tr, langCodeContext } from "../translate";

web/src/component/FeedbackPage.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect } from "react";
 import { Link } from "react-router-dom";
 import { convertIntToDateTime } from "./Common";

web/src/component/FfmpegConfig.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useEffect, useState } from "react";
 
 function FfmpegConfig(props) {

web/src/component/FileDialog.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useNavigate } from "react-router";
 import { Tr } from "../translate";
 

web/src/component/FileEntry.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState } from "react";
 import { useNavigate } from "react-router";
 import { CalcReadableFilesize } from "./Common";

web/src/component/FileInfo.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import {useNavigate, useParams} from "react-router";
 import {useContext, useEffect, useState} from "react";
 import {Tr, tr, langCodeContext} from "../translate";

web/src/component/FilesInFolder.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import {useParams} from "react-router";
 import {useState, useEffect} from "react";
 import {useNavigate} from "react-router-dom";

web/src/component/FilesTable.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import FileEntry from "./FileEntry";
 import { Tr } from "../translate";
 

web/src/component/FoldersTable.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useNavigate } from "react-router";
 import { Tr } from "../translate";
 

web/src/component/GetRandomFiles.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useContext, useEffect, useState } from "react";
 import { useNavigate } from "react-router-dom";
 import { useQuery } from "./Common";

web/src/component/Login.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useNavigate } from "react-router-dom";
 import { useContext, useState } from "react";
 import { Tr, tr, langCodeContext } from "../translate";

web/src/component/Manage.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useNavigate } from "react-router";
 import Database from "./Database";
 

web/src/component/ManageUser.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect } from "react";
 import { Link } from "react-router-dom";
 import { Tr } from "../translate";

web/src/component/Register.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useNavigate } from "react-router-dom";
 import { useContext, useState } from "react";
 import { tr, Tr, langCodeContext } from "../translate";

web/src/component/ReviewEntry.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { Link } from "react-router-dom";
 import { convertIntToDateTime } from "./Common";
 import { Tr, tr, langCodeContext } from "../translate";

web/src/component/ReviewPage.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect } from "react";
 import { useParams } from "react-router";
 import ReviewEntry from "./ReviewEntry";

web/src/component/SearchFiles.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect, useContext } from "react";
 import { useNavigate } from "react-router-dom";
 import { useQuery } from "./Common";

web/src/component/SearchFolders.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useContext, useEffect, useState } from "react";
 import { useNavigate } from "react-router-dom";
 import { useQuery } from "./Common";

web/src/component/Share.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useContext, useEffect, useState } from "react";
 import { useParams } from "react-router";
 import FilesTable from "./FilesTable";

web/src/component/Tags.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useEffect, useState } from "react";
 import { Link } from "react-router-dom";
 import { Tr } from "../translate";

web/src/component/UserProfile.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useState, useEffect, useContext } from "react";
 import { useParams } from "react-router";
 import ReviewEntry from "./ReviewEntry";

web/src/component/UserStatus.jsx

@@ -1,3 +1,4 @@
+import * as React from 'react';
 import { useEffect } from 'react';
 
 function UserStatus(props) {

web/src/index.css

@@ -1,13 +1,66 @@
+#root {
+  display: flex;
+  justify-content: center;
+}
+html {
+  font-size: 1em;
+}
 body {
-  margin: 0;
-  font-family: -apple-system, BlinkMacSystemFont, 'Segoe UI', 'Roboto', 'Oxygen',
-    'Ubuntu', 'Cantarell', 'Fira Sans', 'Droid Sans', 'Helvetica Neue',
+  margin: auto;
+  padding-top: 1rem;
+  max-width: none;
+  min-height: 100vh;
+  font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", "Roboto", "Oxygen",
+    "Ubuntu", "Cantarell", "Fira Sans", "Droid Sans", "Helvetica Neue",
     sans-serif;
   -webkit-font-smoothing: antialiased;
   -moz-osx-font-smoothing: grayscale;
 }
-
 code {
-  font-family: source-code-pro, Menlo, Monaco, Consolas, 'Courier New',
+  font-family: source-code-pro, Menlo, Monaco, Consolas, "Courier New",
     monospace;
 }
+a.unset {
+  color: unset;
+  text-decoration: unset;
+}
+a.active {
+  color: deeppink;
+  background-color: lightgray;
+  border-radius: 0.39em 0.39em 0 0;
+}
+td.clickable {
+  cursor: pointer;
+}
+div.clickable {
+  cursor: pointer;
+}
+div.page {
+  display: flex;
+  flex-direction: column;
+  align-items: center;
+  justify-content: center;
+}
+div.search_toolbar {
+  display: flex;
+  flex-direction: row;
+  flex-wrap: wrap;
+  justify-content: flex-end;
+  width: 100%;
+}
+div.feedback {
+  display: flex;
+  flex-direction: row;
+  flex-wrap: wrap;
+}
+button.refresh {
+  width: 100%;
+}
+td,
+th {
+  padding-bottom: 0.5em;
+  padding-top: 0.5em;
+}
+dialog {
+  border: solid;
+}

web/src/index.js

@@ -1,18 +0,0 @@
-import React from 'react';
-import ReactDOM from 'react-dom';
-import './index.css';
-import 'water.css';
-import App from './App';
-import reportWebVitals from './reportWebVitals';
-
-ReactDOM.render(
-  <React.StrictMode>
-    <App />
-  </React.StrictMode>,
-  document.getElementById('root')
-);
-
-// If you want to start measuring performance in your app, pass a function
-// to log results (for example: reportWebVitals(console.log))
-// or send to an analytics endpoint. Learn more: https://bit.ly/CRA-vitals
-reportWebVitals();

web/src/index.jsx

@@ -0,0 +1,12 @@
+import React from 'react';
+import ReactDOM from 'react-dom';
+import 'water.css';
+import './index.css';
+import App from './App';
+
+ReactDOM.render(
+  <React.StrictMode>
+    <App />
+  </React.StrictMode>,
+  document.getElementById('root')
+);

web/src/reportWebVitals.js

@@ -1,13 +0,0 @@
-const reportWebVitals = onPerfEntry => {
-  if (onPerfEntry && onPerfEntry instanceof Function) {
-    import('web-vitals').then(({ getCLS, getFID, getFCP, getLCP, getTTFB }) => {
-      getCLS(onPerfEntry);
-      getFID(onPerfEntry);
-      getFCP(onPerfEntry);
-      getLCP(onPerfEntry);
-      getTTFB(onPerfEntry);
-    });
-  }
-};
-
-export default reportWebVitals;

web/src/translate/index.jsx

@@ -1,4 +1,5 @@
-import { createContext, renderToString } from "react";
+import * as React from 'react';
+import { createContext } from "react";
 import MAP_zh_CN from "./zh_CN";
 
 const LANG_OPTIONS = {