working stream url

src/expression-engine/models/content/model.ts

@@ -30,6 +30,10 @@ import {
   TagEntries,
 } from "../ee/tags";
 
+import {
+  Snippets,
+} from "../ee/snippets";
+
 import { EE } from "../ee";
 
 export interface ChannelField {
@@ -192,7 +196,23 @@ export class Content extends EE {
       ;
   }
 
-  public async getLiveStream(/* site: string */): Promise<any> {
+  public async getLiveStream(): Promise<any> {
+    return this.getIsLive()
+      .then(({ isLive }) => {
+        if (!isLive) return { isLive, snippet_contents: null };
+
+        return this.getStreamUrl()
+            .then(({ snippet_contents }) => ({isLive, snippet_contents}));
+      });
+  }
+
+  private async getStreamUrl(): Promise<any> {
+    return this.cache.get("snippets:PUBLIC_EMBED_CODE", () => Snippets.findOne({
+      where: { snippet_name: "PUBLIC_EMBED_CODE" },
+    }));
+  }
+
+  private async getIsLive(): Promise<any> {
     // tslint:disable
     return this.cache.get("newspring:live", () => ChannelData.db.query(`
       SELECT

src/expression-engine/models/content/resolver.ts

@@ -58,14 +58,13 @@ export default {
     },
 
     live(_, $, { models }) {
-      // XXX pass in site
       return models.Content.getLiveStream();
     },
   },
 
   LiveFeed: {
     live: ({ isLive }) => !!isLive,
-    streamUrl: (data) => "Hello World",
+    streamUrl: ({ snippet_contents }) => snippet_contents,
   },
 
   ContentColor: {

src/expression-engine/models/ee/snippets.ts

@@ -0,0 +1,42 @@
+/* tslint:disable:no-shadowed-variable */
+
+import {
+  INTEGER,
+  STRING,
+} from "sequelize";
+
+import { MySQLConnector, Tables } from "../../mysql";
+
+const snippetsSchema: Object = {
+  snippet_id: { type: INTEGER, primaryKey: true },
+  site_id: { type: STRING },
+  snippet_name: { type: STRING },
+  snippet_contents: { type: STRING },
+};
+
+let Snippets;
+export {
+  Snippets,
+  snippetsSchema,
+};
+
+export function connect(): Tables {
+  Snippets = new MySQLConnector("exp_snippets", snippetsSchema);
+
+  return {
+    Snippets,
+  };
+};
+
+// export function bind({
+//   ChannelData,
+//   Sites,
+// }: Tables): void {
+
+
+// };
+
+export default {
+  connect,
+  // bind,
+};

src/expression-engine/models/index.ts

@@ -8,6 +8,7 @@ import matrix from "./ee/matrix";
 import playa from "./ee/playa";
 import tags from "./ee/tags";
 import sites from "./ee/sites";
+import snippets from "./ee/snippets";
 import navee from "./../models/navigation/tables";
 
 let tables = {
@@ -18,6 +19,7 @@ let tables = {
   sites,
   tags,
   navee,
+  snippets,
 } as {
   [key: string]: {
     connect: () => Tables;