feat: Added WPP.call.accept function

src/call/functions/acceptCall.ts

@@ -0,0 +1,130 @@
+/*!
+ * Copyright 2021 WPPConnect Team
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+import { WPPError } from '../../util';
+import { CallModel, CallStore, websocket } from '../../whatsapp';
+import { CALL_STATES } from '../../whatsapp/enums';
+
+/**
+ * Accept a incoming call
+ *
+ * @example
+ * ```javascript
+ * // Accept any incoming call
+ * WPP.call.acceptCall();
+ *
+ * // Accept specific call id
+ * WPP.call.acceptCall(callId);
+ *
+ * // Accept any incoming call
+ * WPP.on('call.incoming_call', (call) => {
+ *   WPP.call.acceptCall(call.id);
+ * });
+ * ```
+ *
+ * @param   {string}  callId  The call ID, empty to accept the first one
+ * @return  {[type]}          [return description]
+ */
+export async function acceptCall(callId?: string): Promise<boolean> {
+  let call: CallModel | undefined = undefined;
+
+  if (callId) {
+    call = CallStore.get(callId);
+  } else {
+    // First incoming ring or call group
+    call = CallStore.findFirst(
+      (c) => c.getState() === CALL_STATES.INCOMING_RING || c.isGroup
+    );
+  }
+
+  if (!call) {
+    throw new WPPError(
+      'call_not_found',
+      `Call ${callId || '<empty>'} not found`,
+      {
+        callId,
+      }
+    );
+  }
+
+  if (call.getState() !== 'INCOMING_RING' && !call.isGroup) {
+    throw new WPPError(
+      'call_is_not_incoming_ring',
+      `Call ${callId || '<empty>'} is not incoming ring`,
+      {
+        callId,
+        state: call.getState(),
+      }
+    );
+  }
+
+  if (!call.peerJid.isGroupCall()) {
+    await websocket.ensureE2ESessions([call.peerJid]);
+  }
+
+  const content = [
+    websocket.smax('audio', { enc: 'opus', rate: '16000' }, null),
+    websocket.smax('audio', { enc: 'opus', rate: '8000' }, null),
+  ];
+
+  if (call.isVideo) {
+    content.push(
+      websocket.smax(
+        'video',
+        {
+          orientation: '0',
+          screen_width: '1920',
+          screen_height: '1080',
+          device_orientation: '0',
+          enc: 'vp8',
+          dec: 'vp8',
+        },
+        null
+      )
+    );
+  }
+
+  content.push(
+    ...[
+      websocket.smax('net', { medium: '3' }, null),
+      websocket.smax('encopt', { keygen: '2' }, null),
+    ]
+  );
+
+  const node = websocket.smax(
+    'call',
+    {
+      to: call.peerJid.toString({ legacy: true }),
+      id: websocket.generateId(),
+    },
+    [
+      websocket.smax(
+        'accept',
+        {
+          'call-id': call.id,
+          'call-creator': call.peerJid.toString({ legacy: true }),
+        },
+        content
+      ),
+    ]
+  );
+
+  console.log(node);
+
+  console.log(await websocket.sendSmaxStanza(node));
+
+  return true;
+}

src/call/functions/index.ts

@@ -14,6 +14,7 @@
  * limitations under the License.
  */
 
+export { acceptCall } from './acceptCall';
 export { endCall } from './endCall';
 export { rejectCall } from './rejectCall';
 export { sendCallOffer } from './sendCallOffer';