sanitize table names and add required keyword arguments

Author: dishaprakash

langchain_postgres/v2/async_chat_message_history.py

@@ -22,6 +22,7 @@ def __init__(
         pool: AsyncEngine,
         session_id: str,
         table_name: str,
+        *,
         store_message: bool,
         schema_name: str = "public",
     ):
@@ -96,8 +97,8 @@ async def create(
             engine._pool,
             session_id,
             table_name,
-            store_message,
-            schema_name,
+            store_message=store_message,
+            schema_name=schema_name,
         )
 
     def _insert_query(self, message: BaseMessage) -> tuple[str, dict]:

langchain_postgres/v2/engine.py

@@ -391,6 +391,8 @@ async def _ainit_chat_history_table(
         Returns:
             None
         """
+        table_name = self._escape_postgres_identifier(table_name)
+        schema_name = self._escape_postgres_identifier(schema_name)
         create_table_query = f"""CREATE TABLE IF NOT EXISTS "{schema_name}"."{table_name}"(
             id SERIAL PRIMARY KEY,
             session_id TEXT NOT NULL,