Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
12ec45ccd4 |
7
packages/reacord/library/core/file.ts
Normal file
7
packages/reacord/library/core/file.ts
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
import { Readable } from "node:stream"
|
||||||
|
|
||||||
|
export type ReacordFile = {
|
||||||
|
name?: string
|
||||||
|
description?: string
|
||||||
|
data: Buffer | Readable | string
|
||||||
|
}
|
||||||
@@ -1,4 +1,5 @@
|
|||||||
import type { ReactNode } from "react"
|
import type { ReactNode } from "react"
|
||||||
|
import { ReacordFile } from "./file"
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Represents an interactive message, which can later be replaced or deleted.
|
* Represents an interactive message, which can later be replaced or deleted.
|
||||||
@@ -16,4 +17,7 @@ export type ReacordInstance = {
|
|||||||
* This prevents it from listening to user interactions.
|
* This prevents it from listening to user interactions.
|
||||||
*/
|
*/
|
||||||
deactivate: () => void
|
deactivate: () => void
|
||||||
|
|
||||||
|
/** Attach a file to the message for this instance */
|
||||||
|
attach: (file: ReacordFile) => void
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -301,6 +301,15 @@ function createReacordMessage(message: Discord.Message): Message {
|
|||||||
delete: async () => {
|
delete: async () => {
|
||||||
await message.delete()
|
await message.delete()
|
||||||
},
|
},
|
||||||
|
updateFiles: async (files) => {
|
||||||
|
await message.edit({
|
||||||
|
files: files.map(({ name, description, data }) => ({
|
||||||
|
name,
|
||||||
|
description,
|
||||||
|
attachment: data,
|
||||||
|
})),
|
||||||
|
})
|
||||||
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -310,6 +319,10 @@ function createEphemeralReacordMessage(): Message {
|
|||||||
console.warn("Ephemeral messages can't be edited")
|
console.warn("Ephemeral messages can't be edited")
|
||||||
return Promise.resolve()
|
return Promise.resolve()
|
||||||
},
|
},
|
||||||
|
updateFiles: () => {
|
||||||
|
console.warn("Ephemeral messages can't be edited")
|
||||||
|
return Promise.resolve()
|
||||||
|
},
|
||||||
delete: () => {
|
delete: () => {
|
||||||
console.warn("Ephemeral messages can't be deleted")
|
console.warn("Ephemeral messages can't be deleted")
|
||||||
return Promise.resolve()
|
return Promise.resolve()
|
||||||
@@ -358,7 +371,10 @@ function getDiscordMessageOptions(
|
|||||||
})),
|
})),
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!options.content && !options.embeds?.length) {
|
const hasContent =
|
||||||
|
options.content || options.embeds?.length || options.files?.length
|
||||||
|
|
||||||
|
if (!hasContent) {
|
||||||
options.content = "_ _"
|
options.content = "_ _"
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -63,6 +63,9 @@ export abstract class Reacord {
|
|||||||
this.renderers = this.renderers.filter((it) => it !== renderer)
|
this.renderers = this.renderers.filter((it) => it !== renderer)
|
||||||
renderer.destroy()
|
renderer.destroy()
|
||||||
},
|
},
|
||||||
|
attach: (file) => {
|
||||||
|
renderer.attach(file)
|
||||||
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
if (initialContent !== undefined) {
|
if (initialContent !== undefined) {
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
|
import { ReacordFile } from "../core/file"
|
||||||
import type { Message, MessageOptions } from "./message"
|
import type { Message, MessageOptions } from "./message"
|
||||||
|
|
||||||
export type Channel = {
|
export type Channel = {
|
||||||
send(message: MessageOptions): Promise<Message>
|
send(message: MessageOptions): Promise<Message>
|
||||||
|
sendFiles(files: readonly ReacordFile[]): Promise<Message>
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ import type { Except } from "type-fest"
|
|||||||
import { last } from "../../helpers/last"
|
import { last } from "../../helpers/last"
|
||||||
import type { EmbedOptions } from "../core/components/embed-options"
|
import type { EmbedOptions } from "../core/components/embed-options"
|
||||||
import type { SelectProps } from "../core/components/select"
|
import type { SelectProps } from "../core/components/select"
|
||||||
|
import { ReacordFile } from "../main"
|
||||||
|
|
||||||
export type MessageOptions = {
|
export type MessageOptions = {
|
||||||
content: string
|
content: string
|
||||||
@@ -49,6 +50,7 @@ export type MessageSelectOptionOptions = {
|
|||||||
export type Message = {
|
export type Message = {
|
||||||
edit(options: MessageOptions): Promise<void>
|
edit(options: MessageOptions): Promise<void>
|
||||||
delete(): Promise<void>
|
delete(): Promise<void>
|
||||||
|
updateFiles(files: readonly ReacordFile[]): Promise<void>
|
||||||
}
|
}
|
||||||
|
|
||||||
export function getNextActionRow(options: MessageOptions): ActionRow {
|
export function getNextActionRow(options: MessageOptions): ActionRow {
|
||||||
|
|||||||
@@ -1,3 +1,4 @@
|
|||||||
|
import { ReacordFile } from "../../core/file"
|
||||||
import type { Channel } from "../channel"
|
import type { Channel } from "../channel"
|
||||||
import type { Message, MessageOptions } from "../message"
|
import type { Message, MessageOptions } from "../message"
|
||||||
import { Renderer } from "./renderer"
|
import { Renderer } from "./renderer"
|
||||||
@@ -10,4 +11,10 @@ export class ChannelMessageRenderer extends Renderer {
|
|||||||
protected createMessage(options: MessageOptions): Promise<Message> {
|
protected createMessage(options: MessageOptions): Promise<Message> {
|
||||||
return this.channel.send(options)
|
return this.channel.send(options)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected createMessageFromFiles(
|
||||||
|
files: readonly ReacordFile[],
|
||||||
|
): Promise<Message> {
|
||||||
|
return this.channel.sendFiles(files)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,6 @@
|
|||||||
import { Subject } from "rxjs"
|
import { Subject } from "rxjs"
|
||||||
import { concatMap } from "rxjs/operators"
|
import { concatMap } from "rxjs/operators"
|
||||||
|
import { ReacordFile } from "../../core/file"
|
||||||
import { Container } from "../container.js"
|
import { Container } from "../container.js"
|
||||||
import type { ComponentInteraction } from "../interaction"
|
import type { ComponentInteraction } from "../interaction"
|
||||||
import type { Message, MessageOptions } from "../message"
|
import type { Message, MessageOptions } from "../message"
|
||||||
@@ -7,15 +8,21 @@ import type { Node } from "../node.js"
|
|||||||
|
|
||||||
type UpdatePayload =
|
type UpdatePayload =
|
||||||
| { action: "update" | "deactivate"; options: MessageOptions }
|
| { action: "update" | "deactivate"; options: MessageOptions }
|
||||||
|
| { action: "files"; files: readonly ReacordFile[] }
|
||||||
| { action: "deferUpdate"; interaction: ComponentInteraction }
|
| { action: "deferUpdate"; interaction: ComponentInteraction }
|
||||||
| { action: "destroy" }
|
| { action: "destroy" }
|
||||||
|
|
||||||
|
type NewMessagePayload =
|
||||||
|
| { source: "content"; messageOptions?: MessageOptions }
|
||||||
|
| { source: "files"; files?: readonly ReacordFile[] }
|
||||||
|
|
||||||
export abstract class Renderer {
|
export abstract class Renderer {
|
||||||
readonly nodes = new Container<Node<unknown>>()
|
readonly nodes = new Container<Node<unknown>>()
|
||||||
private componentInteraction?: ComponentInteraction
|
private componentInteraction?: ComponentInteraction
|
||||||
private message?: Message
|
private message?: Message
|
||||||
private active = true
|
private active = true
|
||||||
private updates = new Subject<UpdatePayload>()
|
private updates = new Subject<UpdatePayload>()
|
||||||
|
private files: readonly ReacordFile[] = []
|
||||||
|
|
||||||
private updateSubscription = this.updates
|
private updateSubscription = this.updates
|
||||||
.pipe(concatMap((payload) => this.updateMessage(payload)))
|
.pipe(concatMap((payload) => this.updateMessage(payload)))
|
||||||
@@ -46,6 +53,11 @@ export abstract class Renderer {
|
|||||||
this.updates.next({ action: "destroy" })
|
this.updates.next({ action: "destroy" })
|
||||||
}
|
}
|
||||||
|
|
||||||
|
attach(file: ReacordFile) {
|
||||||
|
const newFiles = (this.files = [...this.files, file])
|
||||||
|
this.updates.next({ action: "files", files: newFiles })
|
||||||
|
}
|
||||||
|
|
||||||
handleComponentInteraction(interaction: ComponentInteraction) {
|
handleComponentInteraction(interaction: ComponentInteraction) {
|
||||||
this.componentInteraction = interaction
|
this.componentInteraction = interaction
|
||||||
|
|
||||||
@@ -60,7 +72,7 @@ export abstract class Renderer {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
protected abstract createMessage(options: MessageOptions): Promise<Message>
|
protected abstract createMessage(options: NewMessagePayload): Promise<Message>
|
||||||
|
|
||||||
private getMessageOptions(): MessageOptions {
|
private getMessageOptions(): MessageOptions {
|
||||||
const options: MessageOptions = {
|
const options: MessageOptions = {
|
||||||
@@ -102,6 +114,15 @@ export abstract class Renderer {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (payload.action === "files") {
|
||||||
|
if (this.message) {
|
||||||
|
await this.message?.updateFiles(payload.files)
|
||||||
|
} else {
|
||||||
|
this.message = await this.createMessageFromFiles(payload.files)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
if (this.componentInteraction) {
|
if (this.componentInteraction) {
|
||||||
const promise = this.componentInteraction.update(payload.options)
|
const promise = this.componentInteraction.update(payload.options)
|
||||||
this.componentInteraction = undefined
|
this.componentInteraction = undefined
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ export * from "./core/components/embed-title"
|
|||||||
export * from "./core/components/link"
|
export * from "./core/components/link"
|
||||||
export * from "./core/components/option"
|
export * from "./core/components/option"
|
||||||
export * from "./core/components/select"
|
export * from "./core/components/select"
|
||||||
|
export * from "./core/file"
|
||||||
export * from "./core/instance"
|
export * from "./core/instance"
|
||||||
export { useInstance } from "./core/instance-context"
|
export { useInstance } from "./core/instance-context"
|
||||||
export * from "./core/reacord"
|
export * from "./core/reacord"
|
||||||
|
|||||||
BIN
packages/reacord/playground/anime.jpg
Normal file
BIN
packages/reacord/playground/anime.jpg
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 954 KiB |
@@ -8,16 +8,14 @@ type Command = {
|
|||||||
|
|
||||||
export function createCommandHandler(client: Client, commands: Command[]) {
|
export function createCommandHandler(client: Client, commands: Command[]) {
|
||||||
client.on("ready", async () => {
|
client.on("ready", async () => {
|
||||||
for (const command of commands) {
|
for (const guild of client.guilds.cache.values()) {
|
||||||
for (const guild of client.guilds.cache.values()) {
|
client.application!.commands.set(
|
||||||
await client.application?.commands.create(
|
commands.map(({ name, description }) => ({
|
||||||
{
|
name,
|
||||||
name: command.name,
|
description,
|
||||||
description: command.description,
|
})),
|
||||||
},
|
guild.id,
|
||||||
guild.id,
|
)
|
||||||
)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,9 @@
|
|||||||
import { Client } from "discord.js"
|
import { Client } from "discord.js"
|
||||||
import "dotenv/config"
|
import "dotenv/config"
|
||||||
|
import { readFile } from "fs/promises"
|
||||||
|
import { join } from "path"
|
||||||
import React from "react"
|
import React from "react"
|
||||||
|
import { fileURLToPath } from "url"
|
||||||
import { Button, ReacordDiscordJs, useInstance } from "../library/main"
|
import { Button, ReacordDiscordJs, useInstance } from "../library/main"
|
||||||
import { createCommandHandler } from "./command-handler"
|
import { createCommandHandler } from "./command-handler"
|
||||||
import { Counter } from "./counter"
|
import { Counter } from "./counter"
|
||||||
@@ -104,6 +107,19 @@ createCommandHandler(client, [
|
|||||||
reacord.reply(interaction, <DeleteThis />)
|
reacord.reply(interaction, <DeleteThis />)
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
name: "anime",
|
||||||
|
description: "shows an anime image",
|
||||||
|
run: async (interaction) => {
|
||||||
|
const reply = reacord.reply(interaction)
|
||||||
|
const image = await readFile(
|
||||||
|
join(fileURLToPath(import.meta.url), "../anime.jpg"),
|
||||||
|
)
|
||||||
|
|
||||||
|
reply.attach({ name: "anime.jpg", data: image })
|
||||||
|
// reply.render("anime")
|
||||||
|
},
|
||||||
|
},
|
||||||
])
|
])
|
||||||
|
|
||||||
await client.login(process.env.TEST_BOT_TOKEN)
|
await client.login(process.env.TEST_BOT_TOKEN)
|
||||||
|
|||||||
Reference in New Issue
Block a user