modify search api scope

Signed-off-by: Arnesh Dadhich <arneshdadhich0011@gmail.com>

Author: isuniverseok

src/client/acontext-py/src/acontext/resources/async_sessions.py

@@ -508,25 +508,25 @@ async def search(
         self,
         *,
         query: str,
-        user_id: str,
+        user: str,
         limit: int | None = None,
     ) -> SessionSearchResult:
         """Search for sessions by semantic similarity to a query string.
 
         Args:
             query: The search query text.
-            user_id: The User ID to search within.
+            user: User identifier to scope the search (e.g., email address).
             limit: Maximum number of results to return (1-100, default 10).
 
         Returns:
             SessionSearchResult containing list of matching session UUIDs.
 
         Example:
-            >>> result = await client.sessions.search(query="conversations", user_id="user_123")
+            >>> result = await client.sessions.search(query="conversations", user="alice@acontext.io")
             >>> for session_id in result.session_ids:
             ...     print(session_id)
         """
-        params = build_params(query=query, user_id=user_id, limit=limit)
+        params = build_params(query=query, user=user, limit=limit)
         data = await self._requester.request(
             "GET", "/sessions/search", params=params or None
         )

src/client/acontext-py/src/acontext/resources/sessions.py

@@ -502,16 +502,14 @@ def search(
         self,
         *,
         query: str,
-        user_id: str,
-        project_id: str,
+        user: str,
         limit: int | None = None,
     ) -> SessionSearchResult:
         """Search for sessions by semantic similarity to a query string.
 
         Args:
             query: The search query text.
-            user_id: The User ID to search within.
-            project_id: The Project ID to search within.
+            user: User identifier to scope the search (e.g., email address).
             limit: Maximum number of results to return (1-100, default 10).
 
         Returns:
@@ -520,12 +518,11 @@ def search(
         Example:
             >>> result = client.sessions.search(
             ...     query="conversations about authentication",
-            ...     user_id="user_123",
-            ...     project_id="proj_456"
+            ...     user="alice@acontext.io"
             ... )
             >>> for session_id in result.session_ids:
             ...     print(session_id)
         """
-        params = build_params(query=query, user_id=user_id, project_id=project_id, limit=limit)
+        params = build_params(query=query, user=user, limit=limit)
         data = self._requester.request("GET", "/sessions/search", params=params or None)
         return SessionSearchResult.model_validate(data)

src/client/acontext-ts/src/resources/sessions.ts

@@ -444,34 +444,29 @@ export class SessionsAPI {
    *
    * @param options - Options for searching sessions.
    * @param options.query - The search query text.
-   * @param options.userId - The User ID to search within.
-   * @param options.projectId - The Project ID to search within.
+   * @param options.user - User identifier to scope the search (e.g., email address).
    * @param options.limit - Maximum number of results to return (1-100, default 10).
    * @returns SessionSearchResult containing list of matching session UUIDs.
    *
    * @example
    * const result = await client.sessions.search({
    *   query: 'conversations about authentication',
-   *   userId: 'user_123',
-   *   projectId: 'proj_456'
+   *   user: 'alice@acontext.io'
    * });
    */
   async search(options: {
     query: string;
-    userId: string;
-    projectId: string;
+    user: string;
     limit?: number | null;
   }): Promise<{ session_ids: string[] }> {
     const params = buildParams({
       query: options.query,
-      user_id: options.userId,
-      project_id: options.projectId,
+      user: options.user,
       limit: options.limit ?? null,
     });
     const data = await this.requester.request('GET', '/sessions/search', {
       params: Object.keys(params).length > 0 ? params : undefined,
     });
-    // Assuming SessionSearchResult schema exists or returning generic object
     return data as { session_ids: string[] };
   }
 }

src/server/api/go/internal/modules/handler/session.go

@@ -780,10 +780,9 @@ func (h *SessionHandler) PatchConfigs(c *gin.Context) {
 }
 
 type SessionSearchReq struct {
-	Query     string `form:"query" json:"query" binding:"required" example:"find conversations about authentication"`
-	UserID    string `form:"user_id" json:"user_id" binding:"required" example:"123e4567-e89b-12d3-a456-426614174000"`
-	ProjectID string `form:"project_id" json:"project_id" binding:"required" example:"123e4567-e89b-12d3-a456-426614174001"`
-	Limit     int    `form:"limit,default=10" json:"limit" binding:"omitempty,min=1,max=100" example:"10"`
+	Query string `form:"query" json:"query" binding:"required" example:"find conversations about authentication"`
+	User  string `form:"user" json:"user" binding:"required" example:"alice@acontext.io"`
+	Limit int    `form:"limit,default=10" json:"limit" binding:"omitempty,min=1,max=100" example:"10"`
 }
 
 // SessionSearch godoc
@@ -794,8 +793,7 @@ type SessionSearchReq struct {
 //	@Accept			json
 //	@Produce		json
 //	@Param			query		query	string	true	"Search query text"
-//	@Param			user_id		query	string	true	"User ID"
-//	@Param			project_id	query	string	true	"Project ID"
+//	@Param			user		query	string	true	"user identifier"	example(alice@acontext.io)
 //	@Param			limit		query	integer	false	"Maximum number of results (1-100, default 10)"
 //	@Security		BearerAuth
 //	@Success		200	{object}	serializer.Response{data=httpclient.SessionSearchResponse}
@@ -807,12 +805,24 @@ func (h *SessionHandler) SessionSearch(c *gin.Context) {
 		return
 	}
 
+	project, ok := c.MustGet("project").(*model.Project)
+	if !ok {
+		c.JSON(http.StatusBadRequest, serializer.ParamErr("", errors.New("project not found")))
+		return
+	}
+
+	user, err := h.userSvc.GetByIdentifier(c.Request.Context(), project.ID, req.User)
+	if err != nil {
+		c.JSON(http.StatusNotFound, serializer.Err(http.StatusNotFound, "user not found in this project", err))
+		return
+	}
+
 	limit := req.Limit
 	if limit == 0 {
 		limit = 10
 	}
 
-	result, err := h.coreClient.SessionSearch(c.Request.Context(), req.UserID, req.ProjectID, req.Query, limit)
+	result, err := h.coreClient.SessionSearch(c.Request.Context(), user.ID.String(), project.ID.String(), req.Query, limit)
 	if err != nil {
 		c.JSON(http.StatusInternalServerError, serializer.Err(http.StatusInternalServerError, "failed to search sessions", err))
 		return

src/server/api/go/internal/modules/handler/user_test.go

@@ -30,6 +30,14 @@ func (m *MockUserService) GetOrCreate(ctx context.Context, projectID uuid.UUID,
 	return args.Get(0).(*model.User), args.Error(1)
 }
 
+func (m *MockUserService) GetByIdentifier(ctx context.Context, projectID uuid.UUID, identifier string) (*model.User, error) {
+	args := m.Called(ctx, projectID, identifier)
+	if args.Get(0) == nil {
+		return nil, args.Error(1)
+	}
+	return args.Get(0).(*model.User), args.Error(1)
+}
+
 func (m *MockUserService) Delete(ctx context.Context, projectID uuid.UUID, identifier string) error {
 	args := m.Called(ctx, projectID, identifier)
 	return args.Error(0)

src/server/api/go/internal/modules/service/user.go

@@ -13,6 +13,7 @@ import (
 
 type UserService interface {
 	GetOrCreate(ctx context.Context, projectID uuid.UUID, identifier string) (*model.User, error)
+	GetByIdentifier(ctx context.Context, projectID uuid.UUID, identifier string) (*model.User, error)
 	Delete(ctx context.Context, projectID uuid.UUID, identifier string) error
 	List(ctx context.Context, in ListUsersInput) (*ListUsersOutput, error)
 	GetResourceCounts(ctx context.Context, projectID uuid.UUID, identifier string) (*GetUserResourcesOutput, error)
@@ -33,6 +34,13 @@ func (s *userService) GetOrCreate(ctx context.Context, projectID uuid.UUID, iden
 	return s.r.GetOrCreate(ctx, projectID, identifier)
 }
 
+func (s *userService) GetByIdentifier(ctx context.Context, projectID uuid.UUID, identifier string) (*model.User, error) {
+	if identifier == "" {
+		return nil, errors.New("user identifier is empty")
+	}
+	return s.r.GetByIdentifier(ctx, projectID, identifier)
+}
+
 func (s *userService) Delete(ctx context.Context, projectID uuid.UUID, identifier string) error {
 	if identifier == "" {
 		return errors.New("user identifier is empty")