<?php
// $Id: user_relationship_migrate.mysql,v 1.1.2.4 2007-12-21 09:47:23 sprsquish Exp $

/**
 * Migrate pending relationships
 */
function user_relationship_migrate_pending() {
  $next_id = db_next_id('{user_relationships}_id');
  db_query('LOCK TABLE {user_relationships} WRITE, {buddylist_pending_requests} READ');
  db_query("SET @rid = %d", $next_id);
  db_query(
    "INSERT INTO {user_relationships} (rid, rtid, requester_id, requestee_id, approved, created_at)
     SELECT (@rid := @rid+1), %d, requester_uid, requestee_uid, 0, %d FROM {buddylist_pending_requests}",
     $rtid, time()
  );
  db_query('UNLOCK TABLES');

  _user_relationship_set_next_id(db_result(db_query("SELECT MAX(rid) FROM {user_relationships}")));

  return TRUE;
}


/**
 * Migrate pending relationships
 */
function user_relationship_migrate_email_preferences() {
  db_query('LOCK TABLE {users} WRITE');
  db_query('UPDATE {users} SET data = REPLACE(data, \'"buddylist_mail"\', \'"user_relationship_mailer_send_mail"\');');
  db_query('UNLOCK TABLES');

  return TRUE;
}


/**
 * Helper function to run the actual transactions
 */
function _user_relationship_migrate_run($rtid) {
  db_query('LOCK TABLES {buddylist} READ, {user_relationships} WRITE');
  db_query('CREATE TEMPORARY TABLE {user_relationship_migration} LIKE {user_relationships}');
  db_query('SET @rid = 0');

  db_query(
    "INSERT IGNORE INTO {user_relationship_migration} (rid, rtid, requester_id, requestee_id, created_at, updated_at, approved) 
     SELECT @rid:=@rid+1, %d, IF( uid > buddy, uid, buddy ) AS uid, IF( uid < buddy, uid, buddy ) AS buddy, timestamp, %d, 1 
     FROM {buddylist}",
    $rtid, time()
  );

  db_query(
    'INSERT INTO {user_relationships} (rid, rtid, requester_id, requestee_id, created_at, updated_at, approved) 
      SELECT rid, rtid, requester_id, requestee_id, created_at, updated_at, approved FROM {user_relationship_migration}'
  );

  db_query(
    'INSERT INTO {user_relationships} (rid, rtid, requester_id, requestee_id, created_at, updated_at, approved) 
      SELECT rid, rtid, requestee_id, requester_id, created_at, updated_at, approved FROM {user_relationship_migration}'
  );

  _user_relationship_set_next_id(db_result(db_query("SELECT MAX(rid) FROM {user_relationships}")));

  db_query('DROP TABLE {user_relationship_migration}');
  db_query('UNLOCK TABLES');

  return TRUE;
}

function _user_relationship_set_next_id($id) {
  $name = db_prefix_tables('{user_relationships}_id');
  db_query('LOCK TABLES {sequences} WRITE');
  db_query("REPLACE INTO {sequences} VALUES ('%s', %d)", $name, $id);
  db_query('UNLOCK TABLES');
}