(channelIds: string[])
| 144 | } |
| 145 | |
| 146 | export async function findManyChannelMessagesCounts(channelIds: string[]) { |
| 147 | if (channelIds.length === 0) return Promise.resolve([]); |
| 148 | return dbReplica |
| 149 | .select({ |
| 150 | channelId: dbMessages.channelId, |
| 151 | count: sql<number>`count(*)`, |
| 152 | }) |
| 153 | .from(dbMessages) |
| 154 | .where(inArray(dbMessages.channelId, channelIds)) |
| 155 | .groupBy(dbMessages.channelId); |
| 156 | } |
| 157 | |
| 158 | export async function findLatestThreads(args: { take: number }) { |
| 159 | const data = await dbReplica.query.dbChannels.findMany({ |
no outgoing calls
no test coverage detected