@@ -45,10 +45,12 @@ func (l *LayerPullingFSLayer) Next(event events.LayerEvent) (Layer, error) {
4545 return & LayerWaiting {l .layerBase }, nil
4646 case * events.Downloading :
4747 return & LayerDownloading {l .layerBase , event .Progress ()}, nil
48+ case * events.DownloadComplete :
49+ return & LayerDownloadComplete {l .layerBase }, nil
4850 case * events.AlreadyExists :
4951 return & LayerAlreadyExists {l .layerBase }, nil
5052 case * events.LayerError :
51- return & LayerErrored {layerBase { event . LayerId ()} , event .Error }, nil
53+ return & LayerErrored {l . layerBase , event .Error }, nil
5254 }
5355 return nil , fmt .Errorf ("invalid transition (pulling-fs-layer + %T)" , event )
5456}
@@ -199,8 +201,8 @@ func (l *LayerAlreadyExists) Status() string {
199201 return "Already exists"
200202}
201203
202- func (l * LayerAlreadyExists ) Next (events.LayerEvent ) (Layer , error ) {
203- return nil , fmt .Errorf ("already completed" )
204+ func (l * LayerAlreadyExists ) Next (event events.LayerEvent ) (Layer , error ) {
205+ return nil , fmt .Errorf ("already completed, tried %T" , event )
204206}
205207
206208type LayerPullComplete struct {
@@ -211,6 +213,6 @@ func (l *LayerPullComplete) Status() string {
211213 return "Pull complete"
212214}
213215
214- func (l * LayerPullComplete ) Next (events.LayerEvent ) (Layer , error ) {
215- return nil , fmt .Errorf ("already completed" )
216+ func (l * LayerPullComplete ) Next (event events.LayerEvent ) (Layer , error ) {
217+ return nil , fmt .Errorf ("already completed, tried %T" , event )
216218}
0 commit comments