588 lines
16 KiB
Plaintext
588 lines
16 KiB
Plaintext
sub ShowServerSelect()
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("ConfigScene")
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
scene.findNode("prompt").text = "Connect to Server"
|
|
|
|
config = scene.findNode("configOptions")
|
|
server_field = CreateObject("roSGNode", "ConfigData")
|
|
server_field.label = "Server"
|
|
server_field.field = "server"
|
|
server_field.type = "string"
|
|
port_field = CreateObject("roSGNode", "ConfigData")
|
|
port_field.label = "Port"
|
|
port_field.field = "port"
|
|
port_field.type = "string"
|
|
items = [ server_field, port_field ]
|
|
config.configItems = items
|
|
|
|
button = scene.findNode("submit")
|
|
button.observeField("buttonSelected", port)
|
|
|
|
server_hostname = config.content.getChild(0)
|
|
server_port = config.content.getChild(1)
|
|
|
|
while(true)
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed()
|
|
return
|
|
else if type(msg) = "roSGNodeEvent"
|
|
node = msg.getNode()
|
|
if node = "submit"
|
|
set_setting("server", server_hostname.value)
|
|
set_setting("port", server_port.value)
|
|
return
|
|
end if
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowSignInSelect()
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("ConfigScene")
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
scene.findNode("prompt").text = "Sign In"
|
|
|
|
config = scene.findNode("configOptions")
|
|
username_field = CreateObject("roSGNode", "ConfigData")
|
|
username_field.label = "Username"
|
|
username_field.field = "username"
|
|
username_field.type = "string"
|
|
password_field = CreateObject("roSGNode", "ConfigData")
|
|
password_field.label = "Password"
|
|
password_field.field = "password"
|
|
password_field.type = "password"
|
|
items = [ username_field, password_field ]
|
|
config.configItems = items
|
|
|
|
button = scene.findNode("submit")
|
|
button.observeField("buttonSelected", port)
|
|
|
|
config = scene.findNode("configOptions")
|
|
|
|
username = config.content.getChild(0)
|
|
password = config.content.getChild(1)
|
|
|
|
while(true)
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed()
|
|
return
|
|
else if type(msg) = "roSGNodeEvent"
|
|
node = msg.getNode()
|
|
if node = "submit"
|
|
' Validate credentials
|
|
get_token(username.value, password.value)
|
|
if get_setting("active_user") <> invalid then return
|
|
print "Login attempt failed..."
|
|
end if
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowLibrarySelect()
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("Library")
|
|
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
|
|
library = scene.findNode("LibrarySelect")
|
|
libs = LibraryList()
|
|
library.libList = libs
|
|
|
|
library.observeField("itemSelected", port)
|
|
|
|
search = scene.findNode("search")
|
|
search.observeField("escape", port)
|
|
search.observeField("search_value", port)
|
|
|
|
sidepanel = scene.findNode("options")
|
|
new_options = []
|
|
options_buttons = [
|
|
{"title": "Change server", "id": "change_server"},
|
|
{"title": "Sign out", "id": "sign_out"}
|
|
]
|
|
for each opt in options_buttons
|
|
o = CreateObject("roSGNode", "OptionsButton")
|
|
o.title = opt.title
|
|
o.id = opt.id
|
|
new_options.append([o])
|
|
o.observeField("escape", port)
|
|
end for
|
|
|
|
sidepanel.options = new_options
|
|
sidepanel.observeField("escape", port)
|
|
|
|
while(true)
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "search"
|
|
library.setFocus(true)
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "options"
|
|
library.setFocus(true)
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "change_server"
|
|
unset_setting("server")
|
|
unset_setting("port")
|
|
SignOut()
|
|
return
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "sign_out"
|
|
SignOut()
|
|
return
|
|
else if nodeEventQ(msg, "search_value")
|
|
query = msg.getRoSGNode().search_value
|
|
if query <> invalid or query <> ""
|
|
ShowSearchOptions(query)
|
|
end if
|
|
search.search_value = ""
|
|
else if nodeEventQ(msg, "itemSelected")
|
|
target = getMsgRowTarget(msg)
|
|
if target.libraryType = "movies"
|
|
ShowMovieOptions(target.data)
|
|
else if target.libraryType = "tvshows"
|
|
ShowTVShowOptions(target.data)
|
|
else if target.libraryType = "boxsets"
|
|
ShowCollections(target.data)
|
|
else
|
|
scene.dialog = make_dialog("This library type is not yet implemented: " + target.libraryType)
|
|
scene.dialog.observeField("buttonSelected", port)
|
|
end if
|
|
else if nodeEventQ(msg, "buttonSelected")
|
|
if msg.getNode() = "popup"
|
|
msg.getRoSGNode().close = true
|
|
end if
|
|
else
|
|
print msg
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowMovieOptions(library)
|
|
library_id = library.id
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("Movies")
|
|
|
|
screen.show()
|
|
|
|
overhang = scene.findNode("overhang")
|
|
overhang.title = library.name
|
|
|
|
themeScene(scene)
|
|
|
|
options = scene.findNode("MovieSelect")
|
|
options.library = library
|
|
|
|
page_num = 1
|
|
page_size = 30
|
|
|
|
sort_order = get_user_setting("movie_sort_order", "Descending")
|
|
sort_field = get_user_setting("movie_sort_field", "DateCreated,SortName")
|
|
|
|
options_list = ItemList(library_id, {"limit": page_size,
|
|
"StartIndex": page_size * (page_num - 1),
|
|
"SortBy": sort_field,
|
|
"SortOrder": sort_order })
|
|
options.movieData = options_list
|
|
|
|
options.observeField("itemSelected", port)
|
|
|
|
pager = scene.findNode("pager")
|
|
pager.currentPage = page_num
|
|
pager.maxPages = options_list.TotalRecordCount / page_size
|
|
if pager.maxPages = 0 then pager.maxPages = 1
|
|
|
|
pager.observeField("escape", port)
|
|
pager.observeField("pageSelected", port)
|
|
|
|
sidepanel = scene.findNode("options")
|
|
movie_options = [
|
|
{"title": "Sort Field",
|
|
"base_title": "Sort Field",
|
|
"key": "movie_sort_field",
|
|
"default": "DateCreated",
|
|
"values": ["DateCreated", "PremiereDate", "SortName"]},
|
|
{"title": "Sort Order",
|
|
"base_title": "Sort Order",
|
|
"key": "movie_sort_order",
|
|
"default": "Descending",
|
|
"values": ["Descending", "Ascending"]}
|
|
]
|
|
new_options = []
|
|
for each opt in movie_options
|
|
o = CreateObject("roSGNode", "OptionsData")
|
|
o.title = opt.title
|
|
o.choices = opt.values
|
|
o.base_title = opt.base_title
|
|
o.config_key = opt.key
|
|
o.value = get_user_setting(opt.key, opt.default)
|
|
new_options.append([o])
|
|
end for
|
|
|
|
sidepanel.options = new_options
|
|
sidepanel.observeField("escape", port)
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "pager"
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "options"
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "pageSelected") and pager.pageSelected <> invalid
|
|
pager.pageSelected = invalid
|
|
page_num = int(val(msg.getData().id))
|
|
pager.currentPage = page_num
|
|
options_list = ItemList(library_id, {"limit": page_size,
|
|
"StartIndex": page_size * (page_num - 1),
|
|
"SortBy": sort_order,
|
|
"SortOrder": sort_field })
|
|
options.movieData = options_list
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "itemSelected")
|
|
target = getMsgRowTarget(msg)
|
|
ShowMovieDetails(target.movieID)
|
|
else
|
|
print msg
|
|
print msg.getField()
|
|
print msg.getData()
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowMovieDetails(movie_id)
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("MovieItemDetailScene")
|
|
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
|
|
content = createObject("roSGNode", "MovieData")
|
|
content.full_data = ItemMetaData(movie_id)
|
|
scene.itemContent = content
|
|
|
|
buttons = scene.findNode("buttons")
|
|
for each b in buttons.getChildren(-1, 0)
|
|
b.observeField("buttonSelected", port)
|
|
end for
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "buttonSelected")
|
|
if msg.getNode() = "play-button"
|
|
showVideoPlayer(movie_id)
|
|
else if msg.getNode() = "watched-button"
|
|
if content.watched
|
|
UnmarkItemWatched(movie_id)
|
|
else
|
|
MarkItemWatched(movie_id)
|
|
end if
|
|
content.watched = not content.watched
|
|
else if msg.getNode() = "favorite-button"
|
|
if content.favorite
|
|
UnmarkItemFavorite(movie_id)
|
|
else
|
|
MarkItemFavorite(movie_id)
|
|
end if
|
|
content.favorite = not content.favorite
|
|
end if
|
|
else
|
|
print msg
|
|
print type(msg)
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowTVShowOptions(library)
|
|
library_id = library.ID
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("TVShows")
|
|
|
|
screen.show()
|
|
|
|
overhang = scene.findNode("overhang")
|
|
overhang.title = library.name
|
|
|
|
themeScene(scene)
|
|
|
|
options = scene.findNode("TVShowSelect")
|
|
options.library = library
|
|
|
|
page_num = 1
|
|
page_size = 30
|
|
|
|
sort_order = get_user_setting("tvshow_sort_order", "Descending")
|
|
sort_field = get_user_setting("tvshow_sort_field", "DateCreated,SortName")
|
|
|
|
options_list = ItemList(library_id, {"limit": page_size,
|
|
"page": page_num,
|
|
"SortBy": sort_field,
|
|
"SortOrder": sort_order })
|
|
options.TVShowData = options_list
|
|
|
|
options.observeField("itemSelected", port)
|
|
|
|
pager = scene.findNode("pager")
|
|
pager.currentPage = page_num
|
|
pager.maxPages = options_list.TotalRecordCount / page_size
|
|
if pager.maxPages = 0 then pager.maxPages = 1
|
|
|
|
pager.observeField("escape", port)
|
|
pager.observeField("pageSelected", port)
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if nodeEventQ(msg, "escape") and msg.getNode() = "pager"
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "pageSelected") and pager.pageSelected <> invalid
|
|
pager.pageSelected = invalid
|
|
page_num = int(val(msg.getData().id))
|
|
pager.currentPage = page_num
|
|
options_list = ItemList(library_id, {"limit": page_size,
|
|
"StartIndex": page_size * (page_num - 1),
|
|
"SortBy": sort_field,
|
|
"SortOrder": sort_order })
|
|
options.TVShowData = options_list
|
|
options.setFocus(true)
|
|
else if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "itemSelected")
|
|
target = getMsgRowTarget(msg)
|
|
ShowTVShowDetails(target.showID)
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowTVShowDetails(show_id)
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("TVShowItemDetailScene")
|
|
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
|
|
content = createObject("roSGNode", "TVShowData")
|
|
content.full_data = ItemMetaData(show_id)
|
|
scene.itemData = content
|
|
scene.seasonData = TVSeasons(show_id)
|
|
|
|
scene.findNode("panel-desc").findNode("buttons").setFocus(true)
|
|
|
|
'buttons = scene.findNode("buttons")
|
|
'buttons.observeField("buttonSelected", port)
|
|
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "buttonSelected")
|
|
' What button could we even be watching yet
|
|
else
|
|
print msg
|
|
print type(msg)
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowCollections(library)
|
|
library_id = library.id
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("Collections")
|
|
|
|
screen.show()
|
|
|
|
overhang = scene.findNode("overhang")
|
|
overhang.title = library.name
|
|
|
|
themeScene(scene)
|
|
|
|
options = scene.findNode("CollectionSelect")
|
|
options.library = library
|
|
|
|
page_num = 1
|
|
page_size = 30
|
|
|
|
sort_order = get_user_setting("collection_sort_order", "Ascending")
|
|
sort_field = get_user_setting("collection_sort_field", "SortName")
|
|
|
|
options_list = ItemList(library_id, {"limit": page_size,
|
|
"StartIndex": page_size * (page_num - 1),
|
|
"SortBy": sort_field,
|
|
"SortOrder": sort_order })
|
|
options.itemData = options_list
|
|
|
|
options.observeField("itemSelected", port)
|
|
|
|
pager = scene.findNode("pager")
|
|
pager.currentPage = page_num
|
|
pager.maxPages = options_list.TotalRecordCount / page_size
|
|
if pager.maxPages = 0 then pager.maxPages = 1
|
|
|
|
pager.observeField("escape", port)
|
|
pager.observeField("pageSelected", port)
|
|
|
|
sidepanel = scene.findNode("options")
|
|
panel_options = [
|
|
{"title": "Sort Field",
|
|
"base_title": "Sort Field",
|
|
"key": "movie_sort_field",
|
|
"default": "DateCreated",
|
|
"values": ["DateCreated", "PremiereDate", "SortName"]},
|
|
{"title": "Sort Order",
|
|
"base_title": "Sort Order",
|
|
"key": "movie_sort_order",
|
|
"default": "Descending",
|
|
"values": ["Descending", "Ascending"]}
|
|
]
|
|
new_options = []
|
|
for each opt in panel_options
|
|
o = CreateObject("roSGNode", "OptionsData")
|
|
o.title = opt.title
|
|
o.choices = opt.values
|
|
o.base_title = opt.base_title
|
|
o.config_key = opt.key
|
|
o.value = get_user_setting(opt.key, opt.default)
|
|
new_options.append([o])
|
|
end for
|
|
|
|
sidepanel.options = new_options
|
|
sidepanel.observeField("escape", port)
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "pager"
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "escape") and msg.getNode() = "options"
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "pageSelected") and pager.pageSelected <> invalid
|
|
pager.pageSelected = invalid
|
|
page_num = int(val(msg.getData().id))
|
|
pager.currentPage = page_num
|
|
options_list = ItemList(library_id, {"limit": page_size,
|
|
"StartIndex": page_size * (page_num - 1),
|
|
"SortBy": sort_order,
|
|
"SortOrder": sort_field })
|
|
options.itemData = options_list
|
|
options.setFocus(true)
|
|
else if nodeEventQ(msg, "itemSelected")
|
|
target = getMsgRowTarget(msg)
|
|
ShowMovieOptions(target)
|
|
else
|
|
print msg
|
|
print msg.getField()
|
|
print msg.getData()
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub ShowSearchOptions(query)
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("SearchResults")
|
|
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
|
|
options = scene.findNode("SearchSelect")
|
|
|
|
sort_order = get_user_setting("search_sort_order", "Descending")
|
|
sort_field = get_user_setting("search_sort_field", "DateCreated,SortName")
|
|
|
|
results = SearchMedia(query)
|
|
options.itemData = results
|
|
options.query = query
|
|
|
|
options.observeField("itemSelected", port)
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
else if nodeEventQ(msg, "itemSelected")
|
|
target = getMsgRowTarget(msg)
|
|
' TODO - swap this based on target.mediatype
|
|
' types: [ Episode, Movie, Audio, Person, Studio, MusicArtist ]
|
|
ShowMovieDetails(target.mediaID)
|
|
else
|
|
print msg
|
|
print msg.getField()
|
|
print msg.getData()
|
|
end if
|
|
end while
|
|
end sub
|
|
|
|
sub showVideoPlayer(video_id)
|
|
port = CreateObject("roMessagePort")
|
|
screen = CreateObject("roSGScreen")
|
|
screen.setMessagePort(port)
|
|
scene = screen.CreateScene("Scene")
|
|
|
|
screen.show()
|
|
|
|
themeScene(scene)
|
|
|
|
video = VideoPlayer(video_id)
|
|
scene.appendChild(video)
|
|
|
|
video.setFocus(true)
|
|
|
|
video.observeField("state", port)
|
|
|
|
while true
|
|
msg = wait(0, port)
|
|
if type(msg) = "roSGScreenEvent" and msg.isScreenClosed() then
|
|
return
|
|
' Video is already gone by this point
|
|
' TODO - add an event listener higher up that watches for closing
|
|
' so we can handle end of video a bit better
|
|
if video = invalid then return
|
|
|
|
progress = int( video.position / video.duration * 100)
|
|
if progress > 95 ' TODO - max resume percentage
|
|
MarkItemWatched(video_id)
|
|
end if
|
|
ticks = video.position * 10000000
|
|
ItemSessionStop(video_id, {"PositionTicks": ticks})
|
|
return
|
|
else if nodeEventQ(msg, "state")
|
|
state = msg.getData()
|
|
if state = "stopped" or state = "finished"
|
|
screen.close()
|
|
else if state = "playing"
|
|
ticks = video.position * 10000000
|
|
ItemSessionStart(video_id, {"PositionTicks": ticks})
|
|
end if
|
|
end if
|
|
end while
|
|
|
|
end sub
|