65 lines
2.2 KiB
TypeScript
65 lines
2.2 KiB
TypeScript
import { ResourceName, DataChangeType, Dictionary } from "farmbot/dist";
|
|
import { devices } from "./device";
|
|
import { box } from "boxed_value";
|
|
import * as _ from "lodash";
|
|
|
|
export let METHOD_MAP: Dictionary<DataChangeType> = {
|
|
"post": "add",
|
|
"put": "update",
|
|
"patch": "update",
|
|
"delete": "remove"
|
|
};
|
|
export let METHODS = ["post", "put", "patch", "delete"];
|
|
export let RESOURCES: ResourceName[] = [
|
|
"images", "plants", "regimens", "peripherals", "logs", "sequences",
|
|
"farm_events", "tool_slots", "tools", "points", "device"];
|
|
|
|
// PROBLEM: The bot doesn't know if the user has changed any of the data.
|
|
// GOOD SOLUTION: Create a push notification system on the API.
|
|
// FAST SOLUTION: Ping the bot every time we push "save" or "update".
|
|
// Our hope is to eventually move this logic into the API.
|
|
export function notifyBotOfChanges(url: string | undefined, action: DataChangeType) {
|
|
if (url) {
|
|
url.split("/").filter((chunk: ResourceName) => {
|
|
return RESOURCES.includes(chunk);
|
|
}).map(async function (resource: ResourceName) {
|
|
devices.current.dataUpdate(action, { [resource]: inferUpdateId(url) });
|
|
});
|
|
}
|
|
}
|
|
|
|
/** More nasty hacks until we have time to implement proper API push state
|
|
* notifications. */
|
|
function inferUpdateId(url: string) {
|
|
try {
|
|
let ids = url
|
|
.split("/")
|
|
.filter(x => !x.includes(",")) // Don't allow batch endpoints to participate.
|
|
.map(x => parseInt(x, 10))
|
|
.filter(x => !_.isNaN(x));
|
|
let id: number | undefined = ids[0];
|
|
let isNum = _.isNumber(id);
|
|
let onlyOne = ids.length === 1;
|
|
return (isNum && onlyOne) ? ("" + id) : "*";
|
|
} catch (error) { // Don't crash - just keep moving along. This is a temp patch.
|
|
return "*";
|
|
}
|
|
}
|
|
|
|
/** The input of an axios error interceptor is an "any" type.
|
|
* Sometimes it will be a real Axios error, other times it will not be.
|
|
*/
|
|
export interface SafeError {
|
|
response: {
|
|
status: number;
|
|
};
|
|
}
|
|
|
|
/** Prevents hard-to-find NPEs and type errors inside of interceptors. */
|
|
export function isSafeError(x: SafeError | any): x is SafeError {
|
|
return !!(
|
|
(box(x).kind === "object") &&
|
|
(box(x.response).kind === "object") &&
|
|
(box(x.response.status).kind === "number"));
|
|
}
|