0.5.0-pre.15

deps/github.ts

@@ -1,2 +1 @@
 export * from "https://deno.land/x/github_api@0.5.0-pre.11/mod.ts";
-

deps/mongo.ts

@@ -0,0 +1,2 @@
+export * from "https://deno.land/x/mongo@v0.31.2/mod.ts";
+export { parse as parseConnectionString } from "https://deno.land/x/mongo@v0.31.2/src/utils/uri.ts";

src/services/mod.ts

@@ -1 +1,2 @@
 export * from "./github/mod.ts";
+export * from "./mongo/mod.ts";

src/services/mongo/mod.ts

@@ -0,0 +1,46 @@
+import {
+  Database,
+  MongoClient,
+  parseConnectionString,
+} from "../../../deps/mongo.ts";
+import { ILogger } from "../../mod.ts";
+
+export class MongoService {
+  constructor(
+    private readonly client: MongoClient,
+    private readonly db: Database,
+  ) {
+  }
+
+  public collection(name: string) {
+    return this.db.collection(name);
+  }
+
+  public close() {
+    this.client.close();
+  }
+
+  public static async create(
+    logging: ILogger,
+    mongoConnectionString: string,
+  ) {
+    if (!mongoConnectionString) {
+      logging.warn(
+        "mongo",
+        "MONGO_CONNECTION_STRING not found. Please create a .env file or set up your environment correctly.",
+      );
+    }
+
+    const client = new MongoClient();
+    const options = await parseConnectionString(mongoConnectionString);
+    if (mongoConnectionString.indexOf("localhost") === -1) {
+      options.tls = true;
+    }
+    const db = await client.connect(options);
+    logging.info(
+      `mongo`,
+      "mongo connected",
+    );
+    return new MongoService(client, db);
+  }
+}