Pin all the things

.flake8

@@ -0,0 +1,17 @@
+[flake8]
+enable-extensions = G
+max-doc-length = 90
+max-line-length = 90
+select = A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q,R,S,T,U,V,W,X,Y,Z,B901,B902,B903,B950
+# E226: Missing whitespace around arithmetic operators can help group things together.
+# E501: Superseeded by B950 (from Bugbear)
+# E722: Superseeded by B001 (from Bugbear)
+# W503: Mutually exclusive with W504.
+# Q000: TODO: Code needs reformatting.
+ignore = E226,E501,E722,W503,Q000
+per-file-ignores =
+    # S101: Pytest uses assert
+    tests/*:S101
+
+# flake8-quotes
+inline-quotes = "

.github/workflows/ci.yml

@@ -18,14 +18,11 @@ jobs:
     - name: Checkout
       uses: actions/checkout@v2.3.4
     - name: Set up Python
-      uses: actions/setup-python@v2
+      uses: actions/setup-python@v4
       with:
         python-version: 3.9
-    - name: Cache pip
-      uses: actions/cache@v2.1.6
-      with:
-        path: ~/.cache/pip
-        key: ${{ hashFiles('**/setup.py') }}-${{ hashFiles('**/requirements*.txt') }}
+        cache: 'pip'
+        cache-dependency-path: '**/requirements*.txt'
     - name: Install dependencies
       run: |
         make install
@@ -68,14 +65,11 @@ jobs:
     - name: Checkout
       uses: actions/checkout@v2
     - name: Set up Python
-      uses: actions/setup-python@v2
+      uses: actions/setup-python@v4
       with:
         python-version: 3.9
-    - name: Cache pip
-      uses: actions/cache@v2.1.6
-      with:
-        path: ~/.cache/pip
-        key: ${{ hashFiles('**/setup.py') }}-${{ hashFiles('**/requirements*.txt') }}
+        cache: 'pip'
+        cache-dependency-path: '**/requirements*.txt'
     - name: Install dependencies
       run: |
         make install
@@ -89,11 +83,6 @@ jobs:
     steps:
     - name: Checkout
       uses: actions/checkout@v2
-    - name: Cache pip
-      uses: actions/cache@v2.1.6
-      with:
-        path: ~/.cache/pip
-        key: ${{ hashFiles('**/setup.py') }}-${{ hashFiles('**/requirements*.txt') }}
     - name: Install sphinx
       run: pip install sphinx
     - name: Documentation

Makefile

@@ -6,11 +6,15 @@ lint:
 	@flake8 demos
 
 test:
-	@pytest -q demos/polls/tests
-	@pytest -q demos/chat/tests
-	@pytest -q demos/blog/tests
-	@pytest -q demos/graphql-demo
-	@SLACK_BOT_TOKEN=xxx GIPHY_API_KEY=xxx pytest -q demos/moderator_bot/tests
+	@pytest demos/blog
+	@pytest demos/chat
+	@pytest demos/graphql-demo
+	@pytest demos/imagetagger
+	@pytest demos/moderator
+	@SLACK_BOT_TOKEN=xxx GIPHY_API_KEY=xxx pytest demos/moderator_bot/tests
+	@pytest demos/motortwit
+	@pytest demos/polls
+	@pytest demos/shortify
 
 ci: lint test doc-spelling
 
@@ -23,11 +27,15 @@ doc-spelling:
 
 install:
 	@pip install -U pip setuptools cython
-	@pip install -Ur requirements-dev.txt
-	@pip install demos/polls
-	@pip install demos/chat
-	@pip install demos/blog
-	@pip install demos/graphql-demo
+	@pip install -r requirements-dev.txt
+	@pip install -r demos/blog/requirements.txt
+	@pip install -r demos/chat/requirements.txt
+	@pip install -r demos/graphql-demo/requirements-dev.txt
+	@pip install -r demos/imagetagger/requirements.txt
+	@pip install -r demos/moderator/requirements-dev.txt
 	@pip install -r demos/moderator_bot/requirements-dev.txt
+	@pip install -r demos/motortwit/requirements.txt
+	@pip install -r demos/polls/requirements-dev.txt
+	@pip install -r demos/shortify/requirements.txt
 
 .PHONY: clean doc

demos/blog/pytest.ini

@@ -1,4 +1,4 @@
-[tool:pytest]
+[pytest]
 addopts =
     # show 10 slowest invocations:
     --durations=10
@@ -11,6 +11,7 @@ addopts =
 
     # show values of the local vars in errors:
     --showlocals
+asyncio_mode = auto
 filterwarnings =
     error
 testpaths = tests/

demos/blog/requirements.txt

@@ -1,6 +1,15 @@
--e .
+aiohttp==3.8.3
+aiohttp-jinja2==1.5
+aiohttp_security[session]==0.4.0
+asyncpg==0.27.0
+asyncpgsa==0.27.1
+bcrypt==4.0.1
+pytoml==0.1.21
+redis==4.3.4
+sqlalchemy==1.4.42
 
 # testing
-pytest
-pytest-aiohttp
-flake8
+pytest==7.2.0
+pytest-aiohttp==1.0.4
+pytest-asyncio==0.20.1
+flake8==3.9.2

demos/blog/setup.py

@@ -7,7 +7,7 @@
     'bcrypt',
     'pytoml',
     'aiohttp_security[session]',
-    'redis==4.3.4',
+    'redis>=4.2',
     'sqlalchemy',
     'asyncpg',
     'asyncpgsa',

demos/chat/pytest.ini

@@ -11,6 +11,7 @@ addopts =
 
     # show values of the local vars in errors:
     --showlocals
+asyncio_mode = auto
 filterwarnings =
     error
 testpaths = tests/

demos/chat/requirements.txt

@@ -0,0 +1,3 @@
+aiohttp==3.8.3
+aiohttp-jinja2==1.5
+faker==15.1.1

demos/graphql-demo/graph/api/contrib.py

@@ -7,7 +7,7 @@
 )
 
 
-GQPHIQL_TEMPLATE = '''
+GQPHIQL_TEMPLATE = """
 <!DOCTYPE html>
 <html>
 <head>
@@ -140,7 +140,7 @@
   </script>
 </body>
 </html>
-'''
+"""
 
 
 def simple_renderer(template, **values):

demos/graphql-demo/graph/api/dataloaders.py

@@ -10,21 +10,18 @@
 
 
 class BaseAIODataLoader(DataLoader):
-    '''
-    The base data loader for aiohttp. It need create when application
-    initialization with current db engine.
-    '''
+    """The base data loader for aiohttp.
+
+    It need create when application initialization with current db engine.
+    """
     engine: Any = None
 
     def __init__(self, engine, *args, **kwargs):
         super().__init__(*args, **kwargs)
         self.engine = engine
 
     def sorted_by_keys(self, items: RowsProxy, keys: List[int]) -> RowsProxy:
-        '''
-        In `aiodataloader` ordering of returning items is very inportant and
-        this function halp to do it.
-        '''
+        """Help ordering of returned items In `aiodataloader`."""
         items_dict = {
             key: value for key, value in zip(sorted(set(keys)), items)
         }
@@ -33,10 +30,10 @@ def sorted_by_keys(self, items: RowsProxy, keys: List[int]) -> RowsProxy:
 
 
 class UserDataLoader(BaseAIODataLoader):
-    '''
-    A simple user data loader. U should use it everywhere, when you think that
-    it is possible problem N + 1 requests.
-    '''
+    """Simple user data loader.
+
+    Should be used everywhere, when it is possible problem N + 1 requests.
+    """
     async def batch_load_fn(self, keys: List[int]) -> RowsProxy:
         async with self.engine.acquire() as conn:
             response = await select_users(conn, keys)

demos/graphql-demo/graph/api/models/room.py

@@ -12,9 +12,7 @@
 
 
 class Message(graphene.ObjectType):
-    '''
-    A messages is main object that representation data of user message.
-    '''
+    """Main object that representation data of user message."""
     id = graphene.Int(
         description="An id of message, it's unique for all message",
     )
@@ -37,9 +35,7 @@ async def resolve_owner(self, info: ResolveInfo) -> List[RowProxy]:
 
 
 class Room(graphene.ObjectType):
-    '''
-    A room is point where users can have conversations.
-    '''
+    """Point where users can have conversations."""
     id = graphene.Int(
         description="An id of room, it's unique for all rooms",
     )

demos/graphql-demo/graph/api/models/user.py

@@ -5,10 +5,7 @@
 
 
 class User(graphene.ObjectType):
-    '''
-    A user is an individual's account on current api that can have
-    conversations.
-    '''
+    """Individual's account on current api that can have conversations."""
     id = graphene.Int(
         description='A id of user',
     )

demos/graphql-demo/graph/api/mutations/__init__.py

@@ -8,9 +8,7 @@
 
 
 class Mutation(graphene.ObjectType):
-    '''
-    The main GraphQL mutation point.
-    '''
+    """Main GraphQL mutation point."""
 
     add_message = AddMessageMutation.Field()
     remove_message = RemoveMessageMutation.Field()

demos/graphql-demo/graph/api/mutations/messages.py

@@ -15,9 +15,7 @@
 
 
 class AddMessageMutation(graphene.Mutation):
-    '''
-    Gives interface for create new messages.
-    '''
+    """Provide interface for create new messages."""
 
     class Arguments:
         room_id = graphene.Int()
@@ -46,9 +44,7 @@ async def mutate(self, info, room_id: int, owner_id: int, body: str):
 
 
 class RemoveMessageMutation(graphene.Mutation):
-    '''
-    Gives interface for create new message by id.
-    '''
+    """Provide interface for create new message by id."""
 
     class Arguments:
         id = graphene.Int()
@@ -65,9 +61,7 @@ async def mutate(self, info, id: int):
 
 
 class StartTypingMessageMutation(graphene.Mutation):
-    '''
-    Gives interface for set info about start typing new message.
-    '''
+    """Provide interface for set info about start typing new message."""
 
     class Arguments:
         room_id = graphene.Int()

demos/graphql-demo/graph/api/queries/__init__.py

@@ -3,6 +3,4 @@
 
 
 class Query(UserQuery, RoomsQuery):
-    '''
-    The main GraphQL query point.
-    '''
+    """Main GraphQL query point."""

demos/graphql-demo/graph/api/subscriptions/__init__.py

@@ -2,6 +2,4 @@
 
 
 class Subscription(MessageSubscription):
-    '''
-    The main GraphQL subscription point.
-    '''
+    """Main GraphQL subscription point."""

demos/graphql-demo/graph/api/subscriptions/messages.py

@@ -8,17 +8,13 @@
 
 
 class RandomType(graphene.ObjectType):
-    '''
-    Random type. Need for test.
-    '''
+    """Random type. Need for test."""
     seconds = graphene.Int()
     random_int = graphene.Int()
 
 
 class MessageAdded(graphene.ObjectType):
-    '''
-    The simple type for representation message response in subscription.
-    '''
+    """The simple type for representation message response in subscription."""
     id = graphene.Int(
         description='The id of message'
     )
@@ -32,10 +28,9 @@ class MessageAdded(graphene.ObjectType):
 
 
 class StartTyping(graphene.ObjectType):
-    '''
-    The simple type for representation info connected with starting of typing
+    """Simple type for representing info connected with starting of typing
     new message by some user.
-    '''
+    """
 
     user = graphene.Field(
         User,
@@ -44,9 +39,7 @@ class StartTyping(graphene.ObjectType):
 
 
 class MessageSubscription(graphene.ObjectType):
-    '''
-    Subscriptions for all actions connected with messages.
-    '''
+    """Subscriptions for all actions connected with messages."""
     random_int = graphene.Field(RandomType)
     typing_start = graphene.Field(
         StartTyping,