Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
68 changes: 40 additions & 28 deletions platforms/pictique-api/src/controllers/UserController.ts
Original file line number Diff line number Diff line change
Expand Up @@ -65,34 +65,8 @@ export class UserController {
// Validate sort parameter
const validSortOptions = ["relevance", "name", "verified", "newest"];
const sortOption = validSortOptions.includes(sort as string) ? sort as string : "relevance";

// Get users and count in parallel
const [users, total] = await Promise.all([
this.userService.searchUsers(q, pageNum, limitNum, verifiedOnly, sortOption),
this.userService.getSearchUsersCount(q, verifiedOnly)
]);

// Calculate pagination metadata
const totalPages = Math.ceil(total / limitNum);
const hasNextPage = pageNum < totalPages;
const hasPrevPage = pageNum > 1;

res.json({
users,
pagination: {
page: pageNum,
limit: limitNum,
total,
totalPages,
hasNextPage,
hasPrevPage
},
searchInfo: {
query: q,
verifiedOnly,
sortBy: sortOption
}
});
const users = await this.userService.searchUsers(q, pageNum, limitNum, verifiedOnly, sortOption);
res.json(users);
} catch (error) {
console.error("Error searching users:", error);
res.status(500).json({ error: "Internal server error" });
Expand Down Expand Up @@ -135,6 +109,44 @@ export class UserController {
}
};

searchByEnameOrName = async (req: Request, res: Response) => {
try {
const { q, page = "1", limit = "10", verified } = req.query;

if (!q || typeof q !== "string") {
return res
.status(400)
.json({ error: "Search query is required" });
}

// Validate search query length
if (q.trim().length < 2) {
return res
.status(400)
.json({ error: "Search query must be at least 2 characters long" });
}

// Parse and validate pagination parameters
const pageNum = parseInt(page as string) || 1;
const limitNum = Math.min(parseInt(limit as string) || 10, 50); // Cap at 50 results

if (pageNum < 1 || limitNum < 1) {
return res
.status(400)
.json({ error: "Invalid pagination parameters" });
}

// Parse verified filter
const verifiedOnly = verified === "true";

const users = await this.userService.searchUsersByEnameOrName(q, pageNum, limitNum, verifiedOnly);
res.json(users);
} catch (error) {
console.error("Error searching users by ename or name:", error);
res.status(500).json({ error: "Internal server error" });
}
};

follow = async (req: Request, res: Response) => {
try {
const followerId = req.user?.id;
Expand Down
1 change: 1 addition & 0 deletions platforms/pictique-api/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -128,6 +128,7 @@ app.get(
// User routes
app.get("/api/users", userController.currentUser);
app.get("/api/users/search", userController.search);
app.get("/api/users/search/ename-name", userController.searchByEnameOrName);
app.get("/api/users/suggestions", userController.getSearchSuggestions);
app.get("/api/users/popular", userController.getPopularSearches);
app.post("/api/users/:id/follow", authGuard, userController.follow);
Expand Down
159 changes: 149 additions & 10 deletions platforms/pictique-api/src/services/UserService.ts
Original file line number Diff line number Diff line change
Expand Up @@ -58,21 +58,37 @@ export class UserService {
return [];
}

// Use query builder for more complex queries
// Use query builder for more complex queries with relevance scoring
const queryBuilder = this.userRepository
.createQueryBuilder("user")
.select([
"user.id",
"user.handle",
"user.name",
"user.ename",
"user.description",
"user.avatarUrl",
"user.isVerified"
])
.addSelect(`
CASE
WHEN user.ename ILIKE :exactQuery THEN 100
WHEN user.name ILIKE :exactQuery THEN 90
WHEN user.handle ILIKE :exactQuery THEN 80
WHEN user.ename ILIKE :query THEN 70
WHEN user.name ILIKE :query THEN 60
WHEN user.handle ILIKE :query THEN 50
WHEN user.description ILIKE :query THEN 30
WHEN user.ename ILIKE :fuzzyQuery THEN 40
WHEN user.name ILIKE :fuzzyQuery THEN 35
WHEN user.handle ILIKE :fuzzyQuery THEN 30
ELSE 0
END`, 'relevance_score')
.where(
"user.name ILIKE :query OR user.ename ILIKE :query OR user.handle ILIKE :query OR user.description ILIKE :query OR user.name ILIKE :fuzzyQuery OR user.ename ILIKE :fuzzyQuery OR user.handle ILIKE :fuzzyQuery",
"user.name ILIKE :query OR user.ename ILIKE :query OR user.handle ILIKE :query OR user.description ILIKE :query OR user.ename ILIKE :fuzzyQuery OR user.name ILIKE :fuzzyQuery OR user.handle ILIKE :fuzzyQuery",
{
query: `%${searchQuery}%`,
exactQuery: searchQuery, // Exact match for highest priority
fuzzyQuery: `%${searchQuery.split('').join('%')}%` // Fuzzy search with wildcards between characters
}
);
Expand All @@ -98,8 +114,10 @@ export class UserService {
break;
case "relevance":
default:
// Default relevance sorting: verified first, then by name
queryBuilder.orderBy("user.isVerified", "DESC").addOrderBy("user.name", "ASC");
// Default relevance sorting: relevance score first, then verified status, then by name
queryBuilder.orderBy("relevance_score", "DESC")
.addOrderBy("user.isVerified", "DESC")
.addOrderBy("user.name", "ASC");
break;
}

Expand All @@ -121,13 +139,14 @@ export class UserService {
return 0;
}

// Use query builder for count
// Use query builder for count with same search logic
const queryBuilder = this.userRepository
.createQueryBuilder("user")
.where(
"user.name ILIKE :query OR user.ename ILIKE :query OR user.handle ILIKE :query OR user.description ILIKE :query OR user.name ILIKE :fuzzyQuery OR user.ename ILIKE :fuzzyQuery OR user.handle ILIKE :fuzzyQuery",
"user.name ILIKE :query OR user.ename ILIKE :query OR user.handle ILIKE :query OR user.description ILIKE :query OR user.ename ILIKE :fuzzyQuery OR user.name ILIKE :fuzzyQuery OR user.handle ILIKE :fuzzyQuery",
{
query: `%${searchQuery}%`,
exactQuery: searchQuery, // Exact match for highest priority
fuzzyQuery: `%${searchQuery.split('').join('%')}%` // Fuzzy search with wildcards between characters
}
);
Expand All @@ -152,7 +171,7 @@ export class UserService {
return [];
}

// Use query builder for suggestions
// Use query builder for suggestions with relevance scoring
const queryBuilder = this.userRepository
.createQueryBuilder("user")
.select([
Expand All @@ -161,18 +180,138 @@ export class UserService {
"user.name",
"user.ename"
])
.addSelect(`
CASE
WHEN user.ename ILIKE :exactQuery THEN 100
WHEN user.name ILIKE :exactQuery THEN 90
WHEN user.ename ILIKE :query THEN 70
WHEN user.name ILIKE :query THEN 60
WHEN user.handle ILIKE :query THEN 50
WHEN user.ename ILIKE :fuzzyQuery THEN 40
WHEN user.name ILIKE :fuzzyQuery THEN 35
WHEN user.handle ILIKE :fuzzyQuery THEN 30
ELSE 0
END`, 'relevance_score')
.where(
"user.name ILIKE :query OR user.ename ILIKE :query OR user.handle ILIKE :query",
{ query: `%${searchQuery}%` }
"user.name ILIKE :query OR user.ename ILIKE :query OR user.handle ILIKE :query OR user.ename ILIKE :fuzzyQuery OR user.name ILIKE :fuzzyQuery OR user.handle ILIKE :fuzzyQuery",
{
query: `%${searchQuery}%`,
exactQuery: searchQuery, // Exact match for highest priority
fuzzyQuery: `%${searchQuery.split('').join('%')}%` // Fuzzy search with wildcards between characters
}
)
.andWhere("user.isArchived = :archived", { archived: false })
.orderBy("user.isVerified", "DESC")
.orderBy("relevance_score", "DESC")
.addOrderBy("user.isVerified", "DESC")
.addOrderBy("user.name", "ASC")
.take(limit);

return queryBuilder.getMany();
};

searchUsersByEnameOrName = async (
query: string,
page: number = 1,
limit: number = 10,
verifiedOnly: boolean = false
) => {
// Sanitize and trim the search query
const searchQuery = query.trim();

// Return empty array if query is too short or empty
if (searchQuery.length < 2) {
return [];
}

// Validate pagination parameters
if (page < 1 || limit < 1 || limit > 100) {
return [];
}

// Specialized search focusing only on ename and name with high priority
const queryBuilder = this.userRepository
.createQueryBuilder("user")
.select([
"user.id",
"user.handle",
"user.name",
"user.ename",
"user.description",
"user.avatarUrl",
"user.isVerified"
])
.addSelect(`
CASE
WHEN user.ename ILIKE :exactQuery THEN 100
WHEN user.name ILIKE :exactQuery THEN 95
WHEN user.ename ILIKE :query THEN 80
WHEN user.name ILIKE :query THEN 75
WHEN user.ename ILIKE :fuzzyQuery THEN 60
WHEN user.name ILIKE :fuzzyQuery THEN 55
ELSE 0
END`, 'relevance_score')
.where(
"user.ename ILIKE :query OR user.name ILIKE :query OR user.ename ILIKE :fuzzyQuery OR user.name ILIKE :fuzzyQuery",
{
query: `%${searchQuery}%`,
exactQuery: searchQuery, // Exact match for highest priority
fuzzyQuery: `%${searchQuery.split('').join('%')}%` // Fuzzy search with wildcards between characters
}
);

// Add verified filter if requested
if (verifiedOnly) {
queryBuilder.andWhere("user.isVerified = :verified", { verified: true });
}

// Add additional filters for better results
queryBuilder.andWhere("user.isArchived = :archived", { archived: false });

// Order by relevance score (ename and name matches first)
return queryBuilder
.orderBy("relevance_score", "DESC")
.addOrderBy("user.isVerified", "DESC")
.addOrderBy("user.name", "ASC")
.skip((page - 1) * limit)
.take(limit)
.getMany();
};

getSearchUsersByEnameOrNameCount = async (
query: string,
verifiedOnly: boolean = false
) => {
// Sanitize and trim the search query
const searchQuery = query.trim();

// Return 0 if query is too short or empty
if (searchQuery.length < 2) {
return 0;
}

// Use query builder for count with same specialized search logic
const queryBuilder = this.userRepository
.createQueryBuilder("user")
.where(
"user.ename ILIKE :query OR user.name ILIKE :query OR user.ename ILIKE :fuzzyQuery OR user.name ILIKE :fuzzyQuery",
{
query: `%${searchQuery}%`,
exactQuery: searchQuery, // Exact match for highest priority
fuzzyQuery: `%${searchQuery.split('').join('%')}%` // Fuzzy search with wildcards between characters
}
);

// Add verified filter if requested
if (verifiedOnly) {
queryBuilder.andWhere("user.isVerified = :verified", { verified: true });
}

// Add additional filters for consistency
queryBuilder.andWhere("user.isArchived = :archived", { archived: false });

return queryBuilder.getCount();
};

getPopularSearches = async (limit: number = 10) => {
// This could be enhanced with actual search analytics in the future
// For now, return some sample popular searches based on verified users
Expand Down
Loading