Method handleSessionRequest

internal/server/grpc_session.go:167–214

(ctx context.Context, dw repo.DirectRepositoryWriter, authz auth.AuthorizationInfo, usernameAtHostname string, req *grpcapi.SessionRequest, respond func(*grpcapi.SessionResponse))

var tracer = otel.Tracer("kopia/grpc")

func (s *Server) handleSessionRequest(ctx context.Context, dw repo.DirectRepositoryWriter, authz auth.AuthorizationInfo, usernameAtHostname string, req *grpcapi.SessionRequest, respond func(*grpcapi.SessionResponse)) {
	if req.GetTraceContext() != nil {
		var tc propagation.TraceContext

		ctx = tc.Extract(ctx, propagation.MapCarrier(req.GetTraceContext()))
	}

	switch inner := req.GetRequest().(type) {
	case *grpcapi.SessionRequest_GetContentInfo:
		respond(handleGetContentInfoRequest(ctx, dw, authz, inner.GetContentInfo))

	case *grpcapi.SessionRequest_GetContent:
		respond(handleGetContentRequest(ctx, dw, authz, inner.GetContent))

	case *grpcapi.SessionRequest_WriteContent:
		respond(handleWriteContentRequest(ctx, dw, authz, inner.WriteContent))

	case *grpcapi.SessionRequest_Flush:
		respond(handleFlushRequest(ctx, dw, authz, inner.Flush))

	case *grpcapi.SessionRequest_GetManifest:
		respond(handleGetManifestRequest(ctx, dw, authz, inner.GetManifest))

	case *grpcapi.SessionRequest_PutManifest:
		respond(handlePutManifestRequest(ctx, dw, authz, inner.PutManifest))

	case *grpcapi.SessionRequest_FindManifests:
		handleFindManifestsRequest(ctx, dw, authz, inner.FindManifests, respond)

	case *grpcapi.SessionRequest_DeleteManifest:
		respond(handleDeleteManifestRequest(ctx, dw, authz, inner.DeleteManifest))

	case *grpcapi.SessionRequest_PrefetchContents:
		respond(handlePrefetchContentsRequest(ctx, dw, authz, inner.PrefetchContents))

	case *grpcapi.SessionRequest_ApplyRetentionPolicy:
		respond(handleApplyRetentionPolicyRequest(ctx, dw, authz, usernameAtHostname, inner.ApplyRetentionPolicy))

	case *grpcapi.SessionRequest_SendNotification:
		respond(s.handleSendNotificationRequest(ctx, dw, authz, inner.SendNotification))

	case *grpcapi.SessionRequest_InitializeSession:
		respond(errorResponse(errors.New("InitializeSession must be the first request in a session")))

	default:
		respond(errorResponse(errors.New("unhandled session request")))
	}
}

func handleGetContentInfoRequest(ctx context.Context, dw repo.DirectRepositoryWriter, authz auth.AuthorizationInfo, req *grpcapi.GetContentInfoRequest) *grpcapi.SessionResponse {
	ctx, span := tracer.Start(ctx, "GRPCSession.GetContentInfo")