kdn
03/26/2018, 10:42 PMkdn
03/26/2018, 10:45 PMSubscription.js
file
const { getUserIdFromAuthorization } = require('../utils')
const Subscription = {
pendingMessages: {
subscribe: async (parent, args, ctx, info) => {
console.log(info)
console.log("AUTHORIZATION: " + ctx.connection.context.Authorization)
const userId = getUserIdFromAuthorization(ctx.connection.context.Authorization)
return ctx.db.subscription.pendingMessage({
where:{
mutation_in: ["CREATED", "UPDATED"],
node: {
user: {id: userId},
},
}
}, info)
}
},
newMessage: {
subscribe: async(parent, args, ctx, info) => {
const userId = getUserIdFromAuthorization(ctx.connection.context.Authorization)
return ctx.db.subscription.message({
where:{
mutation_in: ["CREATED"],
node:{
conversation: {
user: {
id: userId
}
}
}
}
}, info)
}
},
}
module.exports = { Subscription }
kdn
03/26/2018, 10:47 PMindex.js
for resolvers
const { Query } = require('./Query')
const { auth } = require('./Mutation/auth')
const { messages } = require('./Mutation/messages')
const { conversations } = require('./Mutation/conversations')
const { AuthPayload } = require('./AuthPayload')
const { Subscription } = require('./Subscription')
module.exports = {
Query,
Mutation: {
...auth,
...messages,
...conversations,
},
Subscription,
AuthPayload,
}
Daniel K.
03/26/2018, 10:57 PMDaniel K.
03/26/2018, 10:57 PMat0mic
03/27/2018, 12:20 AMdisableAuth: true
at0mic
03/27/2018, 12:21 AM{
"data": null,
"errors": [
{
"message": "Not authorized",
"locations": [
{
"line": 2,
"column": 3
}
],
"path": [
"createCountry"
]
}
]
}
at0mic
03/27/2018, 12:21 AMDaniel K.
03/27/2018, 7:06 AMkdn
03/28/2018, 11:03 PM