(ctx context.Context, provider string, runEmbeddings bool, params map[string]string, data []byte)
| 681 | } |
| 682 | |
| 683 | func (r *Request) createHttpRequest(ctx context.Context, provider string, runEmbeddings bool, params map[string]string, data []byte) (*http.Request, error) { |
| 684 | resourceName := "" |
| 685 | if provider == "azure" { |
| 686 | val, err := r.GetSettingValue("azure", "resourceName") |
| 687 | if err != nil { |
| 688 | return nil, err |
| 689 | } |
| 690 | |
| 691 | resourceName = val |
| 692 | } |
| 693 | |
| 694 | key, err := r.GetSettingValue(provider, "apikey") |
| 695 | if err != nil { |
| 696 | return nil, err |
| 697 | } |
| 698 | |
| 699 | url := buildRequestUrl(provider, runEmbeddings, resourceName, params) |
| 700 | if len(url) == 0 { |
| 701 | return nil, errors.New("request url is empty") |
| 702 | } |
| 703 | |
| 704 | hreq, err := http.NewRequestWithContext(ctx, r.Forwarded.Method, url, io.NopCloser(bytes.NewReader(data))) |
| 705 | |
| 706 | if provider == "azure" { |
| 707 | hreq.Header.Set("api-key", key) |
| 708 | } else { |
| 709 | hreq.Header.Set("Authorization", fmt.Sprintf("Bearer %s", key)) |
| 710 | } |
| 711 | |
| 712 | for k := range r.Forwarded.Header { |
| 713 | if strings.HasPrefix(strings.ToLower(k), "authorization") { |
| 714 | continue |
| 715 | } |
| 716 | |
| 717 | if strings.HasPrefix(strings.ToLower(k), "api-key") { |
| 718 | continue |
| 719 | } |
| 720 | |
| 721 | if strings.ToLower(k) == "accept-encoding" { |
| 722 | continue |
| 723 | } |
| 724 | |
| 725 | hreq.Header.Set(k, r.Forwarded.Header.Get(k)) |
| 726 | } |
| 727 | |
| 728 | return hreq, err |
| 729 | } |
no test coverage detected