Change file structure of workers

package.json

@@ -3,17 +3,17 @@
     "test": "echo \"Error: no test specified\" && exit 1",
     "dev": "run-p dev:server dev:send-user-feed dev:subscriptions dev:sync-resources",
     "dev:server": "nodemon index.js ",
-    "dev:send-user-feed": "nodemon ./src/workers/consumers/sendFeedConsumer.js",
-    "dev:subscriptions": "nodemon ./src/workers/consumers/subscriptionConsumer.js",
-    "dev:sync-resources": "nodemon ./src/workers/consumers/syncResourcesConsumer.js",
-    "dev:generate-users-feeds": "nodemon ./src/workers/generateUsersFeeds.js",
-    "dev:generate-stale-resources": "nodemon ./src/workers/syncResources.js",
+    "dev:send-user-feed": "nodemon ./src/workers/user-feeds/sendFeedConsumer.js",
+    "dev:subscriptions": "nodemon ./src/workers/subscriptions/subscriptionConsumer.js",
+    "dev:sync-resources": "nodemon ./src/workers/sync-resources/syncResourcesConsumer.js",
+    "dev:generate-users-feeds": "nodemon ./src/workers/user-feeds/generateUsersFeeds.js",
+    "dev:generate-stale-resources": "nodemon ./src/workers/sync-resources/syncResources.js",
     "start": "node index.js",
-    "generate-users-feeds": "node ./src/workers/generateUsersFeeds.js",
-    "generate-stale-resources": "node ./src/workers/syncResources.js",
-    "send-user-feed": "node ./src/workers/consumers/sendFeedConsumer.js",
-    "subscriptions": "node ./src/workers/consumers/subscriptionConsumer.js",
-    "sync-resources": "node ./src/workers/consumers/syncResourcesConsumer.js"
+    "generate-users-feeds": "node ./src/workers/user-feeds/generateUsersFeeds.js",
+    "generate-stale-resources": "node ./src/workers/sync-resources/syncResources.js",
+    "send-user-feed": "node ./src/workers/user-feeds/sendFeedConsumer.js",
+    "subscriptions": "node ./src/workers/subscriptions/subscriptionConsumer.js",
+    "sync-resources": "node ./src/workers/sync-resources/syncResourcesConsumer.js"
   },
   "type": "module",
   "dependencies": {

src/services/resource.js

@@ -7,7 +7,7 @@ import {
   extractSubstackAuthorNameFromURL,
   parseMediumUrl,
 } from "../utils/scrapeHelpers.js";
-import subscriptionPublisher from "../workers/publishers/subscriptionPublisher.js";
+import subscriptionPublisher from "../workers/subscriptions/subscriptionPublisher.js";
 
 export default class ResourceService {
   constructor(source) {

src/workers/syncResources.js → src/workers/sync-resources/syncResources.js

@@ -1,13 +1,13 @@
 import dotenv from "dotenv";
-import { startDb } from "../config/database.js";
-import AuthorModel from "../models/authors.js";
+import { startDb } from "../../config/database.js";
+import AuthorModel from "../../models/authors.js";
 import syncResourcesPublisher from "./publishers/syncResourcesPublisher.js";
 import { fileURLToPath } from "url";
 import path from "path";
 
 const __filename = fileURLToPath(import.meta.url);
 
-dotenv.config({ path: path.resolve(__filename, "../../../.env") });
+dotenv.config({ path: path.resolve(__filename, "../../../../.env") });
 
 const syncResources = async () => {
   startDb(process.env.MONGO_URI);

src/workers/generateUsersFeeds.js → src/workers/user-feeds/generateUsersFeeds.js

@@ -1,13 +1,13 @@
 import dotenv from "dotenv";
-import { startDb } from "../config/database.js";
-import UserModel from "../models/users.js";
-import sendUserFeed from "./publishers/sendFeedPublisher.js";
+import { startDb } from "../../config/database.js";
+import UserModel from "../../models/users.js";
+import sendUserFeed from "./sendFeedPublisher.js";
 import { fileURLToPath } from "url";
 import path from "path";
 
 const __filename = fileURLToPath(import.meta.url);
 
-dotenv.config({ path: path.resolve(__filename, "../../../.env") });
+dotenv.config({ path: path.resolve(__filename, "../../../../.env")});
 
 const generateUsersFeeds = async () => {
   startDb(process.env.MONGO_URI);