TypeScript/NestJS中Observable值判断与Agent ID存在性检查问题

我正在学习TypeScript/NestJS，对subscribe概念仍不太理解。我需要检查传入的ID是否存在于数据库中：存在则判定为Agent，否则为Customer，但当前代码无论传入什么ID都会返回true。

现有代码 #

getAgent方法 #

getAgent(agentId: number) {
    const agent$ = from(
        this.agentRepository.findAll({
            attributes: ['agentId'],
            where: {
                agentId: {
                    [Op.eq]: agentId
                }
            }
        })
    );
    return agent$;
}

该方法返回的接口结果示例：

[
  {
    "agentId": 1234567890
  }
]

调用逻辑 #

if (event.author_id === -1) {
    update_actor = 'system';
    source_status = 0;
} else if (this.getAgent(event.author_id)) {
  console.log(this.getAgent(event.author_id));

  update_actor = 'agent';
} else {
update_actor = 'customer';
source_status = 1;
}

尝试过的操作及问题 #

• 添加subscribe()后，控制台输出的是Observable对象而非实际数据：

{
    "closed": false,
    "_parentage": null,
    "_finalizers": null,
    "isStopped": false,
    "destination": {
        "partialObserver": {}
    }
}

• 使用getValue()报错：Property 'getValue' does not exist on type 'Observable<Agent[]>'
• 尝试用pipe转换数据：

const foundAgentId = agent.pipe(
  map(async (agent) => agent.map(({ agentId }) => agentId))
);

此时返回结果为[ 1234567890 ]（存在记录）或[]（无记录），但仍不知道如何用于判断。

我的问题 #

1. 如何让方法返回true/false？
2. 若返回完整Agent列表，如何实现类似agentList.includes(123456780)的判断？

解决方案 #

问题1：让方法返回true/false（判断ID是否存在） #

修改getAgent方法，利用RxJS操作符将Observable转换为布尔值的Observable：

getAgentExists(agentId: number): Observable<boolean> {
  return from(
    this.agentRepository.findAll({
      attributes: ['agentId'],
      where: { agentId: { [Op.eq]: agentId } }
    })
  ).pipe(
    // 检查返回数组是否有数据，有则为true，否则false
    map(agents => agents.length > 0)
  );
}

Observable是异步流，不能直接在同步if条件中判断，需用以下两种方式调用：

方式1：使用subscribe（异步场景）

if (event.author_id === -1) {
  update_actor = 'system';
  source_status = 0;
} else {
  this.getAgentExists(event.author_id).subscribe(isAgent => {
    update_actor = isAgent ? 'agent' : 'customer';
    if (!isAgent) source_status = 1;
    // 后续逻辑（如数据保存）需放在subscribe内
  });
}

方式2：转为Promise（async/await场景）

若调用代码在async函数中，用firstValueFrom将Observable转为Promise：

async yourBusinessFunction() {
  if (event.author_id === -1) {
    update_actor = 'system';
    source_status = 0;
  } else {
    const isAgent = await firstValueFrom(this.getAgentExists(event.author_id));
    update_actor = isAgent ? 'agent' : 'customer';
    if (!isAgent) source_status = 1;
  }
}

问题2：返回完整Agent列表并判断ID是否存在 #

先修改方法返回Agent数组的Observable：

getAllAgents(): Observable<Agent[]> {
  return from(this.agentRepository.findAll({ attributes: ['agentId'] }));
}

再通过以下方式判断ID是否存在：

方式1：在pipe中处理为布尔值

const targetId = 123456780;
this.getAllAgents().pipe(
  map(agents => agents.some(agent => agent.agentId === targetId))
).subscribe(isExists => {
  // 根据isExists处理逻辑
});

方式2：在subscribe中直接判断

const targetId = 123456780;
this.getAllAgents().subscribe(agents => {
  const agentIds = agents.map(agent => agent.agentId);
  if (agentIds.includes(targetId)) {
    update_actor = 'agent';
  } else {
    update_actor = 'customer';
    source_status = 1;
  }
});

关键注意点 #

• Observable是异步流，不能直接在同步if条件中判断，必须等待异步结果返回后再处理逻辑。
• getValue()仅适用于BehaviorSubject这类有初始值的Subject，普通Observable无法使用该方法。
• 尽量用RxJS操作符（如map、some）在流中处理数据，保持响应式代码风格。

内容的提问来源于stack exchange，提问作者itsjustcarlos