SwaggerLife Posts - Answer Overflow

Topics

SwaggerLife

•Created by SwaggerLife on 6/23/2024 in #help

Dublicate Properties in Tables?

I have a table named Users and one named Organizations. The relation between them is many to many. The joining table is called OrganizationMember. I'm wondering whether it would be a good idea, to store certain properties from the User table inside the OrganizationMember. Such as Email, & Full Name and AvatarUrl. The reason being is that OrganizationMember will be used very much. I don't want to modify my queries to include the User every time. Any suggestions would be appreciated.

6 replies

•Created by SwaggerLife on 5/19/2024 in #help

Query improvement suggestions

    /// <summary>
    ///     Retrieves roles assigned to the user within organizations.
    /// </summary>
    /// <param name="userId">The ID of the user.</param>
    /// <param name="cancellationToken">The cancellation token.</param>
    /// <returns>The roles assigned to the user within organizations.</returns>
    private async Task<Dictionary<Guid, MemberRole>> GetOrganizationRolesAsync(Guid userId,
        CancellationToken cancellationToken)
    {
        // Get all organizations the user is a member of
        var userOrganizations = await db.OrganizationMembers
            .Where(om => om.UserId == userId)
            .Select(om => om.OrganizationId)
            .ToListAsync(cancellationToken);

        // Get roles in organizations where the user has a role
        var organizationRoles = await db.OrganizationMemberRoles
            .Where(omr => omr.OrganizationMember.UserId == userId)
            .Select(omr => new { omr.OrganizationId, omr.OrganizationRole.Name })
            .ToListAsync(cancellationToken);

        // Parse roles and add to dictionary
        var parsedRoles = organizationRoles.ToDictionary(
            omr => omr.OrganizationId,
            omr =>
            {
                if (Enum.TryParse<MemberRole>(omr.Name, true, out var role))
                    return role;

                throw new InvalidCastException();
            });

        // For organizations where the user doesn't have a role, add with MemberRole.None
        foreach (var orgId in userOrganizations) parsedRoles.TryAdd(orgId, MemberRole.None);

        return parsedRoles;
    }

    /// <summary>
    ///     Retrieves roles assigned to the user within organizations.
    /// </summary>
    /// <param name="userId">The ID of the user.</param>
    /// <param name="cancellationToken">The cancellation token.</param>
    /// <returns>The roles assigned to the user within organizations.</returns>
    private async Task<Dictionary<Guid, MemberRole>> GetOrganizationRolesAsync(Guid userId,
        CancellationToken cancellationToken)
    {
        // Get all organizations the user is a member of
        var userOrganizations = await db.OrganizationMembers
            .Where(om => om.UserId == userId)
            .Select(om => om.OrganizationId)
            .ToListAsync(cancellationToken);

        // Get roles in organizations where the user has a role
        var organizationRoles = await db.OrganizationMemberRoles
            .Where(omr => omr.OrganizationMember.UserId == userId)
            .Select(omr => new { omr.OrganizationId, omr.OrganizationRole.Name })
            .ToListAsync(cancellationToken);

        // Parse roles and add to dictionary
        var parsedRoles = organizationRoles.ToDictionary(
            omr => omr.OrganizationId,
            omr =>
            {
                if (Enum.TryParse<MemberRole>(omr.Name, true, out var role))
                    return role;

                throw new InvalidCastException();
            });

        // For organizations where the user doesn't have a role, add with MemberRole.None
        foreach (var orgId in userOrganizations) parsedRoles.TryAdd(orgId, MemberRole.None);

        return parsedRoles;
    }

Is there a way I can improve this query?

3 replies

•Created by SwaggerLife on 5/18/2024 in #help

Access Token Expiry date suggestions

What does you guys think, should be the expiry of an access token? I set the expiry of the refresh token to 30 days and the access token to 1 day. Any suggestions would be appreciated. Sincerely.

1 replies

•Created by SwaggerLife on 3/31/2024 in #help

DeleteBehavior?

I'm always confused which DeleteBehavior to assign when configuring my Entities. Can someone please explain to me?

3 replies

•Created by SwaggerLife on 3/29/2024 in #help

Project structure

No description

17 replies

•Created by SwaggerLife on 3/14/2024 in #help

✅ How should I name my ef core migrations?

I'm wondering if there is a good way to name your migrations. I have noticed that, you quickly end-up with a lot of migrations. I'm just wondering if there is a good naming convention.

21 replies

•Created by SwaggerLife on 2/24/2024 in #help

✅ Npgsql.PostgresException

public class CreatePostHandler(
    IHttpContextAccessor contextAccessor,
    DatabaseContext db,
    ISender mediator,
    IValidator<CreatePostCommand> validator)
    : RequestHandler(contextAccessor), IRequestHandler<CreatePostCommand, Result<Post>>
{
    private const string StorageContainer = "images";

    public async Task<Result<Post>> Handle(CreatePostCommand request, CancellationToken cancellationToken)
    {
        try
        {
            var validationResult = await ValidateInputAsync(request, cancellationToken);
            if (!validationResult.IsValid)
                return Result<Post>.Failure("Invalid input received.",
                    validationResult.ErrorMessages(), 400);

            var newBlobName = $"{Guid.NewGuid()}{request.File.GetExtensionType()}";
            var uploadResult = await UploadFileAsync(newBlobName, request.File, cancellationToken);

            if (!uploadResult.IsSuccessful)
                return uploadResult.ToResult(_ => new Post());

            var uri = uploadResult.Data;
            var nsfwResult = await ClassifyFileAsync(uri, cancellationToken);
            if (!nsfwResult.IsSuccessful)
            {
                await DeleteNewlyUploadedFileAsync(newBlobName, cancellationToken);
                return nsfwResult.ToResult<Post>(default!);
            }

            var post = new Post
            {
                Caption = request.Caption,
                Url = uri.ToString(),
                AuthorId = UserId
            };

            return await CreatePostAsync(post, cancellationToken);
        }
        catch (Exception e)
        {
            return Result<Post>.Failure("Something unexpected occurred.", [e.ToString()], 500);
        }
    }

    private async Task<ValidationResult> ValidateInputAsync(CreatePostCommand request,
        CancellationToken cancellationToken)
    {
        return await validator.ValidateAsync(request, cancellationToken);
    }

    private async Task DeleteNewlyUploadedFileAsync(string blobName, CancellationToken cancellationToken)
    {
        await mediator.Send(
            new DeleteFileFromStorageCommand(blobName, StorageContainer),
            cancellationToken);
    }

    private async Task<Result<Uri>> UploadFileAsync(string blobName, IFormFile file,
        CancellationToken cancellationToken)
    {
        return await mediator.Send(new UploadFileToStorageCommand
        {
            ContainerName = StorageContainer,
            BlobName = blobName,
            ContentType = file.ContentType,
            Stream = file.OpenReadStream()
        }, cancellationToken);
    }

    private async Task<Result> ClassifyFileAsync(Uri uri, CancellationToken cancellationToken)
    {
        return await mediator.Send(new ClassifyImageCommand(uri), cancellationToken);
    }

    private async Task<Result<Post>> CreatePostAsync(Post post, CancellationToken cancellationToken)
    {
        var hashtags = await mediator.Send(new ExtractHashtagsCommand(post.Caption), cancellationToken);
        foreach (var hashtag in hashtags)
            post.Hashtags.Add(hashtag);

        db.Posts.Add(post);
        await db.SaveChangesAsync(cancellationToken);
        return Result<Post>.Success(post);
    }
}

public class CreatePostHandler(
    IHttpContextAccessor contextAccessor,
    DatabaseContext db,
    ISender mediator,
    IValidator<CreatePostCommand> validator)
    : RequestHandler(contextAccessor), IRequestHandler<CreatePostCommand, Result<Post>>
{
    private const string StorageContainer = "images";

    public async Task<Result<Post>> Handle(CreatePostCommand request, CancellationToken cancellationToken)
    {
        try
        {
            var validationResult = await ValidateInputAsync(request, cancellationToken);
            if (!validationResult.IsValid)
                return Result<Post>.Failure("Invalid input received.",
                    validationResult.ErrorMessages(), 400);

            var newBlobName = $"{Guid.NewGuid()}{request.File.GetExtensionType()}";
            var uploadResult = await UploadFileAsync(newBlobName, request.File, cancellationToken);

            if (!uploadResult.IsSuccessful)
                return uploadResult.ToResult(_ => new Post());

            var uri = uploadResult.Data;
            var nsfwResult = await ClassifyFileAsync(uri, cancellationToken);
            if (!nsfwResult.IsSuccessful)
            {
                await DeleteNewlyUploadedFileAsync(newBlobName, cancellationToken);
                return nsfwResult.ToResult<Post>(default!);
            }

            var post = new Post
            {
                Caption = request.Caption,
                Url = uri.ToString(),
                AuthorId = UserId
            };

            return await CreatePostAsync(post, cancellationToken);
        }
        catch (Exception e)
        {
            return Result<Post>.Failure("Something unexpected occurred.", [e.ToString()], 500);
        }
    }

    private async Task<ValidationResult> ValidateInputAsync(CreatePostCommand request,
        CancellationToken cancellationToken)
    {
        return await validator.ValidateAsync(request, cancellationToken);
    }

    private async Task DeleteNewlyUploadedFileAsync(string blobName, CancellationToken cancellationToken)
    {
        await mediator.Send(
            new DeleteFileFromStorageCommand(blobName, StorageContainer),
            cancellationToken);
    }

    private async Task<Result<Uri>> UploadFileAsync(string blobName, IFormFile file,
        CancellationToken cancellationToken)
    {
        return await mediator.Send(new UploadFileToStorageCommand
        {
            ContainerName = StorageContainer,
            BlobName = blobName,
            ContentType = file.ContentType,
            Stream = file.OpenReadStream()
        }, cancellationToken);
    }

    private async Task<Result> ClassifyFileAsync(Uri uri, CancellationToken cancellationToken)
    {
        return await mediator.Send(new ClassifyImageCommand(uri), cancellationToken);
    }

    private async Task<Result<Post>> CreatePostAsync(Post post, CancellationToken cancellationToken)
    {
        var hashtags = await mediator.Send(new ExtractHashtagsCommand(post.Caption), cancellationToken);
        foreach (var hashtag in hashtags)
            post.Hashtags.Add(hashtag);

        db.Posts.Add(post);
        await db.SaveChangesAsync(cancellationToken);
        return Result<Post>.Success(post);
    }
}

Any reasons as to why I'm getting this error?

27 replies

•Created by SwaggerLife on 2/23/2024 in #help

Azure video analyzer

:blue_siren: :blue_siren: Is there any azure service that I can use to analyze a video's content? I want to check whether or not a video contains, nudity or other inappropriate stuff?

5 replies

•Created by SwaggerLife on 2/10/2024 in #help

✅ Suggestion on file upload?

When uploading file to azure storage. Should I upload the files through the server (api)? or is there another way. The thing that scares me is that if multiple people upload at the same time than we will have a memory issue. The clients in this case are mobile apps? Any insights would be appreciated.

45 replies

•Created by SwaggerLife on 2/1/2024 in #help

Verify Google Id Token: FormatException

I'm using google sign in on my client. Before authenticating the user I want to Verify the ID Token which I get from the client. On the server side. I'm trying to validate the ID Token (jwt) by using Google.Apis.Auth nuget package. But I'm getting a format exception. Here is the code:

/// <summary>
///   Handler for verifying Google ID tokens.
/// </summary>
public class VerifyGoogleIdTokenHandler(IConfiguration configuration)
    : IRequestHandler<VerifyGoogleIdTokenCommand, Result<GoogleJsonWebSignature.Payload>>
{
    private readonly GoogleJsonWebSignature.ValidationSettings _settings = new()
    {
        Audience = new[]
        {
            configuration[ConfigurationKeys.GoogleWebClientId], configuration[ConfigurationKeys.GoogleAndroidClientId]
        }
    };

    public async Task<Result<GoogleJsonWebSignature.Payload>> Handle(VerifyGoogleIdTokenCommand request,
        CancellationToken cancellationToken)
    {
        try
        {
            var payload = await GoogleJsonWebSignature.ValidateAsync(request.IdToken, _settings);
            if (payload == null)
                throw new InvalidJwtException("Invalid ID token");

            return Result<GoogleJsonWebSignature.Payload>.Success(payload);
        }
        catch (Exception ex)
        {
            return Result<GoogleJsonWebSignature.Payload>.Failure("Invalid ID token", new[] { ex.ToString() }, 400);
        }
    }
}

/// <summary>
///   Handler for verifying Google ID tokens.
/// </summary>
public class VerifyGoogleIdTokenHandler(IConfiguration configuration)
    : IRequestHandler<VerifyGoogleIdTokenCommand, Result<GoogleJsonWebSignature.Payload>>
{
    private readonly GoogleJsonWebSignature.ValidationSettings _settings = new()
    {
        Audience = new[]
        {
            configuration[ConfigurationKeys.GoogleWebClientId], configuration[ConfigurationKeys.GoogleAndroidClientId]
        }
    };

    public async Task<Result<GoogleJsonWebSignature.Payload>> Handle(VerifyGoogleIdTokenCommand request,
        CancellationToken cancellationToken)
    {
        try
        {
            var payload = await GoogleJsonWebSignature.ValidateAsync(request.IdToken, _settings);
            if (payload == null)
                throw new InvalidJwtException("Invalid ID token");

            return Result<GoogleJsonWebSignature.Payload>.Success(payload);
        }
        catch (Exception ex)
        {
            return Result<GoogleJsonWebSignature.Payload>.Failure("Invalid ID token", new[] { ex.ToString() }, 400);
        }
    }
}

2 replies

•Created by SwaggerLife on 1/31/2024 in #help

ASP.NET Core Identity?

Is there a way here I can check if the token has expired or if it already has been used?

/// <summary>
/// Handles the logic for resetting a user's password based on the provided command.
/// </summary>
public class ResetPasswordHandler(UserManager<User> userManager)
    : IRequestHandler<ResetPasswordCommand, Result<bool>>, IDisposable
{
    public void Dispose()
    {
        userManager.Dispose();
        GC.SuppressFinalize(this);
    }

    public async Task<Result<bool>> Handle(ResetPasswordCommand request, CancellationToken cancellationToken)
    {
        // Validate the input using the ResetPasswordValidator.
        var validator = new ResetPasswordValidator();
        var validationResult = await validator.ValidateAsync(request, cancellationToken);

        if (!validationResult.IsValid)
            return Result<bool>.Failure("Invalid input received.", 400);

        // Find the user by email address.
        var user = await userManager.FindByEmailAsync(request.Email);
        if (user == null)
            return Result<bool>.Failure("User not found.", 404);

        // Reset the user's password.
        var result = await userManager.ResetPasswordAsync(user, request.Token, request.Password);

        // Return the appropriate result based on the reset operation success.
        return !result.Succeeded
            ? Result<bool>.Failure("Unable to reset password.", 500)
            : Result<bool>.Success(true);
    }
}

/// <summary>
/// Handles the logic for resetting a user's password based on the provided command.
/// </summary>
public class ResetPasswordHandler(UserManager<User> userManager)
    : IRequestHandler<ResetPasswordCommand, Result<bool>>, IDisposable
{
    public void Dispose()
    {
        userManager.Dispose();
        GC.SuppressFinalize(this);
    }

    public async Task<Result<bool>> Handle(ResetPasswordCommand request, CancellationToken cancellationToken)
    {
        // Validate the input using the ResetPasswordValidator.
        var validator = new ResetPasswordValidator();
        var validationResult = await validator.ValidateAsync(request, cancellationToken);

        if (!validationResult.IsValid)
            return Result<bool>.Failure("Invalid input received.", 400);

        // Find the user by email address.
        var user = await userManager.FindByEmailAsync(request.Email);
        if (user == null)
            return Result<bool>.Failure("User not found.", 404);

        // Reset the user's password.
        var result = await userManager.ResetPasswordAsync(user, request.Token, request.Password);

        // Return the appropriate result based on the reset operation success.
        return !result.Succeeded
            ? Result<bool>.Failure("Unable to reset password.", 500)
            : Result<bool>.Success(true);
    }
}

If so how do I set the expiration time?

1 replies

•Created by SwaggerLife on 1/30/2024 in #help

How to tell SwaggerUI to display `Enum` by the name and not integer value?

I want SwaggerUI to display Enum by the name and not integer value. The only problem is that when triggering an action it's sending the name to the pipline.

public class EnumSchemaFilter : ISchemaFilter
{
    public void Apply(OpenApiSchema model, SchemaFilterContext context)
    {
        if (context.Type.IsEnum)
        {
            model.Enum.Clear();
            Enum.GetNames(context.Type)
                .ToList()
                .ForEach(name => model.Enum.Add(new OpenApiString($"{Convert.ToInt64(Enum.Parse(context.Type, name))} = {name}")));
        }
    }
}

public class EnumSchemaFilter : ISchemaFilter
{
    public void Apply(OpenApiSchema model, SchemaFilterContext context)
    {
        if (context.Type.IsEnum)
        {
            model.Enum.Clear();
            Enum.GetNames(context.Type)
                .ToList()
                .ForEach(name => model.Enum.Add(new OpenApiString($"{Convert.ToInt64(Enum.Parse(context.Type, name))} = {name}")));
        }
    }
}

Is there a way I can tell swagger to only display the enums as their string name? But it should still handle everything by their integer values?

1 replies

•Created by SwaggerLife on 1/28/2024 in #help

✅ Regex help pls:

^[a-z]+(?:_[a-z]+)?[a-z]+$ how can I check so that there are atleast 4 characters?

13 replies

•Created by SwaggerLife on 1/18/2024 in #help

Tips on choosing the right database

I'm currently working on a social media project that involves features like comments, replies, following, followers, and posts. I'm in the process of choosing the right database for the project and wanted to reach out to seek valuable insights. Considering the dynamic nature of social media interactions and the need for efficient data retrieval, I'm a bit torn between different database options. Do you guys have any recommendations or insights on which database might be a good fit for managing the complexities of user interactions? I don't have that much experience in other databases. I'm only familiar with SQL.

10 replies

•Created by SwaggerLife on 7/13/2023 in #help

❔ Linq Query HELP

I have this entity. During deletion, I would like to load all related entities, so that I can delete them also. Here is the entity

/// <summary>
///     Represents a comment entity.
/// </summary>
public class Comment : AbstractEntity, ISuspension
{
    public required string Content { get; set; }
    public int Depth { get; set; }
    public Guid AuthorId { get; set; }
    public virtual User Author { get; set; } = default!;
    public Guid QuoteId { get; set; }
    public virtual Quote Quote { get; set; } = default!;
    public Guid? ParentId { get; set; }
    public virtual Comment ParentComment { get; set; } = default!;
    public virtual ICollection<Comment> Replies { get; set; } = new HashSet<Comment>();
    public virtual ICollection<Like<Comment>> Likes { get; set; } = new HashSet<Like<Comment>>();
    public virtual ICollection<Dislike<Comment>> Dislikes { get; set; } = new HashSet<Dislike<Comment>>();
    public virtual ICollection<Suspension<Comment>> Suspensions { get; set; } = new HashSet<Suspension<Comment>>();
    public bool IsSuspended { get; set; }
}

/// <summary>
///     Represents a comment entity.
/// </summary>
public class Comment : AbstractEntity, ISuspension
{
    public required string Content { get; set; }
    public int Depth { get; set; }
    public Guid AuthorId { get; set; }
    public virtual User Author { get; set; } = default!;
    public Guid QuoteId { get; set; }
    public virtual Quote Quote { get; set; } = default!;
    public Guid? ParentId { get; set; }
    public virtual Comment ParentComment { get; set; } = default!;
    public virtual ICollection<Comment> Replies { get; set; } = new HashSet<Comment>();
    public virtual ICollection<Like<Comment>> Likes { get; set; } = new HashSet<Like<Comment>>();
    public virtual ICollection<Dislike<Comment>> Dislikes { get; set; } = new HashSet<Dislike<Comment>>();
    public virtual ICollection<Suspension<Comment>> Suspensions { get; set; } = new HashSet<Suspension<Comment>>();
    public bool IsSuspended { get; set; }
}

I have come this far

var comment = await DbContext.Comments
            .Include(x => x.Replies)
            .ThenInclue(x => x.Likes)
            .ThenInclue(x => x.Dislikes)
            .ThenInclue(x => x.Suspensions)
            .Include(x => x.Likes)
            .Include(x => x.Dislikes)
            .Include(x => x.Suspensions)
            .FirstOrDefaultAsync(x => x.Id == request.Id && x.AuthorId == UserId, cancellationToken);

var comment = await DbContext.Comments
            .Include(x => x.Replies)
            .ThenInclue(x => x.Likes)
            .ThenInclue(x => x.Dislikes)
            .ThenInclue(x => x.Suspensions)
            .Include(x => x.Likes)
            .Include(x => x.Dislikes)
            .Include(x => x.Suspensions)
            .FirstOrDefaultAsync(x => x.Id == request.Id && x.AuthorId == UserId, cancellationToken);

I would like to load the Replies, and there likes, dislikes, suspensions. I also need to load the replies of replies and there likes, dislikes, suspensions etc. Any help would be appreciated. I don't think this query will do the job.

5 replies

•Created by SwaggerLife on 7/12/2023 in #help

❔ Will this operation be expensive or not?

During a request, I'm checking whether a user is currently suspended or not. So during each request I'm hitting the database and getting the user

builder.Services.AddAuthentication(options =>
            {
                options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
                options.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
                options.DefaultScheme = JwtBearerDefaults.AuthenticationScheme;
            })
            .AddJwtBearer(options =>
            {
                options.SaveToken = true;
                options.RequireHttpsMetadata = false;
                options.Events = new JwtBearerEvents
                {
                    OnTokenValidated = async context =>
                    {
                        var claimsPrincipal = context.Principal;
                        if (claimsPrincipal == null)
                        {
                            context.Fail("Access denied");
                            return;
                        }

                        var claim = claimsPrincipal.Claims.FirstOrDefault(c => c.Type == ClaimTypes.NameIdentifier)?.Value;
                        if (string.IsNullOrEmpty(claim) || !Guid.TryParse(claim, out _))
                        {
                            context.Fail("Access denied.");
                            return;
                        }
                        
                        var userManager = context.HttpContext.RequestServices.GetRequiredService<UserManager<User>>();
                        var user = await userManager.FindByIdAsync(claim);

                        if (user == null || user.IsSuspended)
                        {
                            context.Fail("Access denied.");
                        }
                    }
                };

builder.Services.AddAuthentication(options =>
            {
                options.DefaultAuthenticateScheme = JwtBearerDefaults.AuthenticationScheme;
                options.DefaultChallengeScheme = JwtBearerDefaults.AuthenticationScheme;
                options.DefaultScheme = JwtBearerDefaults.AuthenticationScheme;
            })
            .AddJwtBearer(options =>
            {
                options.SaveToken = true;
                options.RequireHttpsMetadata = false;
                options.Events = new JwtBearerEvents
                {
                    OnTokenValidated = async context =>
                    {
                        var claimsPrincipal = context.Principal;
                        if (claimsPrincipal == null)
                        {
                            context.Fail("Access denied");
                            return;
                        }

                        var claim = claimsPrincipal.Claims.FirstOrDefault(c => c.Type == ClaimTypes.NameIdentifier)?.Value;
                        if (string.IsNullOrEmpty(claim) || !Guid.TryParse(claim, out _))
                        {
                            context.Fail("Access denied.");
                            return;
                        }
                        
                        var userManager = context.HttpContext.RequestServices.GetRequiredService<UserManager<User>>();
                        var user = await userManager.FindByIdAsync(claim);

                        if (user == null || user.IsSuspended)
                        {
                            context.Fail("Access denied.");
                        }
                    }
                };

It just feel like this is not the right way?

8 replies

•Created by SwaggerLife on 5/19/2023 in #help

❔ Upload large files to azure storage!

Does anyone have a method that uploads large files to azure storage efficiently? I'm using

Azure.Storage.Blobs

Azure.Storage.Blobs

Here is the current method

public async Task<Uri?> UploadFileAsync(string containerName, string fileName, Stream stream,
        CancellationToken cancellationToken)
    {
        try
        {
            var containerClient = _blobService.GetBlobContainerClient(containerName);
            await containerClient.CreateIfNotExistsAsync(cancellationToken: cancellationToken);
            var blobClient = containerClient.GetBlockBlobClient(fileName);
            
            var options = new BlobUploadOptions
            {
                TransferOptions = new StorageTransferOptions
                {
                    MaximumConcurrency = 16, // Adjust the concurrency level as needed
                    MaximumTransferSize = 4 * 1024 * 1024, // 4MB chunk size
                },
            };

            await blobClient.UploadAsync(stream, options, cancellationToken);
            return blobClient.Uri;
        }
        catch (Exception ex)
        {
            return null;
        }
    }

public async Task<Uri?> UploadFileAsync(string containerName, string fileName, Stream stream,
        CancellationToken cancellationToken)
    {
        try
        {
            var containerClient = _blobService.GetBlobContainerClient(containerName);
            await containerClient.CreateIfNotExistsAsync(cancellationToken: cancellationToken);
            var blobClient = containerClient.GetBlockBlobClient(fileName);
            
            var options = new BlobUploadOptions
            {
                TransferOptions = new StorageTransferOptions
                {
                    MaximumConcurrency = 16, // Adjust the concurrency level as needed
                    MaximumTransferSize = 4 * 1024 * 1024, // 4MB chunk size
                },
            };

            await blobClient.UploadAsync(stream, options, cancellationToken);
            return blobClient.Uri;
        }
        catch (Exception ex)
        {
            return null;
        }
    }

5 replies

•Created by SwaggerLife on 5/15/2023 in #help

❔ RequestSizeLimit on Actions not Working!

I have an action that is uploading a large file. The file size is 189mb. For some reason I'm getting this error 413 Error: Request Entity Too Large. I even tried adding the RequestSizeLimit attribute on top of the action but it still has no effect. Here is the action

[RequestSizeLimit(int.MaxValue)]
    [HttpPost]
    [Authorize]
    [SwaggerOperation("An action for creating an episode.")]
    public async Task<IActionResult> CreateEpisodeAsync([FromForm] CreateEpisodeRequest request,
        CancellationToken cancellationToken = default)
    {
        var result = await _mutationService.CreateEpisodeAsync(request, cancellationToken);
        var response = result.ToApiResponse();

        if (result.IsSuccessful)
            response.StatusCode = HttpStatusCode.Created;
        else
            response.StatusCode = result.ErrorCode switch
            {
                ErrorCode.NotFound => HttpStatusCode.NotFound,
                ErrorCode.InternalServerError => HttpStatusCode.InternalServerError,
                _ => HttpStatusCode.BadRequest
            };

        return response.ToActionResult();
    }

[RequestSizeLimit(int.MaxValue)]
    [HttpPost]
    [Authorize]
    [SwaggerOperation("An action for creating an episode.")]
    public async Task<IActionResult> CreateEpisodeAsync([FromForm] CreateEpisodeRequest request,
        CancellationToken cancellationToken = default)
    {
        var result = await _mutationService.CreateEpisodeAsync(request, cancellationToken);
        var response = result.ToApiResponse();

        if (result.IsSuccessful)
            response.StatusCode = HttpStatusCode.Created;
        else
            response.StatusCode = result.ErrorCode switch
            {
                ErrorCode.NotFound => HttpStatusCode.NotFound,
                ErrorCode.InternalServerError => HttpStatusCode.InternalServerError,
                _ => HttpStatusCode.BadRequest
            };

        return response.ToActionResult();
    }

5 replies

•Created by SwaggerLife on 5/14/2023 in #help

❔ How do I prevent access to a web server (web api application) from certain clients?

I have a web api running on azure. I also have 2 clients, 1 android app and 1 ios app. The client uses json web tokens to communicate with the server. This is how the authorization is done. In theory the json web tokens are acting like api keys to retrieve and mutate data. But if the user get's their hand on the token, they can make requests to the server from other application/services. Example: they could have their own website that is making calls to the web server with the jwt. Is there a way, I can only allow incoming requests from a certain specific client? In this case our (mobil apps).

14 replies

•Created by SwaggerLife on 5/12/2023 in #help

✅ Only add certain controllers?

Is there a way I can only add/map certain controllers based on if the application is in development or production? I was thinking of using some sort of attribute but don't know how?

3 replies