Merge pull request #116 from CatalystCode/connector-query

Stream query

src/resolvers-cassandra/Settings/index.js

@@ -19,6 +19,7 @@ module.exports = {
   removeBlacklist: mutations.removeBlacklist,
 
   sites: queries.sites,
+  streams: queries.streams,
   twitterAccounts: queries.twitterAccounts,
   trustedTwitterAccounts: queries.trustedTwitterAccounts,
   facebookPages: queries.facebookPages,

src/resolvers-cassandra/Settings/queries.js

@@ -49,6 +49,32 @@ function sites(args, res) { // eslint-disable-line no-unused-vars
   });
 }
 
+/**
+ * @param {{siteId: string}} args
+ * @returns {Promise.<{runTime: string, sites: Array<{pipelineKey: string, pipelineLabel: string, pipelineIcon: string, streamFactory: string}>}>}
+ */
+function streams(args, res) { // eslint-disable-line no-unused-vars
+  return new Promise((resolve, reject) => {
+    cassandraConnector.executeQuery('SELECT * FROM fortis.streams', [])
+    .then(rows => {
+      const streams = rows.map(cassandraRowToStream);
+      resolve({
+        streams
+      });
+    })
+    .catch(reject);
+  });
+}
+
+function cassandraRowToStream(row) {
+  return {
+    pipelineKey: row.pipelinekey,
+    pipelineLabel: row.pipelinelabel,
+    pipelineIcon: row.pipelineicon,
+    streamFactory: row.streamfactory
+  };
+}
+
 function cassandraRowToTwitterAccount(row) {
   return {
     accountName: row.params.accountName,
@@ -172,6 +198,7 @@ function termBlacklist(args, res) { // eslint-disable-line no-unused-vars
 
 module.exports = {
   sites: trackEvent(withRunTime(sites), 'sites'),
+  streams: trackEvent(withRunTime(streams), 'streams'),
   twitterAccounts: trackEvent(withRunTime(twitterAccounts), 'twitterAccounts'),
   trustedTwitterAccounts: trackEvent(withRunTime(trustedTwitterAccounts), 'trustedTwitterAccounts'),
   facebookPages: trackEvent(withRunTime(facebookPages), 'facebookPages'),

src/schemas/SettingsSchema.js

@@ -3,6 +3,7 @@ const graphql = require('graphql');
 module.exports = graphql.buildSchema(`
   type Query {
     sites(siteId: String): SiteCollection
+    streams: StreamCollection
     twitterAccounts(siteId: String!): TwitterAccountCollection
     trustedTwitterAccounts(siteId: String!): TrustedTwitterAccountCollection
     facebookPages(siteId: String!): FacebookPageCollection
@@ -50,17 +51,18 @@ module.exports = graphql.buildSchema(`
     sites: [Site]!,
   }
 
-  type StreamProperties {
+  type StreamCollection {
+    runTime: String,
+    streams: [Stream]!
+  }
+
+  type Stream {
     pipelineKey: String,
     pipelineLabel: String,
     pipelineIcon: String,
     streamFactory: String
   }
 
-  type Stream {
-    properties: StreamProperties!
-  }
-
   type TwitterAccountCollection {
     runTime: String,
     accounts: [TwitterAccount]