|
|
@ -267,7 +267,7 @@ function postsByUserRoute(server: FastifyInstance<Server, IncomingMessage, Serve |
|
|
|
if (blocks.length > 0) return unauthorizedError(reply) |
|
|
|
} |
|
|
|
|
|
|
|
const userPostsQuery = createQuerySpec(`SELECT p.id FROM Users p WHERE p.pk = @user AND p.t = @type`, { user: id, type: UserItemType.Post }) |
|
|
|
const userPostsQuery = createQuerySpec(`SELECT p.id, p.postId FROM Users p WHERE p.pk = @user AND p.t = @type`, { user: id, type: UserItemType.Post }) |
|
|
|
const userPosts = await queryItems<UserPost>({ |
|
|
|
container: userContainer, |
|
|
|
query: userPostsQuery, |
|
|
@ -277,7 +277,7 @@ function postsByUserRoute(server: FastifyInstance<Server, IncomingMessage, Serve |
|
|
|
const posts = await queryItems<Post>({ |
|
|
|
container: containerFor(server.database.client, 'Posts'), |
|
|
|
query: createQuerySpec('SELECT * FROM Posts p WHERE ARRAY_CONTAINS(@posts, p.id)', { |
|
|
|
posts: userPosts.map(p => p.id!), |
|
|
|
posts: userPosts.map(p => p.postId!), |
|
|
|
}), |
|
|
|
logger: request.log |
|
|
|
}) |
|
|
|