Select stream.id in upload-status operations so the cache stays normalized

UploadStreamWithDetails and the editUploadStream response selected
stream fields without id. Apollo cannot normalize an object with no id
selected, so every upload-service poll rewrote VideoGQL.stream as an
anonymous inline object — clobbering the id that feed/detail queries
select. Their cache reads went partial and useQuery silently fell back
to the last network result, rendered as the home feed collapsing to
the first page (and bouncing the viewport) whenever an upload was
polling.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

rbproto/python/shot_pb2.py

@@ -13,7 +13,7 @@ _sym_db = _symbol_database.Default()
 
 
 DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(
-    b'\n\nshot.proto\x12\x0fserialized_shot"?\n\x03\x42ox\x12\x0c\n\x04left\x18\x01 \x01(\x02\x12\x0b\n\x03top\x18\x02 \x01(\x02\x12\r\n\x05width\x18\x03 \x01(\x02\x12\x0e\n\x06height\x18\x04 \x01(\x02"\x1d\n\x05Point\x12\t\n\x01x\x18\x01 \x01(\x02\x12\t\n\x01y\x18\x02 \x01(\x02"\x7f\n\rBallDetection\x12.\n\x0eplane_position\x18\x01 \x01(\x0b\x32\x16.serialized_shot.Point\x12(\n\nannotation\x18\x02 \x01(\x0b\x32\x14.serialized_shot.Box\x12\x14\n\x0cinterpolated\x18\x03 \x01(\x08"T\n\x10RLEBallDetection\x12\x31\n\tdetection\x18\x01 \x01(\x0b\x32\x1e.serialized_shot.BallDetection\x12\r\n\x05\x63ount\x18\x02 \x01(\r"L\n\x13RLEDetectionHistory\x12\x35\n\ndetections\x18\x01 \x03(\x0b\x32!.serialized_shot.RLEBallDetection"F\n\x10\x44\x65tectionHistory\x12\x32\n\ndetections\x18\x01 \x03(\x0b\x32\x1e.serialized_shot.BallDetection"\xfc\x01\n\rCollisionInfo\x12\x0e\n\x06source\x18\x01 \x01(\r\x12M\n\x10\x62\x61ll_identifiers\x18\x02 \x03(\x0b\x32\x33.serialized_shot.CollisionInfo.BallIdentifiersEntry\x12\x17\n\x0fwall_identifier\x18\x03 \x01(\r\x12\x13\n\x0b\x66rame_index\x18\x04 \x01(\r\x12\x0e\n\x06static\x18\x05 \x01(\x08\x1aN\n\x14\x42\x61llIdentifiersEntry\x12\x0b\n\x03key\x18\x01 \x01(\r\x12%\n\x05value\x18\x02 \x01(\x0b\x32\x16.serialized_shot.Point:\x02\x38\x01"\xcc\x02\n\x04Path\x12\x13\n\x0bstart_frame\x18\x01 \x01(\r\x12\x11\n\tend_frame\x18\x02 \x01(\r\x12\x37\n\ndetections\x18\x03 \x01(\x0b\x32!.serialized_shot.DetectionHistoryH\x00\x12>\n\x0erle_detections\x18\x04 \x01(\x0b\x32$.serialized_shot.RLEDetectionHistoryH\x00\x12\x15\n\x0bnot_present\x18\x05 \x01(\x08H\x00\x12\x11\n\tis_static\x18\x06 \x01(\x08\x12\x32\n\nstart_info\x18\x07 \x01(\x0b\x32\x1e.serialized_shot.CollisionInfo\x12\x30\n\x08\x65nd_info\x18\x08 \x01(\x0b\x32\x1e.serialized_shot.CollisionInfoB\x13\n\x11\x64\x65tection_history"R\n\x11IdentifierHistory\x12\x17\n\x0f\x62\x61ll_identifier\x18\x01 \x01(\r\x12$\n\x05paths\x18\x02 \x03(\x0b\x32\x15.serialized_shot.Path"\xf4\x01\n\x12KeyBallIdentifiers\x12\x10\n\x08\x63ue_ball\x18\x01 \x01(\r\x12\x13\n\x0bobject_ball\x18\x02 \x01(\r\x12\x13\n\x0btarget_ball\x18\x03 \x01(\r\x12\x18\n\x10\x63ontact_sequence\x18\x04 \x03(\r\x12\x18\n\x0b\x63ue_ball_id\x18\x05 \x01(\rH\x00\x88\x01\x01\x12\x1b\n\x0eobject_ball_id\x18\x06 \x01(\rH\x01\x88\x01\x01\x12\x1b\n\x0etarget_ball_id\x18\x07 \x01(\rH\x02\x88\x01\x01\x42\x0e\n\x0c_cue_ball_idB\x11\n\x0f_object_ball_idB\x11\n\x0f_target_ball_id"\xa8\x01\n\x04Shot\x12@\n\x14identifier_histories\x18\x03 \x03(\x0b\x32".serialized_shot.IdentifierHistory\x12\x36\n\tkey_balls\x18\x04 \x01(\x0b\x32#.serialized_shot.KeyBallIdentifiers\x12\x13\n\x0bstart_index\x18\x05 \x01(\r\x12\x11\n\tend_index\x18\x06 \x01(\rb\x06proto3'
+    b'\n\nshot.proto\x12\x0fserialized_shot"?\n\x03\x42ox\x12\x0c\n\x04left\x18\x01 \x01(\x02\x12\x0b\n\x03top\x18\x02 \x01(\x02\x12\r\n\x05width\x18\x03 \x01(\x02\x12\x0e\n\x06height\x18\x04 \x01(\x02"\x1d\n\x05Point\x12\t\n\x01x\x18\x01 \x01(\x02\x12\t\n\x01y\x18\x02 \x01(\x02"\x7f\n\rBallDetection\x12.\n\x0eplane_position\x18\x01 \x01(\x0b\x32\x16.serialized_shot.Point\x12(\n\nannotation\x18\x02 \x01(\x0b\x32\x14.serialized_shot.Box\x12\x14\n\x0cinterpolated\x18\x03 \x01(\x08"T\n\x10RLEBallDetection\x12\x31\n\tdetection\x18\x01 \x01(\x0b\x32\x1e.serialized_shot.BallDetection\x12\r\n\x05\x63ount\x18\x02 \x01(\r"L\n\x13RLEDetectionHistory\x12\x35\n\ndetections\x18\x01 \x03(\x0b\x32!.serialized_shot.RLEBallDetection"F\n\x10\x44\x65tectionHistory\x12\x32\n\ndetections\x18\x01 \x03(\x0b\x32\x1e.serialized_shot.BallDetection"\xfc\x01\n\rCollisionInfo\x12\x0e\n\x06source\x18\x01 \x01(\r\x12M\n\x10\x62\x61ll_identifiers\x18\x02 \x03(\x0b\x32\x33.serialized_shot.CollisionInfo.BallIdentifiersEntry\x12\x17\n\x0fwall_identifier\x18\x03 \x01(\r\x12\x13\n\x0b\x66rame_index\x18\x04 \x01(\r\x12\x0e\n\x06static\x18\x05 \x01(\x08\x1aN\n\x14\x42\x61llIdentifiersEntry\x12\x0b\n\x03key\x18\x01 \x01(\r\x12%\n\x05value\x18\x02 \x01(\x0b\x32\x16.serialized_shot.Point:\x02\x38\x01"\xcc\x02\n\x04Path\x12\x13\n\x0bstart_frame\x18\x01 \x01(\r\x12\x11\n\tend_frame\x18\x02 \x01(\r\x12\x37\n\ndetections\x18\x03 \x01(\x0b\x32!.serialized_shot.DetectionHistoryH\x00\x12>\n\x0erle_detections\x18\x04 \x01(\x0b\x32$.serialized_shot.RLEDetectionHistoryH\x00\x12\x15\n\x0bnot_present\x18\x05 \x01(\x08H\x00\x12\x11\n\tis_static\x18\x06 \x01(\x08\x12\x32\n\nstart_info\x18\x07 \x01(\x0b\x32\x1e.serialized_shot.CollisionInfo\x12\x30\n\x08\x65nd_info\x18\x08 \x01(\x0b\x32\x1e.serialized_shot.CollisionInfoB\x13\n\x11\x64\x65tection_history"I\n\x0c\x43olorCluster\x12\x11\n\tlightness\x18\x01 \x01(\x02\x12\t\n\x01\x61\x18\x02 \x01(\x02\x12\t\n\x01\x62\x18\x03 \x01(\x02\x12\x10\n\x08\x66raction\x18\x04 \x01(\x02"B\n\x0fTrajectoryColor\x12/\n\x08\x63lusters\x18\x01 \x03(\x0b\x32\x1d.serialized_shot.ColorCluster"\x8e\x01\n\x11IdentifierHistory\x12\x17\n\x0f\x62\x61ll_identifier\x18\x01 \x01(\r\x12$\n\x05paths\x18\x02 \x03(\x0b\x32\x15.serialized_shot.Path\x12:\n\x10trajectory_color\x18\x03 \x01(\x0b\x32 .serialized_shot.TrajectoryColor"\xf4\x01\n\x12KeyBallIdentifiers\x12\x10\n\x08\x63ue_ball\x18\x01 \x01(\r\x12\x13\n\x0bobject_ball\x18\x02 \x01(\r\x12\x13\n\x0btarget_ball\x18\x03 \x01(\r\x12\x18\n\x10\x63ontact_sequence\x18\x04 \x03(\r\x12\x18\n\x0b\x63ue_ball_id\x18\x05 \x01(\rH\x00\x88\x01\x01\x12\x1b\n\x0eobject_ball_id\x18\x06 \x01(\rH\x01\x88\x01\x01\x12\x1b\n\x0etarget_ball_id\x18\x07 \x01(\rH\x02\x88\x01\x01\x42\x0e\n\x0c_cue_ball_idB\x11\n\x0f_object_ball_idB\x11\n\x0f_target_ball_id"\xa8\x01\n\x04Shot\x12@\n\x14identifier_histories\x18\x03 \x03(\x0b\x32".serialized_shot.IdentifierHistory\x12\x36\n\tkey_balls\x18\x04 \x01(\x0b\x32#.serialized_shot.KeyBallIdentifiers\x12\x13\n\x0bstart_index\x18\x05 \x01(\r\x12\x11\n\tend_index\x18\x06 \x01(\rb\x06proto3'
 )
 
 _globals = globals()
@@ -41,10 +41,14 @@ if _descriptor._USE_C_DESCRIPTORS == False:
     _globals["_COLLISIONINFO_BALLIDENTIFIERSENTRY"]._serialized_end = 745
     _globals["_PATH"]._serialized_start = 748
     _globals["_PATH"]._serialized_end = 1080
-    _globals["_IDENTIFIERHISTORY"]._serialized_start = 1082
+    _globals["_COLORCLUSTER"]._serialized_start = 1082
-    _globals["_IDENTIFIERHISTORY"]._serialized_end = 1164
+    _globals["_COLORCLUSTER"]._serialized_end = 1155
-    _globals["_KEYBALLIDENTIFIERS"]._serialized_start = 1167
+    _globals["_TRAJECTORYCOLOR"]._serialized_start = 1157
-    _globals["_KEYBALLIDENTIFIERS"]._serialized_end = 1411
+    _globals["_TRAJECTORYCOLOR"]._serialized_end = 1223
-    _globals["_SHOT"]._serialized_start = 1414
+    _globals["_IDENTIFIERHISTORY"]._serialized_start = 1226
-    _globals["_SHOT"]._serialized_end = 1582
+    _globals["_IDENTIFIERHISTORY"]._serialized_end = 1368
+    _globals["_KEYBALLIDENTIFIERS"]._serialized_start = 1371
+    _globals["_KEYBALLIDENTIFIERS"]._serialized_end = 1615
+    _globals["_SHOT"]._serialized_start = 1618
+    _globals["_SHOT"]._serialized_end = 1786
 # @@protoc_insertion_point(module_scope)

rbproto/python/shot_pb2.pyi

@@ -160,16 +160,45 @@ class Path(_message.Message):
         end_info: _Optional[_Union[CollisionInfo, _Mapping]] = ...,
     ) -> None: ...
 
+class ColorCluster(_message.Message):
+    __slots__ = ["lightness", "a", "b", "fraction"]
+    LIGHTNESS_FIELD_NUMBER: _ClassVar[int]
+    A_FIELD_NUMBER: _ClassVar[int]
+    B_FIELD_NUMBER: _ClassVar[int]
+    FRACTION_FIELD_NUMBER: _ClassVar[int]
+    lightness: float
+    a: float
+    b: float
+    fraction: float
+    def __init__(
+        self,
+        lightness: _Optional[float] = ...,
+        a: _Optional[float] = ...,
+        b: _Optional[float] = ...,
+        fraction: _Optional[float] = ...,
+    ) -> None: ...
+
+class TrajectoryColor(_message.Message):
+    __slots__ = ["clusters"]
+    CLUSTERS_FIELD_NUMBER: _ClassVar[int]
+    clusters: _containers.RepeatedCompositeFieldContainer[ColorCluster]
+    def __init__(
+        self, clusters: _Optional[_Iterable[_Union[ColorCluster, _Mapping]]] = ...
+    ) -> None: ...
+
 class IdentifierHistory(_message.Message):
-    __slots__ = ["ball_identifier", "paths"]
+    __slots__ = ["ball_identifier", "paths", "trajectory_color"]
     BALL_IDENTIFIER_FIELD_NUMBER: _ClassVar[int]
     PATHS_FIELD_NUMBER: _ClassVar[int]
+    TRAJECTORY_COLOR_FIELD_NUMBER: _ClassVar[int]
     ball_identifier: int
     paths: _containers.RepeatedCompositeFieldContainer[Path]
+    trajectory_color: TrajectoryColor
     def __init__(
         self,
         ball_identifier: _Optional[int] = ...,
         paths: _Optional[_Iterable[_Union[Path, _Mapping]]] = ...,
+        trajectory_color: _Optional[_Union[TrajectoryColor, _Mapping]] = ...,
     ) -> None: ...
 
 class KeyBallIdentifiers(_message.Message):

rbproto/shot.proto

@@ -50,9 +50,21 @@ message Path {
   CollisionInfo end_info = 8;
 }
 
+message ColorCluster {
+  // LAB in OpenCV's 0-255 uint8 scale (see railbird LABCV2Color).
+  float lightness = 1;
+  float a = 2;
+  float b = 3;
+  // Share of this ball's accumulated color pixels in this cluster (0-1).
+  float fraction = 4;
+}
+
+message TrajectoryColor { repeated ColorCluster clusters = 1; }
+
 message IdentifierHistory {
   uint32 ball_identifier = 1;
   repeated Path paths = 2;
+  TrajectoryColor trajectory_color = 3;
 }
 message KeyBallIdentifiers {
   uint32 cue_ball = 1;

rbproto/ts/shot.ts

@@ -740,9 +740,158 @@ function _decodePath(bb: ByteBuffer): Path {
   return message;
 }
 
+export interface ColorCluster {
+  lightness?: number;
+  a?: number;
+  b?: number;
+  fraction?: number;
+}
+
+export function encodeColorCluster(message: ColorCluster): Uint8Array {
+  let bb = popByteBuffer();
+  _encodeColorCluster(message, bb);
+  return toUint8Array(bb);
+}
+
+function _encodeColorCluster(message: ColorCluster, bb: ByteBuffer): void {
+  // optional float lightness = 1;
+  let $lightness = message.lightness;
+  if ($lightness !== undefined) {
+    writeVarint32(bb, 13);
+    writeFloat(bb, $lightness);
+  }
+
+  // optional float a = 2;
+  let $a = message.a;
+  if ($a !== undefined) {
+    writeVarint32(bb, 21);
+    writeFloat(bb, $a);
+  }
+
+  // optional float b = 3;
+  let $b = message.b;
+  if ($b !== undefined) {
+    writeVarint32(bb, 29);
+    writeFloat(bb, $b);
+  }
+
+  // optional float fraction = 4;
+  let $fraction = message.fraction;
+  if ($fraction !== undefined) {
+    writeVarint32(bb, 37);
+    writeFloat(bb, $fraction);
+  }
+}
+
+export function decodeColorCluster(binary: Uint8Array): ColorCluster {
+  return _decodeColorCluster(wrapByteBuffer(binary));
+}
+
+function _decodeColorCluster(bb: ByteBuffer): ColorCluster {
+  let message: ColorCluster = {} as any;
+
+  end_of_message: while (!isAtEnd(bb)) {
+    let tag = readVarint32(bb);
+
+    switch (tag >>> 3) {
+      case 0:
+        break end_of_message;
+
+      // optional float lightness = 1;
+      case 1: {
+        message.lightness = readFloat(bb);
+        break;
+      }
+
+      // optional float a = 2;
+      case 2: {
+        message.a = readFloat(bb);
+        break;
+      }
+
+      // optional float b = 3;
+      case 3: {
+        message.b = readFloat(bb);
+        break;
+      }
+
+      // optional float fraction = 4;
+      case 4: {
+        message.fraction = readFloat(bb);
+        break;
+      }
+
+      default:
+        skipUnknownField(bb, tag & 7);
+    }
+  }
+
+  return message;
+}
+
+export interface TrajectoryColor {
+  clusters?: ColorCluster[];
+}
+
+export function encodeTrajectoryColor(message: TrajectoryColor): Uint8Array {
+  let bb = popByteBuffer();
+  _encodeTrajectoryColor(message, bb);
+  return toUint8Array(bb);
+}
+
+function _encodeTrajectoryColor(
+  message: TrajectoryColor,
+  bb: ByteBuffer,
+): void {
+  // repeated ColorCluster clusters = 1;
+  let array$clusters = message.clusters;
+  if (array$clusters !== undefined) {
+    for (let value of array$clusters) {
+      writeVarint32(bb, 10);
+      let nested = popByteBuffer();
+      _encodeColorCluster(value, nested);
+      writeVarint32(bb, nested.limit);
+      writeByteBuffer(bb, nested);
+      pushByteBuffer(nested);
+    }
+  }
+}
+
+export function decodeTrajectoryColor(binary: Uint8Array): TrajectoryColor {
+  return _decodeTrajectoryColor(wrapByteBuffer(binary));
+}
+
+function _decodeTrajectoryColor(bb: ByteBuffer): TrajectoryColor {
+  let message: TrajectoryColor = {} as any;
+
+  end_of_message: while (!isAtEnd(bb)) {
+    let tag = readVarint32(bb);
+
+    switch (tag >>> 3) {
+      case 0:
+        break end_of_message;
+
+      // repeated ColorCluster clusters = 1;
+      case 1: {
+        let limit = pushTemporaryLength(bb);
+        let values = message.clusters || (message.clusters = []);
+        values.push(_decodeColorCluster(bb));
+        bb.limit = limit;
+        break;
+      }
+
+      default:
+        skipUnknownField(bb, tag & 7);
+    }
+  }
+
+  return message;
+}
+
 export interface IdentifierHistory {
   ball_identifier?: number;
   paths?: Path[];
+  trajectory_color?: TrajectoryColor;
 }
 
 export function encodeIdentifierHistory(
@@ -776,6 +925,17 @@ function _encodeIdentifierHistory(
       pushByteBuffer(nested);
     }
   }
+
+  // optional TrajectoryColor trajectory_color = 3;
+  let $trajectory_color = message.trajectory_color;
+  if ($trajectory_color !== undefined) {
+    writeVarint32(bb, 26);
+    let nested = popByteBuffer();
+    _encodeTrajectoryColor($trajectory_color, nested);
+    writeVarint32(bb, nested.limit);
+    writeByteBuffer(bb, nested);
+    pushByteBuffer(nested);
+  }
 }
 
 export function decodeIdentifierHistory(binary: Uint8Array): IdentifierHistory {
@@ -807,6 +967,14 @@ function _decodeIdentifierHistory(bb: ByteBuffer): IdentifierHistory {
         break;
       }
 
+      // optional TrajectoryColor trajectory_color = 3;
+      case 3: {
+        let limit = pushTemporaryLength(bb);
+        message.trajectory_color = _decodeTrajectoryColor(bb);
+        bb.limit = limit;
+        break;
+      }
+
       default:
         skipUnknownField(bb, tag & 7);
     }

src/operations/config.gql

@@ -7,6 +7,8 @@ query getDeployedConfig {
     minimumAllowedAppVersion
     subscriptionGatingEnabled
     quotaEnforcementEnabled
+    storageLimitEnforcementEnabled
+    capabilityEnforcementEnabled
     bannerMessages {
       color
       dismissible

src/operations/feed.gql

@@ -41,9 +41,11 @@ fragment VideoCardFields on VideoGQL {
   stream {
     id
     lastIntendedSegmentBound
+    uploadCompletionCursor
     streamSegmentType
     isCompleted
     lastSegmentUploadedAt
+    clientUploadStatus
   }
   tableSize
   pocketSize

src/operations/live_streams.gql

@@ -0,0 +1,34 @@
+# Lightweight listing of live (in-progress) streams for pickers like the
+# Shot Lab "follow a live stream" flow. Selects only what a picker card
+# needs; intentionally avoids the heavy VideoCardFields fragment.
+query GetLiveStreams($limit: Int! = 25) {
+  getFeedVideos(
+    limit: $limit
+    filters: { isStreamCompleted: false, requireCursorCompletion: false }
+    includePrivate: MINE
+    feedInput: { allUsers: true }
+  ) {
+    videos {
+      id
+      name
+      startTime
+      createdAt
+      screenshotUri
+      elapsedTime
+      owner {
+        id
+        username
+        profileImageUri
+      }
+      stream {
+        id
+        isCompleted
+        lastSegmentUploadedAt
+      }
+    }
+    pageInfo {
+      hasNextPage
+      endCursor
+    }
+  }
+}

src/operations/payments.gql

@@ -49,6 +49,20 @@ query GetAvailableSubscriptionOptions {
       proMonthlyProductId
       productIds
     }
+    tierOptions {
+      tierName
+      tierDisplayName
+      billingInterval
+      platform
+      isConfigured
+      isAvailable
+      stripeProductId
+      stripePriceId
+      appleProductId
+      currency
+      unitAmount
+      recurringIntervalCount
+    }
   }
 }
 
@@ -67,6 +81,37 @@ query GetSubscriptionStatus {
   }
 }
 
+query GetResolvedTier {
+  getResolvedTier {
+    tierName
+    tierDisplayName
+    hasActiveSubscription
+    entitlementSource
+    entitlementStatus
+    entitlementStartsAt
+    entitlementEndsAt
+    capabilities
+  }
+}
+
+query GetStorageStatus {
+  getStorageStatus {
+    userId
+    tierName
+    retainedStorageUsedBytes
+    retainedStorageLimitBytes
+    isUnlimited
+    policyConfigured
+    remainingStorageBytes
+    storageUsageRatio
+    isNearLimit
+    isOverLimit
+    usageCalculated
+    usageSource
+    lastCalculatedAt
+  }
+}
+
 query GetAppleAppAccountToken {
   getAppleAppAccountToken
 }

src/operations/pool_hall.gql

@@ -0,0 +1,187 @@
+fragment PoolHallFields on PoolHall {
+  id
+  name
+  address
+  city
+  state
+  latitude
+  longitude
+  timezone
+  status
+  createdAt
+  updatedAt
+}
+
+fragment PoolHallCameraFields on PoolHallCamera {
+  id
+  poolHallId
+  name
+  tableLabel
+  streamPath
+  status
+  tableSize
+  pocketSize
+  allowsPrivateVideos
+  claimTermsText
+  claimTermsVersion
+  inUse
+  lastPublishedAt
+  lastUnpublishedAt
+  createdAt
+  updatedAt
+}
+
+fragment PoolHallCameraWithHallFields on PoolHallCamera {
+  ...PoolHallCameraFields
+  poolHall {
+    ...PoolHallFields
+  }
+}
+
+fragment PoolHallCameraStreamCredentialsFields on PoolHallCameraStreamCredentials {
+  streamKey
+  rtmpPath
+  camera {
+    ...PoolHallCameraWithHallFields
+  }
+}
+
+fragment CameraClaimSessionFields on CameraClaimSession {
+  id
+  cameraId
+  userId
+  challengeCode
+  status
+  expiresAt
+  detectedAt
+  failedAt
+  failureReason
+  agreedTermsVersion
+  createdAt
+  updatedAt
+  camera {
+    ...PoolHallCameraWithHallFields
+  }
+}
+
+fragment CameraLeaseFields on CameraLease {
+  id
+  cameraId
+  claimSessionId
+  userId
+  videoId
+  status
+  startedAt
+  endedAt
+  expiresAt
+  endReason
+  createdAt
+  updatedAt
+  camera {
+    ...PoolHallCameraWithHallFields
+  }
+}
+
+query GetPoolHalls {
+  poolHalls {
+    ...PoolHallFields
+  }
+}
+
+query GetClaimablePoolHalls {
+  claimablePoolHalls {
+    ...PoolHallFields
+  }
+}
+
+query GetPoolHallCameras($poolHallId: ID!) {
+  poolHallCameras(poolHallId: $poolHallId) {
+    ...PoolHallCameraWithHallFields
+  }
+}
+
+query GetClaimableCameras($poolHallId: ID!) {
+  claimableCameras(poolHallId: $poolHallId) {
+    ...PoolHallCameraWithHallFields
+  }
+}
+
+query GetCameraClaimSession($id: ID!) {
+  cameraClaimSession(id: $id) {
+    ...CameraClaimSessionFields
+  }
+}
+
+query GetActiveCameraLease {
+  activeCameraLease {
+    ...CameraLeaseFields
+  }
+}
+
+mutation CreatePoolHall($input: CreatePoolHallInput!) {
+  createPoolHall(input: $input) {
+    ...PoolHallFields
+  }
+}
+
+mutation UpdatePoolHall($input: UpdatePoolHallInput!) {
+  updatePoolHall(input: $input) {
+    ...PoolHallFields
+  }
+}
+
+mutation CreatePoolHallCamera($input: CreatePoolHallCameraInput!) {
+  createPoolHallCamera(input: $input) {
+    ...PoolHallCameraStreamCredentialsFields
+  }
+}
+
+mutation UpdatePoolHallCamera($input: UpdatePoolHallCameraInput!) {
+  updatePoolHallCamera(input: $input) {
+    ...PoolHallCameraWithHallFields
+  }
+}
+
+mutation RotatePoolHallCameraStreamKey($cameraId: ID!) {
+  rotatePoolHallCameraStreamKey(cameraId: $cameraId) {
+    ...PoolHallCameraStreamCredentialsFields
+  }
+}
+
+mutation CreateCameraClaimSession(
+  $cameraId: ID!
+  $durationMinutes: Int
+  $videoName: String
+  $videoPrivate: Boolean
+  $agreedTermsVersion: Int
+  $tags: [VideoTagInput!]
+) {
+  createCameraClaimSession(
+    cameraId: $cameraId
+    durationMinutes: $durationMinutes
+    videoName: $videoName
+    videoPrivate: $videoPrivate
+    agreedTermsVersion: $agreedTermsVersion
+    tags: $tags
+  ) {
+    ...CameraClaimSessionFields
+  }
+}
+
+mutation CancelCameraClaimSession($claimSessionId: ID!) {
+  cancelCameraClaimSession(claimSessionId: $claimSessionId) {
+    ...CameraClaimSessionFields
+  }
+}
+
+mutation EndCameraLease($leaseId: ID!) {
+  endCameraLease(leaseId: $leaseId) {
+    ...CameraLeaseFields
+  }
+}
+
+mutation ExtendCameraLease($leaseId: ID!, $additionalMinutes: Int! = 60) {
+  extendCameraLease(leaseId: $leaseId, additionalMinutes: $additionalMinutes) {
+    ...CameraLeaseFields
+  }
+}

src/operations/recorded_shots.gql

@@ -0,0 +1,62 @@
+# Lightweight two-step picker data for loading a recorded shot into Shot Lab.
+query GetRecordedStreams($limit: Int! = 25) {
+  getFeedVideos(
+    limit: $limit
+    filters: { isStreamCompleted: true, excludeVideosWithNoShots: true }
+    includePrivate: MINE
+    feedInput: { allUsers: true }
+  ) {
+    videos {
+      id
+      name
+      createdAt
+      screenshotUri
+      framesPerSecond
+      totalShots
+      owner {
+        id
+        username
+        profileImageUri
+      }
+    }
+  }
+}
+
+query GetRecordedStreamShots($videoId: Int!, $limit: Int! = 200) {
+  getOrderedShots(
+    filterInput: { videoId: [$videoId] }
+    shotsOrdering: { orderings: [{ startFrame: { descending: false } }] }
+    limit: $limit
+  ) {
+    shots {
+      id
+      videoId
+      startFrame
+      endFrame
+      serializedShotPaths {
+        b64EncodedBuffer
+      }
+      cueObjectFeatures {
+        cueObjectDistance
+        cueObjectAngle
+        cueBallSpeed
+        shotDirection
+        spinType
+      }
+      pocketingIntentionFeatures {
+        make
+        targetPocketDistance
+        targetPocketAngle
+        targetPocketAngleDirection
+        marginOfErrorInDegrees
+        intendedPocketType
+        difficulty
+      }
+      pocketingIntentionInfo {
+        ballId
+        pocketId
+        pathMetadataIndex
+      }
+    }
+  }
+}

src/operations/session-coach.gql

@@ -0,0 +1,51 @@
+query GetSessionCoach($videoId: Int!) {
+  getSessionCoach(videoId: $videoId) {
+    videoId
+    processingId
+    analysisVersion
+    state
+    generatedAt
+    processingStatus
+    ineligibilityReason
+    summary
+    shotCount
+    madeCount
+    missedCount
+    unknownOutcomeCount
+    analyzedShotCount
+    makePercentage
+    primaryCandidate {
+      ...SessionCoachCandidateFields
+    }
+    candidates {
+      ...SessionCoachCandidateFields
+    }
+  }
+}
+
+fragment SessionCoachCandidateFields on SessionCoachCandidateGQL {
+  id
+  rank
+  family
+  kind
+  title
+  body
+  action
+  supportingShotIds
+  drillId
+  limitations
+  evidence {
+    bucketKey
+    bucketLabel
+    attemptCount
+    madeCount
+    missedCount
+    makePercentage
+    comparisonAttemptCount
+    comparisonMadeCount
+    comparisonMakePercentage
+    patternShotCount
+    score
+    rankReason
+  }
+}

src/operations/shot_simulation.gql

@@ -9,6 +9,36 @@ query GetTableState(
     useHomography: $useHomography
   ) {
     identifierToPosition
+    identifierToColor {
+      hex
+    }
+  }
+}
+
+query GetLiveTableState($videoId: Int!) {
+  getLiveTableState(videoId: $videoId) {
+    videoId
+    frameIndex
+    tableState {
+      identifierToPosition
+      identifierToColor {
+        hex
+      }
+    }
+  }
+}
+
+query GetShotTableState($shotId: Int!) {
+  getShotTableState(shotId: $shotId) {
+    shotId
+    videoId
+    frameIndex
+    tableState {
+      identifierToPosition
+      identifierToColor {
+        hex
+      }
+    }
   }
 }
 

src/operations/usage_stats.gql

@@ -0,0 +1,45 @@
+query getUsageStats($days: Int! = 30) {
+  getUsageStats(days: $days) {
+    funnel {
+      freemiumEpoch
+      eraSignups
+      eraPaying
+      activationCohort
+      activationActivated
+      payingUsers
+      newPaid7d
+      newPaid30d
+      retentionPrevActive
+      retentionReturned
+    }
+    cohorts {
+      weekStart
+      signups
+      activated7d
+      paid7d
+      activatedNotPaid7d
+    }
+    totalUsers
+    totalVideos
+    totalShots
+    totalRuns
+    windows {
+      label
+      newUsers
+      activeUsers
+      sessions
+      shots
+    }
+    daily {
+      day
+      newUsers
+      activeUsers
+      sessions
+      shots
+    }
+    processingLast24h {
+      status
+      count
+    }
+  }
+}

src/operations/video_upload.gql

@@ -37,10 +37,18 @@ mutation GetUploadLink($videoId: Int!, $segmentIndex: Int!) {
               }
             }
           }
+          ... on StorageLimitExceededErr {
+            reason
+            tierName
+            retainedStorageUsedBytes
+            retainedStorageLimitBytes
+            remainingStorageBytes
+          }
         }
       }
     }
     stream {
+      id
       uploadCompletionCursor
     }
   }
@@ -120,6 +128,7 @@ fragment UploadStreamWithDetails on VideoGQL {
   name
   startTime
   stream {
+    id
     isCompleted
     lastIntendedSegmentBound
     uploadCompletionCursor

src/schema.gql

@@ -52,6 +52,12 @@ type Query {
     filters: NotificationFilters = null
   ): NotificationConnection!
   unreadNotificationCount: Int!
+  poolHalls: [PoolHall!]!
+  claimablePoolHalls: [PoolHall!]!
+  poolHallCameras(poolHallId: ID!): [PoolHallCamera!]!
+  claimableCameras(poolHallId: ID!): [PoolHallCamera!]!
+  cameraClaimSession(id: ID!): CameraClaimSession
+  activeCameraLease: CameraLease
   getRuns(
     filterInput: RunFilterInput!
     runIds: [Int!] = null
@@ -59,6 +65,7 @@ type Query {
     limit: Int! = 500
     countRespectsLimit: Boolean! = false
   ): GetRunsResult!
+  getSessionCoach(videoId: Int!): SessionCoachGQL!
   videoPlayerClusters(videoId: Int!): [PlayerClusterGQL!]!
   getShotAnnotationTypes(errorTypes: Boolean = false): [ShotAnnotationTypeGQL!]!
   getTableState(
@@ -66,6 +73,8 @@ type Query {
     tableSize: Float = 100
     useHomography: HomographyInputGQL = null
   ): TableStateGQL!
+  getLiveTableState(videoId: Int!): LiveTableStateGQL!
+  getShotTableState(shotId: Int!): ShotTableStateGQL!
   simulateShot(simulationInput: SimulateShotInputGQL!): ShotProjectionGQL!
   computePotAim(
     simulationInput: SimulateShotInputGQL!
@@ -93,6 +102,7 @@ type Query {
     countRespectsLimit: Boolean! = false
   ): [ShotGQL!]!
   getShotsByIds(ids: [Int!]!): [ShotGQL!]!
+  getUsageStats(days: Int! = 30): UsageStatsGQL!
   getUser(userId: Int!): UserGQL
   doesUsernameExist(candidateUsername: String!): Boolean!
   getLoggedInUser: UserGQL
@@ -601,7 +611,7 @@ type VideoTagClass {
 }
 
 type HomographyInfoGQL {
-  id: Int!
+  id: Int
   frameIndex: Int!
   crop: BoundingBoxGQL!
   pockets: [BoundingBoxGQL!]!
@@ -721,6 +731,7 @@ type DeployedConfigGQL {
   subscriptionGatingEnabled: Boolean!
   quotaEnforcementEnabled: Boolean!
   storageLimitEnforcementEnabled: Boolean!
+  capabilityEnforcementEnabled: Boolean!
   bannerMessages: [BannerGQL!]!
   defaultAndroidRecordingFormat: StreamSegmentTypeEnum!
   bucketUrl: String!
@@ -881,6 +892,72 @@ input NotificationFilters {
   notificationTypes: [NotificationTypeEnum!] = null
 }
 
+type PoolHall {
+  id: ID!
+  name: String!
+  address: String
+  city: String
+  state: String
+  latitude: Float
+  longitude: Float
+  timezone: String
+  status: String!
+  createdAt: DateTime!
+  updatedAt: DateTime!
+}
+
+type PoolHallCamera {
+  id: ID!
+  poolHallId: ID!
+  name: String!
+  tableLabel: String
+  streamPath: String!
+  status: String!
+  tableSize: Float
+  pocketSize: Float
+  allowsPrivateVideos: Boolean!
+  claimTermsText: String
+  claimTermsVersion: Int
+  lastPublishedAt: DateTime
+  lastUnpublishedAt: DateTime
+  createdAt: DateTime!
+  updatedAt: DateTime!
+  inUse: Boolean!
+  poolHall: PoolHall!
+}
+
+type CameraClaimSession {
+  id: ID!
+  cameraId: ID!
+  userId: ID!
+  challengeCode: String!
+  status: String!
+  expiresAt: DateTime!
+  detectedAt: DateTime
+  failedAt: DateTime
+  failureReason: String
+  agreedTermsVersion: Int
+  createdAt: DateTime!
+  updatedAt: DateTime!
+  camera: PoolHallCamera!
+}
+
+type CameraLease {
+  id: ID!
+  cameraId: ID!
+  claimSessionId: ID
+  userId: ID!
+  videoId: ID
+  status: String!
+  startedAt: DateTime!
+  endedAt: DateTime
+  expiresAt: DateTime
+  endReason: String
+  createdAt: DateTime!
+  updatedAt: DateTime!
+  camera: PoolHallCamera!
+}
+
 type GetRunsResult {
   runs: [RunGQL!]!
   count: Int
@@ -919,6 +996,81 @@ input DatetimeOrdering {
   startingAt: DateTime = null
 }
 
+type SessionCoachGQL {
+  videoId: Int!
+  processingId: Int
+  analysisVersion: String!
+  state: SessionCoachStateEnum!
+  generatedAt: DateTime!
+  processingStatus: String
+  ineligibilityReason: SessionCoachIneligibilityReasonEnum
+  summary: String
+  shotCount: Int!
+  madeCount: Int!
+  missedCount: Int!
+  unknownOutcomeCount: Int!
+  analyzedShotCount: Int!
+  makePercentage: Float
+  primaryCandidate: SessionCoachCandidateGQL
+  candidates: [SessionCoachCandidateGQL!]!
+}
+
+enum SessionCoachStateEnum {
+  PROCESSING
+  READY
+  NO_TRACKED_SHOTS
+  INELIGIBLE
+  FAILED
+}
+
+enum SessionCoachIneligibilityReasonEnum {
+  MULTIPLAYER
+}
+
+type SessionCoachCandidateGQL {
+  id: ID!
+  rank: Int!
+  family: SessionCoachCandidateFamilyEnum!
+  kind: SessionCoachCandidateKindEnum!
+  title: String!
+  body: String!
+  action: String!
+  supportingShotIds: [Int!]!
+  drillId: String
+  evidence: SessionCoachEvidenceGQL!
+  limitations: [String!]!
+}
+
+enum SessionCoachCandidateFamilyEnum {
+  AIMING
+  CUT_ANGLE
+  SPIN
+  OBJECT_TO_POCKET_DISTANCE
+  CUE_TO_OBJECT_DISTANCE
+  BACK_CUT
+}
+
+enum SessionCoachCandidateKindEnum {
+  DIRECTIONAL_MISS
+  OUTCOME_PATTERN
+  USAGE_PATTERN
+}
+
+type SessionCoachEvidenceGQL {
+  bucketKey: String!
+  bucketLabel: String!
+  attemptCount: Int!
+  madeCount: Int!
+  missedCount: Int!
+  makePercentage: Float!
+  comparisonAttemptCount: Int!
+  comparisonMadeCount: Int!
+  comparisonMakePercentage: Float
+  patternShotCount: Int!
+  score: Float!
+  rankReason: String!
+}
+
 type PlayerClusterGQL {
   videoId: Int!
   clusterId: Int!
@@ -946,6 +1098,14 @@ type PlayerClusterShotGQL {
 type TableStateGQL {
   identifierToPosition: [[Float!]!]!
   homography: HomographyInfoGQL
+  identifierToColor: [RGBColorGQL]!
+}
+
+type RGBColorGQL {
+  r: Int!
+  g: Int!
+  b: Int!
+  hex: String!
 }
 
 input HomographyInputGQL {
@@ -976,6 +1136,19 @@ input IntPoint2DInput {
   y: Int!
 }
 
+type LiveTableStateGQL {
+  videoId: Int!
+  frameIndex: Int!
+  tableState: TableStateGQL!
+}
+
+type ShotTableStateGQL {
+  shotId: Int!
+  videoId: Int!
+  frameIndex: Int!
+  tableState: TableStateGQL!
+}
+
 type ShotProjectionGQL {
   trajectories: [BallTrajectoryGQL!]!
   events: [SimulationEventGQL!]!
@@ -1080,6 +1253,60 @@ input CreatedAfter @oneOf {
   createdAt: DateTime
 }
 
+type UsageStatsGQL {
+  funnel: FunnelStatsGQL!
+  totalUsers: Int!
+  totalVideos: Int!
+  totalShots: Int!
+  totalRuns: Int!
+  cohorts: [CohortStatsGQL!]!
+  windows: [UsageStatsWindowGQL!]!
+  daily: [UsageStatsDailyGQL!]!
+  processingLast24h: [ProcessingStatusCountGQL!]!
+}
+
+type FunnelStatsGQL {
+  freemiumEpoch: Date!
+  eraSignups: Int!
+  eraPaying: Int!
+  activationCohort: Int!
+  activationActivated: Int!
+  payingUsers: Int!
+  newPaid7d: Int!
+  newPaid30d: Int!
+  retentionPrevActive: Int!
+  retentionReturned: Int!
+}
+
+type CohortStatsGQL {
+  weekStart: Date!
+  signups: Int!
+  activated7d: Int!
+  paid7d: Int!
+  activatedNotPaid7d: Int!
+}
+
+type UsageStatsWindowGQL {
+  label: String!
+  newUsers: Int!
+  activeUsers: Int!
+  sessions: Int!
+  shots: Int!
+}
+
+type UsageStatsDailyGQL {
+  day: Date!
+  newUsers: Int!
+  activeUsers: Int!
+  sessions: Int!
+  shots: Int!
+}
+
+type ProcessingStatusCountGQL {
+  status: String!
+  count: Int!
+}
+
 type UserRelationshipsResult {
   inquiringUser: UserGQL!
   relationships: [UserRelationship!]!
@@ -1095,6 +1322,7 @@ type StripeSubscriptionOptionsGQL {
   products: [StripeProductGQL!]!
   trialPeriodDays: Int
   appleIap: AppleIapSubscriptionOptionsGQL!
+  tierOptions: [SubscriptionTierPurchaseOptionGQL!]!
 }
 
 type StripeProductGQL {
@@ -1121,6 +1349,21 @@ type AppleIapSubscriptionOptionsGQL {
   productIds: [String!]!
 }
 
+type SubscriptionTierPurchaseOptionGQL {
+  tierName: String!
+  tierDisplayName: String!
+  billingInterval: String!
+  platform: String!
+  isConfigured: Boolean!
+  isAvailable: Boolean!
+  stripeProductId: String
+  stripePriceId: String
+  appleProductId: String
+  currency: String
+  unitAmount: Int
+  recurringIntervalCount: Int
+}
+
 type UserSubscriptionStatusGQL {
   hasActiveSubscription: Boolean!
   entitlementSource: EntitlementSourceTypeEnum
@@ -1330,6 +1573,24 @@ type Mutation {
   markAllNotificationsAsRead: Boolean!
   markNotificationsAsRead(notificationIds: [Int!]!): Boolean!
   deleteNotification(notificationId: Int!): Boolean!
+  createPoolHall(input: CreatePoolHallInput!): PoolHall!
+  updatePoolHall(input: UpdatePoolHallInput!): PoolHall!
+  createPoolHallCamera(
+    input: CreatePoolHallCameraInput!
+  ): PoolHallCameraStreamCredentials!
+  updatePoolHallCamera(input: UpdatePoolHallCameraInput!): PoolHallCamera!
+  rotatePoolHallCameraStreamKey(cameraId: ID!): PoolHallCameraStreamCredentials!
+  createCameraClaimSession(
+    cameraId: ID!
+    durationMinutes: Int = null
+    videoName: String = null
+    videoPrivate: Boolean = null
+    agreedTermsVersion: Int = null
+    tags: [VideoTagInput!] = null
+  ): CameraClaimSession!
+  cancelCameraClaimSession(claimSessionId: ID!): CameraClaimSession!
+  endCameraLease(leaseId: ID!): CameraLease!
+  extendCameraLease(leaseId: ID!, additionalMinutes: Int! = 60): CameraLease!
   finalizePlayerAssignments(
     input: FinalizePlayerAssignmentsInput!
   ): [PlayerClusterGQL!]!
@@ -1409,6 +1670,56 @@ enum ReportReasonEnum {
   OTHER
 }
 
+input CreatePoolHallInput {
+  name: String!
+  address: String = null
+  city: String = null
+  state: String = null
+  latitude: Float = null
+  longitude: Float = null
+  timezone: String = null
+}
+
+input UpdatePoolHallInput {
+  id: ID!
+  name: String = null
+  address: String = null
+  city: String = null
+  state: String = null
+  latitude: Float = null
+  longitude: Float = null
+  timezone: String = null
+  status: String = null
+}
+
+type PoolHallCameraStreamCredentials {
+  camera: PoolHallCamera!
+  streamKey: String!
+  rtmpPath: String!
+}
+
+input CreatePoolHallCameraInput {
+  poolHallId: ID!
+  name: String!
+  tableLabel: String = null
+  streamPath: String = null
+  tableSize: Float = null
+  pocketSize: Float = null
+  allowsPrivateVideos: Boolean = null
+  claimTermsText: String = null
+}
+
+input UpdatePoolHallCameraInput {
+  id: ID!
+  name: String = null
+  tableLabel: String = null
+  status: String = null
+  tableSize: Float = null
+  pocketSize: Float = null
+  allowsPrivateVideos: Boolean = null
+  claimTermsText: String = null
+}
+
 input FinalizePlayerAssignmentsInput {
   videoId: Int!
   clusterAssignments: [ClusterAssignmentInput!]! = []