Using Azure Video Analyser for Media in Azure Functions

[FunctionName("ScheduledXml")]
public async  Task  ScheduledXml([TimerTrigger("0 40 13 * * THU")]TimerInfo myTimer, [Queue("podcastlinks")] ICollector<string> queueItems, ILogger log)
{
    //Fetch an Xml from an external web resource
    HttpClient client = new HttpClient();
    var result = await client.GetAsync("https://feeds.megaphone.fm/lewlater"); // choose your podcast RSS feed here :D

    var podcastXml = await result.Content.ReadAsStringAsync();

    //the xml structure manipulation needed will depend on the source,
    //but most RSS XML's from Megaphone will have an 'enclosure' tag containing the audio location
    XmlDocument xmlDoc = new XmlDocument();
    xmlDoc.LoadXml(podcastXml);
    var lastNode = xmlDoc.GetElementsByTagName("item")[0].ChildNodes.Count - 1;
    var tagData = xmlDoc.GetElementsByTagName("item")[0].ChildNodes[lastNode].OuterXml;

    xmlDoc.LoadXml(tagData);
    var audioFileLocation = xmlDoc.GetElementsByTagName("enclosure")[0].Attributes[0].Value;
    log.LogInformation($"found audio at {audioFileLocation}");
    
    //add the audio file location Url to the Queue
    queueItems.Add(audioFileLocation);
}

[FunctionName("StartIndex")]
public async Task StartIndex([QueueTrigger("podcastlinks")] string podcastlink, string DequeueCount, [DurableClient] IDurableOrchestrationClient durableclient, ILogger log)
{
    if (DequeueCount == "1")
    {
    	log.LogInformation($"Got the link: {podcastlink}");
        IndexerAccessDetail accessDetail = new IndexerAccessDetail() {
          BaseUrl = "https://api.videoindexer.ai",
          ApiKey = "[YOUR_API_KEY]",
          Location = "[YOUR_RESOURCE_LOCATION]", // if using trial account use 'trial'
          AccountId = "[YOUR_VIDEO_INDEXER_ACCOUNTID]"
        };

        HttpClient client = new HttpClient();
        client.DefaultRequestHeaders.Add("Ocp-Apim-Subscription-Key", accessDetail.apiKey);

        // account accessToken to use in the Upload api
        var accountAccessTokenRequest = await client.GetAsync($"{accessDetail.BaseUrl}/auth/{accessDetail.Location}/Accounts/{accessDetail.AccountId}/AccessToken?allowEdit=true");
        var accountAccessToken = (await accountAccessTokenRequest.Content.ReadAsStringAsync()).Replace("\"", "");

        // upload audio from the podcast link to video indexer
        var content = new MultipartFormDataContent();
        var uploadRequest = await client.PostAsync($"{accessDetail.BaseUrl}/{accessDetail.Location}/Accounts/{accessDetail.AccountId}/Videos?accessToken={accountAccessToken}&name=newaudio{Guid.NewGuid()}e&description=some_description&privacy=private&partition=newpt{Guid.NewGuid()}&videoUrl={podcastlink}", content);
        var uploadResult = await uploadRequest.Content.ReadAsStringAsync();
        accessDetail.UploadResult = uploadResult;

        // get the item id of the uploaded artefact from the upload result
        var podcastIndexerId = JsonConvert.DeserializeObject<dynamic>(uploadResult)["id"];
        accessDetail.PodcastIndexerId = podcastIndexerId;

        string instanceId = "InstanceId1"; //VERY IMPORTANT, keep the same instanceId in the following Orchestration Function, so that function can be re-called multiple times 

        //start durable Function orchestration and pass in collected details
        //that enable access to the uploaded artefact
        await durableclient.StartNewAsync("Orchestration", instanceId, accessDetail);

    }

}

[FunctionName("Orchestration")]
public static async Task Orchestration(
[OrchestrationTrigger] IDurableOrchestrationContext context, ILogger log)
{
    //useful to double check instanceId
    log.LogInformation($"running as instance: {context.InstanceId}");
    
    //get indexer access properties from input data
    IndexerAccessDetail accessDetail = context.GetInput<IndexerAccessDetail>();

    var stateResult = await context.CallActivityAsync<string>("CheckState", accessDetail);
    
    //'Sleep' for 5mins then call the orchestration again if not finished
    DateTime refreshTime = context.CurrentUtcDateTime.AddMinutes(5);
    await context.CreateTimer(refreshTime, CancellationToken.None);
    if (stateResult == "Not Finished")
    {
    	context.ContinueAsNew(accessDetail);
    }
    else
    {
    	log.LogInformation($"Completed with:{stateResult}");
    }

}

[FunctionName("CheckState")]
public async Task<string> CheckState([ActivityTrigger] IndexerAccessDetail accessDetail, ILogger log)
{
    if (accessDetail != null && accessDetail?.PodcastIndexerId!=null && accessDetail?.UploadResult != null)
    {
        HttpClient client = new HttpClient();
        client.DefaultRequestHeaders.Add("Ocp-Apim-Subscription-Key", accessDetail.ApiKey);

        //use a new accessToken in each check and avoid re-using the same accessToken
        var itemAccessTokenRequest = await client.GetAsync($"{accessDetail.BaseUrl}/auth/{accessDetail.Location}/Accounts/{accessDetail.AccountId}/Videos/{accessDetail.PodcastIndexerId}/AccessToken?allowEdit=true");
        var itemAccessToken = (await itemAccessTokenRequest.Content.ReadAsStringAsync()).Replace("\"", "");

        //attempt to fetch the index result and check the current state
        var fetchIndex = await client.GetAsync($"{accessDetail.BaseUrl}/{accessDetail.Location}/Accounts/{accessDetail.AccountId}/Videos/{accessDetail.PodcastIndexerId}/Index?accessToken={itemAccessToken}&language=English");
        var indexResult = await fetchIndex.Content.ReadAsStringAsync();

        var processingState = JsonConvert.DeserializeObject<dynamic>(indexResult)["state"];

        if (processingState != "Uploaded" && processingState != "Processing" && processingState != null)
        {
        	log.LogInformation(indexResult); //json index result
        	return processingState;
        }
        log.LogInformation($"Current State is: {processingState}");

        return "Not Finished";
    }
return "Not Finished";
}

<Project Sdk="Microsoft.NET.Sdk">
  <PropertyGroup>
    <TargetFramework>net6.0</TargetFramework>
    <AzureFunctionsVersion>v4</AzureFunctionsVersion>
  </PropertyGroup>
  <ItemGroup>
	  <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.DurableTask" Version="2.6.1" />
	  <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.Storage" Version="5.0.0" />
	  <PackageReference Include="Microsoft.NET.Sdk.Functions" Version="4.0.1" />
  </ItemGroup>
  <ItemGroup>
    <None Update="host.json">
      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
    </None>
    <None Update="local.settings.json">
      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
      <CopyToPublishDirectory>Never</CopyToPublishDirectory>
    </None>
  </ItemGroup>
</Project>