Initial commit - linting in progress!

Author: davilag

.env

@@ -0,0 +1,7 @@
+export SF_URL=
+export SF_USERNAME=
+export SF_PASS=
+export SF_TOKEN=
+export SF_CLIENT_SECRET=
+export SF_CLIENT_ID=
+export SF_EVENT=

.eslintrc.js

@@ -0,0 +1,6 @@
+module.exports = {
+  extends: ['airbnb-typescript'],
+  parserOptions: {
+    project: './tsconfig.json',
+  },
+};

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+dist

package.json

@@ -0,0 +1,31 @@
+{
+  "name": "platform-event-consumer",
+  "version": "1.0.0",
+  "description": "A package to consume Platform Events from Salesforce",
+  "main": "index.ts",
+  "scripts": {
+    "build": "rm -rf ./dist && tsc",
+    "test:lint": "eslint --ext .js,.ts .",
+    "start": "node dist/index.js"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "@salesforce/ts-types": "^1.2.2",
+    "@types/node": "^14.0.5",
+    "cometd": "^5.0.0",
+    "cometd-nodejs-client": "^1.1.0",
+    "ts-force": "^3.0.0-rc.3"
+  },
+  "devDependencies": {
+    "@types/cometd": "^4.0.7",
+    "@typescript-eslint/eslint-plugin": "^2.24.0",
+    "eslint": "^7.0.0",
+    "eslint-config-airbnb-typescript": "^7.2.1",
+    "eslint-plugin-import": "^2.20.1",
+    "eslint-plugin-jsx-a11y": "^6.2.3",
+    "eslint-plugin-react": "^7.19.0",
+    "json-schema": "^0.2.5",
+    "typescript": "^3.8.3"
+  }
+}

src/.gitignore

@@ -0,0 +1,2 @@
+node_modules
+dist

src/@types/cometd-nodejs-client/index.d.ts

@@ -0,0 +1,14 @@
+declare module 'cometd-nodejs-client' {
+  export interface CometDClientOptions {
+    logLevel?: string,
+    httpProxy?: HTTPProxyOptions
+  }
+
+  export interface HTTPProxyOptions {
+    uri?: string,
+    includes?: boolean,
+    excludes?: boolean
+  }
+
+  export function adapt(options?: CometDClientOptions): void;
+}

src/index.ts

@@ -0,0 +1,15 @@
+import { authenticate, subscribe } from './sf';
+
+authenticate(
+  process.env.SF_USERNAME!,
+  process.env.SF_PASS!,
+  process.env.SF_TOKEN!,
+  process.env.SF_URL!,
+  process.env.SF_CLIENT_SECRET!,
+  process.env.SF_CLIENT_ID!,
+)
+  .then((authInfo) => {
+    subscribe(authInfo.accessToken, authInfo.instanceUrl, process.env.SF_EVENT!);
+  });
+
+process.stdin.resume();

src/sf/index.ts

@@ -0,0 +1,59 @@
+import cometD from 'cometd';
+import adapter from 'cometd-nodejs-client';
+import { OAuth, UsernamePasswordConfig } from 'ts-force';
+
+const authenticate = async (
+  username: string,
+  password: string,
+  accessToken: string,
+  loginURL: string,
+  clientSecret: string,
+  clientId: string) => {
+  const config = new UsernamePasswordConfig(
+    clientId,
+    clientSecret,
+    loginURL,
+    username,
+    `${password}${accessToken}`,
+  );
+
+  const oAuth = new OAuth(config);
+  return oAuth.initialize();
+};
+
+const subscribe = (
+  accessToken: string,
+  sfURL: string,
+  event: string,
+) => {
+  adapter.adapt();
+  // Create the CometD object.
+  const cometd = new cometD.CometD();
+
+  // Configure the CometD object.
+  cometd.configure({
+    url: `${sfURL}/cometd/48.0/`,
+    appendMessageTypeToURL: false,
+    requestHeaders: { Authorization: `OAuth ${accessToken}` },
+  });
+
+  // Handshake with the server.
+  cometd.handshake((h) => {
+    if (!h.successful) {
+      console.error('Unsuccessful handshake');
+    }
+
+    console.log('Handshake succesful');
+    // Subscribe to receive messages from the server.
+    cometd.subscribe(`/event/${event}`, (m) => {
+      const dataFromServer = m.data;
+      console.log(dataFromServer);
+      // Use dataFromServer.
+    });
+  });
+};
+
+export {
+  authenticate,
+  subscribe,
+};

tsconfig.json

@@ -0,0 +1,24 @@
+{
+  "compilerOptions": {
+    "typeRoots": [
+      "node_modules/@types",
+      "src/@types",
+    ],
+    "target": "es6",
+    "module": "commonjs",
+    "outDir": "dist",
+    "noImplicitAny": true,
+    "strict": true,
+    "esModuleInterop": true,
+    "experimentalDecorators": true,
+    "emitDecoratorMetadata": true
+  },
+  "include": [
+    "src/**/*"
+  ],
+  "exclude": [
+    ".eslintrc.js",
+    "node_modules",
+    "**/__tests__/*"
+  ]
+}