Add manage conversation after sending message

Author: LordOfTheVillage

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@linkedapi/node",
-  "version": "2.2.0",
+  "version": "2.2.1",
   "description": "Control your LinkedIn accounts and retrieve real-time data, all through this Node.js SDK.",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/mappers/index.ts

@@ -1,5 +1,6 @@
 export * from './base-mapper.abstract';
 export * from './then-workflow-mapper.abstract';
 export * from './array-workflow-mapper';
+export * from './send-message-mapper';
 export * from './simple-workflow-mapper';
 export * from './void-workflow-mapper';

src/mappers/send-message-mapper.ts

@@ -0,0 +1,63 @@
+import { TSendMessageParams } from '../types';
+import { TLinkedApiActionError } from '../types/errors';
+import type {
+  TActionResponse,
+  TWorkflowCompletion,
+  TWorkflowDefinition,
+  TWorkflowSingleData,
+} from '../types/workflows';
+
+import { BaseMapper, TMappedResponse } from './base-mapper.abstract';
+
+export class SendMessageMapper extends BaseMapper<TSendMessageParams, void> {
+  public mapRequest(params: TSendMessageParams): TWorkflowDefinition {
+    const { manageConversation, ...rest } = params;
+
+    const definition: Record<string, unknown> = {
+      actionType: 'st.sendMessage',
+      ...rest,
+    };
+
+    // The child st.manageConversation acts on the conversation this message was sent into, so it
+    // carries only `operation` — no threadId. Core rejects a threadId on a child manageConversation.
+    // Guard on `operation` so an empty passthrough (e.g. Make sending `{ operation: '' }`) is ignored.
+    if (manageConversation?.operation) {
+      definition.then = {
+        actionType: 'st.manageConversation',
+        operation: manageConversation.operation,
+      };
+    }
+
+    return definition as unknown as TWorkflowDefinition;
+  }
+
+  public mapResponse(completion: TWorkflowCompletion): TMappedResponse<void> {
+    if (Array.isArray(completion)) {
+      return {
+        data: undefined,
+        errors: completion.map((action) => action.error).filter(Boolean) as TLinkedApiActionError[],
+      };
+    }
+
+    const errors: TLinkedApiActionError[] = [];
+
+    if (completion.error) {
+      errors.push(completion.error);
+    }
+
+    const thenActions = (completion.data as TWorkflowSingleData | undefined)?.then;
+    if (thenActions) {
+      const childActions = Array.isArray(thenActions) ? thenActions : [thenActions];
+      for (const child of childActions as TActionResponse[]) {
+        if (child.error) {
+          errors.push(child.error);
+        }
+      }
+    }
+
+    return {
+      data: undefined,
+      errors,
+    };
+  }
+}

src/operations/send-message.ts

@@ -1,8 +1,8 @@
 import { Operation, TOperationName } from '../core';
-import { VoidWorkflowMapper } from '../mappers/void-workflow-mapper';
+import { SendMessageMapper } from '../mappers/send-message-mapper';
 import { TSendMessageParams } from '../types';
 
 export class SendMessage extends Operation<TSendMessageParams, void> {
   public override readonly operationName: TOperationName = 'sendMessage';
-  protected override readonly mapper = new VoidWorkflowMapper<TSendMessageParams>('st.sendMessage');
+  protected override readonly mapper = new SendMessageMapper();
 }

src/types/actions/message.ts

@@ -4,6 +4,11 @@ export interface TSendMessageParams extends TBaseActionParams {
   personUrl?: string;
   text: string;
   threadId?: string;
+  manageConversation?: TSendMessageManageConversation;
+}
+
+export interface TSendMessageManageConversation {
+  operation: TManageConversationOperation;
 }
 
 export interface TSyncConversationParams extends TBaseActionParams {