Rename dirs to match module names

Signed-off-by: Miguel A. Cabrera Minagorri <devgorri@gmail.com>

README.md

@@ -42,6 +42,8 @@ Test the installation with:
 pipeless --help
 ```
 
+> NOTE: you may need to reload your shell for the new command to be available
+
 ## Getting Started 🚀
 
 We recommend reading the getting starting guide, however, you can also go directly to the (examples)[examples] directory.

cli/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "pipeless-ai-cli"
-version = "0.1.2"
+version = "0.1.3"
 description = "Pipeless is a framework to build and deploy multimodal perception apps in minutes without worrying about multimedia pipelines"
 authors = ["Miguel Angel Cabrera Minagorri <devgorri@gmail.com>"]
 license = "Apache-2.0"
@@ -9,7 +9,6 @@ homepage = "https://pipeless.ai"
 repository = "https://github.com/miguelaeh/pipeless"
 documentation = "https://github.com/miguelaeh/pipeless"
 keywords = ["multimedia", "framework", "artificial-intelligence", "pipeline", "developer-tools"]
-packages = [{include = "src/cli"}]
 
 [tool.poetry.dependencies]
 python = "^3.10"
@@ -22,4 +21,4 @@ requires = ["poetry-core"]
 build-backend = "poetry.core.masonry.api"
 
 [tool.poetry.scripts]
-pipeless = "src.cli.main:app"
+pipeless = "pipeless_ai_cli.main:app"

cli/src/cli/commands/run.py → cli/src/pipeless_ai_cli/commands/run.py

@@ -2,7 +2,7 @@
 import yaml
 import os
 import importlib.util
-from pipeless.pipeless import Pipeless
+from pipeless_ai.core import Pipeless
 
 def run_app(component: str):
     """

cli/src/cli/commands/templates/default/app.py → cli/src/pipeless_ai_cli/commands/templates/default/app.py

@@ -1,4 +1,4 @@
-from pipeless.lib.app.app import PipelessApp
+from pipeless_ai.lib.app.app import PipelessApp
 
 class App(PipelessApp):
     """

core/pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "pipeless-ai"
-version = "0.1.0"
+version = "0.1.1"
 description = "A framework to build and deploy multimodal perception apps in minutes without worrying about multimedia pipelines"
 authors = ["Miguel Angel Cabrera Minagorri <devgorri@gmail.com>"]
 license = "Apache-2.0"
@@ -9,7 +9,6 @@ homepage = "https://pipeless.ai"
 repository = "https://github.com/miguelaeh/pipeless"
 documentation = "https://github.com/miguelaeh/pipeless"
 keywords = ["multimedia", "framework", "artificial-intelligence", "pipeline", "developer-tools"]
-packages = [{include = "src/pipeless"}]
 
 [tool.poetry.dependencies]
 python = "^3.10"

core/src/pipeless/pipeless.py → core/src/pipeless_ai/core.py

@@ -2,11 +2,11 @@
 import sys
 import time
 
-from pipeless.lib.input import input
-from pipeless.lib.output import output
-from pipeless.lib.worker import worker
-from pipeless.lib.logger import logger, update_logger_level
-from pipeless.lib.config import Config
+from pipeless_ai.lib.input import input
+from pipeless_ai.lib.output import output
+from pipeless_ai.lib.worker import worker
+from pipeless_ai.lib.logger import logger, update_logger_level
+from pipeless_ai.lib.config import Config
 
 def run_all(user_app_class):
     executor = concurrent.futures.ProcessPoolExecutor()

core/src/pipeless/lib/app/app.py → core/src/pipeless_ai/lib/app/app.py

@@ -1,4 +1,4 @@
-from pipeless.lib.timer import timer
+from pipeless_ai.lib.timer import timer
 
 class PipelessApp():
     """

core/src/pipeless/lib/config.py → core/src/pipeless_ai/lib/config.py

@@ -1,8 +1,8 @@
 import os
 import sys
 
-from pipeless.lib.singleton import Singleton
-from pipeless.lib.logger import logger
+from pipeless_ai.lib.singleton import Singleton
+from pipeless_ai.lib.logger import logger
 
 ENV_PREFIX = 'PIPELESS'
 

core/src/pipeless/lib/connection.py → core/src/pipeless_ai/lib/connection.py

@@ -5,9 +5,9 @@
 from pynng import Push0, Pull0, Timeout, Pair0
 from pynng.exceptions import Closed as ClosedException, TryAgain, ConnectionRefused
 
-from pipeless.lib.singleton import Singleton
-from pipeless.lib.config import Config
-from pipeless.lib.logger import logger
+from pipeless_ai.lib.singleton import Singleton
+from pipeless_ai.lib.config import Config
+from pipeless_ai.lib.logger import logger
 
 # Handle SIGNINT (ctrl+c) during sockets dialing blocking process
 def exit(signum, frame):

core/src/pipeless/lib/input/input.py → core/src/pipeless_ai/lib/input/input.py

@@ -9,10 +9,10 @@
 gi.require_version('GstApp', '1.0')
 from gi.repository import Gst, GObject, GstApp, GLib
 
-from pipeless.lib.logger import logger
-from pipeless.lib.connection import InputOutputSocket, InputPushSocket
-from pipeless.lib.config import Config
-from pipeless.lib.messages import EndOfStreamMsg, RgbImageMsg, StreamCapsMsg, StreamTagsMsg
+from pipeless_ai.lib.logger import logger
+from pipeless_ai.lib.connection import InputOutputSocket, InputPushSocket
+from pipeless_ai.lib.config import Config
+from pipeless_ai.lib.messages import EndOfStreamMsg, RgbImageMsg, StreamCapsMsg, StreamTagsMsg
 
 def on_new_sample(sink: GstApp.AppSink) -> Gst.FlowReturn:
     sample = sink.pull_sample()

core/src/pipeless/lib/messages.py → core/src/pipeless_ai/lib/messages.py

@@ -2,7 +2,7 @@
 from enum import Enum
 import numpy as np
 
-from pipeless.lib.logger import logger
+from pipeless_ai.lib.logger import logger
 
 class MsgType(Enum):
     CAPABILITIES = 1

core/src/pipeless/lib/output/output.py → core/src/pipeless_ai/lib/output/output.py

@@ -8,10 +8,10 @@
 gi.require_version('GstPbutils', '1.0')
 from gi.repository import Gst, GstApp, GLib, GstPbutils
 
-from pipeless.lib.connection import InputOutputSocket, OutputPullSocket
-from pipeless.lib.logger import logger
-from pipeless.lib.messages import EndOfStreamMsg, StreamCapsMsg, StreamTagsMsg, deserialize, RgbImageMsg
-from pipeless.lib.config import Config
+from pipeless_ai.lib.connection import InputOutputSocket, OutputPullSocket
+from pipeless_ai.lib.logger import logger
+from pipeless_ai.lib.messages import EndOfStreamMsg, StreamCapsMsg, StreamTagsMsg, deserialize, RgbImageMsg
+from pipeless_ai.lib.config import Config
 
 def fetch_and_send(appsrc: GstApp.AppSrc, copy_timestamps: bool):
     # TODO: we may need to use the 'need-data' and 'enough-data' signals to avoid overflowing the appsrc input queue

core/src/pipeless/lib/timer.py → core/src/pipeless_ai/lib/timer.py

@@ -1,6 +1,6 @@
 from functools import wraps
 import time
-from pipeless.lib.logger import logger
+from pipeless_ai.lib.logger import logger
 
 def timer(func):
     """

core/src/pipeless/lib/worker/worker.py → core/src/pipeless_ai/lib/worker/worker.py

@@ -3,9 +3,9 @@
 import traceback
 import numpy as np
 
-from pipeless.lib.connection import InputPullSocket, OutputPushSocket
-from pipeless.lib.logger import logger
-from pipeless.lib.messages import EndOfStreamMsg, RgbImageMsg, deserialize
+from pipeless_ai.lib.connection import InputPullSocket, OutputPushSocket
+from pipeless_ai.lib.logger import logger
+from pipeless_ai.lib.messages import EndOfStreamMsg, RgbImageMsg, deserialize
 
 def fetch_and_process(user_app):
     """

examples/cats/app.py

@@ -1,5 +1,5 @@
-from pipeless.lib.app.app import PipelessApp
-from pipeless.lib.logger import logger
+from pipeless_ai.lib.app.app import PipelessApp
+from pipeless_ai.lib.logger import logger
 import cv2
 
 class App(PipelessApp):