First commit

Author: phaalonso

backend/.gitignore

@@ -0,0 +1,2 @@
+node_modules
+dist

backend/package-lock.json

@@ -0,0 +1,22 @@
+{
+  "name": "graphql-server-example",
+  "version": "1.0.0",
+  "description": "",
+  "main": "ts-node-dev src/index.ts",
+  "scripts": {
+    "dev": "ts-node-dev --transpile-only --ignore-watch node_modules src/index.ts"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "apollo-server": "^2.21.0",
+    "graphql": "^15.5.0",
+    "mongoose": "^5.11.17"
+  },
+  "devDependencies": {
+    "ts-node": "^9.1.1",
+    "ts-node-dev": "^1.1.1",
+    "typescript": "^4.1.5"
+  }
+}

backend/package.json

@@ -0,0 +1,27 @@
+type User {
+  id: ID!
+  name: String!
+  email: String!,
+}
+
+type Message {
+  id: ID!
+  user: User!
+  content: String!
+}
+
+type Query {
+    users: [User!]!
+    user(id: ID!): User
+    chat: [Message!]!
+}
+
+type Subscription {
+  messageSent: Message
+}
+
+type Mutation {
+  createUser(name: String!, email: String!): User
+  deleteUser(id: ID!): User
+  sendMessage(userID: ID!, content: String!): Message
+}

backend/schema.graphql

@@ -0,0 +1,27 @@
+import { ApolloServer, gql } from 'apollo-server';
+import mongoose from 'mongoose';
+import path from 'path';
+import fs from 'fs';
+
+import resolvers from './resolvers';
+
+const pathToSchema = path.resolve(__dirname, '..', 'schema.graphql');
+const typeDefs = gql`${fs.readFileSync(pathToSchema)}`;
+
+mongoose.connect('mongodb://localhost:27017/graphqlnode', {
+	useNewUrlParser: true,
+	useUnifiedTopology: true,
+});
+
+const server = new ApolloServer({ 
+	typeDefs,
+	resolvers,
+	tracing: true,
+	subscriptions: {
+		path: '/subscriptions'
+	}
+});
+
+server.listen().then(({ url }) => {
+	console.log(`Server is ready at ${url}`);
+})

backend/src/index.ts

@@ -0,0 +1,43 @@
+import User from './schemas/Users';
+import Message from './schemas/Message';
+import { IResolvers, PubSub } from 'apollo-server';
+
+const pubsub = new PubSub();
+const CHAT_CHANNEL = 'CHAT_CHANNEL';
+
+const resolvers: IResolvers =  {
+	Query: {
+		users: () => User.find(),
+		user: (_, { id }) => User.findById(id),
+		chat: () =>  {
+			return Message.find().sort({ "timestamp": -1 }).populate('user');
+		}
+	},
+
+	Mutation: {
+		createUser: (_, { name, email }) => User.create({ name, email }),
+		deleteUser: (_, { id }) => User.remove(id),
+		sendMessage: async (_, { userID, content }) => {
+			// Busca o usuário por id
+			const user = await User.findById(userID);
+
+			// Salva a mensagem no banco de dados
+			const messageSent = await Message.create({ user, content });
+			console.log(messageSent);
+
+			// Pública a mensagem
+			pubsub.publish(CHAT_CHANNEL, { messageSent });
+
+			return messageSent;
+		}
+	},
+
+	Subscription: {
+		messageSent: {
+			subscribe: () => pubsub.asyncIterator([CHAT_CHANNEL])
+		}
+	}
+
+};
+
+export default resolvers;

backend/src/resolvers.ts

@@ -0,0 +1,11 @@
+import mongoose from 'mongoose';
+
+const MessageSchema = new mongoose.Schema({
+	user: {
+		type: mongoose.Schema.Types.ObjectId,
+		ref: 'User'
+	},
+	content: String,
+}, { timestamps: true });
+
+export default mongoose.model('Message', MessageSchema);

backend/src/schemas/Message.ts

@@ -0,0 +1,8 @@
+import {model, Schema} from 'mongoose';
+
+const UserSchema = new Schema({
+	name: String,
+	email: String,
+});
+
+export default model('User', UserSchema);

backend/src/schemas/Users.ts

@@ -0,0 +1,14 @@
+{
+  "compilerOptions": {
+    "target": "es5",
+
+    "strict": true,                           /* Enable all strict type-checking options. */
+    "esModuleInterop": true,                  /* Enables emit interoperability between CommonJS and ES Modules via creation of namespace objects for all imports. Implies 'allowSyntheticDefaultImports'. */
+    "experimentalDecorators": true,        /* Enables experimental support for ES7 decorators. */
+    "emitDecoratorMetadata": true,         /* Enables experimental support for emitting type metadata for decorators. */
+    "skipLibCheck": true,                     /* Skip type checking of declaration files. */
+    "forceConsistentCasingInFileNames": true,  /* Disallow inconsistently-cased references to the same file. */
+
+	"outDir": "./dist"
+  }
+}