Add image and link support to social share nodes, standardize naming

- LinkedIn Share Post: add image upload (register + upload to Digital Media API)
  and link attachment (ARTICLE media category) support
- Reddit Share Post: add image upload (S3 lease + upload) support with kind=image
- Rename Reddit submit-post-reddit → share-post-reddit and X create-post-x →
  share-post-x for consistent naming across all social integrations

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

Author: bchapuis

apps/api/src/runtime/cloudflare-node-registry.ts

@@ -390,8 +390,8 @@ import { ListUserCommentsRedditNode } from "@dafthunk/runtime/nodes/reddit/list-
 import { ListUserPostsRedditNode } from "@dafthunk/runtime/nodes/reddit/list-user-posts-reddit-node";
 import { SearchRedditNode } from "@dafthunk/runtime/nodes/reddit/search-reddit-node";
 import { SearchSubredditsRedditNode } from "@dafthunk/runtime/nodes/reddit/search-subreddits-reddit-node";
+import { SharePostRedditNode } from "@dafthunk/runtime/nodes/reddit/share-post-reddit-node";
 import { SubmitCommentRedditNode } from "@dafthunk/runtime/nodes/reddit/submit-comment-reddit-node";
-import { SubmitPostRedditNode } from "@dafthunk/runtime/nodes/reddit/submit-post-reddit-node";
 import { VoteRedditNode } from "@dafthunk/runtime/nodes/reddit/vote-reddit-node";
 import { ReplicateModelNode } from "@dafthunk/runtime/nodes/replicate/replicate-model-node";
 import { ReceiveScheduledTriggerNode } from "@dafthunk/runtime/nodes/scheduled/receive-scheduled-trigger-node";
@@ -442,7 +442,6 @@ import { BotReceiveWhatsAppMessageNode } from "@dafthunk/runtime/nodes/whatsapp/
 import { BotSendImageWhatsAppNode } from "@dafthunk/runtime/nodes/whatsapp/bot-send-image-whatsapp-node";
 import { BotSendMessageWhatsAppNode } from "@dafthunk/runtime/nodes/whatsapp/bot-send-message-whatsapp-node";
 import { BotSendTemplateWhatsAppNode } from "@dafthunk/runtime/nodes/whatsapp/bot-send-template-whatsapp-node";
-import { CreatePostXNode } from "@dafthunk/runtime/nodes/x/create-post-x-node";
 import { DeletePostXNode } from "@dafthunk/runtime/nodes/x/delete-post-x-node";
 import { FollowUserXNode } from "@dafthunk/runtime/nodes/x/follow-user-x-node";
 import { GetPostXNode } from "@dafthunk/runtime/nodes/x/get-post-x-node";
@@ -454,6 +453,7 @@ import { ListUserMentionsXNode } from "@dafthunk/runtime/nodes/x/list-user-menti
 import { ListUserPostsXNode } from "@dafthunk/runtime/nodes/x/list-user-posts-x-node";
 import { RepostXNode } from "@dafthunk/runtime/nodes/x/repost-x-node";
 import { SearchPostsXNode } from "@dafthunk/runtime/nodes/x/search-posts-x-node";
+import { SharePostXNode } from "@dafthunk/runtime/nodes/x/share-post-x-node";
 import type { Bindings } from "../context";
 
 export class CloudflareNodeRegistry extends BaseNodeRegistry<Bindings> {
@@ -810,12 +810,12 @@ export class CloudflareNodeRegistry extends BaseNodeRegistry<Bindings> {
       this.registerImplementation(SearchRedditNode);
       this.registerImplementation(SearchSubredditsRedditNode);
       this.registerImplementation(SubmitCommentRedditNode);
-      this.registerImplementation(SubmitPostRedditNode);
+      this.registerImplementation(SharePostRedditNode);
       this.registerImplementation(VoteRedditNode);
     }
 
     if (hasX) {
-      this.registerImplementation(CreatePostXNode);
+      this.registerImplementation(SharePostXNode);
       this.registerImplementation(DeletePostXNode);
       this.registerImplementation(FollowUserXNode);
       this.registerImplementation(GetPostXNode);

apps/www/data/categories.json

@@ -127,7 +127,7 @@
         "share-post-linkedin",
         "get-profile-linkedin",
         "list-posts-reddit",
-        "submit-post-reddit",
+        "share-post-reddit",
         "create-event-google-calendar",
         "list-events-google-calendar",
         "send-email-google-mail",

packages/runtime/src/nodes/linkedin/share-post-linkedin-node.ts

@@ -1,9 +1,10 @@
+import type { ImageParameter } from "@dafthunk/runtime";
 import { ExecutableNode, type NodeContext } from "@dafthunk/runtime";
 import type { NodeExecution, NodeType } from "@dafthunk/types";
 
 /**
  * LinkedIn Share Post node implementation
- * Shares a post to LinkedIn
+ * Shares a post to LinkedIn with optional image or link attachment
  */
 export class SharePostLinkedInNode extends ExecutableNode {
   public static readonly nodeType: NodeType = {
@@ -14,7 +15,7 @@ export class SharePostLinkedInNode extends ExecutableNode {
     tags: ["Social", "LinkedIn", "Post", "Share"],
     icon: "send",
     documentation:
-      "This node shares a post to your LinkedIn profile. Supports text content and optional URLs. Requires a connected LinkedIn integration.",
+      "This node shares a post to your LinkedIn profile. Supports text content with optional image or link attachments. Requires a connected LinkedIn integration.",
     usage: 10,
     subscription: true,
     asTool: true,
@@ -33,6 +34,30 @@ export class SharePostLinkedInNode extends ExecutableNode {
         description: "Post text content",
         required: true,
       },
+      {
+        name: "image",
+        type: "image",
+        description: "Optional image to attach to the post",
+        required: false,
+      },
+      {
+        name: "linkUrl",
+        type: "string",
+        description: "Optional link URL to attach to the post",
+        required: false,
+      },
+      {
+        name: "linkTitle",
+        type: "string",
+        description: "Title for the link attachment",
+        required: false,
+      },
+      {
+        name: "linkDescription",
+        type: "string",
+        description: "Description for the link attachment",
+        required: false,
+      },
       {
         name: "visibility",
         type: "string",
@@ -56,9 +81,95 @@ export class SharePostLinkedInNode extends ExecutableNode {
     ],
   };
 
+  private async registerAndUploadImage(
+    accessToken: string,
+    userId: string,
+    image: ImageParameter
+  ): Promise<string> {
+    // Step 1: Register the upload to get an upload URL and asset URN
+    const registerResponse = await fetch(
+      "https://api.linkedin.com/v2/assets?action=registerUpload",
+      {
+        method: "POST",
+        headers: {
+          Authorization: `Bearer ${accessToken}`,
+          "Content-Type": "application/json",
+          "X-Restli-Protocol-Version": "2.0.0",
+        },
+        body: JSON.stringify({
+          registerUploadRequest: {
+            recipes: ["urn:li:digitalmediaRecipe:feedshare-image"],
+            owner: `urn:li:person:${userId}`,
+            serviceRelationships: [
+              {
+                relationshipType: "OWNER",
+                identifier: "urn:li:userGeneratedContent",
+              },
+            ],
+          },
+        }),
+      }
+    );
+
+    if (!registerResponse.ok) {
+      const errorData = await registerResponse.text();
+      throw new Error(`Failed to register image upload: ${errorData}`);
+    }
+
+    const registerResult = (await registerResponse.json()) as {
+      value: {
+        asset: string;
+        uploadMechanism: {
+          "com.linkedin.digitalmedia.uploading.MediaUploadHttpRequest": {
+            uploadUrl: string;
+          };
+        };
+      };
+    };
+
+    const uploadUrl =
+      registerResult.value.uploadMechanism[
+        "com.linkedin.digitalmedia.uploading.MediaUploadHttpRequest"
+      ].uploadUrl;
+    const assetUrn = registerResult.value.asset;
+
+    // Step 2: Upload the image binary data
+    const uploadResponse = await fetch(uploadUrl, {
+      method: "PUT",
+      headers: {
+        Authorization: `Bearer ${accessToken}`,
+        "Content-Type": image.mimeType,
+      },
+      body: image.data,
+    });
+
+    if (!uploadResponse.ok) {
+      const errorData = await uploadResponse.text();
+      throw new Error(`Failed to upload image: ${errorData}`);
+    }
+
+    return assetUrn;
+  }
+
   async execute(context: NodeContext): Promise<NodeExecution> {
     try {
-      const { integrationId, text, visibility } = context.inputs;
+      const {
+        integrationId,
+        text,
+        image,
+        linkUrl,
+        linkTitle,
+        linkDescription,
+        visibility,
+      } = context.inputs as {
+        integrationId?: string;
+        text?: string;
+        image?: ImageParameter;
+        linkUrl?: string;
+        linkTitle?: string;
+        linkDescription?: string;
+        visibility?: string;
+      };
       const { organizationId } = context;
 
       // Validate required inputs
@@ -76,6 +187,13 @@ export class SharePostLinkedInNode extends ExecutableNode {
         return this.createErrorResult("Organization ID is required");
       }
 
+      // Cannot attach both image and link
+      if (image?.data && linkUrl) {
+        return this.createErrorResult(
+          "Cannot attach both an image and a link. Please provide only one."
+        );
+      }
+
       // Validate visibility
       const postVisibility =
         visibility && typeof visibility === "string"
@@ -89,7 +207,6 @@ export class SharePostLinkedInNode extends ExecutableNode {
 
       // Get integration with auto-refreshed token
       const integration = await context.getIntegration(integrationId);
-
       const accessToken = integration.token;
 
       // Get user's LinkedIn ID from metadata
@@ -102,17 +219,54 @@ export class SharePostLinkedInNode extends ExecutableNode {
         );
       }
 
+      // Build share content based on attachment type
+      let shareMediaCategory = "NONE";
+      const media: Array<Record<string, unknown>> = [];
+
+      if (image?.data && image?.mimeType) {
+        // Upload image and get asset URN
+        const assetUrn = await this.registerAndUploadImage(
+          accessToken,
+          userId,
+          image
+        );
+        shareMediaCategory = "IMAGE";
+        media.push({
+          status: "READY",
+          media: assetUrn,
+        });
+      } else if (linkUrl && typeof linkUrl === "string") {
+        shareMediaCategory = "ARTICLE";
+        const linkMedia: Record<string, unknown> = {
+          status: "READY",
+          originalUrl: linkUrl,
+        };
+        if (linkTitle && typeof linkTitle === "string") {
+          linkMedia.title = { text: linkTitle };
+        }
+        if (linkDescription && typeof linkDescription === "string") {
+          linkMedia.description = { text: linkDescription };
+        }
+        media.push(linkMedia);
+      }
+
       // Prepare post data using LinkedIn UGC Post API
+      const shareContent: Record<string, unknown> = {
+        shareCommentary: {
+          text: text as string,
+        },
+        shareMediaCategory,
+      };
+
+      if (media.length > 0) {
+        shareContent.media = media;
+      }
+
       const postData = {
         author: `urn:li:person:${userId}`,
         lifecycleState: "PUBLISHED",
         specificContent: {
-          "com.linkedin.ugc.ShareContent": {
-            shareCommentary: {
-              text: text as string,
-            },
-            shareMediaCategory: "NONE",
-          },
+          "com.linkedin.ugc.ShareContent": shareContent,
         },
         visibility: {
           "com.linkedin.ugc.MemberNetworkVisibility": postVisibility,

…t/submit-post-reddit-node.integration.ts …it/share-post-reddit-node.integration.tspackages/runtime/src/nodes/reddit/submit-post-reddit-node.integration.ts renamed to packages/runtime/src/nodes/reddit/share-post-reddit-node.integration.ts packages/runtime/src/nodes/reddit/submit-post-reddit-node.integration.ts renamed to packages/runtime/src/nodes/reddit/share-post-reddit-node.integration.ts

@@ -6,18 +6,18 @@ import {
   REDDIT_TEST_CONFIG,
   skipIfNoRedditToken,
 } from "./reddit-test-helper";
-import { SubmitPostRedditNode } from "./submit-post-reddit-node";
+import { SharePostRedditNode } from "./share-post-reddit-node";
 
-describe("SubmitPostRedditNode", () => {
+describe("SharePostRedditNode", () => {
   it.skipIf(skipIfNoRedditToken())(
-    "should submit a text post to r/dafthunk_test",
+    "should share a text post to r/dafthunk_test",
     async () => {
-      const node = new SubmitPostRedditNode({
-        nodeId: "submit-post-reddit",
+      const node = new SharePostRedditNode({
+        nodeId: "share-post-reddit",
       } as unknown as Node);
 
       const timestamp = Date.now();
-      const context = createRedditTestContext("submit-post-reddit", {
+      const context = createRedditTestContext("share-post-reddit", {
         subreddit: REDDIT_TEST_CONFIG.subreddit,
         title: `Integration Test Post ${timestamp}`,
         kind: "self",