var client = StorageClient.Create();// Create a bucket with a globally unique namevar bucketName = Guid.NewGuid().ToString();var bucket = client.CreateBucket(projectId, bucketName);// Upload some filesvar content = Encoding.UTF8.GetBytes("hello, world");var obj1 = client.UploadObject(bucketName, "file1.txt", "text/plain", new MemoryStream(content));var obj2 = client.UploadObject(bucketName, "folder1/file2.txt", "text/plain", new MemoryStream(content));// List objectsforeach (var obj in client.ListObjects(bucketName, "")){    Console.WriteLine(obj.Name);}// Download fileusing (var stream = File.OpenWrite("file1.txt")){    client.DownloadObject(bucketName, "file1.txt", stream);}

// Create a signed URL which can be used to get a specific object for one hour.UrlSigner urlSigner = UrlSigner.FromCredential(credential);string url = await urlSigner.SignAsync(bucketName, objectName, TimeSpan.FromHours(1));// Get the content at the created URL.HttpResponseMessage response = await httpClient.GetAsync(url);string content = await response.Content.ReadAsStringAsync();

// Create a request template that will be used to create the signed URL.var destination = "places/world.txt";UrlSigner.RequestTemplate requestTemplate = UrlSigner.RequestTemplate    .FromBucket(bucketName)    .WithObjectName(destination)    .WithHttpMethod(HttpMethod.Put)    .WithContentHeaders(new Dictionary<string, IEnumerable<string>>    {        { "Content-Type", new[] { "text/plain" } }    });// Create options specifying for how long the signer URL will be valid.UrlSigner.Options options = UrlSigner.Options.FromDuration(TimeSpan.FromHours(1));// Create a signed URL which allows the requester to PUT data with the text/plain content-type.UrlSigner urlSigner = UrlSigner.FromCredential(credential);string url = await urlSigner.SignAsync(requestTemplate, options);// Upload the content into the bucket using the signed URL.string source = "world.txt";ByteArrayContent content;using (FileStream stream = File.OpenRead(source)){    byte[] data = new byte[stream.Length];    stream.Read(data, 0, data.Length);    content = new ByteArrayContent(data)    {        Headers = { ContentType = new MediaTypeHeaderValue("text/plain") }    };}HttpResponseMessage response = await httpClient.PutAsync(url, content);

// Create a signed URL which can be used to get a specific object for one hour.var computeCredential = new ComputeCredential();UrlSigner urlSigner = UrlSigner.FromCredential(computeCredential);string url = await urlSigner.SignAsync(bucketName, objectName, TimeSpan.FromHours(1));// Get the content at the created URL.HttpResponseMessage response = await httpClient.GetAsync(url);string content = await response.Content.ReadAsStringAsync();

// Create an HmacBlobSigner from an HMAC Key ID and Secret.UrlSigner.IBlobSigner blobSigner = UrlSigner.HmacBlobSigner.Create(hmacKeyId, hmacKeySecret);// Create a URL signer from the HmacBlobSigner.UrlSigner urlSigner = UrlSigner.FromBlobSigner(blobSigner);// Create an HMAC signed URL which can be used to get a specific object for one hour.string url = urlSigner.Sign(bucketName, objectName, TimeSpan.FromHours(1));// Get the content at the created URL.HttpResponseMessage response = await httpClient.GetAsync(url);string content = await response.Content.ReadAsStringAsync();

// Create a signed URL which can be used to get a specific object for one hour,// using the V4 signing process.UrlSigner urlSigner = UrlSigner.FromCredential(credential);string url = await urlSigner.SignAsync(bucketName, objectName, TimeSpan.FromHours(1), signingVersion: SigningVersion.V4);// Get the content at the created URL.HttpResponseMessage response = await httpClient.GetAsync(url);string content = await response.Content.ReadAsStringAsync();

// Create a signed post policy which can be used to upload a specific object and// expires in 1 hour after creation.UrlSigner urlSigner = UrlSigner.FromCredential(credential);UrlSigner.Options options = UrlSigner.Options    .FromDuration(TimeSpan.FromHours(1))    .WithSigningVersion(SigningVersion.V4)    .WithScheme("https");UrlSigner.PostPolicy postPolicy = UrlSigner.PostPolicy.ForBucketAndKey(bucketName, objectName);postPolicy.SetCustomField(UrlSigner.PostPolicyCustomElement.GoogleMetadata, "x-goog-meta-test", "data");UrlSigner.SignedPostPolicy signedPostPolicy = await urlSigner.SignAsync(postPolicy, options);// Create an HTML form including all the fields in the signed post policy.StringBuilder form = new StringBuilder();form.AppendLine($"<form action=\"{signedPostPolicy.PostUrl}\" method=\"post\" enctype=\"multipart/form-data\">");foreach (var field in signedPostPolicy.Fields){    form.AppendLine($"<input type=\"hidden\" name=\"{field.Key}\" value=\"{field.Value}\">");}// Include the file element. It should always be the last element in the form.form.AppendLine("<input name=\"file\" type=\"file\">");form.AppendLine("<input type=\"submit\" value=\"Upload\">");form.AppendLine("</form>");// You can now save the form to file and serve it as static content// or send it as the response to a request made to your application.File.WriteAllText("PostPolicySimple.html", form.ToString());

// Create a signed post policy which can be used to upload a specific object with a// specific cache-control value and expires in 1 hour after creation.UrlSigner urlSigner = UrlSigner.FromCredential(credential);UrlSigner.Options options = UrlSigner.Options    .FromDuration(TimeSpan.FromHours(1))    .WithSigningVersion(SigningVersion.V4)    .WithScheme("https");UrlSigner.PostPolicy postPolicy = UrlSigner.PostPolicy.ForBucketAndKey(bucketName, objectName);postPolicy.SetField(UrlSigner.PostPolicyStandardElement.Acl, "public-read");postPolicy.SetField(UrlSigner.PostPolicyStandardElement.CacheControl, "public,max-age=86400");UrlSigner.SignedPostPolicy signedPostPolicy = await urlSigner.SignAsync(postPolicy, options);// Create an HTML form including all the fields in the signed post policy.StringBuilder form = new StringBuilder();form.AppendLine($"<form action=\"{signedPostPolicy.PostUrl}\" method=\"post\" enctype=\"multipart/form-data\">");foreach (var field in signedPostPolicy.Fields){    form.AppendLine($"<input type=\"hidden\" name=\"{field.Key}\" value=\"{field.Value}\">");}// Include the file element. It should always be the last element in the form.form.AppendLine("<input name=\"file\" type=\"file\">");form.AppendLine("<input type=\"submit\" value=\"Upload\">");form.AppendLine("</form>");// You can now save the form to file and serve it as static content// or send it as the response to a request made to your application.File.WriteAllText("PostPolicyCacheControl.html", form.ToString());

// Create a signed post policy which can be used to upload a specific object and// expires in 10 seconds after creation.// It also sets a starts-with condition on the acl form element, that should be met// by the actual form used for posting.UrlSigner urlSigner = UrlSigner.FromCredential(credential);UrlSigner.Options options = UrlSigner.Options    .FromDuration(TimeSpan.FromHours(1))    .WithSigningVersion(SigningVersion.V4)    .WithScheme("https");UrlSigner.PostPolicy postPolicy = UrlSigner.PostPolicy.ForBucketAndKey(bucketName, objectName);postPolicy.SetStartsWith(UrlSigner.PostPolicyStandardElement.Acl, "public");UrlSigner.SignedPostPolicy signedPostPolicy = await urlSigner.SignAsync(postPolicy, options);// Create an HTML form including all the fields in the signed post policy.StringBuilder form = new StringBuilder();form.AppendLine($"<form action=\"{signedPostPolicy.PostUrl}\" method=\"post\" enctype=\"multipart/form-data\">");foreach (var field in signedPostPolicy.Fields){    form.AppendLine($"<input type=\"hidden\" name=\"{field.Key}\" value=\"{field.Value}\">");}// Include also an acl element with a value that meets the condition set in the policy.form.AppendLine("<input type=\"hidden\" name=\"acl\" value=\"public-read\">");// Include the file element. It should always be the last element in the form.form.AppendLine("<input name=\"file\" type=\"file\">");form.AppendLine("<input type=\"submit\" value=\"Upload\">");form.AppendLine("</form>");// You can now save the form to file and serve it as static content// or send it as the response to a request made to your application.File.WriteAllText("PostPolicyAcl.html", form.ToString());

// Create a signed post policy which can be used to upload a specific object and// expires in 1 hour after creation.// It also sets a specific HTTP success satus code that should be returned.// Only 200, 201 and 204 are allowed.UrlSigner urlSigner = UrlSigner.FromCredential(credential);UrlSigner.Options options = UrlSigner.Options    .FromDuration(TimeSpan.FromHours(1))    .WithSigningVersion(SigningVersion.V4)    .WithScheme("https");UrlSigner.PostPolicy postPolicy = UrlSigner.PostPolicy.ForBucketAndKey(bucketName, objectName);postPolicy.SetField(UrlSigner.PostPolicyStandardElement.SuccessActionStatus, HttpStatusCode.OK);UrlSigner.SignedPostPolicy signedPostPolicy = await urlSigner.SignAsync(postPolicy, options);// Create an HTML form including all the fields in the signed post policy.StringBuilder form = new StringBuilder();form.AppendLine($"<form action=\"{signedPostPolicy.PostUrl}\" method=\"post\" enctype=\"multipart/form-data\">");foreach (var field in signedPostPolicy.Fields){    form.AppendLine($"<input type=\"hidden\" name=\"{field.Key}\" value=\"{field.Value}\">");}// Include the file element. It should always be the last element in the form.form.AppendLine("<input name=\"file\" type=\"file\">");form.AppendLine("<input type=\"submit\" value=\"Upload\">");form.AppendLine("</form>");// You can now save the form to file and serve it as static content// or send it as the response to a request made to your application.File.WriteAllText("PostPolicySuccessStatus.html", form.ToString());

var client = StorageClient.Create();var source = "world.txt";var destination = "places/world.txt";var contentType = "text/plain";// var acl = PredefinedAcl.PublicRead // publicvar acl = PredefinedObjectAcl.AuthenticatedRead; // privatevar options = new UploadObjectOptions { PredefinedAcl = acl };var uploadUri = await client.InitiateUploadSessionAsync(bucketName, destination, contentType, contentLength: null, options);// Send uploadUri to (unauthenticated) client application, so it can perform the upload:using (var stream = File.OpenRead(source)){    // IUploadProgress defined in Google.Apis.Upload namespace    IProgress<IUploadProgress> progress = new Progress<IUploadProgress>(      p => Console.WriteLine($"bytes: {p.BytesSent}, status: {p.Status}")    );    var actualUploader = ResumableUpload.CreateFromUploadUri(uploadUri, stream);    actualUploader.ProgressChanged += progress.Report;    await actualUploader.UploadAsync();}

// Use EncryptionKey.Create if you already have a key.EncryptionKey key = EncryptionKey.Generate();// This will affect all relevant object-based operations by default.var client = StorageClient.Create(encryptionKey: key);var content = Encoding.UTF8.GetBytes("hello, world");client.UploadObject(bucketName, "encrypted.txt", "text/plain", new MemoryStream(content));// When downloading, either use a client with the same key...client.DownloadObject(bucketName, "encrypted.txt", new MemoryStream());// Or specify a key just for that operation.var client2 = StorageClient.Create();client2.DownloadObject(bucketName, "encrypted.txt", new MemoryStream(),    new DownloadObjectOptions { EncryptionKey = key });

// First create a Pub/Sub topic.PublisherServiceApiClient publisherClient = PublisherServiceApiClient.Create();TopicName topicName = new TopicName(projectId, topicId);publisherClient.CreateTopic(topicName);// Prepare the topic for Storage notifications. The Storage Service Account must have Publish permission// for the topic. The code below adds the service account into the "roles/pubsub.publisher" role for the topic.// Determine the Storage Service Account name to use in IAM operations.StorageClient storageClient = StorageClient.Create();string storageServiceAccount = $"serviceAccount:{storageClient.GetStorageServiceAccountEmail(projectId)}";// Fetch the IAM policy for the topic.GetIamPolicyRequest getPolicyRequest = new GetIamPolicyRequest { ResourceAsResourceName = topicName };Iam.V1.Policy policy = publisherClient.IAMPolicyClient.GetIamPolicy(getPolicyRequest);var role = "roles/pubsub.publisher";// Ensure the Storage Service Account is in the publisher role, setting the IAM policy for the topic// on the server if necessary.if (policy.AddRoleMember(role, storageServiceAccount)){    SetIamPolicyRequest setPolicyRequest = new SetIamPolicyRequest    {        ResourceAsResourceName = topicName,        Policy = policy    };    publisherClient.IAMPolicyClient.SetIamPolicy(setPolicyRequest);}// Now that the topic is ready, we can create a notification configuration for StorageNotification notification = new Notification{    Topic = $"//pubsub.googleapis.com/{topicName}",    PayloadFormat = "JSON_API_V1"};notification = storageClient.CreateNotification(bucket, notification);Console.WriteLine($"Created notification ID: {notification.Id}");