Skip to content
This repository has been archived by the owner on Mar 7, 2018. It is now read-only.

Commit

Permalink
Merge pull request #144 from CatalystCode/remove-docstrings
Browse files Browse the repository at this point in the history 
Remove outdated docstrings
  • Loading branch information
@c-w
c-w committed Sep 14, 2017
2 parents 61639d3 + c0e2dfd commit 5599b63
Show file tree
Hide file tree
Showing 5 changed files with 0 additions and 132 deletions.
4 changes: 0 additions & 4 deletions src/resolvers-cassandra/Messages/mutations.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -3,10 +3,6 @@
const eventHubSender = require('../../clients/eventhub/EventHubSender');
const trackEvent = require('../../clients/appinsights/AppInsightsClient').trackEvent;

/**
* @param {{messages: Array<{RowKey: string, created_at: string, featureCollection: Array<{type: string, features: Array<{type: string, coordinates: number[]}>>, message: string, language: string, link: string, source: string, title: string}>}}} args
* @returns {Promise.<string[]>}
*/
function publishEvents(args, res) { // eslint-disable-line no-unused-vars
return eventHubSender.sendMessages(args && args.input && args.input.messages);
}
Expand Down
24 changes: 0 additions & 24 deletions src/resolvers-cassandra/Messages/queries.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,6 @@ const { parseFromToDate, getSiteDefintion, parseLimit, withRunTime, tilesForBbox
const { makeSet } = require('../../utils/collections');
const trackEvent = require('../../clients/appinsights/AppInsightsClient').trackEvent;

/**
* @typedef {type: string, coordinates: number[][], properties: {edges: string[], messageid: string, createdtime: string, sentiment: number, title: string, originalSources: string[], sentence: string, language: string, source: string, properties: {retweetCount: number, fatalaties: number, userConnecionCount: number, actor1: string, actor2: string, actor1Type: string, actor2Type: string, incidentType: string, allyActor1: string, allyActor2: string, title: string, link: string, originalSources: string[]}, fullText: string}} Feature
*/

function eventToFeature(row) {
const FeatureType = 'MultiPoint';

Expand Down Expand Up @@ -71,10 +67,6 @@ function queryEventsTable(eventIdResponse, args) {
});
}

/**
* @param {externalsourceid: string, bbox: number[], conjunctivetopics: string[], limit: number, pageState: number, fromDate: string, toDate: string, pipelinekeys: string[], fulltextTerm: string} args
* @returns {Promise.<{runTime: string, type: string, bbox: number[], features: Feature[]}>}
**/
function byBbox(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
if (!args.bbox || args.bbox.length !== 4) return reject('Invalid bbox specified');
Expand Down Expand Up @@ -114,10 +106,6 @@ function byBbox(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {site: string, mainTerm: string, filteredEdges: string[], langCode: string, limit: number, offset: number, fromDate: string, toDate: string, sourceFilter: string[], fulltextTerm: string} args
* @returns {Promise.<{runTime: string, type: string, bbox: number[], features: Feature[]}>}
*/
function byEdges(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
if (!args || !args.filteredEdges || !args.filteredEdges.length) return reject('No edges by which to filter specified');
Expand Down Expand Up @@ -153,10 +141,6 @@ function byEdges(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{site: string, messageId: string}} args
* @returns {Promise.<Feature>}
*/
function event(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
if (!args || !args.messageId) return reject('No event id to fetch specified');
Expand Down Expand Up @@ -185,10 +169,6 @@ function event(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{sentence: string, fromLanguage: string, toLanguage: string}} args
* @returns {Promise.<{originalSentence: string, translatedSentence: string}>}
*/
function translate(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
getSiteDefintion()
Expand All @@ -211,10 +191,6 @@ function translate(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{words: string[], fromLanguage: string, toLanguage: string}} args
* @returns {Promise.<{words: Array<{originalSentence: string, translatedSentence: string}>}>}
*/
function translateWords(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
translatorService.translateSentenceArray(args.words, args.fromLanguage, args.toLanguage)
Expand Down
61 changes: 0 additions & 61 deletions src/resolvers-cassandra/Settings/mutations.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -55,10 +55,6 @@ function _insertTopics(siteType) {

const insertTopics = trackEvent(_insertTopics, 'Settings.Topics.Insert', (response, err) => ({numTopicsInserted: err ? 0 : response.numTopicsInserted}));

/**
* @param {{input: {targetBbox: number[], defaultZoomLevel: number, logo: string, title: string, defaultLocation: number[], supportedLanguages: string[]}}} args
* @returns {Promise}
*/
function editSite(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const siteName = args && args.input && args.input.name;
Expand Down Expand Up @@ -109,10 +105,6 @@ function editSite(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{input: {siteType: string, targetBbox: number[], defaultZoomLevel: number, logo: string, title: string, name: string, defaultLocation: number[], storageConnectionString: string, featuresConnectionString: string, mapzenApiKey: string, fbToken: string, supportedLanguages: string[]}}} args
* @returns {Promise}
*/
function createSite(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const siteType = args && args.input && args.input.siteType;
Expand Down Expand Up @@ -165,10 +157,6 @@ function createSite(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{input: {site: string, edges: Array<{name: string}>}}} args
* @returns {Promise.<{runTime: string, edges: Array<{name: string}>}>}
*/
function removeKeywords(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
if (!args || !args.edges || !args.edges.length) return reject('No keywords to remove specified');
Expand All @@ -188,10 +176,6 @@ function removeKeywords(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{input: {site: string, edges: Array<{name: string}>}}} args
* @returns {Promise.<{runTime: string, edges: Array<{name: string}>}>}
*/
function addKeywords(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
if (!args || !args.edges || !args.edges.length) return reject('No keywords to add specified');
Expand All @@ -211,10 +195,6 @@ function addKeywords(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{input: {siteType: string, targetBbox: number[], defaultZoomLevel: number, logo: string, title: string, name: string, defaultLocation: number[], storageConnectionString: string, featuresConnectionString: string, mapzenApiKey: string, fbToken: string, supportedLanguages: string[]}}} args
* @returns {Promise}
*/
function removeSite(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
cassandraConnector.executeBatchMutations([{
Expand Down Expand Up @@ -242,10 +222,6 @@ function paramEntryToMap(paramEntry) {
return paramEntry.reduce((obj, item) => (obj[item.key] = item.value, obj), {});
}

/**
* @param {{input: {pipelineKey: string, pipelineLabel: string, pipelineIcon: string, streamFactory: string, params: Array<{String: String}>, enabled: boolean}}} args
* @returns {Promise}
*/
function modifyStreams(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const streams = args && args.input && args.input.streams;
Expand Down Expand Up @@ -284,11 +260,6 @@ function modifyStreams(args, res) { // eslint-disable-line no-unused-vars
});
}


/**
* @param {{input: {pipelineKey: string, pipelineLabel: string, pipelineIcon: string, streamFactory: string, params: Array<{String: String}>, enabled: boolean}}} args
* @returns {Promise}
*/
function removeStreams(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const streams = args && args.input && args.input.streams;
Expand Down Expand Up @@ -329,10 +300,6 @@ function normalizedFacebookPage(primaryKeyValues) {
};
}

/**
* @param {{input: {site: string, pages: Array<{pageUrl: string, RowKey: string}>}}} args
* @returns {Promise.<{runTime: string, pages: Array<{pageUrl: string, RowKey: string}>}>}
*/
function modifyFacebookPages(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const pages = args && args.input && args.input.pages;
Expand Down Expand Up @@ -367,10 +334,6 @@ function modifyFacebookPages(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{input: {site: string, pages: Array<{pageUrl: string, RowKey: string}>}}} args
* @returns {Promise.<{runTime: string, pages: Array<{pageUrl: string, RowKey: string}>}>}
*/
function removeFacebookPages(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const pages = args && args.input && args.input.pages;
Expand Down Expand Up @@ -408,10 +371,6 @@ function normalizedTrustedTwitterAccount(account) {
};
}

/**
* @param {{input: {site: string, accounts: Array<{acctUrl: string, RowKey: string}>}}} args
* @returns {Promise.<{runTime: string, accounts: Array<{pageUrl: string, RowKey: string}>}>}
*/
function modifyTrustedTwitterAccounts(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const accounts = args && args.input && args.input.accounts;
Expand All @@ -431,10 +390,6 @@ function modifyTrustedTwitterAccounts(args, res) { // eslint-disable-line no-unu
});
}

/**
* @param {{input: {site: string, accounts: Array<{acctUrl: string, RowKey: string}>}}} args
* @returns {Promise.<{runTime: string, accounts: Array<{pageUrl: string, RowKey: string}>}>}
*/
function removeTrustedTwitterAccounts(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const accounts = args && args.input && args.input.accounts;
Expand All @@ -449,10 +404,6 @@ function removeTrustedTwitterAccounts(args, res) { // eslint-disable-line no-unu
});
}

/**
* @param {{input: {site: string, accounts: Array<{accountName: string, consumerKey: string, consumerSecret: string, token: string, tokenSecret: string}>}}} args
* @returns {Promise.<{runTime: string, accounts: Array<{accountName: string, consumerKey: string, consumerSecret: string, token: string, tokenSecret: string}>}>}
*/
function modifyTwitterAccounts(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const accounts = args && args.input && args.input.accounts;
Expand Down Expand Up @@ -480,10 +431,6 @@ function modifyTwitterAccounts(args, res) { // eslint-disable-line no-unused-var
});
}

/**
* @param {{input: {site: string, accounts: Array<{accountName: string, consumerKey: string, consumerSecret: string, token: string, tokenSecret: string}>}}} args
* @returns {Promise.<{runTime: string, accounts: Array<{accountName: string, consumerKey: string, consumerSecret: string, token: string, tokenSecret: string}>}>}
*/
function removeTwitterAccounts(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const accounts = args && args.input && args.input.accounts;
Expand All @@ -501,10 +448,6 @@ function removeTwitterAccounts(args, res) { // eslint-disable-line no-unused-var
});
}

/**
* @param {{input: {site: string, terms: Array<{RowKey: string, lang: string, filteredTerms: string[]}>}}} args
* @returns {Promise.<{runTime: string, filters: Array<{filteredTerms: string[], lang: string, RowKey: string}>}>}
*/
function modifyBlacklist(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const terms = args && args.input && args.input.terms;
Expand Down Expand Up @@ -534,10 +477,6 @@ function modifyBlacklist(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{input: {site: string, terms: Array<{RowKey: string, lang: string, filteredTerms: string[]}>}}} args
* @returns {Promise.<{runTime: string, filters: Array<{filteredTerms: string[], lang: string, RowKey: string}>}>}
*/
function removeBlacklist(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const terms = args && args.input && args.input.terms;
Expand Down
32 changes: 0 additions & 32 deletions src/resolvers-cassandra/Settings/queries.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,6 @@ function transformWatchlist(item, translatedlanguage){
};
}

/**
* @param {{translationLanguage: string}} args
* @returns {Promise.<{runTime: string, edges: Array<{name: string}>}>}
*/
function terms(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const translationLanguage = args.translationLanguage || 'en';
Expand All @@ -45,10 +41,6 @@ function terms(args, res) { // eslint-disable-line no-unused-vars
});
}

/**
* @param {{}} args
* @returns {Promise.<{runTime: string, sites: Array<{name: string, properties: {targetBbox: number[], defaultZoomLevel: number, logo: string, title: string, defaultLocation: number[], storageConnectionString: string, featuresConnectionString: string, mapzenApiKey: string, fbToken: string, supportedLanguages: string[]}}>}>}
*/
function sites(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
getSiteDefintion()
Expand All @@ -57,10 +49,6 @@ 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, enabled: boolean}>}>}
*/
function streams(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
cassandraConnector.executeQuery('SELECT * FROM fortis.streams', [])
Expand Down Expand Up @@ -110,10 +98,6 @@ function cassandraRowToTwitterAccount(row) {
};
}

/**
* @param {{}} args
* @returns {Promise.<{runTime: string, accounts: Array<{accountName: string, consumerKey: string, consumerSecret: string, token: string, tokenSecret: string}>}>}
*/
function twitterAccounts(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const sourcesByPipelineKey = 'SELECT params FROM fortis.streams WHERE pipelinekey = ?';
Expand All @@ -134,10 +118,6 @@ function cassandraRowToTrustedTwitterAccount(row) {
};
}

/**
* @param {{siteId: string}} args
* @returns {Promise.<{runTime: string, accounts: Array<{RowKey: string, acctUrl: string}>}>}
*/
function trustedTwitterAccounts(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const sourcesByConnector = 'SELECT connector, sourceid, sourcetype FROM fortis.trustedsources WHERE pipelinekey = ? ALLOW FILTERING';
Expand All @@ -158,10 +138,6 @@ function cassandraRowToFacebookPage(row) {
};
}

/**
* @param {{siteId: string}} args
* @returns {Promise.<{runTime: string, pages: Array<{RowKey: string, pageUrl: string}>}>}
*/
function facebookPages(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const sourcesByConnector = 'SELECT connector, sourceid, sourcetype FROM fortis.trustedsources WHERE connector = ? ALLOW FILTERING';
Expand All @@ -180,10 +156,6 @@ function facebookPageToId(page) {
return match && match.length >= 1 && match[1];
}

/**
* @param {{siteId: string, days: number}} args
* @returns {Promise.<{analytics: Array<{Name: string, Count: number, LastUpdated: string}>}>}
*/
function facebookAnalytics(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
facebookPages({siteId: args.siteId})
Expand All @@ -204,10 +176,6 @@ function cassandraRowToTermFilter(row) {
};
}

/**
* @param {{siteId: string}} args
* @returns {Promise.<{runTime: string, filters: Array<{filteredTerms: string[], lang: string, RowKey: string}>}>}
*/
function termBlacklist(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
const blacklistQuery = 'SELECT id, conjunctivefilter FROM fortis.blacklist';
Expand Down
11 changes: 0 additions & 11 deletions src/resolvers-cassandra/Tiles/queries.js
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,6 @@ const { tilesForBbox, withRunTime, toConjunctionTopics } = require('../shared');
const { trackEvent } = require('../../clients/appinsights/AppInsightsClient');
const { computeWeightedAvg } = require('../../utils/collections');

/**
* @param {{tilex: number, tiley: number, tilez: number, avgsentimentnumerator: number, mentioncount: number}} rows
*/
function heatmapToFeatures(tiles) {
const type = 'Point';

Expand Down Expand Up @@ -64,10 +61,6 @@ function queryHeatmapTilesByParentTile(args) {
});
}

/**
* @param {{site: string, bbox: number[], mainEdge: string, filteredEdges: string[], zoomLevel: number, sourceFilter: string[], fromDate: string, toDate: string, originalSource: string}} args
* @returns {Promise.<{runTime: string, type: string, bbox: number[], features: Array<{type: string, coordinates: number[], properties: {mentionCount: number, location: string, population: number, neg_sentiment: number, pos_sentiment: number, tileId: string}}>}>}
*/
function heatmapFeaturesByTile(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
queryHeatmapTilesByParentTile(args)
Expand All @@ -76,10 +69,6 @@ function heatmapFeaturesByTile(args, res) { // eslint-disable-line no-unused-var
});
}

/**
* @param {{placeid: String, zoomLevel: int}} args
* @returns {Promise.<{[tile]>}>}
*/
function fetchTileIdsByPlaceId(args, res) { // eslint-disable-line no-unused-vars
return new Promise((resolve, reject) => {
featureServiceClient.fetchById(args.placeid, 'bbox')
Expand Down

0 comments on commit 5599b63

Please sign in to comment.