mirror of
https://github.com/versia-pub/server.git
synced 2025-12-06 08:28:19 +01:00
Lay out groundwork for plugins
This commit is contained in:
parent
158f86c475
commit
795fcd3694
|
|
@ -71,6 +71,7 @@
|
|||
"@prisma/client": "^5.6.0",
|
||||
"blurhash": "^2.0.5",
|
||||
"chalk": "^5.3.0",
|
||||
"eventemitter3": "^5.0.1",
|
||||
"html-to-text": "^9.0.5",
|
||||
"ip-matching": "^2.1.2",
|
||||
"iso-639-1": "^3.1.0",
|
||||
|
|
|
|||
11
plugins/test.plugin.ts
Normal file
11
plugins/test.plugin.ts
Normal file
|
|
@ -0,0 +1,11 @@
|
|||
import { HookTypes, Server } from "./types";
|
||||
|
||||
const registerPlugin = (server: Server) => {
|
||||
server.on(HookTypes.OnPostCreate, (req, newPost, author) => {
|
||||
console.log("New post created!");
|
||||
console.log(`Post details: ${newPost.content} (${newPost.id})`);
|
||||
console.log(`Made by ${author.username} (${author.id})`);
|
||||
});
|
||||
};
|
||||
|
||||
export default registerPlugin;
|
||||
155
plugins/types.ts
Normal file
155
plugins/types.ts
Normal file
|
|
@ -0,0 +1,155 @@
|
|||
import EventEmitter from "eventemitter3";
|
||||
import { StatusWithRelations } from "~database/entities/Status";
|
||||
import { UserWithRelations } from "~database/entities/User";
|
||||
import { LysandObjectType } from "~types/lysand/Object";
|
||||
|
||||
export enum HookTypes {
|
||||
/**
|
||||
* Called before the server starts listening
|
||||
*/
|
||||
PreServe = "preServe",
|
||||
/**
|
||||
* Called after the server stops listening
|
||||
*/
|
||||
PostServe = "postServe",
|
||||
/**
|
||||
* Called on every HTTP request (before anything else is done)
|
||||
*/
|
||||
OnRequestReceive = "onRequestReceive",
|
||||
/**
|
||||
* Called on every HTTP request (after it is processed)
|
||||
*/
|
||||
OnRequestProcessed = "onRequestProcessed",
|
||||
/**
|
||||
* Called on every object received (before it is parsed and added to the database)
|
||||
*/
|
||||
OnObjectReceive = "onObjectReceive",
|
||||
/**
|
||||
* Called on every object processed (after it is parsed and added to the database)
|
||||
*/
|
||||
OnObjectProcessed = "onObjectProcessed",
|
||||
/**
|
||||
* Called when signature verification fails on an object
|
||||
*/
|
||||
OnCryptoFail = "onCryptoFail",
|
||||
/**
|
||||
* Called when signature verification succeeds on an object
|
||||
*/
|
||||
OnCryptoSuccess = "onCryptoSuccess",
|
||||
/**
|
||||
* Called when a user is banned by another user
|
||||
*/
|
||||
OnBan = "onBan",
|
||||
/**
|
||||
* Called when a user is suspended by another user
|
||||
*/
|
||||
OnSuspend = "onSuspend",
|
||||
/**
|
||||
* Called when a user is blocked by another user
|
||||
*/
|
||||
OnUserBlock = "onUserBlock",
|
||||
/**
|
||||
* Called when a user is muted by another user
|
||||
*/
|
||||
OnUserMute = "onUserMute",
|
||||
/**
|
||||
* Called when a user is followed by another user
|
||||
*/
|
||||
OnUserFollow = "onUserFollow",
|
||||
/**
|
||||
* Called when a user registers (before completing email verification)
|
||||
*/
|
||||
OnRegister = "onRegister",
|
||||
/**
|
||||
* Called when a user finishes registering (after completing email verification)
|
||||
*/
|
||||
OnRegisterFinish = "onRegisterFinish",
|
||||
/**
|
||||
* Called when a user deletes their account
|
||||
*/
|
||||
OnDeleteAccount = "onDeleteAccount",
|
||||
/**
|
||||
* Called when a post is created
|
||||
*/
|
||||
OnPostCreate = "onPostCreate",
|
||||
/**
|
||||
* Called when a post is deleted
|
||||
*/
|
||||
OnPostDelete = "onPostDelete",
|
||||
/**
|
||||
* Called when a post is updated
|
||||
*/
|
||||
OnPostUpdate = "onPostUpdate",
|
||||
}
|
||||
|
||||
export interface ServerStats {
|
||||
postCount: number;
|
||||
}
|
||||
|
||||
interface ServerEvents {
|
||||
[HookTypes.PreServe]: () => void;
|
||||
[HookTypes.PostServe]: (stats: ServerStats) => void;
|
||||
[HookTypes.OnRequestReceive]: (req: Request) => void;
|
||||
[HookTypes.OnRequestProcessed]: (req: Request) => void;
|
||||
[HookTypes.OnObjectReceive]: (obj: LysandObjectType) => void;
|
||||
[HookTypes.OnObjectProcessed]: (obj: LysandObjectType) => void;
|
||||
[HookTypes.OnCryptoFail]: (
|
||||
req: Request,
|
||||
obj: LysandObjectType,
|
||||
author: UserWithRelations,
|
||||
publicKey: string
|
||||
) => void;
|
||||
[HookTypes.OnCryptoSuccess]: (
|
||||
req: Request,
|
||||
obj: LysandObjectType,
|
||||
author: UserWithRelations,
|
||||
publicKey: string
|
||||
) => void;
|
||||
[HookTypes.OnBan]: (
|
||||
req: Request,
|
||||
bannedUser: UserWithRelations,
|
||||
banner: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnSuspend]: (
|
||||
req: Request,
|
||||
suspendedUser: UserWithRelations,
|
||||
suspender: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnUserBlock]: (
|
||||
req: Request,
|
||||
blockedUser: UserWithRelations,
|
||||
blocker: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnUserMute]: (
|
||||
req: Request,
|
||||
mutedUser: UserWithRelations,
|
||||
muter: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnUserFollow]: (
|
||||
req: Request,
|
||||
followedUser: UserWithRelations,
|
||||
follower: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnRegister]: (req: Request, newUser: UserWithRelations) => void;
|
||||
[HookTypes.OnDeleteAccount]: (
|
||||
req: Request,
|
||||
deletedUser: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnPostCreate]: (
|
||||
req: Request,
|
||||
newPost: StatusWithRelations,
|
||||
author: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnPostDelete]: (
|
||||
req: Request,
|
||||
deletedPost: StatusWithRelations,
|
||||
deleter: UserWithRelations
|
||||
) => void;
|
||||
[HookTypes.OnPostUpdate]: (
|
||||
req: Request,
|
||||
updatedPost: StatusWithRelations,
|
||||
updater: UserWithRelations
|
||||
) => void;
|
||||
}
|
||||
|
||||
export class Server extends EventEmitter<ServerEvents> {}
|
||||
Loading…
Reference in a new issue