first proper map execution

Author: Tale152

src/interconnected_node/contribution/mapreduce/jobs/MapWorkerJob.ts

@@ -18,8 +18,6 @@ export default class MapWorkerJob implements Job {
     console.log(
       'I am a MapWorker that has received the code:\n' + this.mapFunction
     );
-    console.log('executing the received code');
-    eval(this.mapFunction);
     return new Promise<void>((resolve) => {
       resolve();
     });
@@ -30,8 +28,12 @@ export default class MapWorkerJob implements Job {
   }
 
   enqueueTask(task: Task): Promise<boolean> {
-    console.log('MAP WORKER RECEIVED MAP TASK');
     return new Promise<boolean>((resolve) => {
+      task.execute(
+        { mapFunction: this.mapFunction },
+        () => console.log('COMPLETED MAP TASK'),
+        () => console.log('ERROR ON MAP TASK')
+      );
       resolve(true);
     });
   }

src/interconnected_node/contribution/mapreduce/tasks/MapReduceMapTask.ts

@@ -1,15 +1,22 @@
 import Task from '../../common/Task';
 
 export default class MapReduceMapTask implements Task {
+  private regionId: string;
+  private splits: Object[];
+
   constructor(params: any) {
-    //TODO implement
+    this.regionId = params.regionId;
+    this.splits = params.splits;
   }
 
   execute(
     jobParams: any,
     onCompletionCallback: () => void,
     onErrorCallback: () => void
   ): Promise<void> {
-    throw new Error('Method not implemented.');
+    const mapFunction = jobParams.mapFunction;
+    this.splits.forEach((s) => eval(mapFunction)(s));
+    onCompletionCallback();
+    return new Promise<void>((resolve) => resolve());
   }
 }