mirror of
https://github.com/sourcegraph/sourcegraph.git
synced 2026-02-06 17:51:57 +00:00
6a88babae2
Fixes GRAPH-695 The syntactic code intel worker now actually performs indexing of repositories by piping the TAR archive stream from Gitserver straight into scip-syntax CLI, and then manually invoking the upload enqueuer. ## Test plan - New integration test verifying that indexing worker handles the records correctly and uploads valid indexes <!-- REQUIRED; info at https://docs-legacy.sourcegraph.com/dev/background-information/testing_principles --> ## Changelog <!-- OPTIONAL; info at https://www.notion.so/sourcegraph/Writing-a-changelog-entry-dd997f411d524caabf0d8d38a24a878c -->
41 lines
1.2 KiB
Go
41 lines
1.2 KiB
Go
package uploadhandler
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
"net/http"
|
|
"strconv"
|
|
|
|
sglog "github.com/sourcegraph/log"
|
|
"go.opentelemetry.io/otel/attribute"
|
|
|
|
"github.com/sourcegraph/sourcegraph/internal/observation"
|
|
)
|
|
|
|
// handleEnqueueSinglePayload handles a non-multipart upload. This creates an upload record
|
|
// with state 'queued', proxies the data to the bundle manager, and returns the generated ID.
|
|
func (h *UploadHandler[T]) handleEnqueueSinglePayload(ctx context.Context, uploadState uploadState[T], body io.Reader) (_ any, statusCode int, err error) {
|
|
ctx, _, endObservation := h.operations.handleEnqueueSinglePayload.With(ctx, &err, observation.Args{})
|
|
defer func() {
|
|
endObservation(1, observation.Args{Attrs: []attribute.KeyValue{
|
|
attribute.Int("statusCode", statusCode),
|
|
}})
|
|
}()
|
|
|
|
uploadResult, err := h.enqueuer.EnqueueSinglePayload(ctx, uploadState.metadata, uploadState.uncompressedSize, body)
|
|
|
|
if err != nil {
|
|
return nil, http.StatusInternalServerError, err
|
|
}
|
|
|
|
h.logger.Info(
|
|
"uploadhandler: enqueued upload",
|
|
sglog.Int("id", uploadResult.UploadID),
|
|
)
|
|
|
|
// older versions of src-cli expect a string
|
|
return struct {
|
|
ID string `json:"id"`
|
|
}{ID: strconv.Itoa(uploadResult.UploadID)}, 0, nil
|
|
}
|