4 files changed, 8 insertions, 8 deletions
diff --git a/src/server/api/endpoints/drive/files/delete.ts b/src/server/api/endpoints/drive/files/delete.ts
index e29e330aa8..fc6849e57e 100644
--- a/src/server/api/endpoints/drive/files/delete.ts
+++ b/src/server/api/endpoints/drive/files/delete.ts
@@ -45,8 +45,8 @@ export default (params: any, user: ILocalUser) => new Promise(async (res, rej) =
 	// Delete
 	await del(file);
 
-	// Publish file_deleted event
-	publishDriveStream(user._id, 'file_deleted', file._id);
+	// Publish fileDeleted event
+	publishDriveStream(user._id, 'fileDeleted', file._id);
 
 	res();
 });
diff --git a/src/server/api/endpoints/drive/files/update.ts b/src/server/api/endpoints/drive/files/update.ts
index 9b8c53caf7..915cf4ceb2 100644
--- a/src/server/api/endpoints/drive/files/update.ts
+++ b/src/server/api/endpoints/drive/files/update.ts
@@ -114,6 +114,6 @@ export default (params: any, user: ILocalUser) => new Promise(async (res, rej) =
 	// Response
 	res(fileObj);
 
-	// Publish file_updated event
-	publishDriveStream(user._id, 'file_updated', fileObj);
+	// Publish fileUpdated event
+	publishDriveStream(user._id, 'fileUpdated', fileObj);
 });
diff --git a/src/server/api/endpoints/drive/folders/create.ts b/src/server/api/endpoints/drive/folders/create.ts
index 5997dedf0f..f83fe46cdd 100644
--- a/src/server/api/endpoints/drive/folders/create.ts
+++ b/src/server/api/endpoints/drive/folders/create.ts
@@ -52,6 +52,6 @@ export default (params: any, user: ILocalUser) => new Promise(async (res, rej) =
 	// Response
 	res(folderObj);
 
-	// Publish folder_created event
-	publishDriveStream(user._id, 'folder_created', folderObj);
+	// Publish folderCreated event
+	publishDriveStream(user._id, 'folderCreated', folderObj);
 });
diff --git a/src/server/api/endpoints/drive/folders/update.ts b/src/server/api/endpoints/drive/folders/update.ts
index 259f373bfc..479dd2fd4c 100644
--- a/src/server/api/endpoints/drive/folders/update.ts
+++ b/src/server/api/endpoints/drive/folders/update.ts
@@ -96,6 +96,6 @@ export default (params: any, user: ILocalUser) => new Promise(async (res, rej) =
 	// Response
 	res(folderObj);
 
-	// Publish folder_updated event
-	publishDriveStream(user._id, 'folder_updated', folderObj);
+	// Publish folderUpdated event
+	publishDriveStream(user._id, 'folderUpdated', folderObj);
 });