Method UnmarshalAny

core/transfer/registry/registry.go:351–432

(ctx context.Context, sm streaming.StreamGetter, a typeurl.Any)

}

func (r *OCIRegistry) UnmarshalAny(ctx context.Context, sm streaming.StreamGetter, a typeurl.Any) error {
	var s transfertypes.OCIRegistry
	if err := typeurl.UnmarshalTo(a, &s); err != nil {
		return err
	}

	hostOptions := config.HostOptions{}
	if s.Resolver != nil {
		if s.Resolver.HostDir != "" {
			hostOptions.HostDir = config.HostDirFromRoot(s.Resolver.HostDir)
		}
		if s.Resolver.DefaultScheme != "" {
			hostOptions.DefaultScheme = s.Resolver.DefaultScheme
		}
		if sid := s.Resolver.AuthStream; sid != "" {
			stream, err := sm.Get(ctx, sid)
			if err != nil {
				log.G(ctx).WithError(err).WithField("stream", sid).Debug("failed to get auth stream")
				return err
			}
			r.creds = &credCallback{
				stream: stream,
			}
			hostOptions.Credentials = func(host string) (string, string, error) {
				c, err := r.creds.GetCredentials(context.Background(), s.Reference, host)
				if err != nil {
					return "", "", err
				}

				return c.Username, c.Secret, nil
			}
		}
		r.headers = http.Header{}
		for k, v := range s.Resolver.Headers {
			r.headers.Add(k, v)
		}

		if s.Resolver.HttpDebug != transfertypes.HTTPDebug_DISABLED {
			var writer io.WriteCloser

			// Stream to local client.
			if sid := s.Resolver.LogsStream; sid != "" {
				stream, err := sm.Get(ctx, sid)
				if err != nil {
					return fmt.Errorf("failed to get stream for HTTP debug logs: %w", err)
				}

				writer = tstreaming.WriteByteStream(ctx, stream)
			} else {
				writer = log.G(ctx).Writer()
			}

			go func() {
				<-ctx.Done()
				if err := writer.Close(); err != nil {
					log.G(ctx).Errorf("failed to close HTTP debug logs stream: %v", err)
				}
			}()