+ Base URL: http://localhost:3200/listings
+ Note: Species ID and Breed ID must be UUIDs (not integers). Use the dropdowns below or enter UUIDs manually.
+
+
+
+
+
Get Available Species
+
+
+
+
+
Get Available Breeds
+
+
+
+
+
+
+
+
+
+
+
+
Get All Listings
+
+
+
+
+
+
+
+
+
Get Single Listing
+
+
+
+
+
+
+
+
+
+
+
Search Listings
+
+
+
+
+
+
+
+
+
Near Me Search
+
+
+
+
+
+
+
+
+
+
+
+
+
Create Listing
+
+ ā ļø Important: The Seller ID must be a valid UUID that exists in the users table.
+ If you get a foreign key error, the user doesn't exist. You need to create the user first or use an existing user UUID.
+
+ ā¹ļø Note: User ID is optional for captured locations (is_saved_address = false),
+ but required and must exist in users table for saved addresses (is_saved_address = true).
+
+
+
+
+
+
+
+ Required only if "Is Saved Address" is Yes
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
Update Location
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
š¬ Chat API
+
+
+ Base URL: http://localhost:3200/chat
+
+
+
+
+
Create/Get Conversation
+
+
+
+
+
+
+
+
+
+
+
+
+
Get User Conversations
+
+
+
+
+
+
+
+
+
+
+
Get Messages
+
+
+
+
+
+
+
+
+
Send Message
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/routes/listingRoutes.js b/routes/listingRoutes.js
index d0649d5..eae44c4 100644
--- a/routes/listingRoutes.js
+++ b/routes/listingRoutes.js
@@ -20,6 +20,20 @@ const createNewLocation = async (client, userId, locationData) => {
pincode,
} = locationData;
+ // Validate user exists if this is a saved address
+ let finalUserId = userId;
+ if (is_saved_address && userId) {
+ const userCheck = await client.query("SELECT id FROM users WHERE id = $1 AND deleted = FALSE", [userId]);
+ if (userCheck.rows.length === 0) {
+ throw new Error(`User with id ${userId} does not exist. Cannot create saved address for non-existent user.`);
+ }
+ } else if (!is_saved_address) {
+ // For captured locations (not saved addresses), user_id can be NULL
+ finalUserId = null;
+ } else if (is_saved_address && !userId) {
+ throw new Error("user_id is required when is_saved_address is true");
+ }
+
// 1. Insert into locations (Merged Table)
const insertLocationQuery = `
INSERT INTO locations (
@@ -31,7 +45,7 @@ const createNewLocation = async (client, userId, locationData) => {
RETURNING id
`;
const locationValues = [
- userId,
+ finalUserId,
lat,
lng,
source_type || "manual",
@@ -266,6 +280,18 @@ router.post("/", async (req, res) => {
media // Array of { media_url, media_type, is_primary, sort_order }
} = req.body;
+ // Validate seller exists
+ if (seller_id) {
+ const sellerCheck = await client.query("SELECT id FROM users WHERE id = $1 AND deleted = FALSE", [seller_id]);
+ if (sellerCheck.rows.length === 0) {
+ await client.query("ROLLBACK");
+ return res.status(400).json({ error: `Seller with id ${seller_id} does not exist. Please create the user first.` });
+ }
+ } else {
+ await client.query("ROLLBACK");
+ return res.status(400).json({ error: "seller_id is required" });
+ }
+
let final_location_id = animal?.location_id;
// 1. Create Location (if needed)
@@ -531,11 +557,32 @@ router.delete("/:id", async (req, res) => {
});
+// Get the list of species
+router.get("/species", async (req, res) => {
+ try {
+ const queryText = "SELECT * FROM species WHERE deleted = FALSE ORDER BY name";
+ const result = await pool.query(queryText);
+ res.json(result.rows);
+ } catch (err) {
+ console.error("Error fetching species:", err);
+ res.status(500).json({ error: "Internal server error" });
+ }
+});
+
// Get the list of breeds
router.get("/breeds", async (req, res) => {
try {
- const queryText = "SELECT * FROM breeds";
- const result = await pool.query(queryText);
+ const { species_id } = req.query;
+ let queryText = "SELECT * FROM breeds WHERE deleted = FALSE";
+ const queryParams = [];
+
+ if (species_id) {
+ queryText += " AND species_id = $1";
+ queryParams.push(species_id);
+ }
+
+ queryText += " ORDER BY name";
+ const result = await pool.query(queryText, queryParams);
res.json(result.rows);
} catch (err) {
console.error("Error fetching breeds:", err);
diff --git a/routes/locationRoutes.js b/routes/locationRoutes.js
index 3d5b35c..048a027 100644
--- a/routes/locationRoutes.js
+++ b/routes/locationRoutes.js
@@ -25,6 +25,26 @@ router.post("/", async (req, res) => {
pincode,
} = req.body;
+ // Validate user exists if this is a saved address
+ let finalUserId = user_id;
+ if (is_saved_address && user_id) {
+ const userCheck = await client.query("SELECT id FROM users WHERE id = $1 AND deleted = FALSE", [user_id]);
+ if (userCheck.rows.length === 0) {
+ await client.query("ROLLBACK");
+ return res.status(400).json({
+ error: `User with id ${user_id} does not exist. Cannot create saved address for non-existent user.`
+ });
+ }
+ } else if (!is_saved_address) {
+ // For captured locations (not saved addresses), user_id can be NULL
+ finalUserId = null;
+ } else if (is_saved_address && !user_id) {
+ await client.query("ROLLBACK");
+ return res.status(400).json({
+ error: "user_id is required when is_saved_address is true"
+ });
+ }
+
// 1. Insert into locations
const insertLocationQuery = `
INSERT INTO locations (
@@ -35,7 +55,7 @@ router.post("/", async (req, res) => {
RETURNING *
`;
const locationValues = [
- user_id,
+ finalUserId,
lat,
lng,
source_type || "manual",
@@ -59,7 +79,15 @@ router.post("/", async (req, res) => {
} catch (err) {
await client.query("ROLLBACK");
console.error("Error creating location:", err);
- res.status(500).json({ error: "Internal server error" });
+
+ // Provide more specific error messages
+ if (err.code === '23503') { // Foreign key violation
+ return res.status(400).json({
+ error: `Foreign key constraint violation: ${err.detail || 'The provided user_id does not exist in the users table.'}`
+ });
+ }
+
+ res.status(500).json({ error: err.message || "Internal server error" });
} finally {
client.release();
}
diff --git a/routes/userRoutes.js b/routes/userRoutes.js
new file mode 100644
index 0000000..d6aa12c
--- /dev/null
+++ b/routes/userRoutes.js
@@ -0,0 +1,169 @@
+import express from "express";
+import pool from "../db/pool.js";
+
+const router = express.Router();
+
+// 1. CREATE User
+router.post("/", async (req, res) => {
+ const client = await pool.connect();
+ try {
+ await client.query("BEGIN");
+
+ const {
+ id, // Optional: if provided, use this UUID; otherwise generate one
+ name,
+ phone_number,
+ avatar_url,
+ language,
+ timezone,
+ country_code = "+91",
+ } = req.body;
+
+ // If id is provided, use it; otherwise let the database generate one
+ const insertUserQuery = id
+ ? `
+ INSERT INTO users (id, name, phone_number, avatar_url, language, timezone, country_code)
+ VALUES ($1, $2, $3, $4, $5, $6, $7)
+ RETURNING *
+ `
+ : `
+ INSERT INTO users (name, phone_number, avatar_url, language, timezone, country_code)
+ VALUES ($1, $2, $3, $4, $5, $6)
+ RETURNING *
+ `;
+
+ const userValues = id
+ ? [id, name, phone_number, avatar_url, language, timezone, country_code]
+ : [name, phone_number, avatar_url, language, timezone, country_code];
+
+ const userResult = await client.query(insertUserQuery, userValues);
+
+ await client.query("COMMIT");
+
+ res.status(201).json(userResult.rows[0]);
+ } catch (err) {
+ await client.query("ROLLBACK");
+ console.error("Error creating user:", err);
+
+ if (err.code === "23505") {
+ // Unique constraint violation
+ return res.status(400).json({
+ error: err.detail || "A user with this phone number or ID already exists",
+ });
+ }
+
+ if (err.code === "23503") {
+ // Foreign key violation
+ return res.status(400).json({
+ error: err.detail || "Foreign key constraint violation",
+ });
+ }
+
+ res.status(500).json({ error: err.message || "Internal server error" });
+ } finally {
+ client.release();
+ }
+});
+
+// 2. GET All Users
+router.get("/", async (req, res) => {
+ try {
+ const { limit = 100, offset = 0 } = req.query;
+ const queryText = `
+ SELECT id, name, phone_number, avatar_url, language, timezone, country_code,
+ is_active, created_at, updated_at
+ FROM users
+ WHERE deleted = FALSE
+ ORDER BY created_at DESC
+ LIMIT $1 OFFSET $2
+ `;
+ const result = await pool.query(queryText, [limit, offset]);
+ res.json(result.rows);
+ } catch (err) {
+ console.error("Error fetching users:", err);
+ res.status(500).json({ error: "Internal server error" });
+ }
+});
+
+// 3. GET Single User
+router.get("/:id", async (req, res) => {
+ try {
+ const { id } = req.params;
+ const queryText = `
+ SELECT id, name, phone_number, avatar_url, language, timezone, country_code,
+ is_active, created_at, updated_at
+ FROM users
+ WHERE id = $1 AND deleted = FALSE
+ `;
+ const result = await pool.query(queryText, [id]);
+
+ if (result.rows.length === 0) {
+ return res.status(404).json({ error: "User not found" });
+ }
+
+ res.json(result.rows[0]);
+ } catch (err) {
+ console.error("Error fetching user:", err);
+ res.status(500).json({ error: "Internal server error" });
+ }
+});
+
+// 4. UPDATE User
+router.put("/:id", async (req, res) => {
+ try {
+ const { id } = req.params;
+ const { name, phone_number, avatar_url, language, timezone, country_code, is_active } = req.body;
+
+ const updateQuery = `
+ UPDATE users
+ SET name = COALESCE($1, name),
+ phone_number = COALESCE($2, phone_number),
+ avatar_url = COALESCE($3, avatar_url),
+ language = COALESCE($4, language),
+ timezone = COALESCE($5, timezone),
+ country_code = COALESCE($6, country_code),
+ is_active = COALESCE($7, is_active)
+ WHERE id = $8 AND deleted = FALSE
+ RETURNING *
+ `;
+
+ const values = [name, phone_number, avatar_url, language, timezone, country_code, is_active, id];
+
+ const result = await pool.query(updateQuery, values);
+
+ if (result.rows.length === 0) {
+ return res.status(404).json({ error: "User not found" });
+ }
+
+ res.json(result.rows[0]);
+ } catch (err) {
+ console.error("Error updating user:", err);
+ res.status(500).json({ error: "Internal server error" });
+ }
+});
+
+// 5. DELETE User (Soft Delete)
+router.delete("/:id", async (req, res) => {
+ try {
+ const { id } = req.params;
+ const queryText = `
+ UPDATE users
+ SET deleted = TRUE
+ WHERE id = $1
+ RETURNING id
+ `;
+ const result = await pool.query(queryText, [id]);
+
+ if (result.rows.length === 0) {
+ return res.status(404).json({ error: "User not found" });
+ }
+
+ res.json({ message: "User deleted successfully" });
+ } catch (err) {
+ console.error("Error deleting user:", err);
+ res.status(500).json({ error: "Internal server error" });
+ }
+});
+
+export default router;
+
diff --git a/server.js b/server.js
index b72fe81..a91f5f1 100644
--- a/server.js
+++ b/server.js
@@ -1,24 +1,31 @@
import express from "express";
import cors from "cors";
+import { fileURLToPath } from 'url';
+import { dirname, join } from 'path';
+import http from "http";
+import listingRoutes from "./routes/listingRoutes.js";
+import locationRoutes from "./routes/locationRoutes.js";
+import chatRoutes from "./routes/chatRoutes.js";
+import userRoutes from "./routes/userRoutes.js";
+import { initSocket } from "./socket.js";
+import { startExpirationJob } from "./jobs/expirationJob.js";
const app = express();
app.use(cors());
app.use(express.json());
+// Serve static files from public directory
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+app.use(express.static(join(__dirname, 'public')));
+
const PORT = process.env.PORT || 3200;
// Add routes here
-import listingRoutes from "./routes/listingRoutes.js";
-import locationRoutes from "./routes/locationRoutes.js";
-import chatRoutes from "./routes/chatRoutes.js";
-
-
app.use("/listings", listingRoutes);
app.use("/locations", locationRoutes);
app.use("/chat", chatRoutes);
-import http from "http";
-import { initSocket } from "./socket.js";
-import { startExpirationJob } from "./jobs/expirationJob.js";
+app.use("/users", userRoutes);
const server = http.createServer(app);
initSocket(server);