Merge pull request #3106 from withspectrum/2.2.12

2.2.12

Author: brianlovin

.eslintignore

@@ -7,7 +7,6 @@ npm-debug.log
 build
 .DS_Store
 src/config/FirebaseConfig.js
-npm-debug.log
 rethinkdb_data
 debug
 now-secrets.json

.gitignore

@@ -18,6 +18,7 @@ build-mercury
 build-vulcan
 build-hyperion
 build-pluto
+build-analytics
 package-lock.json
 .vscode
 dump.rdb

.prettierignore

@@ -1,2 +1,3 @@
 flow-typed
-package.json
+package.json
+shared/analytics/event-types/*

analytics/index.js

@@ -0,0 +1,35 @@
+// @flow
+const debug = require('debug')('analytics');
+import createWorker from '../shared/bull/create-worker';
+
+import trackAnalytics from './queues/track-analytics';
+import identifyAnalytics from './queues/identify-analytics';
+
+import { TRACK_ANALYTICS, IDENTIFY_ANALYTICS } from './queues/constants';
+
+const PORT = process.env.PORT || 3009;
+
+debug('\n📈 Analytics worker is starting...');
+debug('Logging with debug enabled!');
+debug('');
+
+const server = createWorker({
+  [TRACK_ANALYTICS]: trackAnalytics,
+  [IDENTIFY_ANALYTICS]: identifyAnalytics,
+});
+
+debug(
+  `🗄 Queues open for business ${(process.env.NODE_ENV === 'production' &&
+    // $FlowIssue
+    `at ${process.env.COMPOSE_REDIS_URL}:${process.env.COMPOSE_REDIS_PORT}`) ||
+    'locally'}`
+);
+
+// $FlowIssue
+server.listen(PORT, 'localhost', () => {
+  debug(
+    `💉 Healthcheck server running at ${server.address().address}:${
+      server.address().port
+    }`
+  );
+});

analytics/models/channel.js

@@ -0,0 +1,10 @@
+// @flow
+import type { DBChannel } from 'shared/types';
+import { db } from './db';
+
+export const getChannelById = (channelId: string): Promise<DBChannel> => {
+  return db
+    .table('channels')
+    .get(channelId)
+    .run();
+};

analytics/models/community.js

@@ -0,0 +1,10 @@
+// @flow
+import type { DBCommunity } from 'shared/types';
+import { db } from './db';
+
+export const getCommunityById = (communityId: string): Promise<DBCommunity> => {
+  return db
+    .table('communities')
+    .get(communityId)
+    .run();
+};

analytics/models/db.js

@@ -0,0 +1,31 @@
+// @flow
+/**
+ * Database setup is done here
+ */
+const IS_PROD = !process.env.FORCE_DEV && process.env.NODE_ENV === 'production';
+
+const DEFAULT_CONFIG = {
+  db: 'spectrum',
+  max: 100, // Maximum number of connections, default is 1000
+  buffer: 10, // Minimum number of connections open at any given moment, default is 50
+  timeoutGb: 60 * 1000, // How long should an unused connection stick around, default is an hour, this is a minute
+};
+
+const PRODUCTION_CONFIG = {
+  password: process.env.AWS_RETHINKDB_PASSWORD,
+  host: process.env.AWS_RETHINKDB_URL,
+  port: process.env.AWS_RETHINKDB_PORT,
+};
+
+const config = IS_PROD
+  ? {
+      ...DEFAULT_CONFIG,
+      ...PRODUCTION_CONFIG,
+    }
+  : {
+      ...DEFAULT_CONFIG,
+    };
+
+var r = require('rethinkdbdash')(config);
+
+module.exports = { db: r };

analytics/models/message.js

@@ -0,0 +1,10 @@
+// @flow
+import type { DBMessage } from 'shared/types';
+import { db } from './db';
+
+export const getMessageById = (messageId: string): Promise<DBMessage> => {
+  return db
+    .table('messages')
+    .get(messageId)
+    .run();
+};

analytics/models/notification.js

@@ -0,0 +1,12 @@
+// @flow
+import type { DBNotification } from 'shared/types';
+import { db } from './db';
+
+export const getNotificationById = (
+  notificationId: string
+): Promise<DBNotification> => {
+  return db
+    .table('notifications')
+    .get(notificationId)
+    .run();
+};

analytics/models/reaction.js

@@ -0,0 +1,10 @@
+// @flow
+import type { DBReaction } from 'shared/types';
+import { db } from './db';
+
+export const getReactionById = (reactionId: string): Promise<DBReaction> => {
+  return db
+    .table('reactions')
+    .get(reactionId)
+    .run();
+};