in internal/seeder/seed.go [60:82]
func (s *SeedService) insertFromIterator(it objectIterator) error {
for {
obj, err := it.Next()
if err != nil {
if err == iterator.Done {
break
}
return fmt.Errorf("error retrieving iterator object: %v", err)
}
metadata := newMetadata(obj)
if err := s.metadataRepo.Insert(metadata); err != nil {
log.Printf("Error inserting metadata: %v", err)
}
if err := s.directoryRepo.UpsertParentDirs(repo.StorageClass(metadata.StorageClass), metadata.Bucket, metadata.Name, metadata.Size, 1); err != nil {
log.Printf("Error upserting directories: %v", err)
}
}
return nil
}