Function resolvePush

apps/web/services/push/index.ts:166–216

({
  channel,
  userId,
  event,
  communityId,
}: {
  channel: {
    id: string;
    memberships: {
      archived: boolean | null;
      user: {
        id: string;
        authsId: string | null;
      };
    }[];
    type: ChannelType | null;
  } | null;
  userId: string | undefined;
  event: any;
  communityId: string;
})

};

export function resolvePush({
  channel,
  userId,
  event,
  communityId,
}: {
  channel: {
    id: string;
    memberships: {
      archived: boolean | null;
      user: {
        id: string;
        authsId: string | null;
      };
    }[];
    type: ChannelType | null;
  } | null;
  userId: string | undefined;
  event: any;
  communityId: string;
}) {
  const promises: Promise<any>[] = [];

  if (channel?.type === ChannelType.DM) {
    channel.memberships.forEach((member) => {
      if (member.user.id !== userId && member.user.authsId) {
        promises.push(pushUser({ ...event, userId: member.user.authsId }));
      }
    });
  } else if (channel?.type === ChannelType.PRIVATE) {
    channel.memberships.forEach((member) => {
      if (
        member.user.id !== userId &&
        member.user.authsId &&
        !member.archived
      ) {
        promises.push(pushUser({ ...event, userId: member.user.authsId }));
      }
    });
  } else {
    promises.push(
      ...[
        // public push
        push(event),
        pushChannel(event),
        pushCommunity({ ...event, communityId }),
      ]
    );
  }
  return promises;
}