pulsar-edit/pulsar
1
1
Fork 0
mirror of https://github.com/pulsar-edit/pulsar.git synced 2024-09-11 19:17:09 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #77 from pulsar-edit/fix-config-watch

Browse Source 
Hooking up NSFW directly for config watching
This commit is contained in:
Maurício Szabo 2022-10-03 18:27:30 -03:00 committed by GitHub
commit 39e8d33cc6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/config-file.js
View File

@ -2,12 +2,14 @@ const _ = require('underscore-plus');
const fs = require('fs-plus');
const dedent = require('dedent');
const { Disposable, Emitter } = require('event-kit');
const { watchPath } = require('./path-watcher');
const CSON = require('season');
const Path = require('path');
const asyncQueue = require('async/queue');
const EVENT_TYPES = new Set(['created', 'modified', 'renamed']);
// TODO: if we ever decide to change path watchers on the future, this is kinda
// duplicated because of https://github.com/pulsar-edit/pulsar/issues/76
const nsfw = require('nsfw');
const EVENT_TYPES = new Set([nsfw.actions.CREATED, nsfw.actions.MODIFIED, nsfw.actions.RENAMED]);
module.exports = class ConfigFile {
static at(path) {
@ -63,7 +65,7 @@ module.exports = class ConfigFile {
});
}
async watch(callback) {
async watch() {
if (!fs.existsSync(this.path)) {
fs.makeTreeSync(Path.dirname(this.path));
CSON.writeFileSync(this.path, {}, { flag: 'wx' });
@ -72,10 +74,13 @@ module.exports = class ConfigFile {
await this.reload();
try {
return await watchPath(this.path, {}, events => {
if (events.some(event => EVENT_TYPES.has(event.action)))
const watcher = await nsfw(this.path, events => {
if (events.some(event => EVENT_TYPES.has(event.action))) {
this.requestLoad();
});
}
})
watcher.start();
return { dispose: () => watcher.stop() };
} catch (error) {
//TODO_PULSAR: Find out why the atom global variable isn't available at this point
this.emitter.emit(