blob: adc9ba4aa79941b156017e595b21d5e1fac3f7b8 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
/*
Spacebar: A FOSS re-implementation and extension of the Discord.com backend.
Copyright (C) 2026 Spacebar and Spacebar Contributors
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
import { emitEvent } from "@spacebar/util";
process.on("uncaughtException", console.error);
process.on("unhandledRejection", console.error);
import moduleAlias from "module-alias";
moduleAlias(__dirname + "../../package.json");
import { config } from "dotenv";
config({ quiet: true });
process.env.DB_LOGGING = "true";
import fs from "node:fs/promises";
import { UnixSocketWriter } from "@spacebar/util/util/ipc/writer/UnixSocketWriter";
import { Event } from "@spacebar/util/interfaces/Event";
import { sleep } from "@spacebar/extensions";
function getArgvOrFail(idx: number, message: string) {
if (process.argv.length <= idx) throw message + "\n";
return process.argv[idx];
}
async function main() {
const sockDir = getArgvOrFail(2, "Usage: node dist/send-ipc-message.js <socket dir>");
if (!(await fs.readdir(sockDir))) throw `Socket directory "${sockDir}" is not a valid directory`;
const unixWriter = new UnixSocketWriter(sockDir);
await unixWriter.init();
const payloadJson = await fs.readFile("/dev/stdin", "utf-8");
const payload = JSON.parse(payloadJson) as Event;
payload.origin ??= "send-ipc-message";
payload.created_at ??= new Date();
payload.transaction_id ??= process.pid.toString();
const id = (payload.guild_id || payload.channel_id || payload.user_id || payload.session_id) as string;
if (!id) return console.error("event doesn't contain any id", payload);
// (payload as unknown).id = id;
await unixWriter.emit(payload);
console.log("Emitted...");
await sleep(1000);
await unixWriter.close();
console.log("Closed...");
}
main().then(() => console.log("meow"));
|
