From 719851cd92d7215a4767d385bdba5db0708535ee Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 08:45:10 +0100
Subject: [PATCH 01/10] Hopefully fix db connections (locked)

---
 zwift_offline.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/zwift_offline.py b/zwift_offline.py
index ecd8bb9..732d646 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -1242,6 +1242,8 @@ def relay_worlds_leave(world_id):
 
 @app.teardown_request
 def teardown_request(exception):
+    db.close_all_sessions()
+    db.session.close()
     if exception != None:
         print('Exception: %s' % exception)
 
@@ -1284,7 +1286,6 @@ def init_database():
 
 
 def check_columns():
-    time.sleep(3)
     rows = db.engine.execute(sqlalchemy.text("PRAGMA table_info(user)"))
     should_have_columns = User.metadata.tables['user'].columns
     current_columns = list()
@@ -1315,8 +1316,7 @@ def before_first_request():
     init_database()
     db.create_all(app=app)
     db.session.commit()
-    check_columns_thread = threading.Thread(target=check_columns)
-    check_columns_thread.start()
+    check_columns()
     send_message_thread = threading.Thread(target=send_server_back_online_message)
     send_message_thread.start()
 
@@ -1460,6 +1460,7 @@ def run_standalone(passedOnline, passedGhostsEnabled, passedSaveGhost, passedPla
     if not MULTIPLAYER:
         login_manager.anonymous_user = AnonUser
     login_manager.init_app(app)
+    db.close_all_sessions()
 
     @login_manager.user_loader
     def load_user(uid):

From 526d956a27db70dc73ed9d68e86ddc3549814bee Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 09:56:50 +0100
Subject: [PATCH 02/10] Added excluded files to proxy Fix for goal week period

---
 standalone.py    |  3 ++-
 zwift_offline.py | 11 +++--------
 2 files changed, 5 insertions(+), 9 deletions(-)

diff --git a/standalone.py b/standalone.py
index 33f6ee5..eec8aa9 100755
--- a/standalone.py
+++ b/standalone.py
@@ -188,7 +188,8 @@ class CDNHandler(SimpleHTTPRequestHandler):
                     return
         exceptions = ['Launcher_ver_cur.xml', 'LauncherMac_ver_cur.xml',
                       'Zwift_ver_cur.xml', 'ZwiftMac_ver_cur.xml',
-                      'ZwiftAndroid_ver_cur.xml', 'Zwift_StreamingFiles_ver_cur.xml']
+                      'ZwiftAndroid_ver_cur.xml', 'Zwift_StreamingFiles_ver_cur.xml',
+                      'site.css', 'MapSchedule_v2.xml', 'background.jpg']
         if os.path.exists(PROXYPASS_FILE) and self.path.startswith('/gameassets/') and not path_end in exceptions:
             # PROXYPASS_FILE existence indicates we know what we're doing and
             # we can try to obtain the official map schedule and update files.
diff --git a/zwift_offline.py b/zwift_offline.py
index 732d646..6c573aa 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -852,14 +852,9 @@ def api_profiles_followees(player_id):
 
 
 def get_week_range(dt):
-     d = datetime.datetime(dt.year,1,1)
-     if (d.weekday()<= 3):
-         d = d - timedelta(d.weekday())
-     else:
-         d = d + timedelta(7-d.weekday())
-     dlt = timedelta(days = (int(dt.strftime('%W'))-1)*7)
-     first = d + dlt
-     last = d + dlt + timedelta(days=6, hours=23, minutes=59, seconds=59)
+     d = datetime.datetime(dt.year,dt.month,dt.day - dt.weekday())
+     first = d
+     last = d + timedelta(days=6, hours=23, minutes=59, seconds=59)
      return first, last
 
 def get_month_range(dt):

From bbb38a6b5b7949a4a5155b67b460ffa8528f1d3e Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 10:26:06 +0100
Subject: [PATCH 03/10] Added logging of SQL warnings Added db.engine.dispose()

---
 zwift_offline.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/zwift_offline.py b/zwift_offline.py
index 6c573aa..f187842 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -42,6 +42,7 @@ import protobuf.hash_seeds_pb2 as hash_seeds_pb2
 logging.basicConfig(filename='zoffline.log', level=os.environ.get("LOGLEVEL", "INFO"))
 logger = logging.getLogger('zoffline')
 logger.setLevel(logging.WARN)
+logging.getLogger('sqlalchemy.engine').setLevel(logging.WARN)
 
 if os.name == 'nt' and platform.release() == '10' and platform.version() >= '10.0.14393':
     # Fix ANSI color in Windows 10 version 10.0.14393 (Windows Anniversary Update)
@@ -1239,6 +1240,7 @@ def relay_worlds_leave(world_id):
 def teardown_request(exception):
     db.close_all_sessions()
     db.session.close()
+    db.engine.dispose()
     if exception != None:
         print('Exception: %s' % exception)
 
@@ -1456,6 +1458,7 @@ def run_standalone(passedOnline, passedGhostsEnabled, passedSaveGhost, passedPla
         login_manager.anonymous_user = AnonUser
     login_manager.init_app(app)
     db.close_all_sessions()
+    db.engine.dispose()
 
     @login_manager.user_loader
     def load_user(uid):

From 75f4394563a51e33f0747ff902172f7f9803ef48 Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 11:27:15 +0100
Subject: [PATCH 04/10] Moved style files, removed exceptions in proxy

---
 cdn/static/web/launcher/embed.html       |   2 +-
 cdn/static/web/launcher/layout.html      |   2 +-
 cdn/{gameassets => style}/background.jpg | Bin
 cdn/{gameassets => style}/site.css       |   2 +-
 standalone.py                            |   3 +--
 zwift_offline.py                         |   8 +++++++-
 6 files changed, 11 insertions(+), 6 deletions(-)
 rename cdn/{gameassets => style}/background.jpg (100%)
 rename cdn/{gameassets => style}/site.css (91%)

diff --git a/cdn/static/web/launcher/embed.html b/cdn/static/web/launcher/embed.html
index 0a7f08d..e1916fb 100644
--- a/cdn/static/web/launcher/embed.html
+++ b/cdn/static/web/launcher/embed.html
@@ -2,7 +2,7 @@
 <head>
     <title>Loading Zwift</title>
     <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bootstrap@4.5.3/dist/css/bootstrap.min.css" integrity="sha384-TX8t27EcRE3e/ihU7zmQxVncDAy5uIKz4rEkgIXeMed4M0jlfIDPvg6uqKI2xXr2" crossorigin="anonymous">
-    <link rel="stylesheet" href="/gameassets/site.css"/>
+    <link rel="stylesheet" href="/style/site.css"/>
 </head>
 <body>
     <div class="container-fluid">
diff --git a/cdn/static/web/launcher/layout.html b/cdn/static/web/launcher/layout.html
index 5b4e3c5..c087606 100644
--- a/cdn/static/web/launcher/layout.html
+++ b/cdn/static/web/launcher/layout.html
@@ -3,7 +3,7 @@
 <head>
   <title>Zwift Launcher</title>
   <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bootstrap@4.5.3/dist/css/bootstrap.min.css" integrity="sha384-TX8t27EcRE3e/ihU7zmQxVncDAy5uIKz4rEkgIXeMed4M0jlfIDPvg6uqKI2xXr2" crossorigin="anonymous">
-  <link rel="stylesheet" href="/gameassets/site.css"/>
+  <link rel="stylesheet" href="/style/site.css"/>
   <!--[if lte IE 9]>
     <style>
       .text-shadow {
diff --git a/cdn/gameassets/background.jpg b/cdn/style/background.jpg
similarity index 100%
rename from cdn/gameassets/background.jpg
rename to cdn/style/background.jpg
diff --git a/cdn/gameassets/site.css b/cdn/style/site.css
similarity index 91%
rename from cdn/gameassets/site.css
rename to cdn/style/site.css
index 7e066de..8beced2 100644
--- a/cdn/gameassets/site.css
+++ b/cdn/style/site.css
@@ -1,5 +1,5 @@
 body {
-    background-image: url('https://cdn.zwift.com/gameassets/background.jpg');
+    background-image: url('https://cdn.zwift.com/style/background.jpg');
     background-repeat: no-repeat;
     background-size: cover;
     overflow: hidden;
diff --git a/standalone.py b/standalone.py
index eec8aa9..33f6ee5 100755
--- a/standalone.py
+++ b/standalone.py
@@ -188,8 +188,7 @@ class CDNHandler(SimpleHTTPRequestHandler):
                     return
         exceptions = ['Launcher_ver_cur.xml', 'LauncherMac_ver_cur.xml',
                       'Zwift_ver_cur.xml', 'ZwiftMac_ver_cur.xml',
-                      'ZwiftAndroid_ver_cur.xml', 'Zwift_StreamingFiles_ver_cur.xml',
-                      'site.css', 'MapSchedule_v2.xml', 'background.jpg']
+                      'ZwiftAndroid_ver_cur.xml', 'Zwift_StreamingFiles_ver_cur.xml']
         if os.path.exists(PROXYPASS_FILE) and self.path.startswith('/gameassets/') and not path_end in exceptions:
             # PROXYPASS_FILE existence indicates we know what we're doing and
             # we can try to obtain the official map schedule and update files.
diff --git a/zwift_offline.py b/zwift_offline.py
index f187842..0a9d948 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -20,7 +20,7 @@ from io import BytesIO
 from shutil import copyfile
 
 import jwt
-from flask import Flask, request, jsonify, g, redirect, render_template, url_for, flash, session, abort, make_response, send_file
+from flask import Flask, request, jsonify, g, redirect, render_template, url_for, flash, session, abort, make_response, send_file, send_from_directory
 from flask_login import UserMixin, AnonymousUserMixin, LoginManager, login_user, current_user, login_required
 from google.protobuf.descriptor import FieldDescriptor
 from protobuf_to_dict import protobuf_to_dict, TYPE_CALLABLE_MAP
@@ -555,6 +555,12 @@ def api_zfiles():
     return zfile.SerializeToString(), 200
 
 
+# Custom static data
+@app.route('/style/<path:filename>')
+def custom_style(filename):
+    return send_from_directory('%s/cdn/style' % SCRIPT_DIR, filename)
+
+
 # Probably don't need, haven't investigated
 @app.route('/api/zfiles/list', methods=['GET', 'POST'])
 def api_zfiles_list():

From 851294af9cb8c061f969875da07c2669c2bff39e Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 12:12:32 +0100
Subject: [PATCH 05/10] Removed static/web/launcher api

---
 zwift_offline.py | 5 -----
 1 file changed, 5 deletions(-)

diff --git a/zwift_offline.py b/zwift_offline.py
index 0a9d948..5e3c939 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -1442,11 +1442,6 @@ def auth_realms_zwift_tokens_access_codes():
         return FAKE_JWT, 200
 
 
-@app.route('/static/web/launcher/<filename>', methods=['GET'])
-def static_web_launcher(filename):
-    return render_template(filename)
-
-
 def run_standalone(passedOnline, passedGhostsEnabled, passedSaveGhost, passedPlayerUpdateQueue):
     global online
     global ghostsEnabled

From d7d69b808e0cb5357f0fb75fa1ca7fceb1365b64 Mon Sep 17 00:00:00 2001
From: oldnapalm <38410858+oldnapalm@users.noreply.github.com>
Date: Thu, 12 Nov 2020 14:42:09 -0300
Subject: [PATCH 06/10] Add preliminar pace partner, fix save ghost

---
 standalone.py | 46 ++++++++++++++++++++++++++++++++++++++++------
 1 file changed, 40 insertions(+), 6 deletions(-)

diff --git a/standalone.py b/standalone.py
index 33f6ee5..0b1e586 100755
--- a/standalone.py
+++ b/standalone.py
@@ -44,6 +44,7 @@ globalGhosts = {}
 ghostsEnabled = {}
 online = {}
 playerUpdateQueue = {}
+globalPacePartners = {}
 
 def roadID(state):
     return (state.f20 & 0xff00) >> 8
@@ -195,13 +196,10 @@ class CDNHandler(SimpleHTTPRequestHandler):
             # This can only work if we're running on a different machine than the Zwift client.
             sent = False
             try:
-
                 url = 'http://{}{}'.format(hostname, self.path)
                 req_header = self.parse_headers()
-
                 resp = requests.get(url, headers=merge_two_dicts(req_header, set_header()), verify=False)
                 sent = True
-
                 self.send_response(resp.status_code)
                 self.send_resp_headers(resp)
                 self.wfile.write(resp.content)
@@ -345,6 +343,37 @@ class GhostsVariables:
     start_road = 0
     start_rt = 0
 
+class PacePartnerVariables:
+    route = None
+    position = 0
+
+def loadPacePartners():
+    folder = '%s/pace_partners' % STORAGE_DIR
+    if not os.path.isdir(folder): return
+    for (root, dirs, files) in os.walk(folder):
+        for pp_id in dirs:
+            route = '%s/%s/route.bin' % (folder, pp_id)
+            if os.path.isfile(route):
+                with open(route, 'rb') as fd:
+                    globalPacePartners[pp_id] = PacePartnerVariables()
+                    pp = globalPacePartners[pp_id]
+                    pp.route = udp_node_msgs_pb2.Ghost()
+                    pp.route.ParseFromString(fd.read())
+                    pp.position = 0
+
+def playPacePartners():
+    while True:
+        keys = globalPacePartners.keys()
+        for pp_id in keys:
+            pp = globalPacePartners[pp_id]
+            state = pp.route.states[pp.position]
+            state.id = int(pp_id)
+            state.worldTime = zwift_offline.world_time()
+            online[pp_id] = state
+            if pp.position < len(pp.route.states): pp.position += 1
+            else: pp.position = 0
+        ppthreadevent.wait(timeout=3)
+
 class UDPHandler(socketserver.BaseRequestHandler):
     def handle(self):
         data = self.request[0]
@@ -383,13 +412,13 @@ class UDPHandler(socketserver.BaseRequestHandler):
         ghosts.lastPackageTime = t
 
         if player_id in ghostsEnabled and ghostsEnabled[player_id]:
-            if not ghosts.loaded and state.roadTime > 0:
+            if not ghosts.loaded and getCourse(state):
                 ghosts.loaded = True
                 loadGhosts(player_id, state, ghosts)
             if state.roadTime and ghosts.last_rt and state.roadTime != ghosts.last_rt:
                 if t >= ghosts.last_rec + update_freq:
-                    state = ghosts.rec.states.add()
-                    state.CopyFrom(state)
+                    s = ghosts.rec.states.add()
+                    s.CopyFrom(state)
                     ghosts.last_rec = t
                 if not ghosts.started and ghosts.play.ghosts and roadID(state) == ghosts.start_road:
                     if isForward(state):
@@ -513,4 +542,9 @@ udpserver_thread = threading.Thread(target=udpserver.serve_forever)
 udpserver_thread.daemon = True
 udpserver_thread.start()
 
+loadPacePartners()
+ppthreadevent = threading.Event()
+pp = threading.Thread(target=playPacePartners)
+pp.start()
+
 zwift_offline.run_standalone(online, ghostsEnabled, saveGhost, playerUpdateQueue)

From 702d89c3506b3b257c042116c6236e3f47161b34 Mon Sep 17 00:00:00 2001
From: oldnapalm <38410858+oldnapalm@users.noreply.github.com>
Date: Thu, 12 Nov 2020 14:47:21 -0300
Subject: [PATCH 07/10] Update zwift_offline.py

---
 zwift_offline.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/zwift_offline.py b/zwift_offline.py
index 5e3c939..0e29cc7 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -814,7 +814,7 @@ def api_profiles_activities_id(player_id, activity_id):
     player_id = current_user.player_id
     if current_user.enable_ghosts:
         try:
-            saveGhost(activity.name, int(player_id))
+            saveGhost(activity.name, player_id)
         except:
             pass
     # Unconditionally *try* and upload to strava and garmin since profile may

From 81c5299165cebef46a391174295eb4b3008adfc8 Mon Sep 17 00:00:00 2001
From: oldnapalm <38410858+oldnapalm@users.noreply.github.com>
Date: Thu, 12 Nov 2020 16:54:03 -0300
Subject: [PATCH 08/10] Fix pace partner loop

---
 standalone.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/standalone.py b/standalone.py
index 0b1e586..54565cd 100755
--- a/standalone.py
+++ b/standalone.py
@@ -370,7 +370,7 @@ def playPacePartners():
             state.id = int(pp_id)
             state.worldTime = zwift_offline.world_time()
             online[pp_id] = state
-            if pp.position < len(pp.route.states): pp.position += 1
+            if pp.position < len(pp.route.states) - 1: pp.position += 1
             else: pp.position = 0
         ppthreadevent.wait(timeout=3)
 

From 8f0ad564d949031fb743df5ebc54cd02e2911f6e Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 21:51:03 +0100
Subject: [PATCH 09/10] Pace partners showing up as pace partners in list

---
 protobuf/world.proto  |  1 +
 protobuf/world_pb2.py | 24 ++++++++++++++++--------
 standalone.py         | 20 +++++++++++++++-----
 zwift_offline.py      | 40 +++++++++++++++++++++++++++++++++++-----
 4 files changed, 67 insertions(+), 18 deletions(-)

diff --git a/protobuf/world.proto b/protobuf/world.proto
index 9530b90..a51f5e0 100644
--- a/protobuf/world.proto
+++ b/protobuf/world.proto
@@ -8,6 +8,7 @@ message World {
 	required uint64 world_time = 6;
 	required uint64 real_time = 7;
 	repeated Player player_states = 8;
+	repeated Player pace_partner_states = 12;
 }
 
 message Worlds {
diff --git a/protobuf/world_pb2.py b/protobuf/world_pb2.py
index 152c255..668183b 100644
--- a/protobuf/world_pb2.py
+++ b/protobuf/world_pb2.py
@@ -19,7 +19,7 @@ DESCRIPTOR = _descriptor.FileDescriptor(
   syntax='proto2',
   serialized_options=None,
   create_key=_descriptor._internal_create_key,
-  serialized_pb=b'\n\x14protobuf/world.proto\"\x80\x01\n\x05World\x12\n\n\x02id\x18\x01 \x02(\r\x12\x0c\n\x04name\x18\x02 \x02(\t\x12\n\n\x02\x66\x33\x18\x03 \x02(\r\x12\n\n\x02\x66\x35\x18\x05 \x02(\x04\x12\x12\n\nworld_time\x18\x06 \x02(\x04\x12\x11\n\treal_time\x18\x07 \x02(\x04\x12\x1e\n\rplayer_states\x18\x08 \x03(\x0b\x32\x07.Player\" \n\x06Worlds\x12\x16\n\x06worlds\x18\x01 \x03(\x0b\x32\x06.World\"%\n\x0fWorldAttributes\x12\x12\n\nworld_time\x18\x02 \x02(\x03\"\xdb\x01\n\x06Player\x12\n\n\x02id\x18\x01 \x02(\r\x12\x11\n\tfirstName\x18\x02 \x02(\t\x12\x10\n\x08lastName\x18\x03 \x02(\t\x12\x10\n\x08\x64istance\x18\x04 \x01(\r\x12\x0c\n\x04time\x18\x05 \x01(\r\x12\n\n\x02\x66\x36\x18\x06 \x01(\r\x12\n\n\x02\x66\x38\x18\x08 \x01(\r\x12\n\n\x02\x66\x39\x18\t \x01(\r\x12\x0b\n\x03\x66\x31\x30\x18\n \x01(\r\x12\x0b\n\x03\x66\x31\x31\x18\x0b \x01(\r\x12\r\n\x05power\x18\x0c \x01(\r\x12\x0b\n\x03\x66\x31\x33\x18\r \x01(\r\x12\t\n\x01x\x18\x0e \x01(\x02\x12\x10\n\x08\x61ltitude\x18\x0f \x01(\x02\x12\t\n\x01y\x18\x10 \x01(\x02'
+  serialized_pb=b'\n\x14protobuf/world.proto\"\xa6\x01\n\x05World\x12\n\n\x02id\x18\x01 \x02(\r\x12\x0c\n\x04name\x18\x02 \x02(\t\x12\n\n\x02\x66\x33\x18\x03 \x02(\r\x12\n\n\x02\x66\x35\x18\x05 \x02(\x04\x12\x12\n\nworld_time\x18\x06 \x02(\x04\x12\x11\n\treal_time\x18\x07 \x02(\x04\x12\x1e\n\rplayer_states\x18\x08 \x03(\x0b\x32\x07.Player\x12$\n\x13pace_partner_states\x18\x0c \x03(\x0b\x32\x07.Player\" \n\x06Worlds\x12\x16\n\x06worlds\x18\x01 \x03(\x0b\x32\x06.World\"%\n\x0fWorldAttributes\x12\x12\n\nworld_time\x18\x02 \x02(\x03\"\xdb\x01\n\x06Player\x12\n\n\x02id\x18\x01 \x02(\r\x12\x11\n\tfirstName\x18\x02 \x02(\t\x12\x10\n\x08lastName\x18\x03 \x02(\t\x12\x10\n\x08\x64istance\x18\x04 \x01(\r\x12\x0c\n\x04time\x18\x05 \x01(\r\x12\n\n\x02\x66\x36\x18\x06 \x01(\r\x12\n\n\x02\x66\x38\x18\x08 \x01(\r\x12\n\n\x02\x66\x39\x18\t \x01(\r\x12\x0b\n\x03\x66\x31\x30\x18\n \x01(\r\x12\x0b\n\x03\x66\x31\x31\x18\x0b \x01(\r\x12\r\n\x05power\x18\x0c \x01(\r\x12\x0b\n\x03\x66\x31\x33\x18\r \x01(\r\x12\t\n\x01x\x18\x0e \x01(\x02\x12\x10\n\x08\x61ltitude\x18\x0f \x01(\x02\x12\t\n\x01y\x18\x10 \x01(\x02'
 )
 
 
@@ -82,6 +82,13 @@ _WORLD = _descriptor.Descriptor(
       message_type=None, enum_type=None, containing_type=None,
       is_extension=False, extension_scope=None,
       serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
+    _descriptor.FieldDescriptor(
+      name='pace_partner_states', full_name='World.pace_partner_states', index=7,
+      number=12, type=11, cpp_type=10, label=3,
+      has_default_value=False, default_value=[],
+      message_type=None, enum_type=None, containing_type=None,
+      is_extension=False, extension_scope=None,
+      serialized_options=None, file=DESCRIPTOR,  create_key=_descriptor._internal_create_key),
   ],
   extensions=[
   ],
@@ -95,7 +102,7 @@ _WORLD = _descriptor.Descriptor(
   oneofs=[
   ],
   serialized_start=25,
-  serialized_end=153,
+  serialized_end=191,
 )
 
 
@@ -126,8 +133,8 @@ _WORLDS = _descriptor.Descriptor(
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=155,
-  serialized_end=187,
+  serialized_start=193,
+  serialized_end=225,
 )
 
 
@@ -158,8 +165,8 @@ _WORLDATTRIBUTES = _descriptor.Descriptor(
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=189,
-  serialized_end=226,
+  serialized_start=227,
+  serialized_end=264,
 )
 
 
@@ -288,11 +295,12 @@ _PLAYER = _descriptor.Descriptor(
   extension_ranges=[],
   oneofs=[
   ],
-  serialized_start=229,
-  serialized_end=448,
+  serialized_start=267,
+  serialized_end=486,
 )
 
 _WORLD.fields_by_name['player_states'].message_type = _PLAYER
+_WORLD.fields_by_name['pace_partner_states'].message_type = _PLAYER
 _WORLDS.fields_by_name['worlds'].message_type = _WORLD
 DESCRIPTOR.message_types_by_name['World'] = _WORLD
 DESCRIPTOR.message_types_by_name['Worlds'] = _WORLDS
diff --git a/standalone.py b/standalone.py
index 0b1e586..1233e40 100755
--- a/standalone.py
+++ b/standalone.py
@@ -366,10 +366,6 @@ def playPacePartners():
         keys = globalPacePartners.keys()
         for pp_id in keys:
             pp = globalPacePartners[pp_id]
-            state = pp.route.states[pp.position]
-            state.id = int(pp_id)
-            state.worldTime = zwift_offline.world_time()
-            online[pp_id] = state
             if pp.position < len(pp.route.states): pp.position += 1
             else: pp.position = 0
         ppthreadevent.wait(timeout=3)
@@ -502,12 +498,26 @@ class UDPHandler(socketserver.BaseRequestHandler):
                     #Check if players are close in world
                     if zwift_offline.isNearby(state, player):
                         nearby.append(p_id)
+            for p_id in globalPacePartners.keys():
+                pace_partner_variables = globalPacePartners[p_id]
+                pace_partner = pace_partner_variables.route.states[pace_partner_variables.position]
+                #Check if pacepartner is close to player in world
+                if zwift_offline.isNearby(state, pace_partner):
+                    nearby.append(p_id)
             players = len(nearby)
             message.num_msgs = players // 10
             if players % 10: message.num_msgs += 1
             for p_id in nearby:
+                player = None
                 if p_id in online.keys():
                     player = online[p_id]
+                elif p_id in globalPacePartners.keys():
+                    pace_partner_variables = globalPacePartners[p_id]
+                    player = pace_partner_variables.route.states[pace_partner_variables.position]
+                    player.id = int(p_id)
+                    player.watchingRiderId = player.id
+                    player.worldTime = zwift_offline.world_time()
+                if player != None:
                     if len(message.states) < 10:
                         state = message.states.add()
                         state.CopyFrom(player)
@@ -547,4 +557,4 @@ ppthreadevent = threading.Event()
 pp = threading.Thread(target=playPacePartners)
 pp.start()
 
-zwift_offline.run_standalone(online, ghostsEnabled, saveGhost, playerUpdateQueue)
+zwift_offline.run_standalone(online, globalPacePartners, ghostsEnabled, saveGhost, playerUpdateQueue)
diff --git a/zwift_offline.py b/zwift_offline.py
index 0e29cc7..94a9792 100644
--- a/zwift_offline.py
+++ b/zwift_offline.py
@@ -93,6 +93,7 @@ app.config['MAX_CONTENT_LENGTH'] = 1024 * 1024
 
 db = SQLAlchemy(app)
 online = {}
+globalPacePartners = {}
 ghostsEnabled = {}
 playerUpdateQueue = {}
 playerIds = {}
@@ -1077,6 +1078,31 @@ def relay_worlds_generic(world_id=None):
                         onlinePlayer.altitude = player.altitude
                         onlinePlayer.y = player.y
                         playersInRegion += 1
+            for p_id in globalPacePartners.keys():
+                pace_partner_variables = globalPacePartners[p_id]
+                pace_partner_id = int(p_id)
+                pace_partner = pace_partner_variables.route.states[pace_partner_variables.position]
+                courseId = getCourse(pace_partner)
+                if course == courseId:
+                    partialProfile = getPartialProfile(pace_partner_id)
+                    if not partialProfile == None:
+                        online_pace_partner = world.pace_partner_states.add()
+                        online_pace_partner.id = pace_partner_id
+                        online_pace_partner.firstName = partialProfile.first_name
+                        online_pace_partner.lastName = partialProfile.last_name
+                        online_pace_partner.distance = pace_partner.distance
+                        online_pace_partner.time = pace_partner.time
+                        online_pace_partner.f6 = 840#0
+                        online_pace_partner.f8 = 0
+                        online_pace_partner.f9 = 0
+                        online_pace_partner.f10 = 0
+                        online_pace_partner.f11 = 0
+                        online_pace_partner.power = pace_partner.power
+                        online_pace_partner.f13 = 2355
+                        online_pace_partner.x = pace_partner.x
+                        online_pace_partner.altitude = pace_partner.altitude
+                        online_pace_partner.y = pace_partner.y
+                        playersInRegion += 1
             world.f5 = playersInRegion
         if world_id:
             world.id = world_id
@@ -1103,10 +1129,12 @@ def relay_worlds_id_join(world_id):
 
 @app.route('/relay/worlds/<int:world_id>/players/<int:player_id>', methods=['GET'])
 def relay_worlds_id_players_id(world_id, player_id):
-    for p_id in online.keys():
-        player = online[p_id]
-        if player.id == player_id:
-            return player.SerializeToString()
+    if player_id in online.keys():
+        player = online[player_id]
+        return player.SerializeToString()
+    if str(player_id) in globalPacePartners.keys():
+        pace_partner = globalPacePartners[str(player_id)]
+        return pace_partner.route.states[pace_partner.position].SerializeToString()
     return None
 
 
@@ -1442,13 +1470,15 @@ def auth_realms_zwift_tokens_access_codes():
         return FAKE_JWT, 200
 
 
-def run_standalone(passedOnline, passedGhostsEnabled, passedSaveGhost, passedPlayerUpdateQueue):
+def run_standalone(passedOnline, passedGlobalPacePartners, passedGhostsEnabled, passedSaveGhost, passedPlayerUpdateQueue):
     global online
+    global globalPacePartners
     global ghostsEnabled
     global saveGhost
     global playerUpdateQueue
     global login_manager
     online = passedOnline
+    globalPacePartners = passedGlobalPacePartners
     ghostsEnabled = passedGhostsEnabled
     saveGhost = passedSaveGhost
     playerUpdateQueue = passedPlayerUpdateQueue

From 03466c45653d0e78234be176a78aab98748816fe Mon Sep 17 00:00:00 2001
From: perast <per.astrand@invid.se>
Date: Thu, 12 Nov 2020 22:02:57 +0100
Subject: [PATCH 10/10] Pace partner fix

---
 standalone.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/standalone.py b/standalone.py
index 1233e40..c39a059 100755
--- a/standalone.py
+++ b/standalone.py
@@ -366,7 +366,7 @@ def playPacePartners():
         keys = globalPacePartners.keys()
         for pp_id in keys:
             pp = globalPacePartners[pp_id]
-            if pp.position < len(pp.route.states): pp.position += 1
+            if pp.position < len(pp.route.states) - 1: pp.position += 1
             else: pp.position = 0
         ppthreadevent.wait(timeout=3)