-
-
Notifications
You must be signed in to change notification settings - Fork 2.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
refactor: Remove babel/register for instant production server startup
- Loading branch information
Showing
13 changed files
with
312 additions
and
292 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,5 @@ | ||
| dist | ||
| build | ||
| node_modules/* | ||
| server/scripts | ||
| .env | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,189 +1,74 @@ | ||
| // @flow | ||
| import http from "http"; | ||
| import IO from "socket.io"; | ||
| import socketRedisAdapter from "socket.io-redis"; | ||
| import SocketAuth from "socketio-auth"; | ||
| import app from "./app"; | ||
| import { Document, Collection, View } from "./models"; | ||
| import policy from "./policies"; | ||
| import { client, subscriber } from "./redis"; | ||
| import { getUserForJWT } from "./utils/jwt"; | ||
|
|
||
| const server = http.createServer(app.callback()); | ||
| let io; | ||
|
|
||
| const { can } = policy; | ||
|
|
||
| io = IO(server, { | ||
| path: "/realtime", | ||
| serveClient: false, | ||
| cookie: false, | ||
| }); | ||
|
|
||
| io.adapter( | ||
| socketRedisAdapter({ | ||
| pubClient: client, | ||
| subClient: subscriber, | ||
| }) | ||
| ); | ||
|
|
||
| SocketAuth(io, { | ||
| authenticate: async (socket, data, callback) => { | ||
| const { token } = data; | ||
|
|
||
| try { | ||
| const user = await getUserForJWT(token); | ||
| socket.client.user = user; | ||
|
|
||
| // store the mapping between socket id and user id in redis | ||
| // so that it is accessible across multiple server nodes | ||
| await client.hset(socket.id, "userId", user.id); | ||
|
|
||
| return callback(null, true); | ||
| } catch (err) { | ||
| return callback(err); | ||
| require("dotenv").config({ silent: true }); | ||
|
|
||
| if ( | ||
| !process.env.SECRET_KEY || | ||
| process.env.SECRET_KEY === "generate_a_new_key" | ||
| ) { | ||
| console.error( | ||
| "The SECRET_KEY env variable must be set with the output of `openssl rand -hex 32`" | ||
| ); | ||
| // $FlowFixMe | ||
| process.exit(1); | ||
| } | ||
|
|
||
| if (process.env.AWS_ACCESS_KEY_ID) { | ||
| [ | ||
| "AWS_REGION", | ||
| "AWS_SECRET_ACCESS_KEY", | ||
| "AWS_S3_UPLOAD_BUCKET_URL", | ||
| "AWS_S3_UPLOAD_BUCKET_NAME", | ||
| "AWS_S3_UPLOAD_MAX_SIZE", | ||
| ].forEach((key) => { | ||
| if (!process.env[key]) { | ||
| console.error(`The ${key} env variable must be set when using AWS`); | ||
| // $FlowFixMe | ||
| process.exit(1); | ||
| } | ||
| }, | ||
| postAuthenticate: async (socket, data) => { | ||
| const { user } = socket.client; | ||
| }); | ||
| } | ||
|
|
||
| // the rooms associated with the current team | ||
| // and user so we can send authenticated events | ||
| let rooms = [`team-${user.teamId}`, `user-${user.id}`]; | ||
|
|
||
| // the rooms associated with collections this user | ||
| // has access to on connection. New collection subscriptions | ||
| // are managed from the client as needed through the 'join' event | ||
| const collectionIds = await user.collectionIds(); | ||
| collectionIds.forEach((collectionId) => | ||
| rooms.push(`collection-${collectionId}`) | ||
| if (process.env.SLACK_KEY) { | ||
| if (!process.env.SLACK_SECRET) { | ||
| console.error( | ||
| `The SLACK_SECRET env variable must be set when using Slack Sign In` | ||
| ); | ||
|
|
||
| // join all of the rooms at once | ||
| socket.join(rooms); | ||
|
|
||
| // allow the client to request to join rooms | ||
| socket.on("join", async (event) => { | ||
| // user is joining a collection channel, because their permissions have | ||
| // changed, granting them access. | ||
| if (event.collectionId) { | ||
| const collection = await Collection.scope({ | ||
| method: ["withMembership", user.id], | ||
| }).findByPk(event.collectionId); | ||
|
|
||
| if (can(user, "read", collection)) { | ||
| socket.join(`collection-${event.collectionId}`); | ||
| } | ||
| } | ||
|
|
||
| // user is joining a document channel, because they have navigated to | ||
| // view a document. | ||
| if (event.documentId) { | ||
| const document = await Document.findByPk(event.documentId, { | ||
| userId: user.id, | ||
| }); | ||
|
|
||
| if (can(user, "read", document)) { | ||
| const room = `document-${event.documentId}`; | ||
|
|
||
| await View.touch(event.documentId, user.id, event.isEditing); | ||
| const editing = await View.findRecentlyEditingByDocument( | ||
| event.documentId | ||
| ); | ||
|
|
||
| socket.join(room, () => { | ||
| // let everyone else in the room know that a new user joined | ||
| io.to(room).emit("user.join", { | ||
| userId: user.id, | ||
| documentId: event.documentId, | ||
| isEditing: event.isEditing, | ||
| }); | ||
|
|
||
| // let this user know who else is already present in the room | ||
| io.in(room).clients(async (err, sockets) => { | ||
| if (err) throw err; | ||
|
|
||
| // because a single user can have multiple socket connections we | ||
| // need to make sure that only unique userIds are returned. A Map | ||
| // makes this easy. | ||
| let userIds = new Map(); | ||
| for (const socketId of sockets) { | ||
| const userId = await client.hget(socketId, "userId"); | ||
| userIds.set(userId, userId); | ||
| } | ||
| socket.emit("document.presence", { | ||
| documentId: event.documentId, | ||
| userIds: Array.from(userIds.keys()), | ||
| editingIds: editing.map((view) => view.userId), | ||
| }); | ||
| }); | ||
| }); | ||
| } | ||
| } | ||
| }); | ||
|
|
||
| // allow the client to request to leave rooms | ||
| socket.on("leave", (event) => { | ||
| if (event.collectionId) { | ||
| socket.leave(`collection-${event.collectionId}`); | ||
| } | ||
| if (event.documentId) { | ||
| const room = `document-${event.documentId}`; | ||
| socket.leave(room, () => { | ||
| io.to(room).emit("user.leave", { | ||
| userId: user.id, | ||
| documentId: event.documentId, | ||
| }); | ||
| }); | ||
| } | ||
| }); | ||
|
|
||
| socket.on("disconnecting", () => { | ||
| const rooms = Object.keys(socket.rooms); | ||
|
|
||
| rooms.forEach((room) => { | ||
| if (room.startsWith("document-")) { | ||
| const documentId = room.replace("document-", ""); | ||
| io.to(room).emit("user.leave", { | ||
| userId: user.id, | ||
| documentId, | ||
| }); | ||
| } | ||
| }); | ||
| }); | ||
|
|
||
| socket.on("presence", async (event) => { | ||
| const room = `document-${event.documentId}`; | ||
|
|
||
| if (event.documentId && socket.rooms[room]) { | ||
| const view = await View.touch( | ||
| event.documentId, | ||
| user.id, | ||
| event.isEditing | ||
| ); | ||
| view.user = user; | ||
|
|
||
| io.to(room).emit("user.presence", { | ||
| userId: user.id, | ||
| documentId: event.documentId, | ||
| isEditing: event.isEditing, | ||
| }); | ||
| } | ||
| }); | ||
| }, | ||
| }); | ||
|
|
||
| server.on("error", (err) => { | ||
| throw err; | ||
| }); | ||
|
|
||
| server.on("listening", () => { | ||
| const address = server.address(); | ||
| console.log(`\n> Listening on http://localhost:${address.port}\n`); | ||
| }); | ||
|
|
||
| server.listen(process.env.PORT || "3000"); | ||
|
|
||
| export const socketio = io; | ||
|
|
||
| export default server; | ||
| // $FlowFixMe | ||
| process.exit(1); | ||
| } | ||
| } | ||
|
|
||
| if (!process.env.URL) { | ||
| console.error( | ||
| "The URL env variable must be set to the externally accessible URL, e.g (https://www.getoutline.com)" | ||
| ); | ||
| // $FlowFixMe | ||
| process.exit(1); | ||
| } | ||
|
|
||
| if (!process.env.DATABASE_URL) { | ||
| console.error( | ||
| "The DATABASE_URL env variable must be set to the location of your postgres server, including authentication and port" | ||
| ); | ||
| // $FlowFixMe | ||
| process.exit(1); | ||
| } | ||
|
|
||
| if (!process.env.REDIS_URL) { | ||
| console.error( | ||
| "The REDIS_URL env variable must be set to the location of your redis server, including authentication and port" | ||
| ); | ||
| // $FlowFixMe | ||
| process.exit(1); | ||
| } | ||
|
|
||
| if (process.env.NODE_ENV === "production") { | ||
| console.log("\n\x1b[33m%s\x1b[0m", "Running Outline in production mode."); | ||
| } else if (process.env.NODE_ENV === "development") { | ||
| console.log( | ||
| "\n\x1b[33m%s\x1b[0m", | ||
| 'Running Outline in development mode with hot reloading. To run Outline in production mode set the NODE_ENV env variable to "production"' | ||
| ); | ||
| } | ||
|
|
||
| require("./main"); |
Oops, something went wrong.