Welcome to your new react app.
+
);
}
diff --git a/src/components/test.jsx b/src/components/test.jsx
index a7f07a2..a76ac2b 100644
--- a/src/components/test.jsx
+++ b/src/components/test.jsx
@@ -12,18 +12,12 @@ const mapDispatchToProps = (dispatch) => ({});
export function App() {
useEffect(() => {
- ipcRenderer.on("test-success", (event, obj) => {
- console.log("Test Success", obj);
- });
- ipcRenderer.on(ipcTypes.default.filewatcher.startSuccess, (event, obj) => {
- console.log(ipcTypes.default.filewatcher.startSuccess, obj);
+ ipcRenderer.on("not a real channel", (event, obj) => {
+ console.log("not a real channel", obj);
});
// Cleanup the listener events so that memory leaks are avoided.
return function cleanup() {
- ipcRenderer.removeAllListeners(
- "test-success",
- ipcTypes.default.filewatcher.startSuccess
- );
+ ipcRenderer.removeAllListeners("not a real channel");
};
}, []);
diff --git a/src/graphql/jobs.queries.js b/src/graphql/jobs.queries.js
new file mode 100644
index 0000000..dc10dd7
--- /dev/null
+++ b/src/graphql/jobs.queries.js
@@ -0,0 +1,26 @@
+import gql from "graphql-tag";
+
+export const INSERT_NEW_JOB = gql`
+ mutation INSERT_JOB($job: [jobs_insert_input!]!) {
+ insert_jobs(objects: $job) {
+ returning {
+ id
+ }
+ }
+ }
+`;
+
+// on_conflict: {
+// constraint: jobs_clm_no_bodyshopid_key
+// update_columns: [
+// ins_co_nm
+// clm_no
+// clm_total
+// ownr_ln
+// ownr_fn
+// v_vin
+// v_make_desc
+// v_model_desc
+// v_type
+// ]
+// }
diff --git a/src/ipc.types.js b/src/ipc.types.js
index 692020b..4bad674 100644
--- a/src/ipc.types.js
+++ b/src/ipc.types.js
@@ -1,4 +1,5 @@
exports.default = {
+ webcontent: "webcontent-send",
test: {
start: "test-start",
},
@@ -7,6 +8,7 @@ exports.default = {
filepathsGet: "filewatcher__filepathsget",
start: "filewatcher__start",
stop: "filewatcher__stop",
+ addPath: "filewatcher__addPath",
},
toRenderer: {
filepathsList: "filewatcher__filepathslist",
diff --git a/src/ipc/ipc-estimate-utils.js b/src/ipc/ipc-estimate-utils.js
new file mode 100644
index 0000000..bd51bc1
--- /dev/null
+++ b/src/ipc/ipc-estimate-utils.js
@@ -0,0 +1,16 @@
+import client from "../graphql/GraphQLClient";
+import { INSERT_NEW_JOB } from "../graphql/jobs.queries";
+import { store } from "../redux/store";
+
+export async function UpsertEstimate(job) {
+ const shopId = store.getState().user.bodyshop.id;
+ console.log("UpsertEstimate -> shopId", shopId);
+
+ const result = await client.mutate({
+ mutation: INSERT_NEW_JOB,
+ variables: {
+ job: { ...job, bodyshopid: shopId },
+ },
+ });
+ console.log("UpsertEstimate -> result", result);
+}
diff --git a/src/ipc/ipc-renderer-handler.js b/src/ipc/ipc-renderer-handler.js
index 4d0b4bb..f609879 100644
--- a/src/ipc/ipc-renderer-handler.js
+++ b/src/ipc/ipc-renderer-handler.js
@@ -4,9 +4,15 @@ import {
setWatcherStatus,
} from "../redux/application/application.actions";
import { store } from "../redux/store";
+import { message } from "antd";
+import { UpsertEstimate } from "./ipc-estimate-utils";
+
const { ipcRenderer } = window;
console.log("----Initializing IPC Listeners in React App.");
+ipcRenderer.on("test-toRenderer", (event, obj) => {
+ console.log("test-toRenderer", obj);
+});
ipcRenderer.on(
ipcTypes.default.fileWatcher.toRenderer.filepathsList,
@@ -15,10 +21,12 @@ ipcRenderer.on(
}
);
-//Filewatcher Section
+//Filewatcher Status Section
ipcRenderer.on(
ipcTypes.default.fileWatcher.toRenderer.startSuccess,
(event, ...obj) => {
+ console.log("Watcher ready.");
+ message.success("Watcher started!");
store.dispatch(setWatcherStatus("READY!"));
}
);
@@ -28,10 +36,25 @@ ipcRenderer.on(
store.dispatch(setWatcherStatus("STOPPED"));
}
);
-
ipcRenderer.on(
ipcTypes.default.fileWatcher.toRenderer.error,
(event, ...obj) => {
store.dispatch(setWatcherStatus(obj));
}
);
+
+//Estimate Section
+ipcRenderer.on(
+ ipcTypes.default.estimate.toRenderer.estimateDecodeStart,
+ (event, ...obj) => {
+ console.log("Decoding started!");
+ }
+);
+
+ipcRenderer.on(
+ ipcTypes.default.estimate.toRenderer.estimateDecodeSuccess,
+ async (event, ...obj) => {
+ console.log("Decoding success!", obj[0]);
+ await UpsertEstimate(obj[0]);
+ }
+);
diff --git a/src/redux/application/application.sagas.js b/src/redux/application/application.sagas.js
index 9c961be..4d19439 100644
--- a/src/redux/application/application.sagas.js
+++ b/src/redux/application/application.sagas.js
@@ -1,5 +1,5 @@
//import { all, call, takeLatest } from "redux-saga/effects";
-import ApplicationActionTypes from "./application.types";
+//import ApplicationActionTypes from "./application.types";
// export function* onJoinRoom() {
// yield takeLatest(ApplicationActionTypes.JOIN_ROOM, joinRoom);
diff --git a/src/redux/root.reducer.js b/src/redux/root.reducer.js
index 71c41c8..067e904 100644
--- a/src/redux/root.reducer.js
+++ b/src/redux/root.reducer.js
@@ -7,7 +7,7 @@ import userReducer from "./user/user.reducer";
const persistConfig = {
key: "root",
storage,
- // blacklist: ["application"],
+ blacklist: ["application"],
};
const rootReducer = combineReducers({