From cfe98e6eef5ca24b5c2656fcda8e3fac71d55a1d Mon Sep 17 00:00:00 2001
From: Jules Laplace <julescarbon@gmail.com>
Date: Mon, 4 Jun 2018 22:19:11 +0200
Subject: going over all this task stuff

---
 app/client/modules/samplernn/samplernn.actions.js | 15 ---------------
 app/client/queue/queue.reducer.js                 |  2 +-
 app/client/socket/socket.task.js                  | 16 ++++++++++++++++
 3 files changed, 17 insertions(+), 16 deletions(-)

(limited to 'app/client')

diff --git a/app/client/modules/samplernn/samplernn.actions.js b/app/client/modules/samplernn/samplernn.actions.js
index c196cc5..ef3e417 100644
--- a/app/client/modules/samplernn/samplernn.actions.js
+++ b/app/client/modules/samplernn/samplernn.actions.js
@@ -282,18 +282,3 @@ export const fetch_url = (url) => (dispatch) => {
     opt: { url }
   }, { preempt: true, watch: true })
 }
-
-export const train_task_now = (dataset, epochs=1) => (dispatch) => {
-  const task = {
-    module: 'samplernn',
-    activity: 'train',
-    dataset: dataset,
-    epochs: epochs,
-    opt: {
-      sample_length: 44100 * 5,
-      n_samples: 6,
-      keep_old_checkpoints: false,
-    }
-  }
-  return actions.queue.add_task(task)
-}
\ No newline at end of file
diff --git a/app/client/queue/queue.reducer.js b/app/client/queue/queue.reducer.js
index 02d6943..05cd015 100644
--- a/app/client/queue/queue.reducer.js
+++ b/app/client/queue/queue.reducer.js
@@ -25,7 +25,7 @@ const queueReducer = (state = queueInitialState, action) => {
         queue: state.queue.concat([action.data]),
       }
     case types.task.index:
-    console.log(action.data)
+      console.log(action.data)
       return {
         ...state,
         tasks: action.data.reduce((a,b) => (a[b.id] = b, a), {}),
diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js
index 595066e..2f3c65a 100644
--- a/app/client/socket/socket.task.js
+++ b/app/client/socket/socket.task.js
@@ -47,6 +47,22 @@ socket.on('task_res', (data) => {
   }
 })
 
+export function add_task(task, opt={}) {
+  socket.emit('task', {
+    type: 'add',
+    task,
+    ...opt,
+  })
+}
+
+export function remove_task(task, opt={}) {
+  socket.emit('task', {
+    type: 'remove',
+    task,
+    ...opt,
+  })
+}
+
 export function start_task(task, opt={}) {
   socket.emit('task', {
     type: 'start',
-- 
cgit v1.2.3-70-g09d2