DEV Community

Discussion on: Get your C# WebAPI controller to keep processing a request after returning 200 OK

Collapse
 
zoltanhalasz profile image
Zoltan Halasz

I have a similar situation in my webApi. The returned value is an entity , which needs long processing as the SQL query is complex (could take even 10-20 seconds). Is this a viable solution to return a value in the finally branch?

Collapse
 
deanashton profile image
Dean Ashton • Edited

Hi Zoltan, sorry for the late reply. Unfortinately I don't think so. This method ha already returned the result by the time you would finish processing. It's really only for things like exporting data to a file or sending a message in a queue for later processing (where the output of the processing is not returned to the caller)

In my case, the processing time for the longrunning task was 1 hour :)

Collapse
 
ryanobray profile image
RyanObray • Edited

Zoltan, I know this is way after the fact but I thought I'd post anyway. You might be able to get creative and push a response after the fact using something like SignalR. But I'm not totally sure if there would be issues trying to do it within a thread that's associated to an active HTTP pipeline request.

There are some other interesting things you can do by writing to the response stream in stages also. A few years ago I was curious about a multi-stage response where I wanted render a page back to the end user and continue updating it as different steps were completing before ultimately redirecting the response to somewhere else. This is how I did it.

At the top of my controller I defined these variables:

private const string htmlPageTemplate = @"<!DOCTYPE HTML>
<html>
    <head>
        <title>Learning Management - Course Auto-Enrollment</title>
        <style>
            body {{
                font-size: 1.2em;
                color: rgb(33, 34, 37);
                font-weight: 400;
                margin-bottom: .889em;
            }}
            h1.error {{
                color: firebrick;
            }}
            h1, h2, h3 {{
                line-height: 1.2;
            }}
            h1
            {{                
                font-weight: 700;
                font-size: 1.5em;
            }}
            h3 {{
                font-weight: 600;
                font-size: 1em;                
            }}
            #output
            {{
                margin: 0 20px;
            }}
            .loader {{
              border: 4px solid #f3f3f3;
              border-top: 4px solid #3498db;
              border-radius: 50%;
              width: 15px;
              height: 15px;
              animation: spin 1s linear infinite;
            }}

            @keyframes spin {{
              0% {{ transform: rotate(0deg); }}
              100% {{ transform: rotate(360deg); }}
            }}
            .stepRow {{
                display: flex;
                width: 100% ;
            }}
            .stepCell, .loaderCell {{
                display: flex;
                height: 2rem;
                align-items: center;
            }}
            .loaderCell {{
                margin-left: 8px;
            }}
            .content {{
                position: relative;
                min-height: 400px;
                padding: 1.5em;
            }}
            .modal {{
                display: none;
                position:absolute;
                z-index: 1;
                left: 0;
                top: 0;
                width: 100%;
                height: 100%;
                overflow: auto;
                background-color: rgb(0,0,0);
                background-color: rgba(0,0,0,0.6);
            }}

            /* Modal Content/Box */
            .modal-content {{
                background-color: #fefefe;
                margin: 25px auto;
                padding: 20px;
                border: 1px solid #333;
                min-height: 300px;
                width: 80%;
            }}
            .bold {{
                font-weight: bold;
            }}
            .requestIdBox {{
                font-size: .75em;
                margin-top: 25px;
                padding-top: 25px;
                border-top: 1px solid rgb(221, 221, 221);
            }}
        </style>
        <script>        
            function addStep(stepText)
            {{
                var output = document.querySelector('#output');
                var loaders = document.querySelectorAll('.loader');
                if(loaders != null && loaders.length > 0)
                {{
                    loaders.forEach(function(loaderItem) {{
                        var loaderParent = loaderItem.parentElement;
                        loaderParent.innerHTML = '(done)';
                    }});
                }}                

                var stepRow = document.createElement('div');
                var stepCell = document.createElement('div');    
                var loaderCell = document.createElement('div');
                var loader = document.createElement('div');

                stepRow.className = 'stepRow';
                stepCell.className = 'stepCell';
                loaderCell.className = 'loaderCell';
                loader.className = 'loader'

                loaderCell.appendChild(loader);        
                stepRow.appendChild(stepCell);
                stepRow.appendChild(loaderCell);
                output.appendChild(stepRow);
                stepCell.innerHTML = stepText;  
            }}
            function showError(header, message, requestId)
            {{
                var modal = document.querySelector('#erroModal');
                var errorHeader = document.querySelector('#errorHeader');
                var errorMessage = document.querySelector('#errorMessage');
                var errorRequestId = document.querySelector('#requestId');
                var loaders = document.querySelectorAll('.loader');

                if(loaders != null && loaders.length > 0)
                {{
                    loaders.forEach(function(loaderItem) {{
                        var loaderParent = loaderItem.parentElement;
                        loaderParent.innerHTML = '(fail)';
                    }});
                }}

                errorHeader.innerHTML = header;
                errorMessage.innerHTML = message;
                errorRequestId.innerHTML = requestId;
                modal.style.display = 'block';
            }}     
        </script>
        {0}
    </head>
    <body>
        {1}
        <div class=""content"">
            <h1>Course Auto-Enrollment</h1>
            <p>You are not currently enrolled in the training you are trying to access. If the course supports auto-enrollment, you will be enrolled now and will then be redirected to the learning management system. Please be patient.</p>
            <h3>Enrollment Progress:</h3>
            <div id=""output""></div>
            <div id=""erroModal"" class=""modal"">
                <div class=""modal-content"">
                    <h1 id=""errorHeader"" class=""error""></h1>
                    <p id=""errorMessage""></p>
                    <div class=""requestIdBox"">
                        <span class=""bold"">Request ID: </span><span id = ""requestId""></span>
                    </div>
                </div>          
            </div>
        </div>
        {2}
    </body>
</html>
";

private const string stepTemplate = @"
<script>
    (function(){{
        addStep('&bull; {0}');
    }}());
</script>
";

private const string errorTemplate = @"
<script>
    (function(){{
        showError('{0}', '{1}', '{2}');
    }}());
</script>
";

private const string redirectTemplate = @"
<script>
    (function(){{
        window.location.replace('{0}');
    }}());
</script>
";  
Enter fullscreen mode Exit fullscreen mode

Notice that the first variable is basically a full static web page and the others are JavaScript blocks that fire functions defined in the static page to add steps to the output, display errors or redirect the browser.

This is what the controller method handling the call looks like:

[Route("{assignmentArea}/{assignmentId}/autoenroll"), HttpGet]
public async Task AutoEnroll(LmsAssignmentArea assignmentArea, int assignmentId, [FromQuery] string auth, CancellationToken cancellationToken)
        {
            Response.Clear();
            var htmlPage = string.Format(htmlPageTemplate,
                                        LocalCache.GetHeaderFooterValue(_logger, HeaderFooterSetting.PageScript),
                                        LocalCache.GetHeaderFooterValue(_logger, HeaderFooterSetting.PageNavBar),
                                        LocalCache.GetHeaderFooterValue(_logger, HeaderFooterSetting.PageFooter));

           await Response.WriteAsync(htmlPage, cancellationToken);

           await DoAutoEnroll(assignmentArea, assignmentId,
             async (autoEnrollStep, trainingName) =>
            {
                switch (autoEnrollStep)
                {
                    case AutoEnrollmentStep.EvaluatingRequirements:
                        await Response.WriteAsync(string.Format(stepTemplate, $"Evaluating training requirements and trainee assignment. ({assignmentArea}-{assignmentId})".FormatForJsStringParam()), cancellationToken);
                        await Task.Delay(500);
                        break;
                    case AutoEnrollmentStep.CreatingTrainingAssignment:
                        await Response.WriteAsync(string.Format(stepTemplate, "Creating training assignment.".FormatForJsStringParam()), cancellationToken);
                        await Task.Delay(500);
                        break;
                    case AutoEnrollmentStep.SynchingAssignmentToLms:
                        await Response.WriteAsync(string.Format(stepTemplate, "Sending training assignment to the learning management system.".FormatForJsStringParam()), cancellationToken);
                        await Task.Delay(500);
                        break;
                    case AutoEnrollmentStep.ValidatingAssignmentStatus:
                        await Response.WriteAsync(string.Format(stepTemplate, "Validating assignment status.".FormatForJsStringParam()), cancellationToken);
                        await Task.Delay(500);
                        break;
                    case AutoEnrollmentStep.EnrollingToTraining:
                        await Response.WriteAsync(string.Format(stepTemplate, $"Enrolling you to course \"{trainingName ?? "undefined"}\".".FormatForJsStringParam()), cancellationToken);
                        await Task.Delay(500);
                        break;
                    default:
                        var errorMessage = $"AUTOENROLL.StepEval.Exception.E.! - Auto enrollment step \"{autoEnrollStep}\" is not properly accounted for in the auto enrollment routine.";
                        this.HandleAPIException("EnrollmentController.SelfAutoEnroll", _logger, errorMessage, new Exception(errorMessage), _localizationSettings.PreferredTimeZone, true, _emailProvider);
                        break;
                }
            },
            async (redirectLocation) =>
            {
                await Response.WriteAsync(string.Format(stepTemplate, "Redirecting to the learning center.".FormatForJsStringParam()), cancellationToken);
                await Response.WriteAsync(string.Format(redirectTemplate, redirectLocation.FormatForJsStringParam()), cancellationToken);
            },
            async (exception, sendEmail, clientMessage, userCanceledRequest) =>
            {
                if (!userCanceledRequest)
                {
                    clientMessage = clientMessage.FormatForJsStringParam();
                    var requestId = this.HandleAPIException("EnrollmentController.SelfAutoEnroll", _logger, clientMessage, exception, _localizationSettings.PreferredTimeZone, sendEmail, _emailProvider);
                    await Response.WriteAsync(string.Format(errorTemplate, "Course Enrollment Failed", clientMessage ?? "An unhandled error occurred.", requestId ?? "(unspecified)"), cancellationToken);
                    await Response.Body.FlushAsync(cancellationToken);
                }
            }, cancellationToken);
        }
Enter fullscreen mode Exit fullscreen mode

Basically what's happening in the handler method is:

  1. I'm clearing the response which I believe I had to do in order to write to it more than once
  2. I call await Response.WriteAsync(<string here>) every time I want to write something back to the browser

Don't get too confused by the DoAutoEnroll(...) method. It's a method that takes several Func definitions that are fired in the method definition depending on the required logic.

The crux of this working is that the first Response.WriteAsync(...) needs to return a fully functional HTML document so something complete can be rendered to the end user's browser. Each subsequent Response.WriteAsync(...) actually appends a <script> block to the bottom of the document and because it contains an immediate function, it fires right after it's rendered which allows me to inject content back into the main body of the HTML document. Before doing this, I didn't realize that you can actually write <script> blocks after the </html> tag and that they still work fine.

Anyway, this is a weird one but for this very specific use case, I found it useful to keep the end user informed as I performed steps in a process and then finally write back the script block that redirects them to a different location.

SignalR is definitely more elegant but gets a little more sticky in a clustered environment. This solution is quick and a little unconventional but came in handy for me.