Compare commits

...

7 Commits

10 changed files with 36 additions and 61 deletions

View File

@ -25,7 +25,7 @@ func getActorsFromDB() {
* @apiSuccess {string} .Thumbnail Portrait Thumbnail * @apiSuccess {string} .Thumbnail Portrait Thumbnail
*/ */
api.AddHandler("getAllActors", api.ActorNode, api.PermUser, func(context api.Context) { api.AddHandler("getAllActors", api.ActorNode, api.PermUser, func(context api.Context) {
query := "SELECT actor_id, name, thumbnail FROM actors" query := "SELECT actor_id, name, thumbnail FROM actors ORDER BY name ASC"
context.Json(readActorsFromResultset(database.Query(query))) context.Json(readActorsFromResultset(database.Query(query)))
}) })

View File

@ -7,7 +7,6 @@ import (
"openmediacenter/apiGo/database" "openmediacenter/apiGo/database"
"openmediacenter/apiGo/videoparser" "openmediacenter/apiGo/videoparser"
"os" "os"
"path/filepath"
) )
func addUploadHandler() { func addUploadHandler() {
@ -31,11 +30,11 @@ func addUploadHandler() {
break break
} }
// todo allow more video formats than mp4
// only allow valid extensions // only allow valid extensions
if filepath.Ext(part.FileName()) != ".mp4" { if !videoparser.ValidVideoSuffix(part.FileName()) {
continue continue
} }
vidpath := PathPrefix + mSettings.VideoPath + part.FileName() vidpath := PathPrefix + mSettings.VideoPath + part.FileName()
dst, err := os.OpenFile(vidpath, os.O_WRONLY|os.O_CREATE, 0644) dst, err := os.OpenFile(vidpath, os.O_WRONLY|os.O_CREATE, 0644)
if err != nil { if err != nil {

View File

@ -78,7 +78,7 @@ func getFromDB() {
* @apiSuccess {string} TagName name of the Tag * @apiSuccess {string} TagName name of the Tag
*/ */
api.AddHandler("getAllTags", api.TagNode, api.PermUser, func(context api.Context) { api.AddHandler("getAllTags", api.TagNode, api.PermUser, func(context api.Context) {
query := "SELECT tag_id,tag_name from tags ORDER BY tag_name" query := "SELECT tag_id,tag_name from tags ORDER BY tag_name ASC"
context.Json(readTagsFromResultset(database.Query(query))) context.Json(readTagsFromResultset(database.Query(query)))
}) })
} }

View File

@ -21,7 +21,7 @@ func (p Perm) String() string {
} }
const SignKey = "89013f1753a6890c6090b09e3c23ff43" const SignKey = "89013f1753a6890c6090b09e3c23ff43"
const TokenExpireHours = 24 const TokenExpireHours = 8760
type Token struct { type Token struct {
Token string Token string

View File

@ -5,7 +5,6 @@ import (
"encoding/json" "encoding/json"
"fmt" "fmt"
"net/http" "net/http"
"reflect"
) )
func Jsonify(v interface{}) []byte { func Jsonify(v interface{}) []byte {
@ -30,45 +29,3 @@ func DecodeRequest(request *http.Request, arg interface{}) error {
return err return err
} }
// setField set a specific field of an object with an object provided
func setField(obj interface{}, name string, value interface{}) error {
structValue := reflect.ValueOf(obj).Elem()
structFieldValue := structValue.FieldByName(name)
if !structFieldValue.IsValid() {
return fmt.Errorf("no such field: %s in obj", name)
}
if !structFieldValue.CanSet() {
return fmt.Errorf("cannot set %s field value", name)
}
structFieldType := structFieldValue.Type()
val := reflect.ValueOf(value)
if structFieldType != val.Type() {
if val.Type().ConvertibleTo(structFieldType) {
// if type is convertible - convert and set
structFieldValue.Set(val.Convert(structFieldType))
} else {
return fmt.Errorf("provided value %s type didn't match obj field type and isn't convertible", name)
}
} else {
// set value if type is the same
structFieldValue.Set(val)
}
return nil
}
// FillStruct fill a custom struct with objects of a map
func FillStruct(i interface{}, m map[string]interface{}) error {
for k, v := range m {
err := setField(i, k, v)
if err != nil {
return err
}
}
return nil
}

View File

@ -25,20 +25,18 @@ func startTVShowReindex(files []Show) {
} }
func insertEpisodesIfNotExisting(show Show) { func insertEpisodesIfNotExisting(show Show) {
query := "SELECT tvshow_episodes.name, season, episode FROM tvshow_episodes JOIN tvshow t on t.id = tvshow_episodes.tvshow_id WHERE t.name=?" query := "SELECT filename FROM tvshow_episodes JOIN tvshow t on t.id = tvshow_episodes.tvshow_id WHERE t.name=?"
rows := database.Query(query, show.Name) rows := database.Query(query, show.Name)
var dbepisodes []string var dbepisodes []string
for rows.Next() { for rows.Next() {
var epname string var filename string
var season int err := rows.Scan(&filename)
var episode int
err := rows.Scan(&epname, &season, &episode)
if err != nil { if err != nil {
fmt.Println(err.Error()) fmt.Println(err.Error())
} }
dbepisodes = append(dbepisodes, fmt.Sprintf("%s S%02dE%02d.mp4", epname, season, episode)) dbepisodes = append(dbepisodes, filename)
} }
// get those episodes that are missing in db // get those episodes that are missing in db
@ -83,6 +81,10 @@ VALUES (?, ?, ?, (SELECT tvshow.id FROM tvshow WHERE tvshow.name=?), ?, ?)`
// difference returns the elements in `a` that aren't in `b`. // difference returns the elements in `a` that aren't in `b`.
func difference(a, b []string) []string { func difference(a, b []string) []string {
if b == nil || len(b) == 0 {
return a
}
mb := make(map[string]struct{}, len(b)) mb := make(map[string]struct{}, len(b))
for _, x := range b { for _, x := range b {
mb[x] = struct{}{} mb[x] = struct{}{}
@ -129,7 +131,10 @@ func getAllTVShows() *[]string {
var res []string var res []string
for rows.Next() { for rows.Next() {
var show string var show string
rows.Scan(&show) err := rows.Scan(&show)
if err != nil {
continue
}
res = append(res, show) res = append(res, show)
} }

View File

@ -14,6 +14,20 @@ type StatusMessage struct {
ContentAvailable bool ContentAvailable bool
} }
func getVideoTypes() []string {
return []string{".mp4", ".mov", ".mkv", ".flv", ".avi", ".mpeg", ".m4v"}
}
func ValidVideoSuffix(filename string) bool {
validExts := getVideoTypes()
for _, validExt := range validExts {
if strings.HasSuffix(filename, validExt) {
return true
}
}
return false
}
func StartReindex() bool { func StartReindex() bool {
fmt.Println("starting reindex..") fmt.Println("starting reindex..")
SendEvent("start") SendEvent("start")
@ -40,7 +54,7 @@ func StartReindex() bool {
var files []string var files []string
for _, file := range filelist { for _, file := range filelist {
if !file.IsDir() && strings.HasSuffix(file.Name(), ".mp4") { if !file.IsDir() && ValidVideoSuffix(file.Name()) {
files = append(files, file.Name()) files = append(files, file.Name())
} }
} }
@ -103,7 +117,7 @@ func StartTVShowReindex() {
} }
for _, epfile := range episodefiles { for _, epfile := range episodefiles {
if strings.HasSuffix(epfile.Name(), ".mp4") { if ValidVideoSuffix(epfile.Name()) {
elem.files = append(elem.files, epfile.Name()) elem.files = append(elem.files, epfile.Name())
} }
} }

View File

@ -58,7 +58,7 @@ export class HomePage extends React.Component<Props, state> {
}; };
} }
sortState = SortBy.date; sortState = SortBy.random;
tagState = DefaultTags.all; tagState = DefaultTags.all;
componentDidMount(): void { componentDidMount(): void {

View File

@ -66,7 +66,7 @@ export class EpisodePage extends React.Component<Props, State> {
export const EpisodeTile = (props: {episode: Episode}): JSX.Element => { export const EpisodeTile = (props: {episode: Episode}): JSX.Element => {
const themestyle = GlobalInfos.getThemeStyle(); const themestyle = GlobalInfos.getThemeStyle();
return ( return (
<Link to={'/tvplayer/' + props.episode.ID}> <Link to={'/media/tvplayer/' + props.episode.ID}>
<div className={tileStyle.tile + ' ' + themestyle.secbackground + ' ' + themestyle.textcolor}> <div className={tileStyle.tile + ' ' + themestyle.secbackground + ' ' + themestyle.textcolor}>
<FontAwesomeIcon <FontAwesomeIcon
style={{ style={{

View File

@ -55,7 +55,7 @@ export class TVShowPage extends React.Component<Props, State> {
(result) => callback(result) (result) => callback(result)
); );
}} }}
linkPath={'/tvshows/' + elem.Id} linkPath={'/media/tvshows/' + elem.Id}
/> />
)} )}
data={this.state.loading ? [] : this.data} data={this.state.loading ? [] : this.data}