#130 - Delete records from 'mdl_logstore_xapi_log' after successfully sent them to LRS

classes/log/store.php

@@ -150,10 +150,12 @@ public function process_events(array $events) {
         $sentevents = [];
         foreach ($eventbatches as $translatoreventsbatch) {
             $xapievents = $xapicontroller->create_events($translatoreventsbatch);
-            foreach (array_keys($xapievents) as $key) {
+            $statements = $xapievents['statements'];
+            $response = $xapievents['response'];
+            foreach (array_keys($statements) as $key) {
                 if (is_numeric($key)) {
-                    $k = $xapievents[$key]['context']['extensions'][$translatoreventreadreturn[0]['context_ext_key']]['id'];
-                    $sentevents[$k] = $xapievents['last_action_result'];
+                    $k = $statements[$key]['context']['extensions'][$translatoreventreadreturn[0]['context_ext_key']]['id'];
+                    $sentevents[$k] = $this->getlast_action_result($response);
                 }
             }
             $this->error_log_value('xapievents', $xapievents);
@@ -162,6 +164,19 @@ public function process_events(array $events) {
         return $sentevents;
     }
 
+    /**
+     * Get last action result from Learning Locker.
+     * @param Object TinCan\LRSResponse
+     *
+     */
+    private function getlast_action_result($response) {
+        if ($response->success == 1) {
+            return "success";
+        } else {
+            return "failure";
+        }
+    }
+
     private function error_log_value($key, $value) {
         $this->error_log('['.$key.'] '.json_encode($value));
     }

classes/task/emit_task.php

@@ -53,6 +53,7 @@ public function execute() {
         foreach (array_keys($storereturn) as $eventid) {
             if ($storereturn[$eventid] == 'success') {
                 $DB->delete_records_list('logstore_xapi_log', 'id', array($eventid));
+                mtrace("Event id ".$eventid." has been successfully sent to LRS.");
             }
         }