Skip to content

Commit

Permalink
chore: core release v0.73.12
Browse files Browse the repository at this point in the history
  • Loading branch information
TomMcL committed Jan 10, 2024
1 parent 720d9d8 commit 2d21229
Show file tree
Hide file tree
Showing 33 changed files with 1,348 additions and 1,620 deletions.
2 changes: 1 addition & 1 deletion .env
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
VEGA_SIM_VEGA_TAG=1debd1d75d26aba9699890cecb09feca5258b3c8
VEGA_SIM_VEGA_TAG=release/v0.73.12
VEGA_SIM_CONSOLE_TAG=develop
VEGA_DEFAULT_KEY_NAME='Key 1'
VEGA_SIM_NETWORKS_INTERNAL_TAG=main
Expand Down
6 changes: 3 additions & 3 deletions vega_sim/proto/blockexplorer/api/v1/blockexplorer_pb2.py

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

1,342 changes: 666 additions & 676 deletions vega_sim/proto/data_node/api/v2/trading_data_pb2.py

Large diffs are not rendered by default.

32 changes: 0 additions & 32 deletions vega_sim/proto/data_node/api/v2/trading_data_pb2.pyi
Original file line number Diff line number Diff line change
Expand Up @@ -696,25 +696,21 @@ class LedgerEntryFilter(_message.Message):
"from_account_filter",
"to_account_filter",
"transfer_types",
"transfer_id",
)
CLOSE_ON_ACCOUNT_FILTERS_FIELD_NUMBER: _ClassVar[int]
FROM_ACCOUNT_FILTER_FIELD_NUMBER: _ClassVar[int]
TO_ACCOUNT_FILTER_FIELD_NUMBER: _ClassVar[int]
TRANSFER_TYPES_FIELD_NUMBER: _ClassVar[int]
TRANSFER_ID_FIELD_NUMBER: _ClassVar[int]
close_on_account_filters: bool
from_account_filter: AccountFilter
to_account_filter: AccountFilter
transfer_types: _containers.RepeatedScalarFieldContainer[_vega_pb2.TransferType]
transfer_id: str
def __init__(
self,
close_on_account_filters: bool = ...,
from_account_filter: _Optional[_Union[AccountFilter, _Mapping]] = ...,
to_account_filter: _Optional[_Union[AccountFilter, _Mapping]] = ...,
transfer_types: _Optional[_Iterable[_Union[_vega_pb2.TransferType, str]]] = ...,
transfer_id: _Optional[str] = ...,
) -> None: ...

class AggregatedLedgerEntry(_message.Message):
Expand Down Expand Up @@ -4919,31 +4915,3 @@ class FeesStatsForParty(_message.Message):
volume_discount_applied: _Optional[str] = ...,
total_maker_fees_received: _Optional[str] = ...,
) -> None: ...

class ObserveTransactionResultsRequest(_message.Message):
__slots__ = ("party_ids", "hashes", "status")
PARTY_IDS_FIELD_NUMBER: _ClassVar[int]
HASHES_FIELD_NUMBER: _ClassVar[int]
STATUS_FIELD_NUMBER: _ClassVar[int]
party_ids: _containers.RepeatedScalarFieldContainer[str]
hashes: _containers.RepeatedScalarFieldContainer[str]
status: bool
def __init__(
self,
party_ids: _Optional[_Iterable[str]] = ...,
hashes: _Optional[_Iterable[str]] = ...,
status: bool = ...,
) -> None: ...

class ObserveTransactionResultsResponse(_message.Message):
__slots__ = ("transaction_results",)
TRANSACTION_RESULTS_FIELD_NUMBER: _ClassVar[int]
transaction_results: _containers.RepeatedCompositeFieldContainer[
_events_pb2.TransactionResult
]
def __init__(
self,
transaction_results: _Optional[
_Iterable[_Union[_events_pb2.TransactionResult, _Mapping]]
] = ...,
) -> None: ...
53 changes: 5 additions & 48 deletions vega_sim/proto/data_node/api/v2/trading_data_pb2_grpc.py
Original file line number Diff line number Diff line change
Expand Up @@ -567,11 +567,6 @@ def __init__(self, channel):
request_serializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.GetPartyVestingStatsRequest.SerializeToString,
response_deserializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.GetPartyVestingStatsResponse.FromString,
)
self.ObserveTransactionResults = channel.unary_stream(
"/datanode.api.v2.TradingDataService/ObserveTransactionResults",
request_serializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.ObserveTransactionResultsRequest.SerializeToString,
response_deserializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.ObserveTransactionResultsResponse.FromString,
)
self.ExportNetworkHistory = channel.unary_stream(
"/datanode.api.v2.TradingDataService/ExportNetworkHistory",
request_serializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.ExportNetworkHistoryRequest.SerializeToString,
Expand Down Expand Up @@ -715,6 +710,11 @@ def ListLedgerEntries(self, request, context):
- receiving account (market ID, asset ID, account type)
- sending AND receiving account
- transfer type either in addition to the above filters or as a standalone option
Note: The date range is restricted to any 5 days.
If no start or end date is provided, only ledger entries from the last 5 days will be returned.
If a start and end date are provided, but the end date is more than 5 days after the start date, only data up to 5 days after the start date will be returned.
If a start date is provided but no end date, the end date will be set to 5 days after the start date.
If no start date is provided, but the end date is, the start date will be set to 5 days before the end date.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
Expand Down Expand Up @@ -1631,15 +1631,6 @@ def GetPartyVestingStats(self, request, context):
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def ObserveTransactionResults(self, request, context):
"""Observe transaction results
Subscribe to a stream of transaction results, optionally filtered by party/hash/status
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def ExportNetworkHistory(self, request, context):
"""Export network history as CSV
Expand Down Expand Up @@ -2269,11 +2260,6 @@ def add_TradingDataServiceServicer_to_server(servicer, server):
request_deserializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.GetPartyVestingStatsRequest.FromString,
response_serializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.GetPartyVestingStatsResponse.SerializeToString,
),
"ObserveTransactionResults": grpc.unary_stream_rpc_method_handler(
servicer.ObserveTransactionResults,
request_deserializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.ObserveTransactionResultsRequest.FromString,
response_serializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.ObserveTransactionResultsResponse.SerializeToString,
),
"ExportNetworkHistory": grpc.unary_stream_rpc_method_handler(
servicer.ExportNetworkHistory,
request_deserializer=data__node_dot_api_dot_v2_dot_trading__data__pb2.ExportNetworkHistoryRequest.FromString,
Expand Down Expand Up @@ -5485,35 +5471,6 @@ def GetPartyVestingStats(
metadata,
)

@staticmethod
def ObserveTransactionResults(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_stream(
request,
target,
"/datanode.api.v2.TradingDataService/ObserveTransactionResults",
data__node_dot_api_dot_v2_dot_trading__data__pb2.ObserveTransactionResultsRequest.SerializeToString,
data__node_dot_api_dot_v2_dot_trading__data__pb2.ObserveTransactionResultsResponse.FromString,
options,
channel_credentials,
insecure,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

@staticmethod
def ExportNetworkHistory(
request,
Expand Down
Loading

0 comments on commit 2d21229

Please sign in to comment.