refactor(redux): Switch to redux middleware & normalizr for Rest

App.js

@@ -62,7 +62,13 @@ class App extends Component {
       {
         storage: AsyncStorage,
         transforms: [encryptor],
-        blacklist: ['user'],
+        blacklist: [
+          'counters',
+          'entities',
+          'pagination',
+          'errorMessage',
+          'user',
+        ],
       },
       () => {
         this.setState({ rehydrated: true });

package.json

@@ -49,11 +49,12 @@
   "dependencies": {
     "entities": "^1.1.1",
     "fuzzysort": "^1.0.1",
-    "lodash.uniqby": "^4.7.0",
+    "lodash": "^4.17.4",
     "lowlight": "^1.5.0",
     "md5": "^2.2.1",
     "moment": "^2.17.1",
     "node-emoji": "^1.7.0",
+    "normalizr": "^3.2.3",
     "opencollective": "^1.0.3",
     "parse-diff": "^0.4.0",
     "query-string": "^4.3.1",

root.reducer.js

@@ -2,16 +2,25 @@ import { combineReducers } from 'redux';
 import { authReducer } from 'auth';
 import { userReducer } from 'user';
 import { repositoryReducer } from 'repository';
-import { organizationReducer } from 'organization';
 import { issueReducer } from 'issue';
 import { searchReducer } from 'search';
 import { notificationsReducer } from 'notifications';
 
+import {
+  entities,
+  counters,
+  pagination,
+  errorMessage,
+} from 'api/rest/reducers';
+
 export const rootReducer = combineReducers({
+  entities,
+  counters,
+  pagination,
+  errorMessage,
   auth: authReducer,
   user: userReducer,
   repository: repositoryReducer,
-  organization: organizationReducer,
   issue: issueReducer,
   search: searchReducer,
   notifications: notificationsReducer,

routes.js

@@ -18,9 +18,9 @@ import {
   LoginScreen,
   WelcomeScreen,
   AuthProfileScreen,
-  EventsScreen,
   PrivacyPolicyScreen,
   UserOptionsScreen,
+  EventsScreen,
 } from 'auth';
 
 // User
@@ -31,8 +31,10 @@ import {
   FollowingListScreen,
 } from 'user';
 
-// Organization
-import { OrganizationProfileScreen } from 'organization';
+import {
+  OrganizationRepositoryListScreen,
+  OrganizationProfileScreen,
+} from 'organization';
 
 // Search
 import { SearchScreen } from 'search';
@@ -61,6 +63,12 @@ import {
 } from 'issue';
 
 const sharedRoutes = {
+  OrgRepositoryList: {
+    screen: OrganizationRepositoryListScreen,
+    navigationOptions: ({ navigation }) => ({
+      title: navigation.state.params.title,
+    }),
+  },
   RepositoryList: {
     screen: RepositoryListScreen,
     navigationOptions: ({ navigation }) => ({

src/api/rest/actions/activity.js

@@ -0,0 +1,15 @@
+import { createActionSet } from 'utils';
+
+export const ACTIVITY_GET_EVENTS_RECEIVED = createActionSet(
+  'ACTIVITY_GET_EVENTS_RECEIVED'
+);
+export const ACTIVITY_GET_NOTIFICATIONS = createActionSet(
+  'ACTIVITY_GET_NOTIFICATIONS'
+);
+
+export const COUNT_ACTIVITY_GET_NOTIFICATIONS = createActionSet(
+  'COUNT_ACTIVITY_GET_NOTIFICATIONS'
+);
+export const ACTIVITY_MARK_NOTIFICATION_THREAD_AS_READ = createActionSet(
+  'ACTIVITY_MARK_NOTIFICATION_THREAD_AS_READ'
+);

src/api/rest/actions/index.js

@@ -0,0 +1,3 @@
+export * from './orgs';
+export * from './search';
+export * from './activity';

src/api/rest/actions/orgs.js

@@ -0,0 +1,5 @@
+import { createActionSet } from 'utils';
+
+export const ORGS_GET_BY_ID = createActionSet('ORGS_GET_BY_ID');
+export const ORGS_GET_REPOS = createActionSet('ORGS_GET_REPOS');
+export const ORGS_GET_MEMBERS = createActionSet('ORGS_GET_MEMBERS');

src/api/rest/actions/search.js

@@ -0,0 +1,3 @@
+import { createActionSet } from 'utils';
+
+export const SEARCH_GET_REPOS = createActionSet('SEARCH_GET_REPOS');

src/api/rest/providers/base/client.js

@@ -0,0 +1,60 @@
+export class Client {
+  Method = {
+    GET: 'GET',
+    HEAD: 'HEAD',
+    PUT: 'PUT',
+    DELETE: 'DELETE',
+    PATCH: 'PATCH',
+    POST: 'POST',
+  };
+
+  fetch = async (
+    url,
+    {
+      method = this.Method.GET,
+      schema = null,
+      normalizrKey = null,
+      headers = {},
+    },
+    params = {}
+  ) => {
+    let finalUrl;
+
+    if (params.url) {
+      // a different url was provided, use it instead (paginated)
+      finalUrl = params.url;
+    } else {
+      finalUrl = url;
+      // add explicitely specified parameters
+      if (params.per_page) {
+        finalUrl = `${finalUrl}${finalUrl.indexOf('?') !== -1
+          ? '&'
+          : '?'}per_page=${params.per_page}`;
+      }
+    }
+
+    if (finalUrl.indexOf(this.API_ROOT) === -1) {
+      finalUrl = `${this.API_ROOT}${finalUrl}`;
+    }
+
+    const parameters = {
+      method,
+      headers: {
+        'Cache-Control': 'no-cache',
+        ...this.authHeaders,
+        ...headers,
+      },
+    };
+
+    return fetch(finalUrl, parameters)
+      .then(response => {
+        // analyze headers for pagination, rates, etc
+        return {
+          response,
+          schema,
+          normalizrKey,
+        };
+      })
+      .catch(error => error);
+  };
+}

src/api/rest/providers/base/index.js

@@ -0,0 +1 @@
+export * from './client';

src/api/rest/providers/github/client.js

@@ -0,0 +1,170 @@
+import { Client } from '../base';
+import Schemas from './schemas';
+
+export class GitHub extends Client {
+  API_ROOT = 'https://api.github.com/';
+
+  setAuthHeaders = token => {
+    this.authHeaders = { Authorization: `token ${token}` };
+  };
+
+  getNextPageUrl = response => {
+    const link = response.headers.get('link');
+
+    if (!link) {
+      return null;
+    }
+
+    const nextLink = link.split(',').find(s => s.indexOf('rel="next"') > -1);
+
+    if (!nextLink) {
+      return null;
+    }
+
+    return nextLink.split(';')[0].slice(1, -1);
+  };
+
+  /**
+   * The organizations endpoint
+   */
+  orgs = {
+    /**
+     * Gets an organization by its id
+     *
+     * @param {string} orgId
+     */
+    getById: async (orgId, params) => {
+      return this.fetch(
+        `orgs/${orgId}`,
+        {
+          schema: Schemas.ORG,
+        },
+        params
+      ).then(struct => struct);
+    },
+    /**
+     * Gets organization members
+     *
+     * @param {string} orgId
+     */
+    getMembers: async (orgId, params) => {
+      return this.fetch(
+        `orgs/${orgId}/members`,
+        {
+          schema: Schemas.USER_ARRAY,
+        },
+        params
+      ).then(struct => {
+        return {
+          ...struct,
+          nextPageUrl: this.getNextPageUrl(struct.response),
+        };
+      });
+    },
+    /**
+     * Gets organization members
+     *
+     * @param {string} orgId
+     */
+    getRepos: async (orgId, params) => {
+      return this.fetch(
+        `orgs/${orgId}/repos`,
+        {
+          schema: Schemas.REPO_ARRAY,
+        },
+        params
+      ).then(struct => {
+        return {
+          ...struct,
+          nextPageUrl: this.getNextPageUrl(struct.response),
+        };
+      });
+    },
+  };
+
+  /**
+   * The activity endpoint
+   */
+  activity = {
+    /**
+     * Gets received events
+     *
+     * @param {string} userId
+     */
+    getEventsReceived: async (userId, params) => {
+      return this.fetch(
+        `users/${userId}/received_events`,
+        {
+          schema: Schemas.EVENT_ARRAY,
+        },
+        params
+      ).then(struct => {
+        return {
+          ...struct,
+          nextPageUrl: this.getNextPageUrl(struct.response),
+        };
+      });
+    },
+    /**
+     * Get all notifications for the current user
+     *
+     * @param {boolean} all If true, show notifications marked as read.
+     * @param {boolean} participating If true, in which the user is directly participating or mentioned.
+     */
+    getNotifications: async (all, participating, params) => {
+      const finalParams = {
+        per_page: 100,
+        ...params,
+      };
+
+      return this.fetch(
+        `notifications?all=${all}&participating=${participating}`,
+        {
+          schema: Schemas.NOTIFICATION_ARRAY,
+        },
+        finalParams
+      ).then(struct => {
+        return {
+          ...struct,
+          nextPageUrl: this.getNextPageUrl(struct.response),
+        };
+      });
+    },
+    markNotificationThreadAsRead: async (id, params) => {
+      return this.fetch(
+        `notifications/threads/${id}`,
+        {
+          method: this.Method.PATCH,
+        },
+        params
+      ).then(struct => {
+        return {
+          ...struct,
+        };
+      });
+    },
+  };
+
+  search = {
+    /**
+     * Search repositories
+     *
+     * @param {string} query
+     */
+    getRepos: async (query, params) => {
+      return this.fetch(
+        `search/repositories?${query}`,
+        {
+          schema: Schemas.REPO_ARRAY,
+          normalizrKey: 'items',
+        },
+        params
+      ).then(struct => {
+        return {
+          ...struct,
+          nextPageUrl: this.getNextPageUrl(struct.response),
+        };
+      });
+    },
+  };
+}

src/api/rest/providers/github/index.js

@@ -0,0 +1 @@
+export * from './client';

src/api/rest/providers/github/schemas/events.js

@@ -0,0 +1,32 @@
+import { schema } from 'normalizr';
+import { initSchema, toTimestamp } from 'utils';
+
+import { userSchema } from './users';
+import { orgSchema } from './orgs';
+import { repoSchema } from './repos';
+
+export const eventSchema = new schema.Entity(
+  'events',
+  {
+    actor: userSchema,
+    org: orgSchema,
+    repo: repoSchema,
+  },
+  {
+    idAttribute: event => event.id,
+    processStrategy: entity => {
+      const processed = initSchema();
+
+      processed.id = entity.id;
+      processed.type = entity.type; // TODO: needs to be normalized in an Enum
+      processed.payload = entity.payload; // TODO: needs to be inspected for more nested entities (forkee)
+      processed.createdAt = toTimestamp(entity.created_at);
+
+      processed.actor = entity.actor;
+      processed.org = entity.org;
+      processed.repo = entity.repo;
+
+      return processed;
+    },
+  }
+);