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/index.tsx

@@ -2391,6 +2391,12 @@ export type GetUploadLinkReturn = {
   value: UploadLinkGetUploadLinkErrors;
 };
 
+export type GetUploadLinksReturn = {
+  __typename?: "GetUploadLinksReturn";
+  stream?: Maybe<UploadStreamGql>;
+  value: UploadLinkBatchGetUploadLinkErrors;
+};
+
 export type HlsPlaylistGql = {
   __typename?: "HLSPlaylistGQL";
   m3u8Text: Scalars["String"]["output"];
@@ -2547,6 +2553,7 @@ export type Mutation = {
   getHlsInitUploadLink: GetUploadLinkReturn;
   getProfileImageUploadLink: GetProfileUploadLinkReturn;
   getUploadLink: GetUploadLinkReturn;
+  getUploadLinks: GetUploadLinksReturn;
   grantManualEntitlement: UserSubscriptionStatusGql;
   inviteUsersToChallenge: Array<ChallengeInvitation>;
   markAllNotificationsAsRead: Scalars["Boolean"]["output"];
@@ -2731,6 +2738,11 @@ export type MutationGetUploadLinkArgs = {
   videoId: Scalars["Int"]["input"];
 };
 
+export type MutationGetUploadLinksArgs = {
+  segmentIndexes: Array<Scalars["Int"]["input"]>;
+  videoId: Scalars["Int"]["input"];
+};
+
 export type MutationGrantManualEntitlementArgs = {
   endsAt?: InputMaybe<Scalars["DateTime"]["input"]>;
   reason?: InputMaybe<Scalars["String"]["input"]>;
@@ -3571,6 +3583,13 @@ export type SegmentStartTimesGql = {
   segmentStartTimes: Array<Scalars["Float"]["output"]>;
 };
 
+export type SegmentUploadLink = {
+  __typename?: "SegmentUploadLink";
+  headers: Array<Maybe<Header>>;
+  segmentIndex: Scalars["Int"]["output"];
+  uploadUrl: Scalars["String"]["output"];
+};
+
 export type SerializedShotPathsGql = {
   __typename?: "SerializedShotPathsGQL";
   b64EncodedBuffer?: Maybe<Scalars["String"]["output"]>;
@@ -4111,6 +4130,16 @@ export type UploadLink = {
   uploadUrl: Scalars["String"]["output"];
 };
 
+export type UploadLinkBatch = {
+  __typename?: "UploadLinkBatch";
+  alreadyUploaded: Array<Scalars["Int"]["output"]>;
+  links: Array<SegmentUploadLink>;
+};
+
+export type UploadLinkBatchGetUploadLinkErrors =
+  | GetUploadLinkErrors
+  | UploadLinkBatch;
+
 export type UploadLinkGetProfileUploadLinkErrors =
   | GetProfileUploadLinkErrors
   | UploadLink;
@@ -5414,6 +5443,69 @@ export type GetMyDrillRunsQuery = {
   }>;
 };
 
+export type GetRecordedStreamsQueryVariables = Exact<{
+  limit?: Scalars["Int"]["input"];
+}>;
+
+export type GetRecordedStreamsQuery = {
+  __typename?: "Query";
+  getFeedVideos: {
+    __typename?: "VideoHistoryGQL";
+    videos: Array<{
+      __typename?: "VideoGQL";
+      id: number;
+      name?: string | null;
+      createdAt?: any | null;
+      screenshotUri?: string | null;
+      framesPerSecond?: number | null;
+      totalShots: number;
+      owner?: {
+        __typename?: "UserGQL";
+        id: number;
+        username: string;
+        profileImageUri?: string | null;
+      } | null;
+    }>;
+  };
+};
+
+export type GetLiveStreamsQueryVariables = Exact<{
+  limit?: Scalars["Int"]["input"];
+}>;
+
+export type GetLiveStreamsQuery = {
+  __typename?: "Query";
+  getFeedVideos: {
+    __typename?: "VideoHistoryGQL";
+    videos: Array<{
+      __typename?: "VideoGQL";
+      id: number;
+      name?: string | null;
+      startTime?: any | null;
+      createdAt?: any | null;
+      screenshotUri?: string | null;
+      elapsedTime?: number | null;
+      owner?: {
+        __typename?: "UserGQL";
+        id: number;
+        username: string;
+        profileImageUri?: string | null;
+      } | null;
+      stream?: {
+        __typename?: "UploadStreamGQL";
+        id: string;
+        isCompleted: boolean;
+        lastSegmentUploadedAt?: any | null;
+      } | null;
+    }>;
+    pageInfo: {
+      __typename?: "PageInfoGQL";
+      hasNextPage: boolean;
+      endCursor?: string | null;
+    };
+  };
+};
+
 export type GetVideoMakePercentageIntervalsQueryVariables = Exact<{
   videoId: Scalars["ID"]["input"];
   intervalDuration: Scalars["Int"]["input"];
@@ -9204,6 +9296,72 @@ export type GetUploadLinkMutation = {
         };
     stream?: {
       __typename?: "UploadStreamGQL";
+      id: string;
+      uploadCompletionCursor: number;
+    } | null;
+  };
+};
+
+export type GetUploadLinksMutationVariables = Exact<{
+  videoId: Scalars["Int"]["input"];
+  segmentIndexes: Array<Scalars["Int"]["input"]> | Scalars["Int"]["input"];
+}>;
+
+export type GetUploadLinksMutation = {
+  __typename?: "Mutation";
+  getUploadLinks: {
+    __typename?: "GetUploadLinksReturn";
+    value:
+      | {
+          __typename?: "GetUploadLinkErrors";
+          error:
+            | { __typename?: "InitUploadAlreadyCompletedErr" }
+            | {
+                __typename?: "MustHaveSetForUploadLinkErr";
+                resolution?: boolean | null;
+                framesPerSecond?: boolean | null;
+              }
+            | { __typename?: "NoInitForChunkedUploadErr" }
+            | {
+                __typename?: "ProcessingFailedErr";
+                processing: {
+                  __typename?: "VideoProcessingGQL";
+                  status: ProcessingStatusEnum;
+                  errors: Array<{
+                    __typename?: "VideoProcessingErrorGQL";
+                    message: string;
+                  }>;
+                };
+              }
+            | { __typename?: "SegmentAlreadyUploadedErr" }
+            | {
+                __typename?: "StorageLimitExceededErr";
+                reason: string;
+                tierName: string;
+                retainedStorageUsedBytes: any;
+                retainedStorageLimitBytes?: any | null;
+                remainingStorageBytes?: any | null;
+              }
+            | { __typename?: "TooManyInitUploadsErr" }
+            | { __typename?: "TooManyProfileImageUploadsErr" };
+        }
+      | {
+          __typename?: "UploadLinkBatch";
+          alreadyUploaded: Array<number>;
+          links: Array<{
+            __typename?: "SegmentUploadLink";
+            segmentIndex: number;
+            uploadUrl: string;
+            headers: Array<{
+              __typename?: "Header";
+              key: string;
+              value: string;
+            } | null>;
+          }>;
+        };
+    stream?: {
+      __typename?: "UploadStreamGQL";
+      id: string;
       uploadCompletionCursor: number;
     } | null;
   };
@@ -9302,6 +9460,7 @@ export type UploadStreamWithDetailsFragment = {
   startTime?: any | null;
   stream?: {
     __typename?: "UploadStreamGQL";
+    id: string;
     isCompleted: boolean;
     lastIntendedSegmentBound?: number | null;
     uploadCompletionCursor: number;
@@ -9326,6 +9485,7 @@ export type GetUploadStreamsWithDetailsQuery = {
       startTime?: any | null;
       stream?: {
         __typename?: "UploadStreamGQL";
+        id: string;
         isCompleted: boolean;
         lastIntendedSegmentBound?: number | null;
         uploadCompletionCursor: number;
@@ -9903,6 +10063,7 @@ export const UploadStreamWithDetailsFragmentDoc = gql`
     name
     startTime
     stream {
+      id
       isCompleted
       lastIntendedSegmentBound
       uploadCompletionCursor
@@ -12381,6 +12542,195 @@ export type GetMyDrillRunsQueryResult = Apollo.QueryResult<
   GetMyDrillRunsQuery,
   GetMyDrillRunsQueryVariables
 >;
+export const GetRecordedStreamsDocument = gql`
+  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
+        }
+      }
+    }
+  }
+`;
+
+/**
+ * __useGetRecordedStreamsQuery__
+ *
+ * To run a query within a React component, call `useGetRecordedStreamsQuery` and pass it any options that fit your needs.
+ * When your component renders, `useGetRecordedStreamsQuery` returns an object from Apollo Client that contains loading, error, and data properties
+ * you can use to render your UI.
+ *
+ * @param baseOptions options that will be passed into the query, supported options are listed on: https://www.apollographql.com/docs/react/api/react-hooks/#options;
+ *
+ * @example
+ * const { data, loading, error } = useGetRecordedStreamsQuery({
+ *   variables: {
+ *      limit: // value for 'limit'
+ *   },
+ * });
+ */
+export function useGetRecordedStreamsQuery(
+  baseOptions?: Apollo.QueryHookOptions<
+    GetRecordedStreamsQuery,
+    GetRecordedStreamsQueryVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useQuery<
+    GetRecordedStreamsQuery,
+    GetRecordedStreamsQueryVariables
+  >(GetRecordedStreamsDocument, options);
+}
+export function useGetRecordedStreamsLazyQuery(
+  baseOptions?: Apollo.LazyQueryHookOptions<
+    GetRecordedStreamsQuery,
+    GetRecordedStreamsQueryVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useLazyQuery<
+    GetRecordedStreamsQuery,
+    GetRecordedStreamsQueryVariables
+  >(GetRecordedStreamsDocument, options);
+}
+export function useGetRecordedStreamsSuspenseQuery(
+  baseOptions?: Apollo.SuspenseQueryHookOptions<
+    GetRecordedStreamsQuery,
+    GetRecordedStreamsQueryVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useSuspenseQuery<
+    GetRecordedStreamsQuery,
+    GetRecordedStreamsQueryVariables
+  >(GetRecordedStreamsDocument, options);
+}
+export type GetRecordedStreamsQueryHookResult = ReturnType<
+  typeof useGetRecordedStreamsQuery
+>;
+export type GetRecordedStreamsLazyQueryHookResult = ReturnType<
+  typeof useGetRecordedStreamsLazyQuery
+>;
+export type GetRecordedStreamsSuspenseQueryHookResult = ReturnType<
+  typeof useGetRecordedStreamsSuspenseQuery
+>;
+export type GetRecordedStreamsQueryResult = Apollo.QueryResult<
+  GetRecordedStreamsQuery,
+  GetRecordedStreamsQueryVariables
+>;
+export const GetLiveStreamsDocument = gql`
+  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
+      }
+    }
+  }
+`;
+
+/**
+ * __useGetLiveStreamsQuery__
+ *
+ * To run a query within a React component, call `useGetLiveStreamsQuery` and pass it any options that fit your needs.
+ * When your component renders, `useGetLiveStreamsQuery` returns an object from Apollo Client that contains loading, error, and data properties
+ * you can use to render your UI.
+ *
+ * @param baseOptions options that will be passed into the query, supported options are listed on: https://www.apollographql.com/docs/react/api/react-hooks/#options;
+ *
+ * @example
+ * const { data, loading, error } = useGetLiveStreamsQuery({
+ *   variables: {
+ *      limit: // value for 'limit'
+ *   },
+ * });
+ */
+export function useGetLiveStreamsQuery(
+  baseOptions?: Apollo.QueryHookOptions<
+    GetLiveStreamsQuery,
+    GetLiveStreamsQueryVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useQuery<GetLiveStreamsQuery, GetLiveStreamsQueryVariables>(
+    GetLiveStreamsDocument,
+    options,
+  );
+}
+export function useGetLiveStreamsLazyQuery(
+  baseOptions?: Apollo.LazyQueryHookOptions<
+    GetLiveStreamsQuery,
+    GetLiveStreamsQueryVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useLazyQuery<GetLiveStreamsQuery, GetLiveStreamsQueryVariables>(
+    GetLiveStreamsDocument,
+    options,
+  );
+}
+export function useGetLiveStreamsSuspenseQuery(
+  baseOptions?: Apollo.SuspenseQueryHookOptions<
+    GetLiveStreamsQuery,
+    GetLiveStreamsQueryVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useSuspenseQuery<
+    GetLiveStreamsQuery,
+    GetLiveStreamsQueryVariables
+  >(GetLiveStreamsDocument, options);
+}
+export type GetLiveStreamsQueryHookResult = ReturnType<
+  typeof useGetLiveStreamsQuery
+>;
+export type GetLiveStreamsLazyQueryHookResult = ReturnType<
+  typeof useGetLiveStreamsLazyQuery
+>;
+export type GetLiveStreamsSuspenseQueryHookResult = ReturnType<
+  typeof useGetLiveStreamsSuspenseQuery
+>;
+export type GetLiveStreamsQueryResult = Apollo.QueryResult<
+  GetLiveStreamsQuery,
+  GetLiveStreamsQueryVariables
+>;
 export const GetVideoMakePercentageIntervalsDocument = gql`
   query GetVideoMakePercentageIntervals(
     $videoId: ID!
@@ -19680,6 +20030,7 @@ export const GetUploadLinkDocument = gql`
         }
       }
       stream {
+        id
         uploadCompletionCursor
       }
     }
@@ -19729,6 +20080,96 @@ export type GetUploadLinkMutationOptions = Apollo.BaseMutationOptions<
   GetUploadLinkMutation,
   GetUploadLinkMutationVariables
 >;
+export const GetUploadLinksDocument = gql`
+  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
+      }
+    }
+  }
+`;
+export type GetUploadLinksMutationFn = Apollo.MutationFunction<
+  GetUploadLinksMutation,
+  GetUploadLinksMutationVariables
+>;
+
+/**
+ * __useGetUploadLinksMutation__
+ *
+ * To run a mutation, you first call `useGetUploadLinksMutation` within a React component and pass it any options that fit your needs.
+ * When your component renders, `useGetUploadLinksMutation` returns a tuple that includes:
+ * - A mutate function that you can call at any time to execute the mutation
+ * - An object with fields that represent the current status of the mutation's execution
+ *
+ * @param baseOptions options that will be passed into the mutation, supported options are listed on: https://www.apollographql.com/docs/react/api/react-hooks/#options-2;
+ *
+ * @example
+ * const [getUploadLinksMutation, { data, loading, error }] = useGetUploadLinksMutation({
+ *   variables: {
+ *      videoId: // value for 'videoId'
+ *      segmentIndexes: // value for 'segmentIndexes'
+ *   },
+ * });
+ */
+export function useGetUploadLinksMutation(
+  baseOptions?: Apollo.MutationHookOptions<
+    GetUploadLinksMutation,
+    GetUploadLinksMutationVariables
+  >,
+) {
+  const options = { ...defaultOptions, ...baseOptions };
+  return Apollo.useMutation<
+    GetUploadLinksMutation,
+    GetUploadLinksMutationVariables
+  >(GetUploadLinksDocument, options);
+}
+export type GetUploadLinksMutationHookResult = ReturnType<
+  typeof useGetUploadLinksMutation
+>;
+export type GetUploadLinksMutationResult =
+  Apollo.MutationResult<GetUploadLinksMutation>;
+export type GetUploadLinksMutationOptions = Apollo.BaseMutationOptions<
+  GetUploadLinksMutation,
+  GetUploadLinksMutationVariables
+>;
 export const GetHlsInitUploadLinkDocument = gql`
   mutation GetHlsInitUploadLink($videoId: Int!) {
     getHlsInitUploadLink(videoId: $videoId) {

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/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/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

src/schema.gql

@@ -526,6 +526,24 @@ type GetUploadLinkReturn {
   stream: UploadStreamGQL
 }
 
+type GetUploadLinksReturn {
+  value: UploadLinkBatchGetUploadLinkErrors!
+  stream: UploadStreamGQL
+}
+
+type SegmentUploadLink {
+  segmentIndex: Int!
+  uploadUrl: String!
+  headers: [Header]!
+}
+
+type UploadLinkBatch {
+  links: [SegmentUploadLink!]!
+  alreadyUploaded: [Int!]!
+}
+
+union UploadLinkBatchGetUploadLinkErrors = UploadLinkBatch | GetUploadLinkErrors
+
 type HLSPlaylistGQL {
   videoId: Int!
   m3u8Text: String!
@@ -755,6 +773,7 @@ type Mutation {
     expectedDurationSeconds: Float = null
   ): CreateUploadStreamReturn!
   getUploadLink(videoId: Int!, segmentIndex: Int!): GetUploadLinkReturn!
+  getUploadLinks(videoId: Int!, segmentIndexes: [Int!]!): GetUploadLinksReturn!
   getHlsInitUploadLink(videoId: Int!): GetUploadLinkReturn!
   setSegmentDuration(
     videoId: Int!