in services/garbage-collector/csharp/Startup.cs [38:69]
public void Configure(IApplicationBuilder app, IWebHostEnvironment env, ILogger<Startup> logger)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
logger.LogInformation("Service is starting...");
app.UseRouting();
_bucketThumbnails = GetEnvironmentVariable("BUCKET_THUMBNAILS");
_projectId = GetEnvironmentVariable("PROJECT_ID");
app.UseEndpoints(endpoints =>
{
endpoints.MapPost("/", async context =>
{
var formatter = CloudEventFormatterAttribute.CreateFormatter(typeof(StorageObjectData));
var cloudEvent = await context.Request.ToCloudEventAsync(formatter);
logger.LogInformation("Received CloudEvent\n" + GetEventLog(cloudEvent));
var storageObjectData = (StorageObjectData)cloudEvent.Data;
var bucket = storageObjectData.Bucket;
var objectName = storageObjectData.Name;
await DeleteFromThumbnailsAsync(objectName, logger);
await DeleteFromFirestore(objectName, logger);
});
});
}