mirror of
https://github.com/PeernetOfficial/core.git
synced 2026-07-17 02:47:51 +01:00
66 lines
1.5 KiB
Go
66 lines
1.5 KiB
Go
/*
|
|
File Name: Search Dispatch.go
|
|
Copyright: 2021 Peernet Foundation s.r.o.
|
|
Author: Peter Kleissner
|
|
*/
|
|
package webapi
|
|
|
|
import (
|
|
"bytes"
|
|
"time"
|
|
|
|
"github.com/PeernetOfficial/core"
|
|
)
|
|
|
|
func (api *WebapiInstance) dispatchSearch(input SearchRequest) (job *SearchJob) {
|
|
Timeout := input.Parse()
|
|
Filter := input.ToSearchFilter()
|
|
|
|
// create the search job
|
|
job = CreateSearchJob(Timeout, input.MaxResults, Filter)
|
|
|
|
// todo: create actual search clients!
|
|
|
|
go job.localSearch(api.backend, input.Term)
|
|
|
|
job.RemoveDefer(job.timeout + time.Minute*10)
|
|
|
|
return job
|
|
}
|
|
|
|
func (job *SearchJob) localSearch(backend *core.Backend, term string) {
|
|
if backend.SearchIndex == nil || backend.GlobalBlockchainCache == nil {
|
|
return
|
|
}
|
|
|
|
results := backend.SearchIndex.Search(term)
|
|
|
|
job.ResultSync.Lock()
|
|
|
|
resultLoop:
|
|
for _, result := range results {
|
|
file, _, found, err := backend.GlobalBlockchainCache.ReadFile(result.PublicKey, result.BlockchainVersion, result.BlockNumber, result.FileID)
|
|
if err != nil || !found {
|
|
continue
|
|
}
|
|
|
|
// new result
|
|
newFile := blockRecordFileToAPI(file)
|
|
|
|
// Deduplicate based on file hash from the same peer.
|
|
for n := range job.AllFiles {
|
|
if bytes.Equal(job.AllFiles[n].Hash, newFile.Hash) && bytes.Equal(job.AllFiles[n].NodeID, newFile.NodeID) {
|
|
continue resultLoop
|
|
}
|
|
}
|
|
|
|
job.Files = append(job.Files, &newFile)
|
|
job.AllFiles = append(job.AllFiles, &newFile)
|
|
job.requireSort = true
|
|
job.statsAdd(&newFile)
|
|
}
|
|
|
|
job.ResultSync.Unlock()
|
|
job.Terminate()
|
|
}
|