removed limit from neo4j block

Author: waleedlatif1

apps/docs/content/docs/en/tools/memory.mdx

@@ -26,10 +26,11 @@ Add a new memory to the database or append to existing memory with the same ID.
 
 | Parameter | Type | Required | Description |
 | --------- | ---- | -------- | ----------- |
-| `conversationId` | string | Yes | Conversation identifier \(e.g., user-123, session-abc\). If a memory with this conversationId already exists for this block, the new message will be appended to it. |
+| `conversationId` | string | No | Conversation identifier \(e.g., user-123, session-abc\). If a memory with this conversationId already exists for this block, the new message will be appended to it. |
+| `id` | string | No | Legacy parameter for conversation identifier. Use conversationId instead. Provided for backwards compatibility. |
 | `role` | string | Yes | Role for agent memory \(user, assistant, or system\) |
 | `content` | string | Yes | Content for agent memory |
-| `blockId` | string | No | Optional block ID. If not provided, uses the current block ID from execution context. |
+| `blockId` | string | No | Optional block ID. If not provided, uses the current block ID from execution context, or defaults to "default". |
 
 #### Output
 
@@ -48,6 +49,7 @@ Retrieve memory by conversationId, blockId, blockName, or a combination. Returns
 | Parameter | Type | Required | Description |
 | --------- | ---- | -------- | ----------- |
 | `conversationId` | string | No | Conversation identifier \(e.g., user-123, session-abc\). If provided alone, returns all memories for this conversation across all blocks. |
+| `id` | string | No | Legacy parameter for conversation identifier. Use conversationId instead. Provided for backwards compatibility. |
 | `blockId` | string | No | Block identifier. If provided alone, returns all memories for this block across all conversations. If provided with conversationId, returns memories for that specific conversation in this block. |
 | `blockName` | string | No | Block name. Alternative to blockId. If provided alone, returns all memories for blocks with this name. If provided with conversationId, returns memories for that conversation in blocks with this name. |
 
@@ -87,6 +89,7 @@ Delete memories by conversationId, blockId, blockName, or a combination. Support
 | Parameter | Type | Required | Description |
 | --------- | ---- | -------- | ----------- |
 | `conversationId` | string | No | Conversation identifier \(e.g., user-123, session-abc\). If provided alone, deletes all memories for this conversation across all blocks. |
+| `id` | string | No | Legacy parameter for conversation identifier. Use conversationId instead. Provided for backwards compatibility. |
 | `blockId` | string | No | Block identifier. If provided alone, deletes all memories for this block across all conversations. If provided with conversationId, deletes memories for that specific conversation in this block. |
 | `blockName` | string | No | Block name. Alternative to blockId. If provided alone, deletes all memories for blocks with this name. If provided with conversationId, deletes memories for that conversation in blocks with this name. |
 

apps/docs/content/docs/en/tools/neo4j.mdx

@@ -20,7 +20,7 @@ Integrate Neo4j graph database into the workflow. Can query, create, merge, upda
 
 ### `neo4j_query`
 
-Execute MATCH queries to read nodes and relationships from Neo4j graph database
+Execute MATCH queries to read nodes and relationships from Neo4j graph database. For best performance and to prevent large result sets, include LIMIT in your query (e.g., 
 
 #### Input
 
@@ -33,8 +33,8 @@ Execute MATCH queries to read nodes and relationships from Neo4j graph database
 | `password` | string | Yes | Neo4j password |
 | `encryption` | string | No | Connection encryption mode \(enabled, disabled\) |
 | `cypherQuery` | string | Yes | Cypher query to execute \(typically MATCH statements\) |
-| `parameters` | object | No | Parameters for the Cypher query as a JSON object |
-| `limit` | number | No | Maximum number of records to return |
+| `parameters` | object | No | Parameters for the Cypher query as a JSON object. Use for any dynamic values including LIMIT \(e.g., query: "MATCH \(n\) RETURN n LIMIT $limit", parameters: \{limit: 100\}\). |
+| `parameters` | string | No | No description |
 
 #### Output
 

apps/sim/app/api/tools/neo4j/query/route.ts

@@ -19,15 +19,6 @@ const QuerySchema = z.object({
   encryption: z.enum(['enabled', 'disabled']).default('disabled'),
   cypherQuery: z.string().min(1, 'Cypher query is required'),
   parameters: z.record(z.unknown()).nullable().optional().default({}),
-  limit: z
-    .union([z.coerce.number().int().positive(), z.literal(''), z.undefined()])
-    .optional()
-    .transform((val) => {
-      if (val === '' || val === undefined || val === null) {
-        return undefined
-      }
-      return val
-    }),
 })
 
 export async function POST(request: NextRequest) {
@@ -63,14 +54,7 @@ export async function POST(request: NextRequest) {
 
     session = driver.session({ database: params.database })
 
-    let finalQuery = params.cypherQuery.trim()
-    const finalParameters = { ...params.parameters }
-    if (params.limit && !/\bLIMIT\s+\d+/i.test(finalQuery)) {
-      finalQuery = `${finalQuery} LIMIT $limitValue`
-      finalParameters.limitValue = params.limit
-    }
-
-    const result = await session.run(finalQuery, finalParameters)
+    const result = await session.run(params.cypherQuery, params.parameters)
 
     const records = result.records.map((record) => {
       const obj: Record<string, unknown> = {}

apps/sim/blocks/blocks/neo4j.ts

@@ -100,21 +100,30 @@ Return ONLY the Cypher query. Do not include any explanations, markdown formatti
 2. **Filtering**: Use WHERE clauses for conditions
 3. **Return**: Specify what to return with RETURN
 4. **Performance**: Use indexes when possible
-5. **Limit Results**: Add LIMIT for large result sets
+5. **Limit Results**: ALWAYS include LIMIT to prevent large result sets
+
+### IMPORTANT: LIMIT Best Practices
+- Always include LIMIT in your queries to prevent performance issues
+- Use parameterized LIMIT for flexibility: LIMIT $limit
+- Place LIMIT at the end after ORDER BY and SKIP clauses
+- Example: MATCH (n:Person) RETURN n ORDER BY n.name LIMIT $limit
 
 ### CYPHER QUERY PATTERNS
 
-**Basic Node Match**:
+**Basic Node Match with LIMIT**:
 MATCH (n:Person) RETURN n LIMIT 25
 
+**Match with Parameterized LIMIT (Recommended)**:
+MATCH (n:Person) RETURN n LIMIT $limit
+
 **Match with Properties**:
 MATCH (n:Person {name: "Alice"}) RETURN n
 
 **Match with Parameters (Recommended)**:
-MATCH (n:Person {name: $name}) RETURN n
+MATCH (n:Person {name: $name}) RETURN n LIMIT 100
 
 **Match with WHERE and Parameters**:
-MATCH (n:Person) WHERE n.age > $minAge RETURN n.name, n.age
+MATCH (n:Person) WHERE n.age > $minAge RETURN n.name, n.age LIMIT $limit
 
 **Match Relationship**:
 MATCH (p:Person)-[:KNOWS]->(friend:Person) RETURN p.name, friend.name
@@ -571,13 +580,6 @@ Return ONLY valid JSON.`,
         generationType: 'neo4j-parameters',
       },
     },
-    {
-      id: 'limit',
-      title: 'Limit Results',
-      type: 'short-input',
-      placeholder: '100',
-      condition: { field: 'operation', value: 'query' },
-    },
   ],
   tools: {
     access: [
@@ -653,11 +655,6 @@ Return ONLY valid JSON.`,
           result.parameters = undefined
         }
 
-        if (rest.limit && rest.limit !== '') {
-          result.limit =
-            typeof rest.limit === 'string' ? Number.parseInt(rest.limit, 10) : rest.limit
-        }
-
         if (rest.detach !== undefined) {
           result.detach = rest.detach === 'true' || rest.detach === true
         }
@@ -676,7 +673,6 @@ Return ONLY valid JSON.`,
     encryption: { type: 'string', description: 'Connection encryption mode' },
     cypherQuery: { type: 'string', description: 'Cypher query to execute' },
     parameters: { type: 'json', description: 'Query parameters as JSON object' },
-    limit: { type: 'number', description: 'Limit number of records' },
     detach: { type: 'boolean', description: 'Use DETACH DELETE for delete operations' },
   },
   outputs: {

apps/sim/tools/neo4j/query.ts

@@ -4,7 +4,8 @@ import type { ToolConfig } from '@/tools/types'
 export const queryTool: ToolConfig<Neo4jQueryParams, Neo4jResponse> = {
   id: 'neo4j_query',
   name: 'Neo4j Query',
-  description: 'Execute MATCH queries to read nodes and relationships from Neo4j graph database',
+  description:
+    'Execute MATCH queries to read nodes and relationships from Neo4j graph database. For best performance and to prevent large result sets, include LIMIT in your query (e.g., "MATCH (n:User) RETURN n LIMIT 100") or use LIMIT $limit with a limit parameter.',
   version: '1.0',
 
   params: {
@@ -54,13 +55,8 @@ export const queryTool: ToolConfig<Neo4jQueryParams, Neo4jResponse> = {
       type: 'object',
       required: false,
       visibility: 'user-or-llm',
-      description: 'Parameters for the Cypher query as a JSON object',
-    },
-    limit: {
-      type: 'number',
-      required: false,
-      visibility: 'user-or-llm',
-      description: 'Maximum number of records to return',
+      description:
+        'Parameters for the Cypher query as a JSON object. Use for any dynamic values including LIMIT (e.g., query: "MATCH (n) RETURN n LIMIT $limit", parameters: {limit: 100}).',
     },
   },
 
@@ -79,7 +75,6 @@ export const queryTool: ToolConfig<Neo4jQueryParams, Neo4jResponse> = {
       encryption: params.encryption || 'disabled',
       cypherQuery: params.cypherQuery,
       parameters: params.parameters,
-      limit: params.limit ? Number(params.limit) : undefined,
     }),
   },
 

apps/sim/tools/neo4j/types.ts

@@ -12,7 +12,6 @@ export interface Neo4jConnectionConfig {
 export interface Neo4jQueryParams extends Neo4jConnectionConfig {
   cypherQuery: string
   parameters?: Record<string, unknown>
-  limit?: number
 }
 
 export interface Neo4jCreateParams extends Neo4jConnectionConfig {