Compare commits
72 Commits
02307f1789
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| d92a8753d8 | |||
| b299593076 | |||
| ce10cdc658 | |||
| 5a3f350015 | |||
| d53299e904 | |||
| d12d3ff6b8 | |||
| d67ffa14a3 | |||
| 71047ce9e8 | |||
| 7da716dde4 | |||
| 3a72a2e094 | |||
| 3c565e6fee | |||
| 2dc750a686 | |||
| ed119a4925 | |||
| e4d99aac00 | |||
| e9b8638c27 | |||
| 4997cfabb0 | |||
|
|
0c906464f0 | ||
|
|
5bafc77d97 | ||
| 30aa44312d | |||
| 2031f589b7 | |||
| b909952790 | |||
| 6d651c7ad6 | |||
| 60909b0963 | |||
| 48617b26da | |||
| ad2544a56b | |||
| 80c104772f | |||
| 09082c0c5d | |||
|
|
27e5da9fd2 | ||
| 0bb8ef5f19 | |||
| cc0910e68e | |||
| fd728fa945 | |||
| ec6dfe8371 | |||
| 49d501a8b0 | |||
|
|
e239f9cd4d | ||
|
|
b68d24deda | ||
|
|
1081832df0 | ||
|
|
c3cee78265 | ||
|
|
4d3163740a | ||
|
|
f1953c45e7 | ||
| 685a1aa82c | |||
| 9dfee9d1d3 | |||
| 1e0adc398c | |||
| 3485d5b61a | |||
| cb81a51bfe | |||
| 314201f238 | |||
|
|
12721cbfbc | ||
|
|
5ef11fbee8 | ||
| e73abce65e | |||
| 9b1cb1bb95 | |||
| c9185e9859 | |||
| e4a0d2a848 | |||
| 1401b80057 | |||
| cfae4ec3a5 | |||
| c344e6a522 | |||
| 696c30aa63 | |||
| 1818d8bec9 | |||
| 4af10a998e | |||
| 6736abc277 | |||
| c9c5e18d70 | |||
| 67c52c84a1 | |||
| 80d1fa865c | |||
| a1810e3f2c | |||
| 75b9e3e14a | |||
| 7fdb406588 | |||
| 0ab616f48b | |||
| e035b1ed58 | |||
| 3f7ec2fb5c | |||
| 6d209c8942 | |||
| f55924596d | |||
| d84c8321c5 | |||
| 38e0de76df | |||
| 9bdca9eba1 |
47
.github/workflows/build-tebako.yml
vendored
Normal file
@@ -0,0 +1,47 @@
|
||||
name: Build Launcher Binary
|
||||
|
||||
on:
|
||||
push:
|
||||
branches: [ master, test ]
|
||||
workflow_dispatch:
|
||||
|
||||
jobs:
|
||||
build-tebako:
|
||||
runs-on: ubuntu-latest
|
||||
strategy:
|
||||
matrix:
|
||||
architecture: [x64]
|
||||
container:
|
||||
image: ghcr.io/tamatebako/tebako-ubuntu-20.04:latest
|
||||
defaults:
|
||||
run:
|
||||
shell: bash
|
||||
steps:
|
||||
- uses: actions/checkout@v4
|
||||
|
||||
- name: Install Gosu and native dependencies
|
||||
run: |
|
||||
apt-get update
|
||||
apt-get install -y libsdl2-dev libgl1-mesa-dev libopenal-dev libgmp-dev libfontconfig1-dev libsndfile1-dev libmpg123-dev libpango1.0-dev libtool libssl-dev libffi-dev
|
||||
|
||||
- name: Update Bundler and lockfile
|
||||
run: |
|
||||
gem install bundler -v 2.4.22
|
||||
bundle _2.4.22_ lock --update --bundler
|
||||
|
||||
- name: Build Tebako binary
|
||||
run: |
|
||||
tebako press -P -R 3.4.1 -m bundle -o w3d_hub_linux_launcher -r $PWD -e w3d_hub_linux_launcher.rb
|
||||
|
||||
- name: Prepare artifact directory
|
||||
run: |
|
||||
mkdir w3d-hub-launcher-x86_64
|
||||
cp w3d_hub_linux_launcher w3d-hub-launcher-x86_64/
|
||||
cp -r media w3d-hub-launcher-x86_64/
|
||||
cp -r locales w3d-hub-launcher-x86_64/
|
||||
|
||||
- name: Upload artifact
|
||||
uses: actions/upload-artifact@v4
|
||||
with:
|
||||
name: w3d-hub-launcher-x86_64
|
||||
path: w3d-hub-launcher-x86_64
|
||||
18
Gemfile
@@ -4,24 +4,24 @@ gem "base64"
|
||||
gem "excon"
|
||||
gem "cyberarm_engine"
|
||||
gem "sdl2-bindings"
|
||||
gem "libui"
|
||||
gem "libui", platforms: [:windows]
|
||||
gem "digest-crc"
|
||||
gem "i18n"
|
||||
gem "ircparser"
|
||||
gem "rexml"
|
||||
gem "rubyzip"
|
||||
gem "websocket-client-simple"
|
||||
gem "win32-process", platforms: [:x64_mingw, :mingw]
|
||||
gem "win32-security", platforms: [:x64_mingw, :mingw]
|
||||
gem "win32-process", platforms: [:windows]
|
||||
gem "win32-security", platforms: [:windows]
|
||||
|
||||
# PACKAGING NOTES
|
||||
# bundler 2.5.x doesn't seem to play nice with ocra[n]
|
||||
# use `bundle _x.y.z_ COMMAND` to use this one...
|
||||
# NOTE: Releasy needs to be installed as a system gem i.e. `rake install`
|
||||
# NOTE: contents of the `gemhome` folder in the packaged folder need to be moved into the lib/ruby/gems\<RUBY_VERSION> folder
|
||||
# group :windows_packaging do
|
||||
# gem "bundler", "~>2.4.3"
|
||||
# gem "rake"
|
||||
# gem "ocran"
|
||||
# gem "releasy"#, path: "../releasy"
|
||||
# end
|
||||
# group :windows_packaging do
|
||||
# gem "bundler", "~>2.4.3"
|
||||
# gem "rake"
|
||||
# gem "ocran"
|
||||
# gem "releasy"#, path: "../releasy"
|
||||
# end
|
||||
37
Gemfile.lock
@@ -1,30 +1,38 @@
|
||||
GEM
|
||||
remote: https://rubygems.org/
|
||||
specs:
|
||||
base64 (0.2.0)
|
||||
concurrent-ruby (1.2.3)
|
||||
cyberarm_engine (0.24.4)
|
||||
base64 (0.3.0)
|
||||
concurrent-ruby (1.3.5)
|
||||
cyberarm_engine (0.24.5)
|
||||
gosu (~> 1.1)
|
||||
digest-crc (0.6.5)
|
||||
digest-crc (0.7.0)
|
||||
rake (>= 12.0.0, < 14.0.0)
|
||||
event_emitter (0.2.6)
|
||||
excon (0.109.0)
|
||||
ffi (1.16.3)
|
||||
excon (1.3.0)
|
||||
logger
|
||||
ffi (1.17.2-x64-mingw-ucrt)
|
||||
ffi (1.17.2-x86_64-linux-gnu)
|
||||
ffi-win32-extensions (1.0.4)
|
||||
ffi
|
||||
fiddle (1.1.8)
|
||||
gosu (1.4.6)
|
||||
i18n (1.14.1)
|
||||
i18n (1.14.7)
|
||||
concurrent-ruby (~> 1.0)
|
||||
ircparser (1.0.0)
|
||||
libui (0.0.15)
|
||||
rake (13.1.0)
|
||||
rexml (3.2.6)
|
||||
rubyzip (2.3.2)
|
||||
libui (0.2.0-x64-mingw-ucrt)
|
||||
fiddle
|
||||
logger (1.7.0)
|
||||
mutex_m (0.3.0)
|
||||
rake (13.3.0)
|
||||
rexml (3.4.4)
|
||||
rubyzip (3.1.1)
|
||||
sdl2-bindings (0.2.3)
|
||||
ffi (~> 1.15)
|
||||
websocket (1.2.10)
|
||||
websocket-client-simple (0.8.0)
|
||||
websocket (1.2.11)
|
||||
websocket-client-simple (0.9.0)
|
||||
base64
|
||||
event_emitter
|
||||
mutex_m
|
||||
websocket
|
||||
win32-process (0.10.0)
|
||||
ffi (>= 1.0.0)
|
||||
@@ -34,6 +42,7 @@ GEM
|
||||
|
||||
PLATFORMS
|
||||
x64-mingw-ucrt
|
||||
x86_64-linux
|
||||
|
||||
DEPENDENCIES
|
||||
base64
|
||||
@@ -51,4 +60,4 @@ DEPENDENCIES
|
||||
win32-security
|
||||
|
||||
BUNDLED WITH
|
||||
2.4.3
|
||||
2.6.8
|
||||
|
||||
234
lib/api.rb
@@ -1,8 +1,14 @@
|
||||
class W3DHub
|
||||
class Api
|
||||
|
||||
# Set Excon default CA file if found
|
||||
if (ca_file = W3DHub.ca_bundle_path)
|
||||
Excon.defaults[:ssl_ca_file] = ca_file
|
||||
end
|
||||
|
||||
LOG_TAG = "W3DHub::Api".freeze
|
||||
|
||||
API_TIMEOUT = 10 # seconds
|
||||
API_TIMEOUT = 30 # seconds
|
||||
USER_AGENT = "Cyberarm's Linux Friendly W3D Hub Launcher v#{W3DHub::VERSION}".freeze
|
||||
DEFAULT_HEADERS = {
|
||||
"User-Agent": USER_AGENT,
|
||||
@@ -41,11 +47,26 @@ class W3DHub
|
||||
end
|
||||
|
||||
#! === W3D Hub API === !#
|
||||
W3DHUB_API_ENDPOINT = "https://secure.w3dhub.com".freeze # "https://example.com" # "http://127.0.0.1:9292".freeze #
|
||||
W3DHUB_API_CONNECTION = Excon.new(W3DHUB_API_ENDPOINT, persistent: true)
|
||||
|
||||
ENDPOINT = "https://secure.w3dhub.com".freeze
|
||||
ALT_W3DHUB_API_ENDPOINT = "https://w3dhub-api.w3d.cyberarm.dev".freeze # "https://secure.w3dhub.com".freeze # "https://example.com" # "http://127.0.0.1:9292".freeze #
|
||||
ALT_W3DHUB_API_API_CONNECTION = Excon.new(ALT_W3DHUB_API_ENDPOINT, persistent: true)
|
||||
|
||||
def self.excon(method, url, headers = DEFAULT_HEADERS, body = nil)
|
||||
logger.debug(LOG_TAG) { "Fetching #{method.to_s.upcase} \"#{url}\"..." }
|
||||
def self.excon(method, url, headers = DEFAULT_HEADERS, body = nil, backend = :w3dhub)
|
||||
case backend
|
||||
when :w3dhub
|
||||
connection = W3DHUB_API_CONNECTION
|
||||
endpoint = W3DHUB_API_ENDPOINT
|
||||
when :alt_w3dhub
|
||||
connection = ALT_W3DHUB_API_API_CONNECTION
|
||||
endpoint = ALT_W3DHUB_API_ENDPOINT
|
||||
when :gsh
|
||||
connection = GSH_CONNECTION
|
||||
endpoint = SERVER_LIST_ENDPOINT
|
||||
end
|
||||
|
||||
logger.debug(LOG_TAG) { "Fetching #{method.to_s.upcase} \"#{endpoint}#{url}\"..." }
|
||||
|
||||
# Inject Authorization header if account data is populated
|
||||
if Store.account
|
||||
@@ -55,8 +76,52 @@ class W3DHub
|
||||
end
|
||||
|
||||
begin
|
||||
Excon.send(
|
||||
connection.send(
|
||||
method,
|
||||
path: url.sub(endpoint, ""),
|
||||
headers: headers,
|
||||
body: body,
|
||||
nonblock: true,
|
||||
tcp_nodelay: true,
|
||||
write_timeout: API_TIMEOUT,
|
||||
read_timeout: API_TIMEOUT,
|
||||
connect_timeout: API_TIMEOUT,
|
||||
idempotent: true,
|
||||
retry_limit: 3,
|
||||
retry_interval: 1,
|
||||
retry_errors: [Excon::Error::Socket, Excon::Error::HTTPStatus] # Don't retry on timeout
|
||||
)
|
||||
rescue Excon::Error::Timeout => e
|
||||
logger.error(LOG_TAG) { "Connection to \"#{url}\" timed out after: #{API_TIMEOUT} seconds" }
|
||||
|
||||
DummyResponse.new(e)
|
||||
rescue Excon::Error => e
|
||||
logger.error(LOG_TAG) { "Connection to \"#{url}\" errored:" }
|
||||
logger.error(LOG_TAG) { e }
|
||||
|
||||
DummyResponse.new(e)
|
||||
end
|
||||
end
|
||||
|
||||
def self.post(url, headers = DEFAULT_HEADERS, body = nil, backend = :w3dhub)
|
||||
excon(:post, url, headers, body, backend)
|
||||
end
|
||||
|
||||
def self.get(url, headers = DEFAULT_HEADERS, body = nil, backend = :w3dhub)
|
||||
excon(:get, url, headers, body, backend)
|
||||
end
|
||||
|
||||
# Api.get but handles any URL instead of known hosts
|
||||
def self.fetch(url, headers = DEFAULT_HEADERS, body = nil, backend = nil)
|
||||
uri = URI(url)
|
||||
|
||||
# Use Api.get for `W3DHUB_API_ENDPOINT` URL's to exploit keep alive and connection reuse (faster responses)
|
||||
return excon(:get, url, headers, body, backend) if "#{uri.scheme}://#{uri.host}" == W3DHUB_API_ENDPOINT
|
||||
|
||||
logger.debug(LOG_TAG) { "Fetching GET \"#{url}\"..." }
|
||||
|
||||
begin
|
||||
Excon.get(
|
||||
url,
|
||||
headers: headers,
|
||||
body: body,
|
||||
@@ -70,7 +135,7 @@ class W3DHub
|
||||
retry_interval: 1,
|
||||
retry_errors: [Excon::Error::Socket, Excon::Error::HTTPStatus] # Don't retry on timeout
|
||||
)
|
||||
rescue Excon::Errors::Timeout => e
|
||||
rescue Excon::Error::Timeout => e
|
||||
logger.error(LOG_TAG) { "Connection to \"#{url}\" timed out after: #{API_TIMEOUT} seconds" }
|
||||
|
||||
DummyResponse.new(e)
|
||||
@@ -82,10 +147,6 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
def self.post(url, headers = DEFAULT_HEADERS, body = nil)
|
||||
excon(:post, url, headers, body)
|
||||
end
|
||||
|
||||
# Method: POST
|
||||
# FORMAT: JSON
|
||||
|
||||
@@ -101,24 +162,16 @@ class W3DHub
|
||||
#
|
||||
# On a failed login the service responds with:
|
||||
# {"error":"login-failed"}
|
||||
def self.refresh_user_login(refresh_token)
|
||||
def self.refresh_user_login(refresh_token, backend = :w3dhub)
|
||||
body = "data=#{JSON.dump({refreshToken: refresh_token})}"
|
||||
response = post("#{ENDPOINT}/apis/launcher/1/user-login", FORM_ENCODED_HEADERS, body)
|
||||
response = post("/apis/launcher/1/user-login", FORM_ENCODED_HEADERS, body, backend)
|
||||
|
||||
if response.status == 200
|
||||
user_data = JSON.parse(response.body, symbolize_names: true)
|
||||
|
||||
return false if user_data[:error]
|
||||
|
||||
body = "data=#{JSON.dump({ id: user_data[:userid] })}"
|
||||
user_details = post("#{ENDPOINT}/apis/w3dhub/1/get-user-details", FORM_ENCODED_HEADERS, body)
|
||||
|
||||
if user_details.status == 200
|
||||
user_details_data = JSON.parse(user_details.body, symbolize_names: true)
|
||||
else
|
||||
logger.error(LOG_TAG) { "Failed to fetch refresh user details:" }
|
||||
logger.error(LOG_TAG) { user_details }
|
||||
end
|
||||
user_details_data = user_details(user_data[:userid]) || {}
|
||||
|
||||
Account.new(user_data, user_details_data)
|
||||
else
|
||||
@@ -129,24 +182,16 @@ class W3DHub
|
||||
end
|
||||
|
||||
# See #user_refresh_token
|
||||
def self.user_login(username, password)
|
||||
def self.user_login(username, password, backend = :w3dhub)
|
||||
body = "data=#{JSON.dump({username: username, password: password})}"
|
||||
response = post("#{ENDPOINT}/apis/launcher/1/user-login", FORM_ENCODED_HEADERS, body)
|
||||
response = post("/apis/launcher/1/user-login", FORM_ENCODED_HEADERS, body, backend)
|
||||
|
||||
if response.status == 200
|
||||
user_data = JSON.parse(response.body, symbolize_names: true)
|
||||
|
||||
return false if user_data[:error]
|
||||
|
||||
body = "data=#{JSON.dump({ id: user_data[:userid] })}"
|
||||
user_details = post("#{ENDPOINT}/apis/w3dhub/1/get-user-details", FORM_ENCODED_HEADERS, body)
|
||||
|
||||
if user_details.status == 200
|
||||
user_details_data = JSON.parse(user_details.body, symbolize_names: true)
|
||||
else
|
||||
logger.error(LOG_TAG) { "Failed to fetch user details:" }
|
||||
logger.error(LOG_TAG) { user_details }
|
||||
end
|
||||
user_details_data = user_details(user_data[:userid]) || {}
|
||||
|
||||
Account.new(user_data, user_details_data)
|
||||
else
|
||||
@@ -156,18 +201,27 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
# /apis/launcher/1/user-login
|
||||
# Client sends an Authorization header bearer token which is received from logging in (Required?)
|
||||
# /apis/w3dhub/1/get-user-details
|
||||
#
|
||||
# Response: avatar-uri (Image download uri), id, username
|
||||
def self.user_details(id)
|
||||
def self.user_details(id, backend = :w3dhub)
|
||||
body = "data=#{JSON.dump({ id: id })}"
|
||||
user_details = post("/apis/w3dhub/1/get-user-details", FORM_ENCODED_HEADERS, body, backend)
|
||||
|
||||
if user_details.status == 200
|
||||
JSON.parse(user_details.body, symbolize_names: true)
|
||||
else
|
||||
logger.error(LOG_TAG) { "Failed to fetch user details:" }
|
||||
logger.error(LOG_TAG) { user_details }
|
||||
false
|
||||
end
|
||||
end
|
||||
|
||||
# /apis/w3dhub/1/get-service-status
|
||||
# Service response:
|
||||
# {"services":{"authentication":true,"packageDownload":true}}
|
||||
def self.service_status
|
||||
response = post("#{ENDPOINT}/apis/w3dhub/1/get-service-status", DEFAULT_HEADERS)
|
||||
def self.service_status(backend = :w3dhub)
|
||||
response = post("/apis/w3dhub/1/get-service-status", DEFAULT_HEADERS, nil, backend)
|
||||
|
||||
if response.status == 200
|
||||
ServiceStatus.new(response.body)
|
||||
@@ -182,11 +236,11 @@ class W3DHub
|
||||
# Client sends an Authorization header bearer token which is received from logging in (Optional)
|
||||
# Launcher sends an empty data request: data={}
|
||||
# Response is a list of applications/games
|
||||
def self.applications
|
||||
response = post("#{ENDPOINT}/apis/launcher/1/get-applications")
|
||||
def self.applications(backend = :w3dhub)
|
||||
response = post("/apis/launcher/1/get-applications", DEFAULT_HEADERS, nil, backend)
|
||||
|
||||
if response.status == 200
|
||||
Applications.new(response.body)
|
||||
Applications.new(response.body, backend)
|
||||
else
|
||||
logger.error(LOG_TAG) { "Failed to fetch applications list:" }
|
||||
logger.error(LOG_TAG) { response }
|
||||
@@ -194,13 +248,82 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
# Populate applications list from primary and alternate backends
|
||||
# (alternate only has latest public builds of _most_ games)
|
||||
def self._applications
|
||||
applications_primary = Store.account ? Api.applications(:w3dhub) : false
|
||||
applications_alternate = Api.applications(:alt_w3dhub)
|
||||
|
||||
# Fail if we fail to fetch applications list from either backend
|
||||
return false unless applications_primary || applications_alternate
|
||||
|
||||
return applications_alternate unless applications_primary
|
||||
|
||||
# Merge the two app lists together
|
||||
apps = applications_alternate
|
||||
if applications_primary
|
||||
applications_primary.games.each do |game|
|
||||
# Check if game exists in alternate list
|
||||
_game = apps.games.find { |g| g.id == game.id }
|
||||
unless _game
|
||||
apps.games << game
|
||||
|
||||
# App didn't exist in alternates list
|
||||
# comparing channels isn't useful
|
||||
next
|
||||
end
|
||||
|
||||
# If it does, check that all of its channels also exist in alternate list
|
||||
# and that the primary versions are the same as the alternates list
|
||||
game.channels.each do |channel|
|
||||
_channel = _game.channels.find { |c| c.id == channel.id }
|
||||
|
||||
unless _channel
|
||||
_game.channels << channel
|
||||
|
||||
# App didn't have channel in alternates list
|
||||
# comparing channel isn't useful
|
||||
next
|
||||
end
|
||||
|
||||
# If channel versions and access levels match then all's well
|
||||
if channel.current_version == _channel.current_version &&
|
||||
channel.user_level == _channel.user_level
|
||||
|
||||
# All's Well!
|
||||
next
|
||||
end
|
||||
|
||||
# If the access levels don't match then overwrite alternate's channel with primary's channel
|
||||
if channel.user_level != _channel.user_level
|
||||
# Replace alternate's channel with primary's channel
|
||||
_game.channels[_game.channels.index(_channel)] = channel
|
||||
|
||||
# Replaced, continue.
|
||||
next
|
||||
end
|
||||
|
||||
# If versions don't match then pick whichever one is higher
|
||||
if Gem::Version.new(channel.current_version) > Gem::Version.new(_channel.current_version)
|
||||
# Replace alternate's channel with primary's channel
|
||||
_game.channels[_game.channels.index(_channel)] = channel
|
||||
else
|
||||
# Do nothing, alternate backend version is greater.
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
apps
|
||||
end
|
||||
|
||||
# /apis/w3dhub/1/get-news
|
||||
# Client sends an Authorization header bearer token which is received from logging in (Optional)
|
||||
# Client requests news for a specific application/game e.g.: data={"category":"ia"} ("launcher-home" retrieves the weekly hub updates)
|
||||
# Response is a JSON hash with a "highlighted" and "news" keys; the "news" one seems to be the desired one
|
||||
def self.news(category)
|
||||
def self.news(category, backend = :w3dhub)
|
||||
body = "data=#{JSON.dump({category: category})}"
|
||||
response = post("#{ENDPOINT}/apis/w3dhub/1/get-news", FORM_ENCODED_HEADERS, body)
|
||||
response = post("/apis/w3dhub/1/get-news", FORM_ENCODED_HEADERS, body, backend)
|
||||
|
||||
if response.status == 200
|
||||
News.new(response.body)
|
||||
@@ -216,9 +339,9 @@ class W3DHub
|
||||
|
||||
# /apis/launcher/1/get-package-details
|
||||
# client requests package details: data={"packages":[{"category":"games","name":"apb.ico","subcategory":"apb","version":""}]}
|
||||
def self.package_details(packages)
|
||||
def self.package_details(packages, backend = :w3dhub)
|
||||
body = URI.encode_www_form("data": JSON.dump({ packages: packages }))
|
||||
response = post("#{ENDPOINT}/apis/launcher/1/get-package-details", FORM_ENCODED_HEADERS, body)
|
||||
response = post("/apis/launcher/1/get-package-details", FORM_ENCODED_HEADERS, body, backend)
|
||||
|
||||
if response.status == 200
|
||||
hash = JSON.parse(response.body, symbolize_names: true)
|
||||
@@ -243,9 +366,9 @@ class W3DHub
|
||||
# /apis/w3dhub/1/get-events
|
||||
#
|
||||
# clients requests events: data={"serverPath":"apb"}
|
||||
def self.events(app_id)
|
||||
def self.events(app_id, backend = :w3dhub)
|
||||
body = URI.encode_www_form("data": JSON.dump({ serverPath: app_id }))
|
||||
response = post("#{ENDPOINT}/apis/w3dhub/1/get-server-events", FORM_ENCODED_HEADERS, body)
|
||||
response = post("/apis/w3dhub/1/get-server-events", FORM_ENCODED_HEADERS, body, backend)
|
||||
|
||||
if response.status == 200
|
||||
array = JSON.parse(response.body, symbolize_names: true)
|
||||
@@ -257,11 +380,10 @@ class W3DHub
|
||||
|
||||
#! === Server List API === !#
|
||||
|
||||
SERVER_LIST_ENDPOINT = "https://gsh.w3dhub.com".freeze
|
||||
|
||||
def self.get(url, headers = DEFAULT_HEADERS, body = nil)
|
||||
excon(:get, url, headers, body)
|
||||
end
|
||||
# SERVER_LIST_ENDPOINT = "https://gsh.w3dhub.com".freeze
|
||||
SERVER_LIST_ENDPOINT = "https://gsh.w3d.cyberarm.dev".freeze
|
||||
# SERVER_LIST_ENDPOINT = "http://127.0.0.1:9292".freeze
|
||||
GSH_CONNECTION = Excon.new(SERVER_LIST_ENDPOINT, persistent: true)
|
||||
|
||||
# Method: GET
|
||||
# FORMAT: JSON
|
||||
@@ -280,8 +402,8 @@ class W3DHub
|
||||
# id, name, score, kills, deaths
|
||||
# ...players[]:
|
||||
# nick, team (index of teams array), score, kills, deaths
|
||||
def self.server_list(level = 1)
|
||||
response = get("#{SERVER_LIST_ENDPOINT}/listings/getAll/v2?statusLevel=#{level}")
|
||||
def self.server_list(level = 1, backend = :gsh)
|
||||
response = get("/listings/getAll/v2?statusLevel=#{level}", DEFAULT_HEADERS, nil, backend)
|
||||
|
||||
if response.status == 200
|
||||
data = JSON.parse(response.body, symbolize_names: true)
|
||||
@@ -302,8 +424,10 @@ class W3DHub
|
||||
# id, name, score, kills, deaths
|
||||
# ...players[]:
|
||||
# nick, team (index of teams array), score, kills, deaths
|
||||
def self.server_details(id, level)
|
||||
response = get("#{SERVER_LIST_ENDPOINT}/listings/getStatus/v2/#{id}?statusLevel=#{level}")
|
||||
def self.server_details(id, level, backend = :gsh)
|
||||
return false unless id && level
|
||||
|
||||
response = get("/listings/getStatus/v2/#{id}?statusLevel=#{level}", DEFAULT_HEADERS, nil, backend)
|
||||
|
||||
if response.status == 200
|
||||
hash = JSON.parse(response.body, symbolize_names: true)
|
||||
|
||||
@@ -24,8 +24,9 @@ class W3DHub
|
||||
|
||||
def to_json(env)
|
||||
d = @data.dup
|
||||
|
||||
d[:avatar_uri] = @avatar_uri
|
||||
d[:access_token_expiry] = d[:access_token_expiry].to_i
|
||||
d[:access_token_expiry] = @access_token_expiry.to_i
|
||||
|
||||
d.to_json(env)
|
||||
end
|
||||
|
||||
@@ -1,14 +1,16 @@
|
||||
class W3DHub
|
||||
class Api
|
||||
class Applications
|
||||
def initialize(response)
|
||||
attr_reader :data
|
||||
|
||||
def initialize(response, source = nil)
|
||||
@data = JSON.parse(response, symbolize_names: true)
|
||||
|
||||
games = @data[:applications].select { |a| a[:category] == "games" }
|
||||
|
||||
@games = []
|
||||
|
||||
games.each { |hash| @games << Game.new(hash) }
|
||||
games.each { |hash| @games << Game.new(hash, source) }
|
||||
@games.sort_by!(&:name).reverse
|
||||
end
|
||||
|
||||
@@ -18,9 +20,11 @@ class W3DHub
|
||||
|
||||
class Game
|
||||
attr_reader :id, :name, :type, :category, :studio_id, :channels, :web_links, :color
|
||||
attr_reader :___source
|
||||
|
||||
def initialize(hash)
|
||||
def initialize(hash, source = nil)
|
||||
@data = hash
|
||||
@data[:___source] = source if source
|
||||
|
||||
@id = @data[:id].to_s
|
||||
@name = @data[:name]
|
||||
@@ -29,33 +33,58 @@ class W3DHub
|
||||
@studio_id = @data[:"studio-id"]
|
||||
|
||||
# TODO: Do processing
|
||||
@channels = @data[:channels].map { |channel| Channel.new(channel) }
|
||||
@channels = @data[:channels].map { |channel| Channel.new(channel, source) }
|
||||
@web_links = @data[:"web-links"]&.map { |link| WebLink.new(link) } || []
|
||||
@extended_data = @data[:"extended-data"]
|
||||
|
||||
color = @data[:"extended-data"].find { |h| h[:name] == "colour" }[:value].sub("#", "")
|
||||
|
||||
color = color.sub("ff", "") if color.length == 8
|
||||
@color = "ff#{color}".to_i(16)
|
||||
|
||||
cfg = @data[:"extended-data"].find { |h| h[:name] == "usesEngineCfg" }
|
||||
@uses_engine_cfg = (cfg && cfg[:value].downcase.strip == "true") == true # explicit truthy compare to prevent return `nil`
|
||||
@uses_engine_cfg = (cfg && cfg[:value].to_s.downcase.strip == "true") == true # explicit truthy compare to prevent return `nil`
|
||||
|
||||
cfg = @data[:"extended-data"].find { |h| h[:name] == "usesRenFolder" }
|
||||
@uses_ren_folder = (cfg && cfg[:value].to_s.downcase.strip == "true") == true # explicit truthy compare to prevent return `nil`
|
||||
end
|
||||
|
||||
def uses_engine_cfg?
|
||||
@uses_engine_cfg
|
||||
end
|
||||
|
||||
def uses_ren_folder?
|
||||
@uses_ren_folder
|
||||
end
|
||||
|
||||
def source
|
||||
@data[:___source]&.to_sym || :w3dhub
|
||||
end
|
||||
|
||||
def source=(sym)
|
||||
@data[:___source] = sym
|
||||
end
|
||||
|
||||
class Channel
|
||||
attr_reader :id, :name, :user_level, :current_version
|
||||
|
||||
def initialize(hash)
|
||||
def initialize(hash, source = nil)
|
||||
@data = hash
|
||||
@data[:___source] = source
|
||||
|
||||
@id = @data[:id].to_s
|
||||
@name = @data[:name]
|
||||
@user_level = @data[:"user-level"]
|
||||
@current_version = @data[:"current-version"]
|
||||
end
|
||||
|
||||
def source
|
||||
@data[:___source]&.to_sym || :w3dhub
|
||||
end
|
||||
|
||||
def source=(sym)
|
||||
@data[:___source] = sym
|
||||
end
|
||||
end
|
||||
|
||||
class WebLink
|
||||
|
||||
@@ -6,7 +6,7 @@ class W3DHub
|
||||
def initialize(response)
|
||||
@data = JSON.parse(response, symbolize_names: true)
|
||||
|
||||
@items = @data[:news].map { |item| Item.new(item) }
|
||||
@items = (@data[:news] && @data[:news].is_a?(Array)) ? @data[:news].map { |item| Item.new(item) } : []
|
||||
end
|
||||
|
||||
class Item
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
class W3DHub
|
||||
class Api
|
||||
class Package
|
||||
attr_reader :category, :subcategory, :name, :version, :size, :checksum, :checksum_chunk_size, :checksum_chunks, :error,
|
||||
attr_reader :category, :subcategory, :name, :version, :size, :checksum, :checksum_chunk_size, :checksum_chunks, :download_url, :error,
|
||||
:custom_partially_valid_at_bytes, :custom_is_patch
|
||||
|
||||
def initialize(hash)
|
||||
@@ -18,6 +18,8 @@ class W3DHub
|
||||
@checksum_chunks = @data[:"checksum-chunks"]
|
||||
@error = @data[:error] || nil
|
||||
|
||||
@download_url = @data[:download_url] || nil
|
||||
|
||||
@custom_partially_valid_at_bytes = 0
|
||||
@custom_is_patch = false
|
||||
end
|
||||
|
||||
@@ -1,6 +1,8 @@
|
||||
class W3DHub
|
||||
class Api
|
||||
class ServerListServer
|
||||
NO_OR_BAD_PING = 1_000_000
|
||||
|
||||
attr_reader :id, :game, :address, :port, :region, :channel, :ping, :status
|
||||
|
||||
def initialize(hash)
|
||||
@@ -12,12 +14,12 @@ class W3DHub
|
||||
@port = @data[:port]
|
||||
@region = @data[:region]
|
||||
@channel = @data[:channel] || "release"
|
||||
@ping = -1
|
||||
@ping = NO_OR_BAD_PING
|
||||
|
||||
@status = @data[:status] ? Status.new(@data[:status]) : nil
|
||||
@status = Status.new(@data[:status])
|
||||
|
||||
@ping_interval = 30_000
|
||||
@last_pinged = Gosu.milliseconds + @ping_interval + 1
|
||||
@last_pinged = Gosu.milliseconds + @ping_interval + 1_000
|
||||
end
|
||||
|
||||
def update(hash)
|
||||
@@ -34,11 +36,11 @@ class W3DHub
|
||||
@status.players = hash[:players]&.select { |t| t[:nick] != "Nod" && t[:nick] != "GDI" }&.map { |t| Player.new(t) } if hash[:players]
|
||||
|
||||
send_ping
|
||||
|
||||
return true
|
||||
else
|
||||
@status = Status.new(hash)
|
||||
end
|
||||
|
||||
false
|
||||
true
|
||||
end
|
||||
|
||||
def send_ping(force_ping = false)
|
||||
@@ -55,7 +57,7 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
@ping = -1 if @ping.zero?
|
||||
@ping = NO_OR_BAD_PING if @ping.zero?
|
||||
|
||||
@ping
|
||||
end,
|
||||
@@ -70,18 +72,18 @@ class W3DHub
|
||||
attr_accessor :name, :password, :map, :max_players, :player_count, :started, :remaining, :teams, :players
|
||||
|
||||
def initialize(hash)
|
||||
@data = hash
|
||||
@data = hash || {}
|
||||
|
||||
@teams = @data[:teams]&.map { |t| Team.new(t) }
|
||||
@players = @data[:players]&.select { |t| t[:nick] != "Nod" && t[:nick] != "GDI" }&.map { |t| Player.new(t) }
|
||||
@teams = @data[:teams]&.map { |t| Team.new(t) } || []
|
||||
@players = @data[:players]&.select { |t| t[:nick] != "Nod" && t[:nick] != "GDI" }&.map { |t| Player.new(t) } || []
|
||||
|
||||
@name = @data[:name]
|
||||
@name = @data[:name] || ""
|
||||
@password = @data[:password] || false
|
||||
@map = @data[:map]
|
||||
@max_players = @data[:maxplayers]
|
||||
@map = @data[:map] || ""
|
||||
@max_players = @data[:maxplayers] || 0
|
||||
@player_count = @players.size || @data[:numplayers].to_i
|
||||
@started = @data[:started]
|
||||
@remaining = @data[:remaining]
|
||||
@started = @data[:started] || Time.now
|
||||
@remaining = @data[:remaining] || "00.00.00"
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
@@ -11,11 +11,13 @@ class W3DHub
|
||||
@@instance = ServerListUpdater.new
|
||||
end
|
||||
|
||||
attr_accessor :auto_reconnect
|
||||
attr_accessor :auto_reconnect, :invocation_id
|
||||
|
||||
def initialize
|
||||
@auto_reconnect = false
|
||||
|
||||
@invocation_id = 0
|
||||
|
||||
logger.info(LOG_TAG) { "Starting emulated SignalR Server List Updater..." }
|
||||
run
|
||||
end
|
||||
@@ -33,7 +35,7 @@ class W3DHub
|
||||
puts e
|
||||
puts e.backtrace
|
||||
|
||||
sleep 10
|
||||
sleep 30
|
||||
retry
|
||||
end
|
||||
end
|
||||
@@ -46,24 +48,31 @@ class W3DHub
|
||||
@auto_reconnect = false
|
||||
|
||||
logger.debug(LOG_TAG) { "Requesting connection token..." }
|
||||
response = Excon.post("https://gsh.w3dhub.com/listings/push/v2/negotiate?negotiateVersion=1", headers: Api::DEFAULT_HEADERS, body: "")
|
||||
response = Api.post("/listings/push/v2/negotiate?negotiateVersion=1", Api::DEFAULT_HEADERS, "", :gsh)
|
||||
|
||||
if response.status != 200
|
||||
@auto_reconnect = true
|
||||
return
|
||||
end
|
||||
|
||||
data = JSON.parse(response.body, symbolize_names: true)
|
||||
|
||||
@invocation_id = 0 if @invocation_id > 9095
|
||||
id = data[:connectionToken]
|
||||
endpoint = "https://gsh.w3dhub.com/listings/push/v2?id=#{id}"
|
||||
endpoint = "#{Api::SERVER_LIST_ENDPOINT}/listings/push/v2?id=#{id}"
|
||||
|
||||
logger.debug(LOG_TAG) { "Connecting to websocket..." }
|
||||
this = self
|
||||
WebSocket::Client::Simple.connect(endpoint, headers: Api::DEFAULT_HEADERS) do |ws|
|
||||
@ws = WebSocket::Client::Simple.connect(endpoint, headers: Api::DEFAULT_HEADERS) do |ws|
|
||||
ws.on(:open) do
|
||||
logger.debug(LOG_TAG) { "Requesting json protocol, v1..." }
|
||||
ws.send({ protocol: "json", version: 1 }.to_json + "\x1e")
|
||||
|
||||
logger.debug(LOG_TAG) { "Subscribing to server changes..." }
|
||||
Store.server_list.each_with_index do |server, i|
|
||||
i += 1
|
||||
Store.server_list.each do |server|
|
||||
this.invocation_id += 1
|
||||
mode = 1 # 2 full details, 1 basic details
|
||||
out = { "type": 1, "invocationId": "#{i}", "target": "SubscribeToServerStatusUpdates", "arguments": [server.id, mode] }
|
||||
out = { "type": 1, "invocationId": "#{this.invocation_id}", "target": "SubscribeToServerStatusUpdates", "arguments": [server.id, mode] }
|
||||
ws.send(out.to_json + "\x1e")
|
||||
end
|
||||
end
|
||||
@@ -84,15 +93,34 @@ class W3DHub
|
||||
case hash[:target]
|
||||
when "ServerRegistered"
|
||||
data = hash[:arguments].first
|
||||
server = ServerListServer.new(data)
|
||||
Store.server_list.push(server)
|
||||
|
||||
this.invocation_id += 1
|
||||
out = { "type": 1, "invocationId": "#{this.invocation_id}", "target": "SubscribeToServerStatusUpdates", "arguments": [data[:id], 1] }
|
||||
ws.send(out.to_json + "\x1e")
|
||||
|
||||
BackgroundWorker.foreground_job(
|
||||
->(data) { [Api.server_details(data[:id], 2), data] },
|
||||
->(array) do
|
||||
server_data, data = array
|
||||
|
||||
next unless server_data
|
||||
|
||||
data[:status] = server_data
|
||||
|
||||
server = ServerListServer.new(data)
|
||||
Store.server_list.push(server)
|
||||
States::Interface.instance&.update_server_browser(server, :update)
|
||||
end,
|
||||
nil,
|
||||
data
|
||||
)
|
||||
|
||||
when "ServerStatusChanged"
|
||||
id, data = hash[:arguments]
|
||||
server = Store.server_list.find { |s| s.id == id }
|
||||
server_updated = server&.update(data)
|
||||
|
||||
BackgroundWorker.foreground_job(-> {}, ->(result){ States::Interface.instance&.update_server_browser(server, :update) }) if server_updated
|
||||
BackgroundWorker.foreground_job(->(server) { server }, ->(server) { States::Interface.instance&.update_server_browser(server, :update) }, nil, server) if server_updated
|
||||
|
||||
when "ServerUnregistered"
|
||||
id = hash[:arguments].first
|
||||
@@ -100,7 +128,7 @@ class W3DHub
|
||||
|
||||
if server
|
||||
Store.server_list.delete(server)
|
||||
BackgroundWorker.foreground_job(-> {}, ->(result){ States::Interface.instance&.update_server_browser(server, :remove) })
|
||||
BackgroundWorker.foreground_job(->(server) { server }, ->(server) { States::Interface.instance&.update_server_browser(server, :remove) }, nil, server)
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -108,17 +136,65 @@ class W3DHub
|
||||
end
|
||||
|
||||
ws.on(:close) do |e|
|
||||
p e
|
||||
logger.error(LOG_TAG) { e }
|
||||
this.auto_reconnect = true
|
||||
ws.close
|
||||
end
|
||||
|
||||
ws.on(:error) do |e|
|
||||
p e
|
||||
logger.error(LOG_TAG) { e }
|
||||
this.auto_reconnect = true
|
||||
ws.close
|
||||
end
|
||||
end
|
||||
|
||||
@ws = nil
|
||||
end
|
||||
|
||||
def refresh_server_list(list)
|
||||
new_servers = []
|
||||
removed_servers = []
|
||||
|
||||
# find new servers
|
||||
list.each do |server|
|
||||
found_server = Store.server_list.find { |s| s.id == server.id }
|
||||
|
||||
new_servers << server unless found_server
|
||||
end
|
||||
|
||||
# find removed servers
|
||||
Store.server_list.each do |server|
|
||||
found_server = list.find { |s| s.id == server.id }
|
||||
|
||||
removed_servers << server unless found_server
|
||||
end
|
||||
|
||||
# purge removed servers from list
|
||||
Store.server_list.reject! do |server|
|
||||
removed_servers.find { |s| server.id == s.id }
|
||||
end
|
||||
|
||||
# add new servers to list
|
||||
Store.server_list = Store.server_list + new_servers
|
||||
|
||||
if @ws
|
||||
# unsubscribe from removed servers
|
||||
removed_servers.each do
|
||||
@invocation_id += 1
|
||||
out = { "type": 1, "invocationId": "#{@invocation_id}", "target": "SubscribeToServerStatusUpdates", "arguments": [server.id, 0] }
|
||||
ws.send(out.to_json + "\x1e")
|
||||
end
|
||||
|
||||
# subscribe to new servers
|
||||
new_servers.each do
|
||||
@invocation_id += 1
|
||||
out = { "type": 1, "invocationId": "#{@invocation_id}", "target": "SubscribeToServerStatusUpdates", "arguments": [server.id, 1] }
|
||||
ws.send(out.to_json + "\x1e")
|
||||
end
|
||||
end
|
||||
|
||||
# sort list
|
||||
Store.server_list.sort_by! { |s| [s.status.player_count, s.id] }.reverse!
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -235,11 +235,11 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
def join_server(app_id, channel, server, password = nil)
|
||||
if installed?(app_id, channel) && Store.settings[:server_list_username].to_s.length.positive?
|
||||
def join_server(app_id, channel, server, username = Store.settings[:server_list_username], password = nil, multi = false)
|
||||
if installed?(app_id, channel) && username.to_s.length.positive?
|
||||
run(
|
||||
app_id, channel,
|
||||
"+connect #{server.address}:#{server.port} +netplayername #{Store.settings[:server_list_username]}#{password ? " +password \"#{password}\"" : ""}"
|
||||
"+connect #{server.address}:#{server.port} +netplayername #{username}#{password ? " +password \"#{password}\"" : ""}#{multi ? " +multi" : ""}"
|
||||
)
|
||||
end
|
||||
end
|
||||
@@ -250,7 +250,7 @@ class W3DHub
|
||||
return nil unless app_data
|
||||
|
||||
found_server = Store.server_list.select do |server|
|
||||
server.game == app_id && server.channel == channel && !server.status.password
|
||||
server.game == app_id && server.channel == channel && !server.status.password && server.status.player_count < server.status.max_players
|
||||
end&.first
|
||||
|
||||
found_server ? found_server : nil
|
||||
|
||||
@@ -112,6 +112,38 @@ class W3DHub
|
||||
@task_state == :failed
|
||||
end
|
||||
|
||||
def normalize_path(path, base_path)
|
||||
path = path.to_s.gsub("\\", "/")
|
||||
return "#{base_path}/#{path}" if W3DHub.windows? # Windows is easy, or annoying, depending how you look at it...
|
||||
|
||||
constructed_path = base_path
|
||||
lowercase_full_path = "#{base_path}/#{path}".downcase.strip.freeze
|
||||
|
||||
accepted_parts = 0
|
||||
split_path = path.split("/")
|
||||
split_path.each do |segment|
|
||||
Dir.glob("#{constructed_path}/*").each do |part|
|
||||
next unless "#{constructed_path}/#{segment}".downcase == part.downcase
|
||||
|
||||
# Handle edge case where a file with the same name is in a higher directory
|
||||
next if File.file?(part) && part.downcase.strip != lowercase_full_path
|
||||
|
||||
constructed_path = part
|
||||
accepted_parts += 1
|
||||
break
|
||||
end
|
||||
end
|
||||
|
||||
# Find file if it exists else use provided path as cased
|
||||
if constructed_path.downcase.strip == lowercase_full_path
|
||||
constructed_path
|
||||
elsif accepted_parts.positive?
|
||||
"#{constructed_path}/#{split_path[accepted_parts..].join('/')}"
|
||||
else
|
||||
"#{base_path}/#{path}" # File doesn't exist, case doesn't matter.
|
||||
end
|
||||
end
|
||||
|
||||
def failure_reason
|
||||
@task_failure_reason || ""
|
||||
end
|
||||
@@ -208,10 +240,17 @@ class W3DHub
|
||||
@manifests << manifest
|
||||
|
||||
until(manifest.full?)
|
||||
fetch_manifest("games", app_id, "manifest.xml", manifest.base_version)
|
||||
manifest = load_manifest("games", app_id, "manifest.xml", manifest.base_version)
|
||||
manifests << manifest
|
||||
if fetch_manifest("games", app_id, "manifest.xml", manifest.base_version)
|
||||
manifest = load_manifest("games", app_id, "manifest.xml", manifest.base_version)
|
||||
manifests << manifest
|
||||
else
|
||||
fail!("Failed to retrieve manifest: games:#{app_id}:manifest.xml-#{manifest.base_version}")
|
||||
return []
|
||||
end
|
||||
end
|
||||
else
|
||||
fail!("Failed to retrieve manifest: games:#{app_id}:manifest.xml-#{@target_version}")
|
||||
return []
|
||||
end
|
||||
|
||||
@manifests
|
||||
@@ -252,7 +291,7 @@ class W3DHub
|
||||
next if packages.detect do |pkg|
|
||||
pkg.category == "games" &&
|
||||
pkg.subcategory == @app_id &&
|
||||
pkg.name == file.package &&
|
||||
pkg.name.to_s.casecmp?(file.package.to_s) &&
|
||||
pkg.version == file.version
|
||||
end
|
||||
|
||||
@@ -288,17 +327,13 @@ class W3DHub
|
||||
@files.reverse.each do |file|
|
||||
break unless folder_exists
|
||||
|
||||
safe_file_name = file.name.gsub("\\", "/")
|
||||
# Fix borked Data -> data 'cause Windows don't care about capitalization
|
||||
safe_file_name.sub!("Data/", "data/")
|
||||
|
||||
file_path = "#{path}/#{safe_file_name}"
|
||||
file_path = normalize_path(file.name, path)
|
||||
|
||||
processed_files += 1
|
||||
@status.progress = processed_files.to_f / file_count
|
||||
|
||||
next if file.removed_since
|
||||
next if accepted_files.key?(safe_file_name)
|
||||
next if accepted_files.key?(file_path)
|
||||
|
||||
unless File.exist?(file_path)
|
||||
rejected_files << { file: file, manifest_version: file.version }
|
||||
@@ -318,7 +353,7 @@ class W3DHub
|
||||
logger.info(LOG_TAG) { file.inspect } if file.checksum.nil?
|
||||
|
||||
if digest.hexdigest.upcase == file.checksum.upcase
|
||||
accepted_files[safe_file_name] = file.version
|
||||
accepted_files[file_path] = file.version
|
||||
logger.info(LOG_TAG) { "[#{file.version}] Verified file: #{file_path}" }
|
||||
else
|
||||
rejected_files << { file: file, manifest_version: file.version }
|
||||
@@ -362,7 +397,7 @@ class W3DHub
|
||||
}
|
||||
end
|
||||
|
||||
package_details = Api.package_details(hashes)
|
||||
package_details = Api.package_details(hashes, @channel.source || :w3dhub)
|
||||
|
||||
unless package_details
|
||||
fail!("Failed to fetch package details")
|
||||
@@ -376,9 +411,9 @@ class W3DHub
|
||||
end
|
||||
|
||||
package = @packages.find do |pkg|
|
||||
pkg.category == rich.category &&
|
||||
pkg.subcategory == rich.subcategory &&
|
||||
"#{pkg.name}.zip" == rich.name &&
|
||||
pkg.category.to_s.casecmp?(rich.category.to_s) &&
|
||||
pkg.subcategory.to_s.casecmp?(rich.subcategory.to_s) &&
|
||||
"#{pkg.name}.zip".casecmp?(rich.name) &&
|
||||
pkg.version == rich.version
|
||||
end
|
||||
|
||||
@@ -522,7 +557,7 @@ class W3DHub
|
||||
logger.info(LOG_TAG) { " #{file.name}" }
|
||||
|
||||
path = Cache.install_path(@application, @channel)
|
||||
file_path = "#{path}/#{file.name}".sub('Data/', 'data/')
|
||||
file_path = normalize_path(file.name, path)
|
||||
|
||||
File.delete(file_path) if File.exist?(file_path)
|
||||
|
||||
@@ -552,6 +587,22 @@ class W3DHub
|
||||
@status.step = :install_dependencies
|
||||
end
|
||||
|
||||
def write_paths_ini
|
||||
path = Cache.install_path(@application, @channel)
|
||||
|
||||
File.open(normalize_path("data/paths.ini", path), "w") do |file|
|
||||
file.puts("[paths]")
|
||||
file.puts("RegBase=W3D Hub")
|
||||
file.puts("RegClient=#{@application.category}\\#{@application.id}-#{@channel.id}")
|
||||
file.puts("RegFDS=#{@application.category}\\#{@application.id}-#{@channel.id}-server")
|
||||
file.puts("FileBase=W3D Hub");
|
||||
file.puts("FileClient=#{@application.category}\\#{@application.id}-#{@channel.id}")
|
||||
file.puts("FileFDS=#{@application.category}\\#{@application.id}-#{@channel.id}-server")
|
||||
|
||||
file.puts("UseRenFolder=#{@application.uses_ren_folder?}")
|
||||
end
|
||||
end
|
||||
|
||||
def mark_application_installed
|
||||
Store.application_manager.installed!(self)
|
||||
|
||||
@@ -573,17 +624,17 @@ class W3DHub
|
||||
# Check for and integrity of local manifest
|
||||
|
||||
package = nil
|
||||
array = Api.package_details([{ category: category, subcategory: subcategory, name: name, version: version }])
|
||||
array = Api.package_details([{ category: category, subcategory: subcategory, name: name, version: version }], @channel.source || :w3dhub)
|
||||
if array.is_a?(Array)
|
||||
package = array.first
|
||||
else
|
||||
fail!("Failed to fetch manifest package details! (#{category}:#{subcategory}:#{name}:#{version})")
|
||||
return
|
||||
return false
|
||||
end
|
||||
|
||||
if package.error?
|
||||
fail!("Failed to retrieve manifest package details! (#{category}:#{subcategory}:#{name}:#{version})\nError: #{package.error.gsub("-", " ").capitalize}")
|
||||
return
|
||||
return false
|
||||
end
|
||||
|
||||
if File.exist?(Cache.package_path(category, subcategory, name, version))
|
||||
@@ -601,9 +652,13 @@ class W3DHub
|
||||
def package_fetch(package, &block)
|
||||
logger.info(LOG_TAG) { "Downloading: #{package.category}:#{package.subcategory}:#{package.name}-#{package.version}" }
|
||||
|
||||
Api.package(package) do |chunk, remaining_bytes, total_bytes|
|
||||
status_okay = Api.package(package) do |chunk, remaining_bytes, total_bytes|
|
||||
block&.call(chunk, remaining_bytes, total_bytes)
|
||||
end
|
||||
|
||||
fail!("Failed to retrieve package: (#{package.category}:#{package.subcategory}:#{package.name}:#{package.version})") unless status_okay
|
||||
|
||||
status_okay
|
||||
end
|
||||
|
||||
def verify_package(package, &block)
|
||||
@@ -680,15 +735,15 @@ class W3DHub
|
||||
logger.info(LOG_TAG) { " Unpacking patch \"#{package_path}\" in \"#{temp_path}\"" }
|
||||
unzip(package_path, temp_path)
|
||||
|
||||
# Fix borked Data -> data 'cause Windows don't care about capitalization
|
||||
safe_file_name = "#{manifest_file.name.sub('Data/', 'data/')}"
|
||||
file_path = normalize_path(manifest_file.name, path)
|
||||
temp_file_path = normalize_path(manifest_file.name, temp_path)
|
||||
|
||||
logger.info(LOG_TAG) { " Loading #{temp_path}/#{safe_file_name}.patch..." }
|
||||
patch_mix = W3DHub::Mixer::Reader.new(file_path: "#{temp_path}/#{safe_file_name}.patch", ignore_crc_mismatches: false)
|
||||
logger.info(LOG_TAG) { " Loading #{temp_file_path}.patch..." }
|
||||
patch_mix = W3DHub::Mixer::Reader.new(file_path: "#{temp_file_path}.patch", ignore_crc_mismatches: false)
|
||||
patch_info = JSON.parse(patch_mix.package.files.find { |f| f.name.casecmp?(".w3dhub.patch") || f.name.casecmp?(".bhppatch") }.data, symbolize_names: true)
|
||||
|
||||
logger.info(LOG_TAG) { " Loading #{path}/#{safe_file_name}..." }
|
||||
target_mix = W3DHub::Mixer::Reader.new(file_path: "#{path}/#{safe_file_name}", ignore_crc_mismatches: false)
|
||||
logger.info(LOG_TAG) { " Loading #{file_path}..." }
|
||||
target_mix = W3DHub::Mixer::Reader.new(file_path: "#{file_path}", ignore_crc_mismatches: false)
|
||||
|
||||
logger.info(LOG_TAG) { " Removing files..." } if patch_info[:removedFiles].size.positive?
|
||||
patch_info[:removedFiles].each do |file|
|
||||
@@ -710,8 +765,8 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
logger.info(LOG_TAG) { " Writing updated #{path}/#{safe_file_name}..." } if patch_info[:updatedFiles].size.positive?
|
||||
W3DHub::Mixer::Writer.new(file_path: "#{path}/#{safe_file_name}", package: target_mix.package, memory_buffer: true)
|
||||
logger.info(LOG_TAG) { " Writing updated #{file_path}..." } if patch_info[:updatedFiles].size.positive?
|
||||
W3DHub::Mixer::Writer.new(file_path: "#{file_path}", package: target_mix.package, memory_buffer: true, encrypted: target_mix.encrypted?)
|
||||
|
||||
FileUtils.remove_dir(temp_path)
|
||||
|
||||
@@ -722,17 +777,15 @@ class W3DHub
|
||||
stream = Zip::InputStream.new(File.open(package_path))
|
||||
|
||||
while (entry = stream.get_next_entry)
|
||||
# Normalize the path to handle case-insensitivity consistently
|
||||
file_path = normalize_path(entry.name, path)
|
||||
|
||||
safe_file_name = entry.name.gsub("\\", "/")
|
||||
# Fix borked Data -> data 'cause Windows don't care about capitalization
|
||||
safe_file_name.sub!("Data/", "data/")
|
||||
|
||||
dir_path = "#{path}/#{File.dirname(safe_file_name)}"
|
||||
dir_path = File.dirname(file_path)
|
||||
unless dir_path.end_with?("/.") || Dir.exist?(dir_path)
|
||||
FileUtils.mkdir_p(dir_path)
|
||||
end
|
||||
|
||||
File.open("#{path}/#{safe_file_name}", "wb") do |f|
|
||||
File.open(file_path, "wb") do |f|
|
||||
i = entry.get_input_stream
|
||||
|
||||
while (chunk = i.read(32_000_000)) # Read up to ~32 MB per chunk
|
||||
|
||||
@@ -40,6 +40,9 @@ class W3DHub
|
||||
install_dependencies
|
||||
return false if failed?
|
||||
|
||||
write_paths_ini
|
||||
return false if failed?
|
||||
|
||||
mark_application_installed
|
||||
return false if failed?
|
||||
|
||||
@@ -50,4 +53,4 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -23,7 +23,12 @@ class W3DHub
|
||||
def self.verify_peer
|
||||
no_verify.tap do |context|
|
||||
context.verify_mode = OpenSSL::SSL::VERIFY_PEER
|
||||
context.cert_store = OpenSSL::X509::Store.new.tap(&:set_default_paths)
|
||||
context.cert_store = OpenSSL::X509::Store.new
|
||||
if (ca_file = W3DHub.ca_bundle_path)
|
||||
context.cert_store.add_file(ca_file)
|
||||
else
|
||||
context.cert_store.set_default_paths
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
|
||||
@@ -43,20 +43,20 @@ class W3DHub
|
||||
@@instance.kill!
|
||||
end
|
||||
|
||||
def self.job(job, callback, error_handler = nil)
|
||||
@@instance.add_job(Job.new(job: job, callback: callback, error_handler: error_handler))
|
||||
def self.job(job, callback, error_handler = nil, data = nil)
|
||||
@@instance.add_job(Job.new(job: job, callback: callback, error_handler: error_handler, data: data))
|
||||
end
|
||||
|
||||
def self.parallel_job(job, callback, error_handler = nil)
|
||||
@@instance.add_parallel_job(Job.new(job: job, callback: callback, error_handler: error_handler))
|
||||
def self.parallel_job(job, callback, error_handler = nil, data = nil)
|
||||
@@instance.add_parallel_job(Job.new(job: job, callback: callback, error_handler: error_handler, data: data))
|
||||
end
|
||||
|
||||
def self.foreground_job(job, callback, error_handler = nil)
|
||||
@@instance.add_job(Job.new(job: job, callback: callback, error_handler: error_handler, deliver_to_queue: true))
|
||||
def self.foreground_job(job, callback, error_handler = nil, data = nil)
|
||||
@@instance.add_job(Job.new(job: job, callback: callback, error_handler: error_handler, deliver_to_queue: true, data: data))
|
||||
end
|
||||
|
||||
def self.foreground_parallel_job(job, callback, error_handler = nil)
|
||||
@@instance.add_parallel_job(Job.new(job: job, callback: callback, error_handler: error_handler, deliver_to_queue: true))
|
||||
def self.foreground_parallel_job(job, callback, error_handler = nil, data = nil)
|
||||
@@instance.add_parallel_job(Job.new(job: job, callback: callback, error_handler: error_handler, deliver_to_queue: true, data: data))
|
||||
end
|
||||
|
||||
def initialize
|
||||
@@ -136,16 +136,16 @@ class W3DHub
|
||||
end
|
||||
|
||||
class Job
|
||||
def initialize(job:, callback:, error_handler: nil, deliver_to_queue: false)
|
||||
def initialize(job:, callback:, error_handler: nil, deliver_to_queue: false, data: nil)
|
||||
@job = job
|
||||
@callback = callback
|
||||
@error_handler = error_handler
|
||||
|
||||
@deliver_to_queue = deliver_to_queue
|
||||
@data = data
|
||||
end
|
||||
|
||||
def do
|
||||
result = @job.call
|
||||
result = @data ? @job.call(@data) : @job.call
|
||||
deliver(result)
|
||||
end
|
||||
|
||||
|
||||
49
lib/cache.rb
@@ -9,18 +9,18 @@ class W3DHub
|
||||
end
|
||||
|
||||
# Fetch a generic uri
|
||||
def self.fetch(uri:, force_fetch: false, async: true)
|
||||
def self.fetch(uri:, force_fetch: false, async: true, backend: :w3dhub)
|
||||
path = path(uri)
|
||||
|
||||
if !force_fetch && File.exist?(path)
|
||||
path
|
||||
elsif async
|
||||
BackgroundWorker.job(
|
||||
-> { Api.get(uri, W3DHub::Api::DEFAULT_HEADERS) },
|
||||
-> { Api.fetch(uri, W3DHub::Api::DEFAULT_HEADERS, nil, backend) },
|
||||
->(response) { File.open(path, "wb") { |f| f.write response.body } if response.status == 200 }
|
||||
)
|
||||
else
|
||||
response = Api.get(uri, W3DHub::Api::DEFAULT_HEADERS)
|
||||
response = Api.fetch(uri, W3DHub::Api::DEFAULT_HEADERS, nil, backend)
|
||||
File.open(path, "wb") { |f| f.write response.body } if response.status == 200
|
||||
end
|
||||
end
|
||||
@@ -69,7 +69,7 @@ class W3DHub
|
||||
|
||||
body = "data=#{JSON.dump({ category: package.category, subcategory: package.subcategory, name: package.name, version: package.version })}"
|
||||
|
||||
response = Api.post("#{Api::ENDPOINT}/apis/launcher/1/get-package", headers, body)
|
||||
response = Api.post("/apis/launcher/1/get-package", headers, body)
|
||||
|
||||
total_bytes = package.size
|
||||
remaining_bytes = total_bytes - start_from_bytes
|
||||
@@ -89,9 +89,15 @@ class W3DHub
|
||||
|
||||
# Download a W3D Hub package
|
||||
def self.fetch_package(package, block)
|
||||
endpoint_download_url = package.download_url || "#{Api::W3DHUB_API_ENDPOINT}/apis/launcher/1/get-package"
|
||||
if package.download_url
|
||||
uri_path = package.download_url.split("/").last
|
||||
endpoint_download_url = package.download_url.sub(uri_path, URI.encode_uri_component(uri_path))
|
||||
end
|
||||
path = package_path(package.category, package.subcategory, package.name, package.version)
|
||||
headers = { "Content-Type": "application/x-www-form-urlencoded", "User-Agent": Api::USER_AGENT }
|
||||
headers["Authorization"] = "Bearer #{Store.account.access_token}" if Store.account
|
||||
headers["Authorization"] = "Bearer #{Store.account.access_token}" if Store.account && !package.download_url
|
||||
body = "data=#{JSON.dump({ category: package.category, subcategory: package.subcategory, name: package.name, version: package.version })}"
|
||||
start_from_bytes = package.custom_partially_valid_at_bytes
|
||||
|
||||
logger.info(LOG_TAG) { " Start from bytes: #{start_from_bytes} of #{package.size}" }
|
||||
@@ -112,16 +118,39 @@ class W3DHub
|
||||
end
|
||||
|
||||
# Create a new connection due to some weirdness somewhere in Excon
|
||||
response = Excon.post(
|
||||
"#{Api::ENDPOINT}/apis/launcher/1/get-package",
|
||||
response = Excon.send(
|
||||
package.download_url ? :get : :post,
|
||||
endpoint_download_url,
|
||||
tcp_nodelay: true,
|
||||
headers: headers,
|
||||
body: "data=#{JSON.dump({ category: package.category, subcategory: package.subcategory, name: package.name, version: package.version })}",
|
||||
body: package.download_url ? "" : body,
|
||||
chunk_size: 50_000,
|
||||
response_block: streamer
|
||||
response_block: streamer,
|
||||
middlewares: Excon.defaults[:middlewares] + [Excon::Middleware::RedirectFollower]
|
||||
)
|
||||
|
||||
response.status == 200 || response.status == 206
|
||||
if response.status == 200 || response.status == 206
|
||||
return true
|
||||
else
|
||||
logger.debug(LOG_TAG) { " Failed to retrieve package: (#{package.category}:#{package.subcategory}:#{package.name}:#{package.version})" }
|
||||
logger.debug(LOG_TAG) { " Download URL: #{endpoint_download_url}, response: #{response&.status || -1}" }
|
||||
|
||||
return false
|
||||
end
|
||||
rescue Excon::Error::Timeout => e
|
||||
logger.error(LOG_TAG) { " Connection to \"#{endpoint_download_url}\" timed out after: #{W3DHub::Api::API_TIMEOUT} seconds" }
|
||||
logger.error(LOG_TAG) { e }
|
||||
logger.debug(LOG_TAG) { " Failed to retrieve package: (#{package.category}:#{package.subcategory}:#{package.name}:#{package.version})" }
|
||||
logger.debug(LOG_TAG) { " Download URL: #{endpoint_download_url}, response: #{response&.status || -1}" }
|
||||
|
||||
return false
|
||||
rescue Excon::Error => e
|
||||
logger.error(LOG_TAG) { " Connection to \"#{endpoint_download_url}\" errored:" }
|
||||
logger.error(LOG_TAG) { e }
|
||||
logger.debug(LOG_TAG) { " Failed to retrieve package: (#{package.category}:#{package.subcategory}:#{package.name}:#{package.version})" }
|
||||
logger.debug(LOG_TAG) { " Download URL: #{endpoint_download_url}, response: #{response&.status || -1}" }
|
||||
|
||||
return false
|
||||
ensure
|
||||
file&.close
|
||||
end
|
||||
|
||||
@@ -32,6 +32,15 @@ class W3DHub
|
||||
linux? || mac?
|
||||
end
|
||||
|
||||
# Detect system CA bundle path for SSL verification
|
||||
def self.ca_bundle_path
|
||||
[
|
||||
"/etc/ssl/certs/ca-certificates.crt", # Debian/Ubuntu
|
||||
"/etc/pki/tls/certs/ca-bundle.crt", # RHEL/Fedora/CentOS
|
||||
"/etc/ssl/ca-bundle.pem" # Some other distros
|
||||
].find { |path| File.exist?(path) }
|
||||
end
|
||||
|
||||
def self.url(path)
|
||||
raise "Hazardous input: #{path}" if path.include?("&&") || path.include?(";")
|
||||
|
||||
@@ -72,15 +81,19 @@ class W3DHub
|
||||
)
|
||||
end
|
||||
|
||||
def self.join_server(server, password)
|
||||
def self.join_server(server:, username: Store.settings[:server_list_username], password: nil, multi: false)
|
||||
if (
|
||||
(server.status.password && password.length.positive?) ||
|
||||
!server.status.password) &&
|
||||
Store.settings[:server_list_username].to_s.length.positive?
|
||||
username.to_s.length.positive?
|
||||
|
||||
Store.application_manager.join_server(
|
||||
server.game,
|
||||
server.channel, server, password
|
||||
server.channel,
|
||||
server,
|
||||
username,
|
||||
password,
|
||||
multi
|
||||
)
|
||||
else
|
||||
CyberarmEngine::Window.instance.push_state(W3DHub::States::MessageDialog, type: "?", title: "?", message: "?")
|
||||
@@ -147,16 +160,56 @@ class W3DHub
|
||||
end
|
||||
|
||||
def self.ask_file(title: "Open File", filter: "*game*.exe")
|
||||
if W3DHub.unix?
|
||||
# search for command
|
||||
cmds = %w{ zenity matedialog qarma kdialog }
|
||||
|
||||
command = cmds.find do |cmd|
|
||||
cmd if system("which #{cmd}")
|
||||
end
|
||||
|
||||
path = case File.basename(command)
|
||||
when "zenity", "matedialog", "qarma"
|
||||
`#{command} --file-selection --title "#{title}" --file-filter "#{filter}"`
|
||||
when "kdialog"
|
||||
`#{command} --title "#{title}" --getopenfilename . "#{filter}"`
|
||||
else
|
||||
raise "No known command found for system file selection dialog!"
|
||||
end
|
||||
|
||||
path.strip
|
||||
else
|
||||
result_ptr = LibUI.open_file(LIBUI_WINDOW)
|
||||
result = result_ptr.null? ? "" : result_ptr.to_s.gsub("\\", "/")
|
||||
|
||||
result
|
||||
result.strip
|
||||
end
|
||||
end
|
||||
|
||||
def self.ask_folder(title: "Open Folder")
|
||||
result_ptr = LibUI.open_folder(window)
|
||||
result = result_ptr.null? ? "" : result_ptr.to_s.gsub("\\", "/")
|
||||
if W3DHub.unix?
|
||||
# search for command
|
||||
cmds = %w{ zenity matedialog qarma kdialog }
|
||||
|
||||
result
|
||||
command = cmds.find do |cmd|
|
||||
cmd if system("which #{cmd}")
|
||||
end
|
||||
|
||||
path = case File.basename(command)
|
||||
when "zenity", "matedialog", "qarma"
|
||||
`#{command} --file-selection --directory --title "#{title}"`
|
||||
when "kdialog"
|
||||
`#{command} --title "#{title}" --getexistingdirectory #{Dir.home}"`
|
||||
else
|
||||
raise "No known command found for system file selection dialog!"
|
||||
end
|
||||
|
||||
path.strip
|
||||
else
|
||||
result_ptr = LibUI.open_folder(LIBUI_WINDOW)
|
||||
result = result_ptr.null? ? "" : result_ptr.to_s.gsub("\\", "/")
|
||||
|
||||
result.strip
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
24
lib/mixer.rb
@@ -6,6 +6,8 @@ class W3DHub
|
||||
# https://github.com/TheUnstoppable/MixLibrary used for reference
|
||||
class Mixer
|
||||
DEFAULT_BUFFER_SIZE = 32_000_000
|
||||
MIX1_HEADER = 0x3158494D
|
||||
MIX2_HEADER = 0x3258494D
|
||||
|
||||
class MixParserException < RuntimeError; end
|
||||
class MixFormatException < RuntimeError; end
|
||||
@@ -203,8 +205,12 @@ class W3DHub
|
||||
|
||||
@buffer.pos = 0
|
||||
|
||||
@encrypted = false
|
||||
|
||||
# Valid header
|
||||
if read_i32 == 0x3158494D
|
||||
if (mime = read_i32) && (mime == MIX1_HEADER || mime == MIX2_HEADER)
|
||||
@encrypted = mime == MIX2_HEADER
|
||||
|
||||
file_data_offset = read_i32
|
||||
file_names_offset = read_i32
|
||||
|
||||
@@ -237,7 +243,7 @@ class W3DHub
|
||||
@buffer.pos = pos
|
||||
end
|
||||
else
|
||||
raise MixParserException, "Invalid MIX file"
|
||||
raise MixParserException, "Invalid MIX file: Expected \"#{MIX1_HEADER}\" or \"#{MIX2_HEADER}\", got \"0x#{mime.to_s(16).upcase}\"\n(#{file_path})"
|
||||
end
|
||||
|
||||
ensure
|
||||
@@ -264,18 +270,24 @@ class W3DHub
|
||||
|
||||
buffer.strip
|
||||
end
|
||||
|
||||
def encrypted?
|
||||
@encrypted
|
||||
end
|
||||
end
|
||||
|
||||
class Writer
|
||||
attr_reader :package
|
||||
|
||||
def initialize(file_path:, package:, memory_buffer: false, buffer_size: DEFAULT_BUFFER_SIZE)
|
||||
def initialize(file_path:, package:, memory_buffer: false, buffer_size: DEFAULT_BUFFER_SIZE, encrypted: false)
|
||||
@package = package
|
||||
|
||||
@buffer = MemoryBuffer.new(file_path: file_path, mode: :write, buffer_size: buffer_size)
|
||||
@buffer.pos = 0
|
||||
|
||||
@buffer.write("MIX1")
|
||||
@encrypted = encrypted
|
||||
|
||||
@buffer.write(encrypted? ? "MIX2" : "MIX1")
|
||||
|
||||
files = @package.files.sort { |a, b| a.file_crc <=> b.file_crc }
|
||||
|
||||
@@ -322,6 +334,10 @@ class W3DHub
|
||||
def write_byte(byte)
|
||||
@buffer.write([byte].pack("c"))
|
||||
end
|
||||
|
||||
def encrypted?
|
||||
@encrypted
|
||||
end
|
||||
end
|
||||
|
||||
# Eager loads patch file and streams target file metadata (doen't load target file data or generate CRCs)
|
||||
|
||||
@@ -3,6 +3,7 @@ class W3DHub
|
||||
class Community < Page
|
||||
def setup
|
||||
@w3dhub_news ||= nil
|
||||
@w3dhub_news_expires ||= 0
|
||||
|
||||
body.clear do
|
||||
stack(width: 1.0, height: 1.0, padding: 8) do
|
||||
@@ -76,6 +77,30 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
def update
|
||||
super
|
||||
|
||||
|
||||
if Gosu.milliseconds >= @w3dhub_news_expires
|
||||
@w3dhub_news = nil
|
||||
@w3dhub_news_expires = Gosu.milliseconds + 30_000 # seconds
|
||||
|
||||
@wd3hub_news_container.clear do
|
||||
title I18n.t(:"games.fetching_news"), padding: 8
|
||||
end
|
||||
|
||||
BackgroundWorker.foreground_job(
|
||||
-> { fetch_w3dhub_news },
|
||||
lambda do |result|
|
||||
if result
|
||||
populate_w3dhub_news
|
||||
Cache.release_net_lock(result)
|
||||
end
|
||||
end
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
def fetch_w3dhub_news
|
||||
lock = Cache.acquire_net_lock("w3dhub_news")
|
||||
return false unless lock
|
||||
@@ -86,10 +111,11 @@ class W3DHub
|
||||
return unless news
|
||||
|
||||
news.items[0..15].each do |item|
|
||||
Cache.fetch(uri: item.image, async: false)
|
||||
Cache.fetch(uri: item.image, async: false, backend: :w3dhub)
|
||||
end
|
||||
|
||||
@w3dhub_news = news
|
||||
@w3dhub_news_expires = Gosu.milliseconds + (60 * 60 * 1000) # 1 hour (in ms)
|
||||
|
||||
"w3dhub_news"
|
||||
end
|
||||
@@ -135,7 +161,13 @@ class W3DHub
|
||||
flow(width: 1.0, max_width: 1230, height: 200, margin: 8, border_thickness: 1, border_color: lighten(Gosu::Color.new(0xff_252525))) do
|
||||
background 0x44_000000
|
||||
|
||||
image image_path, height: 1.0
|
||||
# Ensure the image file exists before trying to load it
|
||||
if File.exist?(image_path)
|
||||
image image_path, height: 1.0
|
||||
else
|
||||
logger.warn("W3DHub::Community") { "Image not found in cache: #{image_path}" }
|
||||
image BLACK_IMAGE, height: 1.0
|
||||
end
|
||||
|
||||
stack(fill: true, height: 1.0, padding: 4, border_thickness_left: 1, border_color_left: lighten(Gosu::Color.new(0xff_252525))) do
|
||||
tagline "<b>#{item.title}</b>", width: 1.0
|
||||
|
||||
@@ -36,7 +36,7 @@ class W3DHub
|
||||
background app_color
|
||||
|
||||
flow(width: 0.70, height: 1.0) do
|
||||
image_path = File.exist?("#{GAME_ROOT_PATH}/media/icons/#{task.app_id}.png") ? "#{GAME_ROOT_PATH}/media/icons/#{task.app_id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
image_path = File.exist?("#{CACHE_PATH}/#{task.app_id}.png") ? "#{CACHE_PATH}/#{task.app_id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
@application_image = image image_path, height: 1.0
|
||||
|
||||
stack(margin_left: 8, width: 0.75) do
|
||||
|
||||
@@ -17,8 +17,7 @@ class W3DHub
|
||||
end
|
||||
|
||||
# Game Menu
|
||||
@game_page_container = stack(width: 1.0, fill: true, background_image: "#{GAME_ROOT_PATH}/media/textures/noiseb.png", background_image_mode: :tiled) do
|
||||
# , background_image: "C:/Users/cyber/Downloads/vlcsnap-2022-04-24-22h24m15s854.png"
|
||||
@game_page_container = stack(width: 1.0, fill: true) do
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -29,6 +28,36 @@ class W3DHub
|
||||
populate_games_list
|
||||
end
|
||||
|
||||
def update
|
||||
super
|
||||
|
||||
|
||||
@game_news.each do |key, value|
|
||||
next if key.end_with?("_expires")
|
||||
|
||||
if Gosu.milliseconds >= @game_news["#{key}_expires"]
|
||||
@game_news.delete(key)
|
||||
@game_news["#{key}_expires"] = Gosu.milliseconds + 30_000 # seconds
|
||||
|
||||
if @focused_game && @focused_game.id == key
|
||||
@game_news_container.clear do
|
||||
title I18n.t(:"games.fetching_news"), padding: 8
|
||||
end
|
||||
|
||||
BackgroundWorker.foreground_job(
|
||||
-> { fetch_game_news(@focused_game) },
|
||||
lambda do |result|
|
||||
if result
|
||||
populate_game_news(@focused_game)
|
||||
Cache.release_net_lock(result)
|
||||
end
|
||||
end
|
||||
)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
def populate_games_list
|
||||
@games_list_container.clear do
|
||||
background 0xaa_121920
|
||||
@@ -56,11 +85,11 @@ class W3DHub
|
||||
padding_left: 4, padding_right: 4, tip: game.name) do
|
||||
background game.color if selected
|
||||
|
||||
image_path = File.exist?("#{GAME_ROOT_PATH}/media/icons/#{game.id}.png") ? "#{GAME_ROOT_PATH}/media/icons/#{game.id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
image_path = File.exist?("#{CACHE_PATH}/#{game.id}.png") ? "#{CACHE_PATH}/#{game.id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
image_color = Store.application_manager.installed?(game.id, game.channels.first.id) ? 0xff_ffffff : 0x66_ffffff
|
||||
|
||||
flow(width: 1.0, height: 1.0, margin: 8, background_image: image_path, background_image_color: image_color, background_image_mode: :fill_height) do
|
||||
image "#{GAME_ROOT_PATH}/media/ui_icons/import.png", width: 24, margin_left: -4, margin_top: -6, color: 0xff_ff8800 if Store.application_manager.updateable?(game.id, game.channels.first.id)
|
||||
image "#{GAME_ROOT_PATH}/media/ui_icons/import.png", width: 24, margin_left: -4, margin_top: -6, color: 0xff_ff8800 if game.channels.any? { |channel| Store.application_manager.updateable?(game.id, channel.id) }
|
||||
end
|
||||
|
||||
# para game.name, width: 1.0, text_align: :center
|
||||
@@ -89,28 +118,25 @@ class W3DHub
|
||||
|
||||
@game_page_container.clear do
|
||||
game_color = Gosu::Color.new(game.color)
|
||||
game_color.alpha = 0x88
|
||||
game_color.alpha = 0xaa
|
||||
|
||||
background game_color
|
||||
@game_page_container.style.background_image_color = game_color
|
||||
@game_page_container.style.default[:background_image_color] = game_color
|
||||
@game_page_container.update_background_image
|
||||
background_image_path = Cache.package_path(game.category, game.id, "background.png", "")
|
||||
if File.exist?(background_image_path)
|
||||
States::Interface.instance&.instance_variable_get(:"@interface_container")&.style&.background_image = get_image(background_image_path)
|
||||
States::Interface.instance&.instance_variable_get(:"@interface_container")&.style&.default[:background_image] = get_image(background_image_path)
|
||||
end
|
||||
|
||||
# Game Stuff
|
||||
flow(width: 1.0, fill: true) do
|
||||
# background 0xff_9999ff
|
||||
|
||||
# Game options
|
||||
stack(width: 360, height: 1.0, padding: 8, scroll: true, border_thickness_right: 1, border_color_right: W3DHub::BORDER_COLOR) do
|
||||
background 0x55_000000
|
||||
stack(width: 360, height: 1.0, padding: 8, scroll: true, background: game_color, border_thickness_right: 1, border_color_right: W3DHub::BORDER_COLOR) do
|
||||
# Game Logo
|
||||
logo_image_path = Cache.package_path(game.category, game.id, "logo.png", "")
|
||||
|
||||
# Game Banner
|
||||
image_path = "#{GAME_ROOT_PATH}/media/banners/#{game.id}.png"
|
||||
|
||||
if File.exist?(image_path)
|
||||
image image_path, width: 1.0
|
||||
if File.exist?(logo_image_path)
|
||||
image logo_image_path, width: 1.0
|
||||
else
|
||||
banner game.name unless File.exist?(image_path)
|
||||
banner game.name unless File.exist?(logo_image_path)
|
||||
end
|
||||
|
||||
stack(width: 1.0, fill: true, scroll: true, margin_top: 32) do
|
||||
@@ -203,8 +229,10 @@ class W3DHub
|
||||
end
|
||||
|
||||
unless Store.offline_mode
|
||||
menu_item(I18n.t(:"games.game_modifications")) do
|
||||
populate_game_modifications(game, channel)
|
||||
if W3DHUB_DEVELOPER
|
||||
menu_item(I18n.t(:"games.game_modifications")) do
|
||||
populate_game_modifications(game, channel)
|
||||
end
|
||||
end
|
||||
|
||||
if game.id != "ren"
|
||||
@@ -300,11 +328,6 @@ class W3DHub
|
||||
|
||||
def populate_all_games_view
|
||||
@game_page_container.clear do
|
||||
background 0x88_353535
|
||||
@game_page_container.style.background_image_color = 0x88_353535
|
||||
@game_page_container.style.default[:background_image_color] = 0x88_353535
|
||||
@game_page_container.update_background_image
|
||||
|
||||
@focused_game = nil
|
||||
@focused_channel = nil
|
||||
|
||||
@@ -352,7 +375,7 @@ class W3DHub
|
||||
end
|
||||
|
||||
container = stack(fill: true, width: 1.0, padding: 8) do
|
||||
image_path = File.exist?("#{GAME_ROOT_PATH}/media/icons/#{game.id}.png") ? "#{GAME_ROOT_PATH}/media/icons/#{game.id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
image_path = File.exist?("#{CACHE_PATH}/#{game.id}.png") ? "#{CACHE_PATH}/#{game.id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
flow(width: 1.0, margin_top: 8) do
|
||||
flow(fill: true)
|
||||
image image_path, width: 0.5
|
||||
@@ -394,10 +417,11 @@ class W3DHub
|
||||
return false unless news
|
||||
|
||||
news.items[0..15].each do |item|
|
||||
Cache.fetch(uri: item.image, async: false)
|
||||
Cache.fetch(uri: item.image, async: false, backend: :w3dhub)
|
||||
end
|
||||
|
||||
@game_news[game.id] = news
|
||||
@game_news["#{game.id}_expires"] = Gosu.milliseconds + (60 * 60 * 1000) # 1 hour (in ms)
|
||||
|
||||
"game_news_#{game.id}"
|
||||
end
|
||||
@@ -406,6 +430,9 @@ class W3DHub
|
||||
return unless @focused_game == game
|
||||
|
||||
if (feed = @game_news[game.id])
|
||||
game_color = Gosu::Color.new(game.color)
|
||||
game_color.alpha = 0xaa
|
||||
|
||||
@game_news_container.clear do
|
||||
# Patch Notes
|
||||
if false # Patch notes
|
||||
@@ -435,10 +462,10 @@ class W3DHub
|
||||
feed.items.sort_by { |i| i.timestamp }.reverse[0..9].each do |item|
|
||||
image_path = Cache.path(item.image)
|
||||
|
||||
flow(width: 1.0, max_width: 869, height: 200, margin: 8, border_thickness: 1, border_color: lighten(Gosu::Color.new(game.color))) do
|
||||
background 0x44_000000
|
||||
|
||||
image image_path, height: 1.0
|
||||
flow(width: 1.0, max_width: 869, height: 200, margin: 8, background: game_color, border_thickness: 1, border_color: lighten(Gosu::Color.new(game.color))) do
|
||||
if File.file?(image_path)
|
||||
image image_path, height: 1.0
|
||||
end
|
||||
|
||||
stack(fill: true, height: 1.0, padding: 4, border_thickness_left: 1, border_color_left: lighten(Gosu::Color.new(game.color))) do
|
||||
tagline "<b>#{item.title}</b>", width: 1.0
|
||||
|
||||
@@ -44,8 +44,10 @@ class W3DHub
|
||||
Store.settings[:account][:data] = account
|
||||
Store.settings.save_settings
|
||||
|
||||
Cache.fetch(uri: account.avatar_uri, force_fetch: true, async: false) if account
|
||||
applications = Api.applications if account
|
||||
if account
|
||||
Cache.fetch(uri: account.avatar_uri, force_fetch: true, async: false, backend: :w3dhub)
|
||||
applications = Api._applications
|
||||
end
|
||||
end
|
||||
|
||||
[account, applications]
|
||||
@@ -79,7 +81,7 @@ class W3DHub
|
||||
|
||||
if Store.account
|
||||
BackgroundWorker.foreground_job(
|
||||
-> { Cache.fetch(uri: Store.account.avatar_uri, async: false) },
|
||||
-> { Cache.fetch(uri: Store.account.avatar_uri, async: false, backend: :w3dhub) },
|
||||
->(result) {
|
||||
populate_account_info
|
||||
page(W3DHub::Pages::Games)
|
||||
@@ -102,6 +104,8 @@ class W3DHub
|
||||
end
|
||||
|
||||
def populate_account_info
|
||||
return if Store.offline_mode
|
||||
|
||||
@host.instance_variable_get(:"@account_container").clear do
|
||||
flow(fill: true, height: 1.0) do
|
||||
avatar_image = begin
|
||||
@@ -150,7 +154,7 @@ class W3DHub
|
||||
Store.account = nil
|
||||
|
||||
BackgroundWorker.foreground_job(
|
||||
-> { Api.applications },
|
||||
-> { Api._applications },
|
||||
lambda do |applications|
|
||||
if applications
|
||||
Store.applications = applications
|
||||
|
||||
@@ -43,7 +43,7 @@ class W3DHub
|
||||
app = Store.applications.games.find { |a| a.id == app_id.to_s }
|
||||
next unless app
|
||||
|
||||
image_path = File.exist?("#{GAME_ROOT_PATH}/media/icons/#{app_id}.png") ? "#{GAME_ROOT_PATH}/media/icons/#{app_id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
image_path = File.exist?("#{CACHE_PATH}/#{app.id}.png") ? "#{CACHE_PATH}/#{app.id}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
|
||||
image image_path, tip: "#{app.name}", height: 1.0,
|
||||
border_thickness_bottom: 1, border_color_bottom: 0x00_000000,
|
||||
@@ -63,19 +63,13 @@ class W3DHub
|
||||
populate_server_list
|
||||
end
|
||||
end
|
||||
|
||||
# button get_image("#{GAME_ROOT_PATH}/media/ui_icons/return.png"), tip: I18n.t(:"server_browser.refresh"), image_height: 1.0, margin_left: 16, padding_left: 2, padding_right: 2, padding_top: 2, padding_bottom: 2 do
|
||||
# fetch_server_list
|
||||
# end
|
||||
|
||||
flow(fill: true)
|
||||
|
||||
button "Direct Connect", height: 1.0, padding_top: 4, padding_bottom: 4 do
|
||||
push_state(W3DHub::States::DirectConnectDialog)
|
||||
end
|
||||
end
|
||||
|
||||
flow(min_width: 372, width: 0.38, max_width: 512, height: 1.0) do |container|
|
||||
button "Direct Connect", height: 1.0, padding_top: 4, padding_bottom: 4 do
|
||||
push_state(W3DHub::States::DirectConnectDialog)
|
||||
end
|
||||
|
||||
flow(fill: true)
|
||||
|
||||
para "#{I18n.t(:"server_browser.nickname")}:"
|
||||
@@ -202,11 +196,11 @@ class W3DHub
|
||||
|
||||
def ping_icon(server)
|
||||
case server.ping
|
||||
when 0..160
|
||||
when 0..150
|
||||
@ping_icons[:good]
|
||||
when 161..250
|
||||
when 151..200
|
||||
@ping_icons[:fair]
|
||||
when 251..1_000
|
||||
when 201..1_000
|
||||
@ping_icons[:poor]
|
||||
when 1_001..5_000
|
||||
@ping_icons[:bad]
|
||||
@@ -216,7 +210,7 @@ class W3DHub
|
||||
end
|
||||
|
||||
def ping_tip(server)
|
||||
server.ping.negative? ? "Ping failed" : "Ping #{server.ping}ms"
|
||||
server.ping == W3DHub::Api::ServerListServer::NO_OR_BAD_PING ? "Ping failed" : "Ping #{server.ping}ms"
|
||||
end
|
||||
|
||||
def find_element_by_tag(container, tag, list = [])
|
||||
@@ -231,7 +225,12 @@ class W3DHub
|
||||
return list.first
|
||||
end
|
||||
|
||||
def refresh_server_list(server, mode = :update) # :remove
|
||||
def refresh_server_list(server, mode = :update) # :remove, :refresh_all
|
||||
if mode == :refresh_all
|
||||
populate_server_list
|
||||
return
|
||||
end
|
||||
|
||||
@refresh_server_list = Gosu.milliseconds + 3_000
|
||||
@refresh_server = server if @selected_server&.id == server.id
|
||||
|
||||
@@ -258,14 +257,14 @@ class W3DHub
|
||||
player_count = find_element_by_tag(server_container, :player_count)
|
||||
server_ping = find_element_by_tag(server_container, :ping)
|
||||
|
||||
game_icon.value = game_icon(server)
|
||||
server_name.value = "<b>#{server&.status&.name}</b>"
|
||||
server_channel.value = Store.application_manager.channel_name(server.game, server.channel).to_s
|
||||
server_region.value = server.region
|
||||
server_map.value = server&.status&.map
|
||||
player_count.value = "#{server&.status&.player_count}/#{server&.status&.max_players}"
|
||||
server_ping.value = ping_icon(server)
|
||||
server_ping.parent.parent.tip = ping_tip(server)
|
||||
game_icon&.value = game_icon(server)
|
||||
server_name&.value = "<b>#{server&.status&.name}</b>"
|
||||
server_channel&.value = Store.application_manager.channel_name(server.game, server.channel).to_s
|
||||
server_region&.value = server.region
|
||||
server_map&.value = server&.status&.map
|
||||
player_count&.value = "#{server&.status&.player_count}/#{server&.status&.max_players}"
|
||||
server_ping&.value = ping_icon(server)
|
||||
server_ping&.parent.parent.tip = ping_tip(server)
|
||||
end
|
||||
|
||||
def update_server_ping(server)
|
||||
@@ -293,7 +292,7 @@ class W3DHub
|
||||
@server_list_container.children.sort_by! do |child|
|
||||
s = Store.server_list.find { |s| s.id == child.style.tag }
|
||||
|
||||
[s.status.player_count, s.id]
|
||||
[s.status.player_count, -s.ping]
|
||||
end.reverse!.each_with_index do |child, i|
|
||||
next if @selected_server_container && child == @selected_server_container
|
||||
|
||||
@@ -308,7 +307,7 @@ class W3DHub
|
||||
end
|
||||
|
||||
def populate_server_list
|
||||
Store.server_list = Store.server_list.sort_by! { |s| [s&.status&.player_count, s&.id] }.reverse if Store.server_list
|
||||
Store.server_list = Store.server_list.sort_by! { |s| [s.status.player_count, s.id] }.reverse
|
||||
|
||||
@server_list_container.clear do
|
||||
Store.server_list.each do |server|
|
||||
@@ -411,11 +410,11 @@ class W3DHub
|
||||
if server.status.password
|
||||
W3DHub.prompt_for_password(
|
||||
accept_callback: proc do |password|
|
||||
W3DHub.join_server(server, password)
|
||||
W3DHub.join_server(server: server, password: password)
|
||||
end
|
||||
)
|
||||
else
|
||||
W3DHub.join_server(server, nil)
|
||||
W3DHub.join_server(server: server)
|
||||
end
|
||||
end
|
||||
)
|
||||
@@ -423,18 +422,24 @@ class W3DHub
|
||||
if server.status.password
|
||||
W3DHub.prompt_for_password(
|
||||
accept_callback: proc do |password|
|
||||
W3DHub.join_server(server, password)
|
||||
W3DHub.join_server(server: server, password: password)
|
||||
end
|
||||
)
|
||||
else
|
||||
W3DHub.join_server(server, nil)
|
||||
W3DHub.join_server(server: server)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
if W3DHUB_DEVELOPER
|
||||
list_box(items: (1..12).to_a.map(&:to_s), margin_left: 16, width: 72, tip: "Number of game clients", **TESTING_BUTTON)
|
||||
button "Multijoin", tip: "Launch multiple clients with configured username_\#{number}", **TESTING_BUTTON, enabled: true
|
||||
client_instances = list_box(items: (1..12).to_a.map(&:to_s), margin_left: 16, width: 72, tip: "Number of game clients", enabled: (game_installed && !game_updatable), **TESTING_BUTTON)
|
||||
button("Multijoin", tip: "Launch multiple clients with configured username_\#{number}", enabled: (game_installed && !game_updatable), **TESTING_BUTTON) do
|
||||
username = Store.settings[:server_list_username]
|
||||
|
||||
client_instances.value.to_i.times do |i|
|
||||
W3DHub.join_server(server: server, username: format("%s_%d", username, i), multi: true)
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
flow(fill: true)
|
||||
@@ -535,7 +540,7 @@ class W3DHub
|
||||
end
|
||||
|
||||
def game_icon(server)
|
||||
image_path = File.exist?("#{GAME_ROOT_PATH}/media/icons/#{server.game.nil? ? 'ren' : server.game}.png") ? "#{GAME_ROOT_PATH}/media/icons/#{server.game.nil? ? 'ren' : server.game}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
image_path = File.exist?("#{CACHE_PATH}/#{server.game.nil? ? 'ren' : server.game}.png") ? "#{CACHE_PATH}/#{server.game.nil? ? 'ren' : server.game}.png" : "#{GAME_ROOT_PATH}/media/icons/default_icon.png"
|
||||
|
||||
if server.status.password
|
||||
@server_locked_icons[server.game] ||= Gosu.render(96, 96) do
|
||||
|
||||
@@ -3,81 +3,57 @@ class W3DHub
|
||||
class Settings < Page
|
||||
def setup
|
||||
body.clear do
|
||||
stack(width: 1.0, height: 1.0, padding: 16, scroll: true) do
|
||||
stack(width: 1.0, height: 1.0, padding: 16) do
|
||||
background 0xaa_252525
|
||||
|
||||
para "<b>Language</b>"
|
||||
flow(width: 1.0, height: 0.12) do
|
||||
para "<b>Launcher Language</b>", width: 0.249, margin_left: 32, margin_top: 12
|
||||
stack(width: 0.75) do
|
||||
@language_menu = list_box items: I18n.available_locales.map { |l| expand_language_code(l.to_s) }, choose: expand_language_code(Store.settings[:language]), width: 1.0
|
||||
para "Select the UI language you'd like to use in the W3D Hub Launcher."
|
||||
stack(width: 1.0, fill: true, max_width: 720, h_align: :center, scroll: true) do
|
||||
stack(width: 1.0, height: 112) do
|
||||
tagline "Launcher Language"
|
||||
@language_menu = list_box items: I18n.available_locales.map { |l| expand_language_code(l.to_s) }, choose: expand_language_code(Store.settings[:language]), width: 1.0, margin_left: 16
|
||||
para "Select the UI language you'd like to use in the W3D Hub Launcher.", margin_left: 16
|
||||
end
|
||||
end
|
||||
|
||||
para "<b>Folder Paths</b>", margin_top: 8, padding_top: 8, border_thickness_top: 2, border_color_top: 0xee_ffffff, width: 1.0
|
||||
stack(width: 1.0, height: 0.3) do
|
||||
flow(width: 1.0, height: 0.5) do
|
||||
para "<b>App Install Folder</b>", width: 0.249, margin_left: 32, margin_top: 12
|
||||
|
||||
stack(width: 0.75) do
|
||||
@app_install_dir_input = edit_line Store.settings[:app_install_dir], width: 1.0
|
||||
para "The folder into which new games and apps will be installed by the launcher"
|
||||
stack(width: 1.0, height: 200, margin_top: 16) do
|
||||
tagline "Launcher Directories"
|
||||
caption "Applications Install Directory", margin_left: 16
|
||||
flow(width: 1.0, fill: true, margin_left: 16) do
|
||||
@app_install_dir_input = edit_line Store.settings[:app_install_dir], fill: true
|
||||
button "Browse...", width: 128, tip: "Browse for applications install directory" do
|
||||
path = W3DHub.ask_folder
|
||||
@app_install_dir_input.value = path unless path.empty?
|
||||
end
|
||||
end
|
||||
|
||||
caption "Package Cache Directory", margin_left: 16, margin_top: 16
|
||||
flow(width: 1.0, fill: true, margin_left: 16) do
|
||||
@package_cache_dir_input = edit_line Store.settings[:package_cache_dir], fill: true
|
||||
button "Browse...", width: 128, tip: "Browse for package cache directory" do
|
||||
path = W3DHub.ask_folder
|
||||
@package_cache_dir_input.value = path unless path.empty?
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
flow(width: 1.0, margin_top: 16) do
|
||||
para "<b>Package Cache Folder</b>", width: 0.249, margin_left: 32, margin_top: 12
|
||||
if W3DHub.unix?
|
||||
stack(width: 1.0, height: 224, margin_top: 16) do
|
||||
tagline "Wine - Windows compatibility layer"
|
||||
caption "Wine Command", margin_left: 16
|
||||
@wine_command_input = edit_line Store.settings[:wine_command], width: 1.0, margin_left: 16
|
||||
para "Command to use to for Windows compatiblity layer.", margin_left: 16
|
||||
|
||||
stack(width: 0.75) do
|
||||
@package_cache_dir_input = edit_line Store.settings[:package_cache_dir], width: 1.0
|
||||
para "A folder which will be used to cache downloaded packages used to install games and apps"
|
||||
caption "Wine Prefix", margin_left: 16, margin_top: 16
|
||||
flow(width: 1.0, height: 48, margin_left: 16) do
|
||||
@wine_prefix_toggle = toggle_button checked: Store.settings[:wine_prefix], enabled: false
|
||||
para "Whether each game gets its own prefix. Uses global/default prefix by default."
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
if true # W3DHub.unix?
|
||||
para "<b>Wine</b>", margin_top: 8, padding_top: 8, border_thickness_top: 2, border_color_top: 0xee_ffffff, width: 1.0
|
||||
flow(width: 1.0, height: 0.12) do
|
||||
para "<b>Wine Command</b>", width: 0.249, margin_left: 32, margin_top: 12
|
||||
stack(width: 0.75) do
|
||||
@wine_command_input = edit_line Store.settings[:wine_command], width: 1.0
|
||||
para "Command to use to for Windows compatiblity layer"
|
||||
end
|
||||
end
|
||||
|
||||
flow(width: 1.0, height: 0.13, margin_top: 16) do
|
||||
para "<b>Wine Prefix</b>", width: 0.249, margin_left: 32, margin_top: 12
|
||||
stack(width: 0.75) do
|
||||
@wine_prefix_toggle = toggle_button checked: Store.settings[:wine_prefix]
|
||||
para "Whether each game gets its own prefix. Uses global/default prefix by default."
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
button "Save" do
|
||||
old_language = Store.settings[:language]
|
||||
Store.settings[:language] = language_code(@language_menu.value)
|
||||
|
||||
Store.settings[:app_install_dir] = @app_install_dir_input.value
|
||||
Store.settings[:package_cache_dir] = @package_cache_dir_input.value
|
||||
|
||||
Store.settings[:wine_command] = @wine_command_input.value
|
||||
Store.settings[:wine_prefix] = @wine_prefix_toggle.value
|
||||
|
||||
Store.settings.save_settings
|
||||
|
||||
begin
|
||||
I18n.locale = Store.settings[:language]
|
||||
rescue I18n::InvalidLocale
|
||||
I18n.locale = :en
|
||||
end
|
||||
|
||||
if old_language == Store.settings[:language]
|
||||
page(Pages::Games)
|
||||
else
|
||||
# pop back to Boot state which will immediately push a new instance of Interface
|
||||
pop_state
|
||||
stack(width: 128, max_height: 256, h_align: :center, margin_top: 16, fill: true) do
|
||||
button "Save", width: 1.0 do
|
||||
save_settings!
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -108,7 +84,35 @@ class W3DHub
|
||||
when "es"
|
||||
"Español"
|
||||
else
|
||||
raise "Unknown language error"
|
||||
logger.warn("W3DHub::Settings") { "Unknown language code: #{string.inspect}" }
|
||||
|
||||
"UNKNOWN"
|
||||
end
|
||||
end
|
||||
|
||||
def save_settings!
|
||||
old_language = Store.settings[:language]
|
||||
Store.settings[:language] = language_code(@language_menu.value)
|
||||
|
||||
Store.settings[:app_install_dir] = @app_install_dir_input.value
|
||||
Store.settings[:package_cache_dir] = @package_cache_dir_input.value
|
||||
|
||||
Store.settings[:wine_command] = @wine_command_input.value
|
||||
Store.settings[:wine_prefix] = @wine_prefix_toggle.value
|
||||
|
||||
Store.settings.save_settings
|
||||
|
||||
begin
|
||||
I18n.locale = Store.settings[:language]
|
||||
rescue I18n::InvalidLocale
|
||||
I18n.locale = :en
|
||||
end
|
||||
|
||||
if old_language == Store.settings[:language]
|
||||
page(Pages::Games)
|
||||
else
|
||||
# pop back to Boot state which will immediately push a new instance of Interface
|
||||
pop_state
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -71,5 +71,15 @@ class W3DHub
|
||||
def save_settings
|
||||
File.write(SETTINGS_FILE_PATH, @settings.to_json)
|
||||
end
|
||||
|
||||
def save_application_cache(json)
|
||||
File.write(APPLICATIONS_CACHE_FILE_PATH, json)
|
||||
end
|
||||
|
||||
def load_application_cache
|
||||
JSON.parse(File.read(APPLICATIONS_CACHE_FILE_PATH), symbolize_names: true)
|
||||
rescue
|
||||
nil
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -11,12 +11,14 @@ class W3DHub
|
||||
@fraction = 0.0
|
||||
@w3dhub_logo = get_image("#{GAME_ROOT_PATH}/media/icons/app.png")
|
||||
@tasks = {
|
||||
# connectivity_check: { started: false, complete: false }, # HEAD connectivity-check.ubuntu.com or HEAD secure.w3dhub.com?
|
||||
connectivity_check: { started: false, complete: false }, # HEAD connectivity-check.ubuntu.com or HEAD secure.w3dhub.com?
|
||||
# launcher_updater: { started: false, complete: false },
|
||||
server_list: { started: false, complete: false },
|
||||
refresh_user_token: { started: false, complete: false },
|
||||
service_status: { started: false, complete: false },
|
||||
applications: { started: false, complete: false },
|
||||
app_icons: { started: false, complete: false },
|
||||
server_list: { started: false, complete: false }
|
||||
app_logos_and_backgrounds: { started: false, complete: false }
|
||||
}
|
||||
|
||||
@offline_mode = false
|
||||
@@ -29,8 +31,8 @@ class W3DHub
|
||||
|
||||
stack(width: 1.0, height: 60) do
|
||||
flow(width: 1.0, height: 26, margin_left: 16, margin_right: 16, margin_bottom: 8, margin_top: 8) do
|
||||
@status_label = caption "Starting #{I18n.t(:app_name_simple)}...", width: 0.5
|
||||
para "#{I18n.t(:app_name)} #{W3DHub::VERSION}", width: 0.5, text_align: :right
|
||||
@status_label = caption "Starting #{I18n.t(:app_name_simple)}...", fill: true
|
||||
para "#{I18n.t(:app_name)} #{W3DHub::VERSION}", text_align: :right
|
||||
end
|
||||
|
||||
@progressbar = progress height: 4, width: 1.0, margin_left: 16, margin_right: 16, margin_bottom: 8
|
||||
@@ -52,7 +54,16 @@ class W3DHub
|
||||
|
||||
@progressbar.value = @fraction
|
||||
|
||||
load_offline_applications_list if @offline_mode
|
||||
if @offline_mode
|
||||
load_offline_applications_list
|
||||
|
||||
unless Store.applications
|
||||
@progressbar.value = 0.0
|
||||
@status_label.value = "<c=f80>Unable to connect to W3D Hub API. No application data cached, unable to continue.</c>"
|
||||
|
||||
return
|
||||
end
|
||||
end
|
||||
|
||||
if @offline_mode || (@progressbar.value >= 1.0 && @task_index == @tasks.size)
|
||||
pop_state
|
||||
@@ -65,7 +76,7 @@ class W3DHub
|
||||
application = Store.applications.games.find { |g| g.id == key.to_s.split("_", 2).first }
|
||||
next unless application
|
||||
|
||||
game[:colour] = application.color
|
||||
game[:colour] = "##{application.color.to_s(16)}"
|
||||
game[:uses_engine_cfg] = application.uses_engine_cfg?
|
||||
end
|
||||
end
|
||||
@@ -118,7 +129,7 @@ class W3DHub
|
||||
|
||||
Store.settings[:account][:data] = account
|
||||
|
||||
Cache.fetch(uri: account.avatar_uri, force_fetch: true, async: false)
|
||||
Cache.fetch(uri: account.avatar_uri, force_fetch: true, async: false, backend: :w3dhub)
|
||||
else
|
||||
Store.settings[:account] = {}
|
||||
end
|
||||
@@ -128,6 +139,41 @@ class W3DHub
|
||||
@tasks[:refresh_user_token][:complete] = true
|
||||
end
|
||||
|
||||
def connectivity_check
|
||||
domains = {
|
||||
"w3dhub-api.w3d.cyberarm.dev": false,
|
||||
"s3.w3d.cyberarm.dev": false,
|
||||
"secure.w3dhub.com": false
|
||||
}
|
||||
|
||||
@status_label.value = "Checking uplink..."
|
||||
domains.each do |key, value|
|
||||
begin
|
||||
Resolv.getaddress(key.to_s)
|
||||
rescue => e
|
||||
logger.error(LOG_TAG) {"Failed to resolve hostname: #{key.to_s}"}
|
||||
logger.error(LOG_TAG) {e}
|
||||
|
||||
push_state(
|
||||
ConfirmDialog,
|
||||
title: "DNS Resolution Failure",
|
||||
message: "Failed to resolve: #{key.to_s}\n\nTry disabling VPN or proxy if in use.\n\n\nContinue offline?",
|
||||
cancel_callback: ->() { window.close },
|
||||
accept_callback: ->() {
|
||||
@offline_mode = true
|
||||
Store.offline_mode = true
|
||||
@tasks[:connectivity_check][:complete] = true
|
||||
}
|
||||
)
|
||||
|
||||
# Prevent task from being marked as completed
|
||||
return false
|
||||
end
|
||||
end
|
||||
|
||||
@tasks[:connectivity_check][:complete] = true
|
||||
end
|
||||
|
||||
def service_status
|
||||
Api.on_thread(:service_status) do |service_status|
|
||||
@service_status = service_status
|
||||
@@ -150,13 +196,39 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
def launcher_updater
|
||||
@status_label.value = "Checking for Launcher updates..." # I18n.t(:"boot.checking_for_updates")
|
||||
|
||||
Api.on_thread(:fetch, "https://api.github.com/repos/Inq8/CAmod/releases/latest") do |response|
|
||||
if response.status == 200
|
||||
hash = JSON.parse(response.body, symbolize_names: true)
|
||||
available_version = hash[:tag_name].downcase.sub("v", "")
|
||||
|
||||
pp Gem::Version.new(available_version) > Gem::Version.new(W3DHub::VERSION)
|
||||
pp [Gem::Version.new(available_version), Gem::Version.new(W3DHub::VERSION)]
|
||||
|
||||
push_state(
|
||||
LauncherUpdaterDialog,
|
||||
release_data: hash,
|
||||
available_version: available_version,
|
||||
cancel_callback: -> { @tasks[:launcher_updater][:complete] = true },
|
||||
accept_callback: -> { @tasks[:launcher_updater][:complete] = true }
|
||||
)
|
||||
else
|
||||
# Failed to retrieve release data from github
|
||||
log "Failed to retrieve release data from Github"
|
||||
@tasks[:launcher_updater][:complete] = true
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
def applications
|
||||
@status_label.value = I18n.t(:"boot.checking_for_updates")
|
||||
|
||||
Api.on_thread(:applications) do |applications|
|
||||
Api.on_thread(:_applications) do |applications|
|
||||
if applications
|
||||
Store.applications = applications
|
||||
|
||||
Store.settings.save_application_cache(applications.data.to_json)
|
||||
@tasks[:applications][:complete] = true
|
||||
else
|
||||
# FIXME: Failed to retreive!
|
||||
@@ -171,17 +243,21 @@ class W3DHub
|
||||
def app_icons
|
||||
return unless Store.applications
|
||||
|
||||
@status_label.value = "Retrieving application icons, this might take a moment..." # I18n.t(:"boot.checking_for_updates")
|
||||
|
||||
packages = []
|
||||
Store.applications.games.each do |app|
|
||||
packages << { category: app.category, subcategory: app.id, name: "#{app.id}.ico", version: "" }
|
||||
end
|
||||
|
||||
Api.on_thread(:package_details, packages) do |package_details|
|
||||
Api.on_thread(:package_details, packages, :alt_w3dhub) do |package_details|
|
||||
package_details ||= nil
|
||||
|
||||
package_details&.each do |package|
|
||||
next if package.error?
|
||||
|
||||
path = Cache.package_path(package.category, package.subcategory, package.name, package.version)
|
||||
generated_icon_path = "#{GAME_ROOT_PATH}/media/icons/#{package.subcategory}.png"
|
||||
generated_icon_path = "#{CACHE_PATH}/#{package.subcategory}.png"
|
||||
|
||||
regenerate = false
|
||||
|
||||
@@ -203,6 +279,34 @@ class W3DHub
|
||||
end
|
||||
end
|
||||
|
||||
def app_logos_and_backgrounds
|
||||
return unless Store.applications
|
||||
|
||||
@status_label.value = "Retrieving application image assets, this might take a moment..." # I18n.t(:"boot.checking_for_updates")
|
||||
|
||||
packages = []
|
||||
Store.applications.games.each do |app|
|
||||
packages << { category: app.category, subcategory: app.id, name: "logo.png", version: "" }
|
||||
packages << { category: app.category, subcategory: app.id, name: "background.png", version: "" }
|
||||
end
|
||||
|
||||
Api.on_thread(:package_details, packages, :alt_w3dhub) do |package_details|
|
||||
package_details ||= nil
|
||||
|
||||
package_details&.each do |package|
|
||||
next if package.error?
|
||||
|
||||
package_cache_path = Cache.package_path(package.category, package.subcategory, package.name, package.version)
|
||||
|
||||
missing_or_broken_image = File.exist?(package_cache_path) ? Digest::SHA256.new.hexdigest(File.binread(package_cache_path)).upcase != package.checksum.upcase : true
|
||||
|
||||
Cache.fetch_package(package, proc {}) if missing_or_broken_image
|
||||
end
|
||||
|
||||
@tasks[:app_logos_and_backgrounds][:complete] = true
|
||||
end
|
||||
end
|
||||
|
||||
def server_list
|
||||
@status_label.value = I18n.t(:"server_browser.fetching_server_list")
|
||||
|
||||
@@ -227,6 +331,12 @@ class W3DHub
|
||||
end
|
||||
|
||||
def load_offline_applications_list
|
||||
if (application_cache = Store.settings.load_application_cache)
|
||||
Store.applications = Api::Applications.new(application_cache.to_json)
|
||||
|
||||
return
|
||||
end
|
||||
|
||||
hash = {
|
||||
applications: []
|
||||
}
|
||||
@@ -262,7 +372,7 @@ class W3DHub
|
||||
hash[:applications] << app unless app_in_array
|
||||
end
|
||||
|
||||
Store.applications = Api::Applications.new(hash.to_json)
|
||||
Store.applications = Api::Applications.new(hash.to_json) unless hash[:applications].empty?
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -29,7 +29,7 @@ class W3DHub
|
||||
|
||||
stack(width: 0.5)
|
||||
|
||||
button "Confirm", width: 0.25, background: 0xff_800000, hover: { background: 0xff_d00000 }, active: { background: 0xff_600000, color: 0xff_ffffff } do
|
||||
button "Confirm", width: 0.25, **DANGEROUS_BUTTON do
|
||||
pop_state
|
||||
@options[:accept_callback]&.call
|
||||
end
|
||||
|
||||
62
lib/states/dialogs/launcher_updater_dialog.rb
Normal file
@@ -0,0 +1,62 @@
|
||||
class W3DHub
|
||||
class States
|
||||
class LauncherUpdaterDialog < Dialog
|
||||
BUTTON_STYLE = { text_size: 18, padding_top: 3, padding_bottom: 3, padding_left: 3, padding_right: 3, height: 18 }
|
||||
LIST_ITEM_THEME = Marshal.load(Marshal.dump(THEME))
|
||||
BUTTON_STYLE.each do |key, value|
|
||||
LIST_ITEM_THEME[:Button][key] = value
|
||||
end
|
||||
|
||||
def setup
|
||||
window.show_cursor = true
|
||||
|
||||
theme(THEME)
|
||||
|
||||
background 0xaa_525252
|
||||
|
||||
stack(width: 1.0, max_width: 760, height: 1.0, max_height: 640, v_align: :center, h_align: :center, background: 0xee_222222, border_thickness: 2, border_color: 0xee_222222, padding: 16) do
|
||||
flow(width: 1.0, height: 36, padding: 8) do
|
||||
background 0xff_0052c0
|
||||
|
||||
title @options[:title] || "Launcher Update Available", fill: true, text_align: :center, font: BOLD_FONT
|
||||
end
|
||||
|
||||
stack(width: 1.0, fill: true, margin_top: 14) do
|
||||
subtitle "Release Notes - #{@options[:available_version]}"
|
||||
|
||||
# case launcher_release_type
|
||||
# when :git
|
||||
# when :tebako
|
||||
# end
|
||||
|
||||
pp @options[:release_data]
|
||||
|
||||
stack(width: 1.0, fill: true, scroll: true, padding: 8, border_thickness: 1, border_color: 0x44_ffffff) do
|
||||
# para @options[:release_data][:body], width: 1.0
|
||||
# FIXME: Finish this bit
|
||||
@options[:release_data][:body].lines.each do |line|
|
||||
line.strip
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
flow(width: 1.0, height: 46, margin_top: 16) do
|
||||
background 0xff_ffffff
|
||||
|
||||
button "Cancel", width: 0.25 do
|
||||
pop_state
|
||||
@options[:cancel_callback]&.call
|
||||
end
|
||||
|
||||
flow(fill: true)
|
||||
|
||||
button "Update", width: 0.25 do
|
||||
pop_state
|
||||
@options[:accept_callback]&.call
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
@@ -24,6 +24,7 @@ class W3DHub
|
||||
stack(width: 1.0, height: 46, padding: 8) do
|
||||
button "Okay", width: 1.0 do
|
||||
pop_state
|
||||
@options[:accept_callback]&.call
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
@@ -1,6 +1,11 @@
|
||||
class W3DHub
|
||||
class States
|
||||
class Interface < CyberarmEngine::GuiState
|
||||
APPLICATIONS_UPDATE_INTERVAL = 10 * 60 * 1000 # ten minutes
|
||||
SERVER_LIST_UPDATE_INTERVAL = 5 * 60 * 1000 # five minutes
|
||||
|
||||
DEFAULT_BACKGROUND_IMAGE = "#{GAME_ROOT_PATH}/media/banners/background.png".freeze
|
||||
|
||||
attr_accessor :interface_task_update_pending
|
||||
|
||||
@@instance = nil
|
||||
@@ -18,6 +23,9 @@ class W3DHub
|
||||
@service_status = @options[:service_status]
|
||||
@applications = @options[:applications]
|
||||
|
||||
@applications_expire = Gosu.milliseconds + APPLICATIONS_UPDATE_INTERVAL # ten minutes
|
||||
@server_list_expire = Gosu.milliseconds + SERVER_LIST_UPDATE_INTERVAL # 5 minutes
|
||||
|
||||
@interface_task_update_pending = nil
|
||||
|
||||
@page = nil
|
||||
@@ -27,10 +35,12 @@ class W3DHub
|
||||
|
||||
theme(W3DHub::THEME)
|
||||
|
||||
@interface_container = stack(width: 1.0, height: 1.0, border_thickness: 1, border_color: W3DHub::BORDER_COLOR, background_image: "#{GAME_ROOT_PATH}/media/banners/background.png", background_image_color: 0xff_525252, background_image_mode: :fill) do
|
||||
@interface_container = stack(width: 1.0, height: 1.0, border_thickness: 1, border_color: W3DHub::BORDER_COLOR, background_image: DEFAULT_BACKGROUND_IMAGE, background_image_mode: :fill) do
|
||||
background 0xff_252525
|
||||
|
||||
@header_container = flow(width: 1.0, height: 84, padding: 4, border_thickness_bottom: 1, border_color_bottom: W3DHub::BORDER_COLOR) do
|
||||
background 0xaa_151515
|
||||
|
||||
flow(width: 148, height: 1.0) do
|
||||
flow(fill: true)
|
||||
image "#{GAME_ROOT_PATH}/media/icons/app.png", height: 84
|
||||
@@ -48,18 +58,26 @@ class W3DHub
|
||||
end
|
||||
|
||||
link I18n.t(:"interface.servers").upcase, text_size: 34, font: BOLD_FONT, margin_left: 12 do
|
||||
@interface_container.style.background_image = DEFAULT_BACKGROUND_IMAGE
|
||||
@interface_container.style.default[:background_image] = DEFAULT_BACKGROUND_IMAGE
|
||||
page(W3DHub::Pages::ServerBrowser)
|
||||
end
|
||||
|
||||
link I18n.t(:"interface.community").upcase, text_size: 34, font: BOLD_FONT, margin_left: 12 do
|
||||
@interface_container.style.background_image = DEFAULT_BACKGROUND_IMAGE
|
||||
@interface_container.style.default[:background_image] = DEFAULT_BACKGROUND_IMAGE
|
||||
page(W3DHub::Pages::Community)
|
||||
end
|
||||
|
||||
link I18n.t(:"interface.downloads").upcase, text_size: 34, font: BOLD_FONT, margin_left: 12 do
|
||||
@interface_container.style.background_image = DEFAULT_BACKGROUND_IMAGE
|
||||
@interface_container.style.default[:background_image] = DEFAULT_BACKGROUND_IMAGE
|
||||
page(W3DHub::Pages::DownloadManager)
|
||||
end
|
||||
|
||||
link I18n.t(:"interface.settings").upcase, text_size: 34, font: BOLD_FONT, margin_left: 12 do
|
||||
@interface_container.style.background_image = DEFAULT_BACKGROUND_IMAGE
|
||||
@interface_container.style.default[:background_image] = DEFAULT_BACKGROUND_IMAGE
|
||||
page(W3DHub::Pages::Settings)
|
||||
end
|
||||
end
|
||||
@@ -128,6 +146,36 @@ class W3DHub
|
||||
@page&.update
|
||||
|
||||
update_interface_task_status(@interface_task_update_pending) if @interface_task_update_pending
|
||||
|
||||
if Gosu.milliseconds >= @applications_expire
|
||||
@applications_expire = Gosu.milliseconds + 30_000
|
||||
|
||||
Api.on_thread(:_applications) do |applications|
|
||||
if applications
|
||||
@applications_expire = Gosu.milliseconds + APPLICATIONS_UPDATE_INTERVAL # ten minutes
|
||||
|
||||
Store.applications = applications
|
||||
|
||||
# TODO: Signal Games and ServerBrowser that applications have been updated
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
if Gosu.milliseconds >= @server_list_expire
|
||||
@server_list_expire = Gosu.milliseconds + 30_000
|
||||
|
||||
Api.on_thread(:server_list, 2) do |list|
|
||||
if list
|
||||
@server_list_expire = Gosu.milliseconds + SERVER_LIST_UPDATE_INTERVAL # five minutes
|
||||
|
||||
Store.server_list_last_fetch = Gosu.milliseconds
|
||||
|
||||
Api::ServerListUpdater.instance.refresh_server_list(list)
|
||||
|
||||
BackgroundWorker.foreground_job(-> {}, ->(_) { States::Interface.instance&.update_server_browser(nil, :refresh_all) })
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
def button_down(id)
|
||||
|
||||
41
lib/theme.rb
@@ -7,12 +7,28 @@ class W3DHub
|
||||
MAX_PAGE_WIDTH = 1200
|
||||
|
||||
TESTING_BUTTON = {
|
||||
background: 0xff_ff8800,
|
||||
background: 0xff_ff8800..0xff_dd6600,
|
||||
border_color: Gosu::Color::NONE,
|
||||
hover: {
|
||||
background: 0xff_ffaa00
|
||||
background: 0xff_dd6600..0xff_bb4400,
|
||||
border_color: 0xff_ff8800,
|
||||
},
|
||||
active: {
|
||||
background: 0xff_ffec00
|
||||
background: 0xff_bb4400..0xff_dd6600,
|
||||
border_color: 0xff_ff8800
|
||||
}
|
||||
}
|
||||
|
||||
DANGEROUS_BUTTON = {
|
||||
background: 0xff_800000..0xff_600000,
|
||||
border_color: Gosu::Color::NONE,
|
||||
hover: {
|
||||
background: 0xff_600000..0xff_400000,
|
||||
border_color: 0xff_800000,
|
||||
},
|
||||
active: {
|
||||
background: 0xff_400000..0xff_600000,
|
||||
border_color: 0xff_800000
|
||||
}
|
||||
}
|
||||
|
||||
@@ -80,15 +96,15 @@ class W3DHub
|
||||
padding_bottom: 8,
|
||||
border_thickness: 2,
|
||||
border_color: Gosu::Color::NONE,
|
||||
background: 0xff_0074e0,
|
||||
background: 0xff_0074e0..0xff_0052c0,
|
||||
hover: {
|
||||
color: 0xff_f2f2f2,
|
||||
background: 0xff_004c94,
|
||||
background: 0xff_0052c0..0xff_0030a0,
|
||||
border_color: 0xff_0074e0
|
||||
},
|
||||
active: {
|
||||
color: 0xff_aaaaaa,
|
||||
background: 0xff_005aad,
|
||||
background: 0xff_0030a0..0xff_0052c0,
|
||||
border_color: 0xff_0074e0
|
||||
}
|
||||
},
|
||||
@@ -151,7 +167,18 @@ class W3DHub
|
||||
MenuItem: {
|
||||
width: 1.0,
|
||||
text_left: :left,
|
||||
margin: 0
|
||||
margin: 0,
|
||||
border_color: Gosu::Color::NONE,
|
||||
background: 0xff_0074e0,
|
||||
hover: {
|
||||
color: 0xff_f2f2f2,
|
||||
background: 0xff_0052c0,
|
||||
border_color: Gosu::Color::NONE
|
||||
},
|
||||
active: {
|
||||
background: 0xff_0030a0,
|
||||
border_color: Gosu::Color::NONE
|
||||
}
|
||||
}
|
||||
}
|
||||
end
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
class W3DHub
|
||||
DIR_NAME = "W3DHubAlt"
|
||||
VERSION = "0.4.2"
|
||||
end
|
||||
DIR_NAME = "W3DHubAlt".freeze
|
||||
VERSION = "0.8.1".freeze
|
||||
end
|
||||
|
||||
|
Before Width: | Height: | Size: 771 KiB |
|
Before Width: | Height: | Size: 528 KiB |
|
Before Width: | Height: | Size: 38 KiB |
|
Before Width: | Height: | Size: 225 KiB |
|
Before Width: | Height: | Size: 714 KiB |
|
Before Width: | Height: | Size: 251 KiB |
|
Before Width: | Height: | Size: 163 KiB |
|
Before Width: | Height: | Size: 477 KiB |
|
Before Width: | Height: | Size: 240 KiB |
@@ -20,11 +20,19 @@ class W3DHub
|
||||
W3DHUB_DEBUG = ARGV.join.include?("--debug")
|
||||
W3DHUB_DEVELOPER = ARGV.join.include?("--developer")
|
||||
|
||||
GAME_ROOT_PATH = File.expand_path(".", __dir__)
|
||||
CACHE_PATH = "#{GAME_ROOT_PATH}/data/cache"
|
||||
SETTINGS_FILE_PATH = "#{GAME_ROOT_PATH}/data/settings.json"
|
||||
# Use the real working directory as the root for runtime data/logs
|
||||
GAME_ROOT_PATH = Dir.pwd
|
||||
|
||||
LOGGER = Logger.new("#{GAME_ROOT_PATH}/data/logs/w3d_hub_linux_launcher.log", "daily")
|
||||
CACHE_PATH = "#{GAME_ROOT_PATH}/data/cache"
|
||||
LOGS_PATH = "#{GAME_ROOT_PATH}/data/logs"
|
||||
SETTINGS_FILE_PATH = "#{GAME_ROOT_PATH}/data/settings.json"
|
||||
APPLICATIONS_CACHE_FILE_PATH = "#{GAME_ROOT_PATH}/data/applications_cache.json"
|
||||
|
||||
# Ensure data/cache and data/logs exist
|
||||
FileUtils.mkdir_p(CACHE_PATH) unless Dir.exist?(CACHE_PATH)
|
||||
FileUtils.mkdir_p(LOGS_PATH) unless Dir.exist?(LOGS_PATH)
|
||||
|
||||
LOGGER = Logger.new("#{LOGS_PATH}/w3d_hub_linux_launcher.log", "daily")
|
||||
LOGGER.level = Logger::Severity::DEBUG # W3DHUB_DEBUG ? Logger::Severity::DEBUG : Logger::Severity::WARN
|
||||
|
||||
LOG_TAG = "W3DHubLinuxLauncher"
|
||||
@@ -80,15 +88,6 @@ require "i18n"
|
||||
require "websocket-client-simple"
|
||||
require "English"
|
||||
require "sdl2"
|
||||
require "libui"
|
||||
|
||||
# Using a WHOLE ui library for: native file/folder open dialogs...
|
||||
LibUI.init
|
||||
LIBUI_WINDOW = LibUI.new_window("", 100, 100, 0)
|
||||
at_exit do
|
||||
LibUI.control_destroy(LIBUI_WINDOW)
|
||||
LibUI.uninit
|
||||
end
|
||||
|
||||
I18n.load_path << Dir["#{W3DHub::GAME_ROOT_PATH}/locales/*.yml"]
|
||||
I18n.default_locale = :en
|
||||
@@ -129,6 +128,7 @@ require_relative "lib/states/dialogs/confirm_dialog"
|
||||
require_relative "lib/states/dialogs/direct_connect_dialog"
|
||||
require_relative "lib/states/dialogs/game_settings_dialog"
|
||||
require_relative "lib/states/dialogs/import_game_dialog"
|
||||
require_relative "lib/states/dialogs/launcher_updater_dialog"
|
||||
|
||||
require_relative "lib/api"
|
||||
require_relative "lib/api/service_status"
|
||||
@@ -158,7 +158,18 @@ require_relative "lib/asterisk/states/game_form"
|
||||
require_relative "lib/asterisk/states/irc_profile_form"
|
||||
require_relative "lib/asterisk/states/server_profile_form"
|
||||
|
||||
require "win32/process" if W3DHub.windows?
|
||||
if W3DHub.windows?
|
||||
require "libui"
|
||||
require "win32/process"
|
||||
|
||||
# Using a WHOLE ui library for: native file/folder open dialogs...
|
||||
LibUI.init
|
||||
LIBUI_WINDOW = LibUI.new_window("", 100, 100, 0)
|
||||
at_exit do
|
||||
LibUI.control_destroy(LIBUI_WINDOW)
|
||||
LibUI.uninit
|
||||
end
|
||||
end
|
||||
|
||||
logger.info(W3DHub::LOG_TAG) { "W3D Hub Linux Launcher v#{W3DHub::VERSION}" }
|
||||
|
||||
|
||||