1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
# coding=utf-8
# --------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for license information.
# --------------------------------------------------------------------------
from typing import Optional, Any
from azure.core.pipeline.policies import UserAgentPolicy
from .models._models import SendMessageError, AckMessageError
from ._version import VERSION
NO_ACK_MESSAGE_ERROR = "NoAckMessageReceivedFromServer"
def format_user_agent(user_agent: Optional[str] = None) -> str:
"""Format user agent string.
:param user_agent: User agent string.
:type user_agent: str
:return: The formatted user agent.
:rtype: str
"""
return UserAgentPolicy(user_agent=user_agent, sdk_moniker=f"webpubsub-client/{VERSION}").user_agent
def raise_for_empty_message_ack(message_ack: Optional[Any], ack_id: Optional[int] = None):
if message_ack is None:
raise SendMessageError(
message="Failed to send message.",
ack_id=ack_id,
error_detail=AckMessageError(
name=NO_ACK_MESSAGE_ERROR,
message="The connection may have been lost during message sending, or the service didn't send ack message.", # pylint: disable=line-too-long
),
)
|
