]> git.mxchange.org Git - friendica.git/commitdiff
uimport: fix file formatting
authorFabrixxm <fabrix.xm@gmail.com>
Tue, 2 Apr 2013 13:44:19 +0000 (09:44 -0400)
committerFabrixxm <fabrix.xm@gmail.com>
Tue, 2 Apr 2013 13:44:19 +0000 (09:44 -0400)
include/uimport.php

index 9cfb183f6ead7f23c28fe9db384c33e6271d3aec..12e85c61ad66b59826119fdc7a88002255ab3775 100644 (file)
@@ -1,4 +1,5 @@
 <?php\r
+\r
 /**\r
  * import account file exported from mod/uexport\r
  * args:\r
 require_once("include/Photo.php");\r
 define("IMPORT_DEBUG", False);\r
 \r
-function last_insert_id(){\r
-    global $db; \r
-    if (IMPORT_DEBUG) return 1;\r
-    if($db->mysqli){\r
-        $thedb = $db->getdb();\r
-        return $thedb->insert_id;\r
-    } else {\r
-        return mysql_insert_id();\r
-    }\r
- }\r
\r
- function last_error(){\r
-    global $db; \r
-    return $db->error;\r
- }\r
\r
- /**\r
-  * Remove columns from array $arr that aren't in table $table\r
-  * \r
-  * @param string $table Table name\r
-  * @param array &$arr Column=>Value array from json (by ref)\r
-  */\r
- function check_cols($table, &$arr){\r
-       $query = sprintf("SHOW COLUMNS IN `%s`", dbesc($table));\r
-       logger("uimport: $query", LOGGER_DEBUG);\r
+function last_insert_id() {\r
+       global $db;\r
+       if (IMPORT_DEBUG)\r
+               return 1;\r
+       if ($db->mysqli) {\r
+               $thedb = $db->getdb();\r
+               return $thedb->insert_id;\r
+       } else {\r
+               return mysql_insert_id();\r
+       }\r
+}\r
+\r
+function last_error() {\r
+       global $db;\r
+       return $db->error;\r
+}\r
+\r
+/**\r
+ * Remove columns from array $arr that aren't in table $table\r
+ * \r
+ * @param string $table Table name\r
+ * @param array &$arr Column=>Value array from json (by ref)\r
+ */\r
+function check_cols($table, &$arr) {\r
+       $query = sprintf("SHOW COLUMNS IN `%s`", dbesc($table));\r
+       logger("uimport: $query", LOGGER_DEBUG);\r
        $r = q($query);\r
        $tcols = array();\r
        // get a plain array of column names\r
-       foreach($r as $tcol) {\r
+       foreach ($r as $tcol) {\r
                $tcols[] = $tcol['Field'];\r
        }\r
        // remove inexistent columns\r
-       foreach($arr as $icol=>$ival) {\r
+       foreach ($arr as $icol => $ival) {\r
                if (!in_array($icol, $tcols)) {\r
                        unset($arr[$icol]);\r
                }\r
        }\r
- }\r
\r
- /**\r
-  * Import data into table $table\r
-  * \r
-  * @param string $table Table name\r
-  * @param array $arr Column=>Value array from json\r
-  */\r
- function db_import_assoc($table, $arr){\r
-    if (isset($arr['id'])) unset($arr['id']);\r
-    check_cols($table, $arr);\r
-    $cols = implode("`,`", array_map('dbesc', array_keys($arr)));\r
-    $vals = implode("','", array_map('dbesc', array_values($arr)));\r
-    $query = "INSERT INTO `$table` (`$cols`) VALUES ('$vals')";\r
-    logger("uimport: $query",LOGGER_TRACE);\r
-    if (IMPORT_DEBUG) return true;\r
-    return q($query);\r
- }\r
+}\r
 \r
-function import_cleanup($newuid) {\r
-    q("DELETE FROM `user` WHERE uid = %d", $newuid);\r
-    q("DELETE FROM `contact` WHERE uid = %d", $newuid);\r
-    q("DELETE FROM `profile` WHERE uid = %d", $newuid);\r
-    q("DELETE FROM `photo` WHERE uid = %d", $newuid);\r
-    q("DELETE FROM `group` WHERE uid = %d", $newuid);\r
-    q("DELETE FROM `group_member` WHERE uid = %d", $newuid);\r
-    q("DELETE FROM `pconfig` WHERE uid = %d", $newuid);\r
+/**\r
+ * Import data into table $table\r
+ * \r
+ * @param string $table Table name\r
+ * @param array $arr Column=>Value array from json\r
+ */\r
+function db_import_assoc($table, $arr) {\r
+       if (isset($arr['id']))\r
+               unset($arr['id']);\r
+       check_cols($table, $arr);\r
+       $cols = implode("`,`", array_map('dbesc', array_keys($arr)));\r
+       $vals = implode("','", array_map('dbesc', array_values($arr)));\r
+       $query = "INSERT INTO `$table` (`$cols`) VALUES ('$vals')";\r
+       logger("uimport: $query", LOGGER_TRACE);\r
+       if (IMPORT_DEBUG)\r
+               return true;\r
+       return q($query);\r
+}\r
 \r
+function import_cleanup($newuid) {\r
+       q("DELETE FROM `user` WHERE uid = %d", $newuid);\r
+       q("DELETE FROM `contact` WHERE uid = %d", $newuid);\r
+       q("DELETE FROM `profile` WHERE uid = %d", $newuid);\r
+       q("DELETE FROM `photo` WHERE uid = %d", $newuid);\r
+       q("DELETE FROM `group` WHERE uid = %d", $newuid);\r
+       q("DELETE FROM `group_member` WHERE uid = %d", $newuid);\r
+       q("DELETE FROM `pconfig` WHERE uid = %d", $newuid);\r
 }\r
 \r
 function import_account(&$a, $file) {\r
-    logger("Start user import from ".$file['tmp_name']);\r
-    /*\r
-        STEPS\r
-        1. checks\r
-        2. replace old baseurl with new baseurl\r
-        3. import data (look at user id and contacts id)\r
-        4. archive non-dfrn contacts\r
-        5. send message to dfrn contacts\r
-     */\r
-\r
-    $account = json_decode(file_get_contents($file['tmp_name']), true);\r
-    if ($account===null) {\r
-        notice(t("Error decoding account file"));\r
-        return;\r
-    }\r
-       \r
-\r
-    if (!x($account, 'version')) { \r
-        notice(t("Error! No version data in file! This is not a Friendica account file?"));\r
-        return;\r
-    }\r
-   \r
-    if ($account['schema'] != DB_UPDATE_VERSION) {\r
-        notice(t("Error! I can't import this file: DB schema version is not compatible."));\r
-        return;\r
-    }\r
-   \r
-       \r
+       logger("Start user import from " . $file['tmp_name']);\r
+       /*\r
+         STEPS\r
+         1. checks\r
+         2. replace old baseurl with new baseurl\r
+         3. import data (look at user id and contacts id)\r
+         4. archive non-dfrn contacts\r
+         5. send message to dfrn contacts\r
+        */\r
+\r
+       $account = json_decode(file_get_contents($file['tmp_name']), true);\r
+       if ($account === null) {\r
+               notice(t("Error decoding account file"));\r
+               return;\r
+       }\r
+\r
+\r
+       if (!x($account, 'version')) {\r
+               notice(t("Error! No version data in file! This is not a Friendica account file?"));\r
+               return;\r
+       }\r
+\r
+       if ($account['schema'] != DB_UPDATE_VERSION) {\r
+               notice(t("Error! I can't import this file: DB schema version is not compatible."));\r
+               return;\r
+       }\r
+\r
+\r
        // check for username\r
        $r = q("SELECT uid FROM user WHERE nickname='%s'", $account['user']['nickname']);\r
-       if ($r===false) {\r
-               logger("uimport:check nickname : ERROR : ".last_error(), LOGGER_NORMAL);\r
+       if ($r === false) {\r
+               logger("uimport:check nickname : ERROR : " . last_error(), LOGGER_NORMAL);\r
                notice(t('Error! Cannot check nickname'));\r
                return;\r
        }\r
-       if (count($r)>0) {\r
-               notice(sprintf(t("User '%s' already exists on this server!"),$account['user']['nickname']));\r
+       if (count($r) > 0) {\r
+               notice(sprintf(t("User '%s' already exists on this server!"), $account['user']['nickname']));\r
                return;\r
        }\r
 \r
-    $oldbaseurl  = $account['baseurl'];\r
-    $newbaseurl = $a->get_baseurl();\r
-    $olduid = $account['user']['uid'];\r
-  \r
-    unset($account['user']['uid']);\r
-    foreach($account['user'] as $k => &$v) {\r
-        $v = str_replace($oldbaseurl, $newbaseurl, $v);\r
-    }\r
-\r
-    \r
-    // import user\r
-    $r = db_import_assoc('user', $account['user']);\r
-    if ($r===false) {\r
-        //echo "<pre>"; var_dump($r, $query, mysql_error()); killme();\r
-        logger("uimport:insert user : ERROR : ".last_error(), LOGGER_NORMAL);\r
-        notice(t("User creation error"));\r
-        return;\r
-    }\r
-    $newuid = last_insert_id();\r
-    //~ $newuid = 1;\r
-    \r
-\r
-\r
-    foreach($account['profile'] as &$profile) {\r
-        foreach($profile as $k=>&$v) {\r
-            $v = str_replace($oldbaseurl, $newbaseurl, $v);\r
-            foreach(array("profile","avatar") as $k)\r
-                $v = str_replace($newbaseurl."/photo/".$k."/".$olduid.".jpg", $newbaseurl."/photo/".$k."/".$newuid.".jpg", $v);\r
-        }\r
-        $profile['uid'] = $newuid;\r
-        $r = db_import_assoc('profile', $profile);\r
-        if ($r===false) {\r
-            logger("uimport:insert profile ".$profile['profile-name']." : ERROR : ".last_error(), LOGGER_NORMAL);\r
-            info(t("User profile creation error"));\r
-            import_cleanup($newuid);\r
-            return;\r
-        }\r
-    }\r
-\r
-    $errorcount=0;\r
-    foreach($account['contact'] as &$contact) {\r
-        if ($contact['uid'] == $olduid && $contact['self'] == '1'){\r
-            foreach($contact as $k=>&$v) {\r
-                $v = str_replace($oldbaseurl, $newbaseurl, $v);\r
-                foreach(array("profile","avatar","micro") as $k)\r
-                    $v = str_replace($newbaseurl."/photo/".$k."/".$olduid.".jpg", $newbaseurl."/photo/".$k."/".$newuid.".jpg", $v);\r
-            }\r
-        }\r
-         if ($contact['uid'] == $olduid && $contact['self'] == '0') {\r
-            switch ($contact['network']){\r
-                case NETWORK_DFRN:\r
-                    //  send relocate message (below)\r
-                    break;\r
-                case NETWORK_ZOT:\r
-                    // TODO handle zot network\r
-                    break;\r
-                case NETWORK_MAIL2:\r
-                    // TODO ?\r
-                    break;\r
-                case NETWORK_FEED:\r
-                case NETWORK_MAIL:\r
-                    // Nothing to do\r
-                    break;\r
-                default:\r
-                    // archive other contacts\r
-                    $contact['archive'] = "1";\r
-            }\r
-        }\r
-        $contact['uid'] = $newuid;\r
-        $r = db_import_assoc('contact', $contact);\r
-        if ($r===false) {\r
-            logger("uimport:insert contact ".$contact['nick'].",".$contact['network']." : ERROR : ".last_error(), LOGGER_NORMAL);\r
-            $errorcount++;\r
-        } else {\r
-            $contact['newid'] = last_insert_id();\r
-        }\r
-    }\r
-    if ($errorcount>0) {\r
-        notice( sprintf(tt("%d contact not imported", "%d contacts not imported", $errorcount), $errorcount) );\r
-    }\r
-\r
-    foreach($account['group'] as &$group) {\r
-        $group['uid'] = $newuid;\r
-        $r = db_import_assoc('group', $group);\r
-        if ($r===false) {\r
-            logger("uimport:insert group ".$group['name']." : ERROR : ".last_error(), LOGGER_NORMAL);\r
-        } else {\r
-            $group['newid'] = last_insert_id();\r
-        }\r
-    }\r
-\r
-    foreach($account['group_member'] as &$group_member) {\r
-        $group_member['uid'] = $newuid;\r
-        \r
-        $import = 0;\r
-        foreach($account['group'] as $group) {\r
-            if ($group['id'] == $group_member['gid'] && isset($group['newid'])) {\r
-                $group_member['gid'] = $group['newid'];\r
-                $import++;\r
-                break;\r
-            }\r
-        }\r
-        foreach($account['contact'] as $contact) {\r
-            if ($contact['id'] == $group_member['contact-id'] && isset($contact['newid'])) {\r
-                $group_member['contact-id'] = $contact['newid'];\r
-                $import++;\r
-                break;\r
-            }\r
-        }\r
-        if ($import==2) {\r
-            $r = db_import_assoc('group_member', $group_member);\r
-            if ($r===false) {\r
-                logger("uimport:insert group member ".$group_member['id']." : ERROR : ".last_error(), LOGGER_NORMAL);\r
-            }\r
-        }\r
-    }\r
-\r
-\r
-\r
-    \r
-    \r
-    foreach($account['photo'] as &$photo) {\r
-        $photo['uid'] = $newuid;\r
-        $photo['data'] = hex2bin($photo['data']);\r
-        \r
-        $p = new Photo($photo['data'], $photo['type']);\r
-        $r = $p->store(\r
-            $photo['uid'],\r
-            $photo['contact-id'], //0\r
-            $photo['resource-id'],\r
-            $photo['filename'],\r
-            $photo['album'],\r
-            $photo['scale'],\r
-            $photo['profile'], //1\r
-            $photo['allow_cid'],\r
-            $photo['allow_gid'],\r
-            $photo['deny_cid'],\r
-            $photo['deny_gid']\r
-        );\r
-        \r
-        if ($r===false) {\r
-            logger("uimport:insert photo ".$photo['resource-id'].",". $photo['scale']. " : ERROR : ".last_error(), LOGGER_NORMAL);\r
-        }\r
-    } \r
-    \r
-    foreach($account['pconfig'] as &$pconfig) {\r
-        $pconfig['uid'] = $newuid;\r
-        $r = db_import_assoc('pconfig', $pconfig);\r
-        if ($r===false) {\r
-            logger("uimport:insert pconfig ".$pconfig['id']. " : ERROR : ".last_error(), LOGGER_NORMAL);\r
-        }\r
-    } \r
-    \r
-    // send relocate messages\r
-    proc_run('php', 'include/notifier.php', 'relocate' , $newuid);\r
-    \r
-    info(t("Done. You can now login with your username and password"));\r
-    goaway( $a->get_baseurl() ."/login");\r
-    \r
-    \r
+       $oldbaseurl = $account['baseurl'];\r
+       $newbaseurl = $a->get_baseurl();\r
+       $olduid = $account['user']['uid'];\r
+\r
+       unset($account['user']['uid']);\r
+       foreach ($account['user'] as $k => &$v) {\r
+               $v = str_replace($oldbaseurl, $newbaseurl, $v);\r
+       }\r
+\r
+\r
+       // import user\r
+       $r = db_import_assoc('user', $account['user']);\r
+       if ($r === false) {\r
+               //echo "<pre>"; var_dump($r, $query, mysql_error()); killme();\r
+               logger("uimport:insert user : ERROR : " . last_error(), LOGGER_NORMAL);\r
+               notice(t("User creation error"));\r
+               return;\r
+       }\r
+       $newuid = last_insert_id();\r
+       //~ $newuid = 1;\r
+\r
+\r
+\r
+       foreach ($account['profile'] as &$profile) {\r
+               foreach ($profile as $k => &$v) {\r
+                       $v = str_replace($oldbaseurl, $newbaseurl, $v);\r
+                       foreach (array("profile", "avatar") as $k)\r
+                               $v = str_replace($newbaseurl . "/photo/" . $k . "/" . $olduid . ".jpg", $newbaseurl . "/photo/" . $k . "/" . $newuid . ".jpg", $v);\r
+               }\r
+               $profile['uid'] = $newuid;\r
+               $r = db_import_assoc('profile', $profile);\r
+               if ($r === false) {\r
+                       logger("uimport:insert profile " . $profile['profile-name'] . " : ERROR : " . last_error(), LOGGER_NORMAL);\r
+                       info(t("User profile creation error"));\r
+                       import_cleanup($newuid);\r
+                       return;\r
+               }\r
+       }\r
+\r
+       $errorcount = 0;\r
+       foreach ($account['contact'] as &$contact) {\r
+               if ($contact['uid'] == $olduid && $contact['self'] == '1') {\r
+                       foreach ($contact as $k => &$v) {\r
+                               $v = str_replace($oldbaseurl, $newbaseurl, $v);\r
+                               foreach (array("profile", "avatar", "micro") as $k)\r
+                                       $v = str_replace($newbaseurl . "/photo/" . $k . "/" . $olduid . ".jpg", $newbaseurl . "/photo/" . $k . "/" . $newuid . ".jpg", $v);\r
+                       }\r
+               }\r
+               if ($contact['uid'] == $olduid && $contact['self'] == '0') {\r
+                       switch ($contact['network']) {\r
+                               case NETWORK_DFRN:\r
+                                       //  send relocate message (below)\r
+                                       break;\r
+                               case NETWORK_ZOT:\r
+                                       // TODO handle zot network\r
+                                       break;\r
+                               case NETWORK_MAIL2:\r
+                                       // TODO ?\r
+                                       break;\r
+                               case NETWORK_FEED:\r
+                               case NETWORK_MAIL:\r
+                                       // Nothing to do\r
+                                       break;\r
+                               default:\r
+                                       // archive other contacts\r
+                                       $contact['archive'] = "1";\r
+                       }\r
+               }\r
+               $contact['uid'] = $newuid;\r
+               $r = db_import_assoc('contact', $contact);\r
+               if ($r === false) {\r
+                       logger("uimport:insert contact " . $contact['nick'] . "," . $contact['network'] . " : ERROR : " . last_error(), LOGGER_NORMAL);\r
+                       $errorcount++;\r
+               } else {\r
+                       $contact['newid'] = last_insert_id();\r
+               }\r
+       }\r
+       if ($errorcount > 0) {\r
+               notice(sprintf(tt("%d contact not imported", "%d contacts not imported", $errorcount), $errorcount));\r
+       }\r
+\r
+       foreach ($account['group'] as &$group) {\r
+               $group['uid'] = $newuid;\r
+               $r = db_import_assoc('group', $group);\r
+               if ($r === false) {\r
+                       logger("uimport:insert group " . $group['name'] . " : ERROR : " . last_error(), LOGGER_NORMAL);\r
+               } else {\r
+                       $group['newid'] = last_insert_id();\r
+               }\r
+       }\r
+\r
+       foreach ($account['group_member'] as &$group_member) {\r
+               $group_member['uid'] = $newuid;\r
+\r
+               $import = 0;\r
+               foreach ($account['group'] as $group) {\r
+                       if ($group['id'] == $group_member['gid'] && isset($group['newid'])) {\r
+                               $group_member['gid'] = $group['newid'];\r
+                               $import++;\r
+                               break;\r
+                       }\r
+               }\r
+               foreach ($account['contact'] as $contact) {\r
+                       if ($contact['id'] == $group_member['contact-id'] && isset($contact['newid'])) {\r
+                               $group_member['contact-id'] = $contact['newid'];\r
+                               $import++;\r
+                               break;\r
+                       }\r
+               }\r
+               if ($import == 2) {\r
+                       $r = db_import_assoc('group_member', $group_member);\r
+                       if ($r === false) {\r
+                               logger("uimport:insert group member " . $group_member['id'] . " : ERROR : " . last_error(), LOGGER_NORMAL);\r
+                       }\r
+               }\r
+       }\r
+\r
+\r
+\r
+\r
+\r
+       foreach ($account['photo'] as &$photo) {\r
+               $photo['uid'] = $newuid;\r
+               $photo['data'] = hex2bin($photo['data']);\r
+\r
+               $p = new Photo($photo['data'], $photo['type']);\r
+               $r = $p->store(\r
+                               $photo['uid'], $photo['contact-id'], //0\r
+                               $photo['resource-id'], $photo['filename'], $photo['album'], $photo['scale'], $photo['profile'], //1\r
+                               $photo['allow_cid'], $photo['allow_gid'], $photo['deny_cid'], $photo['deny_gid']\r
+               );\r
+\r
+               if ($r === false) {\r
+                       logger("uimport:insert photo " . $photo['resource-id'] . "," . $photo['scale'] . " : ERROR : " . last_error(), LOGGER_NORMAL);\r
+               }\r
+       }\r
+\r
+       foreach ($account['pconfig'] as &$pconfig) {\r
+               $pconfig['uid'] = $newuid;\r
+               $r = db_import_assoc('pconfig', $pconfig);\r
+               if ($r === false) {\r
+                       logger("uimport:insert pconfig " . $pconfig['id'] . " : ERROR : " . last_error(), LOGGER_NORMAL);\r
+               }\r
+       }\r
+\r
+       // send relocate messages\r
+       proc_run('php', 'include/notifier.php', 'relocate', $newuid);\r
+\r
+       info(t("Done. You can now login with your username and password"));\r
+       goaway($a->get_baseurl() . "/login");\r
 }\r