GraphQL — Mutations و Subscriptions

type Mutation {
  createUser(input: CreateUserInput!): User!
  updateUser(id: ID!, input: UpdateUserInput!): User!
  deleteUser(id: ID!): Boolean!
}

input CreateUserInput {
  name: String!
  email: String!
  password: String!
}

input UpdateUserInput {
  name: String
  email: String
}

const resolvers = {
  Mutation: {
    createUser: async (_, { input }, { db }) => {
      const user = await db.create('users', input);
      return user;
    },
    updateUser: async (_, { id, input }, { db }) => {
      return db.update('users', { id }, input);
    },
    deleteUser: async (_, { id }, { db }) => {
      await db.delete('users', { id });
      return true;
    },
  },
};

mutation CreateUser($input: CreateUserInput!) {
  createUser(input: $input) {
    id
    name
    email
  }
}

{
  "input": {
    "name": "أحمد",
    "email": "ahmed@example.com",
    "password": "secret123"
  }
}

type Subscription {
  userCreated: User!
  userUpdated(id: ID!): User
  notificationReceived: Notification!
}

type Notification {
  id: ID!
  message: String!
  type: String!
}

const { PubSub } = require('graphql-subscriptions');
const pubsub = new PubSub();

const resolvers = {
  Subscription: {
    userCreated: {
      subscribe: () => pubsub.asyncIterator(['USER_CREATED']),
    },
    notificationReceived: {
      subscribe: () => pubsub.asyncIterator(['NOTIFICATION']),
    },
  },
  Mutation: {
    createUser: async (_, { input }, { db }) => {
      const user = await db.create('users', input);
      pubsub.publish('USER_CREATED', { userCreated: user });
      return user;
    },
  },
};

subscription OnUserCreated {
  userCreated {
    id
    name
    email
  }
}

// في أي مكان في الكود
pubsub.publish('NOTIFICATION', {
  notificationReceived: { id: '1', message: 'مرحباً!', type: 'info' },
});