initial code

Author: jomit

.gitignore

@@ -0,0 +1,70 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (http://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (http://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+**/node_modules/
+jspm_packages/
+
+# Typescript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+
+bin*/
+obj*/
+
+build*/
+
+node1*/
+smartcontracts*/
+
+launch.json
+
+apptokens.json

README.md

@@ -1,2 +1,12 @@
-# ap-bot
-Sample Accounts Payable Bot
+# Accounts Payable Bot using Azure Bot Service
+
+![Accounts Payable Bot using Azure Bot Service](https://raw.githubusercontent.com/jomit/ap-bot/master/architecture.png)
+
+#### Prerequisites
+ 
+TODO
+
+#### Setup
+
+TODO
+

architecture.png

@@ -0,0 +1,6 @@
+require("dotenv").load();
+var messagebusjob = require("./messagebusjob");
+var fs = require("fs");
+
+console.log("Starting Bot Processing Job...");
+messagebusjob.startprocessing();

console/app.js

@@ -0,0 +1,89 @@
+USE [ContosoEdw]
+GO
+
+SET ANSI_NULLS ON
+GO
+SET QUOTED_IDENTIFIER ON
+GO
+CREATE TABLE [dbo].[AutoInvoiceHeader](
+	[InvoiceNumber] [nvarchar](50) NOT NULL,
+	[SupplierCode] [nvarchar](10) NOT NULL,
+	[InvoiceStatus] [nvarchar](50) NOT NULL,
+ CONSTRAINT [PK_AutoInvoiceHeader] PRIMARY KEY CLUSTERED 
+(
+	[InvoiceNumber] ASC,
+	[SupplierCode] ASC
+)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
+) ON [PRIMARY]
+GO
+
+SET ANSI_NULLS ON
+GO
+SET QUOTED_IDENTIFIER ON
+GO
+CREATE TABLE [dbo].[PurchaseOrder](
+	[SAPPONumber] [nvarchar](50) NOT NULL,
+	[PurchaseOrderStatus] [nvarchar](50) NOT NULL,
+ CONSTRAINT [PK_PurchaseOrder] PRIMARY KEY CLUSTERED 
+(
+	[SAPPONumber] ASC
+)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
+) ON [PRIMARY]
+GO
+
+SET ANSI_NULLS ON
+GO
+SET QUOTED_IDENTIFIER ON
+GO
+CREATE TABLE [dbo].[Supplier](
+	[SupplierCode] [nvarchar](10) NOT NULL,
+	[Name] [nvarchar](500) NOT NULL,
+ CONSTRAINT [PK_Suppliers] PRIMARY KEY CLUSTERED 
+(
+	[SupplierCode] ASC
+)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
+) ON [PRIMARY]
+GO
+
+INSERT [dbo].[AutoInvoiceHeader] ([InvoiceNumber], [SupplierCode], [InvoiceStatus]) VALUES (N'11001', N'1234000', N'Processing')
+GO
+INSERT [dbo].[AutoInvoiceHeader] ([InvoiceNumber], [SupplierCode], [InvoiceStatus]) VALUES (N'11001', N'149033', N'InReview')
+GO
+INSERT [dbo].[AutoInvoiceHeader] ([InvoiceNumber], [SupplierCode], [InvoiceStatus]) VALUES (N'11002', N'149033', N'Paid')
+GO
+INSERT [dbo].[AutoInvoiceHeader] ([InvoiceNumber], [SupplierCode], [InvoiceStatus]) VALUES (N'11003', N'120010', N'Pending')
+GO
+INSERT [dbo].[PurchaseOrder] ([SAPPONumber], [PurchaseOrderStatus]) VALUES (N'11001', N'InReview')
+GO
+INSERT [dbo].[PurchaseOrder] ([SAPPONumber], [PurchaseOrderStatus]) VALUES (N'11002', N'Released')
+GO
+INSERT [dbo].[PurchaseOrder] ([SAPPONumber], [PurchaseOrderStatus]) VALUES (N'4300000009', N'Closed')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'120010', N'ABC Company')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1233100', N'Contestant TV')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1233200', N'Connection Consultants')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1233300', N'Contestant House')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1233400', N'Contoso XYZ')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1233500', N'Contestant Funds')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1234000', N'Contoso Space')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1234500', N'Contestant Network')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1234600', N'Contoso LLC')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1234700', N'Contestant Ltd')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1234800', N'Connections Inc.')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'1234900', N'Contestant Holdings')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'134510', N'XYZ Company Ltd')
+GO
+INSERT [dbo].[Supplier] ([SupplierCode], [Name]) VALUES (N'149033', N'Contoso Inc')
+GO

console/dbscript/localdb.sql

@@ -0,0 +1,89 @@
+const fs = require('fs');
+const tokenFile = "./email/apptokens.json";
+
+const credentials = {
+  client: {
+    id: process.env.APP_ID,
+    secret: process.env.APP_PASSWORD,
+  },
+  auth: {
+    tokenHost: 'https://login.microsoftonline.com',
+    authorizePath: 'common/oauth2/v2.0/authorize',
+    tokenPath: 'common/oauth2/v2.0/token'
+  }
+};
+
+const oauth2 = require('simple-oauth2').create(credentials);
+const jwt = require('jsonwebtoken');
+
+function getAuthUrl() {
+  const returnVal = oauth2.authorizationCode.authorizeURL({
+    redirect_uri: process.env.REDIRECT_URI,
+    scope: process.env.APP_SCOPES
+  });
+  console.log(`Generated auth url: ${returnVal}`);
+  return returnVal;
+}
+
+async function getAccessTokenFromCode(auth_code) {
+  let result = await oauth2.authorizationCode.getToken({
+    code: auth_code,
+    redirect_uri: process.env.REDIRECT_URI,
+    scope: process.env.APP_SCOPES
+  });
+
+  const token = oauth2.accessToken.create(result);
+  console.log('Token created: ', token.token);
+
+  saveToken(token);
+
+  return token.token.access_token;
+}
+
+async function getAccessToken() {
+
+  var appTokens = JSON.parse(fs.readFileSync(tokenFile, 'utf8'));
+  var token = appTokens.token;
+  var user = jwt.decode(token.id_token);
+
+  // Check if token is expired ? 
+  if(token.access_token){
+    const FIVE_MINUTES = 300000;  // Expire 5 minutes early to account for clock differences
+    var tokenExpirationTime = new Date(token.expires_at).getTime();
+    const expiration = new Date(parseFloat(tokenExpirationTime - FIVE_MINUTES));
+    if (expiration > new Date()) {
+      console.log("Token not Expired.")
+      return { 
+        "accesstoken": token.access_token,
+        "username" : user.name
+      };
+    }
+  }
+
+  // Get new token from refresh_token
+  const refresh_token = token.refresh_token;
+  if (refresh_token) {
+    console.log("Token Expired. Getting new token using Refresh token.");
+    //console.log(refresh_token);
+    const newToken = await oauth2.accessToken.create({ refresh_token: refresh_token }).refresh();
+    saveToken(newToken);
+    return { 
+      "accesstoken": newToken.token.access_token,
+      "username" : user.name
+    };
+  }
+}
+
+function saveToken(token){
+  fs.writeFile(tokenFile, JSON.stringify(token), function (err) {
+    if (err) {
+      return console.log(err);
+    }
+    console.log("Tokens Saved");
+  });
+}
+
+exports.getAuthUrl = getAuthUrl;
+exports.getAccessTokenFromCode = getAccessTokenFromCode;
+exports.getAccessToken = getAccessToken;
+exports.tokenFile = tokenFile;

console/email/auth.js

@@ -0,0 +1,37 @@
+const authHelper = require('./auth');
+const graph = require('@microsoft/microsoft-graph-client');
+var logger = require("../logger");
+async function replyMessage(msg, callback) {
+    var token = await authHelper.getAccessToken();
+    var client = graph.Client.init({
+        authProvider: (done) => {
+            done(null, token.accesstoken);
+        }
+    });
+    var emailBody = "Hello, </br></br>";
+    if(msg.messageType == 1) {
+        emailBody += "Payment status for " + msg.invoiceNumber + " and vendor " + msg.vendorName + " is : " + msg.status;
+    } else if(msg.messageType == 2){
+        emailBody += "PO status for " + msg.invoiceNumber + " is : " + msg.status;
+    } else if(msg.messageType == 3){
+        emailBody += "Here is the link to download the copy of your invoice : <a href='" + msg.downloadLink +"'>" + msg.invoiceNumber + "</a>";
+    }
+    emailBody += "<br/><br/>Thank you, <br/><br/>Contoso AP Bot"
+
+    const mail = {
+        subject: "Ticket " + msg.serviceNowTicketNumber + " has been Resolved",
+        toRecipients: [{
+            emailAddress: {
+                address: msg.replyTo
+            }
+        }],
+        body: {
+            content: emailBody,
+            contentType: "html"
+        }
+    }
+    await client.api('/users/me/sendMail').post({ message: mail });
+    logger.log("=================> Email sent to : " +  msg.replyTo + "\n")
+};
+exports.replyMessage = replyMessage;
+