a nar@@sdZddlmZddlZeeZddlZddlm Z m Z m Z m Z m Z ddlZddlmZe rddlmZddlmZdd lmZd d lmZmZd d lmZd dlmZedZdZ ddZ!GdddZ"Gddde"e#Z$Gddde"e%Z&Gddde&Z'dS)a Provide special versions of list and dict, that can automatically notify about changes when used for property values. Mutations to these values are detected, and the properties owning the collection is notified of the changes. Consider the following model definition: .. code-block:: python class SomeModel(Model): options = List(String) If we have an instance of this model, ``m`` then we can set the entire value of the ``options`` property at once: .. code-block:: python m.options = ["foo", "bar"] When we do this in the context of a Bokeh server application that is being viewed in a browser, this change is automatically noticed, and the corresponding BokehJS property in the browser is synchronized, possibly causing some change in the visual state of the application in the browser. But it is also desirable that changes *inside* the ``options`` list also be detected. That is, the following kinds of operations should also be automatically synchronized between BokehJS and a Bokeh server: .. code-block:: python m.options.append("baz") m.options[2] = "quux" m.options.insert(0, "bar") The classes in this module provide this functionality. .. note:: These classes form part of the very low-level machinery that implements the Bokeh model and property system. It is unlikely that any of these classes or their methods will be applicable to any standard usage or to anyone who is not directly developing on Bokeh's own infrastructure. ) annotationsN) TYPE_CHECKINGAnyDictSetTuple)import_optional)Document)DocumentPatchedEvent)ColumnarDataSource)HasPropsSetter)Unknown)PropertyDescriptorZpandas) notify_ownerPropertyValueContainerPropertyValueListPropertyValueDictPropertyValueColumnDatacs fdd}djd|_|S)af A decorator for mutating methods of property container classes that notifies owners of the property container about mutating changes. Args: func (callable) : the container method to wrap in a notification Returns: wrapped method Examples: A ``__setitem__`` could be wrapped like this: .. code-block:: python # x[i] = y @notify_owner def __setitem__(self, i, y): return super().__setitem__(i, y) The returned wrapped method will have a docstring indicating what original method it is wrapping. cs,|}|g|Ri|}|||SN) _saved_copy_notify_owners)selfargskwargsoldresultfunc;lib/python3.9/site-packages/bokeh/core/property/wrappers.pywrappers znotify_owner..wrapperzContainer method ``z)`` instrumented to notify property owners)__name____doc__)r!r$r"r r#rps rcspeZdZUdZded<ddfdd Zdd dd d d Zdd dd d dZdddddddZddZ Z S)rab A base class for property container classes that support change notifications on mutating operations. This class maintains an internal list of property owners, and also provides a private mechanism for methods wrapped with :func:`~bokeh.core.property.wrappers.notify_owners` to update those owners when mutating changes occur. z-Set[Tuple[HasProps, PropertyDescriptor[Any]]]_ownersNonereturncst|_tj|i|dSr)setr'super__init__rrr __class__r"r#r-szPropertyValueContainer.__init__rzPropertyDescriptor[Any])owner descriptorr*cCs|j||fdSr)r'addrr1r2r"r"r#_register_ownersz&PropertyValueContainer._register_ownercCs|j||fdSr)r'discardr4r"r"r#_unregister_ownersz(PropertyValueContainer._unregister_ownerNrzDocumentPatchedEvent | None)rhintr*cCs$|jD]\}}|j|||dqdS)Nr8)r'_notify_mutated)rrr8r1r2r"r"r#rsz%PropertyValueContainer._notify_ownerscCs tddS)Nz2Subtypes must implement this to make a backup copy) RuntimeErrorrr"r"r#rsz"PropertyValueContainer._saved_copy)N) r% __module__ __qualname__r&__annotations__r-r5r7rr __classcell__r"r"r/r#rs  rcseZdZdZddfdd ZddZefdd Zefd d Zefd d Z efddZ efddZ efddZ efddZ edfdd ZefddZefddZefddZZS) ra A list property value container that supports change notifications on mutating operations. When a Bokeh model has a ``List`` property, the ``PropertyValueLists`` are transparently created to wrap those values. These ``PropertyValueList`` values are subject to normal property validation. If the property type ``foo = List(Str)`` then attempting to set ``x.foo[0] = 10`` will raise an error. Instances of ``PropertyValueList`` can be explicitly created by passing any object that the standard list initializer accepts, for example: .. code-block:: python >>> PropertyValueList([10, 20]) [10, 20] >>> PropertyValueList((10, 20)) [10, 20] The following mutating operations on lists automatically trigger notifications: .. code-block:: python del x[y] del x[i:j] x += y x *= y x[i] = y x[i:j] = y x.append x.extend x.insert x.pop x.remove x.reverse x.sort r(r)cstj|i|Srr,r-r.r/r"r#r-szPropertyValueList.__init__cCst|Sr)listr<r"r"r#rszPropertyValueList._saved_copycs t|Srr, __delitem__ryr/r"r#rDszPropertyValueList.__delitem__cs t|Sr)r,__iadd__rEr/r"r#rGszPropertyValueList.__iadd__cs t|Sr)r,__imul__rEr/r"r#rHszPropertyValueList.__imul__cst||Srr, __setitem__rirFr/r"r#rJszPropertyValueList.__setitem__cs t|Sr)r,appendrobjr/r"r#rMszPropertyValueList.appendcs t|Sr)r,extend)riterabler/r"r#rPszPropertyValueList.extendcst||Sr)r,insert)rindexrOr/r"r#rRszPropertyValueList.insertcs t|Srr,pop)rrSr/r"r#rVszPropertyValueList.popcs t|Sr)r,removerNr/r"r#rWszPropertyValueList.removecs tSr)r,reverser<r/r"r#rXszPropertyValueList.reversec stjfi|Sr)r,sort)rrr/r"r#rY szPropertyValueList.sort)rT)r%r=r>r&r-rrrDrGrHrJrMrPrRrVrWrXrYr@r"r"r/r#rs2)rcseZdZdZddfdd ZddZefdd Zefd d Zefd d Z efddZ efddZ efddZ efddZ ZS)ra1 A dict property value container that supports change notifications on mutating operations. When a Bokeh model has a ``List`` property, the ``PropertyValueLists`` are transparently created to wrap those values. These ``PropertyValueList`` values are subject to normal property validation. If the property type ``foo = Dict(Str, Str)`` then attempting to set ``x.foo['bar'] = 10`` will raise an error. Instances of ``PropertyValueDict`` can be eplicitly created by passing any object that the standard dict initializer accepts, for example: .. code-block:: python >>> PropertyValueDict(dict(a=10, b=20)) {'a': 10, 'b': 20} >>> PropertyValueDict(a=10, b=20) {'a': 10, 'b': 20} >>> PropertyValueDict([('a', 10), ['b', 20]]) {'a': 10, 'b': 20} The following mutating operations on dicts automatically trigger notifications: .. code-block:: python del x[y] x[i] = y x.clear x.pop x.popitem x.setdefault x.update r(r)cstj|i|SrrAr.r/r"r#r-4szPropertyValueDict.__init__cCst|Sr)dictr<r"r"r#r7szPropertyValueDict._saved_copycs t|SrrCrEr/r"r#rD;szPropertyValueDict.__delitem__cst||SrrIrKr/r"r#rJ@szPropertyValueDict.__setitem__cs tSr)r,clearr<r/r"r#r[DszPropertyValueDict.clearcs tj|SrrUrrr/r"r#rVHszPropertyValueDict.popcs tSr)r,popitemr<r/r"r#r]LszPropertyValueDict.popitemcs tj|Sr)r, setdefaultr\r/r"r#r^PszPropertyValueDict.setdefaultcstj|i|Sr)r,updater.r/r"r#r_TszPropertyValueDict.update)r%r=r>r&r-rrrDrJr[rVr]r^r_r@r"r"r/r#rs"%rc@sdeZdZdZddZddZifddZdd Zdd d d ddddddZdd d dddddZ d S)ra A property value container for ColumnData that supports change notifications on mutating operations. This property value container affords specialized code paths for updating the .data dictionary for ColumnDataSource. When possible, more efficient ColumnDataChangedEvent hints are generated to perform the updates: .. code-block:: python x[i] = y x.update cCs|||fgSr)r_rKr"r"r#rJjsz#PropertyValueColumnData.__setitem__cCs tt|Sr)rrZr<r"r"r#__copy__msz PropertyValueColumnData.__copy__cCsttt||Sr)rcopydeepcopyrZ)rZmemodictr"r"r# __deepcopy__psz$PropertyValueColumnData.__deepcopy__c Os|}tj|g|Ri|}ddlm}t|}t|dkrz|d}t|drh|t|O}n|dd|DO}|j D],\}} ||j |t |d} | j ||| d q|S) Nr)ColumnDataChangedEventrrkeyscSsh|] }|dqS)rr").0xr"r"r# z1PropertyValueColumnData.update..)colsr9) rrZr_document.eventsrdr+relenhasattrr'documentrBr:) rrrrrrdrjEr1r2r8r"r"r#r_ts    zPropertyValueColumnData.updateNr r zDict[str, Any]z int | Nonez Setter | Noner()docsourcenew_datarolloversetterr*c Cs|}|D]\}}t||tjs8t||tjrzt||||} |rjt| |krj| | d} t||| q||} | |||dur| d| =qddl m } |j || |||||ddS)a_ Internal implementation to handle special-casing stream events on ``ColumnDataSource`` columns. Normally any changes to the ``.data`` dict attribute on a ``ColumnDataSource`` triggers a notification, causing all of the data to be synchronized between server and clients. The ``.stream`` method on column data sources exists to provide a more efficient way to perform streaming (i.e. append-only) updates to a data source, without having to perform a full synchronization, which would needlessly re-send all the data. To accomplish this, this function bypasses the wrapped methods on ``PropertyValueDict`` and uses the unwrapped versions on the dict superclass directly. It then explicitly makes a notification, adding a special ``ColumnsStreamedEvent`` hint to the message containing only the small streamed data that BokehJS needs in order to efficiently synchronize. .. warning:: This function assumes the integrity of ``new_data`` has already been verified. Nr)ColumnsStreamedEventr9) ritems isinstancenpZndarrayrMrlrZrJrPrkrur) rrprqrrrsrtrkvdataLrur"r"r#_streams  zPropertyValueColumnData._stream)rprqrtr*c Cs|}|D]\}}|D]v\}} t|ttfr@| |||<q|||dt|ddj} tj| dd | |||dt|dd<qqddl m } |j || ||||ddS) a[ Internal implementation to handle special-casing patch events on ``ColumnDataSource`` columns. Normally any changes to the ``.data`` dict attribute on a ``ColumnDataSource`` triggers a notification, causing all of the data to be synchronized between server and clients. The ``.patch`` method on column data sources exists to provide a more efficient way to perform patching (i.e. random access) updates to a data source, without having to perform a full synchronization, which would needlessly re-send all the data. To accomplish this, this function bypasses the wrapped methods on ``PropertyValueDict`` and uses the unwrapped versions on the dict superclass directly. It then explicitly makes a notification, adding a special ``ColumnsPatchedEvent`` hint to the message containing only the small patched data that BokehJS needs in order to efficiently synchronize. .. warning:: This function assumes the integrity of ``patches`` has already been verified. rrNF)rar)ColumnsPatchedEventr9) rrvrwintslicetupleshaperxZarrayZreshaperkr~r) rrprqZpatchesrtrnameZpatchZindvaluerr~r"r"r#_patchs "4 zPropertyValueColumnData._patch)NN)N) r%r=r>r&rJr`rcr_r}rr"r"r"r#rXs 2r)(r&Z __future__rZloggingZ getLoggerr%logratypingrrrrrZnumpyrxZutil.dependenciesr rnr rkr Zmodels.sourcesr Z has_propsrrtypesrZ descriptorsrZpd__all__rrrBrrZrrr"r"r"r#s*2         !`J