apt-pkg/cdrom.cc

   1 /*
   2  */
   3 #include<config.h>
   4
   5 #include<apt-pkg/init.h>
   6 #include<apt-pkg/error.h>
   7 #include<apt-pkg/cdromutl.h>
   8 #include<apt-pkg/strutl.h>
   9 #include<apt-pkg/cdrom.h>
  10 #include<apt-pkg/aptconfiguration.h>
  11 #include<apt-pkg/configuration.h>
  12 #include<apt-pkg/fileutl.h>
  13
  14 #include<sstream>
  15 #include<fstream>
  16 #include <sys/stat.h>
  17 #include <fcntl.h>
  18 #include <dirent.h>
  19 #include <unistd.h>
  20 #include <stdio.h>
  21 #include <algorithm>
  22 #include <dlfcn.h>
  23
  24 #include "indexcopy.h"
  25
  26 #include<apti18n.h>
  27
  28 using namespace std;
  29
  30 // FindPackages - Find the package files on the CDROM                   /*{{{*/
  31 // ---------------------------------------------------------------------
  32 /* We look over the cdrom for package files. This is a recursive
  33    search that short circuits when it his a package file in the dir.
  34    This speeds it up greatly as the majority of the size is in the
  35    binary-* sub dirs. */
  36 bool pkgCdrom::FindPackages(string CD,
  37                             vector<string> &List,
  38                             vector<string> &SList,
  39                             vector<string> &SigList,
  40                             vector<string> &TransList,
  41                             string &InfoDir, pkgCdromStatus *log,
  42                             unsigned int Depth)
  43 {
  44    static ino_t Inodes[9];
  45    DIR *D;
  46
  47    // if we have a look we "pulse" now
  48    if(log)
  49       log->Update();
  50
  51    if (Depth >= 7)
  52       return true;
  53
  54    if (CD[CD.length()-1] != '/')
  55       CD += '/';
  56
  57    if (chdir(CD.c_str()) != 0)
  58       return _error->Errno("chdir","Unable to change to %s",CD.c_str());
  59
  60    // Look for a .disk subdirectory
  61    if (DirectoryExists(".disk") == true)
  62    {
  63       if (InfoDir.empty() == true)
  64          InfoDir = CD + ".disk/";
  65    }
  66
  67    // Don't look into directories that have been marked to ingore.
  68    if (RealFileExists(".aptignr") == true)
  69       return true;
  70
  71    /* Check _first_ for a signature file as apt-cdrom assumes that all files
  72       under a Packages/Source file are in control of that file and stops
  73       the scanning
  74    */
  75    if (RealFileExists("Release.gpg") == true || RealFileExists("InRelease") == true)
  76    {
  77       SigList.push_back(CD);
  78    }
  79
  80    /* Aha! We found some package files. We assume that everything under
  81       this dir is controlled by those package files so we don't look down
  82       anymore */
  83    std::vector<APT::Configuration::Compressor> const compressor = APT::Configuration::getCompressors();
  84    for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin();
  85         c != compressor.end(); ++c)
  86    {
  87       if (RealFileExists(std::string("Packages").append(c->Extension).c_str()) == false)
  88          continue;
  89
  90       if (_config->FindB("Debug::aptcdrom",false) == true)
  91          std::clog << "Found Packages in " << CD << std::endl;
  92       List.push_back(CD);
  93
  94       // Continue down if thorough is given
  95       if (_config->FindB("APT::CDROM::Thorough",false) == false)
  96          return true;
  97       break;
  98    }
  99    for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin();
 100         c != compressor.end(); ++c)
 101    {
 102       if (RealFileExists(std::string("Sources").append(c->Extension).c_str()) == false)
 103          continue;
 104
 105       if (_config->FindB("Debug::aptcdrom",false) == true)
 106          std::clog << "Found Sources in " << CD << std::endl;
 107       SList.push_back(CD);
 108
 109       // Continue down if thorough is given
 110       if (_config->FindB("APT::CDROM::Thorough",false) == false)
 111          return true;
 112       break;
 113    }
 114
 115    // see if we find translation indices
 116    if (DirectoryExists("i18n") == true)
 117    {
 118       D = opendir("i18n");
 119       for (struct dirent *Dir = readdir(D); Dir != 0; Dir = readdir(D))
 120       {
 121          if(strncmp(Dir->d_name, "Translation-", strlen("Translation-")) != 0)
 122             continue;
 123          string file = Dir->d_name;
 124          for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin();
 125               c != compressor.end(); ++c)
 126          {
 127             string fileext = flExtension(file);
 128             if (file == fileext)
 129                fileext.clear();
 130             else if (fileext.empty() == false)
 131                fileext = "." + fileext;
 132
 133             if (c->Extension == fileext)
 134             {
 135                if (_config->FindB("Debug::aptcdrom",false) == true)
 136                   std::clog << "Found translation " << Dir->d_name << " in " << CD << "i18n/" << std::endl;
 137                file.erase(file.size() - fileext.size());
 138                TransList.push_back(CD + "i18n/" + file);
 139                break;
 140             }
 141          }
 142       }
 143       closedir(D);
 144    }
 145
 146    D = opendir(".");
 147    if (D == 0)
 148       return _error->Errno("opendir","Unable to read %s",CD.c_str());
 149
 150    // Run over the directory
 151    for (struct dirent *Dir = readdir(D); Dir != 0; Dir = readdir(D))
 152    {
 153       // Skip some files..
 154       if (strcmp(Dir->d_name,".") == 0 ||
 155           strcmp(Dir->d_name,"..") == 0 ||
 156           //strcmp(Dir->d_name,"source") == 0 ||
 157           strcmp(Dir->d_name,".disk") == 0 ||
 158           strcmp(Dir->d_name,"experimental") == 0 ||
 159           strcmp(Dir->d_name,"binary-all") == 0 ||
 160           strcmp(Dir->d_name,"debian-installer") == 0)
 161          continue;
 162
 163       // See if the name is a sub directory
 164       struct stat Buf;
 165       if (stat(Dir->d_name,&Buf) != 0)
 166          continue;
 167
 168       if (S_ISDIR(Buf.st_mode) == 0)
 169          continue;
 170
 171       unsigned int I;
 172       for (I = 0; I != Depth; I++)
 173          if (Inodes[I] == Buf.st_ino)
 174             break;
 175       if (I != Depth)
 176          continue;
 177
 178       // Store the inodes weve seen
 179       Inodes[Depth] = Buf.st_ino;
 180
 181       // Descend
 182       if (FindPackages(CD + Dir->d_name,List,SList,SigList,TransList,InfoDir,log,Depth+1) == false)
 183          break;
 184
 185       if (chdir(CD.c_str()) != 0)
 186       {
 187          _error->Errno("chdir","Unable to change to %s", CD.c_str());
 188          closedir(D);
 189          return false;
 190       }
 191    };
 192
 193    closedir(D);
 194
 195    return !_error->PendingError();
 196 }
 197                                                                         /*}}}*/
 198 // Score - We compute a 'score' for a path                              /*{{{*/
 199 // ---------------------------------------------------------------------
 200 /* Paths are scored based on how close they come to what I consider
 201    normal. That is ones that have 'dist' 'stable' 'testing' will score
 202    higher than ones without. */
 203 int pkgCdrom::Score(string Path)
 204 {
 205    int Res = 0;
 206    if (Path.find("stable/") != string::npos)
 207       Res += 29;
 208    if (Path.find("/binary-") != string::npos)
 209       Res += 20;
 210    if (Path.find("testing/") != string::npos)
 211       Res += 28;
 212    if (Path.find("unstable/") != string::npos)
 213       Res += 27;
 214    if (Path.find("/dists/") != string::npos)
 215       Res += 40;
 216    if (Path.find("/main/") != string::npos)
 217       Res += 20;
 218    if (Path.find("/contrib/") != string::npos)
 219       Res += 20;
 220    if (Path.find("/non-free/") != string::npos)
 221       Res += 20;
 222    if (Path.find("/non-US/") != string::npos)
 223       Res += 20;
 224    if (Path.find("/source/") != string::npos)
 225       Res += 10;
 226    if (Path.find("/debian/") != string::npos)
 227       Res -= 10;
 228
 229    // check for symlinks in the patch leading to the actual file
 230    // a symlink gets a big penalty
 231    struct stat Buf;
 232    string statPath = flNotFile(Path);
 233    string cdromPath = _config->FindDir("Acquire::cdrom::mount");
 234    while(statPath != cdromPath && statPath != "./") {
 235       statPath.resize(statPath.size()-1);  // remove the trailing '/'
 236       if (lstat(statPath.c_str(),&Buf) == 0) {
 237         if(S_ISLNK(Buf.st_mode)) {
 238            Res -= 60;
 239            break;
 240         }
 241       }
 242       statPath = flNotFile(statPath); // descent
 243    }
 244
 245    return Res;
 246 }
 247                                                                         /*}}}*/
 248 // DropBinaryArch - Dump dirs with a string like /binary-<foo>/         /*{{{*/
 249 // ---------------------------------------------------------------------
 250 /* Here we drop everything that is not this machines arch */
 251 bool pkgCdrom::DropBinaryArch(vector<string> &List)
 252 {
 253
 254    for (unsigned int I = 0; I < List.size(); I++)
 255    {
 256       const char *Str = List[I].c_str();
 257       const char *Start, *End;
 258       if ((Start = strstr(Str,"/binary-")) == 0)
 259          continue;
 260
 261       // Between Start and End is the architecture
 262       Start += 8;
 263       if ((End = strstr(Start,"/")) != 0 && Start != End &&
 264           APT::Configuration::checkArchitecture(string(Start, End)) == true)
 265          continue; // okay, architecture is accepted
 266
 267       // not accepted -> Erase it
 268       List.erase(List.begin() + I);
 269       --I; // the next entry is at the same index after the erase
 270    }
 271
 272    return true;
 273 }
 274                                                                         /*}}}*/
 275 // DropTranslation - Dump unwanted Translation-<lang> files             /*{{{*/
 276 // ---------------------------------------------------------------------
 277 /* Here we drop everything that is not configured in Acquire::Languages */
 278 bool pkgCdrom::DropTranslation(vector<string> &List)
 279 {
 280    for (unsigned int I = 0; I < List.size(); I++)
 281    {
 282       const char *Start;
 283       if ((Start = strstr(List[I].c_str(), "/Translation-")) == NULL)
 284          continue;
 285       Start += strlen("/Translation-");
 286
 287       if (APT::Configuration::checkLanguage(Start, true) == true)
 288          continue;
 289
 290       // not accepted -> Erase it
 291       List.erase(List.begin() + I);
 292       --I; // the next entry is at the same index after the erase
 293    }
 294
 295    return true;
 296 }
 297                                                                         /*}}}*/
 298 // DropRepeats - Drop repeated files resulting from symlinks            /*{{{*/
 299 // ---------------------------------------------------------------------
 300 /* Here we go and stat every file that we found and strip dup inodes. */
 301 bool pkgCdrom::DropRepeats(vector<string> &List,const char *Name)
 302 {
 303    bool couldFindAllFiles = true;
 304    // Get a list of all the inodes
 305    ino_t *Inodes = new ino_t[List.size()];
 306    for (unsigned int I = 0; I != List.size(); ++I)
 307    {
 308       struct stat Buf;
 309       bool found = false;
 310
 311       std::vector<APT::Configuration::Compressor> const compressor = APT::Configuration::getCompressors();
 312       for (std::vector<APT::Configuration::Compressor>::const_iterator c = compressor.begin();
 313            c != compressor.end(); ++c)
 314       {
 315          std::string filename = std::string(List[I]).append(Name).append(c->Extension);
 316          if (stat(filename.c_str(), &Buf) != 0)
 317             continue;
 318          Inodes[I] = Buf.st_ino;
 319          found = true;
 320          break;
 321       }
 322
 323       if (found == false)
 324       {
 325          _error->Errno("stat","Failed to stat %s%s",List[I].c_str(), Name);
 326          couldFindAllFiles = false;
 327          Inodes[I] = 0;
 328       }
 329    }
 330
 331    // Look for dups
 332    for (unsigned int I = 0; I != List.size(); I++)
 333    {
 334       if (Inodes[I] == 0)
 335          continue;
 336       for (unsigned int J = I+1; J < List.size(); J++)
 337       {
 338          // No match
 339          if (Inodes[J] == 0 || Inodes[J] != Inodes[I])
 340             continue;
 341
 342          // We score the two paths.. and erase one
 343          int ScoreA = Score(List[I]);
 344          int ScoreB = Score(List[J]);
 345          if (ScoreA < ScoreB)
 346          {
 347             List[I] = string();
 348             break;
 349          }
 350
 351          List[J] = string();
 352       }
 353    }
 354    delete[] Inodes;
 355
 356    // Wipe erased entries
 357    for (unsigned int I = 0; I < List.size();)
 358    {
 359       if (List[I].empty() == false)
 360          I++;
 361       else
 362          List.erase(List.begin()+I);
 363    }
 364
 365    return couldFindAllFiles;
 366 }
 367                                                                         /*}}}*/
 368 // ReduceSourceList - Takes the path list and reduces it                /*{{{*/
 369 // ---------------------------------------------------------------------
 370 /* This takes the list of source list expressed entires and collects
 371    similar ones to form a single entry for each dist */
 372 void pkgCdrom::ReduceSourcelist(string /*CD*/,vector<string> &List)
 373 {
 374    sort(List.begin(),List.end());
 375
 376    // Collect similar entries
 377    for (vector<string>::iterator I = List.begin(); I != List.end(); ++I)
 378    {
 379       // Find a space..
 380       string::size_type Space = (*I).find(' ');
 381       if (Space == string::npos)
 382          continue;
 383       string::size_type SSpace = (*I).find(' ',Space + 1);
 384       if (SSpace == string::npos)
 385          continue;
 386
 387       string Word1 = string(*I,Space,SSpace-Space);
 388       string Prefix = string(*I,0,Space);
 389       string Component = string(*I,SSpace);
 390       for (vector<string>::iterator J = List.begin(); J != I; ++J)
 391       {
 392          // Find a space..
 393          string::size_type Space2 = (*J).find(' ');
 394          if (Space2 == string::npos)
 395             continue;
 396          string::size_type SSpace2 = (*J).find(' ',Space2 + 1);
 397          if (SSpace2 == string::npos)
 398             continue;
 399
 400          if (string(*J,0,Space2) != Prefix)
 401             continue;
 402          if (string(*J,Space2,SSpace2-Space2) != Word1)
 403             continue;
 404
 405          string Component2 = string(*J, SSpace2) + " ";
 406          if (Component2.find(Component + " ") == std::string::npos)
 407             *J += Component;
 408          I->clear();
 409       }
 410    }
 411
 412    // Wipe erased entries
 413    for (unsigned int I = 0; I < List.size();)
 414    {
 415       if (List[I].empty() == false)
 416          I++;
 417       else
 418          List.erase(List.begin()+I);
 419    }
 420 }
 421                                                                         /*}}}*/
 422 // WriteDatabase - Write the CDROM Database file                        /*{{{*/
 423 // ---------------------------------------------------------------------
 424 /* We rewrite the configuration class associated with the cdrom database. */
 425 bool pkgCdrom::WriteDatabase(Configuration &Cnf)
 426 {
 427    string DFile = _config->FindFile("Dir::State::cdroms");
 428    string NewFile = DFile + ".new";
 429
 430    unlink(NewFile.c_str());
 431    ofstream Out(NewFile.c_str());
 432    if (!Out)
 433       return _error->Errno("ofstream::ofstream",
 434                            "Failed to open %s.new",DFile.c_str());
 435
 436    /* Write out all of the configuration directives by walking the
 437       configuration tree */
 438    Cnf.Dump(Out, NULL, "%f \"%v\";\n", false);
 439
 440    Out.close();
 441
 442    if (FileExists(DFile) == true)
 443       rename(DFile.c_str(), (DFile + '~').c_str());
 444    if (rename(NewFile.c_str(),DFile.c_str()) != 0)
 445       return _error->Errno("rename","Failed to rename %s.new to %s",
 446                            DFile.c_str(),DFile.c_str());
 447
 448    return true;
 449 }
 450                                                                         /*}}}*/
 451 // WriteSourceList - Write an updated sourcelist                        /*{{{*/
 452 // ---------------------------------------------------------------------
 453 /* This reads the old source list and copies it into the new one. It
 454    appends the new CDROM entires just after the first block of comments.
 455    This places them first in the file. It also removes any old entries
 456    that were the same. */
 457 bool pkgCdrom::WriteSourceList(string Name,vector<string> &List,bool Source)
 458 {
 459    if (List.empty() == true)
 460       return true;
 461
 462    string File = _config->FindFile("Dir::Etc::sourcelist");
 463
 464    // Open the stream for reading
 465    ifstream F((FileExists(File)?File.c_str():"/dev/null"),
 466               ios::in );
 467    if (!F != 0)
 468       return _error->Errno("ifstream::ifstream","Opening %s",File.c_str());
 469
 470    string NewFile = File + ".new";
 471    unlink(NewFile.c_str());
 472    ofstream Out(NewFile.c_str());
 473    if (!Out)
 474       return _error->Errno("ofstream::ofstream",
 475                            "Failed to open %s.new",File.c_str());
 476
 477    // Create a short uri without the path
 478    string ShortURI = "cdrom:[" + Name + "]/";
 479    string ShortURI2 = "cdrom:" + Name + "/";     // For Compatibility
 480
 481    string Type;
 482    if (Source == true)
 483       Type = "deb-src";
 484    else
 485       Type = "deb";
 486
 487    char Buffer[300];
 488    int CurLine = 0;
 489    bool First = true;
 490    while (F.eof() == false)
 491    {
 492       F.getline(Buffer,sizeof(Buffer));
 493       CurLine++;
 494       if (F.fail() && !F.eof())
 495          return _error->Error(_("Line %u too long in source list %s."),
 496                               CurLine,File.c_str());
 497       _strtabexpand(Buffer,sizeof(Buffer));
 498       _strstrip(Buffer);
 499
 500       // Comment or blank
 501       if (Buffer[0] == '#' || Buffer[0] == 0)
 502       {
 503          Out << Buffer << endl;
 504          continue;
 505       }
 506
 507       if (First == true)
 508       {
 509          for (vector<string>::iterator I = List.begin(); I != List.end(); ++I)
 510          {
 511             string::size_type Space = (*I).find(' ');
 512             if (Space == string::npos)
 513                return _error->Error("Internal error");
 514             Out << Type << " cdrom:[" << Name << "]/" << string(*I,0,Space) <<
 515                " " << string(*I,Space+1) << endl;
 516          }
 517       }
 518       First = false;
 519
 520       // Grok it
 521       string cType;
 522       string URI;
 523       const char *C = Buffer;
 524       if (ParseQuoteWord(C,cType) == false ||
 525           ParseQuoteWord(C,URI) == false)
 526       {
 527          Out << Buffer << endl;
 528          continue;
 529       }
 530
 531       // Emit lines like this one
 532       if (cType != Type || (string(URI,0,ShortURI.length()) != ShortURI &&
 533           string(URI,0,ShortURI.length()) != ShortURI2))
 534       {
 535          Out << Buffer << endl;
 536          continue;
 537       }
 538    }
 539
 540    // Just in case the file was empty
 541    if (First == true)
 542    {
 543       for (vector<string>::iterator I = List.begin(); I != List.end(); ++I)
 544       {
 545          string::size_type Space = (*I).find(' ');
 546          if (Space == string::npos)
 547             return _error->Error("Internal error");
 548
 549          Out << "deb cdrom:[" << Name << "]/" << string(*I,0,Space) <<
 550             " " << string(*I,Space+1) << endl;
 551       }
 552    }
 553
 554    Out.close();
 555
 556    rename(File.c_str(), (File + '~').c_str());
 557    if (rename(NewFile.c_str(),File.c_str()) != 0)
 558       return _error->Errno("rename","Failed to rename %s.new to %s",
 559                            File.c_str(),File.c_str());
 560
 561    return true;
 562 }
 563                                                                         /*}}}*/
 564 bool pkgCdrom::MountAndIdentCDROM(Configuration &Database, std::string &CDROM, std::string &ident, pkgCdromStatus * const log)/*{{{*/
 565 {
 566    // Startup
 567    CDROM = _config->FindDir("Acquire::cdrom::mount");
 568    if (CDROM[0] == '.')
 569       CDROM= SafeGetCWD() + '/' + CDROM;
 570
 571    if (log != NULL)
 572    {
 573       string msg;
 574       log->SetTotal(STEP_LAST);
 575       strprintf(msg, _("Using CD-ROM mount point %s\n"), CDROM.c_str());
 576       log->Update(msg, STEP_PREPARE);
 577    }
 578
 579    // Unmount the CD and get the user to put in the one they want
 580    if (_config->FindB("APT::CDROM::NoMount", false) == false)
 581    {
 582       if(log != NULL)
 583          log->Update(_("Unmounting CD-ROM\n"), STEP_UNMOUNT);
 584       UnmountCdrom(CDROM);
 585
 586       if(log != NULL)
 587       {
 588          log->Update(_("Waiting for disc...\n"), STEP_WAIT);
 589          if(!log->ChangeCdrom()) {
 590             // user aborted
 591             return false;
 592          }
 593       }
 594
 595       // Mount the new CDROM
 596       if(log != NULL)
 597          log->Update(_("Mounting CD-ROM...\n"), STEP_MOUNT);
 598
 599       if (MountCdrom(CDROM) == false)
 600          return _error->Error("Failed to mount the cdrom.");
 601    }
 602
 603    // Hash the CD to get an ID
 604    if (log != NULL)
 605       log->Update(_("Identifying.. "), STEP_IDENT);
 606
 607    if (IdentCdrom(CDROM,ident) == false)
 608    {
 609       ident = "";
 610       if (log != NULL)
 611          log->Update("\n");
 612       return false;
 613    }
 614
 615    if (log != NULL)
 616    {
 617       string msg;
 618       strprintf(msg, "[%s]\n", ident.c_str());
 619       log->Update(msg);
 620    }
 621
 622    // Read the database
 623    string DFile = _config->FindFile("Dir::State::cdroms");
 624    if (FileExists(DFile) == true)
 625    {
 626       if (ReadConfigFile(Database,DFile) == false)
 627          return _error->Error("Unable to read the cdrom database %s",
 628                               DFile.c_str());
 629    }
 630    return true;
 631 }
 632                                                                         /*}}}*/
 633 bool pkgCdrom::Ident(string &ident, pkgCdromStatus *log)                /*{{{*/
 634 {
 635    Configuration Database;
 636    std::string CDROM;
 637    if (MountAndIdentCDROM(Database, CDROM, ident, log) == false)
 638       return false;
 639
 640    if (log != NULL)
 641    {
 642       string msg;
 643       strprintf(msg, _("Stored label: %s\n"),
 644             Database.Find("CD::"+ident).c_str());
 645       log->Update(msg);
 646    }
 647
 648    // Unmount and finish
 649    if (_config->FindB("APT::CDROM::NoMount",false) == false)
 650    {
 651       if (log != NULL)
 652          log->Update(_("Unmounting CD-ROM...\n"), STEP_LAST);
 653       UnmountCdrom(CDROM);
 654    }
 655
 656    return true;
 657 }
 658                                                                         /*}}}*/
 659 bool pkgCdrom::Add(pkgCdromStatus *log)                                 /*{{{*/
 660 {
 661    Configuration Database;
 662    std::string ID, CDROM;
 663    if (MountAndIdentCDROM(Database, CDROM, ID, log) == false)
 664       return false;
 665
 666    if(log != NULL)
 667       log->Update(_("Scanning disc for index files..\n"),STEP_SCAN);
 668
 669    // Get the CD structure
 670    vector<string> List;
 671    vector<string> SourceList;
 672    vector<string> SigList;
 673    vector<string> TransList;
 674    string StartDir = SafeGetCWD();
 675    string InfoDir;
 676    if (FindPackages(CDROM,List,SourceList, SigList,TransList,InfoDir,log) == false)
 677    {
 678       if (log != NULL)
 679          log->Update("\n");
 680       return false;
 681    }
 682
 683    if (chdir(StartDir.c_str()) != 0)
 684       return _error->Errno("chdir","Unable to change to %s", StartDir.c_str());
 685
 686    if (_config->FindB("Debug::aptcdrom",false) == true)
 687    {
 688       cout << "I found (binary):" << endl;
 689       for (vector<string>::iterator I = List.begin(); I != List.end(); ++I)
 690          cout << *I << endl;
 691       cout << "I found (source):" << endl;
 692       for (vector<string>::iterator I = SourceList.begin(); I != SourceList.end(); ++I)
 693          cout << *I << endl;
 694       cout << "I found (Signatures):" << endl;
 695       for (vector<string>::iterator I = SigList.begin(); I != SigList.end(); ++I)
 696          cout << *I << endl;
 697    }
 698
 699    //log->Update(_("Cleaning package lists..."), STEP_CLEAN);
 700
 701    // Fix up the list
 702    DropBinaryArch(List);
 703    DropRepeats(List,"Packages");
 704    DropRepeats(SourceList,"Sources");
 705    // FIXME: We ignore stat() errors here as we usually have only one of those in use
 706    // This has little potencial to drop 'valid' stat() errors as we know that one of these
 707    // files need to exist, but it would be better if we would check it here
 708    _error->PushToStack();
 709    DropRepeats(SigList,"Release.gpg");
 710    DropRepeats(SigList,"InRelease");
 711    _error->RevertToStack();
 712    DropRepeats(TransList,"");
 713    if (_config->FindB("APT::CDROM::DropTranslation", true) == true)
 714       DropTranslation(TransList);
 715    if(log != NULL) {
 716       string msg;
 717       strprintf(msg, _("Found %zu package indexes, %zu source indexes, "
 718                       "%zu translation indexes and %zu signatures\n"),
 719                List.size(), SourceList.size(), TransList.size(),
 720                SigList.size());
 721       log->Update(msg, STEP_SCAN);
 722    }
 723
 724    if (List.empty() == true && SourceList.empty() == true)
 725    {
 726       if (_config->FindB("APT::CDROM::NoMount",false) == false)
 727          UnmountCdrom(CDROM);
 728       return _error->Error(_("Unable to locate any package files, perhaps this is not a Debian Disc or the wrong architecture?"));
 729    }
 730
 731    // Check if the CD is in the database
 732    string Name;
 733    if (Database.Exists("CD::" + ID) == false ||
 734        _config->FindB("APT::CDROM::Rename",false) == true)
 735    {
 736       // Try to use the CDs label if at all possible
 737       if (InfoDir.empty() == false &&
 738           FileExists(InfoDir + "/info") == true)
 739       {
 740          ifstream F((InfoDir + "/info").c_str());
 741          if (!F == 0)
 742             getline(F,Name);
 743
 744          if (Name.empty() == false)
 745          {
 746             // Escape special characters
 747             string::iterator J = Name.begin();
 748             for (; J != Name.end(); ++J)
 749                if (*J == '"' || *J == ']' || *J == '[')
 750                   *J = '_';
 751
 752             if(log != NULL)
 753             {
 754                string msg;
 755                strprintf(msg, _("Found label '%s'\n"), Name.c_str());
 756                log->Update(msg);
 757             }
 758             Database.Set("CD::" + ID + "::Label",Name);
 759          }
 760       }
 761
 762       if (_config->FindB("APT::CDROM::Rename",false) == true ||
 763           Name.empty() == true)
 764       {
 765          if(log == NULL)
 766          {
 767             if (_config->FindB("APT::CDROM::NoMount",false) == false)
 768                UnmountCdrom(CDROM);
 769             return _error->Error("No disc name found and no way to ask for it");
 770          }
 771
 772          while(true) {
 773             if(!log->AskCdromName(Name)) {
 774                // user canceld
 775                return false;
 776             }
 777             cout << "Name: '" << Name << "'" << endl;
 778
 779             if (Name.empty() == false &&
 780                 Name.find('"') == string::npos &&
 781                 Name.find('[') == string::npos &&
 782                 Name.find(']') == string::npos)
 783                break;
 784             log->Update(_("That is not a valid name, try again.\n"));
 785          }
 786       }
 787    }
 788    else
 789       Name = Database.Find("CD::" + ID);
 790
 791    // Escape special characters
 792    string::iterator J = Name.begin();
 793    for (; J != Name.end(); ++J)
 794       if (*J == '"' || *J == ']' || *J == '[')
 795          *J = '_';
 796
 797    Database.Set("CD::" + ID,Name);
 798    if(log != NULL)
 799    {
 800       string msg;
 801       strprintf(msg, _("This disc is called: \n'%s'\n"), Name.c_str());
 802       log->Update(msg);
 803       log->Update(_("Copying package lists..."), STEP_COPY);
 804    }
 805
 806    // check for existence and possibly create state directory for copying
 807    string const listDir = _config->FindDir("Dir::State::lists");
 808    string const partialListDir = listDir + "partial/";
 809    if (CreateAPTDirectoryIfNeeded(_config->FindDir("Dir::State"), partialListDir) == false &&
 810        CreateAPTDirectoryIfNeeded(listDir, partialListDir) == false)
 811       return _error->Errno("cdrom", _("List directory %spartial is missing."), listDir.c_str());
 812
 813    // take care of the signatures and copy them if they are ok
 814    // (we do this before PackageCopy as it modifies "List" and "SourceList")
 815    SigVerify SignVerify;
 816    SignVerify.CopyAndVerify(CDROM, Name, SigList, List, SourceList);
 817
 818    // Copy the package files to the state directory
 819    PackageCopy Copy;
 820    SourceCopy SrcCopy;
 821    TranslationsCopy TransCopy;
 822    if (Copy.CopyPackages(CDROM,Name,List, log) == false ||
 823        SrcCopy.CopyPackages(CDROM,Name,SourceList, log) == false ||
 824        TransCopy.CopyTranslations(CDROM,Name,TransList, log) == false)
 825       return false;
 826
 827    // reduce the List so that it takes less space in sources.list
 828    ReduceSourcelist(CDROM,List);
 829    ReduceSourcelist(CDROM,SourceList);
 830
 831    // Write the database and sourcelist
 832    if (_config->FindB("APT::cdrom::NoAct",false) == false)
 833    {
 834       if (WriteDatabase(Database) == false)
 835          return false;
 836
 837       if(log != NULL)
 838          log->Update(_("Writing new source list\n"), STEP_WRITE);
 839       if (WriteSourceList(Name,List,false) == false ||
 840           WriteSourceList(Name,SourceList,true) == false)
 841          return false;
 842    }
 843
 844    // Print the sourcelist entries
 845    if(log != NULL)
 846       log->Update(_("Source list entries for this disc are:\n"));
 847
 848    for (vector<string>::iterator I = List.begin(); I != List.end(); ++I)
 849    {
 850       string::size_type Space = (*I).find(' ');
 851       if (Space == string::npos)
 852       {
 853          if (_config->FindB("APT::CDROM::NoMount",false) == false)
 854             UnmountCdrom(CDROM);
 855          return _error->Error("Internal error");
 856       }
 857
 858       if(log != NULL)
 859       {
 860          stringstream msg;
 861          msg << "deb cdrom:[" << Name << "]/" << string(*I,0,Space) <<
 862             " " << string(*I,Space+1) << endl;
 863          log->Update(msg.str());
 864       }
 865    }
 866
 867    for (vector<string>::iterator I = SourceList.begin(); I != SourceList.end(); ++I)
 868    {
 869       string::size_type Space = (*I).find(' ');
 870       if (Space == string::npos)
 871       {
 872          if (_config->FindB("APT::CDROM::NoMount",false) == false)
 873             UnmountCdrom(CDROM);
 874          return _error->Error("Internal error");
 875       }
 876
 877       if(log != NULL) {
 878          stringstream msg;
 879          msg << "deb-src cdrom:[" << Name << "]/" << string(*I,0,Space) <<
 880             " " << string(*I,Space+1) << endl;
 881          log->Update(msg.str());
 882       }
 883    }
 884
 885    // Unmount and finish
 886    if (_config->FindB("APT::CDROM::NoMount",false) == false) {
 887       if (log != NULL)
 888          log->Update(_("Unmounting CD-ROM...\n"), STEP_LAST);
 889       UnmountCdrom(CDROM);
 890    }
 891
 892    return true;
 893 }
 894                                                                         /*}}}*/
 895 pkgUdevCdromDevices::pkgUdevCdromDevices()                              /*{{{*/
 896    : libudev_handle(NULL)
 897 {
 898
 899 }
 900                                                                         /*}}}*/
 901
 902 bool
 903 pkgUdevCdromDevices::Dlopen()                                           /*{{{*/
 904 {
 905    // alread open
 906    if(libudev_handle != NULL)
 907       return true;
 908
 909    // see if we can get libudev
 910    void *h = ::dlopen("libudev.so.0", RTLD_LAZY);
 911    if(h == NULL)
 912       return false;
 913
 914    // get the pointers to the udev structs
 915    libudev_handle = h;
 916    udev_new = (udev* (*)(void)) dlsym(h, "udev_new");
 917    udev_enumerate_add_match_property = (int (*)(udev_enumerate*, const char*, const char*))dlsym(h, "udev_enumerate_add_match_property");
 918    udev_enumerate_add_match_sysattr = (int (*)(udev_enumerate*, const char*, const char*))dlsym(h, "udev_enumerate_add_match_sysattr");
 919    udev_enumerate_scan_devices = (int (*)(udev_enumerate*))dlsym(h, "udev_enumerate_scan_devices");
 920    udev_enumerate_get_list_entry = (udev_list_entry* (*)(udev_enumerate*))dlsym(h, "udev_enumerate_get_list_entry");
 921    udev_device_new_from_syspath = (udev_device* (*)(udev*, const char*))dlsym(h, "udev_device_new_from_syspath");
 922    udev_enumerate_get_udev = (udev* (*)(udev_enumerate*))dlsym(h, "udev_enumerate_get_udev");
 923    udev_list_entry_get_name = (const char* (*)(udev_list_entry*))dlsym(h, "udev_list_entry_get_name");
 924    udev_device_get_devnode = (const char* (*)(udev_device*))dlsym(h, "udev_device_get_devnode");
 925    udev_enumerate_new = (udev_enumerate* (*)(udev*))dlsym(h, "udev_enumerate_new");
 926    udev_list_entry_get_next = (udev_list_entry* (*)(udev_list_entry*))dlsym(h, "udev_list_entry_get_next");
 927    udev_device_get_property_value = (const char* (*)(udev_device *, const char *))dlsym(h, "udev_device_get_property_value");
 928
 929    return true;
 930 }
 931                                                                         /*}}}*/
 932                                                                         /*{{{*/
 933 // convenience interface, this will just call ScanForRemovable
 934 vector<CdromDevice>
 935 pkgUdevCdromDevices::Scan()
 936 {
 937    bool CdromOnly = _config->FindB("APT::cdrom::CdromOnly", true);
 938    return ScanForRemovable(CdromOnly);
 939 }
 940                                                                         /*}}}*/
 941                                                                         /*{{{*/
 942 vector<CdromDevice>
 943 pkgUdevCdromDevices::ScanForRemovable(bool CdromOnly)
 944 {
 945    vector<CdromDevice> cdrom_devices;
 946    struct udev_enumerate *enumerate;
 947    struct udev_list_entry *l, *devices;
 948    struct udev *udev_ctx;
 949
 950    if(libudev_handle == NULL)
 951       return cdrom_devices;
 952
 953    udev_ctx = udev_new();
 954    enumerate = udev_enumerate_new (udev_ctx);
 955    if (CdromOnly)
 956       udev_enumerate_add_match_property(enumerate, "ID_CDROM", "1");
 957    else {
 958       udev_enumerate_add_match_sysattr(enumerate, "removable", "1");
 959    }
 960
 961    udev_enumerate_scan_devices (enumerate);
 962    devices = udev_enumerate_get_list_entry (enumerate);
 963    for (l = devices; l != NULL; l = udev_list_entry_get_next (l))
 964    {
 965       CdromDevice cdrom;
 966       struct udev_device *udevice;
 967       udevice = udev_device_new_from_syspath (udev_enumerate_get_udev (enumerate), udev_list_entry_get_name (l));
 968       if (udevice == NULL)
 969          continue;
 970       const char* devnode = udev_device_get_devnode(udevice);
 971
 972       // try fstab_dir first
 973       string mountpath;
 974       const char* mp = udev_device_get_property_value(udevice, "FSTAB_DIR");
 975       if (mp)
 976          mountpath = string(mp);
 977       else
 978          mountpath = FindMountPointForDevice(devnode);
 979
 980       // fill in the struct
 981       cdrom.DeviceName = string(devnode);
 982       if (mountpath != "") {
 983          cdrom.MountPath = mountpath;
 984          string s = mountpath;
 985          cdrom.Mounted = IsMounted(s);
 986       } else {
 987          cdrom.Mounted = false;
 988          cdrom.MountPath = "";
 989       }
 990       cdrom_devices.push_back(cdrom);
 991    }
 992    return cdrom_devices;
 993 }
 994                                                                         /*}}}*/
 995
 996 pkgUdevCdromDevices::~pkgUdevCdromDevices()                             /*{{{*/
 997 {
 998    if (libudev_handle != NULL)
 999       dlclose(libudev_handle);
1000 }
1001                                                                         /*}}}*/