chore: updated server IP paths

jaineil · Nov 14, 2021 · d702157 · d702157
1 parent 70d7e34
commit d702157
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 29 deletions.
diff --git a/kafka-server/kafka/connection.js b/kafka-server/kafka/connection.js
@@ -1,9 +1,9 @@
 import kafka from "kafka-node";
-
+import { kafkaIP } from "../kafkaServerConfig.js";
 export class ConnectionProvider {
 	constructor() {
 		this.getConsumer = (topicName) => {
-			this.client = new kafka.KafkaClient("localhost:9092");
+			this.client = new kafka.KafkaClient(`${kafkaIP}:9092`);
 
 			this.kafkaConsumerConnection = new kafka.Consumer(this.client, [
 				{ topic: topicName, partition: 0 },
@@ -17,23 +17,12 @@ export class ConnectionProvider {
 		};
 
 		this.getProducer = () => {
-			// if (!this.kafkaProducerConnection) {
-			//     this.client = new kafka.KafkaClient('localhost:2181');
-
-			//     // const HighLevelProducer = kafka.HighLevelProducer;
-			//     this.kafkaProducerConnection = new kafka.HighLevelProducer(this.client);
-			//     //this.kafkaConnection = new kafka.Producer(this.client);
-			//     console.log('Producer ready!');
-			// }
-
-			this.client = new kafka.KafkaClient("localhost:9092");
+			this.client = new kafka.KafkaClient(`${kafkaIP}:9092`);
 
-			// const HighLevelProducer = kafka.HighLevelProducer;
 			this.kafkaProducerConnection = new kafka.HighLevelProducer(
 				this.client
 			);
 
-			//this.kafkaConnection = new kafka.Producer(this.client);
 			this.client.on("ready", () => {
 				console.log("Producer ready!");
 			});

diff --git a/server/index.js b/server/index.js
@@ -8,9 +8,10 @@ import { make_request } from "./kafka/client.js";
 import customerRoutes from "./routes/customer.routes.js";
 import orderRoutes from "./routes/order.routes.js";
 import restaurantRoutes from "./routes/restaurant.routes.js";
+import { serverIP } from "./serverConfig.js";
 
 const app = express();
-app.use(cors({ origin: "http://localhost:3000", credentials: true }));
+app.use(cors({ origin: `http://${serverIP}:3000`, credentials: true }));
 app.use(cookieParser());
 
 app.use(

diff --git a/server/kafka/connection.js b/server/kafka/connection.js
@@ -1,9 +1,9 @@
 import kafka from "kafka-node";
-
+import { kafkaIP } from "../../kafka-server/kafkaServerConfig.js";
 export class ConnectionProvider {
 	constructor() {
 		this.getConsumer = (topicName) => {
-			this.client = new kafka.KafkaClient("localhost:9092");
+			this.client = new kafka.KafkaClient(`${kafkaIP}:9092`);
 
 			this.kafkaConsumerConnection = new kafka.Consumer(this.client, [
 				{ topic: topicName, partition: 0 },
@@ -17,21 +17,10 @@ export class ConnectionProvider {
 		};
 
 		this.getProducer = () => {
-			// if (!this.kafkaProducerConnection) {
-			//     this.client = new kafka.KafkaClient('localhost:2181');
-
-			//     // const HighLevelProducer = kafka.HighLevelProducer;
-			//     this.kafkaProducerConnection = new kafka.HighLevelProducer(this.client);
-			//     //this.kafkaConnection = new kafka.Producer(this.client);
-			//     console.log('Producer ready!');
-			// }
-
-			this.client = new kafka.KafkaClient("localhost:9092");
-			// const HighLevelProducer = kafka.HighLevelProducer;
+			this.client = new kafka.KafkaClient(`${kafkaIP}:9092`);
 			this.kafkaProducerConnection = new kafka.HighLevelProducer(
 				this.client
 			);
-			//this.kafkaConnection = new kafka.Producer(this.client);
 			this.client.on("ready", () => {
 				console.log("Producer ready!");
 			});