Feat/add docker image

.github/workflows/build_and_publish_docker_image.yml

@@ -0,0 +1,59 @@
+name: build_and_publish_docker_image
+
+on:
+  release:
+    types:
+      - published
+  workflow_dispatch:
+
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+
+jobs:
+  build_and_publish_image:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      packages: write
+
+    steps:
+      - name: Checkout
+        uses: actions/checkout@v4
+
+      - name: Log in to Docker Hub
+        uses: docker/login-action@v3
+        with:
+          registry: docker.io
+          username: ${{ vars.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+
+      - name: Extract Docker metadata
+        uses: docker/metadata-action@v5
+        id: meta
+        with:
+          images: ${{ github.repository }}
+          flavor: |
+            latest=auto
+          tags: |
+            type=raw,value=latest,enable={{is_default_branch}}
+            type=semver,pattern={{version}}
+
+      - name: Test Dockerfile
+        run: docker build -t chatsky_image -f chatsky/utils/docker/chatsky/dockerfile_chatsky .    
+
+      - name: Build and upload image
+        uses: docker/build-push-action@v5
+        with:
+          context: .
+          file: chatsky/utils/docker/chatsky/dockerfile_chatsky
+          push: true
+          tags: ${{ steps.meta.outputs.tags }}
+          labels: ${{ steps.meta.outputs.labels }}
+
+      - name: Update repo description
+        uses: peter-evans/dockerhub-description@e98e4d1628a5f3be2be7c231e50981aee98723ae # v4.0.0
+        with:
+          username: ${{ vars.DOCKERHUB_USERNAME }}
+          password: ${{ secrets.DOCKERHUB_TOKEN }}
+          repository: ${{ github.repository }}

.github/workflows/update_dashboard.yml

@@ -41,7 +41,7 @@ jobs:
         - name: Build and upload image
           uses: docker/build-push-action@v5
           with:
-            context: chatsky/utils/docker
-            file: chatsky/utils/docker/dockerfile_stats
+            context: chatsky/utils/docker/stats
+            file: chatsky/utils/docker/stats/dockerfile_stats
             tags: ${{ steps.meta.outputs.tags }}
             labels: ${{ steps.meta.outputs.labels }}

chatsky/__init__.py

@@ -13,4 +13,8 @@
 from chatsky.pipeline import Pipeline
 from chatsky.script import Context, Script
 
+from chatsky.msg import *
+
+Script.model_rebuild()
+
 import chatsky.__rebuild_pydantic_models__

chatsky/cnd.py

@@ -0,0 +1 @@
+from chatsky.script.conditions import *

chatsky/lbl.py

@@ -0,0 +1 @@
+from chatsky.script.labels import *

chatsky/messengers/common/interface.py

@@ -9,9 +9,10 @@
 import abc
 import asyncio
 import logging
+import uuid
 from pathlib import Path
 from tempfile import gettempdir
-from typing import Optional, Any, List, Tuple, Hashable, TYPE_CHECKING, Type
+from typing import Optional, Any, List, Tuple, TextIO, Hashable, TYPE_CHECKING, Type
 
 if TYPE_CHECKING:
     from chatsky.script import Context, Message
@@ -192,3 +193,43 @@ def on_request(
         This method has the same signature as :py:class:`~chatsky.pipeline.types.PipelineRunnerFunction`.
         """
         return asyncio.run(self.on_request_async(request, ctx_id, update_ctx_misc))
+
+
+class CLIMessengerInterface(PollingMessengerInterface):
+    """
+    Command line message interface is the default message interface, communicating with user via `STDIN/STDOUT`.
+    This message interface can maintain dialog with one user at a time only.
+    """
+
+    def __init__(
+        self,
+        intro: Optional[str] = None,
+        prompt_request: str = "request: ",
+        prompt_response: str = "response: ",
+        out_descriptor: Optional[TextIO] = None,
+    ):
+        super().__init__()
+        self._ctx_id: Optional[Hashable] = None
+        self._intro: Optional[str] = intro
+        self._prompt_request: str = prompt_request
+        self._prompt_response: str = prompt_response
+        self._descriptor: Optional[TextIO] = out_descriptor
+
+    def _request(self) -> List[Tuple[Message, Any]]:
+        return [(Message(input(self._prompt_request)), self._ctx_id)]
+
+    def _respond(self, responses: List[Context]):
+        print(f"{self._prompt_response}{responses[0].last_response.text}; attachments: {responses[0].last_response.attachments}", file=self._descriptor)
+
+    async def connect(self, pipeline_runner: PipelineRunnerFunction, **kwargs):
+        """
+        The CLIProvider generates new dialog id used to user identification on each `connect` call.
+
+        :param pipeline_runner: A function that should process user request and return context;
+            usually it's a :py:meth:`~chatsky.pipeline.pipeline.pipeline.Pipeline._run_pipeline` function.
+        :param \\**kwargs: argument, added for compatibility with super class, it shouldn't be used normally.
+        """
+        self._ctx_id = uuid.uuid4()
+        if self._intro is not None:
+            print(self._intro)
+        await super().connect(pipeline_runner, **kwargs)

chatsky/messengers/http_interface.py

@@ -0,0 +1,30 @@
+import uvicorn
+from fastapi import FastAPI
+from pydantic import BaseModel
+
+from chatsky.messengers.common import MessengerInterface
+from chatsky.script import Message
+
+
+class HTTPMessengerInterface(MessengerInterface):
+    async def connect(self, pipeline_runner):
+        app = FastAPI()
+
+        class Output(BaseModel):
+            user_id: str
+            response: Message
+
+        @app.post("/chat", response_model=Output)
+        async def respond(
+            user_id: str,
+            user_message: str,  # TODO: change type to Message after core rework is done
+        ):
+            message = Message(text=user_message)
+            context = await pipeline_runner(message)
+            return {"user_id": user_id, "response": context.last_response}
+
+        uvicorn.run(
+            app,
+            host="0.0.0.0",
+            port=8020,
+        )

chatsky/msg.py

@@ -0,0 +1,14 @@
+from chatsky.script.core.message import (
+    Location,
+    Attachment,
+    Audio,
+    Video,
+    Image,
+    Document,
+    # Attachments,
+    # Link,
+    # Button,
+    # Keyboard,
+    Message,
+    # MultiMessage
+)

chatsky/pipeline/pipeline/pipeline.py

@@ -17,6 +17,7 @@
 import asyncio
 import logging
 from typing import Union, List, Dict, Optional, Hashable, Callable
+from collections import defaultdict
 
 from chatsky.context_storages import DBContextStorage
 from chatsky.script import Script, Context, ActorStage
@@ -25,7 +26,7 @@
 
 from chatsky.messengers.console import CLIMessengerInterface
 from chatsky.messengers.common import MessengerInterface
-from chatsky.slots.slots import GroupSlot
+from chatsky.slots.slots import GroupSlot, RegexpSlot, FunctionSlot
 from ..service.group import ServiceGroup
 from ..types import (
     ServiceBuilder,
@@ -37,6 +38,7 @@
 )
 from .utils import finalize_service_group, pretty_format_component_info_dict
 from chatsky.pipeline.pipeline.actor import Actor
+from chatsky.pipeline.pipeline.script_parsing import JSONImporter, Path
 
 logger = logging.getLogger(__name__)
 
@@ -271,6 +273,44 @@ def from_script(
             components=[*pre_services, ACTOR, *post_services],
         )
 
+    @classmethod
+    def from_file(
+        cls,
+        file: Union[str, Path],
+        # validation_stage: Optional[bool] = None,
+        condition_handler: Optional[Callable] = None,
+        # verbose: bool = True,
+        parallelize_processing: bool = False,
+        handlers: Optional[Dict[ActorStage, List[Callable]]] = None,
+        context_storage: Optional[Union[DBContextStorage, Dict]] = None,
+        messenger_interface: Optional[MessengerInterface] = None,
+        pre_services: Optional[List[Union[ServiceBuilder, ServiceGroupBuilder]]] = None,
+        post_services: Optional[List[Union[ServiceBuilder, ServiceGroupBuilder]]] = None,
+    ):
+        pre_services = [] if pre_services is None else pre_services
+        post_services = [] if post_services is None else post_services
+        script = JSONImporter(file).import_script()
+
+        def to_tuple(i):
+            if isinstance(i, list):
+                return tuple(i)
+            return i
+
+        config = JSONImporter(file).replace_script_objects(script["CONFIG"])
+        params = {param: to_tuple(script["CONFIG"].get(param)) for param in config.keys() if param != "custom_dir"}
+        del script["CONFIG"]  # todo: add support for CONFIG
+
+        return cls(
+            script=script,
+            **params,
+            condition_handler=condition_handler,
+            parallelize_processing=parallelize_processing,
+            handlers=handlers,
+            messenger_interface=messenger_interface,
+            context_storage=context_storage,
+            components=[*pre_services, ACTOR, *post_services],
+        )
+
     def set_actor(
         self,
         script: Union[Script, Dict],