Pawel plesniak/incomplete stateful command transition

schema/druncschema/common.proto

@@ -0,0 +1,23 @@
+syntax = "proto3";
+
+package dunedaq.druncschema;
+
+import "druncschema/generic.proto";
+import "druncschema/token.proto";
+import "druncschema/request_response.proto";
+
+message LogOnServerRequest {
+  Token token = 1;
+  string text = 2;
+  string severity = 3;
+  string target = 4;
+  bool execute_along_path = 5;
+  bool execute_on_all_subsequent_children_in_path = 6;
+}
+
+message LogOnServerResponse {
+  Token token = 1;
+  string name = 2;
+  ResponseFlag flag = 3;
+  repeated LogOnServerResponse children = 4;
+}

schema/druncschema/controller.proto

@@ -5,6 +5,7 @@ package dunedaq.druncschema.controller;
 import "druncschema/request_response.proto";
 import "druncschema/description.proto";
 import "druncschema/token.proto";
+import "druncschema/common.proto";
 import "google/protobuf/any.proto";
 
 service Controller {
@@ -23,6 +24,8 @@ service Controller {
   rpc who_is_in_charge           (WhoIsInChargeRequest) returns (WhoIsInChargeResponse) {}
 
   rpc to_error                   (ToErrorRequest) returns (ToErrorResponse) {}
+
+  rpc log_on_server              (LogOnServerRequest) returns (LogOnServerResponse) {}
 }
 
 message AddressedCommand {

schema/druncschema/process_manager.proto

@@ -5,6 +5,7 @@ package dunedaq.druncschema.process_manager;
 import "druncschema/request_response.proto";
 import "druncschema/description.proto";
 import "druncschema/token.proto";
+import "druncschema/common.proto";
 import "druncschema/generic.proto";
 
 service ProcessManager {
@@ -17,6 +18,7 @@ service ProcessManager {
   rpc flush     (ProcessQuery) returns (ProcessInstanceList) {}
   rpc ps        (ProcessQuery) returns (ProcessInstanceList) {}
   rpc logs      (LogRequest) returns (LogLines) {}
+  rpc log_on_server              (LogOnServerRequest) returns (LogOnServerResponse) {}
 }
 
 message ProcessRestriction {

src/druncschema/common_pb2.pyi

@@ -0,0 +1,86 @@
+"""
+@generated by mypy-protobuf.  Do not edit manually!
+isort:skip_file
+"""
+
+from collections import abc as _abc
+from druncschema import request_response_pb2 as _request_response_pb2
+from druncschema import token_pb2 as _token_pb2
+from google.protobuf import descriptor as _descriptor
+from google.protobuf import message as _message
+from google.protobuf.internal import containers as _containers
+import builtins as _builtins
+import sys
+import typing as _typing
+
+if sys.version_info >= (3, 11):
+    from typing import TypeAlias as _TypeAlias, Never as _Never
+else:
+    from typing_extensions import TypeAlias as _TypeAlias, Never as _Never
+
+DESCRIPTOR: _descriptor.FileDescriptor
+
+@_typing.final
+class LogOnServerRequest(_message.Message):
+    DESCRIPTOR: _descriptor.Descriptor
+
+    TOKEN_FIELD_NUMBER: _builtins.int
+    TEXT_FIELD_NUMBER: _builtins.int
+    SEVERITY_FIELD_NUMBER: _builtins.int
+    TARGET_FIELD_NUMBER: _builtins.int
+    EXECUTE_ALONG_PATH_FIELD_NUMBER: _builtins.int
+    EXECUTE_ON_ALL_SUBSEQUENT_CHILDREN_IN_PATH_FIELD_NUMBER: _builtins.int
+    text: _builtins.str
+    severity: _builtins.str
+    target: _builtins.str
+    execute_along_path: _builtins.bool
+    execute_on_all_subsequent_children_in_path: _builtins.bool
+    @_builtins.property
+    def token(self) -> _token_pb2.Token: ...
+    def __init__(
+        self,
+        *,
+        token: _token_pb2.Token | None = ...,
+        text: _builtins.str = ...,
+        severity: _builtins.str = ...,
+        target: _builtins.str = ...,
+        execute_along_path: _builtins.bool = ...,
+        execute_on_all_subsequent_children_in_path: _builtins.bool = ...,
+    ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _typing.Literal["token", b"token"]  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
+    _ClearFieldArgType: _TypeAlias = _typing.Literal["execute_along_path", b"execute_along_path", "execute_on_all_subsequent_children_in_path", b"execute_on_all_subsequent_children_in_path", "severity", b"severity", "target", b"target", "text", b"text", "token", b"token"]  # noqa: Y015
+    def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
+
+Global___LogOnServerRequest: _TypeAlias = LogOnServerRequest  # noqa: Y015
+
+@_typing.final
+class LogOnServerResponse(_message.Message):
+    DESCRIPTOR: _descriptor.Descriptor
+
+    TOKEN_FIELD_NUMBER: _builtins.int
+    NAME_FIELD_NUMBER: _builtins.int
+    FLAG_FIELD_NUMBER: _builtins.int
+    CHILDREN_FIELD_NUMBER: _builtins.int
+    name: _builtins.str
+    flag: _request_response_pb2.ResponseFlag.ValueType
+    @_builtins.property
+    def token(self) -> _token_pb2.Token: ...
+    @_builtins.property
+    def children(self) -> _containers.RepeatedCompositeFieldContainer[Global___LogOnServerResponse]: ...
+    def __init__(
+        self,
+        *,
+        token: _token_pb2.Token | None = ...,
+        name: _builtins.str = ...,
+        flag: _request_response_pb2.ResponseFlag.ValueType = ...,
+        children: _abc.Iterable[Global___LogOnServerResponse] | None = ...,
+    ) -> None: ...
+    _HasFieldArgType: _TypeAlias = _typing.Literal["token", b"token"]  # noqa: Y015
+    def HasField(self, field_name: _HasFieldArgType) -> _builtins.bool: ...
+    _ClearFieldArgType: _TypeAlias = _typing.Literal["children", b"children", "flag", b"flag", "name", b"name", "token", b"token"]  # noqa: Y015
+    def ClearField(self, field_name: _ClearFieldArgType) -> None: ...
+    def WhichOneof(self, oneof_group: _Never) -> None: ...
+
+Global___LogOnServerResponse: _TypeAlias = LogOnServerResponse  # noqa: Y015

src/druncschema/common_pb2_grpc.py

@@ -0,0 +1,24 @@
+# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
+"""Client and server classes corresponding to protobuf-defined services."""
+import grpc
+import warnings
+
+
+GRPC_GENERATED_VERSION = '1.75.0'
+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 druncschema/common_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}.'
+    )