in pkg/stream/local/local_file_streamer.go [36:58]
func (s *streamer) CreateStream(url string) (io.ReadSeeker, int64, string, error) {
filePath, err := parseURL(url)
if err != nil {
return nil, 0, "", err
}
md5Sum, md5Err := md5SumFile(filePath, s.fileSystem)
if md5Err != nil {
return nil, 0, "", md5Err
}
file, openErr := s.fileSystem.Open(filePath)
if openErr != nil {
return nil, 0, "", openErr
}
fileInfo, statErr := file.Stat()
if statErr != nil {
return nil, 0, "", statErr
}
return file, fileInfo.Size(), md5Sum, nil
}