Skip to content

Commit

Permalink
csharp: Add operational webhook endpoint API
Browse files Browse the repository at this point in the history
  • Loading branch information
@svix-jplatte
svix-jplatte committed Nov 6, 2024
1 parent 087335b commit 5aabb07
Show file tree
Hide file tree
Showing 3 changed files with 391 additions and 1 deletion.
51 changes: 51 additions & 0 deletions csharp/Svix/Abstractions/IOperationalWebhookEndpoint.cs
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,51 @@
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using Svix.Model;
using Svix.Models;

namespace Svix.Abstractions
{
public interface IOperationalWebhookEndpoint
{
OperationalWebhookEndpointOut Create(OperationalWebhookEndpointIn endpoint,
string idempotencyKey = default);

Task<OperationalWebhookEndpointOut> CreateAsync(OperationalWebhookEndpointIn endpoint,
string idempotencyKey = default, CancellationToken cancellationToken = default);

bool Delete(string endpointId, string idempotencyKey = default);

Task<bool> DeleteAsync(string endpointId, string idempotencyKey = default,
CancellationToken cancellationToken = default);

OperationalWebhookEndpointOut Get(string endpointId, string idempotencyKey = default);

Task<OperationalWebhookEndpointOut> GetAsync(string endpointId, string idempotencyKey = default,
CancellationToken cancellationToken = default);

string GetSecret(string endpointId, string idempotencyKey = default);

Task<string> GetSecretAsync(string endpointId, string idempotencyKey = default,
CancellationToken cancellationToken = default);

ListResponseOperationalWebhookEndpointOut List(ListOptions options = null,
string idempotencyKey = default);

Task<ListResponseOperationalWebhookEndpointOut> ListAsync(ListOptions options = null,
string idempotencyKey = default, CancellationToken cancellationToken = default);

bool RotateSecret(string endpointId, OperationalWebhookEndpointSecretIn secret,
string idempotencyKey = default);

Task<bool> RotateSecretAsync(string endpointId, OperationalWebhookEndpointSecretIn secret,
string idempotencyKey = default, CancellationToken cancellationToken = default);

OperationalWebhookEndpointOut Update(string endpointId,
OperationalWebhookEndpointUpdate endpoint, string idempotencyKey = default);

Task<OperationalWebhookEndpointOut> UpdateAsync(string endpointId,
OperationalWebhookEndpointUpdate endpoint, string idempotencyKey = default,
CancellationToken cancellationToken = default);
}
}
334 changes: 334 additions & 0 deletions csharp/Svix/OperationalWebhookEndpoint.cs
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,334 @@
using System;
using System.Collections.Generic;
using System.Net;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.Logging;
using Svix.Abstractions;
using Svix.Api;
using Svix.Client;
using Svix.Model;
using Svix.Models;

namespace Svix
{
public sealed class OperationalWebhookEndpoint : SvixResourceBase, IOperationalWebhookEndpoint
{
private readonly IWebhookEndpointApi _opWebhookEndpointApi;

public OperationalWebhookEndpoint(ISvixClient svixClient, IWebhookEndpointApi endpoingApi)
: base(svixClient)
{
_opWebhookEndpointApi = endpoingApi ?? throw new ArgumentNullException(nameof(_opWebhookEndpointApi));
}

public OperationalWebhookEndpointOut Create(
OperationalWebhookEndpointIn endpoint, string idempotencyKey = default)
{
try
{
var lEndpoint = _opWebhookEndpointApi.CreateOperationalWebhookEndpoint(
endpoint,
idempotencyKey);

return lEndpoint;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(Create)} failed");

if (Throw)
throw;

return null;
}
}

public async Task<OperationalWebhookEndpointOut> CreateAsync(
OperationalWebhookEndpointIn endpoint, string idempotencyKey = default,
CancellationToken cancellationToken = default)
{
try
{
var lEndpoint = await _opWebhookEndpointApi.CreateOperationalWebhookEndpointAsync(
endpoint,
idempotencyKey,
cancellationToken);

return lEndpoint;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(CreateAsync)} failed");

if (Throw)
throw;

return null;
}
}

public bool Delete(string endpointId, string idempotencyKey = default)
{
try
{
var lResponse = _opWebhookEndpointApi.DeleteOperationalWebhookEndpointWithHttpInfo(
endpointId);

return lResponse.StatusCode == HttpStatusCode.NoContent;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(Delete)} failed");

if (Throw)
throw;

return false;
}
}

public async Task<bool> DeleteAsync(string endpointId, string idempotencyKey = default,
CancellationToken cancellationToken = default)
{
try
{
var lResponse = await _opWebhookEndpointApi.DeleteOperationalWebhookEndpointWithHttpInfoAsync(
endpointId,
cancellationToken);

return lResponse.StatusCode == HttpStatusCode.NoContent;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(DeleteAsync)} failed");

if (Throw)
throw;

return false;
}
}

public OperationalWebhookEndpointOut Get(string endpointId, string idempotencyKey = default)
{
try
{
var lEndpoint = _opWebhookEndpointApi.GetOperationalWebhookEndpoint(endpointId);
return lEndpoint;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(Get)} failed");

if (Throw)
throw;

return null;
}
}

public async Task<OperationalWebhookEndpointOut> GetAsync(string endpointId, string idempotencyKey = default,
CancellationToken cancellationToken = default)
{
try
{
var lEndpoint = await _opWebhookEndpointApi.GetOperationalWebhookEndpointAsync(
endpointId,
cancellationToken);

return lEndpoint;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(GetAsync)} failed");

if (Throw)
throw;

return null;
}
}

public string GetSecret(string endpointId, string idempotencyKey = default)
{
try
{
var lSecret = _opWebhookEndpointApi.GetOperationalWebhookEndpointSecret(
endpointId);

return lSecret?.Key;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(GetSecret)} failed");

if (Throw)
throw;

return null;
}
}

public async Task<string> GetSecretAsync(string endpointId, string idempotencyKey = default,
CancellationToken cancellationToken = default)
{
try
{
var lSecret = await _opWebhookEndpointApi.GetOperationalWebhookEndpointSecretAsync(
endpointId,
cancellationToken);

return lSecret.Key;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(GetSecretAsync)} failed");

if (Throw)
throw;

return null;
}
}

public ListResponseOperationalWebhookEndpointOut List(ListOptions options = null,
string idempotencyKey = default)
{
try
{
var lEndpoints = _opWebhookEndpointApi.ListOperationalWebhookEndpoints(
options?.Limit,
options?.Iterator,
options?.Order);

return lEndpoints;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(List)} failed");

if (Throw)
throw;

return new ListResponseEndpointOut();

Check failure on line 214 in csharp/Svix/OperationalWebhookEndpoint.cs

View workflow job for this annotation

GitHub Actions / C# Lint 

Cannot implicitly convert type 'Svix.Model.ListResponseEndpointOut' to 'Svix.Model.ListResponseOperationalWebhookEndpointOut'

Check failure on line 214 in csharp/Svix/OperationalWebhookEndpoint.cs

View workflow job for this annotation

GitHub Actions / C# Lint 

Cannot implicitly convert type 'Svix.Model.ListResponseEndpointOut' to 'Svix.Model.ListResponseOperationalWebhookEndpointOut'

Check failure on line 214 in csharp/Svix/OperationalWebhookEndpoint.cs

View workflow job for this annotation

GitHub Actions / C# Lint 

Cannot implicitly convert type 'Svix.Model.ListResponseEndpointOut' to 'Svix.Model.ListResponseOperationalWebhookEndpointOut'
}
}

public async Task<ListResponseOperationalWebhookEndpointOut> ListAsync(
ListOptions options = null, string idempotencyKey = default,
CancellationToken cancellationToken = default)
{
try
{
var lEndpoints = await _opWebhookEndpointApi.ListOperationalWebhookEndpointsAsync(
options?.Limit,
options?.Iterator,
options?.Order,
cancellationToken);

return lEndpoints;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(ListAsync)} failed");

if (Throw)
throw;

return new ListResponseEndpointOut();

Check failure on line 239 in csharp/Svix/OperationalWebhookEndpoint.cs

View workflow job for this annotation

GitHub Actions / C# Lint 

Cannot implicitly convert type 'Svix.Model.ListResponseEndpointOut' to 'Svix.Model.ListResponseOperationalWebhookEndpointOut'

Check failure on line 239 in csharp/Svix/OperationalWebhookEndpoint.cs

View workflow job for this annotation

GitHub Actions / C# Lint 

Cannot implicitly convert type 'Svix.Model.ListResponseEndpointOut' to 'Svix.Model.ListResponseOperationalWebhookEndpointOut'

Check failure on line 239 in csharp/Svix/OperationalWebhookEndpoint.cs

View workflow job for this annotation

GitHub Actions / C# Lint 

Cannot implicitly convert type 'Svix.Model.ListResponseEndpointOut' to 'Svix.Model.ListResponseOperationalWebhookEndpointOut'
}
}

public bool RotateSecret(string endpointId, OperationalWebhookEndpointSecretIn secret, string idempotencyKey = default)
{
try
{
var lResponse = _opWebhookEndpointApi.RotateOperationalWebhookEndpointSecretWithHttpInfo(
endpointId,
secret,
idempotencyKey);

return lResponse.StatusCode == HttpStatusCode.NoContent;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(RotateSecret)} failed");

if (Throw)
throw;

return false;
}
}

public async Task<bool> RotateSecretAsync(string endpointId, OperationalWebhookEndpointSecretIn secret,
string idempotencyKey = default, CancellationToken cancellationToken = default)
{
try
{
var lResponse = await _opWebhookEndpointApi.RotateOperationalWebhookEndpointSecretWithHttpInfoAsync(
endpointId,
secret,
idempotencyKey);

return lResponse.StatusCode == HttpStatusCode.NoContent;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(RotateSecretAsync)} failed");

if (Throw)
throw;

return false;
}
}

public OperationalWebhookEndpointOut Update(string endpointId,
OperationalWebhookEndpointUpdate endpoint, string idempotencyKey = default)
{
try
{
var lEndpoint = _opWebhookEndpointApi.UpdateOperationalWebhookEndpoint(
endpointId,
endpoint);

return lEndpoint;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(Update)} failed");

if (Throw)
throw;

return null;
}
}

public async Task<OperationalWebhookEndpointOut> UpdateAsync(string endpointId,
OperationalWebhookEndpointUpdate endpoint, string idempotencyKey = default,
CancellationToken cancellationToken = default)
{
try
{
var lEndpoint = await _opWebhookEndpointApi.UpdateOperationalWebhookEndpointAsync(
endpointId,
endpoint,
cancellationToken);

return lEndpoint;
}
catch (ApiException e)
{
Logger?.LogError(e, $"{nameof(UpdateAsync)} failed");

if (Throw)
throw;

return null;
}
}
}
}
Loading

0 comments on commit 5aabb07

Please sign in to comment.