{ 'SearchServiceName': 'your-azure-search-service-name', 'SearchServiceAdminApiKey': 'YourAdminApiKey', 'SearchIndexName': 'desired-index-name', 'KontentProjectID': 'kontent-project-id', 'KontentWebhookSecret': 'WebhookSecretValue'}

 using Microsoft.Azure.Search;using Microsoft.Azure.Search.Models;using System;using System.ComponentModel.DataAnnotations;namespace Kontent_Azure_Search_Demo.Models{ public class Article { [IsSearchable] [Analyzer(AnalyzerName.AsString.EnMicrosoft), IsRetrievable(false)] public string Body { get; set; } [Key] public string ID { get; set; } public DateTime? PostDate { get; set; } [IsSearchable] [Analyzer(AnalyzerName.AsString.EnMicrosoft)] public string Summary { get; set; } [IsSearchable] [Analyzer(AnalyzerName.AsString.EnMicrosoft)] public string Title { get; set; } public string UrlPattern { get; set; } }}

 using Kentico.Kontent.Delivery;using Kontent_Azure_Search_Demo.Models;using Microsoft.Extensions.Configuration;using System.Collections.Generic;using System.Linq;using System.Threading.Tasks;namespace Kontent_Azure_Search_Demo.Helpers{ public class KontentHelper { private readonly IDeliveryClient deliveryClient; public KontentHelper(IConfiguration configuration) { var projectId = configuration['KontentProjectID']; this.deliveryClient = DeliveryClientBuilder.WithProjectId(projectId).Build(); } public async Task GetArticleByUrlPattern(string urlPattern) { var parameters = new List { new EqualsFilter('system.type', 'article'), new EqualsFilter('elements.url_pattern', urlPattern), new LimitParameter(1) }; var response = await deliveryClient.GetItemsAsync(parameters); return response.Items.FirstOrDefault(); } public async Task> GetArticlesForSearch() { var parameters = new List { new EqualsFilter('system.type', 'article'), new OrderParameter('elements.post_date', SortOrder.Descending) }; var response = await deliveryClient.GetItemsAsync(parameters); return response.Items.Select(GetArticle); } public async Task> GetArticlesForSearch(IEnumerable ids) { var parameters = new List { new EqualsFilter('system.type', 'article'), new InFilter('system.id', string.Join(',',ids)), new LimitParameter(1) }; var response = await deliveryClient.GetItemsAsync(parameters); return response.Items.Select(GetArticle); } private Article GetArticle(ContentItem item) { if (item == null) { return new Article(); } return new Article { Body = item.GetString('body_copy'), ID = item.System.Id, PostDate = item.GetDateTime('post_date'), Summary = item.GetString('summary'), Title = item.GetString('title'), UrlPattern = item.GetString('url_pattern'), }; } }}

using Microsoft.Azure.Search;using Microsoft.Azure.Search.Models;using Microsoft.Extensions.Configuration;using System.Collections.Generic;using System.Linq;using Index = Microsoft.Azure.Search.Models.Index;namespace Kontent_Azure_Search_Demo.Helpers{ public class SearchHelper { private readonly string indexName; private readonly ISearchIndexClient searchIndexClient; private readonly SearchServiceClient searchServiceClient; public SearchHelper(IConfiguration configuration) { indexName = configuration['SearchIndexName']; searchServiceClient = CreateSearchServiceClient(configuration); searchIndexClient = searchServiceClient.Indexes.GetClient(indexName); } public void AddToIndex(IEnumerable documents) { var actions = documents.Select(a => IndexAction.Upload(a)); var batch = IndexBatch.New(actions); searchIndexClient.Documents.Index(batch); } public void CreateIndex() { var definition = new Index() { Name = indexName, Fields = FieldBuilder.BuildForType() }; searchServiceClient.Indexes.Create(definition); } public void DeleteIndexIfExists() { if (searchServiceClient.Indexes.Exists(indexName)) { searchServiceClient.Indexes.Delete(indexName); } } public IEnumerable QueryIndex(string searchText) { var parameters = new SearchParameters(); var results = searchIndexClient.Documents.Search(searchText, parameters); return results.Results.Select(r=>r.Document); } public void RemoveFromIndex(IEnumerable documents) { var actions = documents.Select(a => IndexAction.Delete(a)); var batch = IndexBatch.New(actions); searchIndexClient.Documents.Index(batch); } private SearchServiceClient CreateSearchServiceClient(IConfiguration configuration) { string searchServiceName = configuration['SearchServiceName']; string adminApiKey = configuration['SearchServiceAdminApiKey']; return new SearchServiceClient(searchServiceName, new SearchCredentials(adminApiKey)); } }}

using Kontent_Azure_Search_Demo.Helpers;using Kontent_Azure_Search_Demo.Models;using Microsoft.AspNetCore.Mvc;using Microsoft.Extensions.Configuration;using System.IO;using System.Linq;using System.Threading.Tasks;namespace Kontent_Azure_Search_Demo.Controllers{ public class SearchController : Controller { private readonly KontentHelper kontentHelper; private readonly SearchHelper searchHelper; public SearchController(IConfiguration configuration) { kontentHelper = new KontentHelper(configuration); searchHelper = new SearchHelper(configuration); } public IActionResult Create() { searchHelper.DeleteIndexIfExists(); searchHelper.CreateIndex
(); ViewData['Message'] = 'Index deleted/created.'; return View('Index'); } public IActionResult Index(string searchText) { if (string.IsNullOrWhiteSpace(searchText)) { return View(); } var results = searchHelper.QueryIndex
(searchText); return View(results); } public IActionResult Initialize() { var articles = kontentHelper.GetArticlesForSearch().Result; searchHelper.AddToIndex
(articles); ViewData['Message'] = 'Index initialized.'; return View('Index'); } }}

 @model IEnumerable
@{ ViewData['Title'] = 'Search Page';} 
 
Index actions
 Create index Initialize index 
 @ViewData['Message'] 
 
  Search 
 
@{ if (Model != null) { 
@Model.Count() Results
 foreach (var document in Model) { 
 
  @document.Title  
 
 @document.Summary 
 
 } }}

using Kontent_Azure_Search_Demo.Helpers;using Microsoft.AspNetCore.Mvc;using Microsoft.Extensions.Configuration;using System.Threading.Tasks;namespace Kontent_Azure_Search_Demo.Controllers{ public class ArticleController : Controller { private readonly KontentHelper kontentHelper; public ArticleController(IConfiguration configuration) { kontentHelper = new KontentHelper(configuration); } [Route('article/{urlPattern}')] public async Task Detail(string urlPattern) { var item = await kontentHelper.GetArticleByUrlPattern(urlPattern); return View(item); } }}

 @model Kentico.Kontent.Delivery.ContentItem@{ ViewData['Title'] = Model.GetString('title');}@if (Model.GetAssets('teaser_image').Count() > 0){ var image = Model.GetAssets('teaser_image').First(); }
@Model.GetString('title')
@Html.Raw(Model.GetString('body_copy'))

 ./ngrok http https://localhost:44345 -host-header='localhost:44345'

 using Newtonsoft.Json;using System;namespace Kontent_Azure_Search_Demo.KontentWebhookModels{ public class Data { [JsonProperty('items')] public Item[] Items { get; set; } [JsonProperty('taxonomies')] public Taxonomy[] Taxonomies { get; set; } } public class Item { [JsonProperty('codename')] public string Codename { get; set; } [JsonProperty('id')] public string Id { get; set; } [JsonProperty('language')] public string Language { get; set; } [JsonProperty('type')] public string Type { get; set; } } public class Message { [JsonProperty('api_name')] public string ApiName { get; set; } [JsonProperty('id')] public Guid Id { get; set; } [JsonProperty('operation')] public string Operation { get; set; } [JsonProperty('project_id')] public Guid ProjectId { get; set; } [JsonProperty('type')] public string Type { get; set; } } public class Taxonomy { [JsonProperty('codename')] public string Codename { get; set; } [JsonProperty('id')] public string Id { get; set; } } public class Webhook { [JsonProperty('data')] public Data Data { get; set; } [JsonProperty('message')] public Message Message { get; set; } }}

using Kontent_Azure_Search_Demo.KontentWebhookModels;using Microsoft.Extensions.Configuration;using Newtonsoft.Json;using System;using System.Collections.Generic;using System.Linq;using System.Security.Cryptography;using System.Text;namespace Kontent_Azure_Search_Demo.Helpers{ public class KontentWebhookHelper { private readonly string webhookSecret; public KontentWebhookHelper(IConfiguration configuration) { webhookSecret = configuration['KontentWebhookSecret']; } public ValidationResult ValidateAndProcessWebhook(string signature, string body) { var hash = GenerateHash(body, webhookSecret); if (signature != hash) { return new ValidationResult { IsValid = false, ErrorMessage = 'Invalid signature' }; } // Manually deserialize request body because we needed to use the raw value previously to validate the request var webhook = JsonConvert.DeserializeObject(body); var isContentItemVariantEvent = webhook.Message.Type == 'content_item_variant'; if (!isContentItemVariantEvent) { return new ValidationResult { IsValid = false, ErrorMessage = 'Not content item variant event' }; } var isPublishevent = webhook.Message.Operation == 'publish'; var isUnpublishEvent = webhook.Message.Operation == 'unpublish'; if (!isPublishevent && !isUnpublishEvent) { return new ValidationResult { IsValid = false, ErrorMessage = 'Not publish/unpublish event' }; } var articles = webhook.Data.Items.Where(i => i.Type == 'article' && i.Language == 'en-US'); if (articles.Count() == 0) { return new ValidationResult { IsValid = false, ErrorMessage = 'No 'en-US' articles effected by this event' }; } return new ValidationResult { IsValid = true, Articles = articles }; } private string GenerateHash(string message, string secret) { secret ??= ''; UTF8Encoding SafeUTF8 = new UTF8Encoding(encoderShouldEmitUTF8Identifier: false, throwOnInvalidBytes: true); byte[] keyBytes = SafeUTF8.GetBytes(secret); byte[] messageBytes = SafeUTF8.GetBytes(message); using HMACSHA256 hmacsha256 = new HMACSHA256(keyBytes); byte[] hashmessage = hmacsha256.ComputeHash(messageBytes); return Convert.ToBase64String(hashmessage); } } public class ValidationResult { public IEnumerable Articles { get; set; } public string ErrorMessage { get; set; } public bool IsValid { get; set; } public string Operation { get; set; } }}

namespace Kontent_Azure_Search_Demo.Controllers{ public class SearchController : Controller { // ...other private fields... private readonly SearchHelper searchHelper; public SearchController(IConfiguration configuration) { // ...other constructor code... kontentWebhookHelper = new KontentWebhookHelper(configuration); } // ...other controller actions... [HttpPost('webhook')] public async Task ProcessWebhook() { // Manually read request body so we can use it to validate the request. Body is gone if we use [FromBody] on a parameter. string bodyRaw; using (var reader = new StreamReader(Request.Body)) { bodyRaw = await reader.ReadToEndAsync(); } var processedWebhook = kontentWebhookHelper.ValidateAndProcessWebhook(Request.Headers['X-KC-Signature'], bodyRaw); if (!processedWebhook.IsValid) { return processedWebhook.ErrorMessage; } if (processedWebhook.Operation == 'publish') { var articlesToUpdate = kontentHelper.GetArticlesForSearch(processedWebhook.Articles.Select(a => a.Id)).Result; searchHelper.AddToIndex(articlesToUpdate); } if (processedWebhook.Operation == 'unpublish') { var articlesToRemove = processedWebhook.Articles.Select(a => new Article { ID = a.Id }); searchHelper.RemoveFromIndex(articlesToRemove); } return 'Updated index'; } }}