Guillaume Chau
66 lines
2.1 KiB
JavaScript
66 lines
2.1 KiB
JavaScript
const GraphQLJSON = require('graphql-type-json')
|
|
const { withFilter } = require('graphql-subscriptions')
|
|
// Subs
|
|
const triggers = require('./triggers')
|
|
// Connectors
|
|
const channels = require('./connectors/channels')
|
|
const messages = require('./connectors/messages')
|
|
const users = require('./connectors/users')
|
|
|
|
module.exports = {
|
|
JSON: GraphQLJSON,
|
|
|
|
Channel: {
|
|
messages: (channel, args, context) => messages.getAll(channel.id, context),
|
|
},
|
|
|
|
Message: {
|
|
user: (message, args, context) => users.getOne(message.userId, context),
|
|
},
|
|
|
|
Query: {
|
|
userCurrent: (root, args, context) => users.current(context),
|
|
channels: (root, args, context) => channels.getAll(context),
|
|
channel: (root, { id }, context) => channels.getOne(id, context),
|
|
good: () => 'good',
|
|
bad: () => {
|
|
throw new Error('An error')
|
|
},
|
|
loadNumber: () => new Promise((resolve) => {
|
|
setTimeout(() => resolve(42), 100)
|
|
}),
|
|
},
|
|
|
|
Mutation: {
|
|
userRegister: (root, { input }, context) => users.register(input, context),
|
|
userLogin: (root, args, context) => users.login(args, context),
|
|
userLogout: (root, args, context) => users.logout(context),
|
|
messageAdd: (root, { input }, context) => messages.add(input, context),
|
|
messageUpdate: (root, { input }, context) => messages.update(input, context),
|
|
messageRemove: (root, { id }, context) => messages.remove(id, context),
|
|
mockMessageSend: (root, args, context) => messages.mockMessageSend(context),
|
|
updateCounter: (root, { type, value }, context) => {
|
|
context.pubsub.publish('counter', {
|
|
type,
|
|
counterUpdated: value,
|
|
})
|
|
},
|
|
},
|
|
|
|
Subscription: {
|
|
messageChanged: {
|
|
subscribe: withFilter(
|
|
(parent, args, { pubsub }) => pubsub.asyncIterator(triggers.MESSAGE_CHANGED),
|
|
(payload, vars) => payload.messageChanged.message.channelId === vars.channelId
|
|
),
|
|
},
|
|
|
|
counterUpdated: {
|
|
subscribe: withFilter(
|
|
(parent, args, { pubsub }) => pubsub.asyncIterator('counter'),
|
|
(payload, vars) => payload.type === vars.type
|
|
),
|
|
},
|
|
},
|
|
}
|