func()

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
}