fix(tools): instanceId on duplicate bubbles + pass this.context to HttpBubble

- people-search-tool + company-enrichment-tool: add instanceId to inner FullEnrichBubble calls (require-instance-id)
- reddit-scrape-tool: pass this.context to HttpBubble (no-null-context); type Reddit API response without any

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: zhubzy

packages/bubble-core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bubblelab/bubble-core",
-  "version": "0.1.296",
+  "version": "0.1.297",
   "type": "module",
   "license": "Apache-2.0",
   "main": "./dist/index.js",

packages/bubble-core/src/bubbles/tool-bubble/company-enrichment-tool.ts

@@ -343,41 +343,43 @@ export class CompanyEnrichmentTool extends ToolBubble<
       const { companyIdentifier } = this.params;
       const identifierType = this.detectIdentifierType(companyIdentifier);
 
-      // Build FullEnrich search body based on identifier type.
+      // Build FullEnrich search filters based on identifier type.
       // FullEnrich doesn't support LinkedIn URL search directly — fall back
       // to parsing the slug as a name filter.
-      const params: Record<string, unknown> = {
-        operation: 'company_search',
-        limit: 1,
-        credentials,
-      };
-
+      let filterKey: 'domains' | 'names';
+      let filterValue: string;
       if (identifierType === 'domain') {
-        params.domains = [{ value: companyIdentifier }];
+        filterKey = 'domains';
+        filterValue = companyIdentifier;
       } else if (identifierType === 'linkedin') {
-        // Extract slug: linkedin.com/company/<slug>/... → <slug>
         const match = companyIdentifier.match(
           /linkedin\.com\/company\/([^/?]+)/
         );
-        const slug = match?.[1] ?? companyIdentifier;
-        params.names = [{ value: slug }];
+        filterKey = 'names';
+        filterValue = match?.[1] ?? companyIdentifier;
       } else {
-        params.names = [{ value: companyIdentifier }];
+        filterKey = 'names';
+        filterValue = companyIdentifier;
       }
 
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-      const feResult = await new FullEnrichBubble(
-        params as any,
-        this.context
+      const company_search = await new FullEnrichBubble(
+        {
+          operation: 'company_search',
+          limit: 1,
+          [filterKey]: [{ value: filterValue }],
+          credentials,
+        },
+        this.context,
+        'company_search'
       ).action();
 
-      if (!feResult.success) {
+      if (!company_search.success) {
         return this.createErrorResult(
-          feResult.error || 'FullEnrich company search failed'
+          company_search.error || 'FullEnrich company search failed'
         );
       }
 
-      const data = feResult.data as {
+      const data = company_search.data as {
         companies?: Array<Record<string, unknown>>;
       };
       const company = data.companies?.[0];

packages/bubble-core/src/bubbles/tool-bubble/people-search-tool.ts

@@ -987,57 +987,59 @@ export class PeopleSearchTool extends ToolBubble<
     const feLimit = Math.min(limit, 100);
 
     try {
-      const fullEnrichParams: Record<string, unknown> = {
-        operation: 'people_search',
-        limit: feLimit,
-        credentials,
-      };
-      if (allJobTitles.length > 0)
-        fullEnrichParams.current_position_titles = allJobTitles.map((v) => ({
-          value: v,
-        }));
-      if (companyName)
-        fullEnrichParams.current_company_names = [{ value: companyName }];
-      if (pastCompanyName)
-        fullEnrichParams.past_company_names = [{ value: pastCompanyName }];
-      if (allLocations.length > 0)
-        fullEnrichParams.person_locations = allLocations.map((v) => ({
-          value: v,
-        }));
-      if (skills?.length)
-        fullEnrichParams.person_skills = skills.map((v) => ({ value: v }));
-      if (seniorityLevels?.length)
-        fullEnrichParams.current_position_seniority_level = seniorityLevels.map(
-          (v) => ({ value: v })
-        );
-      if (companyIndustries?.length)
-        fullEnrichParams.current_company_industries = companyIndustries.map(
-          (v) => ({ value: v })
-        );
-      if (
-        minCompanyHeadcount !== undefined ||
-        maxCompanyHeadcount !== undefined
-      ) {
-        const range: { min?: number; max?: number } = {};
-        if (minCompanyHeadcount !== undefined) range.min = minCompanyHeadcount;
-        if (maxCompanyHeadcount !== undefined) range.max = maxCompanyHeadcount;
-        fullEnrichParams.current_company_headcounts = [range];
-      }
-      if (cursor) fullEnrichParams.search_after = cursor;
+      const headcountRange: { min?: number; max?: number } = {};
+      if (minCompanyHeadcount !== undefined)
+        headcountRange.min = minCompanyHeadcount;
+      if (maxCompanyHeadcount !== undefined)
+        headcountRange.max = maxCompanyHeadcount;
 
-      // eslint-disable-next-line @typescript-eslint/no-explicit-any
-      const feResult = await new FullEnrichBubble(
-        fullEnrichParams as any,
-        this.context
+      const people_search = await new FullEnrichBubble(
+        {
+          operation: 'people_search',
+          limit: feLimit,
+          ...(allJobTitles.length > 0 && {
+            current_position_titles: allJobTitles.map((v) => ({ value: v })),
+          }),
+          ...(companyName && {
+            current_company_names: [{ value: companyName }],
+          }),
+          ...(pastCompanyName && {
+            past_company_names: [{ value: pastCompanyName }],
+          }),
+          ...(allLocations.length > 0 && {
+            person_locations: allLocations.map((v) => ({ value: v })),
+          }),
+          ...(skills?.length && {
+            person_skills: skills.map((v) => ({ value: v })),
+          }),
+          ...(seniorityLevels?.length && {
+            current_position_seniority_level: seniorityLevels.map((v) => ({
+              value: v,
+            })),
+          }),
+          ...(companyIndustries?.length && {
+            current_company_industries: companyIndustries.map((v) => ({
+              value: v,
+            })),
+          }),
+          ...((minCompanyHeadcount !== undefined ||
+            maxCompanyHeadcount !== undefined) && {
+            current_company_headcounts: [headcountRange],
+          }),
+          ...(cursor && { search_after: cursor }),
+          credentials,
+        },
+        this.context,
+        'people_search'
       ).action();
 
-      if (!feResult.success) {
+      if (!people_search.success) {
         return this.createErrorResult(
-          feResult.error || 'FullEnrich people search failed'
+          people_search.error || 'FullEnrich people search failed'
         );
       }
 
-      const data = feResult.data as {
+      const data = people_search.data as {
         people?: Array<Record<string, unknown>>;
         metadata?: {
           total: number;

packages/bubble-core/src/bubbles/tool-bubble/reddit-scrape-tool.ts

@@ -4,6 +4,25 @@ import type { BubbleContext } from '../../types/bubble.js';
 import { CredentialType, type BubbleName } from '@bubblelab/shared-schemas';
 import { HttpBubble } from '../service-bubble/http.js';
 
+// Raw Reddit API post shape — subset of fields we read.
+interface RedditApiPost {
+  title?: string;
+  url?: string;
+  author?: string;
+  score?: number;
+  num_comments?: number;
+  created_utc?: number;
+  permalink?: string;
+  selftext?: string;
+  selftext_html?: string;
+  is_self?: boolean;
+  subreddit?: string;
+  post_hint?: string;
+  thumbnail?: string;
+  domain?: string;
+  link_flair_text?: string;
+}
+
 // Reddit post structure schema
 const RedditPostSchema = z.object({
   title: z.string().describe('Post title'),
@@ -304,7 +323,8 @@ export class RedditScrapeTool extends ToolBubble<
         }
 
         // Get the 'after' parameter for next page
-        after = redditData?.data?.after || null;
+        const listing = redditData as { data?: { after?: string } } | undefined;
+        after = listing?.data?.after ?? null;
 
         // If no more posts available, break
         if (!after || posts.length === 0) {
@@ -355,24 +375,27 @@ export class RedditScrapeTool extends ToolBubble<
   /**
    * Fetch data from Reddit's JSON API via HttpBubble (wall-clock timeout via AbortController).
    */
-  private async fetchRedditData(url: string): Promise<any> {
-    const result = await new HttpBubble({
-      url,
-      method: 'GET',
-      headers: {
-        'User-Agent': this.getRandomUserAgent(),
+  private async fetchRedditData(url: string): Promise<unknown> {
+    const reddit_http = await new HttpBubble(
+      {
+        url,
+        method: 'GET',
+        headers: {
+          'User-Agent': this.getRandomUserAgent(),
+        },
+        timeout: 15000,
+        followRedirects: true,
       },
-      timeout: 15000,
-      followRedirects: true,
-    }).action();
+      this.context
+    ).action();
 
-    if (!result.success || !result.data) {
+    if (!reddit_http.success || !reddit_http.data) {
       throw new Error(
-        `Network error: ${result.error ?? 'HttpBubble returned no data'}`
+        `Network error: ${reddit_http.error ?? 'HttpBubble returned no data'}`
       );
     }
 
-    const { status, statusText, json, body } = result.data;
+    const { status, statusText, json, body } = reddit_http.data;
     if (status !== 200) {
       throw new Error(`Reddit API returned status ${status}: ${statusText}`);
     }
@@ -389,8 +412,11 @@ export class RedditScrapeTool extends ToolBubble<
   /**
    * Parse Reddit JSON response into standardized post objects
    */
-  private parseRedditResponse(data: any): RedditPost[] {
+  private parseRedditResponse(raw: unknown): RedditPost[] {
     const posts: RedditPost[] = [];
+    const data = raw as
+      | { data?: { children?: Array<{ data?: RedditApiPost }> } }
+      | undefined;
 
     try {
       if (data?.data?.children) {

packages/bubble-runtime/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bubblelab/bubble-runtime",
-  "version": "0.1.296",
+  "version": "0.1.297",
   "type": "module",
   "license": "Apache-2.0",
   "main": "./dist/index.js",

packages/bubble-scope-manager/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bubblelab/ts-scope-manager",
-  "version": "0.1.296",
+  "version": "0.1.297",
   "private": false,
   "license": "MIT",
   "type": "commonjs",

packages/bubble-shared-schemas/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@bubblelab/shared-schemas",
-  "version": "0.1.296",
+  "version": "0.1.297",
   "type": "module",
   "license": "Apache-2.0",
   "main": "./dist/index.js",

packages/create-bubblelab-app/package.json

@@ -1,6 +1,6 @@
 {
   "name": "create-bubblelab-app",
-  "version": "0.1.296",
+  "version": "0.1.297",
   "type": "module",
   "license": "Apache-2.0",
   "description": "Create BubbleLab AI agent applications with one command",

packages/create-bubblelab-app/templates/basic/package.json

@@ -11,9 +11,9 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@bubblelab/bubble-core": "^0.1.296",
-    "@bubblelab/bubble-runtime": "^0.1.296",
-    "@bubblelab/shared-schemas": "^0.1.296",
+    "@bubblelab/bubble-core": "^0.1.297",
+    "@bubblelab/bubble-runtime": "^0.1.297",
+    "@bubblelab/shared-schemas": "^0.1.297",
     "dotenv": "^16.4.5"
   },
   "devDependencies": {

packages/create-bubblelab-app/templates/reddit-scraper/package.json

@@ -11,8 +11,8 @@
     "typecheck": "tsc --noEmit"
   },
   "dependencies": {
-    "@bubblelab/bubble-core": "^0.1.296",
-    "@bubblelab/bubble-runtime": "^0.1.296",
+    "@bubblelab/bubble-core": "^0.1.297",
+    "@bubblelab/bubble-runtime": "^0.1.297",
     "dotenv": "^16.4.5"
   },
   "devDependencies": {