本文详解如何将不支持 Promise 的回调式异步函数（如 SOAP 客户端调用）安全封装为 Promise，避免返回 undefined，并提供 .then() 链式调用与 async/await 两种现代写法。

本文详解如何将不支持 promise 的回调式异步函数（如 soap 客户端调用）安全封装为 promise，避免返回 `undefined`，并提供 `.then()` 链式调用与 `async/await` 两种现代写法。

在 Node.js 或浏览器环境中，许多传统库（如 soap）仍采用「错误优先回调（error-first callback）」模式，例如 CreateCredential(..., callback, options)。这类函数本身不返回 Promise，若直接在 .then() 链中调用却不显式返回值，后续 .then() 将接收到 undefined —— 这正是原代码中 result is undefined 的根本原因。

要解决该问题，核心原则是：所有异步操作必须被统一纳入 Promise 执行流，并确保每一步都显式 return。以下是推荐的实践方案：

✅ 正确封装回调函数为 Promise

使用 new Promise() 包装回调函数，显式处理成功与失败分支：

function createCredentialWithPromise(credentialClient, rpaReservation, rpaResource, rpaReservationDateFormatted, rpaScheduleGrid) {
  return new Promise((resolve, reject) => {
    credentialClient.CredentialService.CredentialPort.CreateCredential(
      {
        Credential: {
          CredentialHolderReference: holderReference,
          CredentialIdentifier: {
            Type: {
              Name: 'pt:PIN',
              FormatType: 'SIMPLE_NUMBER16'
            },
            Value: rpaReservation.access_code
          },
          CredentialAccessProfile: {
            AccessProfileToken: rpaResource.access_control_identifier,
            ValidFrom: `${rpaReservationDateFormatted} ${rpaScheduleGrid.start_hour}:00`,
            ValidTo: `${rpaReservationDateFormatted} ${rpaScheduleGrid.end_hour}:00`
          }
        }
      },
      (err, result) => {
        if (err) {
          console.error('SOAP CreateCredential failed:', err);
          reject(err);
        } else {
          resolve(result); // 注意：此处 resolve(result)，而非 resolve()
        }
      },
      { auth }
    );
  });
}

⚠️ 注意事项：

• reject() 和 resolve() 必须被调用，且仅调用一次；
• 错误对象应完整传递（如 reject(err)），便于上层捕获堆栈与上下文；
• 不要忽略 err 参数，否则异常将静默丢失。

✅ 方案一：链式 .then() 写法（兼容性好）

function _callAccessControl(response, rpaReservation) {
  if (rpaResource.access_control_identifier && !accessControlExist) {
    return soap.createClientAsync(
      'https://ipevia.com/public/files/onvif/credential.wsdl',
      {
        endpoint: 'https://ipevia.com/index.php?OnvifServer',
        forceSoap12Headers: true
      }
    )
      .then(credentialClient =>
        createCredentialWithPromise(
          credentialClient,
          rpaReservation,
          rpaResource,
          rpaReservationDateFormatted,
          rpaScheduleGrid
        )
      )
      .then(result => {
        // result 是 CreateCredential 的响应体（含 Token）
        const token = parseInt(result.Token, 10);
        return rpaReservation.update({
          access_control_identifier: token
        });
      });
  } else {
    return Promise.resolve(rpaReservation); // 统一返回 Promise，保持调用一致性
  }
}

// 调用方式（可正常获取最终更新后的 reservation）
_callAccessControl(response, rpaReservation)
  .then(updatedReservation => {
    console.log('✅ 更新成功:', updatedReservation);
  })
  .catch(err => {
    console.error('❌ 执行失败:', err);
  });

✅ 方案二：async/await 写法（更简洁、可读性强）

async function _callAccessControl(response, rpaReservation) {
  if (rpaResource.access_control_identifier && !accessControlExist) {
    try {
      const credentialClient = await soap.createClientAsync(
        'https://ipevia.com/public/files/onvif/credential.wsdl',
        {
          endpoint: 'https://ipevia.com/index.php?OnvifServer',
          forceSoap12Headers: true
        }
      );

      const result = await createCredentialWithPromise(
        credentialClient,
        rpaReservation,
        rpaResource,
        rpaReservationDateFormatted,
        rpaScheduleGrid
      );

      const token = parseInt(result.Token, 10);
      return await rpaReservation.update({
        access_control_identifier: token
      });
    } catch (err) {
      console.error('SOAP 流程中断:', err);
      throw err; // 保持错误冒泡，由调用方处理
    }
  } else {
    return rpaReservation;
  }
}

? 总结要点

• ❌ 错误模式：在回调中执行 .update() 但未 return 其 Promise → 链断裂 → undefined；
• ✅ 正确模式：每个异步步骤必须 return 一个 Promise，形成连续的数据流；
• ? 封装是关键：将任意回调函数转为 Promise 是标准化、可复用的基础能力；
• ?️ 始终 catch 或 try/catch：防止未处理的 Promise rejection 导致进程崩溃；
• ? 推荐优先使用 async/await：逻辑线性、调试友好、错误处理直观。

遵循以上模式，即可稳健地将遗留回调 API 无缝集成到现代 Promise/async 生态中。