From 5b0809e76ed9b15e8bc65816a26ada33241f2112 Mon Sep 17 00:00:00 2001
From: visdmin <vili@kiho.fi>
Date: Sun, 29 Oct 2023 01:46:37 +0300
Subject: [PATCH 1/6] ObjectStoragev2 controller idea WIP!!!

---
 .../V1Alpha1ObjectStorage2Controller.cs       |  70 +++++++++
 .../Entities/V1Alpha1ObjectStorage2.cs        | 143 ++++++++++++++++++
 .../V1Alpha1ObjectStorageFinalizer.cs         |  19 +++
 src/UpcloudApiKubernetesOperator/Program.cs   |   1 +
 4 files changed, 233 insertions(+)
 create mode 100644 src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/Finalizer/V1Alpha1ObjectStorageFinalizer.cs

diff --git a/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs b/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs
new file mode 100644
index 0000000..a02ef9e
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs
@@ -0,0 +1,70 @@
+using System.Text.Json;
+
+using k8s;
+using k8s.Models;
+using KubeOps.Operator.Controller;
+using KubeOps.Operator.Controller.Results;
+using KubeOps.Operator.Finalizer;
+using KubeOps.Operator.Kubernetes;
+using KubeOps.Operator.Rbac;
+
+using UpcloudApiKubernetesOperator.Finalizer;
+using UpcloudApiKubernetesOperator.Entities;
+using KubeOps.KubernetesClient;
+using IdentityModel.Client;
+
+
+namespace UpcloudApiKubernetesOperator.Controller.Storage;
+
+[EntityRbac(typeof(V1Alpha1ObjectStorage2), Verbs = RbacVerb.All)]
+public class V1Alpha1ObjectStorage2Controller : IResourceController<V1Alpha1ObjectStorage2>
+{
+    private readonly IKubernetesClient KubernetesClient;
+    private readonly HttpClient HttpClient;
+    private readonly ILogger<V1Alpha1ObjectStorage2Controller> Logger;
+    private readonly IFinalizerManager<V1Alpha1ObjectStorage2> FinalizerManager;
+    private readonly static TimeSpan ResourceInterval = TimeSpan.FromSeconds(30);
+    private readonly JsonSerializerOptions JsonSerializerOptions = new JsonSerializerOptions { WriteIndented = true };
+
+    public V1Alpha1ObjectStorage2Controller(
+        IKubernetesClient kubernetesClient,
+        IHttpClientFactory httpClientFactory,
+        ILogger<V1Alpha1ObjectStorage2Controller> logger,
+        IFinalizerManager<V1Alpha1ObjectStorage2> finalizerManager
+    ) {
+        KubernetesClient = kubernetesClient;
+        HttpClient       = httpClientFactory.CreateClient();
+        Logger           = logger;
+        FinalizerManager = finalizerManager;
+    }
+
+    public async Task<ResourceControllerResult?> ReconcileAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        Logger.LogInformation("Reconciling (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
+            new { kind = entity.GetType(), name = entity.Name() },
+            JsonSerializer.Serialize(entity.Spec,   options: JsonSerializerOptions),
+            JsonSerializer.Serialize(entity.Status, options: JsonSerializerOptions)
+        );
+
+        // TODO: Research what is the best way to obtain required api credentials from a secret.
+        //       Maybe during the operator startup ?
+        // KubernetesClient.Get<V1Secret>()
+
+        await FinalizerManager.RegisterFinalizerAsync<V1Alpha1ObjectStorage2Finalizer>(entity);
+
+        return ResourceControllerResult.RequeueEvent(ResourceInterval);
+    }
+
+    public Task StatusModifiedAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        Logger.LogInformation($"entity {entity.Name()} called {nameof(StatusModifiedAsync)}.");
+        return Task.CompletedTask;
+    }
+
+    public Task DeletedAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        Logger.LogInformation($"entity {entity.Name()} called {nameof(DeletedAsync)}.");
+
+        return Task.CompletedTask;
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
new file mode 100644
index 0000000..fcfac92
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
@@ -0,0 +1,143 @@
+using System.Collections.ObjectModel;
+
+using k8s.Models;
+using KubeOps.Operator.Entities;
+using KubeOps.Operator.Entities.Annotations;
+
+namespace UpcloudApiKubernetesOperator.Entities;
+
+[KubernetesEntity(Group = "api.upcloud.com", ApiVersion = "v1alpha1", Kind = "ObjectStorage2")]
+public class V1Alpha1ObjectStorage2 : CustomKubernetesEntity<V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageSpec, V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageStatus>
+{
+    [Description("Specification for UpCloud router entity: https://developers.upcloud.com/1.3/13-networks/#create-router")]
+    public class V1Alpha1ObjectStorageSpec
+    {
+        [Length(MaxLength = 36, MinLength = -1)]
+        [Description("UUID of already existing object storage instance")]
+        public string Id { get; set; } = string.Empty;
+
+        [Required]
+        [Length(MinLength = 1, MaxLength = 255)]
+        [Description("Region, see: https://developers.upcloud.com/1.3/21-managed-object-storage/#list-regions")]
+        public string Region { get; set; } = string.Empty;
+
+        [Required]
+        [Pattern("stopped|started")]
+        [Description("Service status, see: https://developers.upcloud.com/1.3/21-managed-object-storage/#service-configured-status")]
+        public string ConfiguredStatus { get; set; } = string.Empty;
+
+        [Items(MaxItems = 8, MinItems = 0)]
+        [Description("Contains blocks that define static routes for this router.")]
+        public Collection<Network> Networks { get; set; } = new ();
+
+        [Required]
+        [Items(MaxItems = 50, MinItems = 0)]
+        [Description("List of cloud Users allowed to use object storage, see: https://developers.upcloud.com/1.3/21-managed-object-storage/#list-users")]
+        public Collection<User> Users { get; set; } = new ();
+
+        [Items(MaxItems = 255, MinItems = -1)]
+        [Description("Labels used for service filtering, see labels usage https://developers.upcloud.com/1.3/21-managed-object-storage/#labels-usage-examples")]
+        public Collection<Label> Labels { get; set; } = new ();
+    }
+
+    [Description("Network that can be used to access the object storage instance")]
+    public class Network
+    {
+        [Required]
+        [Length(MinLength = 1, MaxLength = 255)]
+        [Description("Valid network name")]
+        public string Name { get; set; } = string.Empty;
+
+        [Required]
+        [Pattern("IPv4|IPv6")]
+        [Description("Network family name")]
+        public string Family { get; set; } = string.Empty;
+
+        [Required]
+        [Pattern("private|public")]
+        [Description("Network type")]
+        public string Type { get; set; } = string.Empty;
+
+        [Length(MaxLength = 36, MinLength = -1)]
+        [Description("Network uuid")]
+        public string Id { get; set; } = string.Empty;
+    }
+
+    [Description("Cloud API user that has access to the object storage instance")]
+    public class User
+    {
+        [Required]
+        [Length(MaxLength = -1, MinLength = 1)]
+        [Description("Valid cloud user username")]
+        public string Username { get; set; }  = string.Empty;
+    }
+
+    [Description("Label used for service filtering, see: https://developers.upcloud.com/1.3/21-managed-object-storage/#list-labels")]
+    public class Label
+    {
+        [Required]
+        public string Name { get; set; }  = string.Empty;
+        [Required]
+        public string Value { get; set; } = string.Empty;
+    }
+
+    public class V1Alpha1ObjectStorageStatus
+    {
+        [Description("Object storage instance uuid")]
+        public string Id { get; set; } = string.Empty;
+
+        [Description("Configured service status, see: https://developers.upcloud.com/1.3/21-managed-object-storage/#service-configured-status")]
+        public string ConfiguredStatus { get; set; } = string.Empty;
+
+        [Description("Object storage instance creation time")]
+        public string CreatedAt { get; set; } = string.Empty;
+
+        [Description("List of endpoints that can be used to access the instance")]
+        public Collection<Endpoint> Endpoints { get; set; } = new ();
+
+        [Description("List of attached networks that can be used to access the instance")]
+        public Collection<Network> Networks { get; set; } = new ();
+
+        [Description("Current operational state of the object storage instance")]
+        public string OperationalState { get; set; } = string.Empty;
+
+        [Description("Region where the object storage instance is running")]
+        public string Region { get; set; } = string.Empty;
+
+        [Description("Object storage instance last updated time")]
+        public string UpdatedAt { get; set; } = string.Empty;
+
+        [Description("List of cloud API users configured to have access to the object storage instance")]
+        public Collection<ConnectedUser> Users { get; set; } = new ();
+    }
+
+    [Description("Object storage instance endpoint")]
+    public class Endpoint
+    {
+        [Description("Endpoint domain name")]
+        public string DomainName { get; set; } = string.Empty;
+        [Description("Endpoint type")]
+        public string Type { get; set; } = string.Empty;
+    }
+
+    [Description("Object storage instance endpoint")]
+    public class ConnectedUser
+    {
+        public string Username { get; set; } = string.Empty;
+        public string OperationalState { get; set; } = string.Empty;
+        public string UpdatedAt { get; set; } = string.Empty;
+        public string CreatedAt { get; set; } = string.Empty;
+        public Collection<AccessKey> AccessKeys { get; set; } = new ();
+    }
+
+    [Description("Object storage access key")]
+    public class AccessKey
+    {
+        public string Name { get; set; } = string.Empty;
+        public string Enabled { get; set; } = string.Empty;
+        public string AccessKeyId { get; set; } = string.Empty;
+        public string CreatedAt { get; set; } = string.Empty;
+        public string UpdatedAt { get; set; } = string.Empty;
+        public string LastUsedAt { get; set; } = string.Empty;
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/Finalizer/V1Alpha1ObjectStorageFinalizer.cs b/src/UpcloudApiKubernetesOperator/Finalizer/V1Alpha1ObjectStorageFinalizer.cs
new file mode 100644
index 0000000..444cd7c
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/Finalizer/V1Alpha1ObjectStorageFinalizer.cs
@@ -0,0 +1,19 @@
+using k8s.Models;
+using KubeOps.Operator.Finalizer;
+
+using UpcloudApiKubernetesOperator.Entities;
+
+namespace UpcloudApiKubernetesOperator.Finalizer;
+
+public class V1Alpha1ObjectStorage2Finalizer : IResourceFinalizer<V1Alpha1ObjectStorage2>
+{
+    private readonly ILogger<V1Alpha1ObjectStorage2Finalizer> _logger;
+
+    public V1Alpha1ObjectStorage2Finalizer(ILogger<V1Alpha1ObjectStorage2Finalizer> logger) => _logger = logger;
+
+    public Task FinalizeAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        _logger.LogInformation($"entity {entity.Name()} called {nameof(FinalizeAsync)}.");
+        return Task.CompletedTask;
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/Program.cs b/src/UpcloudApiKubernetesOperator/Program.cs
index 9a56b13..38db522 100644
--- a/src/UpcloudApiKubernetesOperator/Program.cs
+++ b/src/UpcloudApiKubernetesOperator/Program.cs
@@ -3,6 +3,7 @@
 var builder = WebApplication.CreateBuilder(args);
 builder.Services.AddKubernetesOperator();
 builder.Services.AddControllers();
+builder.Services.AddHttpClient();
 
 var app = builder.Build();
 

From 2cc9f6d5ae6b22b5afcce7d0b30fc0d69b99662e Mon Sep 17 00:00:00 2001
From: visdmin <vili@kiho.fi>
Date: Mon, 30 Oct 2023 01:01:47 +0200
Subject: [PATCH 2/6] Adding idea of UpC API client.

---
 src/UpcloudApiKubernetesOperator/Program.cs   |  12 +-
 .../IServiceCollectionExtensions.cs           |  33 ++++
 .../ObjectStorageV2/IObjectStorageV2Client.cs |  13 ++
 .../Models/Requests/CreateInstanceRequests.cs |  99 ++++++++++++
 .../Models/Responses/BucketMetrics.cs         |  17 +++
 .../Responses/CreateInstanceResponse.cs       |   9 ++
 .../Responses/DeleteInstanceResponse.cs       |  11 ++
 .../Models/Responses/ErrorResponse.cs         |  21 +++
 .../Responses/InstanceDetailsResponse.cs      | 141 ++++++++++++++++++
 .../ObjectStorageV2/Models/Responses/Label.cs |  14 ++
 .../Responses/ReplaceInstanceResponse.cs      |  11 ++
 .../ObjectStorageV2/ObjectStorageV2Client.cs  | 126 ++++++++++++++++
 .../UpCloudApi/Options/UpCloudApiOptions.cs   |  47 ++++++
 .../UpCloudApi/UpCloudApiClient.cs            |  23 +++
 .../appsettings.Development.json              |  18 ++-
 .../appsettings.json                          |  22 ++-
 16 files changed, 600 insertions(+), 17 deletions(-)
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/CreateInstanceRequests.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/BucketMetrics.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateInstanceResponse.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/DeleteInstanceResponse.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ErrorResponse.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/InstanceDetailsResponse.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/Label.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ReplaceInstanceResponse.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/Options/UpCloudApiOptions.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/UpCloudApiClient.cs

diff --git a/src/UpcloudApiKubernetesOperator/Program.cs b/src/UpcloudApiKubernetesOperator/Program.cs
index 38db522..72400ce 100644
--- a/src/UpcloudApiKubernetesOperator/Program.cs
+++ b/src/UpcloudApiKubernetesOperator/Program.cs
@@ -1,9 +1,15 @@
 using KubeOps.Operator;
+using UpcloudApiKubernetesOperator.Entities;
+using UpcloudApiKubernetesOperator.UpCloudApi.Extensions.DependencyInjection;
 
 var builder = WebApplication.CreateBuilder(args);
-builder.Services.AddKubernetesOperator();
-builder.Services.AddControllers();
-builder.Services.AddHttpClient();
+
+builder.Host.ConfigureServices((context, services) => {
+    services.AddUpCloudApiClient(context.Configuration);
+    services.AddKubernetesOperator();
+    services.AddControllers();
+
+});
 
 var app = builder.Build();
 
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
new file mode 100644
index 0000000..bc4b442
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
@@ -0,0 +1,33 @@
+using IdentityModel.Client;
+using Microsoft.Extensions.Options;
+
+using UpcloudApiKubernetesOperator.UpCloudApi.Options;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.Extensions.DependencyInjection;
+
+public static class IServiceCollectionExtensions
+{
+    public static IServiceCollection AddUpCloudApiClient(this IServiceCollection services, IConfiguration configuration)
+    {
+        services.Configure<UpCloudApiOptions>(
+            config: configuration.GetRequiredSection(key: UpCloudApiOptions.DEFAULT_SECTION_NAME)
+        );
+
+        services.AddHttpClient<UpCloudApiClient>((serviceProvider, httpClient) => {
+            var apiConfiguration = serviceProvider.GetRequiredService<IOptions<UpCloudApiOptions>>().Value;
+
+            httpClient.Timeout     = TimeSpan.FromSeconds(apiConfiguration.RequestTimeoutSeconds);
+            httpClient.BaseAddress = new Uri(apiConfiguration.Endpoint);
+
+            httpClient.SetBasicAuthentication(
+                userName: apiConfiguration.Username,
+                password: apiConfiguration.Password
+            );
+        });
+
+        services.AddSingleton<IObjectStorageV2Client, ObjectStorageV2Client>();
+
+        return services;
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
new file mode 100644
index 0000000..3d77a6e
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
@@ -0,0 +1,13 @@
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
+
+public interface IObjectStorageV2Client
+{
+    Task<InstanceDetailsResponse?> GetDetails(string instanceUuid, CancellationToken cancellationToken = default);
+    Task<IReadOnlyCollection<BucketMetric>> GetBucketMetrics(string instanceUuid, CancellationToken cancellationToken = default);
+    Task<CreateInstanceResponse> CreateInstance(InstanceDetails instanceDetails, CancellationToken cancellationToken = default);
+    Task<ReplaceInstanceResponse> ReplaceInstance(string instanceUuid, InstanceDetails instanceDetails, CancellationToken cancellationToken = default);
+    Task<DeleteInstanceResponse> DeleteInstance(string instanceUuid, CancellationToken cancellationToken = default);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/CreateInstanceRequests.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/CreateInstanceRequests.cs
new file mode 100644
index 0000000..4389bb3
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/CreateInstanceRequests.cs
@@ -0,0 +1,99 @@
+using System.Collections.ObjectModel;
+using System.Text.Json.Serialization;
+
+using UpcloudApiKubernetesOperator.Entities;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
+public readonly struct InstanceDetails
+{
+    [JsonPropertyName("region")]
+    public readonly string Region;
+
+    [JsonPropertyName("configured_status")]
+    public readonly string ConfiguredStatus;
+
+    [JsonPropertyName("networks")]
+    public readonly IReadOnlyCollection<Network> Networks;
+
+    [JsonPropertyName("users")]
+    public readonly IReadOnlyCollection<User> Users;
+
+    [JsonPropertyName("labels")]
+    public readonly IReadOnlyCollection<Label>? Labels;
+
+    [JsonConstructor]
+    public InstanceDetails(
+        string region,
+        string configuredStatus,
+        IReadOnlyCollection<Network> networks,
+        IReadOnlyCollection<User> users,
+        IReadOnlyCollection<Label>? labels
+    ) => (Region, ConfiguredStatus, Networks, Users, Labels) = (region, configuredStatus, networks, users, labels);
+
+    public readonly struct Network
+    {
+        [JsonPropertyName("name")]
+        public readonly string Name;
+
+        [JsonPropertyName("uuid")]
+        public readonly string? UUID;
+
+        [JsonPropertyName("type")]
+        public readonly string Type;
+
+        [JsonPropertyName("family")]
+        public readonly string Family;
+
+        [JsonConstructor]
+        public Network(string name, string? uuid, string type, string family) => (Name, UUID, Type, Family) = (name, uuid, type, family);
+    }
+
+    public readonly struct User
+    {
+        [JsonPropertyName("username")]
+        public readonly string Username;
+
+        [JsonConstructor]
+        public User(string username) => Username = username;
+    }
+
+    public readonly struct Label
+    {
+        [JsonPropertyName("key")]
+        public readonly string Key;
+
+        [JsonPropertyName("value")]
+        public readonly string Value;
+
+        [JsonConstructor]
+        public Label(string key, string value) => (Key, Value) = (key, value);
+    }
+
+    public static InstanceDetails FromKubernetesSpec(V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageSpec spec) =>
+        new (
+            region:           spec.Region,
+            configuredStatus: spec.ConfiguredStatus,
+            networks:         new ReadOnlyCollection<Network>(
+                spec.Networks.Select(x => new Network(
+                    name:   x.Name,
+                    uuid:   string.IsNullOrEmpty(x.Id) ? null : x.Id,
+                    type:   x.Type,
+                    family: x.Family
+                )).ToArray()
+            ),
+            users:           new ReadOnlyCollection<User>(
+                spec.Users.Select(
+                    x => new User(username: x.Username)
+                ).ToArray()
+            ),
+            labels:          spec.Labels.Count switch {
+                0 => null,
+                _ => new ReadOnlyCollection<Label>(
+                    spec.Labels.Select(x => new Label(
+                        key:   x.Name,
+                        value: x.Value
+                    )).ToArray()
+                )
+            }
+        );
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/BucketMetrics.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/BucketMetrics.cs
new file mode 100644
index 0000000..4c25347
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/BucketMetrics.cs
@@ -0,0 +1,17 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+public readonly struct BucketMetric
+{
+    [JsonPropertyName("name")]
+    public readonly string Name;
+
+    [JsonPropertyName("total_objects")]
+    public readonly int TotalObjects;
+
+    [JsonPropertyName("total_size_bytes")]
+    public readonly int TotalSizeBytes;
+
+    [JsonConstructor]
+    public BucketMetric(string name, int totalObjects, int totalSizeBytes) => (Name, TotalObjects, TotalSizeBytes) = (name, totalObjects, totalSizeBytes);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateInstanceResponse.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateInstanceResponse.cs
new file mode 100644
index 0000000..fd742d3
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateInstanceResponse.cs
@@ -0,0 +1,9 @@
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+public readonly struct CreateInstanceResponse
+{
+    public readonly bool Success;
+    public readonly ErrorResponse? ErrorResponse;
+
+    public CreateInstanceResponse(bool success, ErrorResponse? errorResponse) => (Success, ErrorResponse) = (success, errorResponse);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/DeleteInstanceResponse.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/DeleteInstanceResponse.cs
new file mode 100644
index 0000000..8a328c3
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/DeleteInstanceResponse.cs
@@ -0,0 +1,11 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+public readonly struct DeleteInstanceResponse
+{
+    public readonly bool Success;
+    public readonly ErrorResponse? ErrorResponse;
+
+    public DeleteInstanceResponse(bool success, ErrorResponse? errorResponse) => (Success, ErrorResponse) = (success, errorResponse);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ErrorResponse.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ErrorResponse.cs
new file mode 100644
index 0000000..6dfa512
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ErrorResponse.cs
@@ -0,0 +1,21 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+public readonly struct ErrorResponse
+{
+    [JsonPropertyName("type")]
+    public readonly string Type;
+
+    [JsonPropertyName("title")]
+    public readonly string Title;
+
+    [JsonPropertyName("correlation_id")]
+    public readonly string CorrelationId;
+
+    [JsonPropertyName("status")]
+    public readonly int Status;
+
+    [JsonConstructor]
+    public ErrorResponse(string type, string title, string correlationId, int status) => (Type, Title, CorrelationId, Status) = (type, type, correlationId, status);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/InstanceDetailsResponse.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/InstanceDetailsResponse.cs
new file mode 100644
index 0000000..e902d47
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/InstanceDetailsResponse.cs
@@ -0,0 +1,141 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+public readonly struct InstanceDetailsResponse
+{
+    [JsonPropertyName("uuid")]
+    public readonly string UUID;
+
+    [JsonPropertyName("configured_status")]
+    public readonly string ConfiguredStatus;
+
+    [JsonPropertyName("operational_state")]
+    public readonly string OperationalState;
+
+    [JsonPropertyName("region")]
+    public readonly string Region;
+
+    [JsonPropertyName("created_at")]
+    public readonly DateTime CreatedAt;
+
+    [JsonPropertyName("updated_at")]
+    public readonly DateTime UpdatedAt;
+
+    [JsonPropertyName("endpoints")]
+    public readonly IReadOnlyCollection<Endpoint> Endpoints;
+
+    [JsonPropertyName("labels")]
+    public readonly IReadOnlyCollection<Label> Labels;
+
+    [JsonPropertyName("networks")]
+    public readonly IReadOnlyCollection<Network> Networks;
+
+    [JsonPropertyName("users")]
+    public readonly IReadOnlyCollection<User> Users;
+
+    [JsonConstructor]
+    public InstanceDetailsResponse(
+        string uuid,
+        string configuredStatus,
+        string operationalState,
+        string region,
+        DateTime createdAt,
+        DateTime updatedAt,
+        IReadOnlyCollection<Endpoint> endpoints,
+        IReadOnlyCollection<Label> labels,
+        IReadOnlyCollection<Network> networks,
+        IReadOnlyCollection<User> users
+    ) =>
+    (UUID, ConfiguredStatus, OperationalState, Region, CreatedAt, UpdatedAt, Endpoints, Labels, Networks, Users) =
+    (uuid, configuredStatus, operationalState, region, createdAt, updatedAt, endpoints, labels, networks, users);
+}
+
+public readonly struct Endpoint
+{
+    [JsonPropertyName("type")]
+    public readonly string Type;
+
+    [JsonPropertyName("domain_name")]
+    public readonly string DomainName;
+
+    [JsonConstructor]
+    public Endpoint(string type, string domainName) => (Type, DomainName) = (type, domainName);
+}
+
+public readonly struct Network
+{
+    [JsonPropertyName("uuid")]
+    public readonly string? UUID;
+
+    [JsonPropertyName("name")]
+    public readonly string Name;
+
+    [JsonPropertyName("family")]
+    public readonly string Family;
+
+    [JsonPropertyName("type")]
+    public readonly string Type;
+
+    [JsonConstructor]
+    public Network(string? uuid, string name, string family, string type) => (UUID, Name, Family, Type) = (uuid, name, family, type);
+}
+
+public readonly struct User
+{
+    [JsonPropertyName("username")]
+    public readonly string Username;
+
+    [JsonPropertyName("operational_state")]
+    public readonly string OperationalState;
+
+    [JsonPropertyName("created_at")]
+    public readonly DateTime CreatedAt;
+
+    [JsonPropertyName("updated_at")]
+    public readonly DateTime UpdatedAt;
+
+    [JsonPropertyName("access_keys")]
+    public readonly IReadOnlyCollection<AccessKey> AccessKeys;
+
+    [JsonConstructor]
+    public User(
+        string username,
+        string operationalState,
+        DateTime createdAt,
+        DateTime updatedAt,
+        IReadOnlyCollection<AccessKey> accessKeys
+    ) => (Username, OperationalState, CreatedAt, UpdatedAt, AccessKeys) = (username, operationalState, createdAt, updatedAt, accessKeys);
+
+}
+
+public readonly struct AccessKey
+{
+    [JsonPropertyName("access_key_id")]
+    public readonly string Id;
+
+    [JsonPropertyName("created_at")]
+    public readonly DateTime CreatedAt;
+
+    [JsonPropertyName("enabled")]
+    public readonly bool Enabled;
+
+    [JsonPropertyName("last_used_at")]
+    public readonly DateTime LastUsedAt;
+
+    [JsonPropertyName("name")]
+    public readonly string Name;
+
+    [JsonPropertyName("updated_at")]
+    public readonly DateTime UpdatedAt;
+
+    [JsonConstructor]
+    public AccessKey(
+        string id,
+        DateTime createdAt,
+        bool enabled,
+        DateTime lastUsedAt,
+        string name,
+        DateTime updatedAt
+    ) => (Id, CreatedAt, Enabled, LastUsedAt, Name, UpdatedAt) = (id, createdAt, enabled, lastUsedAt, name, updatedAt);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/Label.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/Label.cs
new file mode 100644
index 0000000..5bbfb47
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/Label.cs
@@ -0,0 +1,14 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+public readonly struct Label
+{
+    [JsonPropertyName("key")]
+    public readonly string Key;
+
+    [JsonPropertyName("value")]
+    public readonly string Value;
+
+    [JsonConstructor]
+    public Label(string key, string value) => (Key, Value) = (key, value);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ReplaceInstanceResponse.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ReplaceInstanceResponse.cs
new file mode 100644
index 0000000..f0ef0bc
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/ReplaceInstanceResponse.cs
@@ -0,0 +1,11 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+public readonly struct ReplaceInstanceResponse
+{
+    public readonly bool Success;
+    public readonly ErrorResponse? ErrorResponse;
+
+    public ReplaceInstanceResponse(bool success, ErrorResponse? errorResponse) => (Success, ErrorResponse) = (success, errorResponse);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
new file mode 100644
index 0000000..8391d5e
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
@@ -0,0 +1,126 @@
+using System.Collections.ObjectModel;
+
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
+using k8s.Models;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
+
+internal sealed class ObjectStorageV2Client : UpCloudApiClient, IObjectStorageV2Client
+{
+    public ObjectStorageV2Client(IHttpClientFactory httpClientFactory, ILogger<UpCloudApiClient> logger) : base(httpClientFactory, logger) { }
+
+    public async Task<InstanceDetailsResponse?> GetDetails(string instanceUuid, CancellationToken cancellationToken = default)
+    {
+        try {
+            return await HttpClient.GetFromJsonAsync<InstanceDetailsResponse>(
+                requestUri:        string.Format("/1.3/object-storage-2/{0}", instanceUuid),
+                options:           JsonSerializerOptions,
+                cancellationToken: cancellationToken
+            );
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Requesting object storage v2 details from upc api failed");
+            return null;
+        }
+    }
+
+    public async Task<IReadOnlyCollection<BucketMetric>> GetBucketMetrics(string instanceUuid, CancellationToken cancellationToken = default)
+    {
+        try {
+            var response = await HttpClient.GetFromJsonAsync<BucketMetric[]>(
+                requestUri:        string.Format("1.3/object-storage-2/{0}/metrics/buckets", instanceUuid),
+                options:           JsonSerializerOptions,
+                cancellationToken: cancellationToken
+            );
+
+            return new ReadOnlyCollection<BucketMetric>(response ?? Array.Empty<BucketMetric>());
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Requesting object storage v2 bucket metrics from upc api failed");
+            return new ReadOnlyCollection<BucketMetric>(Array.Empty<BucketMetric>());
+        }
+    }
+
+    public async Task<CreateInstanceResponse> CreateInstance(InstanceDetails instanceDetails, CancellationToken cancellationToken = default)
+    {
+        try {
+            var response = await HttpClient.PostAsJsonAsync<InstanceDetails>(
+                requestUri:        "/1.3/object-storage-2",
+                value:             instanceDetails,
+                options:           JsonSerializerOptions,
+                cancellationToken: cancellationToken
+            );
+
+            if (response.IsSuccessStatusCode) {
+                return new (success: true, errorResponse: null);
+            }
+
+            return new (
+                success:       true,
+                errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
+                    options: JsonSerializerOptions,
+                    cancellationToken: cancellationToken
+                )
+            );
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Create new object storage 2 instance request failed");
+            return new (success: false, errorResponse: null);
+        }
+    }
+
+    public async Task<ReplaceInstanceResponse> ReplaceInstance(string instanceUuid, InstanceDetails instanceDetails, CancellationToken cancellationToken = default)
+    {
+        try {
+            var response = await HttpClient.PutAsJsonAsync<InstanceDetails>(
+                requestUri:        string.Format("/1.3/object-storage-2/{0}", instanceUuid),
+                value:             instanceDetails,
+                options:           JsonSerializerOptions,
+                cancellationToken: cancellationToken
+            );
+
+            if (response.IsSuccessStatusCode) {
+                return new (success: true, errorResponse: null);
+            }
+
+            return new (
+                success:       true,
+                errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
+                    options: JsonSerializerOptions,
+                    cancellationToken: cancellationToken
+                )
+            );
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Replace new object storage 2 instance request failed");
+            return new (success: false, errorResponse: null);
+        }
+    }
+
+    public async Task<DeleteInstanceResponse> DeleteInstance(string instanceUuid, CancellationToken cancellationToken = default)
+    {
+        try {
+            var response = await HttpClient.DeleteAsync(
+                requestUri:        string.Format("/1.3/object-storage-2/{0}", instanceUuid),
+                cancellationToken: cancellationToken
+            );
+
+            if (response.IsSuccessStatusCode) {
+                return new (success: true, errorResponse: null);
+            }
+
+            return new (
+                success:       true,
+                errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
+                    options: JsonSerializerOptions,
+                    cancellationToken: cancellationToken
+                )
+            );
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Delete new object storage 2 instance request failed");
+            return new (success: false, errorResponse: null);
+        }
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/Options/UpCloudApiOptions.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/Options/UpCloudApiOptions.cs
new file mode 100644
index 0000000..c067b2b
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/Options/UpCloudApiOptions.cs
@@ -0,0 +1,47 @@
+using System.Collections.ObjectModel;
+using Microsoft.Extensions.Options;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.Options;
+
+public class UpCloudApiOptions
+{
+    public const string DEFAULT_SECTION_NAME = "UpCloudApiOptions";
+    public string Endpoint           { get; init; } = "https://api.upcloud.com/";
+    public string Username           { get; init; } = string.Empty;
+    public string Password           { get; init; } = string.Empty;
+    public int RequestTimeoutSeconds { get; init; } = default;
+
+    public class Validator : IValidateOptions<UpCloudApiOptions>
+    {
+        public ValidateOptionsResult Validate(string? name, UpCloudApiOptions options)
+        {
+            Collection<string>? errors = null;
+
+            if (string.IsNullOrEmpty(options.Endpoint)) {
+                (errors ??= new ()).Add($"'{nameof(options.Endpoint)}' cannot be null or empty");
+            }
+
+            if (!Uri.TryCreate(uriString: options.Endpoint, creationOptions: new UriCreationOptions(), out _)) {
+                (errors ??= new ()).Add($"'{nameof(options.Endpoint)}' has to be parsable to valid uri");
+            }
+
+            if (string.IsNullOrEmpty(options.Username)) {
+                (errors ??= new ()).Add($"'{nameof(options.Username)}' cannot be null or empty");
+            }
+
+            if (string.IsNullOrEmpty(options.Password)) {
+                (errors ??= new ()).Add($"'{nameof(options.Password)}' cannot be null or empty");
+            }
+
+            if (options.RequestTimeoutSeconds < 1) {
+                (errors ??= new ()).Add($"'{nameof(options.RequestTimeoutSeconds)}' has to be positive integer");
+            }
+
+            if (errors is not null) {
+                return ValidateOptionsResult.Fail(errors);
+            }
+
+            return ValidateOptionsResult.Success;
+        }
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/UpCloudApiClient.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/UpCloudApiClient.cs
new file mode 100644
index 0000000..10683af
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/UpCloudApiClient.cs
@@ -0,0 +1,23 @@
+using System.Text.Json;
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi;
+
+internal abstract class UpCloudApiClient
+{
+    protected readonly HttpClient HttpClient;
+    protected readonly ILogger Logger;
+    protected readonly JsonSerializerOptions JsonSerializerOptions;
+
+    public UpCloudApiClient(IHttpClientFactory httpClientFactory, ILogger<UpCloudApiClient> logger)
+    {
+        HttpClient            = httpClientFactory.CreateClient(name: typeof(UpCloudApiClient).Name);
+        Logger                = logger;
+        JsonSerializerOptions = new JsonSerializerOptions {
+            IncludeFields            = true,
+            IgnoreReadOnlyProperties = false,
+            IgnoreReadOnlyFields     = false,
+            DefaultIgnoreCondition   = JsonIgnoreCondition.WhenWritingNull
+        };
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/appsettings.Development.json b/src/UpcloudApiKubernetesOperator/appsettings.Development.json
index 8983e0f..09183c2 100644
--- a/src/UpcloudApiKubernetesOperator/appsettings.Development.json
+++ b/src/UpcloudApiKubernetesOperator/appsettings.Development.json
@@ -1,9 +1,15 @@
 {
-  "Logging": {
-    "LogLevel": {
-      "Default": "Information",
-      "Microsoft": "Warning",
-      "Microsoft.Hosting.Lifetime": "Information"
+    "Logging": {
+        "LogLevel": {
+            "Default": "Debug",
+            "Microsoft": "Warning",
+            "Microsoft.Hosting.Lifetime": "Debug"
+        }
+    },
+    "UpCloudApiOptions": {
+        "Endpoint": "https://api.upcloud.com",
+        "Username": "cloud-api-user-username",
+        "Password": "cloud-api-user-password",
+        "RequestTimeoutSeconds": 30
     }
-  }
 }
diff --git a/src/UpcloudApiKubernetesOperator/appsettings.json b/src/UpcloudApiKubernetesOperator/appsettings.json
index d9d9a9b..f19a647 100644
--- a/src/UpcloudApiKubernetesOperator/appsettings.json
+++ b/src/UpcloudApiKubernetesOperator/appsettings.json
@@ -1,10 +1,16 @@
 {
-  "Logging": {
-    "LogLevel": {
-      "Default": "Information",
-      "Microsoft": "Warning",
-      "Microsoft.Hosting.Lifetime": "Information"
-    }
-  },
-  "AllowedHosts": "*"
+    "Logging": {
+        "LogLevel": {
+            "Default": "Information",
+            "Microsoft": "Warning",
+            "Microsoft.Hosting.Lifetime": "Information"
+        }
+    },
+    "AllowedHosts": "*",
+    "UpCloudApiOptions": {
+      "Endpoint": "https://api.upcloud.com",
+      "Username": "cloud-api-user-username",
+      "Password": "cloud-api-user-password",
+      "RequestTimeoutSeconds": 30
+  }
 }

From 124ecc56f3ac3c4787dae936b6248da3bce6ef3b Mon Sep 17 00:00:00 2001
From: visdmin <vili@kiho.fi>
Date: Mon, 30 Oct 2023 01:03:33 +0200
Subject: [PATCH 3/6] Adding ideas of how to use the WIP UpC api client into
 object storage v2 entity controller.

---
 .../V1Alpha1ObjectStorage2Controller.cs       | 214 ++++++++++++++++--
 .../Entities/V1Alpha1ObjectStorage2.cs        |  13 +-
 2 files changed, 206 insertions(+), 21 deletions(-)

diff --git a/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs b/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs
index a02ef9e..7722276 100644
--- a/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs
+++ b/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2Controller.cs
@@ -1,18 +1,21 @@
 using System.Text.Json;
+using System.Collections.ObjectModel;
 
-using k8s;
 using k8s.Models;
 using KubeOps.Operator.Controller;
 using KubeOps.Operator.Controller.Results;
 using KubeOps.Operator.Finalizer;
-using KubeOps.Operator.Kubernetes;
 using KubeOps.Operator.Rbac;
+using KubeOps.KubernetesClient;
 
 using UpcloudApiKubernetesOperator.Finalizer;
 using UpcloudApiKubernetesOperator.Entities;
-using KubeOps.KubernetesClient;
-using IdentityModel.Client;
-
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+using System.Threading.Tasks.Dataflow;
+using Microsoft.IdentityModel.Tokens;
+using System.Data;
 
 namespace UpcloudApiKubernetesOperator.Controller.Storage;
 
@@ -20,39 +23,210 @@ namespace UpcloudApiKubernetesOperator.Controller.Storage;
 public class V1Alpha1ObjectStorage2Controller : IResourceController<V1Alpha1ObjectStorage2>
 {
     private readonly IKubernetesClient KubernetesClient;
-    private readonly HttpClient HttpClient;
+    private readonly IObjectStorageV2Client UpcApiClient;
     private readonly ILogger<V1Alpha1ObjectStorage2Controller> Logger;
     private readonly IFinalizerManager<V1Alpha1ObjectStorage2> FinalizerManager;
-    private readonly static TimeSpan ResourceInterval = TimeSpan.FromSeconds(30);
-    private readonly JsonSerializerOptions JsonSerializerOptions = new JsonSerializerOptions { WriteIndented = true };
+    private readonly static TimeSpan ReconcileInterval = TimeSpan.FromSeconds(30);
+    private readonly JsonSerializerOptions SerializerOptions;
 
     public V1Alpha1ObjectStorage2Controller(
         IKubernetesClient kubernetesClient,
-        IHttpClientFactory httpClientFactory,
+        IObjectStorageV2Client upcApiClient,
         ILogger<V1Alpha1ObjectStorage2Controller> logger,
         IFinalizerManager<V1Alpha1ObjectStorage2> finalizerManager
     ) {
-        KubernetesClient = kubernetesClient;
-        HttpClient       = httpClientFactory.CreateClient();
-        Logger           = logger;
-        FinalizerManager = finalizerManager;
+        KubernetesClient  = kubernetesClient;
+        UpcApiClient      = upcApiClient;
+        Logger            = logger;
+        FinalizerManager  = finalizerManager;
+        SerializerOptions = new JsonSerializerOptions {
+            IgnoreReadOnlyFields     = false,
+            IgnoreReadOnlyProperties = false,
+            WriteIndented            = true
+        };
     }
 
     public async Task<ResourceControllerResult?> ReconcileAsync(V1Alpha1ObjectStorage2 entity)
     {
+        if (entity.Status.ReconcileState is V1Alpha1ObjectStorage2.ReconcileState.FAILURE or V1Alpha1ObjectStorage2.ReconcileState.PAUSED) {
+            Logger.LogInformation("Reconciling skipped (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
+                new { kind = entity.GetType(), name = entity.Name(), reconcileStatus = entity.Status.ReconcileState },
+                JsonSerializer.Serialize(entity.Spec,   options: SerializerOptions),
+                JsonSerializer.Serialize(entity.Status, options: SerializerOptions)
+            );
+        }
+
+        await FinalizerManager.RegisterFinalizerAsync<V1Alpha1ObjectStorage2Finalizer>(entity);
+
         Logger.LogInformation("Reconciling (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
             new { kind = entity.GetType(), name = entity.Name() },
-            JsonSerializer.Serialize(entity.Spec,   options: JsonSerializerOptions),
-            JsonSerializer.Serialize(entity.Status, options: JsonSerializerOptions)
+            JsonSerializer.Serialize(entity.Spec,   options: SerializerOptions),
+            JsonSerializer.Serialize(entity.Status, options: SerializerOptions)
         );
 
-        // TODO: Research what is the best way to obtain required api credentials from a secret.
-        //       Maybe during the operator startup ?
-        // KubernetesClient.Get<V1Secret>()
+        // Currently object storage v2 api does not support creation of multiple instances
+        // TODO: update this logic to set instance uuid to the status when API is updated.
+        if (string.IsNullOrEmpty(entity.Status.Id) && string.IsNullOrEmpty(entity.Spec.Id)) {
+            await CreateInstance(entity);
+            return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+        }
 
-        await FinalizerManager.RegisterFinalizerAsync<V1Alpha1ObjectStorage2Finalizer>(entity);
+        var instanceDetails = await UpcApiClient.GetDetails(instanceUuid: entity.Spec.Id);
+        if (instanceDetails is null) {
+            Logger.LogWarning("Entity deleted because not found in upc api (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
+                new { kind = entity.GetType(), name = entity.Name(), reconcileStatus = entity.Status.ReconcileState },
+                JsonSerializer.Serialize(entity.Spec,   options: SerializerOptions),
+                JsonSerializer.Serialize(entity.Status, options: SerializerOptions)
+            );
+            await KubernetesClient.Delete(entity);
+            return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+        }
+
+        if (CheckIfUpdateIsRequired(entity, instanceDetails.Value)) {
+            await UpdateStatus(V1Alpha1ObjectStorage2.ReconcileState.UPDATING, entity, instanceDetails.Value);
+            await TryUpdateInstance(entity);
+            return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+        }
+
+        await UpdateStatus(V1Alpha1ObjectStorage2.ReconcileState.UP_TO_DATE, entity, instanceDetails.Value);
+        return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+    }
+
+    private async Task CreateInstance(V1Alpha1ObjectStorage2 entity)
+    {
+        var response = await UpcApiClient.CreateInstance(
+            instanceDetails: InstanceDetails.FromKubernetesSpec(entity.Spec)
+        );
+
+        if (response.Success is false) {
+            Logger.LogWarning("Creating object storage instance failed, setting reconcile status to failed (error: {errorResponse})",
+                (response.ErrorResponse is not null) ? JsonSerializer.Serialize(response.ErrorResponse) : "n/a"
+            );
+
+            entity.Status.ReconcileState = V1Alpha1ObjectStorage2.ReconcileState.FAILURE;
+            await KubernetesClient.UpdateStatus(entity);
+            return;
+        }
+
+        Logger.LogInformation("Object storage v2 instance created successfully");
+        return;
+    }
+
+    private async Task TryUpdateInstance(V1Alpha1ObjectStorage2 entity)
+    {
+        var response = await UpcApiClient.ReplaceInstance(
+            instanceUuid:    entity.Spec.Id,
+            instanceDetails: InstanceDetails.FromKubernetesSpec(entity.Spec)
+        );
+
+        if (response.Success is false) {
+            Logger.LogWarning("Updating object storage instance failed, setting reconcile status to failed (error: {errorResponse})",
+                (response.ErrorResponse is not null) ? JsonSerializer.Serialize(response.ErrorResponse) : "n/a"
+            );
+
+            entity.Status.ReconcileState = V1Alpha1ObjectStorage2.ReconcileState.FAILURE;
+            await KubernetesClient.UpdateStatus(entity);
+            return;
+        }
+
+        Logger.LogInformation("Updating storage v2 instance created successfully");
+        return;
+    }
+
+    private static bool CheckIfUpdateIsRequired(V1Alpha1ObjectStorage2 entity, InstanceDetailsResponse state)
+    {
+        if (state.ConfiguredStatus != entity.Spec.ConfiguredStatus) {
+            return true;
+        }
+
+        if (state.Region != entity.Spec.Region) {
+            return true;
+        }
+
+        if (state.Networks.Count != entity.Spec.Networks.Count) {
+            return true;
+        }
+
+        foreach (var network in state.Networks) {
+            var equal = entity.Spec.Networks.Where(x =>
+                network.Name   == x.Name   && network.Type == x.Type &&
+                network.Family == x.Family && (network.UUID is null) || network.UUID == x.Id
+            );
+
+            if (equal.IsNullOrEmpty()) {
+                return true;
+            }
+        }
+
+        if (state.Labels.Count != entity.Spec.Labels.Count) {
+            return true;
+        }
+
+        foreach (var label in state.Labels) {
+            var equal = entity.Spec.Labels.Where(x => label.Key == x.Name && label.Value == x.Value);
+            if (equal.IsNullOrEmpty()) {
+                return true;
+            }
+        }
+
+        if (state.Users.Count != entity.Spec.Users.Count) {
+            return true;
+        }
+
+        foreach (var user in state.Users) {
+            var equal = entity.Spec.Users.Where(x => user.Username == x.Username);
+            if (equal.IsNullOrEmpty()) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    public Task UpdateStatus(V1Alpha1ObjectStorage2.ReconcileState reconcileState, V1Alpha1ObjectStorage2 entity, InstanceDetailsResponse state)
+    {
+        entity.Status = new V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageStatus {
+            ReconcileState   = reconcileState,
+            Id               = state.UUID,
+            ConfiguredStatus = state.ConfiguredStatus,
+            CreatedAt        = state.CreatedAt.ToString("s"),
+            Endpoints        = new (
+                state.Endpoints.Select(x => new V1Alpha1ObjectStorage2.Endpoint {
+                    DomainName = x.DomainName,
+                    Type       = x.Type
+                }).ToList()
+            ),
+            Networks         = new (
+                state.Networks.Select(x => new V1Alpha1ObjectStorage2.Network {
+                    Name   = x.Name,
+                    Family = x.Family,
+                    Type   = x.Type,
+                    Id     = x.UUID
+                }).ToList()
+            ),
+            OperationalState = state.OperationalState,
+            Region           = state.Region,
+            UpdatedAt        = state.UpdatedAt.ToString("s"),
+            Users            = new (
+                state.Users.Select(x => new V1Alpha1ObjectStorage2.ConnectedUser{
+                    Username         = x.Username,
+                    OperationalState = x.OperationalState,
+                    UpdatedAt        = x.UpdatedAt.ToString("s"),
+                    CreatedAt        = x.CreatedAt.ToString("s"),
+                    AccessKeys       = new (
+                        x.AccessKeys.Select(x => new V1Alpha1ObjectStorage2.AccessKey {
+                            AccessKeyId = x.Id,
+                            Name        = x.Name,
+                            CreatedAt   = x.CreatedAt.ToString("s"),
+                            LastUsedAt  = x.LastUsedAt.ToString("s"),
+                            UpdatedAt   = x.UpdatedAt.ToString("s")
+                        }).ToList()
+                    )
+                }).ToList()
+            )
+        };
 
-        return ResourceControllerResult.RequeueEvent(ResourceInterval);
+        return KubernetesClient.UpdateStatus(entity);
     }
 
     public Task StatusModifiedAsync(V1Alpha1ObjectStorage2 entity)
diff --git a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
index fcfac92..349512e 100644
--- a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
+++ b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
@@ -60,7 +60,7 @@ public class Network
 
         [Length(MaxLength = 36, MinLength = -1)]
         [Description("Network uuid")]
-        public string Id { get; set; } = string.Empty;
+        public string? Id { get; set; } = null;
     }
 
     [Description("Cloud API user that has access to the object storage instance")]
@@ -83,6 +83,9 @@ public class Label
 
     public class V1Alpha1ObjectStorageStatus
     {
+        [Description("Entity reconcile status")]
+        public ReconcileState ReconcileState { get; set; } = ReconcileState.UPDATING;
+
         [Description("Object storage instance uuid")]
         public string Id { get; set; } = string.Empty;
 
@@ -111,6 +114,14 @@ public class V1Alpha1ObjectStorageStatus
         public Collection<ConnectedUser> Users { get; set; } = new ();
     }
 
+    public enum ReconcileState
+    {
+        PAUSED     = 0,
+        UP_TO_DATE = 1,
+        UPDATING   = 2,
+        FAILURE    = 3,
+    }
+
     [Description("Object storage instance endpoint")]
     public class Endpoint
     {

From a65d1160b556624f710b14dcd5dbafe2b155d466 Mon Sep 17 00:00:00 2001
From: visdmin <vili@kiho.fi>
Date: Mon, 30 Oct 2023 23:36:26 +0200
Subject: [PATCH 4/6] Adding idea of autoloader that allows the controller to
 automatically load existing entities from the api.

This maybe very bad idea.
Feature is nice to have, but the implementation of such behaviour should be maybe isolated to separate K8s job ?
Lets keep it here for now, and think about better solution in the future.
Author suspects that it's not the purpose of the operator to do such a task, much better way could to be define CRD `LoadUpCloudEntitiesJob` or something similar, that would be handle the loading of the entities from the UpC api.

- UpCloud Api client tested locally little here before these changes.
- Creation of new entities seems to work fine with auto loader.

```shell
$ kubectl -n default get objectstorage2s.api.upcloud.com
NAME                                                     RECONCILESTATE   ID                                     CONFIGUREDSTATUS   OPERATIONALSTATE   REGION     UPDATEDAT
object-storage-v2-12c5cbc2-3013-491f-a6f4-eeb38edcda4c   UP_TO_DATE       12c5cbc2-3013-491f-a6f4-eeb38edcda4c   started            running            europe-1   2023-10-30T21:24:00
```
---
 .vscode/settings.json                         |   1 +
 .../AutoLoader/AutoLoaderService.cs           |  69 +++++++++
 .../IServiceCollectionExtensions.cs           |  21 +++
 .../AutoLoader/Loaders/BaseLoader.cs          |  17 +++
 .../IServiceCollectionExtensions.cs           |  10 ++
 .../AutoLoader/Loaders/ILoader.cs             |   6 +
 .../Loaders/ObjectStorageV2Loader.cs          | 134 ++++++++++++++++++
 .../AutoLoader/Options/AutoLoaderOptions.cs   |  37 +++++
 .../Entities/V1Alpha1ObjectStorage2.cs        |  15 ++
 src/UpcloudApiKubernetesOperator/Program.cs   |   4 +-
 .../IServiceCollectionExtensions.cs           |  29 ++--
 .../ObjectStorageV2/IObjectStorageV2Client.cs |   1 +
 .../ObjectStorageV2/ObjectStorageV2Client.cs  |  17 +++
 .../appsettings.Development.json              |   5 +
 .../appsettings.json                          |  15 +-
 15 files changed, 359 insertions(+), 22 deletions(-)
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/AutoLoaderService.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/BaseLoader.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ILoader.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ObjectStorageV2Loader.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/AutoLoader/Options/AutoLoaderOptions.cs

diff --git a/.vscode/settings.json b/.vscode/settings.json
index fcba599..46c37cc 100644
--- a/.vscode/settings.json
+++ b/.vscode/settings.json
@@ -2,6 +2,7 @@
     "cSpell.words": [
         "Finalizer",
         "maxiops",
+        "objectstorages",
         "Peerings"
     ]
 }
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/AutoLoaderService.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/AutoLoaderService.cs
new file mode 100644
index 0000000..3b80164
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/AutoLoaderService.cs
@@ -0,0 +1,69 @@
+using System.Collections.ObjectModel;
+using Microsoft.Extensions.Options;
+using UpcloudApiKubernetesOperator.AutoLoader.Loaders;
+using UpcloudApiKubernetesOperator.AutoLoader.Options;
+
+namespace UpcloudApiKubernetesOperator.AutoLoader;
+
+internal class AutoLoaderService : IHostedService
+{
+    private readonly ReadOnlyCollection<ILoader> Loaders;
+    private readonly ILogger Logger;
+    private readonly AutoLoaderOptions Options;
+    private Task? Runner;
+    private readonly CancellationTokenSource CancellationTokenSource = new();
+
+    public AutoLoaderService(
+        ObjectStorageV2Loader objectStorageV2Loader,
+        IOptions<AutoLoaderOptions> options,
+        ILogger<AutoLoaderService> logger
+    ) {
+        Loaders = new (
+            new ILoader[] {
+                objectStorageV2Loader
+            }
+        );
+        Options = options.Value;
+        Logger  = logger;
+    }
+
+    public Task StartAsync(CancellationToken cancellationToken)
+    {
+        Runner = RunLoaders();
+        Logger.LogInformation("UpCloud entity auto loader enabled (interval: {refreshInterval})", Options.RefreshInterval);
+        return Task.CompletedTask;
+    }
+
+    private async Task RunLoaders()
+    {
+        var interval = TimeSpan.FromSeconds(Options.RefreshInterval);
+
+        while (CancellationTokenSource.IsCancellationRequested is false) {
+            await Task.Delay(interval, cancellationToken: CancellationTokenSource.Token);
+
+            foreach (var loader in Loaders) {
+                try {
+                    await loader.Run(CancellationTokenSource.Token);
+                }
+                catch (Exception ex) {
+                    Logger.LogError(ex, "Executing loader failed (type: {loaderType})", loader.GetType().Name);
+                }
+            }
+        }
+    }
+
+    public async Task StopAsync(CancellationToken cancellationToken)
+    {
+        CancellationTokenSource.Cancel();
+
+        if (Runner is not null && Runner.IsCompleted is false) {
+            try {
+                await Runner;
+            }
+            catch (TaskCanceledException) { }
+            Runner = null;
+        }
+
+        CancellationTokenSource.Dispose();
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/Extensions/DependencyInjection/IServiceCollectionExtensions.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
new file mode 100644
index 0000000..42a76a5
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
@@ -0,0 +1,21 @@
+using Microsoft.Extensions.Options;
+
+using UpcloudApiKubernetesOperator.AutoLoader.Options;
+using UpcloudApiKubernetesOperator.AutoLoader.Loaders.Extensions.DependencyInjection;
+
+namespace UpcloudApiKubernetesOperator.AutoLoader.Extensions.DependencyInjection;
+
+public static class IServiceCollectionExtensions
+{
+    public static IServiceCollection AddAutoLoaderService(this IServiceCollection services, IConfiguration configuration) =>
+        configuration.GetRequiredSection(key: AutoLoaderOptions.DEFAULT_SECTION_NAME) switch {
+            var autoLoaderConfig => autoLoaderConfig.GetValue("Enabled", defaultValue: false) switch {
+                false => services,
+                true  => services
+                    .Configure<AutoLoaderOptions>(config: autoLoaderConfig)
+                    .AddSingleton<IValidateOptions<AutoLoaderOptions>, AutoLoaderOptions.Validator>()
+                    .AddLoaders()
+                    .AddHostedService<AutoLoaderService>()
+            }
+        };
+}
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/BaseLoader.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/BaseLoader.cs
new file mode 100644
index 0000000..eb631e6
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/BaseLoader.cs
@@ -0,0 +1,17 @@
+using KubeOps.KubernetesClient;
+using Microsoft.Extensions.Options;
+using UpcloudApiKubernetesOperator.AutoLoader.Options;
+
+namespace UpcloudApiKubernetesOperator.AutoLoader.Loaders;
+
+internal abstract class BaseLoader : ILoader
+{
+    protected readonly AutoLoaderOptions Options;
+    protected readonly IKubernetesClient KubernetesClient;
+    protected readonly ILogger Logger;
+
+    public BaseLoader(IOptions<AutoLoaderOptions> options, IKubernetesClient kubernetesClient, ILogger<AutoLoaderService> logger) =>
+        (Options, KubernetesClient, Logger) = (options.Value, kubernetesClient, logger);
+
+    public abstract Task Run(CancellationToken cancellationToken);
+}
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/Extensions/DependencyInjection/IServiceCollectionExtensions.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
new file mode 100644
index 0000000..1924d24
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
@@ -0,0 +1,10 @@
+using Microsoft.Extensions.Options;
+using UpcloudApiKubernetesOperator.AutoLoader.Options;
+
+namespace UpcloudApiKubernetesOperator.AutoLoader.Loaders.Extensions.DependencyInjection;
+
+public static class IServiceCollectionExtensions
+{
+    public static IServiceCollection AddLoaders(this IServiceCollection services) => services
+        .AddSingleton<ObjectStorageV2Loader>();
+}
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ILoader.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ILoader.cs
new file mode 100644
index 0000000..39366b8
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ILoader.cs
@@ -0,0 +1,6 @@
+namespace UpcloudApiKubernetesOperator.AutoLoader.Loaders;
+
+internal interface ILoader
+{
+    abstract Task Run(CancellationToken cancellationToken);
+}
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ObjectStorageV2Loader.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ObjectStorageV2Loader.cs
new file mode 100644
index 0000000..4e5bf81
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/Loaders/ObjectStorageV2Loader.cs
@@ -0,0 +1,134 @@
+using System.Collections.ObjectModel;
+
+using Microsoft.Extensions.Options;
+
+using k8s.Models;
+using k8s.Autorest;
+using KubeOps.KubernetesClient;
+
+using UpcloudApiKubernetesOperator.AutoLoader.Options;
+using UpcloudApiKubernetesOperator.Entities;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+namespace UpcloudApiKubernetesOperator.AutoLoader.Loaders;
+
+internal class ObjectStorageV2Loader : BaseLoader
+{
+    protected readonly IObjectStorageV2Client UpCApiClient;
+
+    public ObjectStorageV2Loader(IOptions<AutoLoaderOptions> options, IObjectStorageV2Client upcApiClient, IKubernetesClient kubernetesClient, ILogger<AutoLoaderService> logger)
+        : base(options, kubernetesClient, logger)
+        => UpCApiClient = upcApiClient;
+
+    public override async Task Run(CancellationToken cancellationToken)
+    {
+        Logger.LogDebug("Loading object storage instances from upc api");
+
+        var instancesFromApi = await UpCApiClient.ListInstances(cancellationToken: cancellationToken);
+
+        if (instancesFromApi is null || instancesFromApi.Count == 0) {
+            Logger.LogDebug("Loading object storage instances from upc api completed, no instances found");
+            return;
+        }
+
+        var instancesFromK8s = await KubernetesClient.List<V1Alpha1ObjectStorage2>(@namespace: Options.Namespace, labelSelector: null);
+
+        Collection<InstanceDetailsResponse>? instancesToCreate = null;
+        foreach (var instanceFromApi in instancesFromApi) {
+            if (DoesInstanceExistInK8s(in instancesFromK8s, in instanceFromApi)) {
+                Logger.LogDebug("Loading object storage instance list from upc api, already existing instance skipped (uuid: {instanceUuid})",
+                    instanceFromApi.UUID
+                );
+
+                continue;
+            }
+
+            (instancesToCreate ??= new ()).Add(instanceFromApi);
+        }
+
+        if (instancesToCreate is null || instancesToCreate.Count == 0) {
+            Logger.LogDebug("Loading object storage instances from upc api completed, no new instances found");
+            return;
+        }
+
+        var created = 0;
+        foreach (var newInstanceDetails in instancesToCreate) {
+            var newResource = CreateNewResource(in newInstanceDetails);
+            Logger.LogInformation("Loading object storage instances from upc api completed, creating new instance (uuid: {newInstanceUuid})",
+                newResource.Spec.Id
+            );
+
+            try {
+                _ = await KubernetesClient.Create(resource: newResource);
+
+                Logger.LogInformation("Loading object storage instances from upc api completed, new instance created (uuid: {newInstanceUuid})",
+                    newResource.Spec.Id
+                );
+                created += 1;
+            }
+            catch (HttpOperationException hex) {
+                Logger.LogError(hex, "Loading object storage instances from upc api completed, creating new instance failed (uuid: {newInstanceUuid}, error: {errorContent})",
+                    newResource.Spec.Id,
+                    hex.Response.Content.AsSpan().ToString()
+                );
+            }
+            catch (Exception ex) {
+                Logger.LogError(ex, "Loading object storage instances from upc api completed, creating new instance failed (uuid: {newInstanceUuid})",
+                    newResource.Spec.Id
+                );
+            }
+        }
+
+        Logger.LogDebug("Loading object storage instances from upc api completed (created: {createdCount})",
+            created
+        );
+    }
+
+    private static bool DoesInstanceExistInK8s(in IList<V1Alpha1ObjectStorage2> instancesFromK8s, in InstanceDetailsResponse instancesFromApi)
+    {
+        for (var idx = 0; idx < instancesFromK8s.Count; idx++) {
+            if (instancesFromK8s[idx].Status.Id == instancesFromApi.UUID) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    private V1Alpha1ObjectStorage2 CreateNewResource(in InstanceDetailsResponse newInstanceDetails) => new()
+        {
+            Spec       = CreateNewInstanceSpec(in newInstanceDetails),
+            Status     = new (),
+            Metadata   = new V1ObjectMeta {
+                Name              = string.Format("object-storage-v2-{0}", newInstanceDetails.UUID),
+                NamespaceProperty = Options.Namespace
+            }
+        };
+
+    private static V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageSpec CreateNewInstanceSpec(in InstanceDetailsResponse newInstanceDetails) => new()
+        {
+            Id               = newInstanceDetails.UUID,
+            Region           = newInstanceDetails.Region,
+            ConfiguredStatus = newInstanceDetails.ConfiguredStatus,
+            Networks         = new (
+                newInstanceDetails.Networks.Select(x => new V1Alpha1ObjectStorage2.Network {
+                    Name   = x.Name,
+                    Family = x.Family,
+                    Type   = x.Type,
+                    Id     = x.UUID
+                }).ToList()
+            ),
+            Users            = new (
+                newInstanceDetails.Users.Select(x => new V1Alpha1ObjectStorage2.User {
+                    Username = x.Username
+                }).ToList()
+            ),
+            Labels           = new (
+                newInstanceDetails.Labels.Select(x => new V1Alpha1ObjectStorage2.Label {
+                    Name  = x.Key,
+                    Value = x.Value
+                }).ToList()
+            )
+        };
+}
diff --git a/src/UpcloudApiKubernetesOperator/AutoLoader/Options/AutoLoaderOptions.cs b/src/UpcloudApiKubernetesOperator/AutoLoader/Options/AutoLoaderOptions.cs
new file mode 100644
index 0000000..54f38db
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/AutoLoader/Options/AutoLoaderOptions.cs
@@ -0,0 +1,37 @@
+using System.Collections.ObjectModel;
+
+using Microsoft.Extensions.Options;
+
+namespace UpcloudApiKubernetesOperator.AutoLoader.Options;
+
+internal sealed class AutoLoaderOptions
+{
+    public const string DEFAULT_SECTION_NAME = "AutoLoader";
+    public bool Enabled        { get; init; } = false;
+    public int RefreshInterval { get; init; } = 120;
+    public string Namespace    { get; init; } = string.Empty;
+
+    public AutoLoaderOptions() {}
+
+    public class Validator : IValidateOptions<AutoLoaderOptions>
+    {
+        public ValidateOptionsResult Validate(string? name, AutoLoaderOptions options)
+        {
+            Collection<string>? errors = null;
+
+            if (options.RefreshInterval < 1) {
+                (errors ??= new ()).Add($"'{nameof(options.RefreshInterval)}' has to be positive integer, auto loader refresh interval in seconds");
+            }
+
+            if (string.IsNullOrEmpty(options.Namespace)) {
+                (errors ??= new ()).Add($"'{nameof(options.Namespace)}' cannot be null or empty");
+            }
+
+            if (errors is not null) {
+                return ValidateOptionsResult.Fail(errors);
+            }
+
+            return ValidateOptionsResult.Success;
+        }
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
index 349512e..7649c2a 100644
--- a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
+++ b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
@@ -9,6 +9,15 @@ namespace UpcloudApiKubernetesOperator.Entities;
 [KubernetesEntity(Group = "api.upcloud.com", ApiVersion = "v1alpha1", Kind = "ObjectStorage2")]
 public class V1Alpha1ObjectStorage2 : CustomKubernetesEntity<V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageSpec, V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageStatus>
 {
+    public const string KubeApiVersion = "api.upcloud.com/v1alpha1";
+    public const string KubeKind = "ObjectStorage2";
+
+    public V1Alpha1ObjectStorage2()
+    {
+        ApiVersion = KubeApiVersion;
+        Kind       = KubeKind;
+    }
+
     [Description("Specification for UpCloud router entity: https://developers.upcloud.com/1.3/13-networks/#create-router")]
     public class V1Alpha1ObjectStorageSpec
     {
@@ -83,12 +92,15 @@ public class Label
 
     public class V1Alpha1ObjectStorageStatus
     {
+        [AdditionalPrinterColumn]
         [Description("Entity reconcile status")]
         public ReconcileState ReconcileState { get; set; } = ReconcileState.UPDATING;
 
+        [AdditionalPrinterColumn]
         [Description("Object storage instance uuid")]
         public string Id { get; set; } = string.Empty;
 
+        [AdditionalPrinterColumn]
         [Description("Configured service status, see: https://developers.upcloud.com/1.3/21-managed-object-storage/#service-configured-status")]
         public string ConfiguredStatus { get; set; } = string.Empty;
 
@@ -101,12 +113,15 @@ public class V1Alpha1ObjectStorageStatus
         [Description("List of attached networks that can be used to access the instance")]
         public Collection<Network> Networks { get; set; } = new ();
 
+        [AdditionalPrinterColumn]
         [Description("Current operational state of the object storage instance")]
         public string OperationalState { get; set; } = string.Empty;
 
+        [AdditionalPrinterColumn]
         [Description("Region where the object storage instance is running")]
         public string Region { get; set; } = string.Empty;
 
+        [AdditionalPrinterColumn]
         [Description("Object storage instance last updated time")]
         public string UpdatedAt { get; set; } = string.Empty;
 
diff --git a/src/UpcloudApiKubernetesOperator/Program.cs b/src/UpcloudApiKubernetesOperator/Program.cs
index 72400ce..fb30e9b 100644
--- a/src/UpcloudApiKubernetesOperator/Program.cs
+++ b/src/UpcloudApiKubernetesOperator/Program.cs
@@ -1,14 +1,14 @@
 using KubeOps.Operator;
-using UpcloudApiKubernetesOperator.Entities;
 using UpcloudApiKubernetesOperator.UpCloudApi.Extensions.DependencyInjection;
+using UpcloudApiKubernetesOperator.AutoLoader.Extensions.DependencyInjection;
 
 var builder = WebApplication.CreateBuilder(args);
 
 builder.Host.ConfigureServices((context, services) => {
     services.AddUpCloudApiClient(context.Configuration);
+    services.AddAutoLoaderService(context.Configuration);
     services.AddKubernetesOperator();
     services.AddControllers();
-
 });
 
 var app = builder.Build();
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
index bc4b442..3464985 100644
--- a/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/Extensions/DependencyInjection/IServiceCollectionExtensions.cs
@@ -10,21 +10,20 @@ public static class IServiceCollectionExtensions
 {
     public static IServiceCollection AddUpCloudApiClient(this IServiceCollection services, IConfiguration configuration)
     {
-        services.Configure<UpCloudApiOptions>(
-            config: configuration.GetRequiredSection(key: UpCloudApiOptions.DEFAULT_SECTION_NAME)
-        );
-
-        services.AddHttpClient<UpCloudApiClient>((serviceProvider, httpClient) => {
-            var apiConfiguration = serviceProvider.GetRequiredService<IOptions<UpCloudApiOptions>>().Value;
-
-            httpClient.Timeout     = TimeSpan.FromSeconds(apiConfiguration.RequestTimeoutSeconds);
-            httpClient.BaseAddress = new Uri(apiConfiguration.Endpoint);
-
-            httpClient.SetBasicAuthentication(
-                userName: apiConfiguration.Username,
-                password: apiConfiguration.Password
-            );
-        });
+        services
+            .Configure<UpCloudApiOptions>(config: configuration.GetRequiredSection(key: UpCloudApiOptions.DEFAULT_SECTION_NAME))
+            .AddSingleton<IValidateOptions<UpCloudApiOptions>, UpCloudApiOptions.Validator>()
+            .AddHttpClient<UpCloudApiClient>((serviceProvider, httpClient) => {
+                var apiConfiguration = serviceProvider.GetRequiredService<IOptions<UpCloudApiOptions>>().Value;
+
+                httpClient.Timeout     = TimeSpan.FromSeconds(apiConfiguration.RequestTimeoutSeconds);
+                httpClient.BaseAddress = new Uri(apiConfiguration.Endpoint);
+
+                httpClient.SetBasicAuthentication(
+                    userName: apiConfiguration.Username,
+                    password: apiConfiguration.Password
+                );
+            });
 
         services.AddSingleton<IObjectStorageV2Client, ObjectStorageV2Client>();
 
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
index 3d77a6e..9720175 100644
--- a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
@@ -5,6 +5,7 @@ namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
 
 public interface IObjectStorageV2Client
 {
+    Task<IReadOnlyCollection<InstanceDetailsResponse>> ListInstances(CancellationToken cancellationToken = default);
     Task<InstanceDetailsResponse?> GetDetails(string instanceUuid, CancellationToken cancellationToken = default);
     Task<IReadOnlyCollection<BucketMetric>> GetBucketMetrics(string instanceUuid, CancellationToken cancellationToken = default);
     Task<CreateInstanceResponse> CreateInstance(InstanceDetails instanceDetails, CancellationToken cancellationToken = default);
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
index 8391d5e..13c0c1b 100644
--- a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
@@ -10,6 +10,23 @@ internal sealed class ObjectStorageV2Client : UpCloudApiClient, IObjectStorageV2
 {
     public ObjectStorageV2Client(IHttpClientFactory httpClientFactory, ILogger<UpCloudApiClient> logger) : base(httpClientFactory, logger) { }
 
+    public async Task<IReadOnlyCollection<InstanceDetailsResponse>> ListInstances(CancellationToken cancellationToken = default)
+    {
+        try {
+            var response = await HttpClient.GetFromJsonAsync<InstanceDetailsResponse[]>(
+                requestUri:        "/1.3/object-storage-2",
+                options:           JsonSerializerOptions,
+                cancellationToken: cancellationToken
+            );
+
+            return new ReadOnlyCollection<InstanceDetailsResponse>(response ?? Array.Empty<InstanceDetailsResponse>());
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Requesting object storage v2 instance list from upc api failed");
+            return new ReadOnlyCollection<InstanceDetailsResponse>(Array.Empty<InstanceDetailsResponse>());
+        }
+    }
+
     public async Task<InstanceDetailsResponse?> GetDetails(string instanceUuid, CancellationToken cancellationToken = default)
     {
         try {
diff --git a/src/UpcloudApiKubernetesOperator/appsettings.Development.json b/src/UpcloudApiKubernetesOperator/appsettings.Development.json
index 09183c2..14590ea 100644
--- a/src/UpcloudApiKubernetesOperator/appsettings.Development.json
+++ b/src/UpcloudApiKubernetesOperator/appsettings.Development.json
@@ -11,5 +11,10 @@
         "Username": "cloud-api-user-username",
         "Password": "cloud-api-user-password",
         "RequestTimeoutSeconds": 30
+    },
+    "AutoLoader": {
+        "Enabled": false,
+        "Namespace": "default",
+        "RefreshInterval": 120
     }
 }
diff --git a/src/UpcloudApiKubernetesOperator/appsettings.json b/src/UpcloudApiKubernetesOperator/appsettings.json
index f19a647..d3b53fe 100644
--- a/src/UpcloudApiKubernetesOperator/appsettings.json
+++ b/src/UpcloudApiKubernetesOperator/appsettings.json
@@ -8,9 +8,14 @@
     },
     "AllowedHosts": "*",
     "UpCloudApiOptions": {
-      "Endpoint": "https://api.upcloud.com",
-      "Username": "cloud-api-user-username",
-      "Password": "cloud-api-user-password",
-      "RequestTimeoutSeconds": 30
-  }
+        "Endpoint": "https://api.upcloud.com",
+        "Username": "cloud-api-user-username",
+        "Password": "cloud-api-user-password",
+        "RequestTimeoutSeconds": 30
+    },
+    "AutoLoader": {
+        "Enabled": false,
+        "Namespace": "default",
+        "RefreshInterval": 120
+    }
 }

From ba305cffe6fa562e45cd457670e538b6ca050b61 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Vili-Aleksi=20V=C3=A4is=C3=A4nen?=
 <17277707+visdmin@users.noreply.github.com>
Date: Mon, 30 Oct 2023 23:38:04 +0200
Subject: [PATCH 5/6] Update README.md

---
 README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/README.md b/README.md
index b034e10..af9a3c9 100644
--- a/README.md
+++ b/README.md
@@ -11,7 +11,7 @@ Always refer to the official UpCloud documentation and support channels for auth
 - [ ] Implement UpCloud API objects as custom resource types.
 - [ ] To keep up with UpCloud API object states by pulling changes from the UpCloud API.
 - [ ] To be able to display the current UpCloud API object states via Kubernetes API. 
-- [ ] To be able to maintain the desired state of the UpCloud API objects.
+- [ ] To be able to maintain the desired state of the UpCloud API objects (manipulate UpCloud API objects via K8s entity spec).
 
 These features can be implemented one by one, and the features can be implemented only for selected UpCloud API objects.
 

From 902c7b8e59c07b274e5c7b24c5be646e69f965bd Mon Sep 17 00:00:00 2001
From: visdmin <vili@kiho.fi>
Date: Tue, 31 Oct 2023 00:46:24 +0200
Subject: [PATCH 6/6] Minor fixes and idea about access key creation api
 endpoint usage.

---
 ...Alpha1ObjectStorage2AccessKeyController.cs | 244 ++++++++++++++++++
 .../Entities/V1Alpha1ObjectStorage2.cs        |   4 +-
 .../V1Alpha1ObjectStorage2AccessKey.cs        | 105 ++++++++
 .../ObjectStorageV2/IObjectStorageV2Client.cs |   1 +
 .../Models/Requests/AccessKeyDetails.cs       |  14 +
 ...InstanceRequests.cs => InstanceDetails.cs} |   0
 .../Responses/CreateAccessKeyResponse.cs      |  16 ++
 .../Models/Responses/NewAccessKeyDetails.cs   |  40 +++
 .../ObjectStorageV2/ObjectStorageV2Client.cs  |  40 ++-
 9 files changed, 459 insertions(+), 5 deletions(-)
 create mode 100644 src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2AccessKeyController.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2AccessKey.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/AccessKeyDetails.cs
 rename src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/{CreateInstanceRequests.cs => InstanceDetails.cs} (100%)
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateAccessKeyResponse.cs
 create mode 100644 src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/NewAccessKeyDetails.cs

diff --git a/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2AccessKeyController.cs b/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2AccessKeyController.cs
new file mode 100644
index 0000000..7722276
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/Controller/V1Alpha1ObjectStorage2AccessKeyController.cs
@@ -0,0 +1,244 @@
+using System.Text.Json;
+using System.Collections.ObjectModel;
+
+using k8s.Models;
+using KubeOps.Operator.Controller;
+using KubeOps.Operator.Controller.Results;
+using KubeOps.Operator.Finalizer;
+using KubeOps.Operator.Rbac;
+using KubeOps.KubernetesClient;
+
+using UpcloudApiKubernetesOperator.Finalizer;
+using UpcloudApiKubernetesOperator.Entities;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
+using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+using System.Threading.Tasks.Dataflow;
+using Microsoft.IdentityModel.Tokens;
+using System.Data;
+
+namespace UpcloudApiKubernetesOperator.Controller.Storage;
+
+[EntityRbac(typeof(V1Alpha1ObjectStorage2), Verbs = RbacVerb.All)]
+public class V1Alpha1ObjectStorage2Controller : IResourceController<V1Alpha1ObjectStorage2>
+{
+    private readonly IKubernetesClient KubernetesClient;
+    private readonly IObjectStorageV2Client UpcApiClient;
+    private readonly ILogger<V1Alpha1ObjectStorage2Controller> Logger;
+    private readonly IFinalizerManager<V1Alpha1ObjectStorage2> FinalizerManager;
+    private readonly static TimeSpan ReconcileInterval = TimeSpan.FromSeconds(30);
+    private readonly JsonSerializerOptions SerializerOptions;
+
+    public V1Alpha1ObjectStorage2Controller(
+        IKubernetesClient kubernetesClient,
+        IObjectStorageV2Client upcApiClient,
+        ILogger<V1Alpha1ObjectStorage2Controller> logger,
+        IFinalizerManager<V1Alpha1ObjectStorage2> finalizerManager
+    ) {
+        KubernetesClient  = kubernetesClient;
+        UpcApiClient      = upcApiClient;
+        Logger            = logger;
+        FinalizerManager  = finalizerManager;
+        SerializerOptions = new JsonSerializerOptions {
+            IgnoreReadOnlyFields     = false,
+            IgnoreReadOnlyProperties = false,
+            WriteIndented            = true
+        };
+    }
+
+    public async Task<ResourceControllerResult?> ReconcileAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        if (entity.Status.ReconcileState is V1Alpha1ObjectStorage2.ReconcileState.FAILURE or V1Alpha1ObjectStorage2.ReconcileState.PAUSED) {
+            Logger.LogInformation("Reconciling skipped (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
+                new { kind = entity.GetType(), name = entity.Name(), reconcileStatus = entity.Status.ReconcileState },
+                JsonSerializer.Serialize(entity.Spec,   options: SerializerOptions),
+                JsonSerializer.Serialize(entity.Status, options: SerializerOptions)
+            );
+        }
+
+        await FinalizerManager.RegisterFinalizerAsync<V1Alpha1ObjectStorage2Finalizer>(entity);
+
+        Logger.LogInformation("Reconciling (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
+            new { kind = entity.GetType(), name = entity.Name() },
+            JsonSerializer.Serialize(entity.Spec,   options: SerializerOptions),
+            JsonSerializer.Serialize(entity.Status, options: SerializerOptions)
+        );
+
+        // Currently object storage v2 api does not support creation of multiple instances
+        // TODO: update this logic to set instance uuid to the status when API is updated.
+        if (string.IsNullOrEmpty(entity.Status.Id) && string.IsNullOrEmpty(entity.Spec.Id)) {
+            await CreateInstance(entity);
+            return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+        }
+
+        var instanceDetails = await UpcApiClient.GetDetails(instanceUuid: entity.Spec.Id);
+        if (instanceDetails is null) {
+            Logger.LogWarning("Entity deleted because not found in upc api (entity: {entity}, spec: {entitySpec}, status: {entityStatus})",
+                new { kind = entity.GetType(), name = entity.Name(), reconcileStatus = entity.Status.ReconcileState },
+                JsonSerializer.Serialize(entity.Spec,   options: SerializerOptions),
+                JsonSerializer.Serialize(entity.Status, options: SerializerOptions)
+            );
+            await KubernetesClient.Delete(entity);
+            return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+        }
+
+        if (CheckIfUpdateIsRequired(entity, instanceDetails.Value)) {
+            await UpdateStatus(V1Alpha1ObjectStorage2.ReconcileState.UPDATING, entity, instanceDetails.Value);
+            await TryUpdateInstance(entity);
+            return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+        }
+
+        await UpdateStatus(V1Alpha1ObjectStorage2.ReconcileState.UP_TO_DATE, entity, instanceDetails.Value);
+        return ResourceControllerResult.RequeueEvent(ReconcileInterval);
+    }
+
+    private async Task CreateInstance(V1Alpha1ObjectStorage2 entity)
+    {
+        var response = await UpcApiClient.CreateInstance(
+            instanceDetails: InstanceDetails.FromKubernetesSpec(entity.Spec)
+        );
+
+        if (response.Success is false) {
+            Logger.LogWarning("Creating object storage instance failed, setting reconcile status to failed (error: {errorResponse})",
+                (response.ErrorResponse is not null) ? JsonSerializer.Serialize(response.ErrorResponse) : "n/a"
+            );
+
+            entity.Status.ReconcileState = V1Alpha1ObjectStorage2.ReconcileState.FAILURE;
+            await KubernetesClient.UpdateStatus(entity);
+            return;
+        }
+
+        Logger.LogInformation("Object storage v2 instance created successfully");
+        return;
+    }
+
+    private async Task TryUpdateInstance(V1Alpha1ObjectStorage2 entity)
+    {
+        var response = await UpcApiClient.ReplaceInstance(
+            instanceUuid:    entity.Spec.Id,
+            instanceDetails: InstanceDetails.FromKubernetesSpec(entity.Spec)
+        );
+
+        if (response.Success is false) {
+            Logger.LogWarning("Updating object storage instance failed, setting reconcile status to failed (error: {errorResponse})",
+                (response.ErrorResponse is not null) ? JsonSerializer.Serialize(response.ErrorResponse) : "n/a"
+            );
+
+            entity.Status.ReconcileState = V1Alpha1ObjectStorage2.ReconcileState.FAILURE;
+            await KubernetesClient.UpdateStatus(entity);
+            return;
+        }
+
+        Logger.LogInformation("Updating storage v2 instance created successfully");
+        return;
+    }
+
+    private static bool CheckIfUpdateIsRequired(V1Alpha1ObjectStorage2 entity, InstanceDetailsResponse state)
+    {
+        if (state.ConfiguredStatus != entity.Spec.ConfiguredStatus) {
+            return true;
+        }
+
+        if (state.Region != entity.Spec.Region) {
+            return true;
+        }
+
+        if (state.Networks.Count != entity.Spec.Networks.Count) {
+            return true;
+        }
+
+        foreach (var network in state.Networks) {
+            var equal = entity.Spec.Networks.Where(x =>
+                network.Name   == x.Name   && network.Type == x.Type &&
+                network.Family == x.Family && (network.UUID is null) || network.UUID == x.Id
+            );
+
+            if (equal.IsNullOrEmpty()) {
+                return true;
+            }
+        }
+
+        if (state.Labels.Count != entity.Spec.Labels.Count) {
+            return true;
+        }
+
+        foreach (var label in state.Labels) {
+            var equal = entity.Spec.Labels.Where(x => label.Key == x.Name && label.Value == x.Value);
+            if (equal.IsNullOrEmpty()) {
+                return true;
+            }
+        }
+
+        if (state.Users.Count != entity.Spec.Users.Count) {
+            return true;
+        }
+
+        foreach (var user in state.Users) {
+            var equal = entity.Spec.Users.Where(x => user.Username == x.Username);
+            if (equal.IsNullOrEmpty()) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    public Task UpdateStatus(V1Alpha1ObjectStorage2.ReconcileState reconcileState, V1Alpha1ObjectStorage2 entity, InstanceDetailsResponse state)
+    {
+        entity.Status = new V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageStatus {
+            ReconcileState   = reconcileState,
+            Id               = state.UUID,
+            ConfiguredStatus = state.ConfiguredStatus,
+            CreatedAt        = state.CreatedAt.ToString("s"),
+            Endpoints        = new (
+                state.Endpoints.Select(x => new V1Alpha1ObjectStorage2.Endpoint {
+                    DomainName = x.DomainName,
+                    Type       = x.Type
+                }).ToList()
+            ),
+            Networks         = new (
+                state.Networks.Select(x => new V1Alpha1ObjectStorage2.Network {
+                    Name   = x.Name,
+                    Family = x.Family,
+                    Type   = x.Type,
+                    Id     = x.UUID
+                }).ToList()
+            ),
+            OperationalState = state.OperationalState,
+            Region           = state.Region,
+            UpdatedAt        = state.UpdatedAt.ToString("s"),
+            Users            = new (
+                state.Users.Select(x => new V1Alpha1ObjectStorage2.ConnectedUser{
+                    Username         = x.Username,
+                    OperationalState = x.OperationalState,
+                    UpdatedAt        = x.UpdatedAt.ToString("s"),
+                    CreatedAt        = x.CreatedAt.ToString("s"),
+                    AccessKeys       = new (
+                        x.AccessKeys.Select(x => new V1Alpha1ObjectStorage2.AccessKey {
+                            AccessKeyId = x.Id,
+                            Name        = x.Name,
+                            CreatedAt   = x.CreatedAt.ToString("s"),
+                            LastUsedAt  = x.LastUsedAt.ToString("s"),
+                            UpdatedAt   = x.UpdatedAt.ToString("s")
+                        }).ToList()
+                    )
+                }).ToList()
+            )
+        };
+
+        return KubernetesClient.UpdateStatus(entity);
+    }
+
+    public Task StatusModifiedAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        Logger.LogInformation($"entity {entity.Name()} called {nameof(StatusModifiedAsync)}.");
+        return Task.CompletedTask;
+    }
+
+    public Task DeletedAsync(V1Alpha1ObjectStorage2 entity)
+    {
+        Logger.LogInformation($"entity {entity.Name()} called {nameof(DeletedAsync)}.");
+
+        return Task.CompletedTask;
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
index 7649c2a..dc3eee4 100644
--- a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
+++ b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2.cs
@@ -10,7 +10,7 @@ namespace UpcloudApiKubernetesOperator.Entities;
 public class V1Alpha1ObjectStorage2 : CustomKubernetesEntity<V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageSpec, V1Alpha1ObjectStorage2.V1Alpha1ObjectStorageStatus>
 {
     public const string KubeApiVersion = "api.upcloud.com/v1alpha1";
-    public const string KubeKind = "ObjectStorage2";
+    public const string KubeKind       = "ObjectStorage2";
 
     public V1Alpha1ObjectStorage2()
     {
@@ -18,7 +18,7 @@ public V1Alpha1ObjectStorage2()
         Kind       = KubeKind;
     }
 
-    [Description("Specification for UpCloud router entity: https://developers.upcloud.com/1.3/13-networks/#create-router")]
+    [Description("Specification for UpCloud object storage v2 entity: https://developers.upcloud.com/1.3/21-managed-object-storage/#create-service")]
     public class V1Alpha1ObjectStorageSpec
     {
         [Length(MaxLength = 36, MinLength = -1)]
diff --git a/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2AccessKey.cs b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2AccessKey.cs
new file mode 100644
index 0000000..0e951d7
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/Entities/V1Alpha1ObjectStorage2AccessKey.cs
@@ -0,0 +1,105 @@
+using System.Collections.ObjectModel;
+
+using k8s.Models;
+using KubeOps.Operator.Entities;
+using KubeOps.Operator.Entities.Annotations;
+
+namespace UpcloudApiKubernetesOperator.Entities;
+
+[KubernetesEntity(Group = "api.upcloud.com", ApiVersion = "v1alpha1", Kind = "ObjectStorage2AccessKey")]
+public class V1Alpha1ObjectStorage2AccessKey : CustomKubernetesEntity<V1Alpha1ObjectStorage2AccessKey.V1Alpha1ObjectStorageSpec, V1Alpha1ObjectStorage2AccessKey.V1Alpha1ObjectStorageStatus>
+{
+    public const string KubeApiVersion = "api.upcloud.com/v1alpha1";
+    public const string KubeKind       = "ObjectStorage2AccessKey";
+
+    public V1Alpha1ObjectStorage2AccessKey()
+    {
+        ApiVersion = KubeApiVersion;
+        Kind       = KubeKind;
+    }
+
+    [Description("Specification for UpCloud object storage v2 access key entity: https://developers.upcloud.com/1.3/21-managed-object-storage/#create-access-key")]
+    public class V1Alpha1ObjectStorageSpec
+    {
+        [Required]
+        [Description("Reference to object storage 2 instance")]
+        [EmbeddedResource]
+        public ObjectStorage2Reference ObjectStorage2Reference { get; set; } = new ();
+
+        [Required]
+        [Length(MaxLength = 64, MinLength = 1)]
+        [Pattern("^[a-zA-Z0-9_-]+$")]
+        [Description("Access key name")]
+        public string Name { get; set; } = string.Empty;
+
+        [Required]
+        [Length(MaxLength = -1, MinLength = 1)]
+        [Description("Valid cloud user username, that has access to the object storage 2 instance")]
+        public string Username { get; set; } = string.Empty;
+
+        [Required]
+        [Description("Access key state")]
+        public bool Enabled { get; set; } = true;
+    }
+
+    [Description("Reference to object storage v2 entity")]
+    public class ObjectStorage2Reference
+    {
+        [Required]
+        [Length(MaxLength = 36, MinLength = -1)]
+        [Description("UUID of existing object storage instance")]
+        public string Id { get; set; } = string.Empty;
+
+        [Required]
+        [Description("Kubernetes namespace where the object storage v2 entity exists")]
+        public string Namespace { get; set; } = string.Empty;
+    }
+
+    public class V1Alpha1ObjectStorageStatus
+    {
+        [AdditionalPrinterColumn]
+        [Description("Entity reconcile status")]
+        public ReconcileState ReconcileState { get; set; } = ReconcileState.UPDATING;
+
+        [AdditionalPrinterColumn]
+        [Description("Object storage 2 instance uuid")]
+        public string ObjectStorage2Uuid { get; set; } = string.Empty;
+
+        [AdditionalPrinterColumn]
+        [Description("Access key state")]
+        public bool Enabled { get; set; } = true;
+
+        [AdditionalPrinterColumn]
+        [Description("Access key name")]
+        public string Name { get; set; } = string.Empty;
+
+        [AdditionalPrinterColumn]
+        [Description("Valid cloud user username")]
+        public string Username { get; set; } = string.Empty;
+
+        [AdditionalPrinterColumn]
+        [Description("Access key id")]
+        public string AccessKeyId { get; set; } = string.Empty;
+
+        [AdditionalPrinterColumn]
+        [Description("Name of the secret object holding the access key secret")]
+        public string AccessKeySecretName { get; set; } = string.Empty;
+
+        [Description("Creation time")]
+        public string CreatedAt { get; set; } = string.Empty;
+
+        [Description("Last updated time")]
+        public string UpdatedAt { get; set; } = string.Empty;
+
+        [Description("Last used time")]
+        public string LastUsedAt { get; set; } = string.Empty;
+    }
+
+    public enum ReconcileState
+    {
+        PAUSED     = 0,
+        UP_TO_DATE = 1,
+        UPDATING   = 2,
+        FAILURE    = 3,
+    }
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
index 9720175..5109e4c 100644
--- a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/IObjectStorageV2Client.cs
@@ -11,4 +11,5 @@ public interface IObjectStorageV2Client
     Task<CreateInstanceResponse> CreateInstance(InstanceDetails instanceDetails, CancellationToken cancellationToken = default);
     Task<ReplaceInstanceResponse> ReplaceInstance(string instanceUuid, InstanceDetails instanceDetails, CancellationToken cancellationToken = default);
     Task<DeleteInstanceResponse> DeleteInstance(string instanceUuid, CancellationToken cancellationToken = default);
+    Task<CreateAccessKeyResponse> CreateAccessKey(string instanceUuid, string username, AccessKeyDetails details, CancellationToken cancellationToken = default);
 }
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/AccessKeyDetails.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/AccessKeyDetails.cs
new file mode 100644
index 0000000..fa551a6
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/AccessKeyDetails.cs
@@ -0,0 +1,14 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
+public readonly struct AccessKeyDetails
+{
+    [JsonPropertyName("name")]
+    public readonly string Name;
+
+    [JsonPropertyName("enabled")]
+    public readonly bool Enabled;
+
+    [JsonConstructor]
+    public AccessKeyDetails(string name, bool enabled) => (Name, Enabled) = (name, enabled);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/CreateInstanceRequests.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/InstanceDetails.cs
similarity index 100%
rename from src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/CreateInstanceRequests.cs
rename to src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Requests/InstanceDetails.cs
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateAccessKeyResponse.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateAccessKeyResponse.cs
new file mode 100644
index 0000000..78f3ba5
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/CreateAccessKeyResponse.cs
@@ -0,0 +1,16 @@
+using System.Diagnostics.CodeAnalysis;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+
+public readonly struct CreateAccessKeyResponse
+{
+    public readonly bool Success;
+    public readonly ErrorResponse? ErrorResponse;
+    public readonly NewAccessKeyDetails? Details;
+
+    [MemberNotNullWhen(true, nameof(Details))]
+    public bool IsSuccessful => Success is true && Details is not null;
+
+    public CreateAccessKeyResponse(bool success, ErrorResponse? errorResponse = null, NewAccessKeyDetails? details = null)
+        => (Success, ErrorResponse, Details) = (success, errorResponse, details);
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/NewAccessKeyDetails.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/NewAccessKeyDetails.cs
new file mode 100644
index 0000000..a83fbb3
--- /dev/null
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/Models/Responses/NewAccessKeyDetails.cs
@@ -0,0 +1,40 @@
+using System.Text.Json.Serialization;
+
+namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
+public readonly struct NewAccessKeyDetails
+{
+    [JsonPropertyName("access_key_id")]
+    public readonly string AccessKeyId;
+
+    [JsonPropertyName("created_at")]
+    public readonly DateTime CreatedAt;
+
+    [JsonPropertyName("enabled")]
+    public readonly bool Enabled;
+
+    [JsonPropertyName("last_used_at")]
+    public readonly DateTime LastUsedAt;
+
+    [JsonPropertyName("name")]
+    public readonly string Name;
+
+    [JsonPropertyName("secret_access_key")]
+    public readonly string Secret;
+
+    [JsonPropertyName("updated_at")]
+    public readonly DateTime UpdatedAt;
+
+    [JsonConstructor]
+    public NewAccessKeyDetails(
+        string accessKeyId,
+        DateTime createdAt,
+        bool enabled,
+        DateTime lastUsedAt,
+        string name,
+        string secret,
+        DateTime updatedAt
+    ) =>
+        (AccessKeyId, CreatedAt, Enabled, LastUsedAt, Name, Secret, UpdatedAt) =
+        (accessKeyId, createdAt, enabled, lastUsedAt, name, secret, updatedAt);
+
+}
diff --git a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
index 13c0c1b..308e35d 100644
--- a/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
+++ b/src/UpcloudApiKubernetesOperator/UpCloudApi/ObjectStorageV2/ObjectStorageV2Client.cs
@@ -3,6 +3,7 @@
 using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Responses;
 using UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2.Models.Requests;
 using k8s.Models;
+using Microsoft.AspNetCore.DataProtection.KeyManagement.Internal;
 
 namespace UpcloudApiKubernetesOperator.UpCloudApi.ObjectStorageV2;
 
@@ -74,7 +75,7 @@ public async Task<CreateInstanceResponse> CreateInstance(InstanceDetails instanc
             }
 
             return new (
-                success:       true,
+                success:       false,
                 errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
                     options: JsonSerializerOptions,
                     cancellationToken: cancellationToken
@@ -102,7 +103,7 @@ public async Task<ReplaceInstanceResponse> ReplaceInstance(string instanceUuid,
             }
 
             return new (
-                success:       true,
+                success:       false,
                 errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
                     options: JsonSerializerOptions,
                     cancellationToken: cancellationToken
@@ -128,7 +129,7 @@ public async Task<DeleteInstanceResponse> DeleteInstance(string instanceUuid, Ca
             }
 
             return new (
-                success:       true,
+                success:       false,
                 errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
                     options: JsonSerializerOptions,
                     cancellationToken: cancellationToken
@@ -140,4 +141,37 @@ public async Task<DeleteInstanceResponse> DeleteInstance(string instanceUuid, Ca
             return new (success: false, errorResponse: null);
         }
     }
+
+    public async Task<CreateAccessKeyResponse> CreateAccessKey(string instanceUuid, string username, AccessKeyDetails details, CancellationToken cancellationToken = default)
+    {
+        try {
+            var response = await HttpClient.PostAsJsonAsync(
+                requestUri:        string.Format("/1.3/object-storage-2/{0}/users/{1}/access-keys", instanceUuid, username),
+                value:             details,
+                cancellationToken: cancellationToken
+            );
+
+            if (response.IsSuccessStatusCode) {
+                return new (
+                    success: true,
+                    details: await response.Content.ReadFromJsonAsync<NewAccessKeyDetails>(
+                        options:           JsonSerializerOptions,
+                        cancellationToken: cancellationToken
+                    )
+                );
+            }
+
+            return new (
+                success:       false,
+                errorResponse: await response.Content.ReadFromJsonAsync<ErrorResponse>(
+                    options: JsonSerializerOptions,
+                    cancellationToken: cancellationToken
+                )
+            );
+        }
+        catch (Exception ex) {
+            Logger.LogError(ex, "Delete new object storage 2 instance request failed");
+            return new (success: false);
+        }
+    }
 }