From 51bb147dff78f8418ec4e86b689210f174e96f30 Mon Sep 17 00:00:00 2001
From: undefined <i@undefined.moe>
Date: Sat, 5 Feb 2022 15:51:35 +0800
Subject: [PATCH] core: allow hooking oplog

---
 packages/hydrooj/package.json       | 2 +-
 packages/hydrooj/src/model/oplog.ts | 2 ++
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/packages/hydrooj/package.json b/packages/hydrooj/package.json
index 80b2c48f2..edb9a6b4a 100644
--- a/packages/hydrooj/package.json
+++ b/packages/hydrooj/package.json
@@ -1,6 +1,6 @@
 {
     "name": "hydrooj",
-    "version": "3.4.4",
+    "version": "3.4.5",
     "bin": "bin/hydrooj.js",
     "main": "src/loader",
     "module": "src/loader",
diff --git a/packages/hydrooj/src/model/oplog.ts b/packages/hydrooj/src/model/oplog.ts
index de32c1a6a..eda870715 100644
--- a/packages/hydrooj/src/model/oplog.ts
+++ b/packages/hydrooj/src/model/oplog.ts
@@ -1,5 +1,6 @@
 import { ObjectID } from 'mongodb';
 import { OplogDoc } from '../interface';
+import * as bus from '../service/bus';
 import db from '../service/db';
 import type { Handler } from '../service/server';
 
@@ -18,6 +19,7 @@ export async function add(data: Partial<OplogDoc> & { type: string }): Promise<O
 export async function log<T extends Handler>(handler: T, type: string, data: any) {
     const args = { ...handler.args };
     delete args.password;
+    await bus.serial('oplog/log', type, handler, args, data);
     const res = await coll.insertOne({
         ...data,
         _id: new ObjectID(),