upload webhook

webhooks/application1/.gitignore

@@ -0,0 +1,3 @@
+node_modules
+dist
+.env

webhooks/application1/package.json

@@ -0,0 +1,28 @@
+{
+  "name": "folder_structure",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "build": "tsc",
+    "start": "tsc && node ./dist/index.js"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC",
+  "devDependencies": {
+    "@types/bcrypt": "^5.0.0",
+    "@types/node": "^20.4.8",
+    "typescript": "^5.1.6"
+  },
+  "dependencies": {
+    "@types/express": "^4.17.17",
+    "amqplib": "^0.10.3",
+    "axios": "^1.4.0",
+    "bcrypt": "^5.1.0",
+    "dotenv": "^16.3.1",
+    "express": "^4.18.2",
+    "mongoose": "^7.4.2",
+    "node-cron": "^3.0.2"
+  }
+}

webhooks/application1/src/config/dotenv.config.ts

@@ -0,0 +1,4 @@
+// require("dotenv").config();
+import dotenv from "dotenv";
+
+dotenv.config();

webhooks/application1/src/controller/auth.controler.ts

@@ -0,0 +1,21 @@
+import { Response, Request } from "express";
+
+
+import { writeErrorToFile } from "../node-cron/error_write";
+import { signUp } from "../services/auth.services";
+
+
+export const signup = async (req: Request, res: Response) => {
+  try {
+    const { name, email, username, password, phone_no } = req.body;
+
+    const user = await signUp(name, email, username, password, phone_no);
+
+
+    res.status(201).json({ message: "User Signup successfully application 1" });
+  } catch (e) {
+    console.error(e);
+    res.status(500).json({ message: "Internal server error" });
+    writeErrorToFile(e);
+  }
+};

webhooks/application1/src/database/dbconnection.ts

@@ -0,0 +1,12 @@
+import mongoose from "mongoose";
+import "../config/dotenv.config";
+const url = process.env.DB_CONNECTION_URL;
+
+export const connection = async () => {
+  try {
+    await mongoose.connect(url);
+    console.log("Succesfully connected to the db");
+  } catch (e) {
+    console.log(e, "ERRRRRR");
+  }
+};

webhooks/application1/src/index.ts

@@ -0,0 +1,17 @@
+import express from "express";
+import { connection } from "./database/dbconnection";
+import signUp from "./routes/user.rotes";
+import { task } from "./node-cron/delete_error";
+import dotenv from "dotenv";
+
+dotenv.config();
+const app = express();
+const port = process.env.PORT || 3001;
+app.use(express.json());
+app.use(signUp);
+
+app.listen(port, () => {
+    //  task
+  console.log(`port is running in ${port}`);
+  connection();
+});

webhooks/application1/src/models/user.model.ts

@@ -0,0 +1,24 @@
+import mongoose, { Document, Schema } from "mongoose";
+interface User extends Document {
+  name: string;
+  email: string;
+  username: string;
+  password: string;
+  phone_no: string;
+  created_At: Date;
+  updated_At: Date;
+}
+
+const userSchema: Schema<User> = new Schema<User>({
+  name: { type: String, required: true },
+  email: { type: String, required: true },
+  username: { type: String, required: true },
+  password: { type: String, required: true },
+  phone_no: { type: String, required: true },
+  created_At: { type: Date, default: Date.now },
+  updated_At: { type: Date, default: Date.now },
+});
+
+const UserModel = mongoose.model<User>("User", userSchema);
+
+export default UserModel;

webhooks/application1/src/node-cron/delete_error.ts

@@ -0,0 +1,15 @@
+import fs from "fs";
+import cron from "node-cron";
+import path from "path";
+
+export const task = cron.schedule("* */2 * * * ", () => {
+  const filePath = path.join(__dirname, "../../error.log");
+  console.log(filePath);
+  fs.unlink(filePath, (err) => {
+    if (err) {
+      console.error(err);
+      return;
+    }
+    console.log(`Deleted ${filePath}`);
+  });
+});

webhooks/application1/src/node-cron/error_write.ts

@@ -0,0 +1,10 @@
+import fs from "fs";
+
+export function writeErrorToFile(error) {
+  const errorMessage = `${new Date().toISOString()} - ${error.stack}\n`;
+  try {
+    fs.appendFileSync("error.log", errorMessage);
+  } catch (error) {
+    console.error(`Error writing to file: ${error.message}`);
+  }
+}

webhooks/application1/src/routes/user.rotes.ts

@@ -0,0 +1,9 @@
+import express from "express";
+import { signup } from "../controller/auth.controler";
+
+const router = express.Router();
+
+router.post("/signup", signup);
+
+
+export default router;

webhooks/application1/src/services/auth.services.ts

@@ -0,0 +1,46 @@
+import axios from "axios";
+import UserModel from "../models/user.model";
+
+import bcrypt from "bcrypt";
+
+export async function signUp(
+  name: string,
+  email: string,
+  username: string,
+  password: string,
+  phone_no: bigint
+): Promise<any> {
+  try {
+    const hashedPassword = await bcrypt.hash(password, 2);
+
+    const users = new UserModel({
+      name: name,
+      email: email,
+      username: username,
+      password: hashedPassword,
+      phone_no: phone_no,
+    });
+
+    console.log(users);
+    await users.save();
+
+    axios
+      .post("http://localhost:3001/signup", {
+        name: name,
+        email: email,
+        username: username,
+        password: password,
+        phone_no: phone_no,
+      })
+      .then(function (response) {
+        console.log("==========", response.data);
+      })
+      .catch(function (error) {
+        console.log(error);
+      });
+  } catch (e) {
+    console.error("error creating user :", e);
+    throw new Error("hi error a gya ");
+  }
+}
+

webhooks/application1/tsconfig.json

@@ -0,0 +1,12 @@
+{
+  "compilerOptions":{
+      "module": "NodeNext",
+      "moduleResolution": "NodeNext",
+      "target":"ES2020",
+      "sourceMap": true,
+      "outDir": "dist",    
+  },
+
+  "include": ["src/**/*"],
+  "resolveJsonModule": true
+}

webhooks/application2/.gitignore

@@ -0,0 +1,3 @@
+node_modules
+dist
+.env