角度 - S3バケットの内容をObservableとして取得する方法

Question

Angular4でサービスメソッドを構造化してS3バケットの内容をObservableとして返すs3.listObjects呼び出しを作成するにはどうすればよいですか？

は、ここで私は、現時点でしようとして無残に失敗してるものです：ちょうど

public loadFilesFromS3(): Observable<any[]> { 

    const s3 = new AWS.S3(); 
    const params = { 
     Bucket: 'bucket-name', 
     Prefix: 'prefix-name' 
    }; 

    return (
     s3.listObjects(params, (err, data) => { 
     if (err) { 
      throw err; 
     } else { 
      return(data); 
     } 
     }) 
    ) 

    } 

瞬間のために、この上の完全に立ち往生！ ： - |

Answer 1

ここで私が思いついた宿題がいくつかあります。うまく動作しているようです：

private tracksListSubject = new BehaviorSubject([]); 
public tracksList$: Observable<Track[]> = this.tracksListSubject.asObservable(); 

public loadTracksFromS3() { 

    console.log('loading tracks from S3...'); 

    this.authenticate(); 

    const s3 = new AWS.S3(); 
    const params = { 
     Bucket: config.AWS_BUCKET_NAME 
    }; 

    s3.listObjects(params, (err, data) => { 
     if (err) { 
     console.log('error!', err); 
     } 

     const raw = data.Contents; 
     const tracks: Track[] = []; 
     raw.forEach((item) => { 
     tracks.push({ 
      id: item.ETag, 
      title: item.Key, 
      url: config.AWS_BASE_URL + item.Key, 
      size: Math.round(item.Size/1024/1024 * 10)/10 
     }) 
     }); 

     console.log(tracks.length, 'tracks loaded'); 
     this.tracksListSubject.next(tracks); 
    }); 

    } 

その後、他の部品に私はこのサービスを注入することができ、その上にtracksList$プロパティに加入。私がサービス内のトラックのリストを変更するたびに、私はthis.tracksListSubject.next(newTracksList)を発行します。

Answer 2

Observable.bindNodeCallback関数を使用して、s3.listObjects関数をノードスタイルのコールバックからObservableを返す関数に変換することができます。もし上記のようにすることを

const listObjectsAsObservable = Observable.bindNodeCallback(s3.listObjects.bind(s3)); 

注S3がthisであることを知らせるために、関数にS3オブジェクトをバインドする必要があります。そうしないと、エラーが発生します。

const params = { 
    Bucket: config.AWS_BUCKET_NAME 
}; 
listObjectsAsObservable(params) 
    .subscribe({ 
    next: (response) => console.log(response), 
    error: (err) => console.log(err) 
    });