bartek/openhab-importer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix importing with --force option

Browse Source
This commit is contained in:
Bartłomiej Pluta
2024-11-17 14:58:40 +01:00
parent beff0a2f35
commit 2166490e2d
2 changed files with 31 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
src/importer/index.ts
View File

@@ -1,6 +1,7 @@
import { Config, ImportOptions, Thing } from "@types";
import { adapters } from "../adapters";
import { DummyOpenHAB, OpenHAB } from "../openhab";
import { partitionBy } from "../utils/list";
const createFilter = (filter?: string) => {
@@ -11,13 +12,8 @@ const createFilter = (filter?: string) => {
return new Function("$", `const v = ${filter}; if(typeof v !== 'boolean') throw new Error("Filter should be of boolean type"); return v;`) as ((_: Thing) => true);
};
export const importThings = async (config: Config, options: ImportOptions) => {
const OH = options.dryRun ? DummyOpenHAB : OpenHAB;
const openhab = new OH(config.openHAB);
const sources = options.sources ?? Object.keys(config.sources);
const things = (await Promise.all(sources.map(source => {
const discoverThingsFromSources = async (sources: string[], config: Config, options: ImportOptions): Promise<Thing[]> => {
const promises = sources.map(source => {
const { type, config: cfg } = config.sources[source];
const constructor = adapters[type as keyof (typeof adapters)];
@@ -27,22 +23,30 @@ export const importThings = async (config: Config, options: ImportOptions) => {
}
return new constructor(source, cfg).loadThings();
}))).flat();
});
const existingThings = await openhab.getThings();
const existingThingsUIDs = existingThings.map(t => t.UID);
const filter = createFilter(options.where);
const thingsToImport = things
.filter(t => !existingThingsUIDs.includes(t.UID))
.filter(filter);
if (options.force) {
await openhab.deleteThings(...thingsToImport.map(t => t.UID));
}
await openhab.createThings(...thingsToImport);
return thingsToImport;
const responses = await Promise.all(promises);
return responses.flat().filter(createFilter(options.where));
}
export const importThings = async (config: Config, options: ImportOptions) => {
const OH = options.dryRun ? DummyOpenHAB : OpenHAB;
const openhab = new OH(config.openHAB);
const sources = options.sources ?? Object.keys(config.sources);
const allThingsToImport = await discoverThingsFromSources(sources, config, options);
const allThingsInOH = await openhab.getThings();
const existingThingsUIDs = allThingsInOH.map(t => t.UID);
const [existing, missing] = partitionBy(allThingsToImport, t => existingThingsUIDs.includes(t.UID));
if (options.force) {
await openhab.deleteThings(...existing.map(t => t.UID));
await openhab.createThings(...allThingsToImport);
return allThingsToImport;
}
await openhab.createThings(...missing);
return missing;
}

3
src/utils/list.ts Normal file
View File

@@ -0,0 +1,3 @@
export const partitionBy = <T>(list: T[], condition: (item: T) => boolean): [T[], T[]] => {
return [list.filter(e => condition(e)), list.filter(e => !condition(e))];
}