Sample snippets

+.idea
+.DS_Store

+import composeApiRouteFor from '../../../helpers/composeApiRouteFor';
+
+const communicationsBase = composeApiRouteFor('communication-threads');
+
+export const threadContentsRoute = (threadId: number) => `${communicationsBase}/${threadId}/contents`;
+
+// TODO: should be replaced by threadContentsRoute once API has been adjusted
+export const threadMessagesRoute = (threadId: number) => `${communicationsBase}/${threadId}/messages`;

+import React, {useState} from 'react';
+import {useDebounce} from 'use-debounce';
+import {size, trim} from 'lodash/fp';
+import {useDispatch, useSelector} from 'react-redux';
+import { postThreadContent } from '../../middlewares/thread-contents';
+import {getCurrentThreadId} from '../../../selectors/thread';
+
+const ChatInput = () => {
+  const dispatch = useDispatch();
+  const [inputValue, setInputValue] = useState('');
+  const [message] = useDebounce(trim(inputValue), 300);
+  const isBlankMessage = size(message) === 0;
+  const submitDisabled = isBlankMessage;
+  const threadId = useSelector(getCurrentThreadId);
+  const handleSubmit = () => {
+    dispatch(postThreadContent({threadId, message: inputValue}));
+  };
+  const handleInputChange = (value: string) => {
+    setInputValue(value);
+    return value;
+  };
+
+  return (
+    <div className='chat-input-container'>
+      <form onSubmit={handleSubmit}>
+      <div className='collapse row align-middle mb-1'>
+        <div className='auto columns'>
+          <textarea placeholder={`What's on your mind?`} onChange={({target}) => handleInputChange(target.value)} />
+        </div>
+        {/* DZ */}
+        <div className='shrink columns'>
+          {/* TODO: Insert <Dropzone>*/}
+          <button data-tip data-for='attachment-criteria' className='button secondary hollow large clear pull-left'>
+            <i className='fa fa-paperclip'/>
+          </button>
+          {/* TODO: Insert <ReactTooltip>*/}
+          <button disabled={submitDisabled} type='button' onClick={handleSubmit} className='button success hollow large clear pull-right'>
+            <i className='fa fa-paper-plane'/>
+          </button>
+        </div>
+      </div>
+      </form>
+    </div>
+  );
+};
+
+export default ChatInput;

+import React from 'react';
+import {map, getOr} from 'lodash/fp';
+import {useSelector} from 'react-redux';
+import {plainToClass} from 'class-transformer';
+import ThreadContent from '../../../../../models/ThreadContent';
+import ThreadAttachment, {getAttachmentFileTypeCssClass} from '../../../../../models/ThreadAttachment';
+import {downloadAttachmentRoute} from '../../../../../api-routes';
+import {getCurrentThreadId} from '../../../../selectors/thread';
+
+interface Props {
+  attachments: ThreadContent[];
+}
+
+const FileAttachments = ({attachments}: Props) => {
+  if (!attachments.length) {
+    return null;
+  }
+  const threadId = useSelector(getCurrentThreadId);
+  return (
+    <ul className='attachments inline-list'>
+      {map(({id, contentInstance}) => {
+          const obj = plainToClass(ThreadAttachment, contentInstance);
+          const caption = getOr('', 'media.caption', obj);
+          return (
+            <li key={`file_attachment_${id}`} className={getAttachmentFileTypeCssClass(obj)}>
+              <a href={downloadAttachmentRoute(threadId, obj.id)} target='_blank' className='btn-dl' >
+                <i className='fa fa-download'/>
+              </a>
+              <span className='filename' data-tooltip title={caption}>
+                {caption}
+              </span>
+          </li>);
+        },
+      attachments)}
+    </ul>
+  );
+};
+export default FileAttachments;

+import React from 'react';
+import { getOr } from 'lodash/fp';
+import ThreadContent from '../../../../../models/ThreadContent';
+import isCurrentUser from '../../../../helpers/isCurrentUser';
+interface Props {
+  threadContent: ThreadContent;
+}
+
+const Info = ({threadContent}: Props) => {
+  const readBy = getOr(0, 'contentInstance.readBy', threadContent);
+  const authorId = getOr(0, 'author.id', threadContent);
+  const isSeen = !isCurrentUser(authorId) && readBy;
+  return (
+    <span className='subheader timestamp'>
+      {isSeen && <small className='pull-left mr-1'>
+          <i className='fa fa-check-circle'/>&nbsp; Seen
+      </small>}
+      <small>{threadContent.getLocalTimeString()}</small>
+    </span>
+  );
+};
+
+export default Info;

+import React from 'react';
+import {get} from 'lodash/fp';
+import ThreadContent from '../../../../../models/ThreadContent';
+import Text from '../Text';
+import Info from '../Info';
+
+interface Props {
+  threadContent: ThreadContent;
+}
+
+export default ({threadContent}: Props) => {
+  return (
+    <div className='text-align-right' data-msg-key={get('contentInstance.id', threadContent)}>
+      <div className='wrapper inline-block'>
+        <div className='media-object pull-right' data-animate='slide-in-right slide-out-right'>
+          <div className='small white-bg talk-bubble border tri-right right-in'>
+            <Text threadContent={threadContent} />
+          </div>
+          <Info threadContent={threadContent} />
+        </div>
+      </div>
+    </div>
+  );
+};

+import React from 'react';
+import {getOr} from 'lodash/fp';
+import FileAttachments from '../FileAttachments';
+import ThreadContent from '../../../../../models/ThreadContent';
+import {fileAttachments} from '../../../../../helpers/threadContent';
+
+interface Props {
+  threadContent: ThreadContent;
+}
+
+const Text = ({threadContent}: Props) => {
+
+  return (
+    <div className='talktext'>
+      <p dangerouslySetInnerHTML={{__html: getOr('', 'contentInstance.contentText', threadContent)}}/>
+      <FileAttachments attachments={fileAttachments(threadContent)} />
+    </div>
+  );
+};
+
+export default Text;

+import React from 'react';
+import {get} from 'lodash/fp';
+import ThreadContent from '../../../../../models/ThreadContent';
+import Text from '../Text';
+import Info from '../Info';
+import UserImageBubble from '../../../../../app/components/UserImageBubble';
+import {displayName, profilePicture} from '../../../../../helpers/user';
+
+interface Props {
+  threadContent: ThreadContent;
+}
+const TheirMessage = ({threadContent}: Props) => {
+
+  const {author} = threadContent;
+  const imageProps = {
+    displayName: displayName(author),
+    profilePictureUrl: profilePicture(author)
+  };
+
+  return (
+    <div className='wrapper' data-msg-key={get('contentInstance.id', threadContent)}>
+      <div className='media-object' data-animate='slide-in-right slide-out-right'>
+        <UserImageBubble {...imageProps} />
+        <div className='media-object-section middle'>
+          <div className='small talk-bubble border tri-right left-in'>
+            <Text threadContent={threadContent} />
+          </div>
+          <Info threadContent={threadContent} />
+        </div>
+      </div>
+    </div>
+  );
+};
+export default TheirMessage;

+import React from 'react';
+import {getOr} from 'lodash/fp';
+import ThreadContent from '../../../../models/ThreadContent';
+import TheirMessage from './TheirMessage';
+import isCurrentUser from '../../../helpers/isCurrentUser';
+import MyMessage from './MyMessage';
+
+interface Props {
+  threadContent: ThreadContent;
+}
+
+const ChatMessage = ({threadContent}: Props) => {
+  return isCurrentUser(getOr(0, 'author.id', threadContent))
+    ? <MyMessage threadContent={threadContent} />
+    : <TheirMessage threadContent={threadContent} />;
+};
+
+export default ChatMessage;

+/**
+ * Inbox tab main chat container component
+ */
+
+import React, { useEffect } from 'react';
+import { useDispatch, useSelector } from 'react-redux';
+import { map } from 'lodash/fp';
+import {didSetActiveTab} from '../../../tabs/actions';
+import {COMMUNICATIONS} from '../../../tabs/constants';
+import {LoadingRipple} from '../../../../utilities/components/LoadingRipple';
+import PageLayout from '../../../components/PageLayout';
+import {getCurrentThreadId} from '../../../selectors/thread';
+import {fetchThreadContents} from '../../middlewares/thread-contents';
+import {getIsFetchingThreadContents, getThreadContentsCollection} from '../../selectors';
+import ChatMessage from '../ChatMessage';
+import ThreadContent, {ThreadContentTypes} from '../../../../models/ThreadContent';
+import ChatInput from '../ChatInput';
+
+const Thread = () => {
+  const dispatch = useDispatch();
+  useEffect(() => {
+    dispatch(didSetActiveTab(COMMUNICATIONS));
+  }, []);
+
+  const threadId = useSelector(getCurrentThreadId);
+  const isFetching = useSelector(getIsFetchingThreadContents);
+  const collection = useSelector(getThreadContentsCollection);
+
+  useEffect(() => {
+    dispatch(fetchThreadContents(threadId));
+  }, [threadId]);
+
+  return (
+    <PageLayout>
+      <div id='chat-container' style={{overflowY: 'hidden'}}>
+        <div className={`chat-body-container`}>
+          {isFetching && <LoadingRipple isLoading />}
+          {!isFetching &&
+          <div className='chat-body'>
+            {map(
+              (each: ThreadContent) => (
+                ThreadContentTypes.MESSAGE === each.type ? <ChatMessage
+                  threadContent={each}
+                  key={`thread_content_${each.id}`}
+                /> : null
+              ), collection
+            )}
+          </div>
+          }
+        </div>
+        <ChatInput />
+      </div>
+    </PageLayout>
+  );
+};
+
+export default Thread;

+import { getThunkActionCreator } from 'redux-thunk-routine';
+import { plainToClass } from 'class-transformer';
+import { fetchThreadContents as fetchThreadContentsRoutine, postThreadContent as postThreadContentRoutine } from './routines';
+import AlertifyHelper from '../../../../helpers/AlertifyHelper';
+import {threadContentsRoute, threadMessagesRoute} from '../../api-routes';
+import {apiGet, apiPost} from '../../../../helpers/api';
+import ThreadContent from '../../../../models/ThreadContent';
+
+export const fetchThreadContents = getThunkActionCreator(
+  fetchThreadContentsRoutine,
+  async (threadId: number, page: number = 1) => {
+    try {
+      const { threadContents, meta } = await apiGet(
+        threadContentsRoute(threadId),
+        { page }
+      );
+
+      return {collection: plainToClass(ThreadContent, threadContents), meta};
+    } catch (e) {
+      AlertifyHelper.error('Unable to fetch thread contents');
+      throw e;
+    }
+  }
+);
+
+export const postThreadContent = getThunkActionCreator(
+  postThreadContentRoutine,
+  async ({threadId, message}: {threadId: number, message: string}) => {
+    try {
+      // todo: append attachment ids
+      const attachmentIds: number[] = [];
+      const { threadContent } = await apiPost(threadMessagesRoute(threadId), {
+        message,
+        threadAttachments: attachmentIds
+      });
+      return plainToClass(ThreadContent, threadContent);
+    } catch (e) {
+      AlertifyHelper.error('Failed to send your message.');
+      throw e;
+    }
+  }
+);

+import { createThunkRoutine } from 'redux-thunk-routine';
+
+export const fetchThreadContents = createThunkRoutine('FETCH_THREAD_CONTENTS');
+
+export const postThreadContent = createThunkRoutine('POST_THREAD_CONTENT');

+import composePagePathFor from '../helpers/composePagePathFor';
+
+export const inboxPath = composePagePathFor('inbox');

+import { sortBy, unionBy, get, set } from 'lodash/fp';
+import { createReducer } from '../../helpers/Reducer';
+import {fetchThreadContents as fetchThreadContentsRoutine, postThreadContent} from './middlewares/thread-contents/routines';
+import {ThreadContentsState} from '../../definitions/portal-interfaces';
+import ThreadContent from '../../models/ThreadContent';
+
+const initialState = {
+  collection: [],
+  meta: null,
+  isFetching: false,
+  isFetched: false
+};
+
+const fetchThreadContentsHandler = () => ({
+  [fetchThreadContentsRoutine.REQUEST]: (state: ThreadContentsState) => ({
+    ...state,
+    isFetching: true,
+    isFetched: false
+  }),
+  [fetchThreadContentsRoutine.SUCCESS]: (
+    state: ThreadContentsState,
+    {payload: {collection, meta}}: {payload: ThreadContentsState}) => {
+    const newCollection = unionBy((each: ThreadContent) => get('id', each), collection, state.collection);
+    const orderedCollection = sortBy('createdAt', newCollection);
+    return {
+      ...state,
+      collection: orderedCollection,
+      meta,
+      isFetching: false,
+      isFetched: true
+    };
+  },
+  [fetchThreadContentsRoutine.FAILURE]: (state: ThreadContentsState) => ({
+    ...state,
+    isFetching: false,
+    isFetched: true
+  })
+});
+
+const postThreadContentHandler = () => ({
+  [postThreadContent.SUCCESS]: (
+    state: ThreadContentsState,
+    { payload: threadContent }: { payload: ThreadContent }) => {
+    return set('collection', [...state.collection, threadContent], state);
+  }
+});
+
+export default createReducer(initialState, {
+  ...fetchThreadContentsHandler(),
+  ...postThreadContentHandler()
+});

+import { createSelector } from 'reselect';
+import { get } from 'lodash/fp';
+import { PortalState } from '../../definitions/portal-interfaces';
+
+const threadContents = ({threadContents}: PortalState) => threadContents;
+
+export const getThreadContentsCollection = createSelector(
+  threadContents,
+  get('collection')
+);
+
+export const getIsFetchingThreadContents = createSelector(
+  threadContents,
+  get('isFetching')
+);

+import React from 'react';
+import { StyleSheet } from 'react-native';
+import ListGrid, {
+  HeaderRow,
+  ItemRow,
+  PlayerColumn,
+  PPGColumn
+} from '../../ListGrid';
+import HeaderColumn from '../../ListGrid/HeaderColumn';
+import { BorderRadius, CardHeight } from '../constants';
+
+const styles = StyleSheet.create({
+  itemWrapper: {
+    height: CardHeight,
+    borderRadius: BorderRadius
+  },
+  player: {
+    justifyContent: 'center'
+  },
+  stats: {
+    justifyContent: 'center',
+    alignItems: 'center'
+  }
+});
+
+const AveragesList: React.FC<any> = () => {
+  return (
+    <ListGrid style={{ marginTop: 10 }}>
+      <HeaderRow style={{ marginBottom: 5 }}>
+        <HeaderColumn align="center" size={3} fontSize="sm" label="PLAYER" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="1-week" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="2-week" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="4-week" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="Season" />
+      </HeaderRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="EZEKEL ELLIOT"
+          position="RB"
+          team="DAL"
+          rating={4.3}
+          size={3}
+          style={styles.player}
+        />
+        <PPGColumn size={1.7} style={styles.stats}>
+          24.5
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          14.9
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          15.8
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          24.5
+        </PPGColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="MICHAEL THOMAS"
+          position="WR"
+          team="NO"
+          rating={3.5}
+          size={3}
+          style={styles.player}
+        />
+        <PPGColumn size={1.5} style={styles.stats}>
+          33.2
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          31.6
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          16.9
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          33.2
+        </PPGColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="JULIO JONES"
+          position="WR"
+          team="ATL"
+          rating={4}
+          size={3}
+          style={styles.player}
+        />
+        <PPGColumn size={1.5} style={styles.stats}>
+          33.2
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          17.7
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          25.9
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          33.2
+        </PPGColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="DESEAN WATSON"
+          position="QB"
+          team="HOU"
+          rating={4}
+          size={3}
+          style={styles.player}
+        />
+        <PPGColumn size={1.5} style={styles.stats}>
+          24.5
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          19.9
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          15.6
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          24.5
+        </PPGColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          owned
+          name="COOPER KUPP"
+          position="WR"
+          team="STL"
+          rating={3}
+          size={3}
+          style={styles.player}
+        />
+        <PPGColumn size={1.5} style={styles.stats}>
+          33.2
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          21.8
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          15.8
+        </PPGColumn>
+        <PPGColumn size={1.5} style={styles.stats}>
+          33.2
+        </PPGColumn>
+      </ItemRow>
+    </ListGrid>
+  );
+};
+
+export default AveragesList;

+import { get } from 'lodash/fp';
+import React from 'react';
+import { StyleSheet } from 'react-native';
+import { TouchableOpacity } from 'react-native-gesture-handler';
+import abbreviatePlayerPositon from '../../../../helpers/abbreviatePlayerPositon';
+import {
+  Column,
+  ItemRow,
+  PlayerColumn,
+  PriceWithTrendColumn
+} from '../../../ListGrid';
+import { CardHeight } from '../../../player-card/constants';
+import { BorderRadius } from '../../constants';
+
+interface Props {
+  data: PlayerEdge;
+  isOwned: boolean;
+  activeSort: string;
+  onPress: () => any;
+}
+
+const styles = StyleSheet.create({
+  itemWrapper: {
+    height: CardHeight,
+    borderRadius: BorderRadius
+  },
+  player: {
+    justifyContent: 'center',
+    width: '100%'
+  },
+  column: {
+    justifyContent: 'center',
+    alignItems: 'center'
+  },
+  priceTrend: {
+    justifyContent: 'center',
+    alignItems: 'center'
+  }
+});
+
+const Item: React.FC<Props> = ({
+  data: { node: playerNode },
+  onPress,
+  activeSort,
+  isOwned
+}: Props) => (
+  <TouchableOpacity onPress={onPress}>
+    <ItemRow style={styles.itemWrapper} key={playerNode?.id}>
+      <PlayerColumn
+        isOwned={isOwned}
+        name={`${playerNode?.firstName} ${playerNode?.lastName}`}
+        position={abbreviatePlayerPositon(playerNode?.playerPositions)}
+        team={get('team.abbreviation', playerNode)}
+        rating={4.3}
+        size={4}
+        style={styles.player}
+      />
+      <Column
+        size={2}
+        style={styles.column}
+        color={activeSort === 'rank' && 'info'}
+      >
+        {playerNode?.rank}
+      </Column>
+      <Column
+        size={2.5}
+        style={styles.column}
+        color={activeSort === 'fantasyPoints' && 'info'}
+      >
+        {playerNode?.fantasyPoints}
+      </Column>
+      <Column
+        size={2.5}
+        style={styles.column}
+        color={activeSort === 'fantasyPointsPerGame' && 'info'}
+      >
+        {playerNode?.fantasyPointsPerGame}
+      </Column>
+      <PriceWithTrendColumn
+        rise
+        size={2.3}
+        style={styles.priceTrend}
+        height={45}
+        current={playerNode?.value}
+        color={activeSort === 'value' && 'info'}
+      />
+    </ItemRow>
+  </TouchableOpacity>
+);
+
+export default Item;

+import { StackActions, useNavigation } from '@react-navigation/native';
+import { get, isEmpty } from 'lodash/fp';
+import { Spinner as NativeSpinner, View } from 'native-base';
+import React, { useCallback, useEffect, useState } from 'react';
+import {
+  DataProvider,
+  LayoutProvider,
+  RecyclerListView
+} from 'recyclerlistview';
+import { TabNavigation } from '../../../types/navigation';
+import ListGrid, { HeaderRow } from '../../ListGrid';
+import HeaderColumn from '../../ListGrid/HeaderColumn';
+import { CardHeight } from '../../player-card/constants';
+import { COLUMNS, DEFAULT_SORT } from '../constants';
+import Item from './Item';
+
+interface Props {
+  players: PlayerEdge[];
+  franchisePlayers: Dictionary<FranchisePlayer>;
+  onSort: (field: string, order: string) => void;
+  onFetchMore: VoidFunction;
+  isFetching: boolean;
+}
+
+const layoutProvider = new LayoutProvider(
+  () => 'MARKET_LIST',
+  (_, dim) => {
+    // eslint-disable-next-line no-param-reassign
+    dim.width = 500;
+    // eslint-disable-next-line no-param-reassign
+    dim.height = CardHeight + 1;
+  }
+);
+
+const MainList: React.FC<Props> = ({
+  isFetching,
+  onFetchMore,
+  franchisePlayers,
+  onSort,
+  players
+}: Props) => {
+  const navigation = useNavigation<TabNavigation>();
+  const [sortBy, setSortBy] = useState<string>(DEFAULT_SORT.COLUMN);
+  const [sortDirection, setSortDirection] = useState<SortType>(
+    DEFAULT_SORT.DIRECTION
+  );
+  const [dataProvider, setDataProvider] = useState<DataProvider>(
+    new DataProvider((r1, r2) => r1 !== r2)
+  );
+
+  useEffect(() => {
+    if (sortBy && sortDirection) {
+      onSort(sortBy, sortDirection);
+    }
+    // eslint-disable-next-line react-hooks/exhaustive-deps
+  }, [sortBy, sortDirection]);
+
+  useEffect(() => {
+    if (!isEmpty(players)) {
+      setDataProvider(dataProvider.cloneWithRows(players));
+    }
+    // eslint-disable-next-line react-hooks/exhaustive-deps
+  }, [players]);
+
+  const handleOnSort = (colName: string) => () => {
+    if (colName === sortBy) {
+      setSortDirection(sortDirection === 'ASC' ? 'DESC' : 'ASC');
+    } else {
+      setSortBy(colName);
+      setSortDirection('ASC');
+    }
+  };
+
+  const getColumnSortDirection = (colName: string) =>
+    colName === sortBy ? sortDirection : '';
+
+  const renderFooter = useCallback(
+    () => (isFetching ? <NativeSpinner /> : <View />),
+    [isFetching]
+  );
+
+  const navigateToProfile = (selectedIndex: number) => () => {
+    navigation.dispatch(
+      StackActions.push('PlayerView', {
+        players,
+        selectedIndex,
+        franchisePlayers
+      })
+    );
+  };
+
+  const renderRow = useCallback(
+    (_, data: PlayerEdge, index: number) => {
+      return (
+        <Item
+          data={data}
+          activeSort={sortBy}
+          isOwned={!isEmpty(get(data.node.id, franchisePlayers))}
+          onPress={navigateToProfile(index)}
+        />
+      );
+    },
+    // eslint-disable-next-line react-hooks/exhaustive-deps
+    [dataProvider]
+  );
+
+  const hasPlayerData = dataProvider.getSize() > 0;
+  return (
+    <ListGrid style={{ marginHorizontal: 6 }}>
+      <HeaderRow style={{ height: 45, marginBottom: 20 }}>
+        <HeaderColumn align="center" size={4} fontSize="sm" label="PLAYER" />
+        <HeaderColumn
+          sortable
+          size={2}
+          fontSize="sm"
+          label="Rank"
+          onSort={handleOnSort(COLUMNS.RANK)}
+          sortDirection={getColumnSortDirection(COLUMNS.RANK)}
+        />
+        <HeaderColumn
+          sortable
+          size={2.5}
+          fontSize="sm"
+          label="FP"
+          helpText="FANTASY PTS"
+          onSort={handleOnSort(COLUMNS.FP)}
+          sortDirection={getColumnSortDirection(COLUMNS.FP)}
+        />
+        <HeaderColumn
+          sortable
+          size={2.5}
+          fontSize="sm"
+          label="FPPG"
+          helpText={'FANTASY PTS\n(per game)'}
+          onSort={handleOnSort(COLUMNS.FPPG)}
+          sortDirection={getColumnSortDirection(COLUMNS.FPPG)}
+        />
+        <HeaderColumn
+          sortable
+          size={2.3}
+          fontSize="sm"
+          label="Price"
+          helpText={'TREND\n(24hrs)'}
+          onSort={handleOnSort(COLUMNS.PRICE)}
+          sortDirection={getColumnSortDirection(COLUMNS.PRICE)}
+        />
+      </HeaderRow>
+      {hasPlayerData && (
+        <RecyclerListView
+          style={{ flex: 1 }}
+          dataProvider={dataProvider}
+          layoutProvider={layoutProvider}
+          rowRenderer={renderRow}
+          initialRenderIndex={0}
+          renderAheadOffset={1500}
+          renderFooter={renderFooter}
+          onEndReached={onFetchMore}
+          onEndReachedThreshold={2000}
+        />
+      )}
+    </ListGrid>
+  );
+};
+
+export default MainList;

+import React from 'react';
+import { StyleSheet } from 'react-native';
+import ListGrid, {
+  HeaderRow,
+  ItemRow,
+  PassingColumn,
+  PlayerColumn,
+  ReceivingColumn,
+  RushingColumn
+} from '../../ListGrid';
+import HeaderColumn from '../../ListGrid/HeaderColumn';
+import { BorderRadius } from '../constants';
+
+const styles = StyleSheet.create({
+  itemWrapper: {
+    height: 50,
+    borderRadius: BorderRadius
+  },
+  player: {
+    justifyContent: 'center'
+  },
+  stats: {
+    justifyContent: 'center',
+    alignItems: 'center'
+  }
+});
+
+const StatsList: React.FC<any> = () => {
+  return (
+    <ListGrid style={{ marginTop: 10 }}>
+      <HeaderRow style={{ marginBottom: 5 }}>
+        <HeaderColumn align="center" size={3} fontSize="sm" label="Player" />
+        <HeaderColumn
+          align="center"
+          size={2}
+          fontSize="sm"
+          label="Passing"
+          helpText="PaYD / PaTD"
+        />
+        <HeaderColumn
+          align="center"
+          size={2.5}
+          fontSize="sm"
+          label="Rushing"
+          helpText="Att / RuYd / RuTD"
+        />
+        <HeaderColumn
+          align="center"
+          size={2.5}
+          fontSize="sm"
+          label="Receiving"
+          helpText="Rec / ReYd / ReTD"
+        />
+      </HeaderRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          owned
+          name="EZEKEL ELLIOT"
+          position="RB"
+          team="DAL"
+          rating={4.3}
+          size={3}
+          style={styles.player}
+        />
+        <PassingColumn size={2} yards="0.0" td="0.0" style={styles.stats} />
+        <RushingColumn
+          size={2.5}
+          attempts="16.3"
+          yards="87.5"
+          td="0.7"
+          style={styles.stats}
+        />
+        <ReceivingColumn
+          size={2.5}
+          receptions="4.1"
+          yards="56.7"
+          td="0.3"
+          style={styles.stats}
+        />
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="MICHAEL THOMAS"
+          position="WR"
+          team="NO"
+          rating={3.5}
+          size={3}
+          style={styles.player}
+        />
+        <PassingColumn size={2} yards="0.0" td="0.0" style={styles.stats} />
+        <RushingColumn
+          size={2.5}
+          attempts="16.3"
+          yards="87.5"
+          td="0.7"
+          style={styles.stats}
+        />
+        <ReceivingColumn
+          size={2.5}
+          receptions="4.1"
+          yards="56.7"
+          td="0.3"
+          style={styles.stats}
+        />
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="JULIO JONES"
+          position="WR"
+          team="ATL"
+          rating={4}
+          size={3}
+          style={styles.player}
+        />
+        <PassingColumn size={2} yards="0.0" td="0.0" style={styles.stats} />
+        <RushingColumn
+          size={2.5}
+          attempts="16.3"
+          yards="87.5"
+          td="0.7"
+          style={styles.stats}
+        />
+        <ReceivingColumn
+          size={2.5}
+          receptions="4.1"
+          yards="56.7"
+          td="0.3"
+          style={styles.stats}
+        />
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="DESEAN WATSON"
+          position="QB"
+          team="HOU"
+          rating={4}
+          size={3}
+          style={styles.player}
+        />
+        <PassingColumn size={2} yards="0.0" td="0.0" style={styles.stats} />
+        <RushingColumn
+          size={2.5}
+          attempts="16.3"
+          yards="87.5"
+          td="0.7"
+          style={styles.stats}
+        />
+        <ReceivingColumn
+          size={2.5}
+          receptions="4.1"
+          yards="56.7"
+          td="0.3"
+          style={styles.stats}
+        />
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="COOPER KUPP"
+          position="WR"
+          team="STL"
+          rating={3}
+          size={3}
+          style={styles.player}
+        />
+        <PassingColumn size={2} yards="0.0" td="0.0" style={styles.stats} />
+        <RushingColumn
+          size={2.5}
+          attempts="16.3"
+          yards="87.5"
+          td="0.7"
+          style={styles.stats}
+        />
+        <ReceivingColumn
+          size={2.5}
+          receptions="4.1"
+          yards="56.7"
+          td="0.3"
+          style={styles.stats}
+        />
+      </ItemRow>
+    </ListGrid>
+  );
+};
+
+export default StatsList;

+import React from 'react';
+import { StyleSheet } from 'react-native';
+import ListGrid, {
+  FPColumn,
+  HeaderRow,
+  ItemRow,
+  PlayerColumn
+} from '../../ListGrid';
+import HeaderColumn from '../../ListGrid/HeaderColumn';
+import { BorderRadius, CardHeight } from '../constants';
+
+const styles = StyleSheet.create({
+  itemWrapper: {
+    height: CardHeight,
+    borderRadius: BorderRadius
+  },
+  player: {
+    justifyContent: 'center'
+  },
+  stats: {
+    justifyContent: 'center',
+    alignItems: 'center'
+  }
+});
+
+const TotalsList: React.FC<any> = () => {
+  return (
+    <ListGrid style={{ marginTop: 10 }}>
+      <HeaderRow style={{ marginBottom: 5 }}>
+        <HeaderColumn align="center" size={3} fontSize="sm" label="PLAYER" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="1-week" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="2-week" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="4-week" />
+        <HeaderColumn align="center" size={1.5} fontSize="sm" label="Season" />
+      </HeaderRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="EZEKEL ELLIOT"
+          position="RB"
+          team="DAL"
+          rating={4.3}
+          size={3}
+          style={styles.player}
+        />
+        <FPColumn size={1.7} style={styles.stats}>
+          24.5
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          14.9
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          15.8
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          24.5
+        </FPColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="MICHAEL THOMAS"
+          position="WR"
+          team="NO"
+          rating={3.5}
+          size={3}
+          style={styles.player}
+        />
+        <FPColumn size={1.5} style={styles.stats}>
+          33.2
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          31.6
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          16.9
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          33.2
+        </FPColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="JULIO JONES"
+          position="WR"
+          team="ATL"
+          rating={4}
+          size={3}
+          style={styles.player}
+        />
+        <FPColumn size={1.5} style={styles.stats}>
+          33.2
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          17.7
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          25.9
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          33.2
+        </FPColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          name="DESEAN WATSON"
+          position="QB"
+          team="HOU"
+          rating={4}
+          size={3}
+          style={styles.player}
+        />
+        <FPColumn size={1.5} style={styles.stats}>
+          24.5
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          19.9
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          15.6
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          24.5
+        </FPColumn>
+      </ItemRow>
+      <ItemRow style={styles.itemWrapper}>
+        <PlayerColumn
+          owned
+          name="COOPER KUPP"
+          position="WR"
+          team="STL"
+          rating={3}
+          size={3}
+          style={styles.player}
+        />
+        <FPColumn size={1.5} style={styles.stats}>
+          33.2
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          21.8
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          15.8
+        </FPColumn>
+        <FPColumn size={1.5} style={styles.stats}>
+          33.2
+        </FPColumn>
+      </ItemRow>
+    </ListGrid>
+  );
+};
+
+export default TotalsList;

+export const COLUMNS = {
+  RANK: 'rank',
+  FP: 'fantasyPoints',
+  FPPG: 'fantasyPointsPerGame',
+  PRICE: 'value'
+};
+
+export const DEFAULT_SORT: { COLUMN: string; DIRECTION: SortType } = {
+  COLUMN: COLUMNS.PRICE,
+  DIRECTION: 'DESC'
+};

+import React from 'react';
+import { ViewProps } from 'react-native';
+import ListGrid from '../../ListGrid';
+import WeeklyPlayerRow from '../../WeeklyPlayerRow';
+
+interface ComponentProps {
+  data: Player;
+  active: boolean;
+}
+
+type Props = ComponentProps & ViewProps;
+
+const AverageList: React.FC<Props> = ({ data, active, ...props }: Props) => {
+  const rowLabel = 'PPG';
+  return (
+    // loop here
+    <ListGrid {...props}>
+      <WeeklyPlayerRow
+        key="dummy1"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy2"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy3"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy4"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy5"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy6"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy7"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy8"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy9"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy10"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy11"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy12"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+    </ListGrid>
+  );
+};
+
+export default AverageList;

+import React from 'react';
+import { ViewProps } from 'react-native';
+import ListGrid from '../../ListGrid';
+import StatsPlayerRow from '../../StatsPlayerRow';
+
+interface ComponentProps {
+  data: Player;
+  active: boolean;
+}
+
+type Props = ComponentProps & ViewProps;
+
+const StatsList: React.FC<Props> = ({ data, active, ...props }: Props) => (
+  <ListGrid {...props}>
+    <StatsPlayerRow key="dummy1" player={data} active={active} />
+    <StatsPlayerRow key="dummy2" player={data} active={active} />
+    <StatsPlayerRow key="dummy3" player={data} active={active} />
+    <StatsPlayerRow key="dummy4" player={data} active={active} />
+    <StatsPlayerRow key="dummy5" player={data} active={active} />
+    <StatsPlayerRow key="dummy6" player={data} active={active} />
+    <StatsPlayerRow key="dummy7" player={data} active={active} />
+    <StatsPlayerRow key="dummy8" player={data} active={active} />
+    <StatsPlayerRow key="dummy9" player={data} active={active} />
+    <StatsPlayerRow key="dummy10" player={data} active={active} />
+    <StatsPlayerRow key="dummy11" player={data} active={active} />
+    <StatsPlayerRow key="dummy12" player={data} active={active} />
+  </ListGrid>
+);
+
+export default StatsList;

+import React from 'react';
+import { ViewProps } from 'react-native';
+import ListGrid from '../../ListGrid';
+import WeeklyPlayerRow from '../../WeeklyPlayerRow';
+
+interface ComponentProps {
+  data: Player;
+  active: boolean;
+}
+
+type Props = ComponentProps & ViewProps;
+
+const TotalsList: React.FC<Props> = ({ data, active, ...props }: Props) => {
+  const rowLabel = 'FP';
+  return (
+    // loop here
+    <ListGrid {...props}>
+      <WeeklyPlayerRow
+        key="dummy1"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy2"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy3"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy4"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy5"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy6"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy7"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy8"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy9"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy10"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy11"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+      <WeeklyPlayerRow
+        key="dummy12"
+        player={data}
+        active={active}
+        rowLabel={rowLabel}
+      />
+    </ListGrid>
+  );
+};
+
+export default TotalsList;

+import { get, getOr, isEqual, keyBy, sortBy, findIndex } from 'lodash/fp';
+import { View } from 'native-base';
+import React from 'react';
+import { ViewProps } from 'react-native';
+import { StackActions, useNavigation } from '@react-navigation/native';
+import { TouchableOpacity } from 'react-native-gesture-handler';
+import { ABBREV, POSITIONS } from '../../constants/roster-position';
+import BenchDivider from '../BenchDivider';
+import DefaultPlayerRow from '../DefaultPlayerRow';
+import ListGrid from '../ListGrid';
+import { TAB } from '../../constants/tab';
+import { TabNavigation, StackNavigation } from '../../types/navigation';
+
+interface ComponentProps {
+  players: FranchisePlayer[];
+  rosterSpots: string[];
+  // eslint-disable-next-line react/require-default-props
+  showMarketTrend?: boolean;
+}
+
+type Props = ComponentProps & ViewProps;
+
+const RosterList: React.FC<Props> = ({
+  players,
+  rosterSpots,
+  showMarketTrend = false,
+  ...props
+}: Props) => {
+  const navigation = useNavigation<TabNavigation | StackNavigation>();
+  const benchIndex = rosterSpots.indexOf('BENCH');
+  const franchisePlayers = keyBy('rosterSpotIndex', players);
+  const sortedPlayersSpots = sortBy('rosterSpotIndex', players);
+
+  const navigateToProfile = (index: number) => {
+    navigation.dispatch(
+      StackActions.push('PlayerView', {
+        players: sortedPlayersSpots,
+        selectedIndex: index
+      })
+    );
+  };
+
+  const handleOnPressItem = (index: number) => () => {
+    const rosterSpotIndex = get(
+      [`${index}`, 'rosterSpotIndex'],
+      franchisePlayers
+    );
+    const playerIndex = findIndex({ rosterSpotIndex }, sortedPlayersSpots);
+    if (playerIndex > -1) {
+      navigateToProfile(playerIndex);
+    } else {
+      const position = getOr('', rosterSpots[index], ABBREV);
+      navigation.navigate(TAB.Market, {
+        position: rosterSpots[index] !== POSITIONS.BENCH ? position : null
+      });
+    }
+  };
+
+  return (
+    <ListGrid {...props}>
+      {rosterSpots.map(
+        (position: string, index: number) => (
+          <TouchableOpacity
+            // eslint-disable-next-line react/no-array-index-key
+            key={`player-${position}-${index}`}
+            onPress={handleOnPressItem(index)}
+          >
+            <View>
+              {index === benchIndex && <BenchDivider />}
+              <DefaultPlayerRow
+                active={!isEqual(rosterSpots[index], POSITIONS.BENCH)}
+                position={get(position, ABBREV)}
+                player={get(index, franchisePlayers)}
+                showMarketTrend={showMarketTrend}
+              />
+            </View>
+          </TouchableOpacity>
+        ),
+        rosterSpots
+      )}
+    </ListGrid>
+  );
+};
+
+export default RosterList;

+import { gql } from '@apollo/client';
+
+// eslint-disable-next-line import/prefer-default-export
+export const BUY_FRANCHISE_PLAYER = gql`
+  mutation CreateFranchisePlayers(
+    $franchiseId: String!
+    $playerId: String!
+    $rosterSpotIndex: Int!
+  ) {
+    createNflFranchisePlayer(
+      data: {
+        franchiseId: $franchiseId
+        playerId: $playerId
+        rosterSpotIndex: $rosterSpotIndex
+      }
+    ) {
+      id
+      playerId
+      franchiseId
+      rosterSpotIndex
+      buyPrice
+    }
+  }
+`;

+import { gql } from '@apollo/client';
+import apolloClient from '../../../store/apolloClient';
+
+// eslint-disable-next-line import/prefer-default-export
+export const FIND_FRANCHISE_PLAYERS = gql`
+  query FindFranchisePlayers($franchiseId: String!) {
+    findNflFranchisePlayers(filter: { franchiseId: { eq: $franchiseId } }) {
+      nodes {
+        id
+        playerId
+        franchiseId
+        rosterSpotIndex
+        buyPrice
+      }
+    }
+  }
+`;
+
+export default async (franchiseId: string) => {
+  try {
+    await apolloClient.query({
+      query: FIND_FRANCHISE_PLAYERS,
+      variables: { franchiseId },
+      fetchPolicy: 'network-only'
+    });
+    return null;
+  } catch (e) {
+    return null;
+  }
+};

+import { gql } from '@apollo/client';
+import { get } from 'lodash/fp';
+import apolloClient from '../../../store/apolloClient';
+
+export const FIND_USER_CURRENT_NFL_SEASON_FRANCHISE = gql`
+  query FindNflSeasonFranchises($userId: String!) {
+    currentNflSeason {
+      id
+      franchises(filter: { ownerId: { eq: $userId } }) {
+        nodes {
+          id
+          name
+          fzCash
+        }
+      }
+    }
+  }
+`;
+
+export default async (userId: string) => {
+  try {
+    const { data } = await apolloClient.query({
+      query: FIND_USER_CURRENT_NFL_SEASON_FRANCHISE,
+      variables: { userId },
+      fetchPolicy: 'network-only'
+    });
+    return get('currentNflSeason.franchises.nodes.0', data);
+  } catch (e) {
+    return null;
+  }
+};

+import { gql } from '@apollo/client';
+
+// eslint-disable-next-line import/prefer-default-export
+export const FIND_USER_CURRENT_NFL_SEASON_PLAYER = gql`
+  query FindCurrentNflSeasonPlayer($playerId: String!) {
+    currentNflSeason {
+      id
+      player(id: $playerId) {
+        id
+        lastName
+        firstName
+        fantasyPointsPerGame
+        playerPositions
+        value
+        details {
+          profilePhotos
+        }
+        team {
+          abbreviation
+        }
+      }
+    }
+  }
+`;

+<?php
+
+namespace NexmoBundle\Command;
+
+use AppBundle\Entity\AdminUser;
+use AppBundle\Entity\OpentokSessionTypes;
+use AppBundle\Entity\Patient;
+use AppBundle\Entity\VoiceCall;
+use Doctrine\Bundle\DoctrineBundle\Registry;
+use Monolog\Logger;
+use NexmoBundle\Manager\InboundCallManager;
+use OpenTokBundle\Pool\GlobalAdminOpenTokPool;
+use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+
+class NexmoBroadcastInboundCallCommand extends ContainerAwareCommand
+{
+    /**
+     * @var Logger
+     */
+    private $logger;
+
+    protected function configure()
+    {
+        $this
+            ->setName('nexmo:broadcast-inbound-call')
+            ->setDescription('Broadcast inbound voice call')
+            ->addArgument('voice_call', InputArgument::REQUIRED, 'Voice call id')
+            ->addOption("cobrand", "c", InputOption::VALUE_OPTIONAL, 'Cobrand code of executing context')
+        ;
+    }
+
+    private function logString($s)
+    {
+        return "[{$this->getName()}]: {$s}";
+    }
+
+    /**
+     * @param InputInterface  $input
+     * @param OutputInterface $output
+     * @return int|void|null
+     * @throws \Exception
+     */
+    protected function execute(InputInterface $input, OutputInterface $output)
+    {
+        $this->logger = $this->getContainer()->get("logger");
+
+        /** @var InboundCallManager $manager */
+        $manager = $this->getContainer()->get("nexmo.manager.inbound_call");
+        /** @var VoiceCall $voiceCall */
+        $voiceCall = $manager->getObjectOrHalt($input->getArgument('voice_call'));
+        $manager->initThreadContent($voiceCall);
+        $opentokData = $manager->asOpenTokSignalData($voiceCall);
+
+        if ($voiceCall->getRecipient() instanceof AdminUser) {
+            /** @var GlobalAdminOpenTokPool $pool */
+            $pool = $this->getContainer()->get("opentok_pool_factory")->get(OpentokSessionTypes::ADMIN_POOL);
+            // send opentok signal to admin user
+            $pool->sendSignal("inbound-call", $opentokData);
+        }
+
+        $this->logger->info($this->logString("Broadcasting voice call #{$voiceCall->getId()}"));
+    }
+}

+<?php
+
+namespace NexmoBundle\Controller;
+
+use AppBundle\Entity\Patient;
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Event\VoiceCallEvent;
+use AppBundle\Event\VoiceCallEvents;
+use CobrandBundle\CobrandInstance;
+use FOS\RestBundle\Controller\Annotations\Get;
+use FOS\RestBundle\Controller\Annotations\Post;
+use JMS\DiExtraBundle\Annotation\Inject;
+use NexmoBundle\VoiceCall\VoiceCallOrigins;
+use NexmoBundle\VoiceCall\VoiceCallStatus;
+use NexmoBundle\WebHook\OnAnswerInboundWebHook;
+use NexmoBundle\WebHook\OnEventInboundWebHook;
+use Sentry\SentryBundle\SentrySymfonyClient;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+
+class InboundCallWebHookController extends NexmoWebHookController
+{
+    /**
+     * @var OnAnswerInboundWebHook
+     * @Inject("nexmo.webhooks.answer_inbound")
+     */
+    private $answerHandler;
+
+    /**
+     * @var OnEventInboundWebHook
+     * @Inject("nexmo.webhooks.event_inbound")
+     */
+    private $eventHookHandler;
+
+    /**
+     * Inbound call answer url
+     * @Get("/answer-url", name="answer_webhook")
+     * @param Request $request
+     * @return \Symfony\Component\HttpFoundation\JsonResponse
+     * @throws \Doctrine\DBAL\ConnectionException
+     */
+    public function answerUrlAction(Request $request)
+    {
+        return $this->answerHandler->handle($request);
+    }
+
+    /**
+     * @Post("/event-url", name="event_webhook")
+     * @param Request $request
+     * @return \Symfony\Component\HttpFoundation\JsonResponse
+     * @throws \Exception
+     */
+    public function eventUrlAction(Request $request)
+    {
+        return $this->eventHookHandler->handle($request);
+    }
+}

+<?php
+
+namespace NexmoBundle\Controller;
+
+use AppBundle\Controller\SpokeControllerTrait;
+use AppBundle\Entity\VoiceCall;
+use CobrandBundle\CobrandInstance;
+use Symfony\Bundle\FrameworkBundle\Controller\Controller;
+
+class NexmoWebHookController extends Controller
+{
+    use SpokeControllerTrait;
+
+    /**
+     * @param $s
+     * @return string
+     */
+    protected function logString($s)
+    {
+        return "[nexmo_web_hook] => {$s}";
+    }
+
+    /**
+     * @return string
+     */
+    protected function getCurrentAppName()
+    {
+        try {
+            $appName = $this->getCurrentCobrand()->getApp()->getName();
+        } catch (\Exception $exception) {
+            $appName = "Spoke Health";
+        }
+
+        return $appName;
+    }
+
+
+    /**
+     * @param $uuid
+     * @return VoiceCall
+     */
+    protected function getVoiceCallByUUID($uuid)
+    {
+
+        return $this->getDoctrine()->getRepository("AppBundle:VoiceCall")->findOneBy(["uuid" => $uuid]);
+    }
+
+    /**
+     * @param $uuid
+     * @return VoiceCall
+     * @throws \Exception
+     */
+    protected function findOrCreateVoiceCallByUuid($uuid)
+    {
+        $voiceCall = $this->getVoiceCallByUUID($uuid);
+        if (!$voiceCall instanceof VoiceCall) {
+            $this->get("logger")->info($this->logString("Creating new VoiceCall - UUID: {$uuid}"));
+            // create voice call for this inbound call
+            $voiceCall = new VoiceCall();
+            $voiceCall->setCreatedAt(new \DateTime("now"));
+        }
+
+        return $voiceCall;
+    }
+}

+<?php
+
+namespace NexmoBundle\Controller;
+
+use AppBundle\Controller\SpokeControllerTrait;
+use AppBundle\Entity\User;
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Event\VoiceCallEvent;
+use AppBundle\Event\VoiceCallEvents;
+use CobrandBundle\CobrandInstance;
+use Doctrine\ORM\ORMException;
+use FOS\RestBundle\Controller\Annotations\Get;
+use FOS\RestBundle\Controller\Annotations\Post;
+
+use NexmoBundle\VoiceCall\VoiceCallOrigins;
+use NexmoBundle\VoiceCall\VoiceCallStatus;
+use Symfony\Bundle\FrameworkBundle\Controller\Controller;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+
+class OutboundCallWebHookController extends NexmoWebHookController
+{
+    /**
+     * @Post("/event-url", name="event_webhook")
+     *
+     * @param Request $request
+     * @return \Symfony\Component\HttpFoundation\JsonResponse
+     */
+    public function postEventAction(Request $request)
+    {
+        $uuid = $request->get("uuid");
+        $voiceCall = $this->getDoctrine()->getRepository("AppBundle:VoiceCall")->findOneBy([
+            "uuid"  => $uuid
+        ]);
+
+        if (!$voiceCall instanceof VoiceCall) {
+            return $this->jsonResponse(["success" => false], Response::HTTP_OK);
+        }
+
+        $delegates = [];
+        $requestMap = [
+            "status" => function ($val) use ($voiceCall, &$delegates) {
+                $voiceCall->setStatus($val);
+                // add delegate for changing statuses
+                $delegates[] = function () use ($voiceCall) {
+                    $event = new VoiceCallEvent($voiceCall);
+
+                    switch($voiceCall->getStatus()) {
+                        case VoiceCallStatus::STARTED:
+                        case VoiceCallStatus::RINGING:
+                            $this->get("event_dispatcher")->dispatch(VoiceCallEvents::STARTED_VOICE_CALL, $event);
+                            break;
+                        case VoiceCallStatus::ANSWERED:
+                            $this->get("event_dispatcher")->dispatch(VoiceCallEvents::ANSWERED_VOICE_CALL, $event);
+                            break;
+                        case VoiceCallStatus::BUSY:
+                        case VoiceCallStatus::CANCELLED:
+                        case VoiceCallStatus::REJECTED:
+                        case VoiceCallStatus::FAILED:
+                            $this->get("event_dispatcher")->dispatch(VoiceCallEvents::FAILED_VOICE_CALL, $event);
+                            break;
+                        case VoiceCallStatus::COMPLETED:
+                            $this->get("event_dispatcher")->dispatch(VoiceCallEvents::COMPLETED_VOICE_CALL, $event);
+                            break;
+                    }
+                }; // end delegate func
+            },
+            "timestamp" => function ($val) use ($voiceCall) {
+                $dt = new \DateTime($val);
+                $voiceCall->setUpdatedAt($dt);
+            },
+            "rate" => function ($val) use ($voiceCall) {
+                $voiceCall->setRate($val);
+            },
+            "price" => function ($val) use ($voiceCall) {
+                $voiceCall->setPrice($val);
+            },
+            "duration" => function ($val) use ($voiceCall) {
+                $voiceCall->setDuration($val);
+            },
+        ];
+
+        foreach ($request->request->all() as $key => $val) {
+            if (array_key_exists($key, $requestMap)) {
+                $requestMap[$key]($val);
+            }
+        }
+
+        $em = $this->getEntityManager();
+        $em->persist($voiceCall);
+
+        try {
+            $em->flush();
+            if (!empty($delegates)) {
+                foreach ($delegates as $key => $eachDelegate) {
+                    $eachDelegate();
+                }
+            }
+
+            return $this->jsonResponse(["success" => true], Response::HTTP_OK);
+        } catch (\Exception $exception) {
+            // webhooks need 200 response
+            return $this->jsonResponse(["success" => false], Response::HTTP_OK);
+        }
+    }
+
+
+    /**
+     * @Get("/answer-url", name="answer_webhook")
+     *
+     * @param Request $request
+     * @return \Symfony\Component\HttpFoundation\JsonResponse
+     */
+    public function getAnswerWebHookAction(Request $request)
+    {
+        $callerUser = $this->getDoctrine()->getRepository("AppBundle:User")
+            ->find($request->get("caller_uid", 0));
+
+        $eventUrl = base64_decode($request->get('event_url'));
+
+        if ($callerUser instanceof User) {
+            $proxyNumber = (string) $callerUser->getProfile()->getPrimaryContactNumber();
+        }
+
+        $appName = "Spoke Health";
+        $currentCobrand = $this->get("cobrand.factory")->current();
+        if ($currentCobrand instanceof CobrandInstance) {
+            $appName = $currentCobrand->getApp()->getName();
+        }
+
+        $ncoo = [
+            [
+                "action" => "talk",
+                "text" => "Hi! Please stay on the line while we connect you to your assigned employee on {$appName}."
+            ],
+            [
+                "action" => "connect",
+                "timeout" => 45,
+                "from" => $this->getParameter("nexmo_provisioned_number"),
+                "eventUrl" => [$eventUrl],
+                "endpoint" => [[
+                    "type" => "phone",
+                    "number" => $proxyNumber
+                ]]
+            ]
+        ];
+
+        return $this->jsonResponse($ncoo, Response::HTTP_OK);
+    }
+}

+<?php
+
+namespace NexmoBundle\Event\Logger\Command;
+
+use Chromedia\AuditLogBundle\Entity\Action;
+use Chromedia\AuditLogBundle\Entity\ObjectName;
+use Chromedia\AuditLogBundle\Entity\ObjectType;
+use NexmoBundle\Event\Logger\VoiceCallAuditLogCommand;
+use NexmoBundle\VoiceCall\VoiceCallStatus;
+
+class InboundVoiceCallCommand extends VoiceCallAuditLogCommand
+{
+    public function isProcessable()
+    {
+        return parent::isProcessable();
+    }
+
+    protected function buildLogData()
+    {
+        $actor = $this->voiceCallLog->getActor();
+        $subject = $actor
+            ? $actor->getProfile()->getFullName()
+            : $this->voiceCallLog->getFromNumber();
+        $data = [
+            // to show in patient logs, set object id to patient, object type account
+            "objectId" => $actor ? $actor->getId() : null,
+            "objectType" => ObjectType::ACCOUNT,
+            "objectName" => ObjectName::VOICE_CALL,
+            "actionStatus" => Action::STATUS_SUCCESS,
+            "subject" => $subject
+        ];
+
+        // actor will be admin recipient, since activity logs should always show in admin user's context
+        if ($actor) {
+            $data["actor"] = $this->voiceCallLog->getRecipient();
+        }
+
+        $statusHandlers = [
+            VoiceCallStatus::ANSWERED => function () use (&$data, $subject) {
+                $data["description"] = "{$subject} started an inbound call";
+                $data["action"] = Action::STATUS_SUCCESS;
+            },
+            VoiceCallStatus::COMPLETED => function () use (&$data, $subject) {
+                $data["description"] = "completed an inbound call with {$subject} with duration: ({$this->voiceCallLog->getFormattedDuration()}). ";
+                $data["action"] = Action::STATUS_SUCCESS;
+            },
+            VoiceCallStatus::FAILED => function () use (&$data, $subject) {
+                $data["description"] = "failed to complete an inbound call with {$subject} ({$this->voiceCallLog->getFormattedDuration()}).";
+                $data["action"] = Action::STATUS_FAILURE;
+            },
+            VoiceCallStatus::BUSY => function () use (&$data, $subject) {
+                $data["description"] = "failed to complete an inbound call with {$subject} ({$this->voiceCallLog->getFormattedDuration()}).";
+                $data["action"] = Action::STATUS_FAILURE;
+            },
+        ];
+
+        if (array_key_exists($this->voiceCallLog->getStatus(), $statusHandlers)) {
+            $statusHandlers[$this->voiceCallLog->getStatus()]();
+        }
+
+        return $data;
+    }
+}

+<?php
+
+namespace NexmoBundle\Event\Logger\Command;
+
+use AppBundle\Entity\VoiceCall;
+use Chromedia\AuditLogBundle\Entity\Action;
+use Chromedia\AuditLogBundle\Entity\ObjectName;
+use Chromedia\AuditLogBundle\Entity\ObjectType;
+use NexmoBundle\Event\Logger\VoiceCallAuditLogCommand;
+use NexmoBundle\VoiceCall\VoiceCallStatus;
+
+class UpdateVoiceCallStatusCommand extends VoiceCallAuditLogCommand
+{
+
+    public function isProcessable()
+    {
+        $knownStatus = [
+            VoiceCallStatus::STARTED,
+            VoiceCallStatus::COMPLETED,
+            VoiceCallStatus::FAILED,
+            VoiceCallStatus::BUSY
+        ];
+
+        return parent::isProcessable() && \in_array($this->voiceCallLog->getStatus(), $knownStatus);
+    }
+
+    protected function buildLogData()
+    {
+        $actor = $this->voiceCallLog->getActor();
+        $data = [
+            // to show in patient logs, set object id to patient, object type account
+            "objectId" => $actor ? $actor->getId() : "Unknown",
+            "objectType" => ObjectType::ACCOUNT,
+            "objectName" => ObjectName::VOICE_CALL,
+            "actionStatus" => Action::STATUS_SUCCESS,
+            "subject" => $this->voiceCallLog->getActor()
+                ? $this->voiceCallLog->getActor()->getProfile()->getFullName()
+                : "Anonymous",
+        ];
+
+        $recipientName = $actor
+            ? $this->voiceCallLog->getActor()->getProfile()->getFullName()
+            : "Unknown";
+
+        $statusHandlers = [
+            VoiceCallStatus::STARTED => function () use (&$data, $recipientName) {
+                $data["description"] = "started a voice call with {$recipientName}.";
+                $data["action"] = Action::STATUS_SUCCESS;
+            },
+            VoiceCallStatus::COMPLETED => function () use (&$data, $recipientName) {
+                $data["description"] = "completed a voice call with {$recipientName} ({$this->voiceCallLog->getFormattedDuration()}). ";
+                $data["action"] = Action::STATUS_SUCCESS;
+            },
+            VoiceCallStatus::FAILED => function () use (&$data, $recipientName) {
+                $data["description"] = "failed to complete a voice call with {$recipientName} ({$this->voiceCallLog->getFormattedDuration()}).";
+                $data["action"] = Action::STATUS_FAILURE;
+            },
+            VoiceCallStatus::BUSY => function () use (&$data, $recipientName) {
+                $data["description"] = "failed to complete a voice call with {$recipientName} ({$this->voiceCallLog->getFormattedDuration()}).";
+                $data["action"] = Action::STATUS_FAILURE;
+            },
+        ];
+
+        if (array_key_exists($this->voiceCallLog->getStatus(), $statusHandlers)) {
+            $statusHandlers[$this->voiceCallLog->getStatus()]();
+        }
+
+        return $data;
+    }
+}

+<?php
+
+namespace NexmoBundle\Event\Logger;
+
+use AppBundle\Entity\User;
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Event\VoiceCallEvent;
+use Symfony\Component\EventDispatcher\Event;
+
+abstract class VoiceCallAuditLogCommand
+{
+    /**
+     * @var VoiceCallEvent
+     */
+    protected $event;
+
+    /**
+     * @var VoiceCall
+     */
+    protected $voiceCallLog;
+
+    protected $logData = [];
+
+    public function isProcessable()
+    {
+        $this->event = $this->event instanceof VoiceCallEvent ? $this->event : null;
+        $this->voiceCallLog = $this->event ? $this->event->getVoiceCall() : null;
+
+        return $this->event && $this->voiceCallLog instanceof VoiceCall && $this->voiceCallLog->getDuration() > 0;
+    }
+
+    abstract protected function buildLogData();
+
+    protected function commonLogData()
+    {
+        /**
+         * actor, currently our webhook sets caller as the employee and recipient as the employee
+         */
+        return array(
+            "actionDateTime" => new \DateTime(),
+            "actor" => $this->event->getVoiceCall()->getRecipient()
+        );
+    }
+
+    final public function resolve(Event $event)
+    {
+        $this->event = $event;
+        if ($this->isProcessable()) {
+            $this->logData = array_merge($this->commonLogData(), $this->buildLogData()) ;
+        }
+
+        return $this->logData;
+    }
+}

+<?php
+
+namespace NexmoBundle\Event\Logger;
+
+use AppBundle\Entity\User;
+use AppBundle\Event\VoiceCallEvents;
+use Chromedia\AuditLogBundle\Resolver\EventResolverInterface;
+use NexmoBundle\Event\Logger\Command\InboundVoiceCallCommand;
+use NexmoBundle\Event\Logger\Command\UpdateVoiceCallStatusCommand;
+use Symfony\Component\EventDispatcher\Event;
+use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorage;
+
+class VoiceCallAuditLogResolver implements EventResolverInterface
+{
+    protected $commands;
+
+    /**
+     * @var TokenStorage
+     */
+    protected $tokenStorage;
+
+    public function __construct()
+    {
+        $this->commands = [
+            VoiceCallEvents::COMPLETED_VOICE_CALL => UpdateVoiceCallStatusCommand::class,
+            VoiceCallEvents::FAILED_VOICE_CALL => UpdateVoiceCallStatusCommand::class,
+            VoiceCallEvents::STARTED_VOICE_CALL => UpdateVoiceCallStatusCommand::class,
+            VoiceCallEvents::INBOUND_CALL_ONGOING => InboundVoiceCallCommand::class,
+            VoiceCallEvents::INBOUND_CALL_COMPLETED => InboundVoiceCallCommand::class
+        ];
+    }
+
+    public function setTokenStorage(TokenStorage $v)
+    {
+        $this->tokenStorage = $v;
+    }
+
+    /**
+     * @param Event  $event
+     * @param string $eventName
+     * @return mixed
+     */
+    public function getEventLogInfo(Event $event, $eventName)
+    {
+        if (!isset($this->commands[$eventName])) {
+            return;
+        }
+
+        $class = $this->commands[$eventName];
+        $command = new $class();
+        if ($command instanceof VoiceCallAuditLogCommand) {
+            return $command->resolve($event);
+        }
+    }
+}

+<?php
+namespace NexmoBundle\Event\Logger;
+
+use AppBundle\Event\VoiceCallEvents;
+use Chromedia\AuditLogBundle\Subscriber\AuditLogEventSubscriberInterface;
+
+class VoiceCallAuditLogSubscriber implements AuditLogEventSubscriberInterface
+{
+
+    public function getSubscribedEvents()
+    {
+        return [
+            VoiceCallEvents::STARTED_VOICE_CALL,
+            VoiceCallEvents::FAILED_VOICE_CALL,
+            VoiceCallEvents::COMPLETED_VOICE_CALL,
+            VoiceCallEvents::INBOUND_CALL_ONGOING,
+            VoiceCallEvents::INBOUND_CALL_COMPLETED
+        ];
+    }
+}

+<?php
+
+namespace NexmoBundle\Event\Subscriber;
+
+use AppBundle\Entity\ThreadContent;
+use AppBundle\Entity\ThreadContentTypes;
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Event\VoiceCallEvent;
+use AppBundle\Event\VoiceCallEvents;
+use AppBundle\Service\OpentokSignalingService;
+use Doctrine\Bundle\DoctrineBundle\Registry;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+/**
+ * Class ThreadContentVoiceCallEventSubscriber
+ *
+ */
+class ThreadContentVoiceCallEventSubscriber implements EventSubscriberInterface
+{
+    /**
+     * @var Registry
+     */
+    protected $doctrine;
+
+    /**
+     * @var OpentokSignalingService
+     */
+    protected $opentokSignaling;
+
+    public function setDoctrine(Registry $v)
+    {
+        $this->doctrine = $v;
+    }
+
+    public function setOpentokSignaling(OpentokSignalingService $v)
+    {
+        $this->opentokSignaling = $v;
+    }
+
+    public function onStatusChange(VoiceCallEvent $event)
+    {
+        if (!$event->getVoiceCall() instanceof VoiceCall) {
+            return;
+        }
+
+        /** @var ThreadContent $threadContent */
+        $threadContent = $this->doctrine->getRepository("AppBundle:ThreadContent")
+            ->findOneBy(["contentId" => $event->getVoiceCall()->getId(), "type" => ThreadContentTypes::VOICE_CALL_LOG]);
+
+        if (!$threadContent instanceof ThreadContent) {
+            return;
+        }
+
+
+        $this->opentokSignaling->sendSignal($threadContent->getThread(), "voice_call_update_content", ["thread_content" => $threadContent->getId()]);
+    }
+
+    public static function getSubscribedEvents()
+    {
+        return [
+            VoiceCallEvents::STARTED_VOICE_CALL => 'onStatusChange',
+            VoiceCallEvents::ANSWERED_VOICE_CALL => 'onStatusChange',
+            VoiceCallEvents::COMPLETED_VOICE_CALL => 'onStatusChange',
+            VoiceCallEvents::FAILED_VOICE_CALL => 'onStatusChange'
+        ];
+    }
+}

+<?php
+
+namespace NexmoBundle\Exception;
+
+class NexmoException extends \Exception
+{
+    public static function invalidPrivateKeyPath()
+    {
+        return new self("Invalid path for Nexmo private key.");
+    }
+}

+<?php
+
+
+namespace NexmoBundle\Manager;
+
+use AppBundle\Entity\AdminUser;
+use AppBundle\Entity\OpentokSessionTypes;
+use AppBundle\Entity\Patient;
+use AppBundle\Entity\ThreadContent;
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Exception\NotExistEntityException;
+use AppBundle\Service\Manager\ContactNumberManager;
+use AppBundle\Service\Manager\PatientManager;
+use AppBundle\Service\Manager\ThreadNoteManager;
+use AppBundle\Service\ThreadContentFactory;
+use JMS\DiExtraBundle\Annotation\Inject;
+use JMS\DiExtraBundle\Annotation\InjectParams;
+use JMS\DiExtraBundle\Annotation\Service;
+use NexmoBundle\VoiceCall\VoiceCallOrigins;
+use OpenTokBundle\Pool\GlobalAdminOpenTokPool;
+use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
+
+/**
+ * Class InboundCallManager
+ * @Service("nexmo.manager.inbound_call", parent="nexmo.base_manager", autowire=true, public=true)
+ */
+class InboundCallManager extends NexmoCallManager
+{
+    /**
+     * @var ThreadContentFactory
+     */
+    private $threadContentFactory;
+
+    /**
+     * @var PatientManager
+     */
+    private $patientManager;
+
+    /**
+     * @var ThreadNoteManager
+     */
+    private $threadNoteManager;
+
+    /**
+     * @var ContactNumberManager
+     */
+    private $contactNumberManager;
+
+    /**
+     * Setter Injector for PatientManager
+     * @param $patientManager
+     * @InjectParams({
+     *     "patientManager" = @Inject("spoke.manager.patient", required=false)
+     * })
+     */
+    public function setPatientManager(PatientManager $patientManager)
+    {
+        $this->patientManager = $patientManager;
+    }
+
+    /**
+     * Setter Injector for ThreadContentFactory
+     * @param $threadContentFactory
+     * @InjectParams({
+     *     "threadContentFactory" = @Inject("app.service.thread_content_factory", required=true)
+     * })
+     */
+    public function setThreadContentFactory(ThreadContentFactory $threadContentFactory)
+    {
+        $this->threadContentFactory = $threadContentFactory;
+    }
+
+    /**
+     * Setter injector for ThreadNoteManager
+     * @param ThreadNoteManager $manager
+     * @InjectParams({
+     *     "manager" = @Inject("spoke.manager.thread_note", required=true)
+     * })
+     */
+    public function setThreadNoteManager(ThreadNoteManager $manager)
+    {
+        $this->threadNoteManager = $manager;
+    }
+
+    /**
+     * Setter injector for ContactNumberManager
+     * @param ContactNumberManager $contactNumberManager
+     * @InjectParams({
+     *     "contactNumberManager" = @Inject("spoke.manager.contactNumber", required=true)
+     * })
+     */
+    public function setContactNumberManager(ContactNumberManager $contactNumberManager)
+    {
+        $this->contactNumberManager = $contactNumberManager;
+    }
+
+    public function create()
+    {
+        $voiceCall = parent::create();
+        $voiceCall->setOriginType(VoiceCallOrigins::MEMBER_USER_INBOUND_CALL);
+
+        return $voiceCall;
+    }
+
+    /**
+     * Set up thread content for this voice call
+     * @param VoiceCall $voiceCall
+     * @return null
+     * @throws \Exception
+     */
+    public function initThreadContent(VoiceCall $voiceCall)
+    {
+        // already created thread content
+        if ($voiceCall->getThreadContent()) {
+            return null;
+        }
+        $patient = $voiceCall->getActor();
+        if ($patient instanceof Patient) {
+            $voiceCall->setThreadContent($this->threadContentFactory->createContent($patient->getThread(), $voiceCall, $patient));
+        }
+    }
+
+    public function asOpenTokSignalData(VoiceCall $voiceCall)
+    {
+        $actorData = [
+            "number" => $voiceCall->getFromNumber()
+        ];
+        $patient = $voiceCall->getActor();
+        if ($patient instanceof Patient) {
+            $actorData = array_merge($actorData, [
+                "id" => $patient ? $patient->getId() : 0,
+                "name" => $patient->getProfile()->getFullName(),
+                "company" => $patient->getCompany()->getName()
+            ]);
+        }
+
+        $now = new \DateTime('now');
+        return [
+            "voiceCall" => $voiceCall->getId(),
+            "recipient" => $voiceCall->getRecipient() ? $voiceCall->getRecipient()->getId() : null,
+            "actor" => $actorData,
+            "isCallOngoing" => $voiceCall->getIsCallOngoing(),
+            "duration" => $voiceCall->getDuration(),
+            "runningDuration" => $now->getTimestamp()-$voiceCall->getCreatedAt()->getTimestamp(),
+            "fromNumber" => $voiceCall->getFromNumber()
+        ];
+    }
+
+    protected function getUpdateMappers(VoiceCall $voiceCall)
+    {
+        return [
+            "actor" => function ($value) use ($voiceCall) {
+                $patient = $this->patientManager->getFind($value);
+
+                if (!$patient) {
+                    throw new \Exception("Invalid patient actor for voice call.");
+                }
+
+                $voiceCallNumber = $voiceCall->getFromNumber();
+
+                $contactNumber = $this->contactNumberManager->create(
+                    [
+                        'number' => substr($voiceCallNumber, -10),
+                        'country_number' => substr($voiceCallNumber, 0, strlen($voiceCallNumber) % 10),
+                        'primary' => false
+                    ]
+                );
+
+                $this->patientManager->update($patient, ['contactNumber' => $contactNumber]);
+                $voiceCall->setActor($patient);
+                $this->initThreadContent($voiceCall);
+            },
+            // create ThreadNote for this VoiceCall
+            "notes" => function ($value) use ($voiceCall) {
+                $parentThreadContent = $voiceCall->getThreadContent();
+                $recipient = $voiceCall->getRecipient();
+
+                // must have existing thread content for main voice call log,
+                // must have a recipient, automatically set as actor for notes
+                if ($parentThreadContent && $recipient) {
+                    $threadNote = $this->threadNoteManager->create($value);
+                    $this->threadContentFactory->createContent($parentThreadContent->getThread(), $threadNote, $recipient, $parentThreadContent);
+                }
+            }
+        ];
+    }
+}

+<?php
+namespace NexmoBundle\Manager;
+
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Repository\VoiceCallRepository;
+use AppBundle\Service\Manager\BaseManager;
+use Doctrine\Bundle\DoctrineBundle\Registry;
+use Doctrine\ORM\EntityManager;
+use JMS\DiExtraBundle\Annotation\Inject;
+use JMS\DiExtraBundle\Annotation\InjectParams;
+use JMS\DiExtraBundle\Annotation\Service;
+use Sentry\SentryBundle\SentrySymfonyClient;
+use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
+use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
+
+/**
+ * Class NexmoCallManager
+ * @Service("nexmo.base_manager", autowire=true, public=true)
+ */
+abstract class NexmoCallManager extends BaseManager
+{
+    /**
+     * @var VoiceCallRepository
+     */
+    protected $repository;
+
+    /**
+     * @var SentrySymfonyClient
+     */
+    protected $sentryClient;
+
+    /**
+     * @param VoiceCallRepository $voiceCallRepository
+     */
+    public function __construct(VoiceCallRepository $voiceCallRepository)
+    {
+        $this->repository = $voiceCallRepository;
+    }
+
+    /**
+     * @param SentrySymfonyClient $client
+     * @InjectParams({
+     *     "client" = @Inject("sentry.client", required=false)
+     * })
+     */
+    public function setSentryClient(SentrySymfonyClient $client)
+    {
+        $this->sentryClient = $client;
+    }
+
+    /**
+     * Common query function for all Nexmo related voice call logs since most interact via uuid.
+     * @param $uuid
+     * @return VoiceCall
+     */
+    public function findOneByUUID($uuid)
+    {
+        return $this->repository->findOneBy(["uuid" => $uuid]);
+    }
+
+    /**
+     * @param string $uuid
+     * @return VoiceCall
+     */
+    public function findOneByUuidOrHalt($uuid)
+    {
+        $obj = $this->findOneByUUID($uuid);
+        if (!$obj) {
+            throw new NotFoundHttpException("Invalid voice call uuid.");
+        }
+
+        return $obj;
+    }
+
+    abstract protected function getUpdateMappers(VoiceCall $voiceCall);
+
+    /**
+     * @param VoiceCall $voiceCall
+     * @param array     $params
+     * @throws \Exception
+     */
+    final public function patch(VoiceCall $voiceCall, array $params = [])
+    {
+        try {
+            $this->beginTransaction();
+            $mappers = $this->getUpdateMappers($voiceCall);
+
+            foreach ($params as $key => $value) {
+                if (isset($mappers[$key]) && !is_null($value)) {
+                    $mappers[$key]($value);
+                }
+            }
+
+            $this->save($voiceCall);
+            $this->commit();
+        } catch (\Exception $exception) {
+            $this->rollback();
+            $this->sentryClient->captureException($exception);
+            throw new BadRequestHttpException("Failed to apply patch changes for VoiceCall", $exception);
+        }
+    }
+
+    /**
+     * @return VoiceCall
+     * @throws \Exception
+     */
+    public function create()
+    {
+        $voiceCall = new VoiceCall();
+        $voiceCall->setCreatedAt(new \DateTime());
+
+        return $voiceCall;
+    }
+}

+<?php
+
+namespace NexmoBundle;
+
+use Symfony\Component\HttpKernel\Bundle\Bundle;
+
+class NexmoBundle extends Bundle
+{
+}

+services:
+  nexmo.audit_log_resolver:
+    class: NexmoBundle\Event\Logger\VoiceCallAuditLogResolver
+
+  nexmo.audit_log_subscriber:
+    class: NexmoBundle\Event\Logger\VoiceCallAuditLogSubscriber
+    tags:
+      - { name: audit_log.event_subscriber, resolver : nexmo.audit_log_resolver }

+nexmo_inbound_webhooks:
+  type: annotation
+  resource: NexmoBundle\Controller\InboundCallWebHookController
+  prefix: "web-hooks/inbound-calls"
+  name_prefix: nexmo.webhooks.inbound_call_
+
+nexmo_outbound_webhooks:
+  type: annotation
+  resource: NexmoBundle\Controller\OutboundCallWebHookController
+  prefix: "web-hooks/outbound-calls"
+  name_prefix: nexmo.webhooks.outbound_call_

+imports:
+  - { resource: "@NexmoBundle/Resources/config/logger.yml" }
+
+services:
+  nexmo.voice_call_manager:
+    class: NexmoBundle\VoiceCall\VoiceCallManager
+    arguments: ["%nexmo_application_id%", "@cobrand.factory"]
+    calls:
+      - [setProvisionedNumber, ["%nexmo_provisioned_number%"]]
+      - [setRouter, ["@router"]]
+      - [initWebhookUrls, ["%base_host%"]]
+
+  nexmo.thread_content_voice_call_subscriber:
+    class: NexmoBundle\Event\Subscriber\ThreadContentVoiceCallEventSubscriber
+    calls:
+      - [setDoctrine, ["@doctrine"]]
+      - [setOpentokSignaling, ["@app.opentok_signaling"]]
+    tags:
+      - { name: kernel.event_subscriber }

+<?php
+
+
+namespace NexmoBundle\WebHook;
+
+use AppBundle\Service\ConsoleInvoker;
+use CobrandBundle\CobrandInstance;
+use CobrandBundle\Service\CobrandFactory;
+use JMS\DiExtraBundle\Annotation\Inject;
+use JMS\DiExtraBundle\Annotation\InjectParams;
+use JMS\DiExtraBundle\Annotation\Service;
+use Monolog\Logger;
+use NexmoBundle\Manager\NexmoCallManager;
+use Sentry\SentryBundle\SentrySymfonyClient;
+use Symfony\Component\HttpFoundation\JsonResponse;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;
+
+/**
+ * Class NexmoWebHookHandler
+ * @Service("nexmo.webhooks.base", abstract=true, autowire=true, public=true)
+ */
+abstract class NexmoWebHookHandler
+{
+    /**
+     * @var Request
+     */
+    protected $request;
+
+    protected $logger;
+
+    protected $responseData = [];
+
+    /**
+     * @var SentrySymfonyClient
+     */
+    protected $sentry;
+
+    /**
+     * @var CobrandInstance
+     */
+    protected $currentCobrand;
+
+    /**
+     * @var ConsoleInvoker
+     */
+    protected $consoleInvoker;
+
+    /**
+     * @param Logger $logger
+     * @InjectParams({
+     *     "logger" = @Inject("logger", required=false)
+     * })
+     */
+    public function injectLogger(Logger $logger)
+    {
+        $this->logger = $logger;
+    }
+
+    /**
+     * @param CobrandFactory $factory
+     * @InjectParams({
+     *     "factory" = @Inject("cobrand.factory", required=false)
+     * })
+     */
+    public function injectCurrentCobrand(CobrandFactory $factory)
+    {
+        $this->currentCobrand = $factory->current();
+    }
+
+    /**
+     * @param SentrySymfonyClient $client
+     * @InjectParams({
+     *     "client" = @Inject("sentry.client", required=false)
+     * })
+     */
+    public function injectSentryClient(SentrySymfonyClient $client)
+    {
+        $this->sentry = $client;
+    }
+
+    /**
+     * @param ConsoleInvoker $invoker
+     * @InjectParams({
+     *     "invoker" = @Inject("spoke.console_invoker", required=false)
+     * })
+     */
+    public function injectConsoleInvoker(ConsoleInvoker $invoker)
+    {
+        $this->consoleInvoker = $invoker;
+    }
+
+    /**
+     * @param Request $request
+     * @return JsonResponse
+     */
+    final public function handle(Request $request)
+    {
+        $this->responseData = [];
+        $this->request = $request;
+
+        try {
+            $this->processRequest();
+
+            return new JsonResponse($this->responseData, Response::HTTP_OK);
+        } catch (\Exception $exception) {
+            // Important: Nexmo webhooks needs 200 response code, even for error.
+            $this->sentry->captureException($exception);
+            return new JsonResponse(["error" => $exception->getMessage()], Response::HTTP_OK);
+        }
+    }
+
+    protected function getRequestParam($key, $required = true)
+    {
+        $val = $this->request->get($key, null);
+        if ($required && is_null($val)) {
+            throw new BadRequestHttpException(sprintf('Missing required parameter for nexmo webhook: %s', $key));
+        }
+
+        return $val;
+    }
+
+    protected function logInfo($string)
+    {
+        $this->logger->info("[NEXMO_WEBHOOK]: {$string}");
+    }
+
+    abstract protected function processRequest();
+}

+<?php
+
+
+namespace NexmoBundle\WebHook;
+
+use AppBundle\Entity\AdminUser;
+use AppBundle\Entity\OpentokSessionTypes;
+use AppBundle\Entity\Patient;
+use AppBundle\Entity\VoiceCall;
+use AppBundle\Repository\PatientRepository;
+use AppBundle\Service\Manager\AdminUserManager;
+use AppBundle\Service\Manager\PatientManager;
+use JMS\DiExtraBundle\Annotation\Inject;
+use JMS\DiExtraBundle\Annotation\InjectParams;
+use JMS\DiExtraBundle\Annotation\Service;
+use NexmoBundle\Manager\InboundCallManager;
+use NexmoBundle\VoiceCall\VoiceCallStatus;
+use OpenTokBundle\Pool\GlobalAdminOpenTokPool;
+use OpenTokBundle\Pool\OpenTokPoolFactory;
+
+/**
+ * Class OnAnswerInboundWebHook
+ * @Service("nexmo.webhooks.answer_inbound", autowire=true, public=true)
+ */
+class OnAnswerInboundWebHook extends NexmoWebHookHandler
+{
+    /**
+     * @var InboundCallManager
+     */
+    private $callManager;
+
+    /**
+     * @var AdminUserManager
+     */
+    private $adminUserManager;
+
+    /**
+     * @var PatientManager
+     */
+    private $patientManager;
+
+    /**
+     * @var GlobalAdminOpenTokPool
+     */
+    private $opentokPool;
+
+    /**
+     * @param InboundCallManager $manager
+     * @InjectParams({
+     *     "manager" = @Inject("nexmo.manager.inbound_call", required=false)
+     * })
+     */
+    public function setInboundVoiceCallManager(InboundCallManager $manager)
+    {
+        $this->callManager = $manager;
+    }
+
+    /**
+     * @param AdminUserManager $manager
+     * @InjectParams({
+     *     "manager" = @Inject("spoke.manager.admin_user", required=false)
+     * })
+     */
+    public function injectUserManager(AdminUserManager $manager)
+    {
+        $this->adminUserManager = $manager;
+    }
+
+    /**
+     * @param PatientManager $manager
+     * @InjectParams({
+     *     "manager" = @Inject("spoke.manager.patient", required=false)
+     * })
+     */
+    public function injectPatientManager(PatientManager $manager)
+    {
+        $this->patientManager = $manager;
+    }
+
+    /**
+     * @param OpenTokPoolFactory $factory
+     * @throws \Exception
+     * @InjectParams({
+     *     "factory" = @Inject("opentok_pool_factory", required=false)
+     * })
+     */
+    public function injectAdminPool(OpenTokPoolFactory $factory)
+    {
+        $this->opentokPool = $factory->get(OpentokSessionTypes::ADMIN_POOL);
+    }
+
+
+    /**
+     * @return VoiceCall|object|null
+     * @throws \Exception
+     */
+    private function buildVoiceCallFromRequest()
+    {
+        $uuid = $this->getRequestParam('uuid');
+        $fromNumber = $this->getRequestParam('from');
+        $conversationId = $this->getRequestParam('conversation_uuid');
+
+        $voiceCall = $this->callManager->findOneByUUID($uuid);
+        // no existing voice call with uuid, create one
+        if (!$voiceCall) {
+            $voiceCall = $this->callManager->create();
+        }
+
+        $voiceCall->setUpdatedAt(new \DateTime());
+        $voiceCall->setConversationUuid($conversationId);
+        $voiceCall->setFromNumber($fromNumber);
+        $voiceCall->setUuid($uuid);
+
+        return $voiceCall;
+    }
+
+    protected function processRequest()
+    {
+        $voiceCall = $this->buildVoiceCallFromRequest();
+        $this->logInfo("Inbound call answer url. From number: {$voiceCall->getFromNumber()}");
+
+        // find mapped member based on the contact number
+        // we can only map out one patient to this voice call log
+        // for multiple patients having same contact number will be manually managed
+        $patients = $this->patientManager->findByContactNumber($voiceCall->getFromNumber());
+        /** @var Patient $actor */
+        $actor = 1 == count($patients) ? $patients[0] : null;
+        if ($actor) {
+            $voiceCall->setActor($actor);
+        }
+
+        // as per Jason discussion, we will always forward the call to the default number FOR march 15
+        $proxyNumber = $this->currentCobrand->getNexmo()->defaultNumber;
+
+        // find AdminUser who owns this proxyNumber, can only handle one recipient
+        $adminUsers = $this->adminUserManager->findByContactNumber($proxyNumber);
+        /** @var AdminUser $adminRecipient */
+        $adminRecipient = 1 == count($adminUsers) ? $adminUsers[0] : null;
+        if ($adminRecipient) {
+            $voiceCall->setRecipient($adminRecipient);
+        }
+
+        $voiceCall->setToNumber($proxyNumber);
+
+        try {
+            $this->callManager->beginTransaction();
+            $this->callManager->save($voiceCall);
+            $this->callManager->commit();
+
+            // build out response data for connecting to proxy number
+            $this->responseData = [
+                [
+                    "action" => "connect",
+                    // redirect to advocate or company default number
+                    "endpoint" => [[
+                        "type" => "phone",
+                        "number" => $proxyNumber
+                    ]],
+                    "timeout" => 45
+                ]
+            ];
+        } catch (\Exception $exception) {
+            $appName = $this->currentCobrand ? $this->currentCobrand->getApp()->getName() : null;
+            $this->callManager->rollback();
+            $this->sentry->captureException($exception);
+
+            // failure
+            $this->responseData = [[
+                "action" => "talk",
+                "text" => "Thank you for calling ${appName}, we are currently experiencing technical problems."
+            ]];
+        }
+    }
+}

+<?php
+
+
+namespace NexmoBundle\WebHook;
+
+use AppBundle\Entity\AdminUser;
+use AppBundle\Entity\OpentokSessionTypes;
+use AppBundle\Event\VoiceCallEvent;
+use AppBundle\Event\VoiceCallEvents;
+use JMS\DiExtraBundle\Annotation\Inject;
+use JMS\DiExtraBundle\Annotation\InjectParams;
+use JMS\DiExtraBundle\Annotation\Service;
+use NexmoBundle\Manager\InboundCallManager;
+use NexmoBundle\VoiceCall\VoiceCallStatus;
+use OpenTokBundle\Pool\GlobalAdminOpenTokPool;
+use OpenTokBundle\Pool\OpenTokPoolFactory;
+use Symfony\Component\EventDispatcher\EventDispatcherInterface;
+
+/**
+ * Class OnEventInboundWebHook
+ * @Service("nexmo.webhooks.event_inbound", autowire=true, public=true)
+ */
+class OnEventInboundWebHook extends NexmoWebHookHandler
+{
+    /**
+     * @var InboundCallManager
+     */
+    private $callManager;
+
+    /**
+     * @var EventDispatcherInterface
+     */
+    private $eventDispatcher;
+
+    /**
+     * @var GlobalAdminOpenTokPool
+     */
+    private $opentokPool;
+
+    /**
+     * @param EventDispatcherInterface $dispatcher
+     * @InjectParams({
+     *     "dispatcher" = @Inject("event_dispatcher", required=false)
+     * })
+     */
+    public function setEventDispatcher(EventDispatcherInterface $dispatcher)
+    {
+        $this->eventDispatcher = $dispatcher;
+    }
+
+    /**
+     * @param InboundCallManager $manager
+     * @InjectParams({
+     *     "manager" = @Inject("nexmo.manager.inbound_call", required=false)
+     * })
+     */
+    public function setInboundVoiceCallManager(InboundCallManager $manager)
+    {
+        $this->callManager = $manager;
+    }
+
+    /**
+     * @param OpenTokPoolFactory $factory
+     * @throws \Exception
+     * @InjectParams({
+     *     "factory" = @Inject("opentok_pool_factory", required=false)
+     * })
+     */
+    public function injectAdminPool(OpenTokPoolFactory $factory)
+    {
+        $this->opentokPool = $factory->get(OpentokSessionTypes::ADMIN_POOL);
+    }
+
+    protected function processRequest()
+    {
+        $voiceCall = $this->callManager->findOneByUuidOrHalt($this->getRequestParam('uuid'));
+
+        $requestMap = [
+            "status" => function ($val) use ($voiceCall, &$delegates) {
+                $voiceCall->setStatus($val);
+            },
+            "timestamp" => function ($val) use ($voiceCall) {
+                $dt = new \DateTime($val);
+                $voiceCall->setUpdatedAt($dt);
+            },
+            "rate" => function ($val) use ($voiceCall) {
+                $voiceCall->setRate($val);
+            },
+            "price" => function ($val) use ($voiceCall) {
+                $voiceCall->setPrice($val);
+            },
+            "duration" => function ($val) use ($voiceCall) {
+                $voiceCall->setDuration($val);
+            },
+        ];
+
+        // call event mapper
+        foreach ($this->request->request->all() as $key => $val) {
+            if (array_key_exists($key, $requestMap)) {
+                $requestMap[$key]($val);
+            }
+        }
+
+        try {
+            $this->callManager->beginTransaction();
+            $this->callManager->initThreadContent($voiceCall);
+            $this->callManager->save($voiceCall);
+            $this->callManager->commit();
+
+            if ($voiceCall->getRecipient() instanceof AdminUser) {
+                $this->opentokPool->sendSignal("inbound-call", $this->callManager->asOpenTokSignalData($voiceCall));
+
+                // trigger log only on completed call
+                if (VoiceCallStatus::COMPLETED === $voiceCall->getStatus()) {
+                    $this->eventDispatcher->dispatch(VoiceCallEvents::INBOUND_CALL_COMPLETED, new VoiceCallEvent($voiceCall));
+                }
+            }
+
+            // no needed data for response
+            $this->responseData = [
+                'success' => true
+            ];
+        } catch (\Exception $exception) {
+            $this->sentry->captureException($exception);
+
+            // no needed data for response
+            $this->responseData = [
+                'success' => false
+            ];
+        }
+    }
+}

+package com.styleteq.app;
+
+import android.content.DialogInterface;
+import android.content.Intent;
+import android.os.Bundle;
+import android.view.Menu;
+import android.view.MenuItem;
+import android.view.View;
+import android.widget.TextView;
+import android.widget.Toast;
+
+import com.styleteq.app.adapters.SwipeScreenAdapter;
+import com.styleteq.app.api.STCallback;
+import com.styleteq.app.api.STRequest;
+import com.styleteq.app.api.ServiceGenerator;
+import com.styleteq.app.errors.ErrorBag;
+import com.styleteq.app.errors.ErrorsSerializer;
+import com.styleteq.app.helpers.Logger;
+import com.styleteq.app.helpers.STActivity;
+import com.styleteq.app.helpers.TemporaryValues;
+import com.styleteq.app.helpers.Utils;
+import com.styleteq.app.models.Attachment;
+import com.styleteq.app.models.Booth;
+import com.styleteq.app.models.Session;
+import com.styleteq.app.services.BoothService;
+import com.styleteq.app.ui.ConfirmDeleteDialog;
+import com.styleteq.app.ui.DynamicHeightViewPager;
+import com.styleteq.app.ui.LoadingScreen;
+import com.viewpagerindicator.CirclePageIndicator;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import butterknife.BindView;
+import butterknife.ButterKnife;
+import retrofit2.Call;
+import retrofit2.Response;
+
+public class BoothActivity extends STActivity {
+    @BindView(R.id.booth)
+    public TextView boothName;
+    @BindView(R.id.name)
+    public TextView name;
+    @BindView(R.id.address)
+    public TextView address;
+    @BindView(R.id.view_pager)
+    public DynamicHeightViewPager pager;
+    @BindView(R.id.indicator)
+    public CirclePageIndicator indicator;
+    @BindView(R.id.price)
+    public TextView price;
+    @BindView(R.id.method)
+    public TextView method;
+    @BindView(R.id.businessType)
+    public TextView businessType;
+    @BindView(R.id.boothContainer)
+    public View boothContainer;
+
+    private ConfirmDeleteDialog deleteDialog;
+    private Booth booth;
+    private LoadingScreen loadingScreen;
+    private Menu menu;
+
+    @Override
+    protected void onCreate(Bundle savedInstanceState) {
+        super.onCreate(savedInstanceState);
+        Intent i = getIntent();
+
+        setContentView(R.layout.activity_booth);
+        ButterKnife.bind(this);
+
+        if (savedInstanceState != null) {
+            String s = savedInstanceState.getString("booth");
+            if (s != null)
+                booth = Booth.createFromJsonString(s);
+        }
+        if (booth == null) {
+            if (i.hasExtra("booth")) {
+                booth = Booth.createFromJsonString(i.getStringExtra("booth"));
+            } else if (i.hasExtra("booth_id")) {
+                BoothService s = ServiceGenerator.createService(BoothService.class, "booth");
+                new STRequest<>(s.get(i.getLongExtra("booth_id", 0)), new STCallback<Booth>() {
+                    @Override
+                    public void onCustomResponse(Call<Booth> call, Response<Booth> response) {
+                        if (response.isSuccessful()) {
+                            booth = response.body();
+                            populate();
+                        } else
+                            showResponseError(response);
+                    }
+
+                    @Override
+                    public void onFailure(Call<Booth> call, Throwable t) {
+                        Toast.makeText(BoothActivity.this, t.getMessage(), Toast.LENGTH_SHORT).show();
+                    }
+                }).execute();
+            } else
+                Logger.e("Booth not found");
+        }
+        init();
+        addListeners();
+        if (booth != null) {
+            populate();
+        }
+    }
+
+    private void init() {
+        setToolbar(R.id.tool_bar);
+        loadingScreen = new LoadingScreen();
+        loadingScreen.show(true);
+    }
+
+    private void populate() {
+        boothName.setText(String.format("%s %s for Rent", booth.slots, getResources().getQuantityString(R.plurals.booths, booth.slots)));
+        name.setText(booth.salon.name);
+        address.setText(booth.salon.address());
+
+        List<Attachment> images = booth.images.isEmpty() ? booth.salon.images : booth.images;
+        if (images.isEmpty()) {
+            images = new ArrayList<>();
+            images.add(new Attachment());
+        }
+
+        SwipeScreenAdapter a = new SwipeScreenAdapter(this, images, pager);
+        pager.setAdapter(a);
+
+        indicator.setViewPager(pager);
+        price.setText(String.format("%s %s", Utils.formatDollar(booth.price.doubleValue()), booth.terms));
+        method.setText(booth.payMethod());
+        businessType.setText(booth.salon.businessType);
+
+        deleteDialog = new ConfirmDeleteDialog(this, "Are you sure you want to delete this Booth?",
+                new DialogInterface.OnClickListener() {
+                    public void onClick(DialogInterface dialog, int whichButton) {
+                        showProgressDialogWithAction("Deleting booth");
+                        BoothService s = ServiceGenerator.createService(BoothService.class);
+                        new STRequest<>(s.delete(booth.id), new STCallback<Booth>() {
+                            @Override
+                            public void onCustomResponse(Call<Booth> call, Response<Booth> response) {
+                                hideProgressDialog();
+                                if (response.isSuccessful()) {
+                                    if (!getIntent().hasExtra(Utils.BACK)) {
+                                        TemporaryValues.setBooth(booth);
+                                        TemporaryValues.setMode(TemporaryValues.DELETE_MODE);
+                                        finish();
+                                    } else
+                                        startActivity(new Intent(BoothActivity.this, BoothListActivity.class).putExtra("salon", booth.salon.toJsonString()).addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP));
+                                    Toast.makeText(BoothActivity.this, "Successfully deleted booth!", Toast.LENGTH_LONG).show();
+                                } else {
+                                    ErrorBag e = ErrorsSerializer.parseResourceErrors(response);
+                                    if (e != null)
+                                        Toast.makeText(BoothActivity.this, e.concatenateErrors(), Toast.LENGTH_LONG).show();
+                                }
+                            }
+
+                            @Override
+                            public void onFailure(Call<Booth> call, Throwable t) {
+                                hideProgressDialog();
+                                Toast.makeText(BoothActivity.this, t.getMessage(), Toast.LENGTH_SHORT).show();
+                            }
+                        }).execute();
+                    }
+                });
+
+        setupMenu();
+        loadingScreen.show(false);
+    }
+
+    private void addListeners() {
+        boothContainer.setOnClickListener(new View.OnClickListener() {
+            @Override
+            public void onClick(View v) {
+                startActivity(new Intent(BoothActivity.this, SalonActivity.class)
+                        .putExtra("salon", booth.salon.toJsonString()).putExtra(Utils.BACK, Utils.BACK));
+            }
+        });
+    }
+
+    @Override
+    public boolean onCreateOptionsMenu(Menu menu) {
+        this.menu = menu;
+        if (booth != null)
+            setupMenu();
+        return true;
+    }
+
+    private void setupMenu() {
+        if (menu == null)
+            return;
+        if (Session.isCurrentUser(booth.salon.userId)) {
+            getMenuInflater().inflate(R.menu.menu_salon, menu);
+            menu.findItem(R.id.edit).setTitle("Edit Booth");
+            menu.findItem(R.id.manage_photos).setTitle("Manage Images");
+        } else
+            getMenuInflater().inflate(R.menu.menu_report, menu);
+    }
+
+    @Override
+    public boolean onOptionsItemSelected(MenuItem item) {
+        if (!Session.get().exists()) {
+            STApplication.promptLogin();
+            return true;
+        }
+        switch (item.getItemId()) {
+            case R.id.edit:
+                startActivity(new Intent(this, BoothFormActivity.class).putExtra("booth", booth.toJsonString()));
+                return true;
+            case R.id.manage_photos:
+                startActivity(new Intent(this, UploadBoothPhotosActivity.class).putExtra("booth", booth.toJsonString()).putExtra(Utils.BACK, Utils.BACK));
+                return true;
+            case R.id.delete:
+                deleteDialog.show();
+                return true;
+            case R.id.report:
+                startActivity(new Intent(this, ReportActivity.class).putExtra("booth", booth.toJsonString()));
+                return true;
+            default:
+                return super.onOptionsItemSelected(item);
+        }
+    }
+
+    @Override
+    public void onBackPressed() {
+        if (!loadingScreen.isLoading()) {
+            TemporaryValues.setBooth(booth);
+            super.onBackPressed();
+        }
+    }
+
+    @Override
+    public void onResume() {
+        super.onResume();
+        Booth tempBooth = TemporaryValues.useBooth();
+        if (tempBooth != null) {
+            booth = tempBooth;
+            init();
+            populate();
+        }
+    }
+
+    @Override
+    protected void onSaveInstanceState(Bundle outState) {
+        super.onSaveInstanceState(outState);
+        if (booth != null)
+            outState.putString("booth", booth.toJsonString());
+    }
+}

+package com.styleteq.app.fragments;
+
+import android.app.Activity;
+import android.os.Bundle;
+
+import androidx.annotation.Nullable;
+import androidx.fragment.app.Fragment;
+import androidx.recyclerview.widget.LinearLayoutManager;
+import androidx.recyclerview.widget.RecyclerView;
+
+import android.view.LayoutInflater;
+import android.view.View;
+import android.view.ViewGroup;
+import android.view.animation.AnimationUtils;
+import android.widget.CompoundButton;
+import android.widget.RelativeLayout;
+import android.widget.Switch;
+import android.widget.Toast;
+
+import com.styleteq.app.R;
+import com.styleteq.app.adapters.SchedulesAdapter;
+import com.styleteq.app.api.STCallback;
+import com.styleteq.app.api.STRequest;
+import com.styleteq.app.api.ServiceGenerator;
+import com.styleteq.app.errors.ErrorBag;
+import com.styleteq.app.errors.ErrorsSerializer;
+import com.styleteq.app.models.InfiniteScrollable;
+import com.styleteq.app.models.PaginatedResult;
+import com.styleteq.app.models.Schedule;
+import com.styleteq.app.services.ScheduleService;
+import com.styleteq.app.ui.DividerItemDecorator;
+import com.styleteq.app.ui.InfiniteScrollView;
+import com.styleteq.app.ui.LoadingScreen;
+import com.styleteq.app.ui.NoEntityPlaceholder;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Objects;
+
+import butterknife.ButterKnife;
+import retrofit2.Call;
+import retrofit2.Response;
+
+/**
+ * A simple {@link Fragment} subclass.
+ * create an instance of this fragment.
+ */
+public abstract class MyScheduleFragment extends Fragment implements InfiniteScrollable {
+
+    ScheduleService scheduleService;
+    boolean qWithPast;
+
+    protected ViewGroup container;
+    protected Runnable runnable;
+    protected PaginatedResult currentResult;
+
+    private RelativeLayout fragmentWrapper;
+    private NoEntityPlaceholder placeholder;
+    private LoadingScreen loadingScreen;
+    private boolean loading;
+    private boolean resetList;
+
+    public MyScheduleFragment() {
+        // Required empty public constructor
+    }
+
+    @Override
+    public View onCreateView(LayoutInflater inflater, ViewGroup container, Bundle savedInstanceState) {
+        // Inflate the layout for this fragment
+        this.container = container;
+        return inflater.inflate(R.layout.fragment_my_schedule_list, container, false);
+    }
+
+    @Override
+    public void onActivityCreated(@Nullable Bundle savedInstanceState) {
+        super.onActivityCreated(savedInstanceState);
+        ButterKnife.bind(Objects.requireNonNull(getFragmentActivity()));
+        preInit();
+        init();
+        scheduleService = ServiceGenerator.createService(ScheduleService.class);
+        addListeners();
+        qWithPast = defaultSwitchState();
+    }
+
+    @Override
+    public void onResume() {
+        super.onResume();
+        this.loadingScreen = new LoadingScreen(container);
+        placeholder.setTarget(fragmentWrapper);
+        load(0);
+    }
+
+    @Override
+    public void onStop() {
+        super.onStop();
+        getSchedulesAdapter().clearAll();
+    }
+
+    @Override
+    public void onViewStateRestored(@Nullable Bundle savedInstanceState) {
+        super.onViewStateRestored(savedInstanceState);
+        resetList = true;
+    }
+
+    private void init() {
+        View v = getMainView();
+        RecyclerView recyclerView = v.findViewById(R.id.schedule_list_recycler);
+        InfiniteScrollView scrollView = v.findViewById(R.id.inf_scroll_view);
+        fragmentWrapper = v.findViewById(R.id.schedule_list);
+        placeholder = v.findViewById(R.id.placeholder);
+
+        scrollView.setScrollable(this);
+
+        placeholder.set(Objects.requireNonNull(getActivity()), R.string.schedule_no_title, R.string.schedule_no_sub);
+
+        recyclerView.setLayoutManager(new LinearLayoutManager(getActivity()));
+        recyclerView.setAnimation(AnimationUtils.loadAnimation(getActivity(), android.R.anim.fade_in));
+        recyclerView.setAdapter(getSchedulesAdapter());
+        recyclerView.setNestedScrollingEnabled(false);
+        recyclerView.addItemDecoration(new DividerItemDecorator(Objects.requireNonNull(getActivity()), DividerItemDecorator.VERTICAL_LIST));
+    }
+
+    protected void addListeners() {
+        if (null != getSwitch()) {
+            getSwitch().setChecked(defaultSwitchState());
+            getSwitch().setOnCheckedChangeListener(new CompoundButton.OnCheckedChangeListener() {
+                public void onCheckedChanged(CompoundButton buttonView, boolean isChecked) {
+                    qWithPast = isChecked;
+                    resetList = true;
+                    load(0);
+                }
+            });
+        }
+    }
+
+    protected void load(int page) {
+        this.loadingScreen.show(true);
+        this.loading = true;
+        new STRequest<>(getQuery(page), new STCallback<PaginatedResult>() {
+            @Override
+            public void onCustomResponse(Call<PaginatedResult> call, Response<PaginatedResult> response) {
+                if (response.isSuccessful()) {
+                    currentResult = response.body();
+                    if (null != currentResult && !currentResult.schedules.isEmpty()) {
+                        getResults(currentResult.schedules);
+                    } else {
+                        getResults(Collections.emptyList());
+                    }
+                } else {
+                    ErrorBag b = ErrorsSerializer.parseResourceErrors(response);
+                    if (b != null)
+                        Toast.makeText(getActivity(), b.concatenateErrors(), Toast.LENGTH_SHORT).show();
+                }
+                checkList();
+                endLoading();
+            }
+
+            @Override
+            public void onFailure(Call<PaginatedResult> call, Throwable t) {
+                endLoading();
+                placeholder.showError(t.getMessage());
+            }
+        }).execute();
+    }
+
+    private void checkList() {
+        if (getSchedulesAdapter().getItemCount() > 0) {
+            placeholder.show(false);
+        } else {
+            getSchedulesAdapter().notifyDataSetChanged();
+            placeholder.show(true);
+        }
+    }
+
+    private void getResults(List<Schedule> schedules) {
+        if (resetList) {
+            getSchedulesAdapter().clearAll();
+            resetList = false;
+        }
+        getSchedulesAdapter().addAll(schedules);
+    }
+
+    private void endLoading() {
+        this.loading = false;
+        this.loadingScreen.show(false);
+    }
+
+    @Override
+    public boolean canLoad() {
+        return !this.loading && (null != currentResult && currentResult.hasNext());
+    }
+
+    @Override
+    public Runnable loadMoreResults() {
+        if (runnable == null)
+            runnable = new Runnable() {
+                @Override
+                public void run() {
+                    load(currentResult.nextPage());
+                }
+            };
+        return runnable;
+    }
+
+    protected boolean defaultSwitchState() {
+        return false;
+    }
+
+    protected Switch getSwitch() {
+        return null;
+    }
+
+    protected abstract void preInit();
+
+    protected abstract Call<PaginatedResult> getQuery(int page);
+
+    protected abstract SchedulesAdapter getSchedulesAdapter();
+
+    protected abstract View getMainView();
+
+    protected abstract Activity getFragmentActivity();
+
+    protected abstract String getSource();
+}

+package com.styleteq.app;
+
+import android.content.ComponentName;
+import android.content.Context;
+import android.content.Intent;
+import androidx.annotation.LayoutRes;
+import androidx.multidex.MultiDexApplication;
+import android.view.LayoutInflater;
+import android.view.View;
+
+import com.crashlytics.android.Crashlytics;
+import com.crashlytics.android.core.CrashlyticsCore;
+import com.facebook.FacebookSdk;
+import com.facebook.appevents.AppEventsLogger;
+import com.styleteq.app.firebase.STFirebase;
+import com.styleteq.app.helpers.STActivity;
+import com.styleteq.app.helpers.Utils;
+import com.styleteq.app.models.Session;
+
+import io.fabric.sdk.android.Fabric;
+
+public class STApplication extends MultiDexApplication {
+    private static boolean activityVisible;
+    private static STApplication instance;
+    private STActivity currentActivity;
+
+    public static STApplication getInstance() {
+        return instance;
+    }
+
+    public static Context applicationContext() {
+        return instance.getApplicationContext();
+    }
+
+    public static STActivity getCurrentActivity() {
+        return getInstance().getActivity();
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+        instance = this;
+        // Set up Crashlytics, disabled for debug builds
+        Crashlytics crashlyticsKit = new Crashlytics.Builder()
+                .core(new CrashlyticsCore.Builder().disabled(BuildConfig.DEBUG).build())
+                .build();
+
+        // Initialize Fabric with the debug-disabled crashlytics.
+        Fabric.with(this, crashlyticsKit);
+        STFirebase.subscribe();
+        FacebookSdk.sdkInitialize(getApplicationContext());
+        AppEventsLogger.activateApp(this);
+        Session.get().setNotificationId(0);
+    }
+
+    public void setActivity(STActivity activity) {
+        currentActivity = activity;
+    }
+
+    public STActivity getActivity() {
+        return currentActivity;
+    }
+
+    public static void newActivity(Class klass) {
+        getCurrentActivity().startActivity(new Intent(getCurrentActivity(), klass));
+    }
+
+    public static void newActivity(Intent i) {
+        getCurrentActivity().startActivity(i);
+    }
+
+    public static void newActivity(Class klass, Intent i) {
+        i.setComponent(new ComponentName(getCurrentActivity(), klass));
+        getCurrentActivity().startActivity(i);
+    }
+
+    public static LayoutInflater getLayoutInflater() {
+        return (LayoutInflater) getInstance().getSystemService(Context.LAYOUT_INFLATER_SERVICE);
+    }
+
+    public static View inflate(@LayoutRes int resource) {
+        return getLayoutInflater().inflate(resource, null);
+    }
+
+    public static boolean isActivityVisible() {
+        return activityVisible;
+    }
+
+    public static void activityResumed() {
+        activityVisible = true;
+        Session.get().startSession();
+    }
+
+    public static void activityPaused() {
+        activityVisible = false;
+        Session.get().pauseSession();
+    }
+
+    public static void promptLogin() {
+        newActivity(new Intent(STApplication.getCurrentActivity(), LoginActivity.class).putExtra(Utils.PROMPT, true));
+    }
+}

+package com.styleteq.app.models;
+
+import android.text.TextUtils;
+
+import com.styleteq.app.helpers.ImageHelper;
+import com.styleteq.app.mixpanel.MixPanelModel;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import org.json.JSONObject;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class Style extends Model implements Likeable, Mappable, MixPanelModel {
+    public int id;
+    public String name;
+    public List<Attachment> images;
+    public String description;
+
+    @JsonProperty("user")
+    public User owner;
+
+    @JsonProperty("tag_list")
+    public String[] tagList;
+
+    @JsonProperty("like_count")
+    public int likeCount;
+
+    @JsonProperty("comment_count")
+    public int commentCount;
+
+    @Override
+    public int likeCount() {
+        return likeCount;
+    }
+
+    @JsonProperty("primary_picture_url")
+    public String primaryPictureUrl;
+
+    @JsonProperty("user_id")
+    public long userId;
+
+    public float latitude;
+    public float longitude;
+
+    public String primaryPictureUrl(int style) {
+        return ImageHelper.getImageUrl(primaryPictureUrl, style);
+    }
+
+    @JsonProperty("images_attributes")
+    public List<ImageAttributes> imageAttributes;
+
+    @Override
+    public long id() {
+        return id;
+    }
+
+    public static Style createFromJsonString(String json) {
+        return createFromJsonString(json, Style.class);
+    }
+
+    public boolean is_liked;
+
+    @Override
+    public boolean isLiked() {
+        return is_liked;
+    }
+
+    @Override
+    public void setLiked(boolean liked) {
+        this.is_liked = liked;
+    }
+
+    @Override
+    public void setLikeCount(int count) {
+        this.likeCount = count;
+    }
+
+    public String tagHashString() {
+        if (tagList == null)
+            return null;
+
+        List<String> hash = new ArrayList<>();
+        for (String s : tagList) {
+            hash.add("#" + s);
+        }
+        return TextUtils.join(", ", hash);
+    }
+
+    @Override
+    public MapPosition mapPosition() {
+        MapPosition p = new MapPosition();
+        p.latitude = latitude;
+        p.longitude = longitude;
+        p.label = tagHashString();
+        return p;
+    }
+
+    @Override
+    public JSONObject mixpanelObject() {
+        return toJson();
+    }
+}

+module Queries
+  class Airline < Base
+    def define_fields
+      field :airline, Types::Airline do
+        description 'Get Airline'
+        argument :id, types.Int
+        resolve ->(obj, args, ctx) do
+          ::Airline.find_by(id: args.id)
+        end
+      end
+      field :airlines, Types::PaginatedCollection do
+        description 'Get Airlines'
+        argument :q, types.String
+        argument :page, types.Int
+        argument :per, types.Int
+        argument :sort, types.String
+        argument :includeInactive, types.Boolean
+        resolve ->(obj, args, ctx) do
+          Services::Airline::Search.run(args, ctx)
+        end
+      end
+    end
+  end
+end

+//
+//  ActivityFeedNavigationController.swift
+//  styleteqios
+//
+//  Created by Allejo Chris Velarde on 10/13/16.
+//  Copyright © 2016 Allejo Chris Velarde. All rights reserved.
+//
+
+import Foundation
+import UIKit
+
+class ActivityFeedNavigationController: UINavigationController, AuthenticatedController
+{
+    
+}
+
+extension ActivityFeedNavigationController: LoginControllerDelegate {
+    func didSuccessfulLogin() {
+        self.loadDefaultAuthenticatedView(nil)
+    }
+}

+//
+//  ActivityTableViewCell.swift
+//  styleteqios
+//
+//  Created by Alfonz Montelibano on 4/20/16.
+//  Copyright © 2016 Allejo Chris Velarde. All rights reserved.
+//
+
+import UIKit
+
+protocol ActivityTableViewCellDelegate {
+    func shouldRefreshCell(_ cell: ActivityTableViewCell)
+    
+    func pushController(_ viewController: UIViewController)
+    func shouldRedirectToProfile(_ username: String)
+    func didTapHashTag(_ hashtag: String)
+}
+
+class ActivityTableViewCell: UITableViewCell {
+
+    @IBOutlet weak var primaryImageHeight: NSLayoutConstraint!
+	@IBOutlet weak var activityUserImage: UIImageView!
+	@IBOutlet weak var activityImage: UIImageView!
+	@IBOutlet weak var activityUserNameLabel: UILabel!
+	@IBOutlet weak var activityDescriptionLabel: UILabel!
+	@IBOutlet weak var activityDateLabel: UILabel!
+    
+    @IBOutlet weak var numberOfLIkesUIView: UIView!
+    @IBOutlet weak var numberOfLikesUIButton: UIButton!
+    
+    var delegate: ActivityTableViewCellDelegate?
+    	
+	var activityItem: Activity?
+    var adjustedSize: CGSize?
+	
+    override func awakeFromNib() {
+        super.awakeFromNib()
+        self.activityDateLabel.isHidden = true
+    }
+    
+    override func prepareForReuse() {
+        self.resetCommonElements()
+        self.primaryImageHeight.constant = 0
+        
+    }
+	
+    func resetCommonElements()
+    {
+        self.activityUserImage.image = UIImage(named: "default-image")
+        self.activityDateLabel.text = ""
+        self.activityUserNameLabel.text = ""
+        self.activityDescriptionLabel.text = ""
+        
+    }
+    
+    func loadDefaultImage() {
+        
+        guard let targetImageView = self.activityImage else {
+            return
+        }
+        
+        let defaultImage = UIImage(named: "default-image-transparent")
+        targetImageView.image = defaultImage
+        targetImageView.contentMode = .scaleAspectFill
+        // set default size to square
+        self.primaryImageHeight.constant = UIScreen.main.bounds.size.width
+        
+    }
+	
+	
+	open func loadActivityItem(_ activityItem: Activity){
+		self.activityItem = activityItem
+		loadCommonDetails()
+        
+        if (self.activityItem as? NotificationEntity) != nil {
+            self.primaryImageHeight.constant = 0
+        }
+        
+        // display and update number of likes of a photo
+        if let activityType = self.activityItem?.activityType.rawValue {
+            switch activityType {
+                case "Style":
+                    let style = self.activityItem?.object as! Style
+                    self.updateLikesCountAndIcon(isLiked: style.isLikedByCurrentUser)
+                    self.numberOfLIkesUIView.isHidden = false
+                case "Special":
+                    return
+                default:
+                    self.numberOfLIkesUIView.isHidden = true
+            }
+            
+        }
+        
+        if activityItem.withImage {
+            
+            self.activityImage.contentMode = .scaleAspectFit
+            self.primaryImageHeight.constant = 0
+            WebImageHelper.instance.loadFromUrlString((self.activityItem?.imageUrl)!, imageView: self.activityImage) { (loadedImage) in
+                guard let targetImage = loadedImage else {
+                    return
+                }
+                
+                let adjustedSize = targetImage.getScreenAspectSize(UIScreen.main.bounds.size)
+                self.primaryImageHeight.constant = adjustedSize.height
+            }
+        }
+        else {
+            
+            self.loadDefaultImage()
+            
+            
+        }
+	}
+    
+    func loadCommonDetails() {
+        
+        let usernameTapRecognizer = UITapGestureRecognizer(target: self, action: #selector(self.presentUserProfile(tapGestureRecognizer:)))
+        let userImageTapRecognizer = UITapGestureRecognizer(target: self, action: #selector(self.presentUserProfile(tapGestureRecognizer:)))
+        
+        // Set activity details
+        self.activityUserNameLabel.text = self.activityItem?.getUserName()
+        self.activityUserNameLabel?.isUserInteractionEnabled = true
+        self.activityUserNameLabel.addGestureRecognizer(usernameTapRecognizer)
+        self.activityUserImage.backgroundColor = UIColor.white
+        
+        if let rawDescription = self.activityItem?.description, let rawDateString = self.activityItem?.getDate() {
+            let attributedDescription = NSMutableAttributedString(string: "\(rawDescription) ", attributes: [NSAttributedString.Key.font: UIFont.systemFont(ofSize: 12)])
+            attributedDescription.append(NSAttributedString(string: rawDateString, attributes: [NSAttributedString.Key.font: UIFont.italicSystemFont(ofSize: 10), NSAttributedString.Key.foregroundColor: UIColor.lightGray]))
+            self.activityDescriptionLabel.attributedText = attributedDescription            
+        }
+        else {
+            self.activityDescriptionLabel.text = ""
+        }
+        
+        
+        // Set the profile pic image of the user/owner of this activity
+        if let url = self.activityItem?.getUserImageUrl() {
+            if url.isEmpty == false {
+                WebImageHelper.instance.loadFromUrlString(url, imageView: self.activityUserImage) { _ in
+                    
+                    self.activityUserImage?.isUserInteractionEnabled = true
+                    self.activityUserImage.addGestureRecognizer(userImageTapRecognizer)
+                }
+            }
+        }
+        else {
+            self.activityUserImage.image = #imageLiteral(resourceName: "default-icon")
+            self.activityUserImage?.isUserInteractionEnabled = false
+            self.activityUserNameLabel?.isUserInteractionEnabled = false
+        }
+    }
+    
+    @objc func presentUserProfile(tapGestureRecognizer: UITapGestureRecognizer)
+    {
+        if let userId = self.activityItem?.getUserId() {
+            
+            self.activityUserNameLabel.isUserInteractionEnabled = false
+            self.activityUserImage.isUserInteractionEnabled = false
+                        
+            UserRepository.instance.findById(userId) { (user, error) in
+        
+                self.activityUserNameLabel.isUserInteractionEnabled = true
+                self.activityUserImage.isUserInteractionEnabled = true
+                
+                let storyboard = UIStoryboard(name: "Search", bundle: nil)
+                let controller = storyboard.instantiateViewController(withIdentifier: "SearchProfileDetailController") as! SearchProfileDetailController
+
+                controller.user = user
+                self.delegate?.pushController(controller)
+            }
+        }
+        
+    }
+    
+    @IBAction func pressLikeButton(_ sender: AnyObject) {
+        
+        let currentUser = UserRepository.instance.getCurrentLocalUser()
+        let style = self.activityItem?.object as! Style
+        
+        if !style.isLikedByCurrentUser {
+            currentUser.likeUpload(style) { result, error in
+                self.updateLikesCountAndIcon(isLiked: true)
+            }
+        } else {
+            currentUser.unlikeUpload(style) { result, error in
+                self.updateLikesCountAndIcon(isLiked: false)
+            }
+        }
+    }
+    
+    func updateLikesCountAndIcon(isLiked: Bool) {
+        
+        if isLiked == true {
+            self.numberOfLikesUIButton.setImage(UIImage(named: "fa-heart"), for: UIControl.State.normal)
+        } else {
+            self.numberOfLikesUIButton.setImage(UIImage(named: "fa-heart-o-white"), for: UIControl.State.normal)
+        }
+        
+       (self.activityItem?.object as! Style).getLikesCount() { count, error in
+            self.numberOfLikesUIButton.setTitle(" \(count) \( (count == 1) ? "Like" : "Likes")", for: UIControl.State.normal)
+        }
+    }
+  
+}
+
+
+

+//
+//  ActivityTableViewController.swift
+//  styleteqios
+//
+//  Created by Alfonz Montelibano on 5/10/16.
+//  Copyright © 2016 Allejo Chris Velarde. All rights reserved.
+//
+
+import UIKit
+
+// This is a parent class extended by MainActivityViewController (activity feeds screen)
+// and NotificationsTableViewController (notifications screen)
+
+class ActivityTableViewController: UIViewController, WithProcessIndicatorController {
+	
+	let activityTableViewCellIdentifier = "activityTableViewCell"
+	let specialActivityTableViewCellIdentifier = "specialActivityTableViewCell"
+	var activityItems: [Activity] = []
+    
+    var adjustedHeights: [Int:CGFloat] = [:]
+    
+	
+	// Used for pagination
+	var currentPage: Int = 0
+    var emptyCollectionLabel = UILabel()
+    var refreshControl: UIRefreshControl!
+	
+	// Process Indicator
+	var indicator = UIActivityIndicatorView()
+	var processIndicator: UIActivityIndicatorView {
+		get {
+			return self.indicator
+		}
+	}
+    
+    @IBOutlet weak var tableView: UITableView!
+	
+	override func viewWillAppear(_ animated: Bool) {
+		super.viewWillAppear(animated)
+        
+        self.clear()
+        self.refreshControl?.beginRefreshing()
+        self.fetchActivities()
+        
+        tableView.reloadData()
+	}
+    
+    
+	
+	override func viewDidLoad() {
+		super.viewDidLoad()
+        
+        
+		
+		self.view.backgroundColor = Theme.defaultBackgroundColor()
+		
+		self.registerCellNibs()
+		
+		self.tableView.tableFooterView = UIView()
+        self.tableView.tableHeaderView = UIView()
+        
+        self.emptyCollectionLabel = UILabel(frame: CGRect(x: 20, y: 0, width: self.view.bounds.width - 40, height: self.view.bounds.height))
+        self.emptyCollectionLabel.textAlignment = .center
+        self.emptyCollectionLabel.numberOfLines = 0
+        self.emptyCollectionLabel.isHidden = true
+        self.view.addSubview(self.emptyCollectionLabel)
+		
+		self.activityItems = [Activity]()
+		
+		self.initProcessIndicator(self.view)
+		
+        self.refreshControl = UIRefreshControl()
+		self.refreshControl?.addTarget(self, action: #selector(ActivityTableViewController.handleRefresh(_:)), for: UIControl.Event.valueChanged)
+		self.refreshControl?.tintColor = UIColor.lightGray
+        self.tableView.addSubview(self.refreshControl)
+		
+		
+	}
+    
+    func registerCellNibs()
+    {
+        self.tableView.register(UINib(nibName: "ActivityTableViewCell", bundle: nil), forCellReuseIdentifier: self.activityTableViewCellIdentifier)
+        self.tableView.register(UINib(nibName: "ActivitySpecialCellView", bundle: nil), forCellReuseIdentifier: self.specialActivityTableViewCellIdentifier)
+        self.tableView.register(UINib(nibName: "StyleActivityTableViewCell", bundle: nil), forCellReuseIdentifier: "styleActivityTableViewCell")
+    }
+    
+    func fetchActivities(){
+		
+	}
+	
+	@objc func handleRefresh(_ refreshControl: UIRefreshControl) {
+		self.clear()
+        self.fetchActivities()
+		
+	}
+    
+    func clear()
+    {
+        if nil != self.tableView {
+            self.activityItems.removeAll()
+            self.tableView.reloadData()
+            self.currentPage = 1
+        }
+    }
+	
+	
+}
+
+extension ActivityTableViewController: UITableViewDelegate, UITableViewDataSource
+{
+    // MARK: Table View Delegate Functions
+    
+    func tableView(_ tableView: UITableView, didSelectRowAt indexPath: IndexPath) {
+        
+        let activityItem = self.activityItems[indexPath.row]
+        
+        switch activityItem.activityType{
+        case .Style:
+            self.loadStylePublicView(activityItem.object as! Style)
+            break
+            
+        case .Special:
+            self.loadSpecialPublicView(activityItem.object as! Special)
+            break
+            
+        case .Booth:
+            self.loadBoothPublicView(activityItem.object as! Booth)
+            break
+            
+        case .User:
+            self.loadUserProfilePublicView(activityItem.object as! User)
+            break
+        case .Salon:
+            self.loadSalonPublicView(activityItem.object as! Salon)
+        case .Page:
+            self.loadPublicNotificationAnnouncementPage(activityItem.object as! NotificationAnnouncementPage)
+            break
+        case .Booking:
+            guard let booking = activityItem.object as? Booking else {
+                break
+            }            
+            self.loadBookingDetailView(booking)
+            break
+        default:
+            break
+        }
+    }
+    
+    func tableView(_ tableView: UITableView, willDisplay cell: UITableViewCell, forRowAt indexPath: IndexPath) {
+        if self.isLastIndexPath(indexPath) {
+            self.fetchActivities()
+        }
+    }
+    
+    
+    
+    
+    func isLastIndexPath(_ indexPath: IndexPath) -> Bool {
+        let lastSectionIndex = self.tableView.numberOfSections - 1
+        let lastItemIndex = self.tableView.numberOfRows(inSection: lastSectionIndex) - 1
+        
+        return (lastSectionIndex == indexPath.section && lastItemIndex == indexPath.row)
+    }
+    
+    func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell {
+        let activity = self.activityItems[indexPath.row]
+        
+        switch activity.activityType {
+        case .Special:
+            let cell = tableView.dequeueReusableCell(withIdentifier: self.specialActivityTableViewCellIdentifier) as! ActivitySpecialCellView
+            cell.loadActivityItem(activity)
+            cell.loadSpecial(activity.object as! Special)
+            cell.delegate = self
+            return cell
+            
+        case .Style:
+            let cell = tableView.dequeueReusableCell(withIdentifier: "styleActivityTableViewCell") as! StyleActivityTableViewCell
+            cell.loadActivityItem(activity)
+            cell.delegate = self
+            
+            return cell
+        default:
+            let cell = tableView.dequeueReusableCell(withIdentifier: activityTableViewCellIdentifier) as! ActivityTableViewCell
+            cell.loadActivityItem(activity)
+            cell.delegate = self
+            
+            return cell
+        }
+        
+        
+    }
+    
+    func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int {
+        return self.activityItems.count
+    }
+    
+    func tableView(_ tableView: UITableView, heightForRowAt indexPath: IndexPath) -> CGFloat {
+        let activity = self.activityItems[indexPath.row]
+        switch activity.activityType {
+        case .Special:
+            return 160
+        case .Style:
+            guard let preloadedSize = activity.carouselImageAspectSize, let itemStyle = activity.object as? Style else {
+                return UIScreen.main.bounds.size.width + 100
+            }
+            
+            let labelHeight = itemStyle.description.height(withConstrainedWidth: UIScreen.main.bounds.width, UIFont.systemFont(ofSize: 14))
+            
+            return preloadedSize.height + 64 + labelHeight
+        default:
+            
+            if (activity as? NotificationEntity) != nil {
+                return 80
+            }
+            
+            if activity.withImage == false {
+                return UIScreen.main.bounds.size.width + 100
+            }
+            else {
+                guard let preloadedSize = activity.carouselImageAspectSize else {
+                    return UIScreen.main.bounds.size.width + 100
+                }
+                
+                return preloadedSize.height + 64
+            }
+            
+        }
+        
+    }
+    
+    
+}
+
+extension ActivityTableViewController: ActivityTableViewCellDelegate {
+    func shouldRefreshCell(_ cell: ActivityTableViewCell) {
+    }
+    
+    func pushController(_ viewController: UIViewController) {
+        self.navigationController?.pushViewController(viewController, animated: true)
+    }
+    func shouldRedirectToProfile(_ username: String) {
+        UserRepository.instance.findByUsername(username) { (user, error) in
+            if let user = user {
+                self.loadUserProfilePublicView(user)
+            } else {
+                self.showAlert("Alert!", message: "User not found!", action: nil)
+            }
+        }
+    }
+    func didTapHashTag(_ hashtag: String) {
+        self.loadHashTagSearchResult(hashtag)
+    }
+
+}

+//
+//  MainActivityViewController.swift
+//  styleteqios
+//
+//  Created by Alfonz Montelibano on 4/20/16.
+//  Copyright © 2016 Allejo Chris Velarde. All rights reserved.
+//
+
+import UIKit
+
+class MainActivityViewController: ActivityTableViewController {
+	
+	// Fetch news feed activities. This func is called from ActivityTableViewController.updateList()
+	override func fetchActivities() {
+		
+        if currentPage == 0 {
+            return
+        }
+        
+		self.emptyCollectionLabel.text = "No Feeds Available. Follow a user or shop and get their latest updates."
+        self.startProcessIndicator()
+        ActivityRepository.instance.getActivityByUser(UserRepository.instance.getCurrentLocalUser(), params: ["page": self.currentPage as Any]) { (response, error) in
+            
+            self.stopProcessIndicator()
+            self.refreshControl!.endRefreshing()
+            
+            if error != nil {
+                self.showAlert("Ooops", message: "Unable to load your feeds right now.", action: nil)
+            }
+            else {
+                guard let pager = response else {
+                    return
+                }
+                self.currentPage = pager.nextPage
+                
+                for each in pager.collection as! [Activity] {
+                    self.activityItems.append(each)
+                    self.tableView.reloadData()
+                    
+                }
+            }
+
+            self.emptyCollectionLabel.isHidden = self.activityItems.isEmpty ? false : true
+            
+        }
+	}
+}
+
+extension MainActivityViewController: StyleFullViewDelegate {
+    func didUpdateStyle(_ style: Style) {
+        
+    }
+    
+    func didDeleteStyle(_ style: Style) {
+        self.activityItems = self.activityItems.filter { each in
+            
+            guard let asStyle = each.object as? Style else {
+                return true
+            }
+            
+            return (style.id == asStyle.id) ? false : true
+        }
+        self.tableView?.reloadData()
+    }
+}
+
+