From c9796e6bdcf8c1f115f0a06bf4a529bdeecadf42 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?G=C3=A9ry=20Debongnie?= <ged@odoo.com>
Date: Wed, 20 Mar 2019 11:49:41 +0100
Subject: [PATCH] add store class to core

---
 src/index.ts |  3 ++-
 src/store.ts | 63 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 65 insertions(+), 1 deletion(-)
 create mode 100644 src/store.ts

diff --git a/src/index.ts b/src/index.ts
index 4b86ae2d..163c0545 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -1,5 +1,6 @@
 import { QWeb } from "./qweb";
 import { EventBus } from "./event_bus";
 import { Component } from "./component";
+import { Store, StoreMixin } from "./store";
 
-export const core = { QWeb, EventBus, Component };
+export const core = { QWeb, EventBus, Component, Store, StoreMixin };
diff --git a/src/store.ts b/src/store.ts
new file mode 100644
index 00000000..6e76b55f
--- /dev/null
+++ b/src/store.ts
@@ -0,0 +1,63 @@
+import { EventBus } from "./event_bus";
+
+export function StoreMixin(Component) {
+  return class extends Component {
+    mounted() {
+      this.env.store.on("update", this, this.render);
+    }
+  };
+}
+
+interface StoreConfig {
+  state?: any;
+  actions?: any;
+  mutations?: any;
+}
+export class Store extends EventBus {
+  _state: any;
+  actions: any;
+  mutations: any;
+  _isMutating: boolean = false;
+
+  constructor(config: StoreConfig = {}) {
+    super();
+    this._state = Object.assign({}, config.state);
+    this.actions = config.actions;
+    this.mutations = config.mutations;
+  }
+
+  get state() {
+    return this._clone(this._state);
+  }
+
+  dispatch(action, payload) {
+    if (!this.actions[action]) {
+      throw new Error(`[Error] action ${action} is undefined`);
+    }
+    this.actions[action](
+      {
+        commit: this.commit.bind(this),
+        state: this.state
+      },
+      payload
+    );
+  }
+
+  commit(type, payload) {
+    if (!this.mutations[type]) {
+      throw new Error(`[Error] mutation ${type} is undefined`);
+    }
+    this._isMutating = true;
+    this.mutations[type].call(null, this._state, payload);
+    Promise.resolve().then(() => {
+      if (this._isMutating) {
+        this._isMutating = false;
+        this.trigger("update");
+      }
+    });
+  }
+
+  _clone(obj) {
+    return JSON.parse(JSON.stringify(obj));
+  }
+}