Change directory structure and Add files

Author: Palbahngmiyine

README.md

@@ -1,4 +1,4 @@
 # Solapi SDK for Python
 
-[![Python 3.10.2](https://img.shields.io/badge/python-3.13.2-blue.svg)](https://www.python.org/downloads)
-![Python Supported version](https://img.shields.io/badge/python-%3E%3D3.11-orange)
+[![Python 3.13.2](https://img.shields.io/badge/python-3.13.2-blue.svg)](https://www.python.org/downloads)
+![Python Supported version](https://img.shields.io/badge/python-%3E%3D3.9-orange)

examples/sms/sms.py

@@ -1 +1 @@
-print("test")
+print("test")

poetry.lock

@@ -6,9 +6,11 @@ authors = [
     { name = "SOLAPI Team", email = "contact@solapi.com" }
 ]
 readme = "README.md"
-requires-python = ">=3.11"
+requires-python = ">=3.9"
 dependencies = [
-    "requests (>=2.32.3,<3.0.0)"
+    "requests (>=2.32.3,<3.0.0)",
+    "httpx (>=0.28.1,<0.29.0)",
+    "pydantic (>=2.10.6,<3.0.0)"
 ]
 
 [tool.poetry]

pyproject.toml

@@ -0,0 +1,42 @@
+import datetime
+import hashlib
+import hmac
+import time
+import uuid
+from typing import TypedDict
+
+
+class AuthenticationParameter(TypedDict):
+    api_key: str
+    api_secret: str
+
+
+class Authenticator:
+    def __init__(self, api_key="", api_secret_key=""):
+        self.api_key = api_key
+        self.api_secret_key = api_secret_key
+
+    @staticmethod
+    def unique_id() -> str:
+        return uuid.uuid1().hex
+
+    @staticmethod
+    def get_iso_datetime() -> str:
+        utc_offset_sec = time.altzone if time.localtime().tm_isdst else time.timezone
+        utc_offset = datetime.timedelta(seconds=-utc_offset_sec)
+        return (
+            datetime.datetime.now()
+            .replace(tzinfo=datetime.timezone(offset=utc_offset))
+            .isoformat()
+        )
+
+    @staticmethod
+    def get_signature(key: str, msg: str) -> str:
+        return hmac.new(key.encode(), msg.encode(), hashlib.sha256).hexdigest()
+
+    def get_auth_info(self) -> str:
+        date = self.get_iso_datetime()
+        salt = self.unique_id()
+        data = date + salt
+        signature = self.get_signature(self.api_secret_key, data)
+        return f"HMAC-SHA256 ApiKey={self.api_key}, Date={date}, salt={salt}, signature={signature}"

src/solapi/__init__.py solapi/__init__.pysrc/solapi/__init__.py renamed to solapi/__init__.py

@@ -0,0 +1,69 @@
+from enum import Enum
+from typing import Any, TypedDict, TypeVar
+
+import httpx
+from httpx import Response
+
+from solapi.lib.authenticator import AuthenticationParameter, Authenticator
+
+
+class RequestMethod(str, Enum):
+    GET = "GET"
+    POST = "POST"
+    PUT = "PUT"
+    DELETE = "DELETE"
+
+
+class RequestType(TypedDict):
+    method: RequestMethod
+    url: str
+
+
+T = TypeVar("T")
+R = TypeVar("R")
+
+
+async def default_fetcher(
+    auth_parameter: AuthenticationParameter,
+    request: RequestType,
+    data: T | None = None,
+) -> R:
+    """
+
+    Args:
+        auth_parameter: API Key, Api Secret Key Dictionary. 반드시 활성화된 유효한 API Key, API Secret Key를 입력하셔야 합니다.
+        request: HTTP Request를 위한 파라미터, 정확한 API URL, HTTP Method를 입력해주세요!
+        data: 발송 혹은 API 요청 시 전달해야 할 파라미터 목록, HTTP GET API를 이용하면 None 타입으로 지정됩니다.
+
+    Returns:
+        정상 작동할 경우 JSON 데이터를 반환합니다.
+    """
+    authorization_header_data = Authenticator(
+        auth_parameter["api_key"], auth_parameter["api_secret"]
+    ).get_auth_info()
+    headers = {
+        "Authorization": authorization_header_data,
+        "Content-Type": "application/json",
+    }
+
+    async with httpx.AsyncClient() as client:
+        response: Response = await client.request(
+            method=request["method"], url=request["url"], headers=headers, json=data
+        )
+
+    # 4xx 에러 처리: 클라이언트 오류일 경우
+    # TODO: Custom Error 만들어야 함
+    if 400 <= response.status_code < 500:
+        error_response: dict[str, Any] = response.json()
+        raise Exception(
+            error_response.get("errorCode", "UnknownError"),
+            error_response.get("errorMessage", ""),
+        )
+    # 5xx 에러 처리: 서버 오류일 경우
+    elif response.status_code >= 500:
+        raise Exception("UnknownError", response.text)
+
+    try:
+        return response.json()
+    except Exception as exc:
+        raise Exception(response.text) from exc

src/solapi/lib/__init__.py solapi/lib/__init__.pysrc/solapi/lib/__init__.py renamed to solapi/lib/__init__.py

@@ -1,6 +1,5 @@
 import re
 from datetime import datetime
-from typing import Union
 
 
 class InvalidDateError(Exception):
@@ -61,7 +60,7 @@ def parse_iso(date_string: str) -> datetime:
         raise InvalidDateError("Invalid Date") from e
 
 
-def string_date_transfer(value: Union[str, datetime]) -> datetime:
+def string_date_transfer(value: str | datetime) -> datetime:
     """
     일반 문자열 날짜가 있을 경우 datetime 타입으로 변환해주는 함수
 
@@ -83,7 +82,7 @@ def string_date_transfer(value: Union[str, datetime]) -> datetime:
     return value
 
 
-def transfer(value: Union[str, datetime]) -> str:
+def format_with_transfer(value: str | datetime) -> str:
     """
     string_date_transfer와 format_iso를 한번에 실행하는 함수
 

solapi/lib/authenticator.py

@@ -0,0 +1,66 @@
+from typing import Optional
+
+from solapi.lib.authenticator import AuthenticationParameter
+from solapi.lib.fetcher import RequestMethod, default_fetcher
+from solapi.lib.string_date_transfer import format_with_transfer
+from solapi.requests.request_confiog import SendRequestConfig
+from solapi.requests.send.send_request import (
+    MessageParameter,
+    MultipleDetailMessageSendingRequest,
+)
+from solapi.responses.send.send_repsonse import DetailGroupMessageResponse
+
+
+class SolapiMessageService:
+    def __init__(self, api_key: str, api_secret: str):
+        self.baseUrl = "https://api.solapi.com"
+        self._auth_info: AuthenticationParameter = {
+            "api_key": api_key,
+            "api_secret": api_secret,
+        }
+
+    # TODO: Request도 pydantic 모델로 진행
+    async def send(
+        self,
+        messages: list[MessageParameter] | MessageParameter,
+        request_config: Optional[SendRequestConfig] = None,
+    ):
+        payload = []
+        if isinstance(messages, list):
+            for value in messages:
+                payload.append(value)
+        else:
+            payload.append(messages)
+        pass
+
+        if len(payload) == 0:
+            raise Exception("데이터가 반드시 1건 이상 기입되어 있어야 합니다.")
+
+        parameter: MultipleDetailMessageSendingRequest = {"messages": payload}
+        if request_config["appId"] is not None:
+            parameter.appId = request_config["appId"]
+        if request_config["showMessageList"] is not None:
+            parameter.showMessageList = request_config["showMessageList"]
+        if request_config["scheduledDate"] is not None:
+            parameter.scheduledDate = format_with_transfer(
+                request_config["scheduledDate"]
+            )
+
+        response = await default_fetcher(
+            self._auth_info,
+            {
+                "method": RequestMethod("POST"),
+                "url": f"${self.baseUrl}/messages/v4/send-many/detail",
+            },
+            parameter,
+        )
+        validated_response = DetailGroupMessageResponse.model_validate(response)
+        count = validated_response.group_info.count
+        if (
+            len(validated_response.failed_message_list) > 0
+            and count.total == count.registeredFailed
+        ):
+            raise Exception("")
+
+        return validated_response
+