feat: allow setting timeouts on uploads (#1208)

Co-authored-by: Jonathan Lui <jonathanlui@google.com>

src/bucket.ts

@@ -347,6 +347,7 @@ export interface UploadOptions
   encryptionKey?: string | Buffer;
   kmsKeyName?: string;
   resumable?: boolean;
+  timeout?: number;
   // eslint-disable-next-line @typescript-eslint/no-explicit-any
   onUploadProgress?: (progressEvent: any) => void;
 }
@@ -3239,6 +3240,9 @@ class Bucket extends ServiceObject {
    *     `options.predefinedAcl = 'publicRead'`)
    * @param {boolean} [options.resumable] Force a resumable upload. (default:
    *     true for files larger than 5 MB).
+   * @param {number} [options.timeout=60000] Set the HTTP request timeout in
+   *     milliseconds. This option is not available for resumable uploads.
+   *     Default: `60000`
    * @param {string} [options.uri] The URI for an already-created resumable
    *     upload. See {@link File#createResumableUpload}.
    * @param {string} [options.userProject] The ID of the project which will be

src/file.ts

@@ -211,6 +211,7 @@ export interface CreateWriteStreamOptions extends CreateResumableUploadOptions {
   contentType?: string;
   gzip?: string | boolean;
   resumable?: boolean;
+  timeout?: number;
   validation?: string | boolean;
 }
 
@@ -1573,6 +1574,9 @@ class File extends ServiceObject<File> {
    *     working with streams, the file format and size is unknown until it's
    *     completely consumed. Because of this, it's best for you to be explicit
    *     for what makes sense given your input.
+   * @param {number} [timeout=60000] Set the HTTP request timeout in
+   *     milliseconds. This option is not available for resumable uploads.
+   *     Default: `60000`
    * @property {string} [uri] The URI for an already-created resumable
    *     upload. See {@link File#createResumableUpload}.
    * @property {string} [userProject] The ID of the project which will be
@@ -3564,10 +3568,7 @@ class File extends ServiceObject<File> {
    *
    * @private
    */
-  startSimpleUpload_(
-    dup: Duplexify,
-    options?: CreateResumableUploadOptions
-  ): void {
+  startSimpleUpload_(dup: Duplexify, options?: CreateWriteStreamOptions): void {
     options = Object.assign(
       {
         metadata: {},
@@ -3594,6 +3595,10 @@ class File extends ServiceObject<File> {
       reqOpts.qs.kmsKeyName = this.kmsKeyName;
     }
 
+    if (typeof options.timeout === 'number') {
+      reqOpts.timeout = options.timeout;
+    }
+
     if (options.userProject || this.userProject) {
       reqOpts.qs.userProject = options.userProject || this.userProject;
     }

test/file.ts

@@ -4151,6 +4151,7 @@ describe('File', () => {
         predefinedAcl: 'allUsers',
         private: true,
         public: true,
+        timeout: 99,
       };
 
       // eslint-disable-next-line @typescript-eslint/no-explicit-any
@@ -4161,6 +4162,7 @@ describe('File', () => {
             name: file.name,
             predefinedAcl: options.predefinedAcl,
           },
+          timeout: options.timeout,
           uri:
             'https://storage.googleapis.com/upload/storage/v1/b/' +
             file.bucket.name +