Merge branch 'master' of https://github.com/discord-open-source/discord-gateway into main
This commit is contained in:
parent
1c57e93f81
commit
f5a723d9b4
@ -1,4 +1,4 @@
|
||||
# discord-gateway
|
||||
Open Source Discord WebSocket Gateway Server
|
||||
|
||||
For the WebSocket we use [ws](https://www.npmjs.com/package/ws) and we'll write our own packet handler for the individual opcodes and events.
|
||||
## [Wiki](https://github.com/discord-open-source/discord-gateway/wiki/)
|
||||
|
||||
16
client.js
Normal file
16
client.js
Normal file
@ -0,0 +1,16 @@
|
||||
const WebSocket = require("ws");
|
||||
|
||||
const ws = new WebSocket("ws://127.0.0.1:8080");
|
||||
|
||||
ws.on("open", () => {
|
||||
ws.send(JSON.stringify({ req_type: "new_auth" }));
|
||||
// ws.send(JSON.stringify({ req_type: "check_auth", token: "" }));
|
||||
// op: 0,
|
||||
// d: {},
|
||||
// s: 42,
|
||||
// t: "GATEWAY_EVENT_NAME",
|
||||
});
|
||||
|
||||
ws.on("message", (data) => {
|
||||
console.log(data);
|
||||
});
|
||||
BIN
package-lock.json
generated
Normal file
BIN
package-lock.json
generated
Normal file
Binary file not shown.
22
package.json
Normal file
22
package.json
Normal file
@ -0,0 +1,22 @@
|
||||
{
|
||||
"name": "websocket_learn",
|
||||
"version": "1.0.0",
|
||||
"description": "",
|
||||
"main": "index.js",
|
||||
"scripts": {
|
||||
"test": "echo \"Error: no test specified\" && exit 1"
|
||||
},
|
||||
"keywords": [],
|
||||
"author": "",
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"lambert-db": "^1.1.2",
|
||||
"node-fetch": "^2.6.1",
|
||||
"uuid": "^8.3.2",
|
||||
"ws": "^7.4.2"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@types/uuid": "^8.3.0",
|
||||
"@types/ws": "^7.4.0"
|
||||
}
|
||||
}
|
||||
BIN
src/.DS_Store
vendored
Normal file
BIN
src/.DS_Store
vendored
Normal file
Binary file not shown.
31
src/assets/codes.ts
Normal file
31
src/assets/codes.ts
Normal file
@ -0,0 +1,31 @@
|
||||
export enum OPCODES {
|
||||
Dispatch,
|
||||
Heartbeat,
|
||||
Identify,
|
||||
Presence_Update,
|
||||
Voice_State_Update,
|
||||
Resume,
|
||||
Reconnect,
|
||||
Request_Guild_Members,
|
||||
Invalid_Session,
|
||||
Hello,
|
||||
Heartbeat_ACK,
|
||||
}
|
||||
export enum CLOSECODES {
|
||||
Unknown_error = 4000,
|
||||
Unknown_opcode,
|
||||
Decode_error,
|
||||
Not_authenticated,
|
||||
Authentication_failed,
|
||||
Already_authenticated,
|
||||
Invalid_session,
|
||||
Invalid_seq,
|
||||
Rate_limited,
|
||||
Session_timed_out,
|
||||
Invalid_shard,
|
||||
Sharding_required,
|
||||
Invalid_API_version,
|
||||
Invalid_intent,
|
||||
Disallowed_intent,
|
||||
}
|
||||
export enum SEQUENCENUM {}
|
||||
15
src/assets/datastru.ts
Normal file
15
src/assets/datastru.ts
Normal file
@ -0,0 +1,15 @@
|
||||
//* https://discord.com/developers/docs/topics/gateway
|
||||
|
||||
import { OPCODES, SEQUENCENUM } from "./codes";
|
||||
|
||||
export interface message_prod {
|
||||
op: OPCODES;
|
||||
d: object;
|
||||
s: SEQUENCENUM;
|
||||
t: string;
|
||||
}
|
||||
|
||||
export interface message_dev {
|
||||
req_type: "new_auth" | "check_auth";
|
||||
token?: string;
|
||||
}
|
||||
5
src/extras/Database.ts
Normal file
5
src/extras/Database.ts
Normal file
@ -0,0 +1,5 @@
|
||||
import { MongoDatabase } from "lambert-db";
|
||||
|
||||
const db = new MongoDatabase();
|
||||
|
||||
export default db;
|
||||
43
src/index.ts
Normal file
43
src/index.ts
Normal file
@ -0,0 +1,43 @@
|
||||
import WebSocket from "ws";
|
||||
import DB from "./extras/Database";
|
||||
import { message_dev } from "./assets/datastru";
|
||||
import { v4 } from "uuid";
|
||||
|
||||
class Server {
|
||||
db: any;
|
||||
constructor() {
|
||||
this.db = DB;
|
||||
}
|
||||
|
||||
async listen(): Promise<void> {
|
||||
await this.db.init();
|
||||
const wss = new WebSocket.Server({ port: 8080 });
|
||||
|
||||
wss.on("connection", (ws) => {
|
||||
ws.on("message", async (msg: any) => {
|
||||
const message: message_dev = msg;
|
||||
|
||||
if (message.req_type) {
|
||||
switch (message.req_type) {
|
||||
case "new_auth":
|
||||
const token = v4();
|
||||
await this.db.data.auth.push({ token });
|
||||
return ws.send({ new_token: token });
|
||||
case "check_auth":
|
||||
if (!message.token) {
|
||||
return ws.send({ error: "token not providen" });
|
||||
}
|
||||
return this.db.data.auth({ token: message.token }).get();
|
||||
}
|
||||
} else {
|
||||
ws.send({ error: "req_type not providen" });
|
||||
}
|
||||
});
|
||||
|
||||
ws.send("connected");
|
||||
});
|
||||
}
|
||||
}
|
||||
|
||||
const s = new Server();
|
||||
s.listen();
|
||||
71
tsconfig.json
Normal file
71
tsconfig.json
Normal file
@ -0,0 +1,71 @@
|
||||
{
|
||||
"include": ["src/**/*.ts"],
|
||||
"exclude": ["*.js", "dist", "marion", "attachments"],
|
||||
"compilerOptions": {
|
||||
/* Visit https://aka.ms/tsconfig.json to read more about this file */
|
||||
|
||||
/* Basic Options */
|
||||
// "incremental": true, /* Enable incremental compilation */
|
||||
"target": "ES6" /* Specify ECMAScript target version: 'ES3' (default), 'ES5', 'ES2015', 'ES2016', 'ES2017', 'ES2018', 'ES2019', 'ES2020', or 'ESNEXT'. */,
|
||||
"module": "commonjs" /* Specify module code generation: 'none', 'commonjs', 'amd', 'system', 'umd', 'es2015', 'es2020', or 'ESNext'. */,
|
||||
"lib": ["ES2015", "DOM"] /* Specify library files to be included in the compilation. */,
|
||||
"allowJs": true /* Allow javascript files to be compiled. */,
|
||||
"checkJs": true /* Report errors in .js files. */,
|
||||
// "jsx": "preserve", /* Specify JSX code generation: 'preserve', 'react-native', or 'react'. */
|
||||
"declaration": true /* Generates corresponding '.d.ts' file. */,
|
||||
"declarationMap": false /* Generates a sourcemap for each corresponding '.d.ts' file. */,
|
||||
// "sourceMap": true /* Generates corresponding '.map' file. */,
|
||||
// "outFile": "./", /* Concatenate and emit output to single file. */
|
||||
"outDir": "./dist/" /* Redirect output structure to the directory. */,
|
||||
"rootDir": "./src/" /* Specify the root directory of input files. Use to control the output directory structure with --outDir. */,
|
||||
// "composite": true, /* Enable project compilation */
|
||||
// "tsBuildInfoFile": "./", /* Specify file to store incremental compilation information */
|
||||
// "removeComments": true, /* Do not emit comments to output. */
|
||||
// "noEmit": true, /* Do not emit outputs. */
|
||||
// "importHelpers": true, /* Import emit helpers from 'tslib'. */
|
||||
// "downlevelIteration": true, /* Provide full support for iterables in 'for-of', spread, and destructuring when targeting 'ES5' or 'ES3'. */
|
||||
// "isolatedModules": true, /* Transpile each file as a separate module (similar to 'ts.transpileModule'). */
|
||||
|
||||
/* Strict Type-Checking Options */
|
||||
"strict": false /* Enable all strict type-checking options. */,
|
||||
"noImplicitAny": true /* Raise error on expressions and declarations with an implied 'any' type. */,
|
||||
// "strictNullChecks": true, /* Enable strict null checks. */
|
||||
// "strictFunctionTypes": true, /* Enable strict checking of function types. */
|
||||
// "strictBindCallApply": true, /* Enable strict 'bind', 'call', and 'apply' methods on functions. */
|
||||
"strictPropertyInitialization": false /* Enable strict checking of property initialization in classes. */,
|
||||
// "noImplicitThis": true, /* Raise error on 'this' expressions with an implied 'any' type. */
|
||||
"alwaysStrict": true /* Parse in strict mode and emit "use strict" for each source file. */,
|
||||
|
||||
/* Additional Checks */
|
||||
// "noUnusedLocals": true, /* Report errors on unused locals. */
|
||||
// "noUnusedParameters": true, /* Report errors on unused parameters. */
|
||||
// "noImplicitReturns": true, /* Report error when not all code paths in function return a value. */
|
||||
// "noFallthroughCasesInSwitch": true, /* Report errors for fallthrough cases in switch statement. */
|
||||
|
||||
/* Module Resolution Options */
|
||||
// "moduleResolution": "node", /* Specify module resolution strategy: 'node' (Node.js) or 'classic' (TypeScript pre-1.6). */
|
||||
// "baseUrl": "./", /* Base directory to resolve non-absolute module names. */
|
||||
// "paths": {}, /* A series of entries which re-map imports to lookup locations relative to the 'baseUrl'. */
|
||||
// "rootDirs": [], /* List of root folders whose combined content represents the structure of the project at runtime. */
|
||||
// "typeRoots": [], /* List of folders to include type definitions from. */
|
||||
"types": ["node"] /* Type declaration files to be included in compilation. */,
|
||||
// "allowSyntheticDefaultImports": true, /* Allow default imports from modules with no default export. This does not affect code emit, just typechecking. */
|
||||
"esModuleInterop": true /* Enables emit interoperability between CommonJS and ES Modules via creation of namespace objects for all imports. Implies 'allowSyntheticDefaultImports'. */,
|
||||
// "preserveSymlinks": true, /* Do not resolve the real path of symlinks. */
|
||||
// "allowUmdGlobalAccess": true, /* Allow accessing UMD globals from modules. */
|
||||
|
||||
/* Source Map Options */
|
||||
// "sourceRoot": "", /* Specify the location where debugger should locate TypeScript files instead of source locations. */
|
||||
// "mapRoot": "", /* Specify the location where debugger should locate map files instead of generated locations. */
|
||||
"inlineSourceMap": true /* Emit a single file with source maps instead of having a separate file. */,
|
||||
// "inlineSources": true, /* Emit the source alongside the sourcemaps within a single file; requires '--inlineSourceMap' or '--sourceMap' to be set. */
|
||||
|
||||
/* Experimental Options */
|
||||
// "experimentalDecorators": true, /* Enables experimental support for ES7 decorators. */
|
||||
// "emitDecoratorMetadata": true, /* Enables experimental support for emitting type metadata for decorators. */
|
||||
|
||||
/* Advanced Options */
|
||||
"skipLibCheck": true /* Skip type checking of declaration files. */,
|
||||
"forceConsistentCasingInFileNames": true /* Disallow inconsistently-cased references to the same file. */
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user