mirror of
				https://github.com/docker/compose.git
				synced 2025-10-31 03:03:49 +01:00 
			
		
		
		
	
		
			
				
	
	
		
			68 lines
		
	
	
		
			1.5 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			68 lines
		
	
	
		
			1.5 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| /*
 | |
|    Copyright 2020 Docker Compose CLI authors
 | |
| 
 | |
|    Licensed under the Apache License, Version 2.0 (the "License");
 | |
|    you may not use this file except in compliance with the License.
 | |
|    You may obtain a copy of the License at
 | |
| 
 | |
|        http://www.apache.org/licenses/LICENSE-2.0
 | |
| 
 | |
|    Unless required by applicable law or agreed to in writing, software
 | |
|    distributed under the License is distributed on an "AS IS" BASIS,
 | |
|    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 | |
|    See the License for the specific language governing permissions and
 | |
|    limitations under the License.
 | |
| */
 | |
| 
 | |
| package proxy
 | |
| 
 | |
| import (
 | |
| 	"github.com/hashicorp/go-uuid"
 | |
| 	"github.com/sirupsen/logrus"
 | |
| 	"google.golang.org/grpc/metadata"
 | |
| 
 | |
| 	streamsv1 "github.com/docker/compose-cli/cli/server/protos/streams/v1"
 | |
| 	"github.com/docker/compose-cli/cli/server/proxy/streams"
 | |
| )
 | |
| 
 | |
| func (p *proxy) NewStream(stream streamsv1.Streaming_NewStreamServer) error {
 | |
| 	var (
 | |
| 		ctx = stream.Context()
 | |
| 	)
 | |
| 	id, err := uuid.GenerateUUID()
 | |
| 	if err != nil {
 | |
| 		return err
 | |
| 	}
 | |
| 	md := metadata.New(map[string]string{
 | |
| 		"id": id,
 | |
| 	})
 | |
| 
 | |
| 	// return the id of the stream to the client
 | |
| 	if err := stream.SendHeader(md); err != nil {
 | |
| 		return err
 | |
| 	}
 | |
| 
 | |
| 	errc := make(chan error)
 | |
| 
 | |
| 	p.mu.Lock()
 | |
| 	p.streams[id] = &streams.Stream{
 | |
| 		Streaming_NewStreamServer: stream,
 | |
| 		ErrChan:                   errc,
 | |
| 	}
 | |
| 	p.mu.Unlock()
 | |
| 
 | |
| 	defer func() {
 | |
| 		p.mu.Lock()
 | |
| 		delete(p.streams, id)
 | |
| 		p.mu.Unlock()
 | |
| 	}()
 | |
| 
 | |
| 	select {
 | |
| 	case err := <-errc:
 | |
| 		return err
 | |
| 	case <-ctx.Done():
 | |
| 		logrus.Debug("client context canceled")
 | |
| 		return ctx.Err()
 | |
| 	}
 | |
| }
 |