From 5136e17615a11ff737ca26a1ad5527c7493d75fc Mon Sep 17 00:00:00 2001 From: Andreas Rath Date: Tue, 19 Nov 2024 08:37:47 +0100 Subject: [PATCH] PREPARING FOR RELEASE 5.0.0 --- Makefile | 4 +- RELEASE.md | 7 ++ ondewo-csi-api | 2 +- ondewo/csi/conversation_pb2.py | 35 ++++-- ondewo/csi/conversation_pb2.pyi | 118 +++++++++++------- ondewo/csi/conversation_pb2_grpc.py | 183 ++++++++++++++++++++++------ setup.py | 2 +- 7 files changed, 256 insertions(+), 95 deletions(-) diff --git a/Makefile b/Makefile index a515177..e010730 100644 --- a/Makefile +++ b/Makefile @@ -16,7 +16,7 @@ export # MUST BE THE SAME AS API in Mayor and Minor Version Number # example: API 2.9.0 --> Client 2.9.X -ONDEWO_CSI_VERSION = 4.0.1 +ONDEWO_CSI_VERSION = 5.0.0 PYPI_USERNAME?=ENTER_HERE_YOUR_PYPI_USERNAME PYPI_PASSWORD?=ENTER_HERE_YOUR_PYPI_PASSWORD @@ -27,7 +27,7 @@ CURRENT_RELEASE_NOTES=`cat RELEASE.md \ | sed -n '/Release ONDEWO CSI Python Client ${ONDEWO_CSI_VERSION}/,/\*\*/p'` GH_REPO="https://github.com/ondewo/ondewo-csi-client-python" -ONDEWO_CSI_API_GIT_BRANCH=master +ONDEWO_CSI_API_GIT_BRANCH=tags/5.0.0 ONDEWO_PROTO_COMPILER_GIT_BRANCH=tags/5.2.0 ONDEWO_CSI_API_DIR=ondewo-csi-api ONDEWO_PROTO_COMPILER_DIR=ondewo-proto-compiler diff --git a/RELEASE.md b/RELEASE.md index 1b0479c..2acaf55 100644 --- a/RELEASE.md +++ b/RELEASE.md @@ -1,4 +1,11 @@ # Release History + +***************** +## Release ONDEWO CSI Python Client 5.0.0 + +### Improvements + * Tracking API Version [5.0.0](https://github.com/ondewo/ondewo-csi-api/releases/tag/5.0.0) ( [Documentation](https://ondewo.github.io/ondewo-csi-api/) ) + ***************** ## Release ONDEWO CSI Python Client 4.0.1 diff --git a/ondewo-csi-api b/ondewo-csi-api index a92272a..429070f 160000 --- a/ondewo-csi-api +++ b/ondewo-csi-api @@ -1 +1 @@ -Subproject commit a92272a855167e3327d71a4fc90555c0ebdd592a +Subproject commit 429070fbbdda9b102de0217ce205d016070844a1 diff --git a/ondewo/csi/conversation_pb2.py b/ondewo/csi/conversation_pb2.py index f12ac28..71018b2 100644 --- a/ondewo/csi/conversation_pb2.py +++ b/ondewo/csi/conversation_pb2.py @@ -1,11 +1,22 @@ # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! +# NO CHECKED-IN PROTOBUF GENCODE # source: ondewo/csi/conversation.proto +# Protobuf Python Version: 5.27.2 """Generated protocol buffer code.""" from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool +from google.protobuf import runtime_version as _runtime_version from google.protobuf import symbol_database as _symbol_database from google.protobuf.internal import builder as _builder +_runtime_version.ValidateProtobufRuntimeVersion( + _runtime_version.Domain.PUBLIC, + 5, + 27, + 2, + '', + 'ondewo/csi/conversation.proto' +) # @@protoc_insertion_point(imports) _sym_db = _symbol_database.Default() @@ -22,21 +33,21 @@ from google.protobuf import any_pb2 as google_dot_protobuf_dot_any__pb2 -DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1dondewo/csi/conversation.proto\x12\nondewo.csi\x1a\x1bgoogle/protobuf/empty.proto\x1a\x17google/rpc/status.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a\x18ondewo/nlu/session.proto\x1a\x1fondewo/t2s/text-to-speech.proto\x1a\x1fondewo/s2t/speech-to-text.proto\x1a\x18ondewo/nlu/context.proto\x1a\x19google/protobuf/any.proto\"~\n\x0bS2sPipeline\x12\n\n\x02id\x18\x01 \x01(\t\x12\x17\n\x0fs2t_pipeline_id\x18\x02 \x01(\t\x12\x16\n\x0enlu_project_id\x18\x03 \x01(\t\x12\x19\n\x11nlu_language_code\x18\x04 \x01(\t\x12\x17\n\x0ft2s_pipeline_id\x18\x05 \x01(\t\"\x1b\n\rS2sPipelineId\x12\n\n\x02id\x18\x01 \x01(\t\"\x19\n\x17ListS2sPipelinesRequest\"F\n\x18ListS2sPipelinesResponse\x12*\n\tpipelines\x18\x01 \x03(\x0b\x32\x17.ondewo.csi.S2sPipeline\"\x86\x01\n\x10S2sStreamRequest\x12\x13\n\x0bpipeline_id\x18\x01 \x01(\t\x12\x12\n\nsession_id\x18\x02 \x01(\t\x12\r\n\x05\x61udio\x18\x03 \x01(\x0c\x12\x15\n\rend_of_stream\x18\x04 \x01(\x08\x12#\n\x1binitial_intent_display_name\x18\x05 \x01(\t\"\xd1\x01\n\x11S2sStreamResponse\x12\x42\n\x16\x64\x65tect_intent_response\x18\x01 \x01(\x0b\x32 .ondewo.nlu.DetectIntentResponseH\x00\x12=\n\x13synthesize_response\x18\x02 \x01(\x0b\x32\x1e.ondewo.t2s.SynthesizeResponseH\x00\x12-\n\x0bsip_trigger\x18\x03 \x01(\x0b\x32\x16.ondewo.csi.SipTriggerH\x00\x42\n\n\x08response\"\xc7\x01\n\nSipTrigger\x12\x33\n\x04type\x18\x01 \x01(\x0e\x32%.ondewo.csi.SipTrigger.SipTriggerType\x12(\n\x07\x63ontent\x18\x02 \x01(\x0b\x32\x17.google.protobuf.Struct\"Z\n\x0eSipTriggerType\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\n\n\x06HANGUP\x10\x01\x12\x12\n\x0eHUMAN_HANDOVER\x10\x02\x12\x0c\n\x08SEND_NOW\x10\x03\x12\t\n\x05PAUSE\x10\x04\"\x95\x01\n\x1b\x43heckUpstreamHealthResponse\x12&\n\ns2t_status\x18\x01 \x01(\x0b\x32\x12.google.rpc.Status\x12&\n\nnlu_status\x18\x02 \x01(\x0b\x32\x12.google.rpc.Status\x12&\n\nt2s_status\x18\x03 \x01(\x0b\x32\x12.google.rpc.Status\"\x16\n\x14\x43ontrolStreamRequest\"J\n\x15\x43ontrolStreamResponse\x12\x31\n\x0e\x63ontrol_status\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\"L\n\x17SetControlStatusRequest\x12\x31\n\x0e\x63ontrol_status\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\"\x88\x01\n\x18SetControlStatusResponse\x12\x35\n\x12old_control_status\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\x12\x35\n\x12new_control_status\x18\x02 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\"C\n\tCondition\x12\'\n\x04type\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ConditionType\x12\r\n\x05value\x18\x02 \x01(\t\"\xfb\x02\n\x1f\x43ontrolMessageServiceParameters\x12/\n\nt2s_config\x18\x01 \x01(\x0b\x32\x19.ondewo.t2s.RequestConfigH\x00\x12\x39\n\ns2t_config\x18\x02 \x01(\x0b\x32#.ondewo.s2t.TranscribeRequestConfigH\x00\x12\x13\n\x0btransfer_id\x18\x03 \x01(\t\x12\x11\n\twav_files\x18\x04 \x03(\x0c\x12\x0c\n\x04text\x18\x05 \x01(\t\x12$\n\x07\x63ontext\x18\x06 \x01(\x0b\x32\x13.ondewo.nlu.Context\x12\x12\n\nsession_id\x18\x07 \x01(\t\x12\x14\n\x0c\x63ontext_name\x18\x08 \x01(\t\x12.\n\x0f\x63ondition_start\x18\t \x01(\x0b\x32\x15.ondewo.csi.Condition\x12,\n\rcondition_end\x18\n \x01(\x0b\x32\x15.ondewo.csi.ConditionB\x08\n\x06\x63onfig\"\xc2\x01\n\x0e\x43ontrolMessage\x12\x36\n\x07service\x18\x01 \x01(\x0e\x32%.ondewo.csi.ControlMessageServiceName\x12\x37\n\x06method\x18\x02 \x01(\x0e\x32\'.ondewo.csi.ControlMessageServiceMethod\x12?\n\nparameters\x18\x03 \x01(\x0b\x32+.ondewo.csi.ControlMessageServiceParameters*+\n\rControlStatus\x12\x06\n\x02OK\x10\x00\x12\x12\n\x0e\x45MERGENCY_STOP\x10\x01*l\n\x19\x43ontrolMessageServiceName\x12\x0f\n\x0bUNKNOWNNAME\x10\x00\x12\x0e\n\nondewo_s2t\x10\x01\x12\x0e\n\nondewo_t2s\x10\x02\x12\x0e\n\nondewo_nlu\x10\x03\x12\x0e\n\nondewo_sip\x10\x04*\x85\x03\n\x1b\x43ontrolMessageServiceMethod\x12\x11\n\rUNKNOWNMETHOD\x10\x00\x12\x11\n\rupdate_config\x10\x01\x12\x0f\n\x0bundo_config\x10\x02\x12\x10\n\x0creset_config\x10\x03\x12\x0c\n\x08\x65nd_call\x10\x04\x12\x11\n\rtransfer_call\x10\x05\x12\x12\n\x0eplay_wav_files\x10\x06\x12\r\n\tplay_text\x10\x07\x12\x08\n\x04mute\x10\x08\x12\x0b\n\x07un_mute\x10\t\x12\x1d\n\x19stop_all_control_messages\x10\n\x12\x0f\n\x0btrain_agent\x10\x0b\x12\x16\n\x12\x63\x61ncel_train_agent\x10\x0c\x12\x12\n\x0e\x64\x65lete_session\x10\r\x12\x17\n\x13\x64\x65lete_all_contexts\x10\x0e\x12\x12\n\x0e\x63reate_context\x10\x0f\x12\x12\n\x0eupdate_context\x10\x10\x12\x12\n\x0e\x64\x65lete_context\x10\x11\x12\x11\n\rdetect_intent\x10\x12*\\\n\rConditionType\x12\x0e\n\nUNKNOWTYPE\x10\x00\x12\r\n\timmediate\x10\x01\x12\x0c\n\x08\x64uration\x10\x02\x12\x0c\n\x08\x64\x61tetime\x10\x03\x12\x10\n\x0cinteractions\x10\x04\x32\xfa\x05\n\rConversations\x12\x46\n\x11\x43reateS2sPipeline\x12\x17.ondewo.csi.S2sPipeline\x1a\x16.google.protobuf.Empty\"\x00\x12\x46\n\x0eGetS2sPipeline\x12\x19.ondewo.csi.S2sPipelineId\x1a\x17.ondewo.csi.S2sPipeline\"\x00\x12\x46\n\x11UpdateS2sPipeline\x12\x17.ondewo.csi.S2sPipeline\x1a\x16.google.protobuf.Empty\"\x00\x12H\n\x11\x44\x65leteS2sPipeline\x12\x19.ondewo.csi.S2sPipelineId\x1a\x16.google.protobuf.Empty\"\x00\x12_\n\x10ListS2sPipelines\x12#.ondewo.csi.ListS2sPipelinesRequest\x1a$.ondewo.csi.ListS2sPipelinesResponse\"\x00\x12N\n\tS2sStream\x12\x1c.ondewo.csi.S2sStreamRequest\x1a\x1d.ondewo.csi.S2sStreamResponse\"\x00(\x01\x30\x01\x12X\n\x13\x43heckUpstreamHealth\x12\x16.google.protobuf.Empty\x1a\'.ondewo.csi.CheckUpstreamHealthResponse\"\x00\x12[\n\x10GetControlStream\x12 .ondewo.csi.ControlStreamRequest\x1a!.ondewo.csi.ControlStreamResponse\"\x00\x30\x01\x12_\n\x10SetControlStatus\x12#.ondewo.csi.SetControlStatusRequest\x1a$.ondewo.csi.SetControlStatusResponse\"\x00\x62\x06proto3') +DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x1dondewo/csi/conversation.proto\x12\nondewo.csi\x1a\x1bgoogle/protobuf/empty.proto\x1a\x17google/rpc/status.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1cgoogle/protobuf/struct.proto\x1a\x18ondewo/nlu/session.proto\x1a\x1fondewo/t2s/text-to-speech.proto\x1a\x1fondewo/s2t/speech-to-text.proto\x1a\x18ondewo/nlu/context.proto\x1a\x19google/protobuf/any.proto\"~\n\x0bS2sPipeline\x12\n\n\x02id\x18\x01 \x01(\t\x12\x17\n\x0fs2t_pipeline_id\x18\x02 \x01(\t\x12\x16\n\x0enlu_project_id\x18\x03 \x01(\t\x12\x19\n\x11nlu_language_code\x18\x04 \x01(\t\x12\x17\n\x0ft2s_pipeline_id\x18\x05 \x01(\t\"\x1b\n\rS2sPipelineId\x12\n\n\x02id\x18\x01 \x01(\t\"\x19\n\x17ListS2sPipelinesRequest\"F\n\x18ListS2sPipelinesResponse\x12*\n\tpipelines\x18\x01 \x03(\x0b\x32\x17.ondewo.csi.S2sPipeline\"\x86\x01\n\x10S2sStreamRequest\x12\x13\n\x0bpipeline_id\x18\x01 \x01(\t\x12\x12\n\nsession_id\x18\x02 \x01(\t\x12\r\n\x05\x61udio\x18\x03 \x01(\x0c\x12\x15\n\rend_of_stream\x18\x04 \x01(\x08\x12#\n\x1binitial_intent_display_name\x18\x05 \x01(\t\"\xd1\x01\n\x11S2sStreamResponse\x12\x42\n\x16\x64\x65tect_intent_response\x18\x01 \x01(\x0b\x32 .ondewo.nlu.DetectIntentResponseH\x00\x12=\n\x13synthesize_response\x18\x02 \x01(\x0b\x32\x1e.ondewo.t2s.SynthesizeResponseH\x00\x12-\n\x0bsip_trigger\x18\x03 \x01(\x0b\x32\x16.ondewo.csi.SipTriggerH\x00\x42\n\n\x08response\"\xc7\x01\n\nSipTrigger\x12\x33\n\x04type\x18\x01 \x01(\x0e\x32%.ondewo.csi.SipTrigger.SipTriggerType\x12(\n\x07\x63ontent\x18\x02 \x01(\x0b\x32\x17.google.protobuf.Struct\"Z\n\x0eSipTriggerType\x12\x0f\n\x0bUNSPECIFIED\x10\x00\x12\n\n\x06HANGUP\x10\x01\x12\x12\n\x0eHUMAN_HANDOVER\x10\x02\x12\x0c\n\x08SEND_NOW\x10\x03\x12\t\n\x05PAUSE\x10\x04\"\x95\x01\n\x1b\x43heckUpstreamHealthResponse\x12&\n\ns2t_status\x18\x01 \x01(\x0b\x32\x12.google.rpc.Status\x12&\n\nnlu_status\x18\x02 \x01(\x0b\x32\x12.google.rpc.Status\x12&\n\nt2s_status\x18\x03 \x01(\x0b\x32\x12.google.rpc.Status\"\x16\n\x14\x43ontrolStreamRequest\"J\n\x15\x43ontrolStreamResponse\x12\x31\n\x0e\x63ontrol_status\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\"L\n\x17SetControlStatusRequest\x12\x31\n\x0e\x63ontrol_status\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\"\x88\x01\n\x18SetControlStatusResponse\x12\x35\n\x12old_control_status\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\x12\x35\n\x12new_control_status\x18\x02 \x01(\x0e\x32\x19.ondewo.csi.ControlStatus\"C\n\tCondition\x12\'\n\x04type\x18\x01 \x01(\x0e\x32\x19.ondewo.csi.ConditionType\x12\r\n\x05value\x18\x02 \x01(\t\"\xfb\x02\n\x1f\x43ontrolMessageServiceParameters\x12/\n\nt2s_config\x18\x01 \x01(\x0b\x32\x19.ondewo.t2s.RequestConfigH\x00\x12\x39\n\ns2t_config\x18\x02 \x01(\x0b\x32#.ondewo.s2t.TranscribeRequestConfigH\x00\x12\x13\n\x0btransfer_id\x18\x03 \x01(\t\x12\x11\n\twav_files\x18\x04 \x03(\x0c\x12\x0c\n\x04text\x18\x05 \x01(\t\x12$\n\x07\x63ontext\x18\x06 \x01(\x0b\x32\x13.ondewo.nlu.Context\x12\x12\n\nsession_id\x18\x07 \x01(\t\x12\x14\n\x0c\x63ontext_name\x18\x08 \x01(\t\x12.\n\x0f\x63ondition_start\x18\t \x01(\x0b\x32\x15.ondewo.csi.Condition\x12,\n\rcondition_end\x18\n \x01(\x0b\x32\x15.ondewo.csi.ConditionB\x08\n\x06\x63onfig\"\xc2\x01\n\x0e\x43ontrolMessage\x12\x36\n\x07service\x18\x01 \x01(\x0e\x32%.ondewo.csi.ControlMessageServiceName\x12\x37\n\x06method\x18\x02 \x01(\x0e\x32\'.ondewo.csi.ControlMessageServiceMethod\x12?\n\nparameters\x18\x03 \x01(\x0b\x32+.ondewo.csi.ControlMessageServiceParameters*D\n\rControlStatus\x12\x06\n\x02OK\x10\x00\x12\x12\n\x0e\x45MERGENCY_STOP\x10\x01\x12\x17\n\x13VAD_START_OF_SPEECH\x10\x02*\xa0\x01\n\x19\x43ontrolMessageServiceName\x12\x0f\n\x0bUNKNOWNNAME\x10\x00\x12\x0e\n\nondewo_s2t\x10\x01\x12\x0e\n\nondewo_t2s\x10\x02\x12\x0e\n\nondewo_nlu\x10\x03\x12\x0e\n\nondewo_sip\x10\x04\x12\x0f\n\x0bondewo_vtsi\x10\x05\x12\x0e\n\nondewo_csi\x10\x06\x12\x11\n\rondewo_survey\x10\x07*\x85\x03\n\x1b\x43ontrolMessageServiceMethod\x12\x11\n\rUNKNOWNMETHOD\x10\x00\x12\x11\n\rupdate_config\x10\x01\x12\x0f\n\x0bundo_config\x10\x02\x12\x10\n\x0creset_config\x10\x03\x12\x0c\n\x08\x65nd_call\x10\x04\x12\x11\n\rtransfer_call\x10\x05\x12\x12\n\x0eplay_wav_files\x10\x06\x12\r\n\tplay_text\x10\x07\x12\x08\n\x04mute\x10\x08\x12\x0b\n\x07un_mute\x10\t\x12\x1d\n\x19stop_all_control_messages\x10\n\x12\x0f\n\x0btrain_agent\x10\x0b\x12\x16\n\x12\x63\x61ncel_train_agent\x10\x0c\x12\x12\n\x0e\x64\x65lete_session\x10\r\x12\x17\n\x13\x64\x65lete_all_contexts\x10\x0e\x12\x12\n\x0e\x63reate_context\x10\x0f\x12\x12\n\x0eupdate_context\x10\x10\x12\x12\n\x0e\x64\x65lete_context\x10\x11\x12\x11\n\rdetect_intent\x10\x12*\\\n\rConditionType\x12\x0e\n\nUNKNOWTYPE\x10\x00\x12\r\n\timmediate\x10\x01\x12\x0c\n\x08\x64uration\x10\x02\x12\x0c\n\x08\x64\x61tetime\x10\x03\x12\x10\n\x0cinteractions\x10\x04\x32\xfa\x05\n\rConversations\x12\x46\n\x11\x43reateS2sPipeline\x12\x17.ondewo.csi.S2sPipeline\x1a\x16.google.protobuf.Empty\"\x00\x12\x46\n\x0eGetS2sPipeline\x12\x19.ondewo.csi.S2sPipelineId\x1a\x17.ondewo.csi.S2sPipeline\"\x00\x12\x46\n\x11UpdateS2sPipeline\x12\x17.ondewo.csi.S2sPipeline\x1a\x16.google.protobuf.Empty\"\x00\x12H\n\x11\x44\x65leteS2sPipeline\x12\x19.ondewo.csi.S2sPipelineId\x1a\x16.google.protobuf.Empty\"\x00\x12_\n\x10ListS2sPipelines\x12#.ondewo.csi.ListS2sPipelinesRequest\x1a$.ondewo.csi.ListS2sPipelinesResponse\"\x00\x12N\n\tS2sStream\x12\x1c.ondewo.csi.S2sStreamRequest\x1a\x1d.ondewo.csi.S2sStreamResponse\"\x00(\x01\x30\x01\x12X\n\x13\x43heckUpstreamHealth\x12\x16.google.protobuf.Empty\x1a\'.ondewo.csi.CheckUpstreamHealthResponse\"\x00\x12[\n\x10GetControlStream\x12 .ondewo.csi.ControlStreamRequest\x1a!.ondewo.csi.ControlStreamResponse\"\x00\x30\x01\x12_\n\x10SetControlStatus\x12#.ondewo.csi.SetControlStatusRequest\x1a$.ondewo.csi.SetControlStatusResponse\"\x00\x62\x06proto3') _globals = globals() _builder.BuildMessageAndEnumDescriptors(DESCRIPTOR, _globals) _builder.BuildTopDescriptorsAndMessages(DESCRIPTOR, 'ondewo.csi.conversation_pb2', _globals) -if _descriptor._USE_C_DESCRIPTORS == False: - DESCRIPTOR._options = None +if not _descriptor._USE_C_DESCRIPTORS: + DESCRIPTOR._loaded_options = None _globals['_CONTROLSTATUS']._serialized_start=2231 - _globals['_CONTROLSTATUS']._serialized_end=2274 - _globals['_CONTROLMESSAGESERVICENAME']._serialized_start=2276 - _globals['_CONTROLMESSAGESERVICENAME']._serialized_end=2384 - _globals['_CONTROLMESSAGESERVICEMETHOD']._serialized_start=2387 - _globals['_CONTROLMESSAGESERVICEMETHOD']._serialized_end=2776 - _globals['_CONDITIONTYPE']._serialized_start=2778 - _globals['_CONDITIONTYPE']._serialized_end=2870 + _globals['_CONTROLSTATUS']._serialized_end=2299 + _globals['_CONTROLMESSAGESERVICENAME']._serialized_start=2302 + _globals['_CONTROLMESSAGESERVICENAME']._serialized_end=2462 + _globals['_CONTROLMESSAGESERVICEMETHOD']._serialized_start=2465 + _globals['_CONTROLMESSAGESERVICEMETHOD']._serialized_end=2854 + _globals['_CONDITIONTYPE']._serialized_start=2856 + _globals['_CONDITIONTYPE']._serialized_end=2948 _globals['_S2SPIPELINE']._serialized_start=307 _globals['_S2SPIPELINE']._serialized_end=433 _globals['_S2SPIPELINEID']._serialized_start=435 @@ -69,6 +80,6 @@ _globals['_CONTROLMESSAGESERVICEPARAMETERS']._serialized_end=2032 _globals['_CONTROLMESSAGE']._serialized_start=2035 _globals['_CONTROLMESSAGE']._serialized_end=2229 - _globals['_CONVERSATIONS']._serialized_start=2873 - _globals['_CONVERSATIONS']._serialized_end=3635 + _globals['_CONVERSATIONS']._serialized_start=2951 + _globals['_CONVERSATIONS']._serialized_end=3713 # @@protoc_insertion_point(module_scope) diff --git a/ondewo/csi/conversation_pb2.pyi b/ondewo/csi/conversation_pb2.pyi index e532957..a312a4e 100644 --- a/ondewo/csi/conversation_pb2.pyi +++ b/ondewo/csi/conversation_pb2.pyi @@ -15,6 +15,7 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. """ + import builtins import collections.abc import google.protobuf.descriptor @@ -47,6 +48,8 @@ class _ControlStatusEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._ """Status that control stream is ok""" EMERGENCY_STOP: _ControlStatus.ValueType # 1 """Status that control stream needs to stop immediately""" + VAD_START_OF_SPEECH: _ControlStatus.ValueType # 2 + """Status that voice activity detection detected start of speech""" class ControlStatus(_ControlStatus, metaclass=_ControlStatusEnumTypeWrapper): """Control status""" @@ -55,6 +58,8 @@ OK: ControlStatus.ValueType # 0 """Status that control stream is ok""" EMERGENCY_STOP: ControlStatus.ValueType # 1 """Status that control stream needs to stop immediately""" +VAD_START_OF_SPEECH: ControlStatus.ValueType # 2 +"""Status that voice activity detection detected start of speech""" global___ControlStatus = ControlStatus class _ControlMessageServiceName: @@ -73,6 +78,12 @@ class _ControlMessageServiceNameEnumTypeWrapper(google.protobuf.internal.enum_ty """NLU control message service name""" ondewo_sip: _ControlMessageServiceName.ValueType # 4 """SIP control message service name""" + ondewo_vtsi: _ControlMessageServiceName.ValueType # 5 + """VTSI control message service name""" + ondewo_csi: _ControlMessageServiceName.ValueType # 6 + """CSI control message service name""" + ondewo_survey: _ControlMessageServiceName.ValueType # 7 + """Survey control message service name""" class ControlMessageServiceName(_ControlMessageServiceName, metaclass=_ControlMessageServiceNameEnumTypeWrapper): """Control message services""" @@ -87,6 +98,12 @@ ondewo_nlu: ControlMessageServiceName.ValueType # 3 """NLU control message service name""" ondewo_sip: ControlMessageServiceName.ValueType # 4 """SIP control message service name""" +ondewo_vtsi: ControlMessageServiceName.ValueType # 5 +"""VTSI control message service name""" +ondewo_csi: ControlMessageServiceName.ValueType # 6 +"""CSI control message service name""" +ondewo_survey: ControlMessageServiceName.ValueType # 7 +"""Survey control message service name""" global___ControlMessageServiceName = ControlMessageServiceName class _ControlMessageServiceMethod: @@ -999,7 +1016,7 @@ Example value need be given as a string in the format: 
value="4" None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["id", b"id", "nlu_language_code", b"nlu_language_code", "nlu_project_id", b"nlu_project_id", "s2t_pipeline_id", b"s2t_pipeline_id", "t2s_pipeline_id", b"t2s_pipeline_id"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["id", b"id", "nlu_language_code", b"nlu_language_code", "nlu_project_id", b"nlu_project_id", "s2t_pipeline_id", b"s2t_pipeline_id", "t2s_pipeline_id", b"t2s_pipeline_id"]) -> None: ...
 
 global___S2sPipeline = S2sPipeline
 
-@typing_extensions.final
+@typing.final
 class S2sPipelineId(google.protobuf.message.Message):
     """The top-level message sent by client to `GetS2sPipeline` and `DeleteS2sPipeline` endpoints."""
 
@@ -1049,11 +1066,11 @@ class S2sPipelineId(google.protobuf.message.Message):
         *,
         id: builtins.str = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["id", b"id"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["id", b"id"]) -> None: ...
 
 global___S2sPipelineId = S2sPipelineId
 
-@typing_extensions.final
+@typing.final
 class ListS2sPipelinesRequest(google.protobuf.message.Message):
     """The top-level message sent by client to `ListS2sPipelines` endpoint. Currently without arguments.
     TODO: add filtering options
@@ -1067,7 +1084,7 @@ class ListS2sPipelinesRequest(google.protobuf.message.Message):
 
 global___ListS2sPipelinesRequest = ListS2sPipelinesRequest
 
-@typing_extensions.final
+@typing.final
 class ListS2sPipelinesResponse(google.protobuf.message.Message):
     """The top-level message received from `ListS2sPipelines` endpoint."""
 
@@ -1077,16 +1094,17 @@ class ListS2sPipelinesResponse(google.protobuf.message.Message):
     @property
     def pipelines(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[global___S2sPipeline]:
         """Collection of S2S pipelines of the server."""
+
     def __init__(
         self,
         *,
         pipelines: collections.abc.Iterable[global___S2sPipeline] | None = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["pipelines", b"pipelines"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["pipelines", b"pipelines"]) -> None: ...
 
 global___ListS2sPipelinesResponse = ListS2sPipelinesResponse
 
-@typing_extensions.final
+@typing.final
 class S2sStreamRequest(google.protobuf.message.Message):
     """The top-level message sent by the client to the
     `S2sStream` method.
@@ -1131,11 +1149,11 @@ class S2sStreamRequest(google.protobuf.message.Message):
         end_of_stream: builtins.bool = ...,
         initial_intent_display_name: builtins.str = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["audio", b"audio", "end_of_stream", b"end_of_stream", "initial_intent_display_name", b"initial_intent_display_name", "pipeline_id", b"pipeline_id", "session_id", b"session_id"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["audio", b"audio", "end_of_stream", b"end_of_stream", "initial_intent_display_name", b"initial_intent_display_name", "pipeline_id", b"pipeline_id", "session_id", b"session_id"]) -> None: ...
 
 global___S2sStreamRequest = S2sStreamRequest
 
-@typing_extensions.final
+@typing.final
 class S2sStreamResponse(google.protobuf.message.Message):
     """The top-level message returned from the
     `S2sStream` method.
@@ -1160,12 +1178,15 @@ class S2sStreamResponse(google.protobuf.message.Message):
     @property
     def detect_intent_response(self) -> ondewo.nlu.session_pb2.DetectIntentResponse:
         """full NLU detect intent response"""
+
     @property
     def synthesize_response(self) -> ondewo.t2s.text_to_speech_pb2.SynthesizeResponse:
         """full T2S synthesize response"""
+
     @property
     def sip_trigger(self) -> global___SipTrigger:
         """SIP trigger message"""
+
     def __init__(
         self,
         *,
@@ -1173,13 +1194,13 @@ class S2sStreamResponse(google.protobuf.message.Message):
         synthesize_response: ondewo.t2s.text_to_speech_pb2.SynthesizeResponse | None = ...,
         sip_trigger: global___SipTrigger | None = ...,
     ) -> None: ...
-    def HasField(self, field_name: typing_extensions.Literal["detect_intent_response", b"detect_intent_response", "response", b"response", "sip_trigger", b"sip_trigger", "synthesize_response", b"synthesize_response"]) -> builtins.bool: ...
-    def ClearField(self, field_name: typing_extensions.Literal["detect_intent_response", b"detect_intent_response", "response", b"response", "sip_trigger", b"sip_trigger", "synthesize_response", b"synthesize_response"]) -> None: ...
-    def WhichOneof(self, oneof_group: typing_extensions.Literal["response", b"response"]) -> typing_extensions.Literal["detect_intent_response", "synthesize_response", "sip_trigger"] | None: ...
+    def HasField(self, field_name: typing.Literal["detect_intent_response", b"detect_intent_response", "response", b"response", "sip_trigger", b"sip_trigger", "synthesize_response", b"synthesize_response"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing.Literal["detect_intent_response", b"detect_intent_response", "response", b"response", "sip_trigger", b"sip_trigger", "synthesize_response", b"synthesize_response"]) -> None: ...
+    def WhichOneof(self, oneof_group: typing.Literal["response", b"response"]) -> typing.Literal["detect_intent_response", "synthesize_response", "sip_trigger"] | None: ...
 
 global___S2sStreamResponse = S2sStreamResponse
 
-@typing_extensions.final
+@typing.final
 class SipTrigger(google.protobuf.message.Message):
     """SIP trigger message"""
 
@@ -1222,18 +1243,19 @@ class SipTrigger(google.protobuf.message.Message):
     @property
     def content(self) -> google.protobuf.struct_pb2.Struct:
         """extra parameters for the trigger"""
+
     def __init__(
         self,
         *,
         type: global___SipTrigger.SipTriggerType.ValueType = ...,
         content: google.protobuf.struct_pb2.Struct | None = ...,
     ) -> None: ...
-    def HasField(self, field_name: typing_extensions.Literal["content", b"content"]) -> builtins.bool: ...
-    def ClearField(self, field_name: typing_extensions.Literal["content", b"content", "type", b"type"]) -> None: ...
+    def HasField(self, field_name: typing.Literal["content", b"content"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing.Literal["content", b"content", "type", b"type"]) -> None: ...
 
 global___SipTrigger = SipTrigger
 
-@typing_extensions.final
+@typing.final
 class CheckUpstreamHealthResponse(google.protobuf.message.Message):
     """Health checks"""
 
@@ -1245,12 +1267,15 @@ class CheckUpstreamHealthResponse(google.protobuf.message.Message):
     @property
     def s2t_status(self) -> google.rpc.status_pb2.Status:
         """Health checks for Speech-2-Text"""
+
     @property
     def nlu_status(self) -> google.rpc.status_pb2.Status:
         """Health checks for NLU"""
+
     @property
     def t2s_status(self) -> google.rpc.status_pb2.Status:
         """Health checks for Text-2-Speech"""
+
     def __init__(
         self,
         *,
@@ -1258,12 +1283,12 @@ class CheckUpstreamHealthResponse(google.protobuf.message.Message):
         nlu_status: google.rpc.status_pb2.Status | None = ...,
         t2s_status: google.rpc.status_pb2.Status | None = ...,
     ) -> None: ...
-    def HasField(self, field_name: typing_extensions.Literal["nlu_status", b"nlu_status", "s2t_status", b"s2t_status", "t2s_status", b"t2s_status"]) -> builtins.bool: ...
-    def ClearField(self, field_name: typing_extensions.Literal["nlu_status", b"nlu_status", "s2t_status", b"s2t_status", "t2s_status", b"t2s_status"]) -> None: ...
+    def HasField(self, field_name: typing.Literal["nlu_status", b"nlu_status", "s2t_status", b"s2t_status", "t2s_status", b"t2s_status"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing.Literal["nlu_status", b"nlu_status", "s2t_status", b"s2t_status", "t2s_status", b"t2s_status"]) -> None: ...
 
 global___CheckUpstreamHealthResponse = CheckUpstreamHealthResponse
 
-@typing_extensions.final
+@typing.final
 class ControlStreamRequest(google.protobuf.message.Message):
     """Control stream message"""
 
@@ -1275,7 +1300,7 @@ class ControlStreamRequest(google.protobuf.message.Message):
 
 global___ControlStreamRequest = ControlStreamRequest
 
-@typing_extensions.final
+@typing.final
 class ControlStreamResponse(google.protobuf.message.Message):
     """Control stream response message"""
 
@@ -1289,11 +1314,11 @@ class ControlStreamResponse(google.protobuf.message.Message):
         *,
         control_status: global___ControlStatus.ValueType = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["control_status", b"control_status"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["control_status", b"control_status"]) -> None: ...
 
 global___ControlStreamResponse = ControlStreamResponse
 
-@typing_extensions.final
+@typing.final
 class SetControlStatusRequest(google.protobuf.message.Message):
     """Request to set control status"""
 
@@ -1307,11 +1332,11 @@ class SetControlStatusRequest(google.protobuf.message.Message):
         *,
         control_status: global___ControlStatus.ValueType = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["control_status", b"control_status"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["control_status", b"control_status"]) -> None: ...
 
 global___SetControlStatusRequest = SetControlStatusRequest
 
-@typing_extensions.final
+@typing.final
 class SetControlStatusResponse(google.protobuf.message.Message):
     """Response of setting the control status with the old and new status objects"""
 
@@ -1329,11 +1354,11 @@ class SetControlStatusResponse(google.protobuf.message.Message):
         old_control_status: global___ControlStatus.ValueType = ...,
         new_control_status: global___ControlStatus.ValueType = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["new_control_status", b"new_control_status", "old_control_status", b"old_control_status"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["new_control_status", b"new_control_status", "old_control_status", b"old_control_status"]) -> None: ...
 
 global___SetControlStatusResponse = SetControlStatusResponse
 
-@typing_extensions.final
+@typing.final
 class Condition(google.protobuf.message.Message):
     """A condition message with its type and value
 
@@ -1387,11 +1412,11 @@ class Condition(google.protobuf.message.Message):
         type: global___ConditionType.ValueType = ...,
         value: builtins.str = ...,
     ) -> None: ...
-    def ClearField(self, field_name: typing_extensions.Literal["type", b"type", "value", b"value"]) -> None: ...
+    def ClearField(self, field_name: typing.Literal["type", b"type", "value", b"value"]) -> None: ...
 
 global___Condition = Condition
 
-@typing_extensions.final
+@typing.final
 class ControlMessageServiceParameters(google.protobuf.message.Message):
     """Parameters of the control message passed to the service specified in the control message"""
 
@@ -1407,32 +1432,38 @@ class ControlMessageServiceParameters(google.protobuf.message.Message):
     CONTEXT_NAME_FIELD_NUMBER: builtins.int
     CONDITION_START_FIELD_NUMBER: builtins.int
     CONDITION_END_FIELD_NUMBER: builtins.int
+    transfer_id: builtins.str
+    """SIP: callee id to transfer call to"""
+    text: builtins.str
+    """text, e.g. for NLU detect intent response or Text-2-Speech voice synthesis"""
+    session_id: builtins.str
+    """NLU: the session id of a NLU session"""
+    context_name: builtins.str
+    """NLU: the name of the context of a NLU session"""
     @property
     def t2s_config(self) -> ondewo.t2s.text_to_speech_pb2.RequestConfig:
         """Text-2-Speech: configuration to control the synthesis of a text into audio"""
+
     @property
     def s2t_config(self) -> ondewo.s2t.speech_to_text_pb2.TranscribeRequestConfig:
         """Speech-2-Text: configuration to control the recognition of text based on human voice audio"""
-    transfer_id: builtins.str
-    """SIP: callee id to transfer call to"""
+
     @property
     def wav_files(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.bytes]:
         """SIP: bytes of audio files to play to a caller"""
-    text: builtins.str
-    """text, e.g. for NLU detect intent response or Text-2-Speech voice synthesis"""
+
     @property
     def context(self) -> ondewo.nlu.context_pb2.Context:
         """NLU: context for creating, updating or deleting contextual information from a NLU session"""
-    session_id: builtins.str
-    """NLU: the session id of a NLU session"""
-    context_name: builtins.str
-    """NLU: the name of the context of a NLU session"""
+
     @property
     def condition_start(self) -> global___Condition:
         """CSI: the condition that defines when a control message should be executed"""
+
     @property
     def condition_end(self) -> global___Condition:
         """CSI: the condition that defines when a control message should stop its execution"""
+
     def __init__(
         self,
         *,
@@ -1447,13 +1478,13 @@ class ControlMessageServiceParameters(google.protobuf.message.Message):
         condition_start: global___Condition | None = ...,
         condition_end: global___Condition | None = ...,
     ) -> None: ...
-    def HasField(self, field_name: typing_extensions.Literal["condition_end", b"condition_end", "condition_start", b"condition_start", "config", b"config", "context", b"context", "s2t_config", b"s2t_config", "t2s_config", b"t2s_config"]) -> builtins.bool: ...
-    def ClearField(self, field_name: typing_extensions.Literal["condition_end", b"condition_end", "condition_start", b"condition_start", "config", b"config", "context", b"context", "context_name", b"context_name", "s2t_config", b"s2t_config", "session_id", b"session_id", "t2s_config", b"t2s_config", "text", b"text", "transfer_id", b"transfer_id", "wav_files", b"wav_files"]) -> None: ...
-    def WhichOneof(self, oneof_group: typing_extensions.Literal["config", b"config"]) -> typing_extensions.Literal["t2s_config", "s2t_config"] | None: ...
+    def HasField(self, field_name: typing.Literal["condition_end", b"condition_end", "condition_start", b"condition_start", "config", b"config", "context", b"context", "s2t_config", b"s2t_config", "t2s_config", b"t2s_config"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing.Literal["condition_end", b"condition_end", "condition_start", b"condition_start", "config", b"config", "context", b"context", "context_name", b"context_name", "s2t_config", b"s2t_config", "session_id", b"session_id", "t2s_config", b"t2s_config", "text", b"text", "transfer_id", b"transfer_id", "wav_files", b"wav_files"]) -> None: ...
+    def WhichOneof(self, oneof_group: typing.Literal["config", b"config"]) -> typing.Literal["t2s_config", "s2t_config"] | None: ...
 
 global___ControlMessageServiceParameters = ControlMessageServiceParameters
 
-@typing_extensions.final
+@typing.final
 class ControlMessage(google.protobuf.message.Message):
     """A control message
 
@@ -1497,6 +1528,7 @@ class ControlMessage(google.protobuf.message.Message):
     @property
     def parameters(self) -> global___ControlMessageServiceParameters:
         """Parameters to use to invoke the method of the service"""
+
     def __init__(
         self,
         *,
@@ -1504,7 +1536,7 @@ class ControlMessage(google.protobuf.message.Message):
         method: global___ControlMessageServiceMethod.ValueType = ...,
         parameters: global___ControlMessageServiceParameters | None = ...,
     ) -> None: ...
-    def HasField(self, field_name: typing_extensions.Literal["parameters", b"parameters"]) -> builtins.bool: ...
-    def ClearField(self, field_name: typing_extensions.Literal["method", b"method", "parameters", b"parameters", "service", b"service"]) -> None: ...
+    def HasField(self, field_name: typing.Literal["parameters", b"parameters"]) -> builtins.bool: ...
+    def ClearField(self, field_name: typing.Literal["method", b"method", "parameters", b"parameters", "service", b"service"]) -> None: ...
 
 global___ControlMessage = ControlMessage
diff --git a/ondewo/csi/conversation_pb2_grpc.py b/ondewo/csi/conversation_pb2_grpc.py
index 7f989ce..24f9dc6 100644
--- a/ondewo/csi/conversation_pb2_grpc.py
+++ b/ondewo/csi/conversation_pb2_grpc.py
@@ -1,10 +1,30 @@
 # Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
 """Client and server classes corresponding to protobuf-defined services."""
 import grpc
+import warnings
 
 from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2
 from ondewo.csi import conversation_pb2 as ondewo_dot_csi_dot_conversation__pb2
 
+GRPC_GENERATED_VERSION = '1.67.1'
+GRPC_VERSION = grpc.__version__
+_version_not_supported = False
+
+try:
+    from grpc._utilities import first_version_is_lower
+    _version_not_supported = first_version_is_lower(GRPC_VERSION, GRPC_GENERATED_VERSION)
+except ImportError:
+    _version_not_supported = True
+
+if _version_not_supported:
+    raise RuntimeError(
+        f'The grpc package installed is at version {GRPC_VERSION},'
+        + f' but the generated code in ondewo/csi/conversation_pb2_grpc.py depends on'
+        + f' grpcio>={GRPC_GENERATED_VERSION}.'
+        + f' Please upgrade your grpc module to grpcio>={GRPC_GENERATED_VERSION}'
+        + f' or downgrade your generated code using grpcio-tools<={GRPC_VERSION}.'
+    )
+
 
 class ConversationsStub(object):
     """endpoints of csi service
@@ -20,47 +40,47 @@ def __init__(self, channel):
                 '/ondewo.csi.Conversations/CreateS2sPipeline',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.S2sPipeline.SerializeToString,
                 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
-                )
+                _registered_method=True)
         self.GetS2sPipeline = channel.unary_unary(
                 '/ondewo.csi.Conversations/GetS2sPipeline',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.S2sPipelineId.SerializeToString,
                 response_deserializer=ondewo_dot_csi_dot_conversation__pb2.S2sPipeline.FromString,
-                )
+                _registered_method=True)
         self.UpdateS2sPipeline = channel.unary_unary(
                 '/ondewo.csi.Conversations/UpdateS2sPipeline',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.S2sPipeline.SerializeToString,
                 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
-                )
+                _registered_method=True)
         self.DeleteS2sPipeline = channel.unary_unary(
                 '/ondewo.csi.Conversations/DeleteS2sPipeline',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.S2sPipelineId.SerializeToString,
                 response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
-                )
+                _registered_method=True)
         self.ListS2sPipelines = channel.unary_unary(
                 '/ondewo.csi.Conversations/ListS2sPipelines',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.ListS2sPipelinesRequest.SerializeToString,
                 response_deserializer=ondewo_dot_csi_dot_conversation__pb2.ListS2sPipelinesResponse.FromString,
-                )
+                _registered_method=True)
         self.S2sStream = channel.stream_stream(
                 '/ondewo.csi.Conversations/S2sStream',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.S2sStreamRequest.SerializeToString,
                 response_deserializer=ondewo_dot_csi_dot_conversation__pb2.S2sStreamResponse.FromString,
-                )
+                _registered_method=True)
         self.CheckUpstreamHealth = channel.unary_unary(
                 '/ondewo.csi.Conversations/CheckUpstreamHealth',
                 request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                 response_deserializer=ondewo_dot_csi_dot_conversation__pb2.CheckUpstreamHealthResponse.FromString,
-                )
+                _registered_method=True)
         self.GetControlStream = channel.unary_stream(
                 '/ondewo.csi.Conversations/GetControlStream',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.ControlStreamRequest.SerializeToString,
                 response_deserializer=ondewo_dot_csi_dot_conversation__pb2.ControlStreamResponse.FromString,
-                )
+                _registered_method=True)
         self.SetControlStatus = channel.unary_unary(
                 '/ondewo.csi.Conversations/SetControlStatus',
                 request_serializer=ondewo_dot_csi_dot_conversation__pb2.SetControlStatusRequest.SerializeToString,
                 response_deserializer=ondewo_dot_csi_dot_conversation__pb2.SetControlStatusResponse.FromString,
-                )
+                _registered_method=True)
 
 
 class ConversationsServicer(object):
@@ -272,6 +292,7 @@ def add_ConversationsServicer_to_server(servicer, server):
     generic_handler = grpc.method_handlers_generic_handler(
             'ondewo.csi.Conversations', rpc_method_handlers)
     server.add_generic_rpc_handlers((generic_handler,))
+    server.add_registered_method_handlers('ondewo.csi.Conversations', rpc_method_handlers)
 
 
  # This class is part of an EXPERIMENTAL API.
@@ -290,11 +311,21 @@ def CreateS2sPipeline(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/CreateS2sPipeline',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/CreateS2sPipeline',
             ondewo_dot_csi_dot_conversation__pb2.S2sPipeline.SerializeToString,
             google_dot_protobuf_dot_empty__pb2.Empty.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def GetS2sPipeline(request,
@@ -307,11 +338,21 @@ def GetS2sPipeline(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/GetS2sPipeline',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/GetS2sPipeline',
             ondewo_dot_csi_dot_conversation__pb2.S2sPipelineId.SerializeToString,
             ondewo_dot_csi_dot_conversation__pb2.S2sPipeline.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def UpdateS2sPipeline(request,
@@ -324,11 +365,21 @@ def UpdateS2sPipeline(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/UpdateS2sPipeline',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/UpdateS2sPipeline',
             ondewo_dot_csi_dot_conversation__pb2.S2sPipeline.SerializeToString,
             google_dot_protobuf_dot_empty__pb2.Empty.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def DeleteS2sPipeline(request,
@@ -341,11 +392,21 @@ def DeleteS2sPipeline(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/DeleteS2sPipeline',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/DeleteS2sPipeline',
             ondewo_dot_csi_dot_conversation__pb2.S2sPipelineId.SerializeToString,
             google_dot_protobuf_dot_empty__pb2.Empty.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def ListS2sPipelines(request,
@@ -358,11 +419,21 @@ def ListS2sPipelines(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/ListS2sPipelines',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/ListS2sPipelines',
             ondewo_dot_csi_dot_conversation__pb2.ListS2sPipelinesRequest.SerializeToString,
             ondewo_dot_csi_dot_conversation__pb2.ListS2sPipelinesResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def S2sStream(request_iterator,
@@ -375,11 +446,21 @@ def S2sStream(request_iterator,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.stream_stream(request_iterator, target, '/ondewo.csi.Conversations/S2sStream',
+        return grpc.experimental.stream_stream(
+            request_iterator,
+            target,
+            '/ondewo.csi.Conversations/S2sStream',
             ondewo_dot_csi_dot_conversation__pb2.S2sStreamRequest.SerializeToString,
             ondewo_dot_csi_dot_conversation__pb2.S2sStreamResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def CheckUpstreamHealth(request,
@@ -392,11 +473,21 @@ def CheckUpstreamHealth(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/CheckUpstreamHealth',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/CheckUpstreamHealth',
             google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
             ondewo_dot_csi_dot_conversation__pb2.CheckUpstreamHealthResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def GetControlStream(request,
@@ -409,11 +500,21 @@ def GetControlStream(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_stream(request, target, '/ondewo.csi.Conversations/GetControlStream',
+        return grpc.experimental.unary_stream(
+            request,
+            target,
+            '/ondewo.csi.Conversations/GetControlStream',
             ondewo_dot_csi_dot_conversation__pb2.ControlStreamRequest.SerializeToString,
             ondewo_dot_csi_dot_conversation__pb2.ControlStreamResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
 
     @staticmethod
     def SetControlStatus(request,
@@ -426,8 +527,18 @@ def SetControlStatus(request,
             wait_for_ready=None,
             timeout=None,
             metadata=None):
-        return grpc.experimental.unary_unary(request, target, '/ondewo.csi.Conversations/SetControlStatus',
+        return grpc.experimental.unary_unary(
+            request,
+            target,
+            '/ondewo.csi.Conversations/SetControlStatus',
             ondewo_dot_csi_dot_conversation__pb2.SetControlStatusRequest.SerializeToString,
             ondewo_dot_csi_dot_conversation__pb2.SetControlStatusResponse.FromString,
-            options, channel_credentials,
-            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+            options,
+            channel_credentials,
+            insecure,
+            call_credentials,
+            compression,
+            wait_for_ready,
+            timeout,
+            metadata,
+            _registered_method=True)
diff --git a/setup.py b/setup.py
index ba5dc3d..4c2dc51 100644
--- a/setup.py
+++ b/setup.py
@@ -27,7 +27,7 @@ def read_requirements(file_path: str, encoding: str = 'utf-8') -> List[str]:
 
 setup(
     name="ondewo-csi-client",
-    version='4.0.1',
+    version='5.0.0',
     author="ONDEWO GmbH",
     author_email="office@ondewo.com",
     description="ONDEWO Communication System Integration (CSI) Client library for Python",