Added Makefile and fixed linting issues.

Author: johnbywater

Makefile

@@ -0,0 +1,71 @@
+.EXPORT_ALL_VARIABLES:
+
+POETRY_VERSION = 1.6.1
+POETRY ?= poetry
+
+POETRY_INSTALLER_URL ?= https://install.python-poetry.org
+
+-include $(DOTENV_BASE_FILE)
+-include $(DOTENV_LOCAL_FILE)
+
+.PHONY: install-poetry
+install-poetry:
+	curl -sSL $(POETRY_INSTALLER_URL) | python3
+	$(POETRY) --version
+
+.PHONY: install-packages
+install-packages:
+	$(POETRY) install -vv $(opts)
+
+.PHONY: lock-packages
+lock-packages:
+	$(POETRY) lock -vv --no-update
+
+.PHONY: update-packages
+update-packages:
+	$(POETRY) update -vv
+
+.PHONY: lint-black
+lint-black:
+	$(POETRY) run black --check --diff .
+
+.PHONY: lint-flake8
+lint-flake8:
+	$(POETRY) run flake8
+
+.PHONY: lint-isort
+lint-isort:
+	$(POETRY) run isort --check-only --diff .
+
+.PHONY: lint-mypy
+lint-mypy:
+	$(POETRY) run mypy
+
+.PHONY: lint-python
+lint-python: lint-black lint-flake8 lint-isort lint-mypy
+
+.PHONY: lint
+lint: lint-python
+
+.PHONY: fmt-black
+fmt-black:
+	$(POETRY) run black .
+
+.PHONY: fmt-isort
+fmt-isort:
+	$(POETRY) run isort .
+
+.PHONY: fmt
+fmt: fmt-black fmt-isort
+
+.PHONY: test
+test:
+	$(POETRY) run python -m pytest $(opts) $(call tests,.)
+
+.PHONY: build
+build:
+	$(POETRY) build
+
+.PHONY: publish
+publish:
+	$(POETRY) publish

eventsourcing_dynamodb/factory.py

@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
 import boto3
 from eventsourcing.persistence import (
     AggregateRecorder,

eventsourcing_dynamodb/models.py

@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
 import time
 from dataclasses import dataclass
 

eventsourcing_dynamodb/recorders.py

@@ -1,3 +1,4 @@
+# -*- coding: utf-8 -*-
 import logging
 import time
 from typing import Any, List, Sequence
@@ -108,7 +109,9 @@ def _get_events_from_dynamo(
                 "Unable to access table %s in dynamo. %s"
                 % (self.dynamo_table_name, e.response.get("Error", {}).get("Message"))
             )
-            raise ValueError("Unable to access table %s" % (self.dynamo_table_name,))
+            raise ValueError(
+                "Unable to access table %s" % (self.dynamo_table_name,)
+            ) from e
 
 
 class DynamoApplicationRecorder(DynamoAggregateRecorder, ApplicationRecorder):

poetry.lock

@@ -1,11 +1,11 @@
-[project]
+[tool.poetry]
 name = "eventsourcing-dynamodb"
 version = "0.1.0"
 description = "Python package for eventsourcing with DynamoDB"
 authors = [
-    {name = "John Bywater",email = "john.bywater@appropriatesoftware.net"}
+    "John Bywater <john.bywater@appropriatesoftware.net>",
 ]
-license = {text = "BSD 3-Clause"}
+license = "BSD 3-Clause"
 classifiers = [
 #    "Development Status :: 3 - Alpha",
     "Development Status :: 4 - Beta",

pyproject.toml

@@ -1,11 +1,10 @@
+# -*- coding: utf-8 -*-
 import os
 from decimal import Decimal
-from itertools import chain
 from uuid import uuid4
 
 from eventsourcing.application import Application, EventSourcedLog
 from eventsourcing.domain import Aggregate, DomainEvent
-from eventsourcing.system import NotificationLogReader
 from eventsourcing.tests.application import (
     TIMEIT_FACTOR,
     BankAccounts,
@@ -52,8 +51,7 @@ def test_example_application(self) -> None:
         app = BankAccounts()
 
         # Check the factory topic.
-        self.assertEqual(get_topic(type(app.factory)),
-                         self.expected_factory_topic)
+        self.assertEqual(get_topic(type(app.factory)), self.expected_factory_topic)
 
         # Check AccountNotFound exception.
         with self.assertRaises(BankAccounts.AccountNotFoundError):

tests/test_application.py

@@ -15,7 +15,7 @@
 from eventsourcing_dynamodb.recorders import (
     DynamoAggregateRecorder,
     DynamoApplicationRecorder,
-    DynamoProcessRecorder
+    DynamoProcessRecorder,
 )