Added utilities functions to manage a queue to import data into datastore from...

Added utilities functions to manage a queue to import data into datastore from endpoints #CIVIC-3123

dkan_datastore.module

@@ -533,3 +533,42 @@ function dkan_datastore_node_presave($node) {
     $wrap->field_datastore_status->set(dkan_datastore_status($node));
   }
 }
+<<<<<<< HEAD
+=======
+
+/**
+ * Implements hook_cron_queue_info().
+ */
+function dkan_datastore_cron_queue_info() {
+  $queues['dkan_datastore_queue'] = array(
+     'worker callback' => 'dkan_datastore_queue_import_worker',
+     'time' => 120,
+     'skip on cron' => FALSE,
+  );
+
+  return $queues;
+}
+
+/**
+ * Utility function for add a new resource to datastore queue.
+ */
+function dkan_datastore_queue_import($uuid, $fid) {
+  $item = array(
+    'uuid' => $uuid,
+    'fid' => $fid
+  );
+  DrupalQueue::get('dkan_datastore_queue')->createItem($item);
+  watchdog('dkan_datastore', t('Added %file to queue for import into datastore', array('%file' => $fid)));
+}
+
+/**
+ * Callback used with queue for index content into datastore.
+ */
+function dkan_datastore_queue_import_worker($item) {
+  $file = file_load($item['fid']);
+  $uri = $file->uri;
+  $file_path = file_create_url($uri);
+  $datastore = dkan_datastore_go($item['uuid']);
+  $datastore->updateByFile($file_path);
+}
+>>>>>>> Added utilities functions to manage a queue to import data into datastore from endpoints #CIVIC-3123