Paymentservice

.dockerignore

@@ -0,0 +1 @@
+node_modules

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+.DS_Store

Dockerfile

@@ -0,0 +1,49 @@
+# Copyright 2020 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+FROM node:20.2.0-alpine@sha256:f25b0e9d3d116e267d4ff69a3a99c0f4cf6ae94eadd87f1bf7bd68ea3ff0bef7 as base
+
+FROM base as builder
+
+# Some packages (e.g. @google-cloud/profiler) require additional
+# deps for post-install scripts
+RUN apk add --update --no-cache \
+    python3 \
+    make \
+    g++ 
+
+WORKDIR /usr/src/app
+
+COPY package*.json ./
+
+RUN npm install --only=production
+
+FROM base as without-grpc-health-probe-bin
+
+WORKDIR /usr/src/app
+
+COPY --from=builder /usr/src/app/node_modules ./node_modules
+
+COPY . .
+
+EXPOSE 50051
+
+ENTRYPOINT [ "node", "index.js" ]
+
+FROM without-grpc-health-probe-bin
+
+# renovate: datasource=github-releases depName=grpc-ecosystem/grpc-health-probe
+ENV GRPC_HEALTH_PROBE_VERSION=v0.4.18
+RUN wget -qO/bin/grpc_health_probe https://github.com/grpc-ecosystem/grpc-health-probe/releases/download/${GRPC_HEALTH_PROBE_VERSION}/grpc_health_probe-linux-amd64 && \
+    chmod +x /bin/grpc_health_probe

Jenkinsfile

@@ -0,0 +1,25 @@
+pipeline {
+    agent any
+
+    stages {
+        stage('Build & Tag Docker Image') {
+            steps {
+                script {
+                    withDockerRegistry(credentialsId: 'docker-cred', toolName: 'docker') {
+                        sh "docker build -t abhishek0768/paymentservice:latest ."
+                    }
+                }
+            }
+        }
+
+        stage('Push Docker Image') {
+            steps {
+                script {
+                    withDockerRegistry(credentialsId: 'docker-cred', toolName: 'docker') {
+                        sh "docker push abhishek0768/paymentservice:latest "
+                    }
+                }
+            }
+        }
+    }
+}

charge.js

@@ -0,0 +1,86 @@
+// Copyright 2018 Google LLC
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+const cardValidator = require('simple-card-validator');
+const { v4: uuidv4 } = require('uuid');
+const pino = require('pino');
+
+const logger = pino({
+  name: 'paymentservice-charge',
+  messageKey: 'message',
+  formatters: {
+    level (logLevelString, logLevelNum) {
+      return { severity: logLevelString }
+    }
+  }
+});
+
+
+class CreditCardError extends Error {
+  constructor (message) {
+    super(message);
+    this.code = 400; // Invalid argument error
+  }
+}
+
+class InvalidCreditCard extends CreditCardError {
+  constructor (cardType) {
+    super(`Credit card info is invalid`);
+  }
+}
+
+class UnacceptedCreditCard extends CreditCardError {
+  constructor (cardType) {
+    super(`Sorry, we cannot process ${cardType} credit cards. Only VISA or MasterCard is accepted.`);
+  }
+}
+
+class ExpiredCreditCard extends CreditCardError {
+  constructor (number, month, year) {
+    super(`Your credit card (ending ${number.substr(-4)}) expired on ${month}/${year}`);
+  }
+}
+
+/**
+ * Verifies the credit card number and (pretend) charges the card.
+ *
+ * @param {*} request
+ * @return transaction_id - a random uuid.
+ */
+module.exports = function charge (request) {
+  const { amount, credit_card: creditCard } = request;
+  const cardNumber = creditCard.credit_card_number;
+  const cardInfo = cardValidator(cardNumber);
+  const {
+    card_type: cardType,
+    valid
+  } = cardInfo.getCardDetails();
+
+  if (!valid) { throw new InvalidCreditCard(); }
+
+  // Only VISA and mastercard is accepted, other card types (AMEX, dinersclub) will
+  // throw UnacceptedCreditCard error.
+  if (!(cardType === 'visa' || cardType === 'mastercard')) { throw new UnacceptedCreditCard(cardType); }
+
+  // Also validate expiration is > today.
+  const currentMonth = new Date().getMonth() + 1;
+  const currentYear = new Date().getFullYear();
+  const { credit_card_expiration_year: year, credit_card_expiration_month: month } = creditCard;
+  if ((currentYear * 12 + currentMonth) > (year * 12 + month)) { throw new ExpiredCreditCard(cardNumber.replace('-', ''), month, year); }
+
+  logger.info(`Transaction processed: ${cardType} ending ${cardNumber.substr(-4)} \
+    Amount: ${amount.currency_code}${amount.units}.${amount.nanos}`);
+
+  return { transaction_id: uuidv4() };
+};

genproto.sh

@@ -0,0 +1,23 @@
+#!/bin/bash -eu
+#
+# Copyright 2018 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+# [START gke_paymentservice_genproto]
+
+# protos are loaded dynamically for node, simply copies over the proto.
+mkdir -p proto
+cp -r ../../protos/* ./proto
+
+# [END gke_paymentservice_genproto]

index.js

@@ -0,0 +1,66 @@
+/*
+ * Copyright 2018 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+'use strict';
+
+
+if(process.env.DISABLE_PROFILER) {
+  console.log("Profiler disabled.")
+}
+else {
+  console.log("Profiler enabled.")
+  require('@google-cloud/profiler').start({
+    serviceContext: {
+      service: 'paymentservice',
+      version: '1.0.0'
+    }
+  });
+}
+
+
+if(process.env.ENABLE_TRACING == "1") {
+  console.log("Tracing enabled.")
+  const { NodeTracerProvider } = require('@opentelemetry/sdk-trace-node');
+  const { SimpleSpanProcessor } = require('@opentelemetry/sdk-trace-base');
+  const { GrpcInstrumentation } = require('@opentelemetry/instrumentation-grpc');
+  const { registerInstrumentations } = require('@opentelemetry/instrumentation');
+  const { OTLPTraceExporter } = require("@opentelemetry/exporter-otlp-grpc");
+
+  const provider = new NodeTracerProvider();
+
+  const collectorUrl = process.env.COLLECTOR_SERVICE_ADDR
+
+  provider.addSpanProcessor(new SimpleSpanProcessor(new OTLPTraceExporter({url: collectorUrl})));
+  provider.register();
+
+  registerInstrumentations({
+    instrumentations: [new GrpcInstrumentation()]
+  });
+}
+else {
+  console.log("Tracing disabled.")
+}
+
+
+const path = require('path');
+const HipsterShopServer = require('./server');
+
+const PORT = process.env['PORT'];
+const PROTO_PATH = path.join(__dirname, '/proto/');
+
+const server = new HipsterShopServer(PROTO_PATH, PORT);
+
+server.listen();