Skip to content
Snippets Groups Projects

Full MVC of gitlab-zoekt-indexer

Merged Dylan Griffith requested to merge add-new-api-paths into main
All threads resolved!
Compare and Show latest version
2 files
+ 5
5
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -49,7 +49,7 @@ type indexRequest struct {
@@ -49,7 +49,7 @@ type indexRequest struct {
type indexBuilder interface {
type indexBuilder interface {
getIndexDir() string
getIndexDir() string
indexRepository(ctx context.Context, req indexRequest, indexDir string) error
indexRepository(ctx context.Context, req indexRequest) error
}
}
type defaultIndexBuilder struct {
type defaultIndexBuilder struct {
@@ -60,7 +60,7 @@ func (b defaultIndexBuilder) getIndexDir() string {
@@ -60,7 +60,7 @@ func (b defaultIndexBuilder) getIndexDir() string {
return b.indexDir
return b.indexDir
}
}
func (b defaultIndexBuilder) indexRepository(ctx context.Context, req indexRequest, indexDir string) error {
func (b defaultIndexBuilder) indexRepository(ctx context.Context, req indexRequest) error {
if req.GitalyConnectionInfo == nil {
if req.GitalyConnectionInfo == nil {
return errors.New("gitalyConnectionInfo is not set")
return errors.New("gitalyConnectionInfo is not set")
}
}
@@ -78,7 +78,7 @@ func (b defaultIndexBuilder) indexRepository(ctx context.Context, req indexReque
@@ -78,7 +78,7 @@ func (b defaultIndexBuilder) indexRepository(ctx context.Context, req indexReque
defer cancel()
defer cancel()
idx := &indexer.Indexer{
idx := &indexer.Indexer{
IndexDir: indexDir,
IndexDir: b.indexDir,
ProjectID: req.RepoID,
ProjectID: req.RepoID,
CorrelationID: correlation.GetCorrelationID(ctx),
CorrelationID: correlation.GetCorrelationID(ctx),
GitalyAddress: req.GitalyConnectionInfo.Address,
GitalyAddress: req.GitalyConnectionInfo.Address,
@@ -180,7 +180,7 @@ func (s *indexServer) handleIndex() http.HandlerFunc {
@@ -180,7 +180,7 @@ func (s *indexServer) handleIndex() http.HandlerFunc {
return
return
}
}
err = s.indexBuilder.indexRepository(r.Context(), req, s.indexBuilder.getIndexDir())
err = s.indexBuilder.indexRepository(r.Context(), req)
if err != nil {
if err != nil {
s.respondWithError(w, r, route, err)
s.respondWithError(w, r, route, err)
return
return
Loading