Revert "Refactor/handle webhook (#647)" (#648)

This reverts commit 76e4430.

app/models/webhooks.py

@@ -1,14 +1,7 @@
-import json
-import logging
-from typing import List, Type
-import boto3  # type: ignore
+import boto3
+import datetime
 import os
 import uuid
-from datetime import datetime
-from pydantic import BaseModel
-
-from models import model_utils
-
 
 client = boto3.client(
     "dynamodb",
@@ -21,66 +14,6 @@
 table = "webhooks"
 
 
-class WebhookPayload(BaseModel):
-    channel: str | None = None
-    text: str | None = None
-    as_user: bool | None = None
-    attachments: str | list | None = []
-    blocks: str | list | None = []
-    thread_ts: str | None = None
-    reply_broadcast: bool | None = None
-    unfurl_links: bool | None = None
-    unfurl_media: bool | None = None
-    icon_emoji: str | None = None
-    icon_url: str | None = None
-    mrkdwn: bool | None = None
-    link_names: bool | None = None
-    username: str | None = None
-    parse: str | None = None
-
-    class Config:
-        extra = "forbid"
-
-
-class AwsSnsPayload(BaseModel):
-    Type: str | None = None
-    MessageId: str | None = None
-    Token: str | None = None
-    TopicArn: str | None = None
-    Message: str | None = None
-    SubscribeURL: str | None = None
-    Timestamp: str | None = None
-    SignatureVersion: str | None = None
-    Signature: str | None = None
-    SigningCertURL: str | None = None
-    Subject: str | None = None
-    UnsubscribeURL: str | None = None
-
-    class Config:
-        extra = "forbid"
-
-
-class AccessRequest(BaseModel):
-    """
-    AccessRequest represents a request for access to an AWS account.
-
-    This class defines the schema for an access request, which includes the following fields:
-    - account: The name of the AWS account to which access is requested.
-    - reason: The reason for requesting access to the AWS account.
-    - startDate: The start date and time for the requested access period.
-    - endDate: The end date and time for the requested access period.
-    """
-
-    account: str
-    reason: str
-    startDate: datetime
-    endDate: datetime
-
-
-class UpptimePayload(BaseModel):
-    text: str | None = None
-
-
 def create_webhook(channel, user_id, name):
     id = str(uuid.uuid4())
     response = client.put_item(
@@ -89,7 +22,7 @@ def create_webhook(channel, user_id, name):
             "id": {"S": id},
             "channel": {"S": channel},
             "name": {"S": name},
-            "created_at": {"S": str(datetime.now())},
+            "created_at": {"S": str(datetime.datetime.now())},
             "active": {"BOOL": True},
             "user_id": {"S": user_id},
             "invocation_count": {"N": "0"},
@@ -170,42 +103,3 @@ def toggle_webhook(id):
         },
     )
     return response
-
-
-def validate_string_payload_type(payload: str) -> tuple:
-    """
-    This function takes a string payload and returns the type of webhook payload it is based on the parameters it contains.
-
-    Args:
-        payload (str): The payload to validate.
-
-    Returns:
-        tuple: A tuple containing the type of payload and the payload dictionary. If the payload is invalid, both values are None.
-    """
-
-    payload_type = None
-    payload_dict = None
-    try:
-        payload_dict = json.loads(payload)
-    except json.JSONDecodeError:
-        logging.warning("Invalid JSON payload")
-        return None, None
-
-    known_models: List[Type[BaseModel]] = [
-        WebhookPayload,
-        AwsSnsPayload,
-        AccessRequest,
-        UpptimePayload,
-    ]
-    model_params = model_utils.get_dict_of_parameters_from_models(known_models)
-
-    for model, params in model_params.items():
-        if model_utils.is_parameter_in_model(params, payload_dict):
-            payload_type = model
-            break
-
-    if payload_type:
-        return payload_type, payload_dict
-    else:
-        logging.warning("Unknown type for payload: %s", json.dumps(payload_dict))
-        return None, None

app/server/event_handlers/aws.py

@@ -3,62 +3,8 @@
 import re
 import os
 import urllib.parse
-
-from fastapi import HTTPException
-
 from server.utils import log_ops_message
 from integrations import notify
-from models.webhooks import AwsSnsPayload
-from sns_message_validator import (
-    SNSMessageValidator,
-    InvalidMessageTypeException,
-    InvalidCertURLException,
-    InvalidSignatureVersionException,
-    SignatureVerificationFailureException,
-)
-
-sns_message_validator = SNSMessageValidator()
-
-
-def validate_sns_payload(awsSnsPayload: AwsSnsPayload, client):
-    try:
-        valid_payload = AwsSnsPayload.model_validate(awsSnsPayload)
-        sns_message_validator.validate_message(message=valid_payload.model_dump())
-    except (
-        InvalidMessageTypeException,
-        InvalidSignatureVersionException,
-        SignatureVerificationFailureException,
-        InvalidCertURLException,
-    ) as e:
-        logging.error(
-            f"Failed to parse AWS event message due to {e.__class__.__qualname__}: {e}"
-        )
-        if isinstance(e, InvalidMessageTypeException):
-            log_message = f"Invalid message type ```{awsSnsPayload.Type}``` in message: ```{awsSnsPayload}```"
-        elif isinstance(e, InvalidSignatureVersionException):
-            log_message = f"Unexpected signature version ```{awsSnsPayload.SignatureVersion}``` in message: ```{awsSnsPayload}```"
-        elif isinstance(e, InvalidCertURLException):
-            log_message = f"Invalid certificate URL ```{awsSnsPayload.SigningCertURL}``` in message: ```{awsSnsPayload}```"
-        elif isinstance(e, SignatureVerificationFailureException):
-            log_message = f"Failed to verify signature ```{awsSnsPayload.Signature}``` in message: ```{awsSnsPayload}```"
-        log_ops_message(client, log_message)
-        raise HTTPException(
-            status_code=500,
-            detail=f"Failed to parse AWS event message due to {e.__class__.__qualname__}: {e}",
-        )
-    except Exception as e:
-        logging.error(
-            f"Failed to parse AWS event message due to {e.__class__.__qualname__}: {e}"
-        )
-        log_ops_message(
-            client,
-            f"Error parsing AWS event due to {e.__class__.__qualname__}: ```{awsSnsPayload}```",
-        )
-        raise HTTPException(
-            status_code=500,
-            detail=f"Failed to parse AWS event message due to {e.__class__.__qualname__}: {e}",
-        )
-    return valid_payload
 
 
 def parse(payload, client):