Enhances API routing and event processing

Improves API routing with authentication support.
Provides consistent event processing across AWS services.
Updates description and keywords to better reflect project goals.

Author: paulcruse3

README.md

@@ -84,14 +84,23 @@ pip install acai_aws
 # app.py (entry point for your Lambda)
 from acai_aws.apigateway.router import Router
 
+
+def authenticate(request, response, requirements):
+    if request.headers.get('x-api-key') != 'secret-key':
+        response.code = 401
+        response.set_error('auth', 'Unauthorized')
+
+
 router = Router(
     base_path='api/v1',
     handlers='handlers',            # directory mode
     schema='openapi.yml',           # optional OpenAPI document
     auto_validate=True,
     validate_response=True,
-    before_all=lambda request, response, _: request.context.update({'trace_id': request.headers.get('trace-id')})
+    with_auth=authenticate
 )
+router.auto_load()
+
 
 def handler(event, context):
     return router.route(event, context)
@@ -101,14 +110,8 @@ def handler(event, context):
 # handlers/users.py
 from acai_aws.apigateway.requirements import requirements
 
-def authenticate(request, response, _requirements):
-    if request.headers.get('x-api-key') != 'secret':
-        response.code = 401
-        response.set_error('auth', 'Unauthorized')
-
 @requirements(
     auth_required=True,
-    before=authenticate,
     required_body={
         'type': 'object',
         'required': ['email', 'name'],
@@ -179,31 +182,129 @@ pipenv run generate
 
 ## 🔄 Event Processing
 
-Acai AWS provides consistent event objects for AWS stream and queue services. Decorate your handler with `acai_aws.common.records.requirements.requirements` to auto-detect the source and normalize each record.
+Acai AWS provides consistent event objects for AWS stream and queue services. Decorate your handler with `acai_aws.common.records.requirements.requirements` to auto-detect the source and wrap records.
 
 ```python
 from acai_aws.dynamodb.requirements import requirements
 
+class ProductRecord:
+    def __init__(self, record):
+        self.id = record.body['id']
+        self.payload = record.body
+
 @requirements(
     operations=['created', 'updated'],
     timeout=10,
-    data_class=lambda record: record.body
+    data_class=ProductRecord
 )
-def handler(event):
-    for record in event.records:
-        process(record)  # record is dict from the stream, filtered and validated
-    return {'processed': len(event.records)}
+def handler(records):
+    for record in records.records:
+        process_product(record.id, record.payload)
+    return {'processed': len(records.records)}
 ```
 
 Supported services include:
 
-- **DynamoDB Streams** (`acai_aws.dynamodb.event.Event`)
-- **SQS** (`acai_aws.sqs.event.Event`)
-- **SNS** (`acai_aws.sns.event.Event`)
-- **S3** (optional `get_object` helper to pull objects)
-- **Kinesis**, **Firehose**, **MSK**, **MQ**, **DocumentDB**
+**DynamoDB Streams**
+
+```python
+from acai_aws.dynamodb.requirements import requirements as ddb_requirements
+
+@ddb_requirements()
+def dynamodb_handler(records):
+    for record in records.records:
+        handle_ddb_change(record.operation, record.body)
+```
+
+**Amazon SQS**
+
+```python
+from acai_aws.sqs.requirements import requirements as sqs_requirements
+
+@sqs_requirements()
+def sqs_handler(records):
+    for record in records.records:
+        handle_message(record.body, record.attributes)
+```
+
+**Amazon SNS**
+
+```python
+from acai_aws.sns.requirements import requirements as sns_requirements
+
+@sns_requirements()
+def sns_handler(records):
+    for record in records.records:
+        handle_notification(record.body, record.subject)
+```
+
+**Amazon S3**
+
+```python
+from acai_aws.s3.requirements import requirements as s3_requirements
+
+@s3_requirements(get_object=True, data_type='json')
+def s3_handler(records):
+    for record in records.records:
+        handle_object(record.bucket, record.key, record.body)
+```
+
+**Amazon Kinesis**
+
+```python
+from acai_aws.kinesis.requirements import requirements as kinesis_requirements
+
+@kinesis_requirements()
+def kinesis_handler(records):
+    for record in records.records:
+        handle_stream_event(record.partition_key, record.body)
+```
+
+**Amazon Firehose**
+
+```python
+from acai_aws.firehose.requirements import requirements as firehose_requirements
+
+@firehose_requirements()
+def firehose_handler(records):
+    for record in records.records:
+        handle_delivery(record.record_id, record.body)
+```
+
+**Amazon MSK**
+
+```python
+from acai_aws.msk.requirements import requirements as msk_requirements
+
+@msk_requirements()
+def msk_handler(records):
+    for record in records.records:
+        handle_msk_message(record.topic, record.body)
+```
+
+**Amazon MQ**
+
+```python
+from acai_aws.mq.requirements import requirements as mq_requirements
+
+@mq_requirements()
+def mq_handler(records):
+    for record in records.records:
+        handle_mq_message(record.message_id, record.body)
+```
+
+**Amazon DocumentDB Change Streams**
+
+```python
+from acai_aws.documentdb.requirements import requirements as docdb_requirements
+
+@docdb_requirements()
+def docdb_handler(records):
+    for record in records.records:
+        handle_docdb_change(record.operation, record.full_document)
+```
 
-Each record exposes intuitive properties like `record.operation`, `record.body`, `record.headers`, or service-specific fields.
+Each record exposes intuitive properties like `record.operation`, `record.body`, or service-specific metadata (bucket, partition, headers, etc.).
 
 ---
 

setup.py

@@ -6,15 +6,16 @@
 
 setup(
     name='acai_aws',
-    version=os.getenv('CIRCLE_TAG'),
-    url='https://github.com/syngenta/acai-python.git',
+    version=os.getenv('CIRCLE_TAG', '0.0.0'),
+    url='https://github.com/syngenta/acai-python',
     author='Paul Cruse III',
     author_email='[email protected]',
-    description='DRY, configurable, opinionated, minimalist framework for use with AWS Serverless Lambdas',
+    description='DRY, configurable, declarative framework for building AWS Lambda APIs and event processors',
     long_description=long_description,
     long_description_content_type='text/markdown',
     packages=find_packages(),
-    python_requires='>=3.0',
+    include_package_data=True,
+    python_requires='>=3.8',
     install_requires=[
         'boto3',
         'dynamodb_json',
@@ -27,18 +28,41 @@
         'simplejson',
         'xmltodict'
     ],
+    keywords=[
+        'aws', 'lambda', 'serverless', 'apigateway', 'router', 'openapi', 'pydantic',
+        'dynamodb', 'sqs', 'sns', 's3', 'kinesis', 'firehose', 'msk', 'documentdb',
+        'event-driven', 'validation', 'jsonschema', 'python-framework'
+    ],
+    project_urls={
+        'Homepage': 'https://github.com/syngenta/acai-python',
+        'Documentation': 'https://syngenta.github.io/acai-python-docs/',
+        'Source': 'https://github.com/syngenta/acai-python',
+        'Issue Tracker': 'https://github.com/syngenta/acai-python/issues',
+        'CI/CD': 'https://circleci.com/gh/syngenta/acai-python'
+    },
+    license='Apache 2.0',
+    platforms=['any'],
+    zip_safe=False,
     classifiers=[
-        'Environment :: Web Environment',
+        'Development Status :: 5 - Production/Stable',
         'Intended Audience :: Developers',
-        'Topic :: Internet :: WWW/HTTP :: Dynamic Content',
-        'Topic :: Software Development :: Libraries :: Python Modules',
+        'Intended Audience :: Information Technology',
+        'License :: OSI Approved :: Apache Software License',
+        'Environment :: Web Environment',
+        'Environment :: Console',
+        'Operating System :: OS Independent',
         'Programming Language :: Python',
         'Programming Language :: Python :: 3',
-        'Programming Language :: Python :: 3.6',
-        'Programming Language :: Python :: 3.7',
         'Programming Language :: Python :: 3.8',
         'Programming Language :: Python :: 3.9',
         'Programming Language :: Python :: 3.10',
-        'Programming Language :: Python :: 3.11'
+        'Programming Language :: Python :: 3.11',
+        'Programming Language :: Python :: 3.12',
+        'Topic :: Internet :: WWW/HTTP :: Dynamic Content',
+        'Topic :: Software Development :: Libraries :: Python Modules',
+        'Topic :: Software Development :: Libraries :: Application Frameworks',
+        'Topic :: System :: Distributed Computing',
+        'Topic :: System :: Monitoring',
+        'Natural Language :: English'
     ]
 )