Sun.Core.OpenSearch 1.0.0

Cách dùng OpenSearch trong Startup.cs hoặc nơi bạn cấu hình services: services.AddOpenSearch(Configuration);

cách dùng ở controller hoặc api

using Sun.Core.OpenSearch.Helpers; using Sun.Core.OpenSearch.Services; using Sun.Core.OpenSearch.Models;

public class YourController : ControllerBase { private readonly IOpenSearchService _openSearchService;

public YourController(IOpenSearchService openSearchService)
{
    _openSearchService = openSearchService;
}

[HttpGet("search")]
public async Task<IActionResult> Search(string query)
{
    var searchResponse = await _openSearchService.SearchAsync<YourDocumentType>(
        OpenSearchHelpers.BuildMatchQuery<YourDocumentType>("title", query),
        "your_index_name"
    );

    return Ok(searchResponse.Documents);
}

[HttpGet("advanced-search")]
public async Task<IActionResult> AdvancedSearch(string query, double? minPrice, double? maxPrice)
{
    var mustClauses = new List<Func<QueryContainerDescriptor<YourDocumentType>, QueryContainer>>
    {
        q => q.Match(m => m.Field(f => f.Title).Query(query))
    };

    if (minPrice.HasValue || maxPrice.HasValue)
    {
        mustClauses.Add(q => q.Range(r => r
            .Field(f => f.Price)
            .GreaterThanOrEquals(minPrice)
            .LessThanOrEquals(maxPrice)
        ));
    }

    var searchResponse = await _openSearchService.SearchAsync<YourDocumentType>(
        OpenSearchHelpers.BuildBoolQuery<YourDocumentType>(mustClauses, new List<Func<QueryContainerDescriptor<YourDocumentType>, QueryContainer>>(), new List<Func<QueryContainerDescriptor<YourDocumentType>, QueryContainer>>()),
        "your_index_name"
    );

    return Ok(searchResponse.Documents);
}

}