o e?Z@GdddeZAGdddeAZBGdddeAZCGdddZDdZEdZFd ZGd!ZHd"ZId#ZJd$ZKd%ZLeGeHeIeJeKfZMeGeeDjNfeHeeDjOfeIeeDjNfeJeeDjOfeFeeDjPfeKeeDjQfeLeeDjRfiZSeTeUeVeWee ffeXd&<Gd'd(d(e ZYGd)d*d*e ZZGd+d,d,eCZ[dS)-N)ABC)IncompleteReadError StreamReader TimeoutError) AwaitableCallableListOptionalProtocolUnion)MaintenanceNotificationNodeFailedOverNotificationNodeFailingOverNotificationNodeMigratedNotificationNodeMigratingNotificationNodeMovingNotificationOSSNodeMigratedNotificationOSSNodeMigratingNotification)safe_str )timeout)AskErrorAuthenticationError$AuthenticationWrongNumberOfArgsErrorBusyLoadingErrorClusterCrossSlotErrorClusterDownErrorConnectionErrorExecAbortErrorExternalAuthProviderErrorMasterDownError ModuleError MovedErrorNoPermissionError NoScriptErrorOutOfMemoryError ReadOnlyError ResponseError TryAgainError) EncodableT)Encoder)SERVER_CLOSED_CONNECTION_ERROR SocketBufferz:Error loading the extension. Please check the server logs.z5Error unloading module: no such module with that namez/Error unloading module: operation not possible.z[Error unloading module: the module exports one or more module-side data types, can't unload)zxAUTH called without any password configured for the default user. Are you sure your configuration is correct?z(Client sent AUTH, but no password is setzproblem with LDAP servicec@steZdZdedededeeeeee ee eie e e eeeeeeeeeeeeedZeddZdd Zd d Zd S) BaseParserzmax number of clients reachedzinvalid passwordz,wrong number of arguments for 'auth' commandz,wrong number of arguments for 'AUTH' command)ERROOM WRONGPASS EXECABORTLOADINGNOSCRIPTREADONLYNOAUTHNOPERMASKTRYAGAINMOVED CLUSTERDOWN CROSSSLOT MASTERDOWNcCs`|dd}||jvr,|t|dd}|j|}t|tr&||t}|||dSt|S)zParse an error response rr,N) status_code)splitEXCEPTION_CLASSESlen isinstancedictgetr))clsresponse error_codeexception_classrLR/root/parts/websockify/install/lib/python3.10/site-packages/redis/_parsers/base.py parse_errorms     zBaseParser.parse_errorcCtNNotImplementedErrorselfrLrLrM on_disconnectyzBaseParser.on_disconnectcCrOrPrQrT connectionrLrLrM on_connect|rVzBaseParser.on_connectN)__name__ __module__ __qualname__rrrMODULE_LOAD_ERRORr#MODULE_EXPORTS_DATA_TYPES_ERRORNO_SUCH_MODULE_ERROR MODULE_UNLOAD_NOT_POSSIBLE_ERRORNO_AUTH_SET_ERROREXTERNAL_AUTH_PROVIDER_ERRORr'r rr&r(r%rr*r$rrr"rC classmethodrNrUrYrLrLrLrMr0IsF#  r0c@s8eZdZdZddZddZddZdd Zd d Zd S) _RESPBasez&Base class for sync-based resp parsingcCs||_d|_d|_d|_dSrP)socket_read_sizeencoder_sock_bufferrTrerLrLrM__init__s z_RESPBase.__init__cCs$z|WdStyYdSwrP)rU ExceptionrSrLrLrM__del__s  z_RESPBase.__del__cCs(|j|_t|j|j|j|_|j|_dS)zCalled when the socket connectsN)rgr/resocket_timeoutrhrfrWrLrLrMrYs   z_RESPBase.on_connectcCs*d|_|jdur|jd|_d|_dS)z"Called when the socket disconnectsN)rgrhcloserfrSrLrLrMrUs    z_RESPBase.on_disconnectcCs|jo|j|SrP)rhcan_read)rTrrLrLrMrosz_RESPBase.can_readN) rZr[r\__doc__rjrlrYrUrorLrLrLrMrds rdc @sVeZdZdZdZdefddZdefddZ dd ede e e d e e ffd d Z d S)AsyncBaseParserz5Base parsing class for the python-backed async parser_stream _read_sizerecCsd|_||_dSrPrrrirLrLrMrjs zAsyncBaseParser.__init__returnctrPrQrSrLrLrMcan_read_destructivesz$AsyncBaseParser.can_read_destructiveFdisable_decodingNcrvrPrQ)rTrxrLrLrM read_responseszAsyncBaseParser.read_response)F)rZr[r\rp __slots__intrjboolrwr r+r)rryrLrLrLrMrqsrqc@sLeZdZdZeddZeddZeddZedd Zed d Z d S) MaintenanceNotificationsParserzEProtocol defining maintenance push notification parsing functionalitycCs|d}t|d}t||SNr,r)rr)rIidslotsrLrLrMparse_oss_maintenance_start_msgs  z>MaintenanceNotificationsParser.parse_oss_maintenance_start_msgc Csh|d}|d}i}|D]"\}}}t|}t|}t|} ||vr%g||<|||| iq t||Sr~)rappendr) rIrnodes_to_slots_mapping_datanodes_to_slots_mappingsrc_node dest_noder src_node_str dest_node_str slots_strrLrLrM#parse_oss_maintenance_completed_msgs  zBMaintenanceNotificationsParser.parse_oss_maintenance_completed_msgcCs|d}|d}|||Sr~rL)rInotification_typerttlrLrLrMparse_maintenance_start_msgs z:MaintenanceNotificationsParser.parse_maintenance_start_msgcCs|d}||S)Nr,rL)rIrrrLrLrMparse_maintenance_completed_msgsz>MaintenanceNotificationsParser.parse_maintenance_completed_msgcCsb|d}|d}|ddurd\}}nt|d}|d\}}|dur(t|nd}t||||S)Nr,rr)NN:)rrBr{r)rIrrhostportvaluerLrLrMparse_moving_msgs   z/MaintenanceNotificationsParser.parse_moving_msgN) rZr[r\rp staticmethodrrrrrrLrLrLrMr}s    r} invalidateMOVING MIGRATINGMIGRATED FAILING_OVER FAILED_OVER SMIGRATING SMIGRATED-MSG_TYPE_TO_MAINT_NOTIFICATION_PARSER_MAPPINGc@seZdZUdZeed<dZeeed<dZeeed<dZ eeed<dZ eeed<dd Z d d Z d d Z ddZddZddZddZdS)PushNotificationsParserz6Protocol defining RESP3-specific parsing functionalitypubsub_push_handler_funcNinvalidation_push_handler_funcnode_moving_push_handler_funcmaintenance_push_handler_func#oss_cluster_maint_push_handler_funccCrO)zHandle pubsub push responsesrQrTrIrLrLrMhandle_pubsub_push_response8sz3PushNotificationsParser.handle_pubsub_push_responsec Ks|d}t|tr |}|tgtttRvr||Sz|tkr,|jr,||WS|tkrC|j rCt |d}||}| |WS|tvrn|j rnt |d}|t krY||}n t |d}|||}|durn| |WS|tkr|j sx|j rt |d}||}|dur|j r| ||j r| |WdSWdSWdSWdSWdSty}ztd|||WYd}~dSd}~ww)Nrr,"Error handling {} message ({}): {}rEbytesdecode_INVALIDATION_MESSAGE_MAINTENANCE_MESSAGES_MOVING_MESSAGE_SMIGRATED_MESSAGErrrrr_SMIGRATING_MESSAGErrkloggererrorformatrTrIkwargsmsg_typeparser_function notificationrerLrLrMhandle_push_response<s           z,PushNotificationsParser.handle_push_responsecC ||_dSrPrrTrrLrLrMset_pubsub_push_handler{ z/PushNotificationsParser.set_pubsub_push_handlercCrrPrrTrrLrLrMset_invalidation_push_handler~rz5PushNotificationsParser.set_invalidation_push_handlercCrrPrrTrrLrLrMset_node_moving_push_handlerrz4PushNotificationsParser.set_node_moving_push_handlercCrrPrrTrrLrLrMset_maintenance_push_handlerrz4PushNotificationsParser.set_maintenance_push_handlercCrrPrrTrrLrLrM"set_oss_cluster_maint_push_handlerrz:PushNotificationsParser.set_oss_cluster_maint_push_handler)rZr[r\rpr__annotations__rr rrrrrrrrrrrLrLrLrMr/s ? rc@seZdZUdZeed<dZeeed<dZeede dfed<dZ eede dfed<dZ eede dfed<d d Z d d Z d dZddZddZddZddZdS)AsyncPushNotificationsParserzYdSw)NzBuffer is closed.TrF)rOSErrorrh async_timeoutrsat_eofrrSrLrLrMrws4 z#_AsyncRESPBase.can_read_destructivelengthc s|d}|j|}t|j|kr|j|j|d}n7|j|jd}z|j|t|IdH}WntyD}ztt|d}~ww||dd}|j ||j|7_|S)z Read `length` bytes of data. These are assumed to be followed by a ' ' terminator which is subsequently discarded. rN) rrDrhrs readexactlyrrr.rr)rTrwantendresulttaildatarrLrLrM_reads    z_AsyncRESPBase._readcs|jd|j}|dkr|j|j|}n'|j|jd}|jIdH}|ds/tt||dd}|j ||jt |d7_|S)zq read an unknown number of bytes up to the next ' ' line separator, which is discarded. s rNrr) rhfindrrsreadlineendswithrr.rrrD)rTfoundrrrrLrLrM _readline%s  z_AsyncRESPBase._readline)rZr[r\rprqrzr{rjrrYrUr|rwrrr __classcell__rLrLrrMrs   r)\loggingsysabcrasynciorrrtypingrrrr r r redis.maint_notificationsr r rrrrrr redis.utilsr version_infomajorminorrr exceptionsrrrrrrrr r!r"r#r$r%r&r'r(r)r*r+encodersr-socketr.r/r]r_r`r^rarb getLoggerrZrr0rdrqr}rr_MIGRATING_MESSAGE_MIGRATED_MESSAGE_FAILING_OVER_MESSAGE_FAILED_OVER_MESSAGErrrrrrrrrrFstrtupletyperrrrrLrLrLrMs   (  P     7#G "\^