Program.cs

// Copyright 2023 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

using CloudNative.CloudEvents.AspNetCore;
using CloudNative.CloudEvents;
using Google.Events.Protobuf.Cloud.Storage.V1;
using Google.Events.Protobuf;

var builder = WebApplication.CreateBuilder(args);

var port = Environment.GetEnvironmentVariable("PORT") ?? "8080";
var url = $"http://0.0.0.0:{port}";
builder.WebHost.UseUrls(url);

var app = builder.Build();

app.MapPost("/", async context =>
{
    var formatter = CloudEventFormatterAttribute.CreateFormatter(typeof(StorageObjectData));
    //var formatter = new ProtobufJsonCloudEventFormatter<StorageObjectData>();
    CloudEvent cloudEvent = await context.Request.ToCloudEventAsync(formatter);

    Console.WriteLine("CloudEvent information:");
    Console.WriteLine($"  SpecVersion: {cloudEvent.SpecVersion.VersionId}");
    Console.WriteLine($"  ID: {cloudEvent.Id}");
    Console.WriteLine($"  Source: {cloudEvent.Source}");
    Console.WriteLine($"  Type: {cloudEvent.Type}");
    Console.WriteLine($"  Subject: {cloudEvent.Subject}");
    Console.WriteLine($"  DataSchema: {cloudEvent.DataSchema}");
    Console.WriteLine($"  DataContentType: {cloudEvent.DataContentType}");
    Console.WriteLine($"  Data: {cloudEvent.Data}");
    Console.WriteLine($"  Time: {cloudEvent.Time?.ToUniversalTime():yyyy-MM-dd'T'HH:mm:ss.fff'Z'}");

    var data = cloudEvent.Data as StorageObjectData;

    Console.WriteLine("Storage object information:");
    Console.WriteLine($"  Name: {data?.Name}");
    Console.WriteLine($"  Bucket: {data?.Bucket}");
    Console.WriteLine($"  Size: {data?.Size}");
    Console.WriteLine($"  Content type: {data?.ContentType}");
});

app.Run();