···
"github.com/blevesearch/bleve/v2"
"github.com/blevesearch/bleve/v2/index/upsidedown"
+
"github.com/blevesearch/bleve/v2/mapping"
"github.com/blevesearch/bleve/v2/search/query"
"tangled.sh/tangled.sh/core/appview/db"
"tangled.sh/tangled.sh/core/appview/indexer/base36"
···
"tangled.sh/tangled.sh/core/appview/pagination"
+
issueIndexerDocType = "issueIndexerDocType"
···
log.Println("Initialized the issue indexer")
+
func generateIssueIndexMapping() (mapping.IndexMapping, error) {
+
mapping := bleve.NewIndexMapping()
+
docMapping := bleve.NewDocumentMapping()
+
textFieldMapping := bleve.NewTextFieldMapping()
+
textFieldMapping.Store = false
+
textFieldMapping.IncludeInAll = false
+
boolFieldMapping := bleve.NewBooleanFieldMapping()
+
boolFieldMapping.Store = false
+
boolFieldMapping.IncludeInAll = false
+
keywordFieldMapping := bleve.NewKeywordFieldMapping()
+
keywordFieldMapping.Store = false
+
keywordFieldMapping.IncludeInAll = false
+
// numericFieldMapping := bleve.NewNumericFieldMapping()
+
docMapping.AddFieldMappingsAt("title", textFieldMapping)
+
docMapping.AddFieldMappingsAt("body", textFieldMapping)
+
docMapping.AddFieldMappingsAt("repo_at", keywordFieldMapping)
+
docMapping.AddFieldMappingsAt("is_open", boolFieldMapping)
+
mapping.AddDocumentMapping(issueIndexerDocType, docMapping)
+
mapping.AddDocumentMapping("_all", bleve.NewDocumentDisabledMapping())
+
mapping.DefaultMapping = bleve.NewDocumentDisabledMapping()
func (ix *Indexer) intialize(_ context.Context) (bool, error) {
return false, errors.New("indexer is already initialized")
···
+
mapping, err := generateIssueIndexMapping()
indexer, err = bleve.New(ix.path, mapping)
···
dataList = append(dataList, &IssueData{
+
RepoAt: issue.RepoAt.String(),
+
log.Println(dataList[len(dataList)-1])
err = ix.Index(ctx, dataList...)
···
// IssueData data stored and will be indexed
+
RepoAt string `json:"repo_at"`
IssueID int `json:"issue_id"`
Title string `json:"title"`
Body string `json:"body"`
···
Comments []IssueCommentData `json:"comments"`
+
// Type returns the document type, for bleve's mapping.Classifier interface.
+
func (i *IssueData) Type() string {
+
return issueIndexerDocType
type IssueCommentData struct {
Body string `json:"body"`
···
matchAndQuery(opts.Keyword, "body"),
+
queries = append(queries, keywordFieldQuery(opts.RepoAt, "repo_at"))
queries = append(queries, boolFieldQuery(opts.IsOpen, "is_open"))
// TODO: append more queries
···
+
func keywordFieldQuery(keyword, field string) query.Query {
+
q := bleve.NewTermQuery(keyword)
boltless.me