mirror of
https://github.com/laurent22/joplin.git
synced 2024-12-12 08:54:00 +02:00
238 lines
7.6 KiB
JavaScript
238 lines
7.6 KiB
JavaScript
const shim = require('@joplin/lib/shim').default;
|
|
const { GeolocationReact } = require('./geolocation-react.js');
|
|
const PoorManIntervals = require('@joplin/lib/PoorManIntervals').default;
|
|
const RNFetchBlob = require('rn-fetch-blob').default;
|
|
const { generateSecureRandom } = require('react-native-securerandom');
|
|
const FsDriverRN = require('./fs-driver-rn').default;
|
|
const urlValidator = require('valid-url');
|
|
const { Buffer } = require('buffer');
|
|
const { Linking, Platform } = require('react-native');
|
|
const mimeUtils = require('@joplin/lib/mime-utils.js').mime;
|
|
const { basename, fileExtension } = require('@joplin/lib/path-utils');
|
|
const uuid = require('@joplin/lib/uuid').default;
|
|
const Resource = require('@joplin/lib/models/Resource').default;
|
|
|
|
const injectedJs = {
|
|
webviewLib: require('@joplin/lib/rnInjectedJs/webviewLib'),
|
|
};
|
|
|
|
function shimInit() {
|
|
shim.Geolocation = GeolocationReact;
|
|
shim.sjclModule = require('@joplin/lib/vendor/sjcl-rn.js');
|
|
|
|
shim.fsDriver = () => {
|
|
if (!shim.fsDriver_) shim.fsDriver_ = new FsDriverRN();
|
|
return shim.fsDriver_;
|
|
};
|
|
|
|
shim.randomBytes = async count => {
|
|
const randomBytes = await generateSecureRandom(count);
|
|
const temp = [];
|
|
for (const n in randomBytes) {
|
|
if (!randomBytes.hasOwnProperty(n)) continue;
|
|
temp.push(randomBytes[n]);
|
|
}
|
|
return temp;
|
|
};
|
|
|
|
shim.fetch = async function(url, options = null) {
|
|
// The native fetch() throws an uncatchable error that crashes the
|
|
// app if calling it with an invalid URL such as '//.resource' or
|
|
// "http://ocloud. de" so detect if the URL is valid beforehand and
|
|
// throw a catchable error. Bug:
|
|
// https://github.com/facebook/react-native/issues/7436
|
|
const validatedUrl = urlValidator.isUri(url);
|
|
if (!validatedUrl) throw new Error(`Not a valid URL: ${url}`);
|
|
|
|
return shim.fetchWithRetry(() => {
|
|
// If the request has a body and it's not a GET call, and it
|
|
// doesn't have a Content-Type header we display a warning,
|
|
// because it could trigger a "Network request failed" error.
|
|
// https://github.com/facebook/react-native/issues/30176
|
|
if (options?.body && options?.method && options.method !== 'GET' && !options?.headers?.['Content-Type']) {
|
|
console.warn('Done a non-GET fetch call without a Content-Type header. It may make the request fail.', url, options);
|
|
}
|
|
|
|
// Among React Native `fetch()` many bugs, one of them is that
|
|
// it will truncate strings when they contain binary data.
|
|
// Browser fetch() or Node fetch() work fine but as always RN's
|
|
// one doesn't. There's no obvious way to fix this so we'll
|
|
// have to wait if it's eventually fixed upstream. See here for
|
|
// more info:
|
|
// https://github.com/laurent22/joplin/issues/3986#issuecomment-718019688
|
|
|
|
return fetch(validatedUrl, options);
|
|
}, options);
|
|
};
|
|
|
|
shim.fetchBlob = async function(url, options) {
|
|
if (!options || !options.path) throw new Error('fetchBlob: target file path is missing');
|
|
|
|
const headers = options.headers ? options.headers : {};
|
|
const method = options.method ? options.method : 'GET';
|
|
const overwrite = 'overwrite' in options ? options.overwrite : true;
|
|
|
|
const dirs = RNFetchBlob.fs.dirs;
|
|
let localFilePath = options.path;
|
|
if (localFilePath.indexOf('/') !== 0) localFilePath = `${dirs.DocumentDir}/${localFilePath}`;
|
|
|
|
if (!overwrite) {
|
|
if (await shim.fsDriver().exists(localFilePath)) {
|
|
return { ok: true };
|
|
}
|
|
}
|
|
|
|
delete options.path;
|
|
delete options.overwrite;
|
|
|
|
const doFetchBlob = () => {
|
|
return RNFetchBlob.config({
|
|
path: localFilePath,
|
|
trusty: options.ignoreTlsErrors,
|
|
}).fetch(method, url, headers);
|
|
};
|
|
|
|
try {
|
|
const response = await shim.fetchWithRetry(doFetchBlob, options);
|
|
|
|
// Returns an object that's roughtly compatible with a standard Response object
|
|
const output = {
|
|
ok: response.respInfo.status < 400,
|
|
path: response.data,
|
|
status: response.respInfo.status,
|
|
headers: response.respInfo.headers,
|
|
// If response type is 'path' then calling text() or json() (or base64())
|
|
// on RNFetchBlob response object will make it read the file on the native thread,
|
|
// serialize it, and send over the RN bridge.
|
|
// For larger files this can cause the app to crash.
|
|
// For these type of responses we're not using the response text anyway
|
|
// so can override it here to return empty values
|
|
text: response.type === 'path' ? () => '' : response.text,
|
|
json: response.type === 'path' ? () => {} : response.json,
|
|
};
|
|
|
|
return output;
|
|
} catch (error) {
|
|
throw new Error(`fetchBlob: ${method} ${url}: ${error.toString()}`);
|
|
}
|
|
};
|
|
|
|
shim.uploadBlob = async function(url, options) {
|
|
if (!options || !options.path) throw new Error('uploadBlob: source file path is missing');
|
|
|
|
const headers = options.headers ? options.headers : {};
|
|
const method = options.method ? options.method : 'POST';
|
|
|
|
try {
|
|
const response = await RNFetchBlob.config({
|
|
trusty: options.ignoreTlsErrors,
|
|
}).fetch(method, url, headers, RNFetchBlob.wrap(options.path));
|
|
|
|
// Returns an object that's roughtly compatible with a standard Response object
|
|
return {
|
|
ok: response.respInfo.status < 400,
|
|
data: response.data,
|
|
text: response.text,
|
|
json: response.json,
|
|
status: response.respInfo.status,
|
|
headers: response.respInfo.headers,
|
|
};
|
|
} catch (error) {
|
|
throw new Error(`uploadBlob: ${method} ${url}: ${error.toString()}`);
|
|
}
|
|
};
|
|
|
|
shim.readLocalFileBase64 = async function(path) {
|
|
return RNFetchBlob.fs.readFile(path, 'base64');
|
|
};
|
|
|
|
shim.stringByteLength = function(string) {
|
|
return Buffer.byteLength(string, 'utf-8');
|
|
};
|
|
|
|
shim.Buffer = Buffer;
|
|
|
|
shim.openUrl = url => {
|
|
Linking.openURL(url);
|
|
};
|
|
|
|
shim.httpAgent = () => {
|
|
return null;
|
|
};
|
|
|
|
shim.waitForFrame = () => {
|
|
return new Promise(function(resolve) {
|
|
requestAnimationFrame(function() {
|
|
resolve();
|
|
});
|
|
});
|
|
};
|
|
|
|
shim.mobilePlatform = () => {
|
|
return Platform.OS;
|
|
};
|
|
|
|
shim.appVersion = () => {
|
|
const p = require('react-native-version-info').default;
|
|
return p.appVersion;
|
|
};
|
|
|
|
// NOTE: This is a limited version of createResourceFromPath - unlike the Node version, it
|
|
// only really works with images. It does not resize the image either.
|
|
shim.createResourceFromPath = async function(filePath, defaultProps = null) {
|
|
defaultProps = defaultProps ? defaultProps : {};
|
|
const resourceId = defaultProps.id ? defaultProps.id : uuid.create();
|
|
|
|
const ext = fileExtension(filePath);
|
|
let mimeType = mimeUtils.fromFileExtension(ext);
|
|
if (!mimeType) mimeType = 'image/jpeg';
|
|
|
|
let resource = Resource.new();
|
|
resource.id = resourceId;
|
|
resource.mime = mimeType;
|
|
resource.title = basename(filePath);
|
|
resource.file_extension = ext;
|
|
|
|
const targetPath = Resource.fullPath(resource);
|
|
await shim.fsDriver().copy(filePath, targetPath);
|
|
|
|
if (defaultProps) {
|
|
resource = Object.assign({}, resource, defaultProps);
|
|
}
|
|
|
|
const itDoes = await shim.fsDriver().waitTillExists(targetPath);
|
|
if (!itDoes) throw new Error(`Resource file was not created: ${targetPath}`);
|
|
|
|
const fileStat = await shim.fsDriver().stat(targetPath);
|
|
resource.size = fileStat.size;
|
|
|
|
resource = await Resource.save(resource, { isNew: true });
|
|
|
|
return resource;
|
|
};
|
|
|
|
shim.injectedJs = function(name) {
|
|
if (!(name in injectedJs)) throw new Error(`Cannot find injectedJs file (add it to "injectedJs" object): ${name}`);
|
|
return injectedJs[name];
|
|
};
|
|
|
|
shim.setTimeout = (fn, interval) => {
|
|
return PoorManIntervals.setTimeout(fn, interval);
|
|
};
|
|
|
|
shim.setInterval = (fn, interval) => {
|
|
return PoorManIntervals.setInterval(fn, interval);
|
|
};
|
|
|
|
shim.clearTimeout = (id) => {
|
|
return PoorManIntervals.clearTimeout(id);
|
|
};
|
|
|
|
shim.clearInterval = (id) => {
|
|
return PoorManIntervals.clearInterval(id);
|
|
};
|
|
|
|
}
|
|
|
|
module.exports = { shimInit };
|