#r "Newtonsoft.Json"

using System.Net;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Primitives;
using Newtonsoft.Json;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Microsoft.Azure.Management.ResourceManager.Fluent;
using Microsoft.IdentityModel.Clients.ActiveDirectory;
using Microsoft.Rest;
using System.Linq;

public static async Task<IActionResult> Run(HttpRequest req, ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");
 
            int capacity;
 
            if (!string.IsNullOrEmpty(req.Query["capacity"]) && int.TryParse(req.Query["capacity"], out capacity))
            {
                log.LogInformation("You want to chagne the capacity to "+ capacity.ToString());
                // Step1. How to: Use the portal to create an Azure AD application and service principal that can access resources
                //      https://docs.microsoft.com/en-us/azure/active-directory/develop/howto-create-service-principal-portal
 
                // Step2. How to: Add app roles in your application and receive them in the token
                //      https://docs.microsoft.com/en-us/azure/active-directory/develop/howto-add-app-roles-in-azure-ad-apps
                // For security concerns, I only give the resource group => contributor 
                //                          and the service plan read permission
 
                var subscriptionId = "Your Subscription Id";
                var appId = "e6f6d231-Your-App-Id";
                var secretKey = "2z]pj0vy2JRapjo:R@TJSoW1AmOCC=o8";
                var tenantId = "72f988bf-Your Tenant-id";
                var resourceGroup = "jackywebl1rg";
                var servicePlanName = "ASP-jackywebl1rg-81ee";
 
 
                // Step 3. change capacity
                var context = new AuthenticationContext("https://login.windows.net/" + tenantId);
                ClientCredential clientCredential = new ClientCredential(appId, secretKey);
                var tokenResponse = context.AcquireTokenAsync("https://management.azure.com/", clientCredential).Result;
                var accessToken = tokenResponse.AccessToken;
                TokenCredentials credential = new TokenCredentials(accessToken);
                var webSiteManagementClient = new Microsoft.Azure.Management.WebSites.WebSiteManagementClient(credential);
                webSiteManagementClient.SubscriptionId = subscriptionId;
                var servicePlan = webSiteManagementClient.AppServicePlans.ListByResourceGroupWithHttpMessagesAsync(resourceGroup).Result.Body.Where(x => x.Name.Equals(servicePlanName)).FirstOrDefault();
 
                var appServicePlanRequest = await webSiteManagementClient.AppServicePlans.ListByResourceGroupWithHttpMessagesAsync(resourceGroup);
                appServicePlanRequest.Body.ToList().ForEach(x => log.LogInformation($">>>{x.Name}"));
                var appServicePlan = appServicePlanRequest.Body.Where(x => x.Name.Equals(servicePlanName)).FirstOrDefault();
                if (appServicePlan == null)
                {
                    log.LogError("Could not find app service plan.");
                }
 
                //scale up/down
                //servicePlan.Sku.Family = "P";
                //servicePlan.Sku.Name = "P1v2";
                //servicePlan.Sku.Size = "P1v2";
                //servicePlan.Sku.Tier = "PremiumV2";
                servicePlan.Sku.Capacity = capacity; // scale out: number of instances 
                var updateResult = webSiteManagementClient.AppServicePlans.CreateOrUpdateWithHttpMessagesAsync(resourceGroup, servicePlanName, servicePlan).Result;
                log.LogInformation("Completed!!");
                return (ActionResult)new OkObjectResult($"Hello, {capacity} {updateResult.Response.StatusCode}");
            }
            else
            {
                return new BadRequestObjectResult("Please pass a capacity on the query string or in the request body");
            }

}

using System;
using System.IO;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Extensions.Http;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using Microsoft.Azure.Management.ResourceManager.Fluent;
using Microsoft.IdentityModel.Clients.ActiveDirectory;
using Microsoft.Rest;
using System.Linq;
 
namespace ScaleWebAppFunction
{
    public static class Function1
    {
        [FunctionName("ScaleWebApp")]
        public static async Task<IActionResult> Run(
            [HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = null)] HttpRequest req,
            ILogger log)
        {
            log.LogInformation("C# HTTP trigger function processed a request.");
 
            int capacity;
 
            if (!string.IsNullOrEmpty(req.Query["capacity"]) && int.TryParse(req.Query["capacity"], out capacity))
            {
                log.LogInformation("You want to chagne the capacity to "+ capacity.ToString());
                // Step1. How to: Use the portal to create an Azure AD application and service principal that can access resources
                //      https://docs.microsoft.com/en-us/azure/active-directory/develop/howto-create-service-principal-portal
 
                // Step2. How to: Add app roles in your application and receive them in the token
                //      https://docs.microsoft.com/en-us/azure/active-directory/develop/howto-add-app-roles-in-azure-ad-apps
                // For security concerns, I only give the resource group => contributor 
                //                          and the service plan read permission
 
                var subscriptionId = "Your subscription id";
                var appId = "e6f6d231-Your-App_id";
                var secretKey = "2z]pj0vy2JRapjo:R@TJSoW1AmOCC=o8";
                var tenantId = "72f988bf-Your-Tenant-Id";
                var resourceGroup = "jackywebl1rg";
                var servicePlanName = "ASP-jackywebl1rg-81ee";
 
 
                // Step 3. change capacity
                var context = new AuthenticationContext("https://login.windows.net/" + tenantId);
                ClientCredential clientCredential = new ClientCredential(appId, secretKey);
                var tokenResponse = context.AcquireTokenAsync("https://management.azure.com/", clientCredential).Result;
                var accessToken = tokenResponse.AccessToken;
                TokenCredentials credential = new TokenCredentials(accessToken);
                var webSiteManagementClient = new Microsoft.Azure.Management.WebSites.WebSiteManagementClient(credential);
                webSiteManagementClient.SubscriptionId = subscriptionId;
                var servicePlan = webSiteManagementClient.AppServicePlans.ListByResourceGroupWithHttpMessagesAsync(resourceGroup).Result.Body.Where(x => x.Name.Equals(servicePlanName)).FirstOrDefault();
 
                var appServicePlanRequest = await webSiteManagementClient.AppServicePlans.ListByResourceGroupWithHttpMessagesAsync(resourceGroup);
                appServicePlanRequest.Body.ToList().ForEach(x => log.LogInformation($">>>{x.Name}"));
                var appServicePlan = appServicePlanRequest.Body.Where(x => x.Name.Equals(servicePlanName)).FirstOrDefault();
                if (appServicePlan == null)
                {
                    log.LogError("Could not find app service plan.");
                }
 
                //scale up/down
                //servicePlan.Sku.Family = "P";
                //servicePlan.Sku.Name = "P1v2";
                //servicePlan.Sku.Size = "P1v2";
                //servicePlan.Sku.Tier = "PremiumV2";
                servicePlan.Sku.Capacity = capacity; // scale out: number of instances 
                var updateResult = webSiteManagementClient.AppServicePlans.CreateOrUpdateWithHttpMessagesAsync(resourceGroup, servicePlanName, servicePlan).Result;
                log.LogInformation("Completed!!");
                return (ActionResult)new OkObjectResult($"Hello, {capacity} {updateResult.Response.StatusCode}");
            }
            else
            {
                return new BadRequestObjectResult("Please pass a capacity on the query string or in the request body");
            }
            
        }
    }
}

static async Task MainAsync()
    {
        Func<CancellationToken, Task<SecuritySettings>> GetSecurityCredentials = (ct) =>
        {
            // get the X509Certificate2 either from Certificate store or from file.
            var clientCert = new System.Security.Cryptography.X509Certificates.X509Certificate2(@"C:\Users\jchiou\jackysf320191031213903.pfx", "Password01!");
            var remoteSecuritySettings = new RemoteX509SecuritySettings(new List<string> { "8AB797576F2EF93574631A6BD7C5B381C86A60C4" });
            return Task.FromResult<SecuritySettings>(new X509SecuritySettings(clientCert, remoteSecuritySettings));
        };

        // create client using ServiceFabricClientBuilder.UseX509Security
        var client = new ServiceFabricClientBuilder()
                        .UseEndpoints(new Uri(@"https://jackysf3.eastasia.cloudapp.azure.com:19080"))
                        .UseX509Security(GetSecurityCredentials)
                        .BuildAsync().GetAwaiter().GetResult();

        await client.Services.UpdateServiceAsync("ServiceFabricApp1~Stateless1", new StatelessServiceUpdateDescription(instanceCount: 5, defaultMoveCost: Microsoft.ServiceFabric.Common.MoveCost.Zero, flags: "1"));

        var serviceDesc = await client.Services.GetServiceDescriptionAsync("ServiceFabricApp1~Stateless1");

    }

using System;
using System.Threading.Tasks;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Host;
using Microsoft.Extensions.Logging;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Blob;
 
namespace DeleteFilesOlderThanXDays
{
    public static class DeleteFilesOlderThan30Days
    {
        [FunctionName("DeleteFilesOlderThan30Days")]
        public async static Task Run([TimerTrigger("0 30 3 * * *")]TimerInfo myTimer, ILogger log)
        {
            log.LogInformation($"C# Timer trigger function executed at: {DateTime.Now}");
 
            string accountName = "Your Storage Account Name";
            string accountKey = "Your Account Access Key";
 
            log.LogInformation("Storage Account Name: " + accountName);
            var account = new CloudStorageAccount(new StorageCredentials(accountName, accountKey), true);
            var blobClient = account.CreateCloudBlobClient();
//change it to your container name
            var container = blobClient.GetContainerReference("Your Container Name");
 
            log.LogInformation("Get a list of all blobs in your container");     
            
            BlobResultSegment result = await container.ListBlobsSegmentedAsync(null);
 
            log.LogInformation("Iterate each blob");
 
            int segmentSize = 10000;
 
            BlobContinuationToken continuationToken = null;
            CloudBlob blob;
 
            try
            {
                // Call the listing operation and enumerate the result segment.
                // When the continuation token is null, the last segment has been returned
                // and execution can exit the loop.
                do
                {
                    BlobResultSegment resultSegment = await container.ListBlobsSegmentedAsync(string.Empty,
                        true, BlobListingDetails.Metadata, segmentSize, continuationToken, null, null);
 
                    foreach (var blobItem in resultSegment.Results)
                    {
                        // A flat listing operation returns only blobs, not virtual directories.
                        blob = (CloudBlob)blobItem;
 
                        // Write out some blob properties.
                        log.LogInformation("Blob name: {0} {1}", blob.Name, blob.Properties.LastModified);
 
                        log.LogInformation("Calculate when LastModified is compared to today");
                        TimeSpan? diff = DateTime.Today - blob.Properties.LastModified;
                        // 30 days, you can change it to 90 days and etc.
                        if (diff?.Days > 30)
                        {
                            log.LogInformation("Delete: " + blob.Name);
                            await blob.DeleteAsync();
                        }
                    }
 
                    log.LogInformation($"Foreach completed at: {DateTime.Now}");
 
                    // Get the continuation token and loop until it is null.
                    continuationToken = resultSegment.ContinuationToken;
 
                } while (continuationToken != null);
            }
            catch (StorageException e)
            {
                log.LogInformation(e.Message);
            }
 
            log.LogInformation($"C# Timer trigger function completed at: {DateTime.Now}");
        }
    }
}