mirror of
https://github.com/Kong/insomnia
synced 2024-11-12 17:26:32 +00:00
0a616fba6b
* VCS proof of concept underway! * Stuff * Some things * Replace deprecated Electron makeSingleInstance * Rename `window` variables so not to be confused with window object * Don't unnecessarily update request when URL does not change * Regenerate package-lock * Fix tests + ESLint * Publish - insomnia-app@1.0.49 - insomnia-cookies@0.0.12 - insomnia-httpsnippet@1.16.18 - insomnia-importers@2.0.13 - insomnia-libcurl@0.0.23 - insomnia-prettify@0.1.7 - insomnia-url@0.1.6 - insomnia-xpath@1.0.9 - insomnia-plugin-base64@1.0.6 - insomnia-plugin-cookie-jar@1.0.8 - insomnia-plugin-core-themes@1.0.5 - insomnia-plugin-default-headers@1.1.9 - insomnia-plugin-file@1.0.7 - insomnia-plugin-hash@1.0.7 - insomnia-plugin-jsonpath@1.0.12 - insomnia-plugin-now@1.0.11 - insomnia-plugin-os@1.0.13 - insomnia-plugin-prompt@1.1.9 - insomnia-plugin-request@1.0.18 - insomnia-plugin-response@1.0.16 - insomnia-plugin-uuid@1.0.10 * Broken but w/e * Some tweaks * Big refactor. Create local snapshots and push done * POC merging and a lot of improvements * Lots of work done on initial UI/UX * Fix old tests * Atomic writes and size-based batches * Update StageEntry definition once again to be better * Factor out GraphQL query logic * Merge algorithm, history modal, other minor things * Fix test * Merge, checkout, revert w/ user changes now work * Force UI to refresh when switching branches changes active request * Rough draft pull() and some cleanup * E2EE stuff and some refactoring * Add ability to share project with team and fixed tests * VCS now created in root component and better remote project handling * Remove unused definition * Publish - insomnia-account@0.0.2 - insomnia-app@1.1.1 - insomnia-cookies@0.0.14 - insomnia-httpsnippet@1.16.20 - insomnia-importers@2.0.15 - insomnia-libcurl@0.0.25 - insomnia-prettify@0.1.9 - insomnia-sync@0.0.2 - insomnia-url@0.1.8 - insomnia-xpath@1.0.11 - insomnia-plugin-base64@1.0.8 - insomnia-plugin-cookie-jar@1.0.10 - insomnia-plugin-core-themes@1.0.7 - insomnia-plugin-file@1.0.9 - insomnia-plugin-hash@1.0.9 - insomnia-plugin-jsonpath@1.0.14 - insomnia-plugin-now@1.0.13 - insomnia-plugin-os@1.0.15 - insomnia-plugin-prompt@1.1.11 - insomnia-plugin-request@1.0.20 - insomnia-plugin-response@1.0.18 - insomnia-plugin-uuid@1.0.12 * Move some deps around * Fix Flow errors * Update package.json * Fix eslint errors * Fix tests * Update deps * bootstrap insomnia-sync * TRy fixing appveyor * Try something else * Bump lerna * try powershell * Try again * Fix imports * Fixed errors * sync types refactor * Show remote projects in workspace dropdown * Improved pulling of non-local workspaces * Loading indicators and some tweaks * Clean up sync staging modal * Some sync improvements: - No longer store stage - Upgrade Electron - Sync UI/UX improvements * Fix snyc tests * Upgraded deps and hot loader tweaks (it's broken for some reason) * Fix tests * Branches dialog, network refactoring, some tweaks * Fixed merging when other branch is empty * A bunch of small fixes from real testing * Fixed pull merge logic * Fix tests * Some bug fixes * A few small tweaks * Conflict resolution and other improvements * Fix tests * Add revert changes * Deal with duplicate projects per workspace * Some tweaks and accessibility improvements * Tooltip accessibility * Fix API endpoint * Fix tests * Remove jest dep from insomnia-importers
151 lines
3.7 KiB
JavaScript
151 lines
3.7 KiB
JavaScript
// @flow
|
|
import fs from 'fs';
|
|
import path from 'path';
|
|
import mkdirp from 'mkdirp';
|
|
import type { BaseDriver } from './base';
|
|
|
|
export default class FileSystemDriver implements BaseDriver {
|
|
_directory: string;
|
|
|
|
constructor(config: { directory: string }) {
|
|
this._directory = config.directory;
|
|
console.log(`[FileSystemDriver] Initialized in "${this._directory}"`);
|
|
}
|
|
|
|
async hasItem(key: string): Promise<boolean> {
|
|
return new Promise((resolve, reject) => {
|
|
fs.stat(this._getKeyPath(key), (err, result) => {
|
|
if (err && err.code === 'ENOENT') {
|
|
resolve(false);
|
|
} else if (err) {
|
|
reject(err);
|
|
} else {
|
|
resolve(true);
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
setItem(key: string, value: Buffer): Promise<void> {
|
|
return new Promise((resolve, reject) => {
|
|
const finalPath = this._getKeyPath(key);
|
|
|
|
// Temp path contains randomness to avoid race-condition collisions. This
|
|
// doesn't actually avoid race conditions but at least it won't fail.
|
|
const tmpPath = `${finalPath}.${Math.random()}.tmp`;
|
|
|
|
// This method implements atomic writes by first writing to a temporary
|
|
// file (non-atomic) then renaming the file to the final value (atomic)
|
|
fs.writeFile(tmpPath, value, 'utf8', err => {
|
|
if (err) {
|
|
return reject(err);
|
|
}
|
|
fs.rename(tmpPath, finalPath, err => {
|
|
if (err) {
|
|
return reject(err);
|
|
}
|
|
resolve();
|
|
});
|
|
});
|
|
});
|
|
}
|
|
|
|
getItem(key: string): Promise<Buffer | null> {
|
|
return new Promise((resolve, reject) => {
|
|
fs.readFile(this._getKeyPath(key), (err, data) => {
|
|
if (err && err.code === 'ENOENT') {
|
|
resolve(null);
|
|
} else if (err) {
|
|
reject(err);
|
|
} else {
|
|
resolve(data);
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
removeItem(key: string): Promise<void> {
|
|
return new Promise((resolve, reject) => {
|
|
fs.unlink(this._getKeyPath(key), err => {
|
|
if (err && err.code === 'ENOENT') {
|
|
resolve();
|
|
} else if (err) {
|
|
reject(err);
|
|
} else {
|
|
resolve();
|
|
}
|
|
});
|
|
});
|
|
}
|
|
|
|
clear(): Promise<void> {
|
|
return new Promise((resolve, reject) => {
|
|
fs.readdir(this._directory, (err, names) => {
|
|
if (err) {
|
|
return reject(err);
|
|
}
|
|
|
|
for (const name of names) {
|
|
fs.unlinkSync(this._getKeyPath(name));
|
|
}
|
|
|
|
resolve();
|
|
});
|
|
});
|
|
}
|
|
|
|
async keys(prefix: string, recursive: boolean): Promise<Array<string>> {
|
|
const next = dir => {
|
|
return new Promise(async (resolve, reject) => {
|
|
let keys: Array<string> = [];
|
|
let names = [];
|
|
try {
|
|
names = fs.readdirSync(dir);
|
|
} catch (err) {
|
|
if (err.code !== 'ENOENT') {
|
|
reject(err);
|
|
}
|
|
}
|
|
|
|
for (const name of names) {
|
|
if (name.indexOf('.') === 0) {
|
|
// Skip any non-vcs files
|
|
continue;
|
|
}
|
|
|
|
const p = path.join(dir, name);
|
|
const isDir = fs.statSync(p).isDirectory();
|
|
if (isDir && recursive) {
|
|
const more = await next(p);
|
|
keys = [...keys, ...more];
|
|
} else if (!recursive && isDir) {
|
|
keys.push(p);
|
|
} else if (!isDir) {
|
|
keys.push(p);
|
|
}
|
|
}
|
|
|
|
resolve(keys);
|
|
});
|
|
};
|
|
|
|
const rawKeys = await next(this._getKeyPath(prefix));
|
|
|
|
const keys = [];
|
|
for (const rawKey of rawKeys) {
|
|
keys.push(rawKey.substring(this._directory.length));
|
|
}
|
|
|
|
return keys;
|
|
}
|
|
|
|
_getKeyPath(key: string): string {
|
|
const p = path.join(this._directory, key);
|
|
|
|
// Create base directory
|
|
mkdirp.sync(path.dirname(p));
|
|
|
|
return p;
|
|
}
|
|
}
|