Method Delete

internal/storage/postgres/bundle_writer.go:74–98

(ctx context.Context, tenantID, name string)

}

func (b *BundleWriter) Delete(ctx context.Context, tenantID, name string) (err error) {
	ctx, span := internal.Tracer.Start(ctx, "bundle-writer.delete-bundle")
	defer span.End()

	slog.DebugContext(ctx, "deleting bundle", slog.Any("bundle", name))

	deleteBuilder := b.database.Builder.Delete(BundlesTable).Where(squirrel.Eq{"name": name, "tenant_id": tenantID})

	var query string
	var args []interface{}

	query, args, err = deleteBuilder.ToSql()
	if err != nil {
		return utils.HandleError(ctx, span, err, base.ErrorCode_ERROR_CODE_SQL_BUILDER)
	}

	_, err = b.database.WritePool.Exec(ctx, query, args...)
	if err != nil {
		return utils.HandleError(ctx, span, err, base.ErrorCode_ERROR_CODE_EXECUTION)
	}

	slog.DebugContext(ctx, "bundle successfully deleted")

	return nil
}