Method Write

internal/servers/bundle_server.go:35–73

Write handles the writing of bundles.

(ctx context.Context, request *v1.BundleWriteRequest)

// Write handles the writing of bundles.
func (r *BundleServer) Write(ctx context.Context, request *v1.BundleWriteRequest) (*v1.BundleWriteResponse, error) {
	ctx, span := internal.Tracer.Start(ctx, "bundle.write")
	defer span.End()

	v := request.Validate()
	if v != nil {
		return nil, status.Error(GetStatus(v), v.Error()) // Return validation error
	}

	for _, bundle := range request.GetBundles() {
		for _, operation := range bundle.GetOperations() {
			err := validation.ValidateBundleOperation(operation)
			if err != nil {
				return nil, status.Error(GetStatus(err), err.Error()) // Return operation validation error
			}
		}
	}

	var bundles []storage.Bundle
	for _, b := range request.GetBundles() {
		bundles = append(bundles, storage.Bundle{
			Name:       b.GetName(),
			DataBundle: b,
			TenantID:   request.GetTenantId(),
		})
	}

	names, err := r.bw.Write(ctx, bundles)
	if err != nil {
		span.RecordError(err)
		span.SetStatus(otelCodes.Error, err.Error())
		slog.ErrorContext(ctx, err.Error())
		return nil, status.Error(GetStatus(err), err.Error())
	}

	return &v1.BundleWriteResponse{
		Names: names,
	}, nil
}

// Read handles the reading of bundles.
func (r *BundleServer) Read(ctx context.Context, request *v1.BundleReadRequest) (*v1.BundleReadResponse, error) {