os.getenv replaced with os.environ

.github/workflows/build_and_publish_docs.yml

@@ -39,6 +39,11 @@ jobs:
             make venv
 
       - name: build documentation
+        env:
+          TG_BOT_TOKEN: ${{ secrets.TG_BOT_TOKEN }}
+          TG_API_ID: ${{ secrets.TG_API_ID }}
+          TG_API_HASH: ${{ secrets.TG_API_HASH }}
+          TG_BOT_USERNAME: ${{ secrets.TG_BOT_USERNAME }}
         run: |
             make doc
 

.github/workflows/test_coverage.yml

@@ -50,5 +50,10 @@ jobs:
           touch venv  # disable venv target
 
       - name: run tests
+        env:
+          TG_BOT_TOKEN: ${{ secrets.TG_BOT_TOKEN }}
+          TG_API_ID: ${{ secrets.TG_API_ID }}
+          TG_API_HASH: ${{ secrets.TG_API_HASH }}
+          TG_BOT_USERNAME: ${{ secrets.TG_BOT_USERNAME }}
         run: |
           make test TEST_ALLOW_SKIP=telegram

.github/workflows/test_full.yml

@@ -43,6 +43,11 @@ jobs:
         shell: bash
 
       - name: run pytest
+        env:
+          TG_BOT_TOKEN: ${{ secrets.TG_BOT_TOKEN }}
+          TG_API_ID: ${{ secrets.TG_API_ID }}
+          TG_API_HASH: ${{ secrets.TG_API_HASH }}
+          TG_BOT_USERNAME: ${{ secrets.TG_BOT_USERNAME }}
         run: |
           if [ "$RUNNER_OS" == "Linux" ]; then
               source <(cat .env_file | sed 's/=/=/' | sed 's/^/export /')
@@ -72,6 +77,11 @@ jobs:
         shell: bash
 
       - name: run pytest
+        env:
+          TG_BOT_TOKEN: ${{ secrets.TG_BOT_TOKEN }}
+          TG_API_ID: ${{ secrets.TG_API_ID }}
+          TG_API_HASH: ${{ secrets.TG_API_HASH }}
+          TG_BOT_USERNAME: ${{ secrets.TG_BOT_USERNAME }}
         run: |
           source <(cat .env_file | sed 's/=/=/' | sed 's/^/export /')
           pytest --tb=long -vv --cache-clear --no-cov --allow-skip=all tests/

tests/context_storages/test_dbs.py

@@ -121,42 +121,42 @@ def test_pickle(testing_file, testing_context, context_id):
     asyncio.run(delete_pickle(db))
 
 
+@pytest.mark.docker
 @pytest.mark.skipif(not MONGO_ACTIVE, reason="Mongodb server is not running")
 @pytest.mark.skipif(not mongo_available, reason="Mongodb dependencies missing")
-@pytest.mark.docker
 def test_mongo(testing_context, context_id):
     if system() == "Windows":
         pytest.skip()
 
     db = context_storage_factory(
         "mongodb://{}:{}@localhost:27017/{}".format(
-            os.getenv("MONGO_INITDB_ROOT_USERNAME"),
-            os.getenv("MONGO_INITDB_ROOT_PASSWORD"),
-            os.getenv("MONGO_INITDB_ROOT_USERNAME"),
+            os.environ["MONGO_INITDB_ROOT_USERNAME"],
+            os.environ["MONGO_INITDB_ROOT_PASSWORD"],
+            os.environ["MONGO_INITDB_ROOT_USERNAME"],
         )
     )
     generic_test(db, testing_context, context_id)
     asyncio.run(delete_mongo(db))
 
 
+@pytest.mark.docker
 @pytest.mark.skipif(not REDIS_ACTIVE, reason="Redis server is not running")
 @pytest.mark.skipif(not redis_available, reason="Redis dependencies missing")
-@pytest.mark.docker
 def test_redis(testing_context, context_id):
-    db = context_storage_factory("redis://{}:{}@localhost:6379/{}".format("", os.getenv("REDIS_PASSWORD"), "0"))
+    db = context_storage_factory("redis://{}:{}@localhost:6379/{}".format("", os.environ["REDIS_PASSWORD"], "0"))
     generic_test(db, testing_context, context_id)
     asyncio.run(delete_redis(db))
 
 
+@pytest.mark.docker
 @pytest.mark.skipif(not POSTGRES_ACTIVE, reason="Postgres server is not running")
 @pytest.mark.skipif(not postgres_available, reason="Postgres dependencies missing")
-@pytest.mark.docker
 def test_postgres(testing_context, context_id):
     db = context_storage_factory(
         "postgresql+asyncpg://{}:{}@localhost:5432/{}".format(
-            os.getenv("POSTGRES_USERNAME"),
-            os.getenv("POSTGRES_PASSWORD"),
-            os.getenv("POSTGRES_DB"),
+            os.environ["POSTGRES_USERNAME"],
+            os.environ["POSTGRES_PASSWORD"],
+            os.environ["POSTGRES_DB"],
         )
     )
     generic_test(db, testing_context, context_id)
@@ -171,29 +171,29 @@ def test_sqlite(testing_file, testing_context, context_id):
     asyncio.run(delete_sql(db))
 
 
+@pytest.mark.docker
 @pytest.mark.skipif(not MYSQL_ACTIVE, reason="Mysql server is not running")
 @pytest.mark.skipif(not mysql_available, reason="Mysql dependencies missing")
-@pytest.mark.docker
 def test_mysql(testing_context, context_id):
     db = context_storage_factory(
         "mysql+asyncmy://{}:{}@localhost:3307/{}".format(
-            os.getenv("MYSQL_USERNAME"),
-            os.getenv("MYSQL_PASSWORD"),
-            os.getenv("MYSQL_DATABASE"),
+            os.environ["MYSQL_USERNAME"],
+            os.environ["MYSQL_PASSWORD"],
+            os.environ["MYSQL_DATABASE"],
         )
     )
     generic_test(db, testing_context, context_id)
     asyncio.run(delete_sql(db))
 
 
+@pytest.mark.docker
 @pytest.mark.skipif(not YDB_ACTIVE, reason="YQL server not running")
 @pytest.mark.skipif(not ydb_available, reason="YDB dependencies missing")
-@pytest.mark.docker
 def test_ydb(testing_context, context_id):
     db = context_storage_factory(
         "{}{}".format(
-            os.getenv("YDB_ENDPOINT"),
-            os.getenv("YDB_DATABASE"),
+            os.environ["YDB_ENDPOINT"],
+            os.environ["YDB_DATABASE"],
         ),
         table_name="test",
     )

tests/messengers/telegram/test_tutorials.py

@@ -27,7 +27,9 @@
         "3_buttons_with_callback",
     ],
 )
-def test_client_tutorials_without_telegram(tutorial_module_name):
+@pytest.mark.telegram
+def test_client_tutorials_without_telegram(tutorial_module_name, env_vars):
+    assert "TG_BOT_TOKEN" in env_vars
     tutorial_module = importlib.import_module(f"tutorials.{dot_path_to_addon}.{tutorial_module_name}")
     pipeline = tutorial_module.pipeline
     happy_path = tutorial_module.happy_path

tutorials/context_storages/2_postgresql.py

@@ -23,9 +23,9 @@
 
 # %%
 db_uri = "postgresql+asyncpg://{}:{}@localhost:5432/{}".format(
-    os.getenv("POSTGRES_USERNAME"),
-    os.getenv("POSTGRES_PASSWORD"),
-    os.getenv("POSTGRES_DB"),
+    os.environ["POSTGRES_USERNAME"],
+    os.environ["POSTGRES_PASSWORD"],
+    os.environ["POSTGRES_DB"],
 )
 db = context_storage_factory(db_uri)
 

tutorials/context_storages/3_mongodb.py

@@ -23,9 +23,9 @@
 
 # %%
 db_uri = "mongodb://{}:{}@localhost:27017/{}".format(
-    os.getenv("MONGO_INITDB_ROOT_USERNAME"),
-    os.getenv("MONGO_INITDB_ROOT_PASSWORD"),
-    os.getenv("MONGO_INITDB_ROOT_USERNAME"),
+    os.environ["MONGO_INITDB_ROOT_USERNAME"],
+    os.environ["MONGO_INITDB_ROOT_PASSWORD"],
+    os.environ["MONGO_INITDB_ROOT_USERNAME"],
 )
 db = context_storage_factory(db_uri)
 

tutorials/context_storages/4_redis.py

@@ -22,7 +22,7 @@
 
 
 # %%
-db_uri = "redis://{}:{}@localhost:6379/{}".format("", os.getenv("REDIS_PASSWORD"), "0")
+db_uri = "redis://{}:{}@localhost:6379/{}".format("", os.environ["REDIS_PASSWORD"], "0")
 db = context_storage_factory(db_uri)
 
 

tutorials/context_storages/5_mysql.py

@@ -23,9 +23,9 @@
 
 # %%
 db_uri = "mysql+asyncmy://{}:{}@localhost:3307/{}".format(
-    os.getenv("MYSQL_USERNAME"),
-    os.getenv("MYSQL_PASSWORD"),
-    os.getenv("MYSQL_DATABASE"),
+    os.environ["MYSQL_USERNAME"],
+    os.environ["MYSQL_PASSWORD"],
+    os.environ["MYSQL_DATABASE"],
 )
 db = context_storage_factory(db_uri)
 

tutorials/context_storages/7_yandex_database.py

@@ -31,8 +31,8 @@
 # db_uri="grpc://localhost:2136/local"
 
 db_uri = "{}{}".format(
-    os.getenv("YDB_ENDPOINT"),
-    os.getenv("YDB_DATABASE"),
+    os.environ["YDB_ENDPOINT"],
+    os.environ["YDB_DATABASE"],
 )
 db = context_storage_factory(db_uri)
 

tutorials/messengers/telegram/1_basic.py

@@ -60,7 +60,7 @@
 
 
 # %%
-interface = PollingTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = PollingTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 
 # %%
@@ -73,8 +73,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/2_buttons.py

@@ -90,7 +90,7 @@
     },
 }
 
-interface = PollingTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = PollingTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 # this variable is only for testing
 happy_path = (
@@ -158,8 +158,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/3_buttons_with_callback.py

@@ -138,7 +138,7 @@
     ),
 )
 
-interface = PollingTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = PollingTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 
 # %%
@@ -151,8 +151,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/4_conditions.py

@@ -102,7 +102,7 @@
 
 
 # %%
-interface = PollingTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = PollingTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 
 # %%
@@ -115,8 +115,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/5_conditions_with_media.py

@@ -41,7 +41,7 @@
 
 
 # %%
-interface = PollingTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = PollingTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 
 # %%
@@ -167,8 +167,6 @@ def extract_data(ctx: Context, _: Pipeline):  # A function to extract data with
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/6_conditions_extras.py

@@ -93,7 +93,7 @@
 
 
 # %%
-interface = PollingTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = PollingTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 
 # %%
@@ -106,8 +106,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/7_polling_setup.py

@@ -33,7 +33,7 @@
 
 # %%
 interface = PollingTelegramInterface(
-    token=os.getenv("TG_BOT_TOKEN", ""),
+    token=os.environ["TG_BOT_TOKEN"],
     interval=2,
     allowed_updates=update_types,
     timeout=30,
@@ -53,8 +53,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()
 
 

tutorials/messengers/telegram/8_webhook_setup.py

@@ -35,7 +35,7 @@
 
 
 # %%
-interface = CallbackTelegramInterface(token=os.getenv("TG_BOT_TOKEN", ""))
+interface = CallbackTelegramInterface(token=os.environ["TG_BOT_TOKEN"])
 
 
 # %%
@@ -49,8 +49,6 @@
 
 
 def main():
-    if not os.getenv("TG_BOT_TOKEN"):
-        print("`TG_BOT_TOKEN` variable needs to be set to use TelegramInterface.")
     pipeline.run()