Fixing logic for the preview iframe

adding config object for Twitter API configuration
adding form for Twitter API configuration

config/schema/statusmessage.schema.yml

@@ -0,0 +1,16 @@
+twitter_api.config:
+  type: config_object
+  label: 'Credentials to authenticate with Twitter API'
+  mapping:
+    oauth_access_token:
+          type: text
+          label: 'Access Token'
+    oauth_access_token_secret:
+          type: text
+          label: 'Access Token Secret'
+    consumer_key:
+          type: text
+          label: 'Consumer key'
+    consumer_secret:
+          type: text
+          label: 'Consumer secret'

includes/statusmessage.twit.inc

@@ -0,0 +1,10 @@
+<?php
+
+/*
+ * Consumer Key (API Key)	R8AjTzTSeCIHg72sDElMOzxYU
+ * Consumer Secret (API Secret)	tTA5tyFUNncY97pFELWMH3mFux8NXGhMDQl8hFQFXqvaLDxBiV
+ */
+
+
+
+

includes/twit.php

@@ -0,0 +1,613 @@
+<?php
+
+require_once(DRUPAL_ROOT . '/sites/all/libraries/twitter-api-php/TwitterAPIExchange.php');
+
+function twit_submit_libraries_info() {
+
+    $libraries['twitter-api-php'] = array(
+        'name' => 'Twitter API Exchange',
+        'vendor url' => 'https://github.com/J7mbo/twitter-api-php',
+        'files' => array(
+            'php' => array('TwitterAPIExchange.php'), //this can be a path to the file location like array('lib/simple.js')
+        ),
+    );
+
+    return $libraries;
+}
+
+/**
+*Add new hashtag to taxonomy as hashtag vocabulary type
+*/
+function twit_submit_block_taxonomy_add($term) {
+  $taxTerm = new stdClass();
+  $taxTerm->name = $term;
+  $taxTerm->vid = 6;
+  taxonomy_term_save($taxTerm);
+  return $taxTerm->tid;
+}
+
+/**
+*Check to see if hashtag is already in taxonomy before adding
+*/
+function twit_submit_block_taxonomy_check($term)  {
+  $query = db_select('taxonomy_term_data', 'ttd')
+    ->fields('ttd', array('tid', 'name'))
+    ->condition('ttd.name', $term->text);
+  $query = db_query('SELECT tid FROM taxonomy_term_data WHERE name = :name', array(
+    ':name' => $term->text)
+  );
+  if ($query->rowCount() >= 2) {
+    dpm($query->rowCount());
+    $result = $query->fetchObject();
+    dpm($result);
+    $tid = $result->tid;
+  } else {
+    $tid = twit_submit_block_taxonomy_add($term->text);
+  }
+  return $tid;
+}
+
+/**
+*Update tracking of hashtag trends
+*/
+function twithash_block_update($hashArray, $unixtime, $uid, $ip, $tweetId = NULL, $location = NULL) {
+  $tmid = null;
+  if ($location == NULL) {
+    if ($ip == '127.0.0.1') {
+      $geo = 1;
+    } else {
+      $geo = 1;
+    }//Handling of non-local IPs to be added later
+  } else {
+    $checkLocQuery = db_query(
+      ' SELECT id FROM twithash_geo
+        WHERE country = :country
+        AND city = :city
+        AND region = :region',
+        array(
+          ':country' => 'Canada',
+          ':city' => $location->city,
+          ':region' => $location->province,
+        )
+    );
+    $locResult = $checkLocQuery->fetchAll();
+    if ($checkLocQuery->rowCount() > 0) {
+      $geo = $locResult[0]->id;
+    } else {
+      $locInsert = db_insert('twithash_geo')
+                      ->fields(array(
+                        'country' => 'Canada',
+                        'city' => $location->city,
+                        'region' => $location->province,
+                      ));
+      $locId = $locInsert->execute();
+
+      if ($locId != NULL && $locId > 0) {
+        $geo = $locId;
+      }
+    }
+  }
+  $count = count($hashArray);
+  //Populate twithash_term table with new terms or update number of hits for recurring terms. Simultaneously update twithash_term_update table which
+  //tracks specific dates for each time a given term is searched.
+  for ($i = 0; $i<$count; $i++)  {
+    $keyword = $hashArray[$i];
+
+    $transaction = db_transaction();
+    try{
+      $tID = db_query('insert into twithash_term (term, hits, start) values (:term, 1, :start) on DUPLICATE KEY UPDATE hits = hits + :hits',
+        array(
+          ':term'  => $keyword,
+          ':start'  =>  $unixtime,
+          ':hits' => 1
+        ),
+        array('return' => Database::RETURN_INSERT_ID));
+        //Insert IDs are collected for use in the query_master table, which tracks which different terms were compared up to a maximum
+        //of 5 terms (the maximum allowed by Google Trends)
+        if ($tID != 0)
+        db_insert('twithash_term_update')
+          ->fields(array(
+            't_id'  =>  $tID,
+            'hit_time'  =>  $unixtime
+          ))
+          ->execute();
+          $tIDs[] = $tID;
+    }
+    catch (Exception $e) {
+    $transaction->rollback();
+    throw $e;
+    }
+  }
+
+    $numTerms = isset($tIDs) ? count($tIDs) : 0;//Get number of terms in query
+    switch ($numTerms)  {//add overall query to twithash_master
+      case 0:
+      break;
+      case 1:
+        $tmid = db_query('
+        INSERT INTO twithash_master (uid, query_date, geo, source, tid_1) VALUES (:uid, :query_date, :geo, :source, :tid_1)',
+          array(
+            ':uid'  => $uid,
+            ':query_date'  =>  $unixtime,
+            ':geo'  => $geo,
+            ':source' => 1,
+            ':tid_1'  =>  $tIDs[0]
+          ),
+        array('return' => Database::RETURN_INSERT_ID));
+      break;
+      case 2:
+        $tmid = db_query('insert into twithash_master (uid, query_date, geo, source, tid_1, tid_2) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2)',
+          array(
+            ':uid'  => $uid,
+            ':query_date'  =>  $unixtime,
+            ':geo'  => $geo,
+            ':source' => 1,
+            ':tid_1'  =>  $tIDs[0],
+            ':tid_2'  =>  $tIDs[1]
+          ),
+        array('return' => Database::RETURN_INSERT_ID));
+      break;
+      case 3:
+        $tmid = db_query('insert into twithash_master (uid, query_date, geo, source, tid_1, tid_2, tid_3) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2, :tid_3)',
+          array(
+            ':uid'  => $uid,
+            ':query_date'  =>  $unixtime,
+            ':geo'  => $geo,
+            ':source' => 1,
+            ':tid_1'  =>  $tIDs[0],
+            ':tid_2'  =>  $tIDs[1],
+            ':tid_3'  =>  $tIDs[2]
+          ),
+        array('return' => Database::RETURN_INSERT_ID));
+      break;
+      case 4:
+        $tmid = db_query('insert into twithash_master (uid, query_date, geo, source, tid_1, tid_2, tid_3, tid_4) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2, :tid_3, :tid_4)',
+          array(
+            ':uid'  => $uid,
+            ':query_date'  =>  $unixtime,
+            ':geo'  => $geo,
+            ':source' => 1,
+            ':tid_1'  =>  $tIDs[0],
+            ':tid_2'  =>  $tIDs[1],
+            ':tid_3'  =>  $tIDs[2],
+            ':tid_4'  =>  $tIDs[3]
+          ),
+        array('return' => Database::RETURN_INSERT_ID));
+      break;
+      case 5:
+        $tmid = db_query('insert into twithash_master (uid, query_date, geo, source, tid_1, tid_2, tid_3, tid_4, tid_5) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2, :tid_3, :tid_4, :tid_5)',
+          array(
+            ':uid'  => $uid,
+            ':query_date'  =>  $unixtime,
+            ':geo'  => $geo,
+            ':source' => 1,
+            ':tid_1'  =>  $tIDs[0],
+            ':tid_2'  =>  $tIDs[1],
+            ':tid_3'  =>  $tIDs[2],
+            ':tid_4'  =>  $tIDs[3],
+            ':tid_5'  =>  $tIDs[4]
+          ),
+        array('return' => Database::RETURN_INSERT_ID));
+      break;
+    }
+
+    if ($tweetId != NULL && $tmid != NULL) {
+      $tweetIdQuery = db_insert('twithash_tid')
+        ->fields(array(
+          'tweetId' => $tweetId,
+          'thmid' => $tmid))
+        ->execute();
+    }
+    return $tmid;
+}
+
+/**
+*Provide simple form for visitor to submit tweets
+*/
+function twit_submit_block_form() {
+  $form = array();
+  $form['twit_fieldset'] = array(
+    '#type' => 'fieldset',
+    '#title' => t('SUBMIT TWEET'),
+    '#prefix' => '<div id="terms-fieldset-wrapper">',
+    '#suffix' => '</div>',
+    '#collapsible' => TRUE,
+    '#collapsed' => TRUE,
+    '#ajax' => array(
+      'callback' => 'twit_submit_block_submit_callback',
+    )
+//    '#attributes' => array('onkeypress' => 'if(event.keyCode==13){ this.form.submit;}'),
+  );
+  $form['twit_fieldset']['tweet'] = array(
+    '#type' => 'textarea',
+    '#title' => t('Tweet'),
+    '#description' => t('Please enter Tweet URL'),
+    '#maxlength' => 80,
+    '#size' => 25,
+    '#attributes' => array('onchange' => 'tweetCheck(this.form.tweet.value)',),
+
+  );
+
+  $form['twit_fieldset']['submit'] = array(
+    '#type' => 'submit',
+    '#value' => 'Submit',
+    '#id' => 'twitSubmitBtn',
+    '#ajax' => array(
+        'callback' => 'twit_submit_block_submit_callback',
+      )
+  );
+
+  $form['twit-notification'] = array(
+    '#prefix' => '<div id="twit-notification">',
+    '#suffix' => '</div>',
+  );
+  $form['twit-check'] = array(
+    '#prefix' => '<div id="twit-check">',
+    '#suffix' => '</div>',
+  );
+
+  $form['#attached']['js'][] = array(
+    'type' => 'inline',
+    'data' => drupal_get_path('module', 'twit_submit') . '/twit_submit.js',
+    'type' => 'file',
+  );
+
+
+  return $form;
+}
+
+/**
+*Form submit handler
+*/
+
+function twit_submit_form_submit($form, &$form_state) {
+    twit_submit_block_submit_callback($form, $form_state);
+}
+
+function twit_submit_block_submit_callback($form, &$form_state)  {
+  $form_state['rebuild'] = TRUE;
+  //define Tokens for REST API request
+  $settings = array(
+      'oauth_access_token' => "181287687-FNQLOpVXocD3gP46souGOj4FY1kMPlDzNw795MwQ",
+      'oauth_access_token_secret' => "w9KuI6T44w2HX6P8OCcOUDePHdyT6l0iGRCljKuZF9AE9",
+      'consumer_key' => "GULWdbfgUBicLUxEAD5a6KeE6",
+      'consumer_secret' => "6ereWWc9nkTZCS0TtgCDfW4tcTO3E5Wy5LW1kXk8qSrxL2YBAD"
+  );
+  //Acquire tweet ID
+  $tweetSubmit = $form_state['values']['tweet'];
+  $tweetIdArr = explode('status/', $tweetSubmit);
+  $tweetId = $tweetIdArr[1];
+  if ($tweetId == null) {
+      return null;
+  }
+  $url = 'https://api.twitter.com/1.1/statuses/show.json';
+  $getfield = '?id='.$tweetId.'&tweet_mode=extended';
+  $requestMethod = 'GET';
+
+  $twitter = new TwitterAPIExchange($settings);
+  $response = $twitter->setGetfield($getfield)
+      ->buildOauth($url, $requestMethod)
+      ->performRequest();
+  //Decode request
+  $tresponse_decoded = json_decode($response);
+  dpm($tresponse_decoded);
+
+  //Create datetime object for title, media file path and content date field
+  $nowtime = new DateTime();
+  $unixtime = $nowtime->getTimestamp();
+  $today = date("m.d.y");
+  //Get screen name for title, media file path and content screen name field
+  $twit_user = $tresponse_decoded->user->screen_name;
+  //Check access level of user submitting tweet
+  global $user;
+  $ip = $user->data['geoip_location']['ip_address'];//get user's IP
+  $uid = $user->uid;
+  //Handler to optionally disable publishing of tweets based on access level
+  if (in_array('content administrator', $user->roles) || in_array('administrator', $user->roles))  {
+    $articleStatus = 1;
+    $articlePromote = 0;
+  }else{
+    $articleStatus = 1;
+    $articlePromote = 0;
+  }
+  //Prepare node object
+  $node = new stdClass();
+  $node->type = 'tweet';
+  $node->language = LANGUAGE_NONE;
+  node_object_prepare($node);
+  //Define node title
+  $node->title = $twit_user . '_' . $nowtime->format('Y.m.d.Hi');
+  //Set basic node data: language, status, promoted, uid, posted/created date and tweet ID
+  $node->body[$node->language][0]['value'] = $tresponse_decoded->full_text;
+  $node->body[$node->language][0]['format'] = 'filtered_html';
+  $node->status = $articleStatus;
+  $node->promote = $articlePromote;
+  $node->workbench_access = array('twitcher_tweet' => 'twitcher_tweet');
+  $node->uid = $uid;
+  $node->date = date('Y-m-d');//***!This should be changed to previous date variable
+  $node->created = time();
+  $node->field_tweet_id[$node->language][0]['value'] = $tresponse_decoded->id;
+  //Get hashtags, populate taxonomy and set content type to tid
+  $hashArray = array();
+  $i = 0;
+  foreach($tresponse_decoded->entities->hashtags as $key => $h) {
+    $hashArray[] = $h->text;
+    $tid = twit_submit_block_taxonomy_check($h);
+    $node->field_hashtag[$node->language][$i]['tid'] = $tid;
+    $i++;
+  }
+  $twithashUpdate = twithash_block_update($hashArray, $unixtime, $uid, $ip, $tresponse_decoded->id);
+  if (!empty($tresponse_decoded->entities->user_mentions)) {
+    $userArray = array();
+
+    foreach($tresponse_decoded->entities->user_mentions as $userName) {
+      $userArray[] = $userName->screen_name;
+    }
+    $twitUserUpdate = twituser_block_update($userArray, $unixtime, $uid, $ip, $tresponse_decoded->id);
+  }
+  //Set content's link field to urls as displayed within the tweet
+  $i = 0;
+  if (!empty($tresponse_decoded->entities->urls)) {
+    foreach ($tresponse_decoded->entities->urls as $url)  {
+      $node->field_tweet_links[$node->language][$i]['value'] = $tresponse_decoded->entities->urls[$i]->display_url;
+      $i++;
+    }
+  }
+  if (!empty($tresponse_decoded->user->profile_image_url_https)) {
+      $node->field_profile_pic[$node->language][0]['value'] = $tresponse_decoded->user->profile_image_url_https;
+  }
+  //Check for attached media and create a directory for saving
+  if (isset($tresponse_decoded->extended_entities->media)) {
+    if (!is_dir(DRUPAL_ROOT . '/sites/default/files/Tweet_Media/' . $today))  {
+      mkdir(DRUPAL_ROOT . '/sites/default/files/Tweet_Media/' . $today);
+    }
+    //Save each media entity with a unique filename within directory
+    $i = 0;
+    foreach($tresponse_decoded->extended_entities->media as $media)  {
+      $ext = substr($media->media_url, -3);
+      $filename = 'public://Tweet_Media/' . $today . '/' . $twit_user . $unixtime . $i . '.' . $ext;
+      file_put_contents($filename, file_get_contents($media->media_url));
+      //Download file and save to Drupal filesystem
+      $image = file_get_contents($media->media_url);
+      $file = file_save_data($image, $filename,FILE_EXISTS_REPLACE);
+      //Associate file with content image field
+      $node->field_tweet_images[$node->language][$i] = array(
+          'fid' => $file->fid,
+          'filename' => $file->filename,
+          'filemime' => $file->filemime,
+          'uid' => 1,
+          'uri' => $file->uri,
+          'status' => 1
+      );
+      $i++;
+    }
+    if(!empty($tresponse_decoded->extended_entities->media[0]->video_info->variants)) {
+      $z = null;
+      $vidUrl = null;
+      $bitrate = new stdClass();
+      $bitrate->value = null;
+      $bitrate->index = null;
+
+      for ($z = 0; $z < $tresponse_decoded->extended_entities->media[0]->video_info->variants; $z++) {
+        if (!empty($tresponse_decoded->extended_entities->media[0]->video_info->variants[$z]->bitrate) &&
+          $tresponse_decoded->extended_entities->media[0]->video_info->variants[$z]->content_type === 'video/mp4') {
+          if ($tresponse_decoded->extended_entities->media[0]->video_info->variants[$z]->bitrate > $bitrate->value) {
+            $bitrate->value = $tresponse_decoded->extended_entities->media[0]->video_info->variants[$z]->bitrate;
+            $bitrate->index = $z;
+          }
+        }
+      }
+
+      if ($bitrate->index !== null) {
+        $vidUrl = $tresponse_decoded->extended_entities->media[0]->video_info->variants[$bitrate->index]->url;
+      }
+
+        $destination = 'public://Tweet_Media/' . $today;
+
+        if ($vFile = system_retrieve_file($vidUrl, $destination, TRUE, FILE_EXISTS_REPLACE)) {
+            $node->field_tweet_video[$node->language][0]['value'] = $vFile->uri;
+        }
+    }
+  }
+  //Set content screen name, date and tweet url
+  $node->field_screen_name[$node->language][0]['value'] = $twit_user;
+  $node->field_tweet_date[$node->language][0]['value'] = $unixtime;
+  $node->field_tweet_date[$node->language][0]['timezone'] = 'America/New_York';
+  $node->field_tweet_date[$node->language][0]['data_type'] = 'datestamp';
+  $node->field_tweet_url[$node->language][0]['value'] = $tweetSubmit;
+  //Set the node path and save
+  $path = 'tweet/' . $tweetId;
+  $node->path = array('alias' => $path);
+  // if(node_save($node))  {
+  //   $commands[] = ajax_command_html('#twit-notification', 'Tweet submitted to Twitcher!');
+  // }else{
+  //
+  //   $commands[] = ajax_command_html('#twit-notification', 'Tweet could not be saved.');
+  // }
+
+  try {
+    node_save($node);
+    $commands[] = ajax_command_css('#twit-notification', array("display" => "block"));
+    $commands[] = ajax_command_html('#twit-notification', 'Tweet submitted to Twitcher!');
+  }catch(Exception $e)  {
+    dpm($e->getMessage());
+    $commands[] = ajax_command_css('#twit-notification', array("display" => "block"));
+    $commands[] = ajax_command_html('#twit-notification', 'Tweet could not be saved.');
+  }
+
+  $commands[] = ajax_command_invoke('#edit-tweet', 'val', array(''));
+  // $commands[] = ajax_command_invoke('#twit-notification', 'addClass', array('twit-active'));
+  $commands[] = ajax_command_invoke('#twit-notification', 'delay', array(3000));
+  $commands[] = ajax_command_invoke('#twit-notification', 'fadeOut', array('slow'));
+
+
+  return array('#type' => 'ajax', '#commands' => $commands);
+}
+
+/*
+ * Implements hook_block_info()
+*/
+/**
+ * @return mixed
+ */
+function twit_submit_block_info() {
+  $blocks['twit_submit'] = array(
+    'info' => t('Submit tweet as article/node!'),
+  );
+
+  return $blocks;
+}
+
+/*
+ * Implements hook_block_view()
+*/
+/**
+ * @param $delta
+ * @return array
+ */
+function twit_submit_block_view($delta) {
+  $block = array();
+  $twit_form = drupal_get_form('twit_submit_block_form');
+
+  switch ($delta) {
+    case 'twit_submit':
+      $block['subject'] = t('Widget to submit tweets and save as node');
+      $block['content'] = drupal_render($twit_form);
+      break;
+  }
+  return $block;
+}
+
+
+/**
+ * @param $userArray
+ * @param $unixtime
+ * @param $uid
+ * @param $ip
+ * @param null $tweetId
+ * @param null $location
+ * @return DatabaseStatementInterface|int|null
+ * @throws Exception
+ */
+function twituser_block_update($userArray, $unixtime, $uid, $ip, $tweetId = NULL, $location = NULL) {
+  $tumid = null;
+  // watchdog('twituser', var_dump($userArray));
+  if ($ip == '127.0.0.1' && $location == NULL) {
+    $geo = 1;
+  } else {
+    $location = smart_ip_get_location($ip);
+    $geo = 1;
+  }//Handling of non-local IPs to be added later
+  $count = count($userArray);
+  //Populate twithash_term table with new terms or update number of hits for recurring terms. Simultaneously update twithash_term_update table which
+  //tracks specific dates for each time a given term is searched.
+  for ($i = 0; $i<$count; $i++)  {
+    $userName = $userArray[$i];
+
+    $transaction = db_transaction();
+    try{
+      $tID = db_query('insert into twituser_name (name, hits, start) values (:name, 1, :start) on DUPLICATE KEY UPDATE hits = hits + :hits',
+        array(
+          ':name'  => $userName,
+          ':start'  =>  $unixtime,
+          ':hits' => 1
+        ),
+        array('return' => Database::RETURN_INSERT_ID));
+        //Insert IDs are collected for use in the query_master table, which tracks which different terms were compared up to a maximum
+        //of 5 terms (the maximum allowed by Google Trends)
+        if ($tID != 0)
+        db_insert('twituser_name_update')
+          ->fields(array(
+            't_id'  =>  $tID,
+            'hit_time'  =>  $unixtime
+          ))
+          ->execute();
+          $tIDs[] = $tID;
+    }
+    catch (Exception $e) {
+      $transaction->rollback();
+    throw $e;
+    }
+  }
+  $numTerms = isset($tIDs) ? count($tIDs) : 0;//Get number of terms in query
+  switch ($numTerms)  {//add overall query to twithash_master
+    case 0:
+    break;
+    case 1:
+      $tumid = db_query('insert into twituser_master (uid, query_date, geo, source, tid_1) values (:uid, :query_date, :geo, :source, :tid_1)',
+        array(
+          ':uid'  => $uid,
+          ':query_date'  =>  $unixtime,
+          ':geo'  => $geo,
+          ':source' => 1,
+          ':tid_1'  =>  $tIDs[0]
+        ),
+        array('return' => Database::RETURN_INSERT_ID));
+    break;
+    case 2:
+      $tumid = db_query('insert into twituser_master (uid, query_date, geo, source, tid_1, tid_2) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2)',
+        array(
+          ':uid'  => $uid,
+          ':query_date'  =>  $unixtime,
+          ':geo'  => $geo,
+          ':source' => 1,
+          ':tid_1'  =>  $tIDs[0],
+          ':tid_2'  =>  $tIDs[1]
+        ),
+      array('return' => Database::RETURN_INSERT_ID));
+    break;
+    case 3:
+      $tumid = db_query('insert into twituser_master (uid, query_date, geo, source, tid_1, tid_2, tid_3) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2, :tid_3)',
+        array(
+          ':uid'  => $uid,
+          ':query_date'  =>  $unixtime,
+          ':geo'  => $geo,
+          ':source' => 1,
+          ':tid_1'  =>  $tIDs[0],
+          ':tid_2'  =>  $tIDs[1],
+          ':tid_3'  =>  $tIDs[2]
+        ),
+        array('return' => Database::RETURN_INSERT_ID));
+    break;
+    case 4:
+      $tumid = db_query('insert into twituser_master (uid, query_date, geo, source, tid_1, tid_2, tid_3, tid_4) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2, :tid_3, :tid_4)',
+        array(
+          ':uid'  => $uid,
+          ':query_date'  =>  $unixtime,
+          ':geo'  => $geo,
+          ':source' => 1,
+          ':tid_1'  =>  $tIDs[0],
+          ':tid_2'  =>  $tIDs[1],
+          ':tid_3'  =>  $tIDs[2],
+          ':tid_4'  =>  $tIDs[3]
+        ),
+      array('return' => Database::RETURN_INSERT_ID));
+    break;
+    case 5:
+      $tumid = db_query('insert into twituser_master (uid, query_date, geo, source, tid_1, tid_2, tid_3, tid_4, tid_5) values (:uid, :query_date, :geo, :source, :tid_1, :tid_2, :tid_3, :tid_4, :tid_5)',
+        array(
+          ':uid'  => $uid,
+          ':query_date'  =>  $unixtime,
+          ':geo'  => $geo,
+          ':source' => 1,
+          ':tid_1'  =>  $tIDs[0],
+          ':tid_2'  =>  $tIDs[1],
+          ':tid_3'  =>  $tIDs[2],
+          ':tid_4'  =>  $tIDs[3],
+          ':tid_5'  =>  $tIDs[4]
+        ),
+      array('return' => Database::RETURN_INSERT_ID));
+    break;
+  }
+
+
+  if ($tweetId != NULL && $tumid != NULL) {
+    $tweetIdQuery = db_insert('twituser_tid')
+      ->fields(array(
+        'tweetId' => $tweetId,
+        'tumid' => $tumid))
+      ->execute();
+  }
+
+  return $tumid > 0 ? $tumid : -1;
+}

js/statusmessage.js

@@ -8,72 +8,87 @@
       Drupal.AjaxCommands.prototype.generatePreview = function(ajax, response, status) {
 
         if (validateUrl(response.url)) {
-          console.dir(response);
-        }
-        var cleanUrl = response.url.replace(/^http(s?):\/\//i, "");
-        // console.log(cleanUrl);
-        $.ajax({
-          type:'POST',
-          url:'/statusmessage/generate-preview/' + cleanUrl,
-          success: function(response) {
-
-            // console.log(response.data);
-            if (response.data != null) {
-              var parser = new DOMParser();
-              var doc = parser.parseFromString(response.data, "text/html");
-
-              var imgs = doc.querySelectorAll('img')
-              var metaTags = doc.querySelectorAll('meta');
-              var title = doc.querySelector('title');
-              var markup;
-              var description;
-              var previewImage;
-
-              imgs.forEach(function (img) {
-                var imgClasses = img.classList;
-                if (imgClasses.value !== null && imgClasses.value.length > 0) {
-                  if (imgClasses.value.includes('logo')) {
-                    previewImage = img;
-                  }
-                }
-                if (previewImage !== null) {
-                }
-              });
 
+          var cleanUrl = response.url.replace(/^http(s?):\/\//i, "");
+          // console.log(cleanUrl);
+          $.ajax({
+            type: 'POST',
+            url: '/statusmessage/generate-preview/' + cleanUrl,
+            success: function (response) {
 
-              metaTags.forEach(function (metaTag) {
-                if (metaTag.name == 'description') {
-                  description = metaTag.content;
+              // console.log(response.data);
+              if (response.data != null) {
+                var parser = new DOMParser();
+                var doc = parser.parseFromString(response.data, "text/html");
 
-                }
-              });
+                var markup = buildPreview(doc);
+
+                var statusBlock = document.getElementById('block-statusblock');
+                var oldPreviewIframe = document.querySelector('.statusmessage-preview-iframe');
 
-              console.dir(description);
-              console.log(previewImage);
+                if (oldPreviewIframe !== null) {
+                  oldPreviewIframe.parentNode.removeChild(oldPreviewIframe);
 
-              markup = '<div id="statusmessage-preview"><h2> ' + title != null ? title.innerHTML : "No Title</h2>"
-                + description != null ? description.innerHTML : "No Description"
-                  + '<img src="' + previewImage != null ? previewImage.src + '" />' : 'google images />'
-                    + '</div>';
+                }
+                previewIframe = document.createElement('iframe');
+                previewIframe.classList.add('statusmessage-preview-iframe');
+                statusBlock.appendChild(previewIframe);
+                previewIframe.contentWindow.document.open();
+                previewIframe.contentWindow.document.appendChild(markup)
+                previewIframe.contentWindow.document.close();
+              }
+            }
+          });
+        }
+      };
 
-              console.dir(markup);
-              console.log(markup);
+      function validateUrl(input) {
+        return input.match(new RegExp("([a-zA-Z0-9]+://)?([a-zA-Z0-9_]+:[a-zA-Z0-9_]+@)?([a-zA-Z0-9.-]+\\.[A-Za-z]{2,4})(:[0-9]+)?(/.*)?"));
+      }
 
+      function buildPreview(doc) {
+        var imgs = doc.querySelectorAll('img');
+        var metaTags = doc.querySelectorAll('meta');
+        var title = doc.querySelector('title');
+        var markup;
+        var description;
+        var previewImage = null;
 
-              var statusBlock = document.getElementById('block-statusblock');
-              var previewIframe = document.createElement('iframe');
-              previewIframe.classList.add('statusmessage-preview-iframe');
-              statusBlock.appendChild(previewIframe);
-              previewIframe.contentWindow.document.open();
-              previewIframe.contentWindow.document.write(markup);
-              previewIframe.contentWindow.document.close();
+        imgs.forEach(function (img) {
+          if (previewImage === null) {
+            var imgClasses = img.classList;
+
+            if (imgClasses.value.toLowerCase().indexOf('logo') || img.alt.toLowerCase().indexOf('logo') || img.title.toLowerCase().indexOf('logo') || img.src.toLowerCase().indexOf('logo')) {
+              previewImage = img;
             }
           }
         });
-      };
 
-      function validateUrl(input) {
-        return input.match(new RegExp("([a-zA-Z0-9]+://)?([a-zA-Z0-9_]+:[a-zA-Z0-9_]+@)?([a-zA-Z0-9.-]+\\.[A-Za-z]{2,4})(:[0-9]+)?(/.*)?"));
+        metaTags.forEach(function (metaTag) {
+          if (metaTag.name == 'description') {
+            description = metaTag.content;
+
+          }
+        });
+
+        console.dir(description);
+        console.dir(previewImage.src);
+        var outer = document.createElement('div');
+        outer.className = 'statusmessage-preview';
+        var titlemarkup = document.createElement('h4');
+        titlemarkup.innerHTML = title.innerHTML;
+        var descmarkup = document.createElement('p');
+        descmarkup.innerText = description;
+        var imgmarkup = document.createElement('img');
+        imgmarkup.src = previewImage.src;
+
+
+        var wrapper = document.createElement('div');
+        wrapper.appendChild(titlemarkup);
+        wrapper.appendChild(descmarkup);
+        wrapper.appendChild(imgmarkup);
+
+        return wrapper;
       }
 
     }

src/Form/StatusForm.php

@@ -71,8 +71,12 @@ class StatusForm extends FormBase {
         'placeholder' => t('Post a status update'),
       ),
       '#ajax' => [
-        'event' => 'change',
-        'callback' => '::statusAjaxSubmit',
+        'event' => 'change, paste, keyup',
+        'callback' => '::generatePreview',
+        'progress' => array(
+          'type' => 'throbber',
+          'message' => t('Generating preview'),
+        ),
       ],
     );
 
@@ -138,14 +142,14 @@ $stophere = null;
    * @throws \InvalidArgumentException
    */
 
-  public function statusAjaxSubmit(array &$form, FormStateInterface $form_state) {
+  public function generatePreview(array &$form, FormStateInterface $form_state) {
 
     $message = $form_state->getValue('message');
 
     preg_match_all('#\bhttps?://[^,\s()<>]+(?:\([\w\d]+\)|([^,[:punct:]\s]|/))#', $message, $match);
 
 
-    if ($this->previewGenerator !== null && !empty($match) && array_values($match)[0]) {
+    if ($this->previewGenerator !== null && !empty($match) && array_values($match)[0] !== null) {
 
       $url = array_values($match)[0];
 
@@ -159,6 +163,44 @@ $stophere = null;
 
     }
 
+//    if (!empty($this->statusTypeService)) {
+//      foreach ($this->statusTypeService->loadAll() as $type) {
+//        if (!$type->getMedia()) {
+//
+//          $userViewed = \Drupal::routeMatch()->getParameters()->get('user') === null ? \Drupal::currentUser()->id() : \Drupal::routeMatch()->getParameters()->get('user')->id();
+//
+//          if ($userViewed !== null) {
+//
+//            $statusEntity = Status::create([
+//              'type' => $type->id(),
+//              'uid' => \Drupal::currentUser()->id(),
+//              'recipient' => $userViewed
+//            ]);
+//
+//            $statusEntity->setMessage($form_state->getValue('message'));
+//            $statusEntity->save();
+//
+//            if (\Drupal::service('module_handler')->moduleExists('heartbeat')) {
+//
+////              $configManager = \Drupal::service('config.manager');
+//              $feedConfig = \Drupal::config('heartbeat_feed.settings');
+////              $feedConfig = $feedConfig = $configManager->get('heartbeat_feed.settings');
+//              $response = new AjaxResponse();
+//              $response->addCommand(new SelectFeedCommand($feedConfig->get('message')));
+//
+//              return $response;
+//            }
+//            break;
+//          }
+//        }
+//      }
+//    }
+  }
+  public function statusAjaxSubmit(array &$form, FormStateInterface $form_state) {
+
+
+
+
     if (!empty($this->statusTypeService)) {
       foreach ($this->statusTypeService->loadAll() as $type) {
         if (!$type->getMedia()) {
@@ -192,43 +234,17 @@ $stophere = null;
       }
     }
   }
-  public function submitForm(array &$form, FormStateInterface $form_state) {
 
+  /**
+   * Form submission handler.
+   *
+   * @param array $form
+   *   An associative array containing the structure of the form.
+   * @param \Drupal\Core\Form\FormStateInterface $form_state
+   *   The current state of the form.
+   */
+  public function submitForm(array &$form, FormStateInterface $form_state) {
 
-//    $jigga = null;
-//
-//    if (!empty($this->statusTypeService)) {
-//      foreach ($this->statusTypeService->loadAll() as $type) {
-//        if (!$type->getMedia()) {
-//
-//          $userViewed = \Drupal::routeMatch()->getParameters()->get('user') === null ? \Drupal::currentUser()->id() : \Drupal::routeMatch()->getParameters()->get('user')->id();
-//
-//          if ($userViewed !== null) {
-//
-//            $statusEntity = Status::create([
-//              'type' => $type->id(),
-//              'uid' => \Drupal::currentUser()->id(),
-//              'recipient' => $userViewed
-//            ]);
-//
-//            $statusEntity->setMessage($form_state->getValue('message'));
-//            $statusEntity->save();
-//
-//            if (\Drupal::service('module_handler')->moduleExists('heartbeat')) {
-//
-////              $configManager = \Drupal::service('config.manager');
-//              $feedConfig = \Drupal::config('heartbeat_feed.settings');
-////              $feedConfig = $feedConfig = $configManager->get('heartbeat_feed.settings');
-//              $response = new AjaxResponse();
-//              $response->addCommand(new SelectFeedCommand($feedConfig->get('message')));
-//
-//              return $response;
-//            }
-//            break;
-//          }
-//        }
-//      }
-//    }
   }
 }
 

src/Form/TwitterApiForm.php

@@ -0,0 +1,120 @@
+<?php
+
+namespace Drupal\statusmessage\Form;
+
+use Drupal\Core\Form\FormBase;
+use Drupal\Core\Form\FormStateInterface;
+use Drupal\statusmessage\StatusTwitter;
+use Symfony\Component\DependencyInjection\ContainerInterface;
+use Drupal\Core\Config\ConfigFactory;
+
+/**
+ * Class TwitterApiForm.
+ *
+ * @package Drupal\statusmessage\Form
+ */
+class TwitterApiForm extends FormBase {
+
+  /**
+   * The configuration factory.
+   *
+   * @var \Drupal\Core\Config\ConfigFactoryInterface
+   */
+  protected $configFactory;
+
+  private $statusTwitter;
+  /**
+   * Constructs a new TwitterApiForm object.
+   */
+  public function __construct(ConfigFactory $config_factory) {
+    $this->configFactory = $config_factory;
+  }
+
+  public static function create(ContainerInterface $container) {
+    return new static(
+      $container->get('config.factory')
+    );
+  }
+
+
+  /**
+   * {@inheritdoc}
+   */
+  public function getFormId() {
+    return 'twitter_api_form';
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function buildForm(array $form, FormStateInterface $form_state) {
+
+    $form['oauth_access_token'] = [
+      '#type' => 'textfield',
+      '#title' => $this->t('Oauth Access Token'),
+//      '#description' => $this->t('Oauth Access Token'),
+      '#maxlength' => 64,
+      '#size' => 64,
+    ];
+    $form['oauth_access_token_secret'] = [
+      '#type' => 'textfield',
+      '#title' => $this->t('Oauth Access Token Secret'),
+//      '#description' => $this->t('Oauth Access Token Secret'),
+      '#maxlength' => 64,
+      '#size' => 64,
+    ];
+    $form['consumer_key'] = [
+      '#type' => 'textfield',
+      '#title' => $this->t('Consumer Key'),
+//      '#description' => $this->t('Consumer Key'),
+      '#maxlength' => 64,
+      '#size' => 64,
+    ];
+    $form['consumer_secret'] = [
+      '#type' => 'textfield',
+      '#title' => $this->t('Consumer Secret'),
+//      '#description' => $this->t('Consumer Secret'),
+      '#maxlength' => 64,
+      '#size' => 64,
+    ];
+
+    $form['submit'] = [
+      '#type' => 'submit',
+      '#value' => $this->t('Submit'),
+    ];
+
+    return $form;
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function validateForm(array &$form, FormStateInterface $form_state) {
+    parent::validateForm($form, $form_state);
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function submitForm(array &$form, FormStateInterface $form_state) {
+    // Display result.
+    foreach ($form_state->getValues() as $key => $value) {
+      drupal_set_message($key . ': ' . $value);
+    }
+
+    if ($this->statusTwitter === null) {
+      $this->statusTwitter = new StatusTwitter();
+    }
+
+    if ($form_state->getValue('oauth_access_token')) {
+
+      $twitterConfig = $this->configFactory->getEditable('twitter_api.settings');
+
+      $twitterConfig->set('consumer_key', $form_state->getValue('consumer_key'))->save();
+      $twitterConfig->set('consumer_secret', $form_state->getValue('consumer_secret'))->save();
+      $twitterConfig->set('oauth_access_token', $form_state->getValue('oauth_access_token'))->save();
+      $twitterConfig->set('oauth_access_token_secret', $form_state->getValue('oauth_access_token_secret'))->save();
+
+    }
+  }
+}

src/StatusTwitter.php

@@ -0,0 +1,85 @@
+<?php
+/**
+ * Created by IntelliJ IDEA.
+ * User: logicp
+ * Date: 6/9/17
+ * Time: 4:12 PM
+ */
+
+namespace Drupal\statusmessage;
+
+
+class StatusTwitter {
+
+  protected $oauthAccessToken;
+  protected $oauthAccessTokenSecret;
+  protected $consumerKey;
+  protected $consumerSecret;
+
+
+  public function __construct() {
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getConsumerSecret()
+  {
+    return $this->consumerSecret;
+  }
+
+  /**
+   * @param mixed $consumerSecret
+   */
+  public function setConsumerSecret($consumerSecret)
+  {
+    $this->consumerSecret = $consumerSecret;
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getConsumerKey()
+  {
+    return $this->consumerKey;
+  }
+
+  /**
+   * @param mixed $consumerKey
+   */
+  public function setConsumerKey($consumerKey)
+  {
+    $this->consumerKey = $consumerKey;
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getOauthAccessTokenSecret()
+  {
+    return $this->oauthAccessTokenSecret;
+  }
+
+  /**
+   * @param mixed $oauthAccessTokenSecret
+   */
+  public function setOauthAccessTokenSecret($oauthAccessTokenSecret) {
+    $this->oauthAccessTokenSecret = $oauthAccessTokenSecret;
+  }
+
+  /**
+   * @return mixed
+   */
+  public function getOauthAccessToken() {
+    return $this->oauthAccessToken;
+  }
+
+  /**
+   * @param mixed $oauthAccessToken
+   */
+  public function setOauthAccessToken($oauthAccessToken) {
+    $this->oauthAccessToken = $oauthAccessToken;
+  }
+
+
+}

statusmessage.links.action.yml

@@ -8,4 +8,8 @@ entity.status_type.add_form:
   title: 'Add Status type'
   appears_on:
     - entity.status_type.collection
-
+config.statusmessage.twitter_form:
+  route_name: 'statusmessage.twitter_api_form'
+  title: 'Configure Twitter API'
+  appears_on:
+    - config.statusmessage.twitter

statusmessage.links.menu.yml

@@ -14,3 +14,11 @@ entity.status_type.collection:
   parent: system.admin_structure
   weight: 99
 
+# Configuration for Twitter API OAUTH Authentication
+config.statusmessage.twitter:
+  title: Twitter API Settings
+  description: 'Configure Authentication tokens for Twitter API'
+  route_name: statusmessage.twitter_api_form
+  parent: system.admin_structure
+
+

statusmessage.routing.yml

@@ -23,3 +23,12 @@ statusmessage.status_preview_controller_generate_35:
     _title: 'Generate'
   requirements:
     _permission: 'access content'
+
+statusmessage.twitter_api_form:
+  path: '/statusmessage/form/twitter_api'
+  defaults:
+    _form: '\Drupal\statusmessage\Form\TwitterApiForm'
+    _title: 'TwitterApiForm'
+  requirements:
+    _access: 'TRUE'
+