chore: Remove unused files
This commit is contained in:
Bouncey
committed by
mrugesh mohapatra
mrugesh mohapatra
parent
6e9fbd7219
commit
010fa63e76
@ -1,314 +0,0 @@
|
||||
/*
|
||||
* Copyright (c) Microsoft Open Technologies, Inc. All rights reserved.
|
||||
* Microsoft Open Technologies would like to thank its contributors, a list
|
||||
* of whom are at http://rx.codeplex.com/wikipage?title=Contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you
|
||||
* may not use this file except in compliance with the License. You may
|
||||
* obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
|
||||
* implied. See the License for the specific language governing permissions
|
||||
* and limitations under the License.
|
||||
*/
|
||||
|
||||
import debugFactory from 'debug';
|
||||
import { Observable, AnonymousObservable, helpers } from 'rx';
|
||||
|
||||
const debug = debugFactory('fcc:ajax$');
|
||||
const root = typeof window !== 'undefined' ? window : {};
|
||||
|
||||
// Gets the proper XMLHttpRequest for support for older IE
|
||||
function getXMLHttpRequest() {
|
||||
if (root.XMLHttpRequest) {
|
||||
return new root.XMLHttpRequest();
|
||||
} else {
|
||||
var progId;
|
||||
try {
|
||||
var progIds = [
|
||||
'Msxml2.XMLHTTP',
|
||||
'Microsoft.XMLHTTP',
|
||||
'Msxml2.XMLHTTP.4.0'
|
||||
];
|
||||
for (var i = 0; i < 3; i++) {
|
||||
try {
|
||||
progId = progIds[i];
|
||||
if (new root.ActiveXObject(progId)) {
|
||||
break;
|
||||
}
|
||||
} catch (e) {
|
||||
// purposely do nothing
|
||||
helpers.noop(e);
|
||||
}
|
||||
}
|
||||
return new root.ActiveXObject(progId);
|
||||
} catch (e) {
|
||||
throw new Error('XMLHttpRequest is not supported by your browser');
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Get CORS support even for older IE
|
||||
function getCORSRequest() {
|
||||
var xhr = new root.XMLHttpRequest();
|
||||
if ('withCredentials' in xhr) {
|
||||
return xhr;
|
||||
} else if (root.XDomainRequest) {
|
||||
return new XDomainRequest();
|
||||
} else {
|
||||
throw new Error('CORS is not supported by your browser');
|
||||
}
|
||||
}
|
||||
|
||||
function parseXhrResponse(responseType, xhr) {
|
||||
switch (responseType) {
|
||||
case 'json':
|
||||
if ('response' in xhr) {
|
||||
return xhr.responseType ?
|
||||
xhr.response :
|
||||
JSON.parse(xhr.response || xhr.responseText || 'null');
|
||||
} else {
|
||||
return JSON.parse(xhr.responseText || 'null');
|
||||
}
|
||||
case 'xml':
|
||||
return xhr.responseXML;
|
||||
case 'text':
|
||||
default:
|
||||
return ('response' in xhr) ? xhr.response : xhr.responseText;
|
||||
}
|
||||
}
|
||||
|
||||
function normalizeAjaxSuccessEvent(e, xhr, settings) {
|
||||
return {
|
||||
response: parseXhrResponse(settings.responseType || xhr.responseType, xhr),
|
||||
status: xhr.status,
|
||||
responseType: xhr.responseType,
|
||||
xhr: xhr,
|
||||
originalEvent: e
|
||||
};
|
||||
}
|
||||
|
||||
function normalizeAjaxErrorEvent(e, xhr, type) {
|
||||
return {
|
||||
type: type,
|
||||
status: xhr.status,
|
||||
xhr: xhr,
|
||||
originalEvent: e
|
||||
};
|
||||
}
|
||||
|
||||
/*
|
||||
* Creates an observable for an Ajax request with either a settings object
|
||||
* with url, headers, etc or a string for a URL.
|
||||
*
|
||||
* @example
|
||||
* source = Rx.DOM.ajax('/products');
|
||||
* source = Rx.DOM.ajax( url: 'products', method: 'GET' });
|
||||
*
|
||||
* interface Options {
|
||||
* url: String, // URL of the request
|
||||
* body?: Object, // The body of the request
|
||||
* method? = 'GET' : 'GET' | 'POST' | 'PUT' | 'PATCH' | 'DELETE',
|
||||
* async? = true: Boolean, // Whether the request is async
|
||||
* headers?: Object, // optional headers
|
||||
* crossDomain?: true // if a cross domain request, else false
|
||||
* }
|
||||
*
|
||||
* ajax$(url?: String, options: Options) => Observable[XMLHttpRequest]
|
||||
*/
|
||||
export function ajax$(options) {
|
||||
var settings = {
|
||||
method: 'GET',
|
||||
crossDomain: false,
|
||||
async: true,
|
||||
headers: {},
|
||||
responseType: 'text',
|
||||
createXHR: function() {
|
||||
return this.crossDomain ? getCORSRequest() : getXMLHttpRequest();
|
||||
},
|
||||
normalizeError: normalizeAjaxErrorEvent,
|
||||
normalizeSuccess: normalizeAjaxSuccessEvent
|
||||
};
|
||||
|
||||
if (typeof options === 'string') {
|
||||
settings.url = options;
|
||||
} else {
|
||||
for (var prop in options) {
|
||||
if (hasOwnProperty.call(options, prop)) {
|
||||
settings[prop] = options[prop];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
var normalizeError = settings.normalizeError;
|
||||
var normalizeSuccess = settings.normalizeSuccess;
|
||||
|
||||
if (!settings.crossDomain && !settings.headers['X-Requested-With']) {
|
||||
settings.headers['X-Requested-With'] = 'XMLHttpRequest';
|
||||
}
|
||||
settings.hasContent = typeof settings.body !== 'undefined';
|
||||
|
||||
return new AnonymousObservable(function(observer) {
|
||||
var isDone = false;
|
||||
var xhr;
|
||||
|
||||
var processResponse = function(xhr, e) {
|
||||
var status = xhr.status === 1223 ? 204 : xhr.status;
|
||||
if ((status >= 200 && status <= 300) || status === 0 || status === '') {
|
||||
try {
|
||||
observer.onNext(normalizeSuccess(e, xhr, settings));
|
||||
observer.onCompleted();
|
||||
} catch (err) {
|
||||
observer.onError(err);
|
||||
}
|
||||
} else {
|
||||
observer.onError(normalizeError(e, xhr, 'error'));
|
||||
}
|
||||
isDone = true;
|
||||
};
|
||||
|
||||
try {
|
||||
xhr = settings.createXHR();
|
||||
} catch (err) {
|
||||
observer.onError(err);
|
||||
}
|
||||
|
||||
try {
|
||||
if (settings.user) {
|
||||
xhr.open(
|
||||
settings.method,
|
||||
settings.url,
|
||||
settings.async,
|
||||
settings.user,
|
||||
settings.password
|
||||
);
|
||||
} else {
|
||||
xhr.open(settings.method, settings.url, settings.async);
|
||||
}
|
||||
|
||||
var headers = settings.headers;
|
||||
for (var header in headers) {
|
||||
if (hasOwnProperty.call(headers, header)) {
|
||||
xhr.setRequestHeader(header, headers[header]);
|
||||
}
|
||||
}
|
||||
|
||||
if (
|
||||
!xhr.upload ||
|
||||
(!('withCredentials' in xhr) && root.XDomainRequest)
|
||||
) {
|
||||
xhr.onload = function(e) {
|
||||
if (settings.progressObserver) {
|
||||
settings.progressObserver.onNext(e);
|
||||
settings.progressObserver.onCompleted();
|
||||
}
|
||||
processResponse(xhr, e);
|
||||
};
|
||||
|
||||
if (settings.progressObserver) {
|
||||
xhr.onprogress = function(e) {
|
||||
settings.progressObserver.onNext(e);
|
||||
};
|
||||
}
|
||||
|
||||
xhr.onerror = function(e) {
|
||||
if (settings.progressObserver) {
|
||||
settings.progressObserver.onError(e);
|
||||
}
|
||||
observer.onError(normalizeError(e, xhr, 'error'));
|
||||
isDone = true;
|
||||
};
|
||||
|
||||
xhr.onabort = function(e) {
|
||||
if (settings.progressObserver) {
|
||||
settings.progressObserver.onError(e);
|
||||
}
|
||||
observer.onError(normalizeError(e, xhr, 'abort'));
|
||||
isDone = true;
|
||||
};
|
||||
} else {
|
||||
|
||||
xhr.onreadystatechange = function(e) {
|
||||
if (xhr.readyState === 4) {
|
||||
processResponse(xhr, e);
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
debug(
|
||||
'ajax$ sending content',
|
||||
settings.hasContent && settings.body
|
||||
);
|
||||
xhr.send(settings.hasContent && settings.body || null);
|
||||
} catch (err) {
|
||||
observer.onError(err);
|
||||
}
|
||||
|
||||
return function() {
|
||||
if (!isDone && xhr.readyState !== 4) { xhr.abort(); }
|
||||
};
|
||||
});
|
||||
}
|
||||
|
||||
// Creates an observable sequence from an Ajax POST Request with the body.
|
||||
// post$(url: String, body: Object) => Observable[Any]
|
||||
export function post$(url, body) {
|
||||
try {
|
||||
body = JSON.stringify(body);
|
||||
} catch (e) {
|
||||
return Observable.throw(e);
|
||||
}
|
||||
|
||||
return ajax$({ url, body, method: 'POST' });
|
||||
}
|
||||
|
||||
// postJSON$(url: String, body: Object) => Observable[Object]
|
||||
export function postJSON$(url, body) {
|
||||
try {
|
||||
body = JSON.stringify(body);
|
||||
} catch (e) {
|
||||
return Observable.throw(e);
|
||||
}
|
||||
|
||||
return ajax$({
|
||||
url,
|
||||
body,
|
||||
method: 'POST',
|
||||
responseType: 'json',
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
Accept: 'application/json'
|
||||
},
|
||||
normalizeError: (e, xhr) => parseXhrResponse('json', xhr)
|
||||
})
|
||||
.map(({ response }) => response);
|
||||
}
|
||||
|
||||
// Creates an observable sequence from an Ajax GET Request with the body.
|
||||
// get$(url: String) => Obserable[Any]
|
||||
export function get$(url) {
|
||||
return ajax$({ url: url });
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates an observable sequence from JSON from an Ajax request
|
||||
*
|
||||
* @param {String} url The URL to GET
|
||||
* @returns {Observable} The observable sequence which contains the parsed JSON
|
||||
*/
|
||||
// getJSON$(url: String) => Observable[Object];
|
||||
export function getJSON$(url) {
|
||||
return ajax$({
|
||||
url: url,
|
||||
responseType: 'json',
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
Accept: 'application/json'
|
||||
},
|
||||
normalizeError: (e, xhr) => parseXhrResponse('json', xhr)
|
||||
}).map(({ response }) => response);
|
||||
}
|
||||
@ -1,118 +0,0 @@
|
||||
import debug from 'debug';
|
||||
// import { renderToString } from 'react-dom/server';
|
||||
// import createMemoryHistory from 'history/createMemoryHistory';
|
||||
// import { NOT_FOUND } from 'redux-first-router';
|
||||
// import devtoolsEnhancer from 'remote-redux-devtools';
|
||||
|
||||
// import {
|
||||
// errorThrowerMiddleware
|
||||
// } from '../utils/react.js';
|
||||
// import { createApp, provideStore, App } from '../../common/app';
|
||||
// import waitForEpics from '../../common/utils/wait-for-epics.js';
|
||||
// import { titleSelector } from '../../common/app/redux';
|
||||
|
||||
const log = debug('fcc:react-server');
|
||||
// const isDev = process.env.NODE_ENV !== 'production';
|
||||
|
||||
// // add routes here as they slowly get reactified
|
||||
// // remove their individual controllers
|
||||
// const routes = [
|
||||
// '/settings',
|
||||
// '/settings/*',
|
||||
// '/:username'
|
||||
// ];
|
||||
|
||||
// const devRoutes = [];
|
||||
|
||||
// const middlewares = isDev ? [errorThrowerMiddleware] : [];
|
||||
|
||||
// const markupMap = {};
|
||||
|
||||
export default function reactSubRouter(app) {
|
||||
// var router = app.loopback.Router();
|
||||
|
||||
// router.get('/videos', (req, res) => res.redirect('/map'));
|
||||
// router.get(
|
||||
// '/videos/:dashedName',
|
||||
// (req, res) => res.redirect(`/challenges/${req.params.dashedName}`)
|
||||
// );
|
||||
|
||||
// router.get(
|
||||
// '/portfolio/:redirectUsername',
|
||||
// (req, res) => res.redirect(`/${req.params.redirectUsername}`)
|
||||
// );
|
||||
|
||||
// // These routes are in production
|
||||
// routes.forEach((route) => {
|
||||
// router.get(route, serveReactApp);
|
||||
// });
|
||||
|
||||
// if (process.env.NODE_ENV === 'development') {
|
||||
// devRoutes.forEach(function(route) {
|
||||
// router.get(route, serveReactApp);
|
||||
// });
|
||||
// }
|
||||
|
||||
// app.use(router);
|
||||
|
||||
// function serveReactApp(req, res, next) {
|
||||
// const serviceOptions = { req };
|
||||
// if (req.originalUrl in markupMap) {
|
||||
// log('sending markup from cache');
|
||||
// const { state, title, markup } = markupMap[req.originalUrl];
|
||||
// res.expose(state, 'data', { isJSON: true });
|
||||
// // note(berks): we render without express-flash dumping our messages
|
||||
// // the app will query for these on load
|
||||
// return res.renderWithoutFlash('layout-react', { markup, title });
|
||||
// }
|
||||
// return createApp({
|
||||
// serviceOptions,
|
||||
// middlewares,
|
||||
// enhancers: [
|
||||
// devtoolsEnhancer({ name: 'server' })
|
||||
// ],
|
||||
// history: createMemoryHistory({ initialEntries: [ req.originalUrl ] }),
|
||||
// defaultState: {}
|
||||
// })
|
||||
// .filter(({
|
||||
// location: {
|
||||
// type,
|
||||
// kind,
|
||||
// pathname
|
||||
// } = {}
|
||||
// }) => {
|
||||
// if (kind === 'redirect') {
|
||||
// log('react found a redirect');
|
||||
// res.redirect(pathname);
|
||||
// return false;
|
||||
// }
|
||||
|
||||
// if (type === NOT_FOUND) {
|
||||
// log(`react tried to find ${req.path} but got 404`);
|
||||
// next();
|
||||
// return false;
|
||||
// }
|
||||
|
||||
// return true;
|
||||
// })
|
||||
// .flatMap(({ store, epic }) => {
|
||||
// return waitForEpics(epic)
|
||||
// .map(() => renderToString(
|
||||
// provideStore(App, store)
|
||||
// ))
|
||||
// .map((markup) => ({ markup, store, epic }));
|
||||
// })
|
||||
// .do(({ markup, store, epic }) => {
|
||||
// log('react markup rendered, data fetched');
|
||||
// const state = store.getState();
|
||||
// const title = titleSelector(state);
|
||||
// epic.dispose();
|
||||
// res.expose(state, 'data', { isJSON: true });
|
||||
// // note(berks): we render without express-flash dumping our messages
|
||||
// // the app will query for these on load
|
||||
// res.renderWithoutFlash('layout-react', { markup, title });
|
||||
// markupMap[req.originalUrl] = { markup, state, title };
|
||||
// })
|
||||
// .subscribe(() => log('html rendered and sent'), next);
|
||||
// }
|
||||
}
|
||||
Reference in New Issue
Block a user