settings: frontend api and reducer logic

pkg/interface/src/logic/api/global.ts

@@ -11,6 +11,7 @@ import LaunchApi from './launch';
 import GraphApi from './graph';
 import S3Api from './s3';
 import {HarkApi} from './hark';
+import SettingsApi from './settings';
 
 export default class GlobalApi extends BaseApi<StoreState> {
   local = new LocalApi(this.ship, this.channel, this.store);
@@ -22,6 +23,7 @@ export default class GlobalApi extends BaseApi<StoreState> {
   s3 = new S3Api(this.ship, this.channel, this.store);
   graph = new GraphApi(this.ship, this.channel, this.store);
   hark = new HarkApi(this.ship, this.channel, this.store);
+  settings = new SettingsApi(this.ship, this.channel, this.store);
 
   constructor(
     public ship: Patp,

pkg/interface/src/logic/api/settings.ts

@@ -0,0 +1,74 @@
+import BaseApi from './base';
+import { StoreState } from '../store/type';
+import {
+  SettingsUpdate,
+  SettingsData,
+  Key,
+  Value,
+  Bucket,
+} from '~/types/settings';
+
+
+export default class SettingsApi extends BaseApi<StoreState> {
+  private storeAction(action: SettingsEvent): Promise<any> {
+    return this.action('settings-store', 'settings-event', action);
+  }
+
+  putBucket(key: Key, bucket: Bucket) {
+    this.storeAction({
+      "put-bucket": {
+        "bucket-key": key,
+        "bucket": bucket,
+      }
+    });
+  }
+
+  delBucket(key: Key) {
+    this.storeAction({
+      "del-bucket": {
+        "bucket-key": key,
+      }
+    });
+  }
+
+  putEntry(buc: Key, key: Key, val: Value) {
+    this.storeAction({
+      "put-entry": {
+        "bucket-key": buc,
+        "entry-key": key,
+        "value": val,
+      }
+    });
+  }
+
+  delEntry(buc: Key, key: Key) {
+    this.storeAction({
+      "put-entry": {
+        "bucket-key": buc,
+        "entry-key": key,
+      }
+    });
+  }
+
+  async getAll() {
+    const data = await this.scry("settings-store", "/all");
+    this.store.handleEvent({data: {"settings-data": data.all}});
+  }
+
+  async getBucket(bucket: Key) {
+    const data = await this.scry('settings-store', `/bucket/${bucket}`);
+    this.store.handleEvent({data: {"settings-data": {
+      "bucket-key": bucket,
+      "bucket": data.bucket,
+    }}});
+  }
+
+  async getEntry(bucket: Key, entry: Key) {
+    const data = await this.scry('settings-store', `/entry/${bucket}/${entry}`);
+    this.store.handleEvent({data: {"settings-data": {
+      "bucket-key": bucket,
+      "entry-key": entry,
+      "entry": data.entry,
+    }}});
+  }
+}

pkg/interface/src/logic/reducers/settings-update.ts

@@ -0,0 +1,77 @@
+import _ from 'lodash';
+import { StoreState } from '../../store/type';
+import {
+  SettingsUpdate,
+} from '~/types/settings';
+
+type SettingsState = Pick<StoreState, 'settings'>;
+
+export default class SettingsReducer<S extends SettingsState>{
+  reduce(json: Cage, state: S) {
+    let data = json["settings-event"];
+    if (data) {
+      this.putBucket(data, state);
+      this.delBucket(data, state);
+      this.putEntry(data, state);
+      this.delEntry(data, state);
+    }
+    data = json["settings-data"];
+    if (data) {
+      this.getAll(data, state);
+      this.getBucket(data, state);
+      this.getEntry(data, state);
+    }
+  }
+
+  putBucket(json: SettingsUpdate, state: S) {
+    const data = _.get(json, 'put-bucket', false);
+    if (data) {
+      state.settings[data["bucket-key"]] = data.bucket;
+    }
+  }
+
+  delBucket(json: SettingsUpdate, state: S) {
+    const data = _.get(json, 'del-bucket', false);
+    if (data) {
+      delete state.settings[data["bucket-key"]];
+    }
+  }
+
+  putEntry(json: SettingsUpdate, state: S) {
+    const data = _.get(json, 'put-entry', false);
+    if (data) {
+      if (!state.settings[data["bucket-key"]]) {
+        state.settings[data["bucket-key"]] = {};
+      }
+      state.settings[data["bucket-key"]][data["entry-key"]] = data.value;
+    }
+  }
+
+  delEntry(json: SettingsUpdate, state: S) {
+    const data = _.get(json, 'del-entry', false);
+    if (data) {
+      delete state.settings[data["bucket-key"]][data["entry-key"]];
+    }
+  }
+
+  getAll(json: any, state: S) {
+    state.settings = json;
+  }
+
+  getBucket(json: any, state: S) {
+    const key    = _.get(json, 'bucket-key', false);
+    const bucket = _.get(json, 'bucket', false);
+    if (key && bucket) {
+      state.settings[key] = bucket;
+    }
+  }
+
+  getEntry(json: any, state: S) {
+    const bucketKey = _.get(json, 'bucket-key', false);
+    const entryKey  = _.get(json, 'entry-key', false);
+    const entry     = _.get(json, 'entry', false);
+    if (bucketKey && entryKey && entry) {
+      state.settings[bucketKey][entryKey] = entry;
+    }
+  }
+}

pkg/interface/src/logic/store/store.ts

@@ -13,6 +13,7 @@ import { HarkReducer } from '../reducers/hark-update';
 import GroupReducer from '../reducers/group-update';
 import LaunchReducer from '../reducers/launch-update';
 import ConnectionReducer from '../reducers/connection';
+import SettingsReducer from '../reducers/settings-update';
 import {OrderedMap} from '../lib/OrderedMap';
 import { BigIntOrderedMap } from '../lib/BigIntOrderedMap';
 
@@ -39,6 +40,7 @@ export default class GlobalStore extends BaseStore<StoreState> {
   groupReducer = new GroupReducer();
   launchReducer = new LaunchReducer();
   connReducer = new ConnectionReducer();
+  settingsReducer = new SettingsReducer();
 
   rehydrate() {
     this.localReducer.rehydrate(this.state);
@@ -89,7 +91,8 @@ export default class GlobalStore extends BaseStore<StoreState> {
         graph: {},
         group: {}
       },
-      notificationsCount: 0
+      notificationsCount: 0,
+      settings: {}
     };
   }
 
@@ -104,5 +107,6 @@ export default class GlobalStore extends BaseStore<StoreState> {
     this.connReducer.reduce(data, this.state);
     GraphReducer(data, this.state);
     HarkReducer(data, this.state);
+    this.settingsReducer.reduce(data, this.state);
   }
 }

pkg/interface/src/logic/subscription/global.ts

@@ -44,6 +44,7 @@ export default class GlobalSubscription extends BaseSubscription<StoreState> {
     this.subscribe('/updates', 'hark-store');
     this.subscribe('/updates', 'hark-graph-hook');
     this.subscribe('/updates', 'hark-group-hook');
+    this.subscribe('/all', 'settings-store');
   }
 
   restart() {

pkg/interface/src/types/cage.ts

@@ -5,6 +5,7 @@ import { MetadataUpdate } from "./metadata-update";
 import { GroupUpdate } from "./group-update";
 import { LaunchUpdate, WeatherState } from "./launch-update";
 import { ConnectionStatus } from "./connection";
+import { SettingsUpdate } from "./settings";
 
 interface MarksToTypes {
   readonly json: any;
@@ -14,6 +15,7 @@ interface MarksToTypes {
   readonly groupUpdate: GroupUpdate;
   readonly "launch-update": LaunchUpdate;
   readonly "link-listen-update": LinkListenUpdate;
+  readonly "settings-event": SettingsUpdate;
   // not really marks but w/e
   readonly 'local': LocalUpdate;
   readonly 'weather': WeatherState | {};

pkg/interface/src/types/settings.ts

@@ -0,0 +1,55 @@
+export type Key = string;
+export type Value = string | boolean | number;
+export type Bucket = Map<string, Value>;
+export type Settings = Map<string, Bucket>;
+
+interface PutBucket {
+  "put-bucket": {
+    "bucket-key": Key;
+    "bucket": Bucket;
+  };
+}
+
+interface DelBucket {
+  "del-bucket": {
+    "bucket-key": Key;
+  };
+}
+
+interface PutEntry {
+  "put-entry": {
+    "bucket-key": Key;
+    "entry-key": Key;
+    "value": Value;
+  };
+}
+
+interface DelEntry {
+  "del-entry": {
+    "bucket-key": Key;
+    "entry-key": Key;
+  };
+}
+
+interface AllData {
+  "all": Settings;
+}
+
+interface BucketData {
+  "bucket": Bucket;
+}
+
+interface EntryData {
+  "entry": Value;
+}
+
+export type SettingsUpdate =
+  | PutBucket
+  | DelBucket
+  | PutEntry
+  | DelEntry;
+
+export type SettingsData =
+  | AllData
+  | BucketData
+  | EntryData;

pkg/interface/src/views/App.js

@@ -94,6 +94,7 @@ class App extends React.Component {
       this.updateTheme(this.themeWatcher);
     }, 500);
     this.api.local.getBaseHash();
+    this.api.settings.getAll();
     this.store.rehydrate();
     Mousetrap.bindGlobal(['command+/', 'ctrl+/'], (e) => {
       e.preventDefault();