generated from tiramisulabs/monorepo
-
Notifications
You must be signed in to change notification settings - Fork 2
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
1061567
commit adb4b69
Showing
13 changed files
with
733 additions
and
503 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 |
|---|---|---|
| @@ -0,0 +1,13 @@ | ||
| root = true | ||
|
|
||
| [*] | ||
| charset = utf-8 | ||
| end_of_line = crlf | ||
| trim_trailing_whitespace = true | ||
| insert_final_newline = true | ||
| indent_style = tab | ||
| indent_size = 2 | ||
| quote_type = single | ||
|
|
||
| [Makefile] | ||
| indent_style = tab |
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,92 +1,89 @@ | ||
| import { HttpClient, Logger, } from 'seyfert'; | ||
| import { InternalRuntimeConfigHTTP } from 'seyfert/lib/client/base'; | ||
| import { APIInteraction, InteractionResponseType, InteractionType } from 'seyfert/lib/types'; | ||
| import type { HttpServerAdapter } from 'seyfert/lib/client/types'; | ||
|
|
||
| import nacl from 'tweetnacl'; | ||
| import { isCloudfareWorker } from 'seyfert/lib/common'; | ||
|
|
||
| export class GenericAdapter implements HttpServerAdapter { | ||
| publicKeyHex!: Buffer; | ||
| applicationId!: string; | ||
| debugger?: Logger; | ||
| logger!: Logger | ||
|
|
||
| constructor(public client: HttpClient) { | ||
| this.logger = client.logger | ||
| } | ||
|
|
||
| async start() { | ||
| if (this.client.debugger) this.debugger = this.client.debugger | ||
|
|
||
| const { | ||
| publicKey, | ||
| applicationId, | ||
| } = await this.client.getRC<InternalRuntimeConfigHTTP>() | ||
|
|
||
| if (!publicKey) { | ||
| throw new Error('Expected a publicKey, check your config file'); | ||
| } | ||
| if (applicationId) { | ||
| this.applicationId = applicationId; | ||
| } | ||
| this.publicKeyHex = Buffer.from(publicKey, 'hex'); | ||
| this.logger.info(`Running on <url>`); | ||
| } | ||
|
|
||
| protected async verifySignature(req: Request) { | ||
| const timestamp = req.headers.get('x-signature-timestamp'); | ||
| const ed25519 = req.headers.get('x-signature-ed25519') ?? ''; | ||
| const body = (await req.json()) as APIInteraction; | ||
| if ( | ||
| nacl!.sign.detached.verify( | ||
| Buffer.from(timestamp + JSON.stringify(body)), | ||
| Buffer.from(ed25519, 'hex'), | ||
| this.publicKeyHex, | ||
| ) | ||
| ) { | ||
| return body; | ||
| } | ||
| return; | ||
| } | ||
|
|
||
| async fetch(req: Request) { | ||
| const rawBody = await this.verifySignature(req); | ||
| if (!rawBody) { | ||
| this.debugger?.debug('Invalid request/No info, returning 418 status.'); | ||
| // I'm a teapot | ||
| return new Response('', { status: 418 }); | ||
| } | ||
| switch (rawBody.type) { | ||
| case InteractionType.Ping: | ||
| this.debugger?.debug('Ping interaction received, responding.'); | ||
| return Response.json( | ||
| { type: InteractionResponseType.Pong }, | ||
| { | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| }, | ||
| }, | ||
| ); | ||
| default: | ||
| if (isCloudfareWorker()) { | ||
| // you can not do more net requests after responding. | ||
| // so we use discord api instead | ||
| return this.client.handleCommand | ||
| .interaction(rawBody, -1) | ||
| .then(() => new Response()) | ||
| .catch(() => new Response()); | ||
| } | ||
| return new Promise(async r => { | ||
| const { headers, response } = await this.client.onPacket(rawBody) | ||
| r( | ||
| response instanceof FormData | ||
| ? new Response(response, { headers }) | ||
| : Response.json(response, { | ||
| headers, | ||
| }), | ||
| ); | ||
| }); | ||
| } | ||
| } | ||
| } | ||
| import type { HttpClient, Logger } from 'seyfert'; | ||
| import type { InternalRuntimeConfigHTTP } from 'seyfert/lib/client/base'; | ||
| import { type APIInteraction, InteractionResponseType, InteractionType } from 'seyfert/lib/types'; | ||
| import type { HttpServerAdapter } from 'seyfert/lib/client/types'; | ||
|
|
||
| import nacl from 'tweetnacl'; | ||
| import { isCloudfareWorker } from 'seyfert/lib/common'; | ||
|
|
||
| export class GenericAdapter implements HttpServerAdapter { | ||
| publicKeyHex!: Buffer; | ||
| applicationId!: string; | ||
| debugger?: Logger; | ||
| logger: Logger; | ||
|
|
||
| constructor(public client: HttpClient) { | ||
| this.logger = client.logger; | ||
| } | ||
|
|
||
| async start() { | ||
| if (this.client.debugger) this.debugger = this.client.debugger; | ||
|
|
||
| const { publicKey, applicationId } = await this.client.getRC<InternalRuntimeConfigHTTP>(); | ||
|
|
||
| if (!publicKey) { | ||
| throw new Error('Expected a publicKey, check your config file'); | ||
| } | ||
| if (applicationId) { | ||
| this.applicationId = applicationId; | ||
| } | ||
| this.publicKeyHex = Buffer.from(publicKey, 'hex'); | ||
| this.logger.info('Running on <url>'); | ||
| } | ||
|
|
||
| protected async verifySignature(req: Request) { | ||
| const timestamp = req.headers.get('x-signature-timestamp'); | ||
| const ed25519 = req.headers.get('x-signature-ed25519') ?? ''; | ||
| const body = (await req.json()) as APIInteraction; | ||
| if ( | ||
| nacl!.sign.detached.verify( | ||
| Buffer.from(timestamp + JSON.stringify(body)), | ||
| Buffer.from(ed25519, 'hex'), | ||
| this.publicKeyHex, | ||
| ) | ||
| ) { | ||
| return body; | ||
| } | ||
| return; | ||
| } | ||
|
|
||
| async fetch(req: Request) { | ||
| const rawBody = await this.verifySignature(req); | ||
| if (!rawBody) { | ||
| this.debugger?.debug('Invalid request/No info, returning 418 status.'); | ||
| // I'm a teapot | ||
| return new Response('', { status: 418 }); | ||
| } | ||
| switch (rawBody.type) { | ||
| case InteractionType.Ping: | ||
| this.debugger?.debug('Ping interaction received, responding.'); | ||
| return Response.json( | ||
| { type: InteractionResponseType.Pong }, | ||
| { | ||
| headers: { | ||
| 'Content-Type': 'application/json', | ||
| }, | ||
| }, | ||
| ); | ||
| default: | ||
| if (isCloudfareWorker()) { | ||
| // you can not do more net requests after responding. | ||
| // so we use discord api instead | ||
| return this.client.handleCommand | ||
| .interaction(rawBody, -1) | ||
| .then(() => new Response()) | ||
| .catch(() => new Response()); | ||
| } | ||
| return new Promise(async r => { | ||
| const { headers, response } = await this.client.onPacket(rawBody); | ||
| r( | ||
| response instanceof FormData | ||
| ? new Response(response, { headers }) | ||
| : Response.json(response, { | ||
| headers, | ||
| }), | ||
| ); | ||
| }); | ||
| } | ||
| } | ||
| } |
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 +1 @@ | ||
| export * from './adapter' | ||
| export * from './adapter'; |
Oops, something went wrong.