Add getUploadLinks batch mutation (schema + operation)

Batched counterpart to getUploadLink: one validation pass server-side,
N locally-signed URLs per round-trip, already-acknowledged indexes
returned in alreadyUploaded. Schema grafted additively (a full
gql-export from BE master would drop schema entries belonging to
not-yet-merged BE branches).

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

src/operations/feed.gql

@@ -41,6 +41,7 @@ fragment VideoCardFields on VideoGQL {
   stream {
     id
     lastIntendedSegmentBound
+    uploadCompletionCursor
     streamSegmentType
     isCompleted
     lastSegmentUploadedAt
@@ -77,6 +78,7 @@ fragment VideoCardFields on VideoGQL {
     replies {
       id
       message
+      replyToCommentId
       user {
         ...UserSocialsFields
       }

src/operations/leaderboards.gql

@@ -1,5 +1,21 @@
-query GetMakesLeaderboard($interval: TimeInterval, $when: DateTime) {
+query GetMakesLeaderboard(
-  getMakesLeaderboard(interval: $interval, when: $when) {
+  $interval: TimeInterval
+  $when: DateTime
+  $gameType: String
+  $tableSizeMin: Float
+  $tableSizeMax: Float
+  $pocketSizeMin: Float
+  $pocketSizeMax: Float
+) {
+  getMakesLeaderboard(
+    interval: $interval
+    when: $when
+    gameType: $gameType
+    tableSizeMin: $tableSizeMin
+    tableSizeMax: $tableSizeMax
+    pocketSizeMin: $pocketSizeMin
+    pocketSizeMax: $pocketSizeMax
+  ) {
     entries {
       user {
         id
@@ -13,8 +29,24 @@ query GetMakesLeaderboard($interval: TimeInterval, $when: DateTime) {
   }
 }
 
-query GetRunsLeaderboard($interval: TimeInterval, $when: DateTime) {
+query GetRunsLeaderboard(
-  getLongestRunsLeaderboard(interval: $interval, when: $when) {
+  $interval: TimeInterval
+  $when: DateTime
+  $gameType: String
+  $tableSizeMin: Float
+  $tableSizeMax: Float
+  $pocketSizeMin: Float
+  $pocketSizeMax: Float
+) {
+  getLongestRunsLeaderboard(
+    interval: $interval
+    when: $when
+    gameType: $gameType
+    tableSizeMin: $tableSizeMin
+    tableSizeMax: $tableSizeMax
+    pocketSizeMin: $pocketSizeMin
+    pocketSizeMax: $pocketSizeMax
+  ) {
     entries {
       id
       runLength

src/operations/legacy_shotsim.gql

@@ -0,0 +1,25 @@
+# Legacy shot-sim operations still used by mobile master's
+# LiveStreamPicker / RecordedShotPicker; remove when those are deleted.
+
+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
+      }
+    }
+  }
+}

src/operations/recorded_shots.gql

@@ -1,10 +1,12 @@
-# Lightweight two-step picker data for loading a recorded shot into Shot Lab.
+# Lightweight two-step picker data for Shot Lab's video-first source: the
-query GetRecordedStreams($limit: Int! = 25) {
+# caller's recent videos (completed or still uploading), then that video's
+# shots. The stream fields hint at "actively updating" without gating.
+query GetShotLabVideos($userId: Int!, $limit: Int! = 25) {
   getFeedVideos(
     limit: $limit
-    filters: { isStreamCompleted: true, excludeVideosWithNoShots: true }
+    includeCallersVideos: false
     includePrivate: MINE
-    feedInput: { allUsers: true }
+    feedInput: { userId: $userId }
   ) {
     videos {
       id
@@ -18,6 +20,11 @@ query GetRecordedStreams($limit: Int! = 25) {
         username
         profileImageUri
       }
+      stream {
+        id
+        isCompleted
+        lastSegmentUploadedAt
+      }
     }
   }
 }
@@ -36,26 +43,11 @@ query GetRecordedStreamShots($videoId: Int!, $limit: Int! = 200) {
       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,99 @@
+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
+    }
+    agentGeneration {
+      ...SessionCoachGenerationFields
+    }
+  }
+}
+
+mutation RequestSessionCoachGeneration($videoId: Int!) {
+  requestSessionCoachGeneration(videoId: $videoId) {
+    state
+    agentGeneration {
+      ...SessionCoachGenerationFields
+    }
+  }
+}
+
+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
+  }
+}
+
+fragment SessionCoachGenerationFields on SessionCoachGenerationGQL {
+  id
+  state
+  createdAt
+  completedAt
+  decision {
+    selectedCandidateId
+    title
+    body
+    suggestedAction
+    drillId
+    drillReason
+    practiceAttemptCount
+    practiceTarget
+  }
+  diagnostics {
+    analysisVersion
+    promptVersion
+    providerKey
+    modelName
+    inputHash
+    attemptCount
+    maxAttempts
+    enqueueCount
+    latencyMs
+    inputTokens
+    cachedInputTokens
+    outputTokens
+    failureCode
+    updatedAt
+    startedAt
+    lastEnqueuedAt
+    abstentionReason
+  }
+}

src/operations/usage_stats.gql

@@ -12,6 +12,13 @@ query getUsageStats($days: Int! = 30) {
       retentionPrevActive
       retentionReturned
     }
+    cohorts {
+      weekStart
+      signups
+      activated7d
+      paid7d
+      activatedNotPaid7d
+    }
     totalUsers
     totalVideos
     totalShots

src/operations/video.gql

@@ -131,6 +131,7 @@ query GetVideoSocialDetailsById($videoId: Int!) {
       replies {
         id
         message
+        replyToCommentId
         user {
           ...UserSocialsFields
         }

src/operations/video_upload.gql

@@ -48,6 +48,52 @@ mutation GetUploadLink($videoId: Int!, $segmentIndex: Int!) {
       }
     }
     stream {
+      id
+      uploadCompletionCursor
+    }
+  }
+}
+
+mutation GetUploadLinks($videoId: Int!, $segmentIndexes: [Int!]!) {
+  getUploadLinks(videoId: $videoId, segmentIndexes: $segmentIndexes) {
+    value {
+      ... on UploadLinkBatch {
+        links {
+          segmentIndex
+          uploadUrl
+          headers {
+            key
+            value
+          }
+        }
+        alreadyUploaded
+      }
+      ... on GetUploadLinkErrors {
+        error {
+          ... on MustHaveSetForUploadLinkErr {
+            resolution
+            framesPerSecond
+          }
+          ... on ProcessingFailedErr {
+            processing {
+              status
+              errors {
+                message
+              }
+            }
+          }
+          ... on StorageLimitExceededErr {
+            reason
+            tierName
+            retainedStorageUsedBytes
+            retainedStorageLimitBytes
+            remainingStorageBytes
+          }
+        }
+      }
+    }
+    stream {
+      id
       uploadCompletionCursor
     }
   }
@@ -127,6 +173,7 @@ fragment UploadStreamWithDetails on VideoGQL {
   name
   startTime
   stream {
+    id
     isCompleted
     lastIntendedSegmentBound
     uploadCompletionCursor