thuru-zz

<policies>
    <inbound>
		<!-- validates RS256 JWT token -->
        <validate-jwt header-name="massrover_token" failed-validation-httpcode="401" failed-validation-error-message="Unauthorized"
            require-expiration-time="true" require-signed-tokens="true">
             <audiences>
                 <audience>audience id</audience>
             </audiences>
             <issuers>
                 <issuer>issuer id</issuer>

thuru-zz

using Microsoft.Azure.Documents;
using System.Collections.Generic;
using System;

public static async Task Run(IReadOnlyList<Document> input, TraceWriter log)
{
    foreach(var changeInput in input)
    {
        if(changeInput.GetPropertyValue<string>("city") == "colombo")
        {

thuru-zz

using Microsoft.Azure.Documents;
using Microsoft.Azure.Documents.Client;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace SQLSDK
{

thuru-zz

public class ChangeFeedProcessorSDK
    {

        private readonly DocumentCollectionInfo _monitoredCollection;
        private readonly DocumentCollectionInfo _leaseCollection;
        public ChangeFeedProcessorSDK(DocumentCollectionInfo monitorCollection, DocumentCollectionInfo leaseCollection)
        {
            _monitoredCollection = monitorCollection;
            _leaseCollection = leaseCollection;
        }

thuru-zz

<Project Sdk="Microsoft.NET.Sdk.Web">

  <PropertyGroup>
    <TargetFramework>net471</TargetFramework>
  </PropertyGroup>

  <ItemGroup>
    <Folder Include="wwwroot\" />
  </ItemGroup>

thuru-zz

public void ConfigureServices(IServiceCollection services)
{
        services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);

         // This is right
         services.AddSingleton<IProductService, ProductService>();
            
         // this is wrong and DV should fail
         services.AddSingleton<IMyDbContext, MyDbContext>();
}

thuru-zz

protected override IEnumerable<ServiceInstanceListener> CreateServiceInstanceListeners()
        {
            return new ServiceInstanceListener[]
            {
                new ServiceInstanceListener(serviceContext =>
                    new HttpSysCommunicationListener(serviceContext, "GatewayHttpSysServiceEnpoint", (url, listener) =>
                    {
                        ServiceEventSource.Current.ServiceMessage(serviceContext, $"Starting HttpSys on {url}");

                        return new WebHostBuilder()

thuru-zz

public class ReverseProxyServiceResponseFilter : IResultFilter
{
        public void OnResultExecuted(ResultExecutedContext context)
        {
            if(context.HttpContext.Response.StatusCode == 404)
            {
                context.HttpContext.Response.Headers.Add("X-ServiceFabric", "ResourceNotFound");
            }
        }

thuru-zz

string reverseProxyUrl = "http://localhost:19801/ApplicationName/InternalServiceName/RestOfTheUri";

var httpClient = new HttpClient();
var response = await httpClient.GetAsync(reverseProxyUrl);

thuru-zz

string reverseProxyUrl = "http://localhost:19801/ApplicationName/InternalServiceName/RestOfTheUri";

var httpClient = new HttpClient();
var response = await httpClient.GetAsync(reverseProxyUrl);