update communitypost

pytrade.py

@@ -78,8 +78,11 @@ def _encode_jwt(payload: dict, minutes: Optional[int] = None, days: Optional[int
     }
     return jwt.encode(to_encode, app.config["JWT_SECRET"], algorithm="HS256")
 
-def create_access_token(user_id: int, email: str) -> str:
-    return _encode_jwt({"sub": str(user_id), "email": email, "type": "access"}, minutes=ACCESS_MINUTES)
+def create_access_token(user_id: int, email: str, name: Optional[str] = None) -> str:
+    payload = {"sub": str(user_id), "email": email, "type": "access"}
+    if name:
+        payload["name"] = name  # optional convenience for UI
+    return _encode_jwt(payload, minutes=ACCESS_MINUTES)
 
 def create_refresh_token(user_id: int, email: str) -> str:
     return _encode_jwt({"sub": str(user_id), "email": email, "type": "refresh"}, days=REFRESH_DAYS)
@@ -406,7 +409,7 @@ def sign_in():
     if not user:
         return jsonify({"message": "Invalid email or password"}), 401
 
-    access_token = create_access_token(user_id=user["userId"], email=user["email"])
+    access_token = create_access_token(user_id=user["userId"], email=user["email"], name=user["name"])
     refresh_token = create_refresh_token(user_id=user["userId"], email=user["email"])
 
     payload = {
@@ -481,6 +484,138 @@ def logout():
     clear_token_cookies(resp)
     return resp
 
+
+#community forum to post the data
+
+# --- Add this API anywhere below other routes ---
+@app.post("/posts")
+@jwt_required
+def create_community_post():
+    """
+    TEMP: Open endpoint. Expects JSON:
+    { userId?, userName?, title?, category?, tags?, body }
+    """
+    data = request.get_json(silent=True) or {}
+
+    user_id = int((data.get("userId") or 0))
+    user_name = (data.get("userName") or "").strip() or "Guest"
+    title = (data.get("title") or "").strip()
+    category = (data.get("category") or "").strip()
+    tags = (data.get("tags") or "").strip()
+    body = (data.get("body") or "").strip()
+
+    if not body:
+        return jsonify({"message": "body is required"}), 400
+
+    conn = get_db_connection()
+    cursor = None
+    try:
+        cursor = conn.cursor()
+        # Return the new identity in the same statement (more reliable than SCOPE_IDENTITY())
+        cursor.execute("""
+            INSERT INTO Community (user_id, user_name, title, category, tags, body)
+            OUTPUT INSERTED.id
+            VALUES (?, ?, ?, ?, ?, ?)
+        """, (user_id, user_name, title, category, tags, body))
+
+        row = cursor.fetchone()
+        conn.commit()
+
+        if not row or row[0] is None:
+            return jsonify({"error": "Failed to retrieve new post id"}), 500
+
+        new_id = int(row[0])
+
+        return jsonify({
+            "id": new_id,
+            "message": "Post created",
+            "userId": user_id,
+            "userName": user_name
+        }), 201
+    except Exception as e:
+        app.logger.exception("create_community_post failed")
+        return jsonify({"error": str(e)}), 500
+    finally:
+        try:
+            if cursor: cursor.close()
+        except:
+            pass
+        conn.close()
+
+
+@app.get("/posts")
+def list_community_posts():
+    """
+    List community posts (public). Supports paging:
+      GET /posts?limit=50&offset=0
+    Returns: { total, offset, limit, count, results: Post[] }
+    """
+    limit_raw = request.args.get("limit", "50")
+    offset_raw = request.args.get("offset", "0")
+    try:
+        limit = max(1, min(200, int(limit_raw)))
+    except Exception:
+        limit = 50
+    try:
+        offset = max(0, int(offset_raw))
+    except Exception:
+        offset = 0
+
+    conn = get_db_connection()
+    cur = None
+    try:
+        cur = conn.cursor()
+        # data page
+        cur.execute("""
+            SELECT
+                id,
+                user_id      AS userId,
+                user_name    AS userName,
+                title,
+                category,
+                tags,
+                body,
+                created_at   AS createdAt
+            FROM Community
+            ORDER BY created_at DESC
+            OFFSET ? ROWS FETCH NEXT ? ROWS ONLY
+        """, (offset, limit))
+        rows = cur.fetchall()
+
+        posts = [
+            {
+                "id": int(r[0]),
+                "userId": int(r[1]),
+                "userName": r[2],
+                "title": r[3],
+                "category": r[4],
+                "tags": r[5],
+                "body": r[6],
+                "createdAt": r[7].isoformat() if hasattr(r[7], "isoformat") else r[7],
+            }
+            for r in rows
+        ]
+
+        # total count
+        cur.execute("SELECT COUNT(*) FROM Community")
+        total = int(cur.fetchone()[0])
+
+        return jsonify({
+            "total": total,
+            "offset": offset,
+            "limit": limit,
+            "count": len(posts),
+            "results": posts
+        }), 200
+    except Exception as e:
+        app.logger.exception("list_community_posts failed")
+        return jsonify({"error": str(e)}), 500
+    finally:
+        try:
+            if cur: cur.close()
+        except:
+            pass
+        conn.close()
 # ------------------------------------------------------------------------------
 # Run
 # ------------------------------------------------------------------------------

signin.py

@@ -55,3 +55,33 @@ def ensure_user_table_exists():
         try: cur.close()
         except: pass
         conn.close()
+
+
+# --- Add below existing ensure_user_table_exists() call ---
+def ensure_community_table_exists() -> None:
+    conn = get_db_connection()
+    try:
+        cursor = conn.cursor()
+        cursor.execute("""
+IF NOT EXISTS (SELECT * FROM sysobjects WHERE name='Community' AND xtype='U')
+BEGIN
+    CREATE TABLE Community (
+        id INT IDENTITY(1,1) PRIMARY KEY,
+        user_id INT NOT NULL,
+        user_name NVARCHAR(200) NOT NULL,
+        title NVARCHAR(300) NULL,
+        category NVARCHAR(100) NULL,
+        tags NVARCHAR(1000) NULL,        
+        body NVARCHAR(MAX) NOT NULL,
+        created_at DATETIME2 NOT NULL DEFAULT SYSUTCDATETIME()
+    );
+    CREATE INDEX IX_Community_UserId ON Community(user_id);
+    CREATE INDEX IX_Community_CreatedAt ON Community(created_at DESC);
+END
+        """)
+        conn.commit()
+    finally:
+        try: cursor.close()
+        except: pass
+        conn.close()
+