Add TLS support for rethinkdb

Author: ggabarrin

package.json

@@ -121,6 +121,11 @@
           "description": "Password for the RethinkDB connection.",
           "default": ""
         },
+        "security-notes.collab.ssl": {
+          "type": "string",
+          "description": "SSL/TLS certificate file path for the RethinkDB connection (optional).",
+          "default": ""
+        },
         "security-notes.collab.projectName": {
           "type": "string",
           "description": "Project name used as the RethinkDB table.",

src/extension.ts

@@ -29,6 +29,7 @@ export function activate(context: vscode.ExtensionContext) {
       getSetting('collab.password'),
       getSetting('collab.database'),
       getSetting('collab.projectName'),
+      getSetting('collab.ssl'),
       noteMap,
     );
   } else {

src/persistence/remote-db/index.ts

@@ -2,6 +2,7 @@ import * as vscode from 'vscode';
 import * as rethinkdb from 'rethinkdb';
 import { Serializer } from '../serialization/serializer';
 import { Deserializer } from '../serialization/deserializer';
+import { readFileSync } from 'fs';
 
 export class RemoteDb {
   private host: string;
@@ -10,6 +11,7 @@ export class RemoteDb {
   private password: string;
   private database: string;
   private table: string;
+  private ssl: string;
   private noteMap: Map<string, vscode.CommentThread>;
   private connection: any;
 
@@ -20,6 +22,7 @@ export class RemoteDb {
     password: string,
     database: string,
     table: string,
+    ssl: string,
     noteMap: Map<string, vscode.CommentThread>,
   ) {
     this.host = host;
@@ -28,6 +31,7 @@ export class RemoteDb {
     this.password = password;
     this.database = database;
     this.table = table;
+    this.ssl = ssl;
     this.noteMap = noteMap;
 
     this.connect();
@@ -41,6 +45,12 @@ export class RemoteDb {
         db: this.database,
         user: this.username,
         password: this.password,
+        ssl:
+          this.ssl !== ''
+            ? {
+                ca: readFileSync(this.ssl).toString().trim(),
+              }
+            : undefined,
       },
       (err: Error, conn: any) => {
         if (err) {