706 lines
18 KiB
JavaScript
706 lines
18 KiB
JavaScript
/* eslint no-eq-null: 0, eqeqeq: [2, "smart"] */
|
|
/* global createCache db calcStyleDigest db tryRegExp styleCodeEmpty styleSectionGlobal
|
|
getStyleWithNoCode msg sync uuidv4 URLS */
|
|
/* exported styleManager */
|
|
'use strict';
|
|
|
|
/*
|
|
This style manager is a layer between content script and the DB. When a style
|
|
is added/updated, it broadcast a message to content script and the content
|
|
script would try to fetch the new code.
|
|
|
|
The live preview feature relies on `runtime.connect` and `port.onDisconnect`
|
|
to cleanup the temporary code. See /edit/live-preview.js.
|
|
*/
|
|
const styleManager = (() => {
|
|
const preparing = prepare();
|
|
|
|
/* styleId => {
|
|
data: styleData,
|
|
preview: styleData,
|
|
appliesTo: Set<url>
|
|
} */
|
|
const styles = new Map();
|
|
const uuidIndex = new Map();
|
|
|
|
/* url => {
|
|
maybeMatch: Set<styleId>,
|
|
sections: Object<styleId => {
|
|
id: styleId,
|
|
code: Array<String>
|
|
}>
|
|
} */
|
|
const cachedStyleForUrl = createCache({
|
|
onDeleted: (url, cache) => {
|
|
for (const section of Object.values(cache.sections)) {
|
|
const style = styles.get(section.id);
|
|
if (style) {
|
|
style.appliesTo.delete(url);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
|
|
const BAD_MATCHER = {test: () => false};
|
|
const compileRe = createCompiler(text => `^(${text})$`);
|
|
const compileSloppyRe = createCompiler(text => `^${text}$`);
|
|
const compileExclusion = createCompiler(buildExclusion);
|
|
|
|
const DUMMY_URL = {
|
|
hash: '',
|
|
host: '',
|
|
hostname: '',
|
|
href: '',
|
|
origin: '',
|
|
password: '',
|
|
pathname: '',
|
|
port: '',
|
|
protocol: '',
|
|
search: '',
|
|
searchParams: new URLSearchParams(),
|
|
username: ''
|
|
};
|
|
|
|
handleLivePreviewConnections();
|
|
|
|
return Object.assign({
|
|
compareRevision
|
|
}, ensurePrepared({
|
|
get,
|
|
getByUUID,
|
|
getSectionsByUrl,
|
|
putByUUID,
|
|
installStyle,
|
|
deleteStyle,
|
|
deleteByUUID,
|
|
editSave,
|
|
findStyle,
|
|
importStyle,
|
|
importMany,
|
|
toggleStyle,
|
|
getAllStyles, // used by import-export
|
|
getStylesByUrl, // used by popup
|
|
styleExists,
|
|
addExclusion,
|
|
removeExclusion,
|
|
addInclusion,
|
|
removeInclusion
|
|
}));
|
|
|
|
function handleLivePreviewConnections() {
|
|
chrome.runtime.onConnect.addListener(port => {
|
|
if (port.name !== 'livePreview') {
|
|
return;
|
|
}
|
|
let id;
|
|
port.onMessage.addListener(data => {
|
|
if (!id) {
|
|
id = data.id;
|
|
}
|
|
const style = styles.get(id);
|
|
style.preview = data;
|
|
broadcastStyleUpdated(style.preview, 'editPreview');
|
|
});
|
|
port.onDisconnect.addListener(() => {
|
|
port = null;
|
|
if (id) {
|
|
const style = styles.get(id);
|
|
if (!style) {
|
|
// maybe deleted
|
|
return;
|
|
}
|
|
style.preview = null;
|
|
broadcastStyleUpdated(style.data, 'editPreviewEnd');
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
function escapeRegExp(text) {
|
|
// https://github.com/lodash/lodash/blob/0843bd46ef805dd03c0c8d804630804f3ba0ca3c/lodash.js#L152
|
|
return text.replace(/[\\^$.*+?()[\]{}|]/g, '\\$&');
|
|
}
|
|
|
|
function get(id, noCode = false) {
|
|
const data = styles.get(id).data;
|
|
return noCode ? getStyleWithNoCode(data) : data;
|
|
}
|
|
|
|
function getByUUID(uuid) {
|
|
const id = uuidIndex.get(uuid);
|
|
if (id) {
|
|
return get(id);
|
|
}
|
|
}
|
|
|
|
function getAllStyles(noCode = false) {
|
|
const datas = [...styles.values()].map(s => s.data);
|
|
return noCode ? datas.map(getStyleWithNoCode) : datas;
|
|
}
|
|
|
|
function compareRevision(rev1, rev2) {
|
|
return rev1 - rev2;
|
|
}
|
|
|
|
function putByUUID(doc) {
|
|
const id = uuidIndex.get(doc._id);
|
|
if (id) {
|
|
doc.id = id;
|
|
} else {
|
|
delete doc.id;
|
|
}
|
|
const oldDoc = id && styles.has(id) && styles.get(id).data;
|
|
let diff = -1;
|
|
if (oldDoc) {
|
|
diff = compareRevision(oldDoc._rev, doc._rev);
|
|
if (diff > 0) {
|
|
sync.put(oldDoc._id, oldDoc._rev);
|
|
return;
|
|
}
|
|
}
|
|
if (diff < 0) {
|
|
return db.exec('put', doc)
|
|
.then(event => {
|
|
doc.id = event.target.result;
|
|
uuidIndex.set(doc._id, doc.id);
|
|
return handleSave(doc, 'sync');
|
|
});
|
|
}
|
|
}
|
|
|
|
function toggleStyle(id, enabled) {
|
|
const style = styles.get(id);
|
|
const data = Object.assign({}, style.data, {enabled});
|
|
return saveStyle(data)
|
|
.then(newData => handleSave(newData, 'toggle', false))
|
|
.then(() => id);
|
|
}
|
|
|
|
// used by install-hook-userstyles.js
|
|
function findStyle(filter, noCode = false) {
|
|
for (const style of styles.values()) {
|
|
if (filterMatch(filter, style.data)) {
|
|
return noCode ? getStyleWithNoCode(style.data) : style.data;
|
|
}
|
|
}
|
|
return null;
|
|
}
|
|
|
|
function styleExists(filter) {
|
|
return [...styles.values()].some(s => filterMatch(filter, s.data));
|
|
}
|
|
|
|
function filterMatch(filter, target) {
|
|
for (const key of Object.keys(filter)) {
|
|
if (filter[key] !== target[key]) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function importStyle(data) {
|
|
// FIXME: is it a good idea to save the data directly?
|
|
return saveStyle(data)
|
|
.then(newData => handleSave(newData, 'import'));
|
|
}
|
|
|
|
function importMany(items) {
|
|
items.forEach(beforeSave);
|
|
return db.exec('putMany', items)
|
|
.then(events => {
|
|
for (let i = 0; i < items.length; i++) {
|
|
afterSave(items[i], events[i].target.result);
|
|
}
|
|
return Promise.all(items.map(i => handleSave(i, 'import')));
|
|
});
|
|
}
|
|
|
|
function installStyle(data, reason = null) {
|
|
const style = styles.get(data.id);
|
|
if (!style) {
|
|
data = Object.assign(createNewStyle(), data);
|
|
} else {
|
|
data = Object.assign({}, style.data, data);
|
|
}
|
|
if (!reason) {
|
|
reason = style ? 'update' : 'install';
|
|
}
|
|
let url = !data.url && data.updateUrl;
|
|
if (url) {
|
|
const usoId = URLS.extractUsoArchiveId(url);
|
|
url = usoId && `${URLS.usoArchive}?style=${usoId}` ||
|
|
URLS.extractGreasyForkId(url) && url.match(/^.*?\/\d+/)[0];
|
|
if (url) data.url = data.installationUrl = url;
|
|
}
|
|
// FIXME: update updateDate? what about usercss config?
|
|
return calcStyleDigest(data)
|
|
.then(digest => {
|
|
data.originalDigest = digest;
|
|
return saveStyle(data);
|
|
})
|
|
.then(newData => handleSave(newData, reason));
|
|
}
|
|
|
|
function editSave(data) {
|
|
const style = styles.get(data.id);
|
|
if (style) {
|
|
data = Object.assign({}, style.data, data);
|
|
} else {
|
|
data = Object.assign(createNewStyle(), data);
|
|
}
|
|
data.updateDate = Date.now();
|
|
return saveStyle(data)
|
|
.then(newData => handleSave(newData, 'editSave'));
|
|
}
|
|
|
|
function addIncludeExclude(id, rule, type) {
|
|
const data = Object.assign({}, styles.get(id).data);
|
|
if (!data[type]) {
|
|
data[type] = [];
|
|
}
|
|
if (data[type].includes(rule)) {
|
|
throw new Error('The rule already exists');
|
|
}
|
|
data[type] = data[type].concat([rule]);
|
|
return saveStyle(data)
|
|
.then(newData => handleSave(newData, 'styleSettings'));
|
|
}
|
|
|
|
function removeIncludeExclude(id, rule, type) {
|
|
const data = Object.assign({}, styles.get(id).data);
|
|
if (!data[type]) {
|
|
return;
|
|
}
|
|
if (!data[type].includes(rule)) {
|
|
return;
|
|
}
|
|
data[type] = data[type].filter(r => r !== rule);
|
|
return saveStyle(data)
|
|
.then(newData => handleSave(newData, 'styleSettings'));
|
|
}
|
|
|
|
function addExclusion(id, rule) {
|
|
return addIncludeExclude(id, rule, 'exclusions');
|
|
}
|
|
|
|
function removeExclusion(id, rule) {
|
|
return removeIncludeExclude(id, rule, 'exclusions');
|
|
}
|
|
|
|
function addInclusion(id, rule) {
|
|
return addIncludeExclude(id, rule, 'inclusions');
|
|
}
|
|
|
|
function removeInclusion(id, rule) {
|
|
return removeIncludeExclude(id, rule, 'inclusions');
|
|
}
|
|
|
|
function deleteStyle(id, reason) {
|
|
const style = styles.get(id);
|
|
const rev = Date.now();
|
|
return db.exec('delete', id)
|
|
.then(() => {
|
|
if (reason !== 'sync') {
|
|
sync.delete(style.data._id, rev);
|
|
}
|
|
for (const url of style.appliesTo) {
|
|
const cache = cachedStyleForUrl.get(url);
|
|
if (cache) {
|
|
delete cache.sections[id];
|
|
}
|
|
}
|
|
styles.delete(id);
|
|
uuidIndex.delete(style.data._id);
|
|
return msg.broadcast({
|
|
method: 'styleDeleted',
|
|
style: {id}
|
|
});
|
|
})
|
|
.then(() => id);
|
|
}
|
|
|
|
function deleteByUUID(_id, rev) {
|
|
const id = uuidIndex.get(_id);
|
|
const oldDoc = id && styles.has(id) && styles.get(id).data;
|
|
if (oldDoc && compareRevision(oldDoc._rev, rev) <= 0) {
|
|
// FIXME: does it make sense to set reason to 'sync' in deleteByUUID?
|
|
return deleteStyle(id, 'sync');
|
|
}
|
|
}
|
|
|
|
function ensurePrepared(methods) {
|
|
const prepared = {};
|
|
for (const [name, fn] of Object.entries(methods)) {
|
|
prepared[name] = (...args) =>
|
|
preparing.then(() => fn(...args));
|
|
}
|
|
return prepared;
|
|
}
|
|
|
|
function createNewStyle() {
|
|
return {
|
|
enabled: true,
|
|
updateUrl: null,
|
|
md5Url: null,
|
|
url: null,
|
|
originalMd5: null,
|
|
installDate: Date.now()
|
|
};
|
|
}
|
|
|
|
function broadcastStyleUpdated(data, reason, method = 'styleUpdated', codeIsUpdated = true) {
|
|
const style = styles.get(data.id);
|
|
const excluded = new Set();
|
|
const updated = new Set();
|
|
for (const [url, cache] of cachedStyleForUrl.entries()) {
|
|
if (!style.appliesTo.has(url)) {
|
|
cache.maybeMatch.add(data.id);
|
|
continue;
|
|
}
|
|
const code = getAppliedCode(createMatchQuery(url), data);
|
|
if (!code) {
|
|
excluded.add(url);
|
|
delete cache.sections[data.id];
|
|
} else {
|
|
updated.add(url);
|
|
cache.sections[data.id] = {
|
|
id: data.id,
|
|
code
|
|
};
|
|
}
|
|
}
|
|
style.appliesTo = updated;
|
|
return msg.broadcast({
|
|
method,
|
|
style: {
|
|
id: data.id,
|
|
md5Url: data.md5Url,
|
|
enabled: data.enabled
|
|
},
|
|
reason,
|
|
codeIsUpdated
|
|
});
|
|
}
|
|
|
|
function beforeSave(style) {
|
|
if (!style.name) {
|
|
throw new Error('style name is empty');
|
|
}
|
|
if (style.id == null) {
|
|
delete style.id;
|
|
}
|
|
if (!style._id) {
|
|
style._id = uuidv4();
|
|
}
|
|
style._rev = Date.now();
|
|
fixUsoMd5Issue(style);
|
|
}
|
|
|
|
function afterSave(style, newId) {
|
|
if (style.id == null) {
|
|
style.id = newId;
|
|
}
|
|
uuidIndex.set(style._id, style.id);
|
|
sync.put(style._id, style._rev);
|
|
}
|
|
|
|
function saveStyle(style) {
|
|
beforeSave(style);
|
|
return db.exec('put', style)
|
|
.then(event => {
|
|
afterSave(style, event.target.result);
|
|
return style;
|
|
});
|
|
}
|
|
|
|
function handleSave(data, reason, codeIsUpdated) {
|
|
const style = styles.get(data.id);
|
|
let method;
|
|
if (!style) {
|
|
styles.set(data.id, {
|
|
appliesTo: new Set(),
|
|
data
|
|
});
|
|
method = 'styleAdded';
|
|
} else {
|
|
style.data = data;
|
|
method = 'styleUpdated';
|
|
}
|
|
broadcastStyleUpdated(data, reason, method, codeIsUpdated);
|
|
return data;
|
|
}
|
|
|
|
// get styles matching a URL, including sloppy regexps and excluded items.
|
|
function getStylesByUrl(url, id = null) {
|
|
// FIXME: do we want to cache this? Who would like to open popup rapidly
|
|
// or search the DB with the same URL?
|
|
const result = [];
|
|
const datas = !id ? [...styles.values()].map(s => s.data) :
|
|
styles.has(id) ? [styles.get(id).data] : [];
|
|
const query = createMatchQuery(url);
|
|
for (const data of datas) {
|
|
let excluded = false;
|
|
let sloppy = false;
|
|
let sectionMatched = false;
|
|
const match = urlMatchStyle(query, data);
|
|
// TODO: enable this when the function starts returning false
|
|
// if (match === false) {
|
|
// continue;
|
|
// }
|
|
if (match === 'excluded') {
|
|
excluded = true;
|
|
}
|
|
for (const section of data.sections) {
|
|
if (styleSectionGlobal(section) && styleCodeEmpty(section.code)) {
|
|
continue;
|
|
}
|
|
const match = urlMatchSection(query, section);
|
|
if (match) {
|
|
if (match === 'sloppy') {
|
|
sloppy = true;
|
|
}
|
|
sectionMatched = true;
|
|
break;
|
|
}
|
|
}
|
|
if (sectionMatched) {
|
|
result.push({
|
|
data: getStyleWithNoCode(data),
|
|
excluded,
|
|
sloppy
|
|
});
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
function getSectionsByUrl(url, id) {
|
|
let cache = cachedStyleForUrl.get(url);
|
|
if (!cache) {
|
|
cache = {
|
|
sections: {},
|
|
maybeMatch: new Set()
|
|
};
|
|
buildCache(styles.values());
|
|
cachedStyleForUrl.set(url, cache);
|
|
} else if (cache.maybeMatch.size) {
|
|
buildCache(
|
|
[...cache.maybeMatch]
|
|
.filter(i => styles.has(i))
|
|
.map(i => styles.get(i))
|
|
);
|
|
}
|
|
if (id) {
|
|
if (cache.sections[id]) {
|
|
return {[id]: cache.sections[id]};
|
|
}
|
|
return {};
|
|
}
|
|
return cache.sections;
|
|
|
|
function buildCache(styleList) {
|
|
const query = createMatchQuery(url);
|
|
for (const {appliesTo, data, preview} of styleList) {
|
|
const code = getAppliedCode(query, preview || data);
|
|
if (code) {
|
|
cache.sections[data.id] = {
|
|
id: data.id,
|
|
code
|
|
};
|
|
appliesTo.add(url);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
function getAppliedCode(query, data) {
|
|
if (urlMatchStyle(query, data) !== true) {
|
|
return;
|
|
}
|
|
const code = [];
|
|
for (const section of data.sections) {
|
|
if (urlMatchSection(query, section) === true && !styleCodeEmpty(section.code)) {
|
|
code.push(section.code);
|
|
}
|
|
}
|
|
return code.length && code;
|
|
}
|
|
|
|
function prepare() {
|
|
const ADD_MISSING_PROPS = {
|
|
name: style => `ID: ${style.id}`,
|
|
_id: () => uuidv4(),
|
|
_rev: () => Date.now()
|
|
};
|
|
|
|
return db.exec('getAll')
|
|
.then(event => event.target.result || [])
|
|
.then(styleList => {
|
|
// setup missing _id, _rev
|
|
const updated = [];
|
|
for (const style of styleList) {
|
|
if (addMissingProperties(style)) {
|
|
updated.push(style);
|
|
}
|
|
}
|
|
if (updated.length) {
|
|
return db.exec('putMany', updated)
|
|
.then(() => styleList);
|
|
}
|
|
return styleList;
|
|
})
|
|
.then(styleList => {
|
|
for (const style of styleList) {
|
|
fixUsoMd5Issue(style);
|
|
styles.set(style.id, {
|
|
appliesTo: new Set(),
|
|
data: style
|
|
});
|
|
uuidIndex.set(style._id, style.id);
|
|
}
|
|
});
|
|
|
|
function addMissingProperties(style) {
|
|
let touched = false;
|
|
for (const key in ADD_MISSING_PROPS) {
|
|
if (!style[key]) {
|
|
style[key] = ADD_MISSING_PROPS[key](style);
|
|
touched = true;
|
|
}
|
|
}
|
|
return touched;
|
|
}
|
|
}
|
|
|
|
function urlMatchStyle(query, style) {
|
|
if (
|
|
style.exclusions &&
|
|
style.exclusions.some(e => compileExclusion(e).test(query.urlWithoutParams))
|
|
) {
|
|
return 'excluded';
|
|
}
|
|
if (!style.enabled) {
|
|
return 'disabled';
|
|
}
|
|
return true;
|
|
}
|
|
|
|
function urlMatchSection(query, section) {
|
|
if (
|
|
section.domains &&
|
|
section.domains.some(d => d === query.domain || query.domain.endsWith(`.${d}`))
|
|
) {
|
|
return true;
|
|
}
|
|
if (section.urlPrefixes && section.urlPrefixes.some(p => p && query.url.startsWith(p))) {
|
|
return true;
|
|
}
|
|
// as per spec the fragment portion is ignored in @-moz-document:
|
|
// https://www.w3.org/TR/2012/WD-css3-conditional-20120911/#url-of-doc
|
|
// but the spec is outdated and doesn't account for SPA sites
|
|
// so we only respect it for `url()` function
|
|
if (section.urls && (
|
|
section.urls.includes(query.url) ||
|
|
section.urls.includes(query.urlWithoutHash)
|
|
)) {
|
|
return true;
|
|
}
|
|
if (section.regexps && section.regexps.some(r => compileRe(r).test(query.url))) {
|
|
return true;
|
|
}
|
|
/*
|
|
According to CSS4 @document specification the entire URL must match.
|
|
Stylish-for-Chrome implemented it incorrectly since the very beginning.
|
|
We'll detect styles that abuse the bug by finding the sections that
|
|
would have been applied by Stylish but not by us as we follow the spec.
|
|
*/
|
|
if (section.regexps && section.regexps.some(r => compileSloppyRe(r).test(query.url))) {
|
|
return 'sloppy';
|
|
}
|
|
// TODO: check for invalid regexps?
|
|
return styleSectionGlobal(section);
|
|
}
|
|
|
|
function createCompiler(compile) {
|
|
// FIXME: FIFO cache doesn't work well here, if we want to match many
|
|
// regexps more than the cache size, we will never hit the cache because
|
|
// the first cache is deleted. So we use a simple map but it leaks memory.
|
|
const cache = new Map();
|
|
return text => {
|
|
let re = cache.get(text);
|
|
if (!re) {
|
|
re = tryRegExp(compile(text));
|
|
if (!re) {
|
|
re = BAD_MATCHER;
|
|
}
|
|
cache.set(text, re);
|
|
}
|
|
return re;
|
|
};
|
|
}
|
|
|
|
function compileGlob(text) {
|
|
return escapeRegExp(text).replace(/\\\\\\\*|\\\*/g, m => m.length > 2 ? m : '.*');
|
|
}
|
|
|
|
function buildExclusion(text) {
|
|
// match pattern
|
|
const match = text.match(/^(\*|[\w-]+):\/\/(\*\.)?([\w.]+\/.*)/);
|
|
if (!match) {
|
|
return '^' + compileGlob(text) + '$';
|
|
}
|
|
return '^' +
|
|
(match[1] === '*' ? '[\\w-]+' : match[1]) +
|
|
'://' +
|
|
(match[2] ? '(?:[\\w.]+\\.)?' : '') +
|
|
compileGlob(match[3]) +
|
|
'$';
|
|
}
|
|
|
|
// The md5Url provided by USO includes a duplicate "update" subdomain (see #523),
|
|
// This fixes any already installed styles containing this error
|
|
function fixUsoMd5Issue(style) {
|
|
if (style && style.md5Url && style.md5Url.includes('update.update.userstyles')) {
|
|
style.md5Url = style.md5Url.replace('update.update.userstyles', 'update.userstyles');
|
|
}
|
|
}
|
|
|
|
function createMatchQuery(url) {
|
|
let urlWithoutHash;
|
|
let urlWithoutParams;
|
|
let domain;
|
|
return {
|
|
url,
|
|
get urlWithoutHash() {
|
|
if (!urlWithoutHash) {
|
|
urlWithoutHash = url.split('#')[0];
|
|
}
|
|
return urlWithoutHash;
|
|
},
|
|
get urlWithoutParams() {
|
|
if (!urlWithoutParams) {
|
|
const u = createURL(url);
|
|
urlWithoutParams = u.origin + u.pathname;
|
|
}
|
|
return urlWithoutParams;
|
|
},
|
|
get domain() {
|
|
if (!domain) {
|
|
const u = createURL(url);
|
|
domain = u.hostname;
|
|
}
|
|
return domain;
|
|
}
|
|
};
|
|
}
|
|
|
|
function createURL(url) {
|
|
try {
|
|
return new URL(url);
|
|
} catch (err) {
|
|
return DUMMY_URL;
|
|
}
|
|
}
|
|
})();
|