我已经使用 Prisma 建立了一个项目,用于处理与服务器之间的通信/存储/检索数据。它本质上与此处的示例架构相同。唯一的主要区别是我的解析器没有分成不同的文件,它们都驻留在 index.js 中。
现在,我正在尝试实现订阅,它将捕获对我的模型的所有更改。但在我的一生中,除了 DELETE 操作之外,我无法订阅触发任何其他操作。我已经阅读了多个论坛帖子和示例,但问题仍然存在。
我的 index.js 订阅解析器如下所示:
Subscription: {
userChanges: {
subscribe: (_, args, context, info) => {
console.log("CHECKCHECK");
return context.prisma.subscription.user(
{ where: { mutation_in: ['CREATED'] } },
info
)
}
},
taskChanges: {
subscribe: async (_, args, context, info) => {
return await context.prisma.subscription.task({}, info)
}
}
}
我的 schema.graphql 看起来像这样:
# import Task, User from '../generated/prisma.graphql'
# import TaskSubscriptionPayload, UserSubscriptionPayload from '../generated/prisma.graphql'
type Query {
task(id: ID!): Task
tasks: [Task]!
user(id: ID!): User
users: [User!]
getUserTasks(id:ID!): [Task]!
}
type Mutation {
addTask(
name: String!,
priority: Float!,
weight: Int!,
best: Float!,
expected: Float!,
worst: Float!,
calculated: Float!,
stdDev: Float!,
actualTime: Float,
tags: [String!]!,
ownedBy: ID!
): Task!
updateTask(
id: ID!,
name: String!,
priority: Float!,
weight: Int!,
best: Float!,
expected: Float!,
worst: Float!,
calculated: Float!,
stdDev: Float!,
actualTime: Float,
tags: [String!]!,
ownedBy: ID!
): Task!
deleteTask(id: ID!): Task!
addNewUser(name: String!): User!
deleteUser(id:ID!): User!
}
type Subscription {
taskChanges: TaskSubscriptionPayload
userChanges: UserSubscriptionPayload
}
我一定遗漏了一些东西,因为我在 Prisma 论坛上发现的任何/所有问题都已在 3 月份通过修复解决。我怀疑这可能与 Async prisma 绑定有关,但这只是直觉。
任何帮助将非常感激。
谢谢,
一个