images.go 30.6 KB
Newer Older
1
2
3
package server

import (
4
	"archive/zip"
5
	"bytes"
6
	"context"
7
	"crypto/sha256"
8
	"encoding/base64"
Patrick Devine's avatar
Patrick Devine committed
9
	"encoding/hex"
10
11
12
13
	"encoding/json"
	"errors"
	"fmt"
	"io"
14
	"io/fs"
15
	"log"
16
	"log/slog"
17
	"net/http"
Michael Yang's avatar
Michael Yang committed
18
	"net/url"
19
20
	"os"
	"path/filepath"
Michael Yang's avatar
Michael Yang committed
21
	"runtime"
Michael Yang's avatar
Michael Yang committed
22
	"strconv"
23
24
	"strings"

Michael Yang's avatar
Michael Yang committed
25
26
	"golang.org/x/exp/slices"

27
	"github.com/ollama/ollama/api"
28
	"github.com/ollama/ollama/auth"
29
	"github.com/ollama/ollama/convert"
Michael Yang's avatar
Michael Yang committed
30
	"github.com/ollama/ollama/format"
31
	"github.com/ollama/ollama/llm"
32
	"github.com/ollama/ollama/server/envconfig"
33
	"github.com/ollama/ollama/types/errtypes"
Michael Yang's avatar
Michael Yang committed
34
	"github.com/ollama/ollama/types/model"
35
	"github.com/ollama/ollama/version"
36
37
)

Michael Yang's avatar
Michael Yang committed
38
39
40
41
42
43
44
type registryOptions struct {
	Insecure bool
	Username string
	Password string
	Token    string
}

45
type Model struct {
Michael Yang's avatar
Michael Yang committed
46
	Name           string `json:"name"`
47
	Config         ConfigV2
Michael Yang's avatar
Michael Yang committed
48
49
	ShortName      string
	ModelPath      string
50
	ParentModel    string
Michael Yang's avatar
Michael Yang committed
51
52
53
54
55
56
	AdapterPaths   []string
	ProjectorPaths []string
	Template       string
	System         string
	License        []string
	Digest         string
Patrick Devine's avatar
Patrick Devine committed
57
	Size           int64
Michael Yang's avatar
Michael Yang committed
58
	Options        map[string]interface{}
59
60
61
	Messages       []Message
}

62
63
64
65
func (m *Model) IsEmbedding() bool {
	return slices.Contains(m.Config.ModelFamilies, "bert") || slices.Contains(m.Config.ModelFamilies, "nomic-bert")
}

Michael Yang's avatar
Michael Yang committed
66
67
68
69
70
71
72
func (m *Model) String() string {
	var modelfile model.File

	modelfile.Commands = append(modelfile.Commands, model.Command{
		Name: "model",
		Args: m.ModelPath,
	})
73
74

	if m.Template != "" {
Michael Yang's avatar
Michael Yang committed
75
76
77
78
		modelfile.Commands = append(modelfile.Commands, model.Command{
			Name: "template",
			Args: m.Template,
		})
79
80
81
	}

	if m.System != "" {
Michael Yang's avatar
Michael Yang committed
82
83
84
85
		modelfile.Commands = append(modelfile.Commands, model.Command{
			Name: "system",
			Args: m.System,
		})
86
87
88
	}

	for _, adapter := range m.AdapterPaths {
Michael Yang's avatar
Michael Yang committed
89
90
91
92
		modelfile.Commands = append(modelfile.Commands, model.Command{
			Name: "adapter",
			Args: adapter,
		})
93
94
95
	}

	for _, projector := range m.ProjectorPaths {
Michael Yang's avatar
Michael Yang committed
96
97
98
99
		modelfile.Commands = append(modelfile.Commands, model.Command{
			Name: "projector",
			Args: projector,
		})
100
101
102
103
104
105
	}

	for k, v := range m.Options {
		switch v := v.(type) {
		case []any:
			for _, s := range v {
Michael Yang's avatar
Michael Yang committed
106
107
108
109
				modelfile.Commands = append(modelfile.Commands, model.Command{
					Name: k,
					Args: fmt.Sprintf("%v", s),
				})
110
111
			}
		default:
Michael Yang's avatar
Michael Yang committed
112
113
114
115
			modelfile.Commands = append(modelfile.Commands, model.Command{
				Name: k,
				Args: fmt.Sprintf("%v", v),
			})
116
117
118
119
		}
	}

	for _, license := range m.License {
Michael Yang's avatar
Michael Yang committed
120
121
122
123
		modelfile.Commands = append(modelfile.Commands, model.Command{
			Name: "license",
			Args: license,
		})
124
125
126
	}

	for _, msg := range m.Messages {
Michael Yang's avatar
Michael Yang committed
127
128
129
130
		modelfile.Commands = append(modelfile.Commands, model.Command{
			Name: "message",
			Args: fmt.Sprintf("%s %s", msg.Role, msg.Content),
		})
131
132
	}

Michael Yang's avatar
Michael Yang committed
133
	return modelfile.String()
134
135
}

136
137
138
type Message struct {
	Role    string `json:"role"`
	Content string `json:"content"`
139
140
141
142
143
}

type ManifestV2 struct {
	SchemaVersion int      `json:"schemaVersion"`
	MediaType     string   `json:"mediaType"`
Michael Yang's avatar
Michael Yang committed
144
	Config        *Layer   `json:"config"`
145
146
147
148
	Layers        []*Layer `json:"layers"`
}

type ConfigV2 struct {
149
150
151
152
153
154
	ModelFormat   string   `json:"model_format"`
	ModelFamily   string   `json:"model_family"`
	ModelFamilies []string `json:"model_families"`
	ModelType     string   `json:"model_type"`
	FileType      string   `json:"file_type"`

155
	// required by spec
156
157
	Architecture string `json:"architecture"`
	OS           string `json:"os"`
158
	RootFS       RootFS `json:"rootfs"`
159
160
}

Michael Yang's avatar
Michael Yang committed
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
func (c *ConfigV2) SetModelFormat(format string) {
	if c.ModelFormat == "" {
		c.ModelFormat = format
	}
}

func (c *ConfigV2) SetModelFamily(families ...string) {
	for _, family := range families {
		if c.ModelFamily == "" {
			c.ModelFamily = family
		}

		if !slices.Contains(c.ModelFamilies, family) {
			c.ModelFamilies = append(c.ModelFamilies, family)
		}
	}
}

func (c *ConfigV2) SetModelType(modelType string) {
	if c.ModelType == "" {
		c.ModelType = modelType
	}
}

func (c *ConfigV2) SetFileType(fileType string) {
	if c.FileType == "" {
		c.FileType = fileType
	}
}

191
192
193
194
195
type RootFS struct {
	Type    string   `json:"type"`
	DiffIDs []string `json:"diff_ids"`
}

Michael Yang's avatar
Michael Yang committed
196
func (m *ManifestV2) GetTotalSize() (total int64) {
Patrick Devine's avatar
Patrick Devine committed
197
198
199
	for _, layer := range m.Layers {
		total += layer.Size
	}
Michael Yang's avatar
Michael Yang committed
200

Patrick Devine's avatar
Patrick Devine committed
201
202
203
204
	total += m.Config.Size
	return total
}

Patrick Devine's avatar
Patrick Devine committed
205
func GetManifest(mp ModelPath) (*ManifestV2, string, error) {
206
	fp, err := mp.GetManifestPath()
207
	if err != nil {
Patrick Devine's avatar
Patrick Devine committed
208
		return nil, "", err
209
	}
210

211
	if _, err = os.Stat(fp); err != nil {
Patrick Devine's avatar
Patrick Devine committed
212
		return nil, "", err
213
214
215
216
	}

	var manifest *ManifestV2

217
	bts, err := os.ReadFile(fp)
218
	if err != nil {
Patrick Devine's avatar
Patrick Devine committed
219
		return nil, "", fmt.Errorf("couldn't open file '%s'", fp)
220
221
	}

Patrick Devine's avatar
Patrick Devine committed
222
223
224
	shaSum := sha256.Sum256(bts)
	shaStr := hex.EncodeToString(shaSum[:])

225
	if err := json.Unmarshal(bts, &manifest); err != nil {
Patrick Devine's avatar
Patrick Devine committed
226
		return nil, "", err
227
228
	}

Patrick Devine's avatar
Patrick Devine committed
229
	return manifest, shaStr, nil
230
231
232
}

func GetModel(name string) (*Model, error) {
233
	mp := ParseModelPath(name)
Patrick Devine's avatar
Patrick Devine committed
234
	manifest, digest, err := GetManifest(mp)
235
236
237
238
239
	if err != nil {
		return nil, err
	}

	model := &Model{
240
241
242
243
244
		Name:      mp.GetFullTagname(),
		ShortName: mp.GetShortTagname(),
		Digest:    digest,
		Template:  "{{ .Prompt }}",
		License:   []string{},
Patrick Devine's avatar
Patrick Devine committed
245
		Size:      manifest.GetTotalSize(),
246
247
	}

248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
	filename, err := GetBlobsPath(manifest.Config.Digest)
	if err != nil {
		return nil, err
	}

	configFile, err := os.Open(filename)
	if err != nil {
		return nil, err
	}
	defer configFile.Close()

	if err := json.NewDecoder(configFile).Decode(&model.Config); err != nil {
		return nil, err
	}

263
	for _, layer := range manifest.Layers {
Patrick Devine's avatar
Patrick Devine committed
264
		filename, err := GetBlobsPath(layer.Digest)
265
266
267
268
		if err != nil {
			return nil, err
		}

269
270
271
		switch layer.MediaType {
		case "application/vnd.ollama.image.model":
			model.ModelPath = filename
272
			model.ParentModel = layer.From
273
		case "application/vnd.ollama.image.embed":
274
275
			// Deprecated in versions  > 0.1.2
			// TODO: remove this warning in a future version
276
			slog.Info("WARNING: model contains embeddings, but embeddings in modelfiles have been deprecated and will be ignored.")
277
278
		case "application/vnd.ollama.image.adapter":
			model.AdapterPaths = append(model.AdapterPaths, filename)
Michael Yang's avatar
Michael Yang committed
279
280
		case "application/vnd.ollama.image.projector":
			model.ProjectorPaths = append(model.ProjectorPaths, filename)
281
282
283
284
285
286
287
288
289
		case "application/vnd.ollama.image.template":
			bts, err := os.ReadFile(filename)
			if err != nil {
				return nil, err
			}

			model.Template = string(bts)
		case "application/vnd.ollama.image.system":
			bts, err := os.ReadFile(filename)
290
291
292
			if err != nil {
				return nil, err
			}
293
294

			model.System = string(bts)
295
296
297
298
299
300
301
		case "application/vnd.ollama.image.prompt":
			bts, err := os.ReadFile(filename)
			if err != nil {
				return nil, err
			}

			model.Template = string(bts)
302
		case "application/vnd.ollama.image.params":
Michael Yang's avatar
Michael Yang committed
303
304
305
306
307
			params, err := os.Open(filename)
			if err != nil {
				return nil, err
			}
			defer params.Close()
308

309
			// parse model options parameters into a map so that we can see which fields have been specified explicitly
310
			if err = json.NewDecoder(params).Decode(&model.Options); err != nil {
311
312
				return nil, err
			}
313
314
315
316
317
318
319
320
321
322
		case "application/vnd.ollama.image.messages":
			msgs, err := os.Open(filename)
			if err != nil {
				return nil, err
			}
			defer msgs.Close()

			if err = json.NewDecoder(msgs).Decode(&model.Messages); err != nil {
				return nil, err
			}
Patrick Devine's avatar
Patrick Devine committed
323
324
325
326
327
328
		case "application/vnd.ollama.image.license":
			bts, err := os.ReadFile(filename)
			if err != nil {
				return nil, err
			}
			model.License = append(model.License, string(bts))
329
330
331
332
333
334
		}
	}

	return model, nil
}

335
336
func realpath(mfDir, from string) string {
	abspath, err := filepath.Abs(from)
Michael Yang's avatar
Michael Yang committed
337
	if err != nil {
338
		return from
339
340
	}

Michael Yang's avatar
Michael Yang committed
341
	home, err := os.UserHomeDir()
342
	if err != nil {
Michael Yang's avatar
Michael Yang committed
343
		return abspath
344
345
	}

346
	if from == "~" {
Michael Yang's avatar
Michael Yang committed
347
		return home
348
349
350
351
352
353
354
	} else if strings.HasPrefix(from, "~/") {
		return filepath.Join(home, from[2:])
	}

	if _, err := os.Stat(filepath.Join(mfDir, from)); err == nil {
		// this is a file relative to the Modelfile
		return filepath.Join(mfDir, from)
355
356
	}

Michael Yang's avatar
Michael Yang committed
357
358
359
	return abspath
}

Michael Yang's avatar
Michael Yang committed
360
func CreateModel(ctx context.Context, name, modelFileDir, quantization string, modelfile *model.File, fn func(resp api.ProgressResponse)) error {
361
362
363
364
365
366
367
	deleteMap := make(map[string]struct{})
	if manifest, _, err := GetManifest(ParseModelPath(name)); err == nil {
		for _, layer := range append(manifest.Layers, manifest.Config) {
			deleteMap[layer.Digest] = struct{}{}
		}
	}

368
369
	config := ConfigV2{
		OS:           "linux",
Michael Yang's avatar
Michael Yang committed
370
		Architecture: "amd64",
Michael Yang's avatar
Michael Yang committed
371
372
373
		RootFS: RootFS{
			Type: "layers",
		},
374
375
	}

Michael Yang's avatar
Michael Yang committed
376
	var layers Layers
377
	messages := []string{}
Michael Yang's avatar
Michael Yang committed
378

379
	params := make(map[string][]string)
Michael Yang's avatar
Michael Yang committed
380
381
	fromParams := make(map[string]any)

Michael Yang's avatar
Michael Yang committed
382
	for _, c := range modelfile.Commands {
Michael Yang's avatar
Michael Yang committed
383
384
		mediatype := fmt.Sprintf("application/vnd.ollama.image.%s", c.Name)

385
386
		switch c.Name {
		case "model":
Michael Yang's avatar
Michael Yang committed
387
388
389
390
391
392
393
394
395
			if strings.HasPrefix(c.Args, "@") {
				blobPath, err := GetBlobsPath(strings.TrimPrefix(c.Args, "@"))
				if err != nil {
					return err
				}

				c.Args = blobPath
			}

396
397
			pathName := realpath(modelFileDir, c.Args)

398
			ggufName, err := convertModel(name, pathName, fn)
399
			if err != nil {
400
				var pathErr *fs.PathError
401
402
403
				switch {
				case errors.Is(err, zip.ErrFormat):
					// it's not a safetensor archive
404
405
				case errors.As(err, &pathErr):
					// it's not a file on disk, could be a model reference
406
407
408
409
410
411
412
413
				default:
					return err
				}
			}

			if ggufName != "" {
				pathName = ggufName
				defer os.RemoveAll(ggufName)
Michael Yang's avatar
Michael Yang committed
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433

				if quantization != "" {
					quantization = strings.ToUpper(quantization)
					fn(api.ProgressResponse{Status: fmt.Sprintf("quantizing %s model to %s", "F16", quantization)})
					tempfile, err := os.CreateTemp(filepath.Dir(ggufName), quantization)
					if err != nil {
						return err
					}
					defer os.RemoveAll(tempfile.Name())

					if err := llm.Quantize(ggufName, tempfile.Name(), quantization); err != nil {
						return err
					}

					if err := tempfile.Close(); err != nil {
						return err
					}

					pathName = tempfile.Name()
				}
434
435
436
			}

			bin, err := os.Open(pathName)
437
			if err != nil {
Michael Yang's avatar
Michael Yang committed
438
439
440
441
442
443
				// not a file on disk so must be a model reference
				modelpath := ParseModelPath(c.Args)
				manifest, _, err := GetManifest(modelpath)
				switch {
				case errors.Is(err, os.ErrNotExist):
					fn(api.ProgressResponse{Status: "pulling model"})
Michael Yang's avatar
Michael Yang committed
444
					if err := PullModel(ctx, c.Args, &registryOptions{}, fn); err != nil {
445
446
447
						return err
					}

Michael Yang's avatar
Michael Yang committed
448
					manifest, _, err = GetManifest(modelpath)
449
450
451
					if err != nil {
						return err
					}
Michael Yang's avatar
Michael Yang committed
452
453
				case err != nil:
					return err
454
				}
455

456
				fn(api.ProgressResponse{Status: "reading model metadata"})
Michael Yang's avatar
Michael Yang committed
457
				fromConfigPath, err := GetBlobsPath(manifest.Config.Digest)
Michael Yang's avatar
Michael Yang committed
458
459
460
461
				if err != nil {
					return err
				}

Michael Yang's avatar
Michael Yang committed
462
				fromConfigFile, err := os.Open(fromConfigPath)
Michael Yang's avatar
Michael Yang committed
463
464
465
				if err != nil {
					return err
				}
Michael Yang's avatar
Michael Yang committed
466
				defer fromConfigFile.Close()
Michael Yang's avatar
Michael Yang committed
467

Michael Yang's avatar
Michael Yang committed
468
469
				var fromConfig ConfigV2
				if err := json.NewDecoder(fromConfigFile).Decode(&fromConfig); err != nil {
Michael Yang's avatar
Michael Yang committed
470
471
472
					return err
				}

Bruce MacDonald's avatar
Bruce MacDonald committed
473
474
475
476
477
				// if the model is still not in gguf format, error out
				if fromConfig.ModelFormat != "gguf" {
					return fmt.Errorf("%s is not in gguf format, this base model is not compatible with this version of ollama", c.Args)
				}

Michael Yang's avatar
Michael Yang committed
478
479
480
481
				config.SetModelFormat(fromConfig.ModelFormat)
				config.SetModelFamily(append(fromConfig.ModelFamilies, fromConfig.ModelFamily)...)
				config.SetModelType(fromConfig.ModelType)
				config.SetFileType(fromConfig.FileType)
Michael Yang's avatar
Michael Yang committed
482

Michael Yang's avatar
Michael Yang committed
483
484
485
486
				for _, layer := range manifest.Layers {
					deleteMap[layer.Digest] = struct{}{}
					if layer.MediaType == "application/vnd.ollama.image.params" {
						fromParamsPath, err := GetBlobsPath(layer.Digest)
Michael Yang's avatar
Michael Yang committed
487
488
489
490
						if err != nil {
							return err
						}

Michael Yang's avatar
Michael Yang committed
491
						fromParamsFile, err := os.Open(fromParamsPath)
Michael Yang's avatar
Michael Yang committed
492
493
494
						if err != nil {
							return err
						}
Michael Yang's avatar
Michael Yang committed
495
						defer fromParamsFile.Close()
Michael Yang's avatar
Michael Yang committed
496

Michael Yang's avatar
Michael Yang committed
497
						if err := json.NewDecoder(fromParamsFile).Decode(&fromParams); err != nil {
Michael Yang's avatar
Michael Yang committed
498
499
500
501
							return err
						}
					}

Michael Yang's avatar
Michael Yang committed
502
					layer, err := NewLayerFromLayer(layer.Digest, layer.MediaType, modelpath.GetShortTagname())
503
504
505
					if err != nil {
						return err
					}
Michael Yang's avatar
Michael Yang committed
506

Michael Yang's avatar
Michael Yang committed
507
					layers.Add(layer)
508
				}
Michael Yang's avatar
Michael Yang committed
509
510
511

				deleteMap[manifest.Config.Digest] = struct{}{}
				continue
512
			}
Michael Yang's avatar
Michael Yang committed
513
			defer bin.Close()
514

515
516
517
			var offset int64
			for {
				fn(api.ProgressResponse{Status: "creating model layer"})
518
519
520
				if _, err := bin.Seek(offset, io.SeekStart); err != nil {
					return err
				}
521

Michael Yang's avatar
Michael Yang committed
522
523
524
525
526
527
528
				ggml, size, err := llm.DecodeGGML(bin)
				if errors.Is(err, io.EOF) {
					break
				} else if errors.Is(err, llm.ErrUnsupportedFormat) {
					return fmt.Errorf("model binary specified in FROM field is not a valid gguf format model, %w", err)
				} else if err != nil {
					return err
529
				}
Michael Yang's avatar
Michael Yang committed
530

Michael Yang's avatar
Michael Yang committed
531
				config.SetModelFormat(ggml.Name())
Michael Yang's avatar
Michael Yang committed
532
533
534
				config.SetModelFamily(ggml.KV().Architecture())
				config.SetModelType(format.HumanNumber(ggml.KV().ParameterCount()))
				config.SetFileType(ggml.KV().FileType())
535

536
				mediatype := mediatype
Michael Yang's avatar
Michael Yang committed
537
				if ggml.KV().Architecture() == "clip" {
538
539
					mediatype = "application/vnd.ollama.image.projector"
				}
540

Michael Yang's avatar
Michael Yang committed
541
				sr := io.NewSectionReader(bin, offset, size)
542
543
544
545
546
547
548
				layer, err := NewLayer(sr, mediatype)
				if err != nil {
					return err
				}

				layers.Add(layer)

Michael Yang's avatar
Michael Yang committed
549
				offset += size
550
			}
Michael Yang's avatar
Michael Yang committed
551
		case "adapter":
552
553
554
555
556
557
558
559
			if strings.HasPrefix(c.Args, "@") {
				blobPath, err := GetBlobsPath(strings.TrimPrefix(c.Args, "@"))
				if err != nil {
					return err
				}

				c.Args = blobPath
			}
Bruce MacDonald's avatar
Bruce MacDonald committed
560

Michael Yang's avatar
Michael Yang committed
561
			fn(api.ProgressResponse{Status: "creating adapter layer"})
562
			bin, err := os.Open(realpath(modelFileDir, c.Args))
563
			if err != nil {
Michael Yang's avatar
Michael Yang committed
564
				return err
565
			}
Michael Yang's avatar
Michael Yang committed
566
			defer bin.Close()
567

Michael Yang's avatar
Michael Yang committed
568
			_, size, err := llm.DecodeGGML(bin)
Michael Yang's avatar
Michael Yang committed
569
570
571
572
			if err != nil {
				return err
			}

Michael Yang's avatar
Michael Yang committed
573
			sr := io.NewSectionReader(bin, 0, size)
Michael Yang's avatar
Michael Yang committed
574
			layer, err := NewLayer(sr, mediatype)
575
			if err != nil {
Michael Yang's avatar
Michael Yang committed
576
				return err
577
			}
Bruce MacDonald's avatar
Bruce MacDonald committed
578

Michael Yang's avatar
Michael Yang committed
579
			layers.Add(layer)
Michael Yang's avatar
Michael Yang committed
580
581
		case "license":
			fn(api.ProgressResponse{Status: "creating license layer"})
Michael Yang's avatar
Michael Yang committed
582
583
584

			bin := strings.NewReader(c.Args)
			layer, err := NewLayer(bin, mediatype)
Bruce MacDonald's avatar
Bruce MacDonald committed
585
586
587
588
			if err != nil {
				return err
			}

Michael Yang's avatar
Michael Yang committed
589
			layers.Add(layer)
Michael Yang's avatar
Michael Yang committed
590
591
592
		case "template", "system":
			fn(api.ProgressResponse{Status: fmt.Sprintf("creating %s layer", c.Name)})

Michael Yang's avatar
Michael Yang committed
593
594
			bin := strings.NewReader(c.Args)
			layer, err := NewLayer(bin, mediatype)
595
			if err != nil {
596
				return err
597
			}
598

Michael Yang's avatar
Michael Yang committed
599
			layers.Replace(layer)
600
601
		case "message":
			messages = append(messages, c.Args)
602
		default:
603
			params[c.Name] = append(params[c.Name], c.Args)
604
605
606
		}
	}

607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
	if len(messages) > 0 {
		fn(api.ProgressResponse{Status: "creating parameters layer"})

		msgs := make([]api.Message, 0)

		for _, m := range messages {
			// todo: handle images
			msg := strings.SplitN(m, ": ", 2)
			msgs = append(msgs, api.Message{Role: msg[0], Content: msg[1]})
		}

		var b bytes.Buffer
		if err := json.NewEncoder(&b).Encode(msgs); err != nil {
			return err
		}

		layer, err := NewLayer(&b, "application/vnd.ollama.image.messages")
		if err != nil {
			return err
		}

		layers.Replace(layer)
	}

Michael Yang's avatar
Michael Yang committed
631
	if len(params) > 0 {
Michael Yang's avatar
Michael Yang committed
632
		fn(api.ProgressResponse{Status: "creating parameters layer"})
Michael Yang's avatar
Michael Yang committed
633

634
		formattedParams, err := api.FormatParams(params)
635
		if err != nil {
Michael Yang's avatar
Michael Yang committed
636
			return err
637
		}
638

Michael Yang's avatar
Michael Yang committed
639
		for k, v := range fromParams {
Michael Yang's avatar
Michael Yang committed
640
641
642
643
644
			if _, ok := formattedParams[k]; !ok {
				formattedParams[k] = v
			}
		}

Michael Yang's avatar
Michael Yang committed
645
646
		var b bytes.Buffer
		if err := json.NewEncoder(&b).Encode(formattedParams); err != nil {
647
648
649
			return err
		}

Michael Yang's avatar
Michael Yang committed
650
		fn(api.ProgressResponse{Status: "creating config layer"})
Michael Yang's avatar
Michael Yang committed
651
		layer, err := NewLayer(&b, "application/vnd.ollama.image.params")
652
		if err != nil {
Michael Yang's avatar
Michael Yang committed
653
			return err
654
		}
Michael Yang's avatar
Michael Yang committed
655

Michael Yang's avatar
Michael Yang committed
656
		layers.Replace(layer)
657
658
	}

Michael Yang's avatar
Michael Yang committed
659
660
661
	digests := make([]string, len(layers.items))
	for i, layer := range layers.items {
		digests[i] = layer.Digest
662
663
	}

Michael Yang's avatar
Michael Yang committed
664
	config.RootFS.DiffIDs = digests
Michael Yang's avatar
Michael Yang committed
665

Michael Yang's avatar
Michael Yang committed
666
667
	var b bytes.Buffer
	if err := json.NewEncoder(&b).Encode(config); err != nil {
668
669
670
		return err
	}

Michael Yang's avatar
Michael Yang committed
671
672
	configLayer, err := NewLayer(&b, "application/vnd.docker.container.image.v1+json")
	if err != nil {
673
674
675
		return err
	}

Michael Yang's avatar
Michael Yang committed
676
	delete(deleteMap, configLayer.Digest)
677

Michael Yang's avatar
Michael Yang committed
678
679
	for _, layer := range append(layers.items, configLayer) {
		committed, err := layer.Commit()
680
681
682
		if err != nil {
			return err
		}
683

Michael Yang's avatar
Michael Yang committed
684
685
686
		status := "writing layer"
		if !committed {
			status = "using already created layer"
687
688
		}

Michael Yang's avatar
Michael Yang committed
689
		fn(api.ProgressResponse{Status: fmt.Sprintf("%s %s", status, layer.Digest)})
690

Michael Yang's avatar
Michael Yang committed
691
		delete(deleteMap, layer.Digest)
692
693
	}

Michael Yang's avatar
Michael Yang committed
694
695
	fn(api.ProgressResponse{Status: "writing manifest"})
	if err := WriteManifest(name, configLayer, layers.items); err != nil {
696
697
		return err
	}
698

699
	if !envconfig.NoPrune {
Michael Yang's avatar
Michael Yang committed
700
701
		if err := deleteUnusedLayers(nil, deleteMap, false); err != nil {
			return err
702
703
704
		}
	}

Michael Yang's avatar
Michael Yang committed
705
706
	fn(api.ProgressResponse{Status: "success"})
	return nil
707
708
}

709
func convertModel(name, path string, fn func(resp api.ProgressResponse)) (string, error) {
710
	r, err := zip.OpenReader(path)
711
712
713
714
715
716
717
718
719
720
721
	if err != nil {
		return "", err
	}
	defer r.Close()

	tempDir, err := os.MkdirTemp("", "ollama-convert")
	if err != nil {
		return "", err
	}
	defer os.RemoveAll(tempDir)

722
	fn(api.ProgressResponse{Status: "unpacking model metadata"})
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
	for _, f := range r.File {
		fpath := filepath.Join(tempDir, f.Name)
		outFile, err := os.OpenFile(fpath, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, f.Mode())
		if err != nil {
			return "", err
		}

		rc, err := f.Open()
		if err != nil {
			return "", err
		}

		_, err = io.Copy(outFile, rc)
		if err != nil {
			return "", err
		}

		outFile.Close()
		rc.Close()
	}

744
	mf, err := convert.GetModelFormat(tempDir)
745
746
747
748
	if err != nil {
		return "", err
	}

749
	params, err := mf.GetParams(tempDir)
750
751
	if err != nil {
		return "", err
752
753
	}

754
755
756
757
758
759
	mArch, err := mf.GetModelArch(name, tempDir, params)
	if err != nil {
		return "", err
	}

	fn(api.ProgressResponse{Status: "processing tensors"})
760
	if err := mArch.GetTensors(); err != nil {
761
762
763
		return "", err
	}

764
	if err := mArch.LoadVocab(); err != nil {
765
766
767
		return "", err
	}

768
	fn(api.ProgressResponse{Status: "converting model"})
769
	path, err = mArch.WriteGGUF()
770
771
772
773
	if err != nil {
		return "", err
	}

774
	return path, nil
775
776
}

Michael Yang's avatar
Michael Yang committed
777
func CopyModel(src, dst model.Name) error {
778
779
780
781
782
783
784
	if !dst.IsFullyQualified() {
		return model.Unqualified(dst)
	}
	if !src.IsFullyQualified() {
		return model.Unqualified(src)
	}

785
786
787
788
	if src.Filepath() == dst.Filepath() {
		return nil
	}

Michael Yang's avatar
Michael Yang committed
789
	manifests, err := GetManifestPath()
790
791
792
793
	if err != nil {
		return err
	}

794
	dstpath := filepath.Join(manifests, dst.Filepath())
Michael Yang's avatar
Michael Yang committed
795
	if err := os.MkdirAll(filepath.Dir(dstpath), 0o755); err != nil {
796
797
		return err
	}
Patrick Devine's avatar
Patrick Devine committed
798

799
	srcpath := filepath.Join(manifests, src.Filepath())
Michael Yang's avatar
Michael Yang committed
800
	srcfile, err := os.Open(srcpath)
Patrick Devine's avatar
Patrick Devine committed
801
802
803
	if err != nil {
		return err
	}
Michael Yang's avatar
Michael Yang committed
804
	defer srcfile.Close()
Patrick Devine's avatar
Patrick Devine committed
805

Michael Yang's avatar
Michael Yang committed
806
	dstfile, err := os.Create(dstpath)
Patrick Devine's avatar
Patrick Devine committed
807
808
809
	if err != nil {
		return err
	}
Michael Yang's avatar
Michael Yang committed
810
	defer dstfile.Close()
Patrick Devine's avatar
Patrick Devine committed
811

Michael Yang's avatar
Michael Yang committed
812
813
	_, err = io.Copy(dstfile, srcfile)
	return err
Patrick Devine's avatar
Patrick Devine committed
814
815
}

Michael Yang's avatar
Michael Yang committed
816
func deleteUnusedLayers(skipModelPath *ModelPath, deleteMap map[string]struct{}, dryRun bool) error {
817
818
819
820
	fp, err := GetManifestPath()
	if err != nil {
		return err
	}
Michael Yang's avatar
Michael Yang committed
821
822
823
824

	walkFunc := func(path string, info os.FileInfo, _ error) error {
		if info.IsDir() {
			return nil
825
826
		}

Michael Yang's avatar
Michael Yang committed
827
828
829
830
		dir, file := filepath.Split(path)
		dir = strings.Trim(strings.TrimPrefix(dir, fp), string(os.PathSeparator))
		tag := strings.Join([]string{dir, file}, ":")
		fmp := ParseModelPath(tag)
831

Michael Yang's avatar
Michael Yang committed
832
		// skip the manifest we're trying to delete
833
		if skipModelPath != nil && skipModelPath.GetFullTagname() == fmp.GetFullTagname() {
Michael Yang's avatar
Michael Yang committed
834
			return nil
835
		}
Michael Yang's avatar
Michael Yang committed
836
837
838
839

		// save (i.e. delete from the deleteMap) any files used in other manifests
		manifest, _, err := GetManifest(fmp)
		if err != nil {
Michael Yang's avatar
Michael Yang committed
840
			// nolint: nilerr
Michael Yang's avatar
Michael Yang committed
841
842
843
844
845
846
847
848
			return nil
		}

		for _, layer := range manifest.Layers {
			delete(deleteMap, layer.Digest)
		}

		delete(deleteMap, manifest.Config.Digest)
849
		return nil
Michael Yang's avatar
Michael Yang committed
850
851
852
	}

	if err := filepath.Walk(fp, walkFunc); err != nil {
Michael Yang's avatar
Michael Yang committed
853
854
		return err
	}
855
856

	// only delete the files which are still in the deleteMap
Michael Yang's avatar
Michael Yang committed
857
858
859
	for k := range deleteMap {
		fp, err := GetBlobsPath(k)
		if err != nil {
860
			slog.Info(fmt.Sprintf("couldn't get file path for '%s': %v", k, err))
Michael Yang's avatar
Michael Yang committed
861
862
863
864
			continue
		}
		if !dryRun {
			if err := os.Remove(fp); err != nil {
865
				slog.Info(fmt.Sprintf("couldn't remove file '%s': %v", fp, err))
866
867
				continue
			}
Michael Yang's avatar
Michael Yang committed
868
		} else {
869
			slog.Info(fmt.Sprintf("wanted to remove: %s", fp))
870
871
872
		}
	}

873
874
875
876
	return nil
}

func PruneLayers() error {
Michael Yang's avatar
Michael Yang committed
877
	deleteMap := make(map[string]struct{})
878
879
880
881
882
883
884
	p, err := GetBlobsPath("")
	if err != nil {
		return err
	}

	blobs, err := os.ReadDir(p)
	if err != nil {
885
		slog.Info(fmt.Sprintf("couldn't read dir '%s': %v", p, err))
886
887
888
889
890
		return err
	}

	for _, blob := range blobs {
		name := blob.Name()
891
		name = strings.ReplaceAll(name, "-", ":")
Michael Yang's avatar
Michael Yang committed
892
893
894
		if strings.HasPrefix(name, "sha256:") {
			deleteMap[name] = struct{}{}
		}
895
896
	}

897
	slog.Info(fmt.Sprintf("total blobs: %d", len(deleteMap)))
898
899
900
901
902
903

	err = deleteUnusedLayers(nil, deleteMap, false)
	if err != nil {
		return err
	}

904
	slog.Info(fmt.Sprintf("total unused blobs removed: %d", len(deleteMap)))
905
906
907
908

	return nil
}

Michael Yang's avatar
Michael Yang committed
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
func PruneDirectory(path string) error {
	info, err := os.Lstat(path)
	if err != nil {
		return err
	}

	if info.IsDir() && info.Mode()&os.ModeSymlink == 0 {
		entries, err := os.ReadDir(path)
		if err != nil {
			return err
		}

		for _, entry := range entries {
			if err := PruneDirectory(filepath.Join(path, entry.Name())); err != nil {
				return err
			}
		}

		entries, err = os.ReadDir(path)
		if err != nil {
			return err
		}

		if len(entries) > 0 {
			return nil
		}

		return os.Remove(path)
	}

	return nil
}

942
943
944
945
946
947
948
func DeleteModel(name string) error {
	mp := ParseModelPath(name)
	manifest, _, err := GetManifest(mp)
	if err != nil {
		return err
	}

Michael Yang's avatar
Michael Yang committed
949
	deleteMap := make(map[string]struct{})
950
	for _, layer := range manifest.Layers {
Michael Yang's avatar
Michael Yang committed
951
		deleteMap[layer.Digest] = struct{}{}
952
	}
Michael Yang's avatar
Michael Yang committed
953
	deleteMap[manifest.Config.Digest] = struct{}{}
954
955
956
957
958
959

	err = deleteUnusedLayers(&mp, deleteMap, false)
	if err != nil {
		return err
	}

960
	fp, err := mp.GetManifestPath()
961
962
963
964
965
	if err != nil {
		return err
	}
	err = os.Remove(fp)
	if err != nil {
966
		slog.Info(fmt.Sprintf("couldn't remove manifest file '%s': %v", fp, err))
967
968
969
970
971
972
		return err
	}

	return nil
}

Michael Yang's avatar
Michael Yang committed
973
func PushModel(ctx context.Context, name string, regOpts *registryOptions, fn func(api.ProgressResponse)) error {
974
	mp := ParseModelPath(name)
975
976
	fn(api.ProgressResponse{Status: "retrieving manifest"})

977
978
979
980
	if mp.ProtocolScheme == "http" && !regOpts.Insecure {
		return fmt.Errorf("insecure protocol http")
	}

Patrick Devine's avatar
Patrick Devine committed
981
	manifest, _, err := GetManifest(mp)
982
	if err != nil {
983
		fn(api.ProgressResponse{Status: "couldn't retrieve manifest"})
984
985
986
987
		return err
	}

	var layers []*Layer
Jeffrey Morgan's avatar
Jeffrey Morgan committed
988
	layers = append(layers, manifest.Layers...)
Michael Yang's avatar
Michael Yang committed
989
	layers = append(layers, manifest.Config)
990
991

	for _, layer := range layers {
Michael Yang's avatar
Michael Yang committed
992
		if err := uploadBlob(ctx, mp, layer, regOpts, fn); err != nil {
993
			slog.Info(fmt.Sprintf("error uploading blob: %v", err))
994
995
			return err
		}
996
997
	}

998
	fn(api.ProgressResponse{Status: "pushing manifest"})
Michael Yang's avatar
Michael Yang committed
999
1000
	requestURL := mp.BaseURL()
	requestURL = requestURL.JoinPath("v2", mp.GetNamespaceRepository(), "manifests", mp.Tag)
1001
1002
1003
1004
1005
1006

	manifestJSON, err := json.Marshal(manifest)
	if err != nil {
		return err
	}

Michael Yang's avatar
Michael Yang committed
1007
1008
	headers := make(http.Header)
	headers.Set("Content-Type", "application/vnd.docker.distribution.manifest.v2+json")
Michael Yang's avatar
Michael Yang committed
1009
	resp, err := makeRequestWithRetry(ctx, http.MethodPut, requestURL, headers, bytes.NewReader(manifestJSON), regOpts)
1010
1011
1012
1013
1014
	if err != nil {
		return err
	}
	defer resp.Body.Close()

1015
	fn(api.ProgressResponse{Status: "success"})
1016
1017
1018
1019

	return nil
}

Michael Yang's avatar
Michael Yang committed
1020
func PullModel(ctx context.Context, name string, regOpts *registryOptions, fn func(api.ProgressResponse)) error {
1021
1022
	mp := ParseModelPath(name)

1023
1024
1025
1026
1027
	var manifest *ManifestV2
	var err error
	var noprune string

	// build deleteMap to prune unused layers
Michael Yang's avatar
Michael Yang committed
1028
	deleteMap := make(map[string]struct{})
1029

1030
	if !envconfig.NoPrune {
1031
1032
1033
1034
1035
1036
1037
		manifest, _, err = GetManifest(mp)
		if err != nil && !errors.Is(err, os.ErrNotExist) {
			return err
		}

		if manifest != nil {
			for _, l := range manifest.Layers {
Michael Yang's avatar
Michael Yang committed
1038
				deleteMap[l.Digest] = struct{}{}
1039
			}
Michael Yang's avatar
Michael Yang committed
1040
			deleteMap[manifest.Config.Digest] = struct{}{}
1041
1042
1043
		}
	}

1044
1045
	if mp.ProtocolScheme == "http" && !regOpts.Insecure {
		return fmt.Errorf("insecure protocol http")
1046
	}
1047

1048
	fn(api.ProgressResponse{Status: "pulling manifest"})
1049

1050
	manifest, err = pullModelManifest(ctx, mp, regOpts)
1051
	if err != nil {
1052
		return fmt.Errorf("pull model manifest: %s", err)
1053
1054
1055
	}

	var layers []*Layer
Bruce MacDonald's avatar
Bruce MacDonald committed
1056
	layers = append(layers, manifest.Layers...)
Michael Yang's avatar
Michael Yang committed
1057
	layers = append(layers, manifest.Config)
1058
1059

	for _, layer := range layers {
1060
1061
1062
1063
1064
1065
1066
1067
		if err := downloadBlob(
			ctx,
			downloadOpts{
				mp:      mp,
				digest:  layer.Digest,
				regOpts: regOpts,
				fn:      fn,
			}); err != nil {
1068
1069
			return err
		}
1070
		delete(deleteMap, layer.Digest)
1071
	}
1072
	delete(deleteMap, manifest.Config.Digest)
1073

Michael Yang's avatar
Michael Yang committed
1074
1075
1076
	fn(api.ProgressResponse{Status: "verifying sha256 digest"})
	for _, layer := range layers {
		if err := verifyBlob(layer.Digest); err != nil {
1077
1078
1079
1080
1081
1082
1083
1084
			if errors.Is(err, errDigestMismatch) {
				// something went wrong, delete the blob
				fp, err := GetBlobsPath(layer.Digest)
				if err != nil {
					return err
				}
				if err := os.Remove(fp); err != nil {
					// log this, but return the original error
1085
					slog.Info(fmt.Sprintf("couldn't remove file with digest mismatch '%s': %v", fp, err))
1086
1087
				}
			}
Michael Yang's avatar
Michael Yang committed
1088
1089
1090
1091
			return err
		}
	}

1092
	fn(api.ProgressResponse{Status: "writing manifest"})
1093

1094
	manifestJSON, err := json.Marshal(manifest)
1095
1096
1097
1098
	if err != nil {
		return err
	}

1099
	fp, err := mp.GetManifestPath()
1100
1101
1102
	if err != nil {
		return err
	}
1103
1104
1105
	if err := os.MkdirAll(filepath.Dir(fp), 0o755); err != nil {
		return err
	}
1106

Bruce MacDonald's avatar
Bruce MacDonald committed
1107
	err = os.WriteFile(fp, manifestJSON, 0o644)
1108
	if err != nil {
1109
		slog.Info(fmt.Sprintf("couldn't write to %s", fp))
1110
1111
1112
		return err
	}

1113
1114
1115
1116
1117
1118
1119
1120
	if noprune == "" {
		fn(api.ProgressResponse{Status: "removing any unused layers"})
		err = deleteUnusedLayers(nil, deleteMap, false)
		if err != nil {
			return err
		}
	}

1121
	fn(api.ProgressResponse{Status: "success"})
1122
1123
1124
1125

	return nil
}

Michael Yang's avatar
Michael Yang committed
1126
func pullModelManifest(ctx context.Context, mp ModelPath, regOpts *registryOptions) (*ManifestV2, error) {
Michael Yang's avatar
Michael Yang committed
1127
	requestURL := mp.BaseURL().JoinPath("v2", mp.GetNamespaceRepository(), "manifests", mp.Tag)
1128

Michael Yang's avatar
Michael Yang committed
1129
1130
	headers := make(http.Header)
	headers.Set("Accept", "application/vnd.docker.distribution.manifest.v2+json")
Michael Yang's avatar
Michael Yang committed
1131
	resp, err := makeRequestWithRetry(ctx, http.MethodGet, requestURL, headers, nil, regOpts)
1132
1133
1134
1135
1136
1137
1138
1139
1140
1141
1142
1143
1144
1145
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	var m *ManifestV2
	if err := json.NewDecoder(resp.Body).Decode(&m); err != nil {
		return nil, err
	}

	return m, err
}

// GetSHA256Digest returns the SHA256 hash of a given buffer and returns it, and the size of buffer
Michael Yang's avatar
Michael Yang committed
1146
func GetSHA256Digest(r io.Reader) (string, int64) {
Michael Yang's avatar
Michael Yang committed
1147
1148
1149
1150
1151
1152
	h := sha256.New()
	n, err := io.Copy(h, r)
	if err != nil {
		log.Fatal(err)
	}

Michael Yang's avatar
Michael Yang committed
1153
	return fmt.Sprintf("sha256:%x", h.Sum(nil)), n
1154
1155
}

1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
var errUnauthorized = fmt.Errorf("unauthorized: access denied")

// getTokenSubject returns the subject of a JWT token, it does not validate the token
func getTokenSubject(token string) string {
	parts := strings.Split(token, ".")
	if len(parts) != 3 {
		slog.Error("jwt token does not contain 3 parts")
		return ""
	}

	payload := parts[1]
	payloadBytes, err := base64.RawURLEncoding.DecodeString(payload)
	if err != nil {
		slog.Error(fmt.Sprintf("failed to decode jwt payload: %v", err))
		return ""
	}

	var payloadMap map[string]interface{}
	if err := json.Unmarshal(payloadBytes, &payloadMap); err != nil {
		slog.Error(fmt.Sprintf("failed to unmarshal payload JSON: %v", err))
		return ""
	}

	sub, ok := payloadMap["sub"]
	if !ok {
		slog.Error("jwt does not contain 'sub' field")
		return ""
	}

	return fmt.Sprintf("%s", sub)
}
1187

Michael Yang's avatar
Michael Yang committed
1188
func makeRequestWithRetry(ctx context.Context, method string, requestURL *url.URL, headers http.Header, body io.ReadSeeker, regOpts *registryOptions) (*http.Response, error) {
1189
	anonymous := true // access will default to anonymous if no user is found associated with the public key
Michael Yang's avatar
Michael Yang committed
1190
	for i := 0; i < 2; i++ {
Michael Yang's avatar
Michael Yang committed
1191
		resp, err := makeRequest(ctx, method, requestURL, headers, body, regOpts)
Michael Yang's avatar
Michael Yang committed
1192
		if err != nil {
Michael Yang's avatar
Michael Yang committed
1193
			if !errors.Is(err, context.Canceled) {
1194
				slog.Info(fmt.Sprintf("request failed: %v", err))
Michael Yang's avatar
Michael Yang committed
1195
1196
			}

Michael Yang's avatar
Michael Yang committed
1197
1198
			return nil, err
		}
Michael Yang's avatar
Michael Yang committed
1199
1200
1201
1202

		switch {
		case resp.StatusCode == http.StatusUnauthorized:
			// Handle authentication error with one retry
Michael Yang's avatar
Michael Yang committed
1203
1204
			challenge := parseRegistryChallenge(resp.Header.Get("www-authenticate"))
			token, err := getAuthorizationToken(ctx, challenge)
Michael Yang's avatar
Michael Yang committed
1205
1206
1207
			if err != nil {
				return nil, err
			}
1208
			anonymous = getTokenSubject(token) == "anonymous"
Michael Yang's avatar
Michael Yang committed
1209
1210
1211
1212
1213
1214
1215
1216
1217
1218
1219
1220
1221
1222
1223
1224
1225
			regOpts.Token = token
			if body != nil {
				_, err = body.Seek(0, io.SeekStart)
				if err != nil {
					return nil, err
				}
			}
		case resp.StatusCode == http.StatusNotFound:
			return nil, os.ErrNotExist
		case resp.StatusCode >= http.StatusBadRequest:
			responseBody, err := io.ReadAll(resp.Body)
			if err != nil {
				return nil, fmt.Errorf("%d: %s", resp.StatusCode, err)
			}
			return nil, fmt.Errorf("%d: %s", resp.StatusCode, responseBody)
		default:
			return resp, nil
Michael Yang's avatar
Michael Yang committed
1226
1227
1228
		}
	}

1229
1230
1231
1232
1233
1234
1235
1236
1237
1238
	if anonymous {
		// no user is associated with the public key, and the request requires non-anonymous access
		pubKey, nestedErr := auth.GetPublicKey()
		if nestedErr != nil {
			slog.Error(fmt.Sprintf("couldn't get public key: %v", nestedErr))
			return nil, errUnauthorized
		}
		return nil, &errtypes.UnknownOllamaKey{Key: pubKey}
	}
	// user is associated with the public key, but is not authorized to make the request
Michael Yang's avatar
Michael Yang committed
1239
	return nil, errUnauthorized
Michael Yang's avatar
Michael Yang committed
1240
1241
}

Michael Yang's avatar
Michael Yang committed
1242
1243
1244
1245
1246
1247
1248
1249
1250
1251
1252
1253
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
1264
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
func makeRequest(ctx context.Context, method string, requestURL *url.URL, headers http.Header, body io.Reader, regOpts *registryOptions) (*http.Response, error) {
	if requestURL.Scheme != "http" && regOpts != nil && regOpts.Insecure {
		requestURL.Scheme = "http"
	}

	req, err := http.NewRequestWithContext(ctx, method, requestURL.String(), body)
	if err != nil {
		return nil, err
	}

	if headers != nil {
		req.Header = headers
	}

	if regOpts != nil {
		if regOpts.Token != "" {
			req.Header.Set("Authorization", "Bearer "+regOpts.Token)
		} else if regOpts.Username != "" && regOpts.Password != "" {
			req.SetBasicAuth(regOpts.Username, regOpts.Password)
		}
	}

	req.Header.Set("User-Agent", fmt.Sprintf("ollama/%s (%s %s) Go/%s", version.Version, runtime.GOARCH, runtime.GOOS, runtime.Version()))

	if s := req.Header.Get("Content-Length"); s != "" {
		contentLength, err := strconv.ParseInt(s, 10, 64)
		if err != nil {
			return nil, err
		}

		req.ContentLength = contentLength
	}

Michael Yang's avatar
Michael Yang committed
1275
	resp, err := http.DefaultClient.Do(req)
Michael Yang's avatar
Michael Yang committed
1276
1277
1278
1279
1280
1281
1282
	if err != nil {
		return nil, err
	}

	return resp, nil
}

Patrick Devine's avatar
Patrick Devine committed
1283
1284
1285
1286
1287
1288
1289
1290
1291
1292
1293
1294
1295
1296
1297
1298
1299
1300
1301
1302
1303
1304
1305
func getValue(header, key string) string {
	startIdx := strings.Index(header, key+"=")
	if startIdx == -1 {
		return ""
	}

	// Move the index to the starting quote after the key.
	startIdx += len(key) + 2
	endIdx := startIdx

	for endIdx < len(header) {
		if header[endIdx] == '"' {
			if endIdx+1 < len(header) && header[endIdx+1] != ',' { // If the next character isn't a comma, continue
				endIdx++
				continue
			}
			break
		}
		endIdx++
	}
	return header[startIdx:endIdx]
}

Michael Yang's avatar
Michael Yang committed
1306
func parseRegistryChallenge(authStr string) registryChallenge {
Patrick Devine's avatar
Patrick Devine committed
1307
1308
	authStr = strings.TrimPrefix(authStr, "Bearer ")

Michael Yang's avatar
Michael Yang committed
1309
	return registryChallenge{
Patrick Devine's avatar
Patrick Devine committed
1310
1311
1312
1313
1314
1315
		Realm:   getValue(authStr, "realm"),
		Service: getValue(authStr, "service"),
		Scope:   getValue(authStr, "scope"),
	}
}

1316
var errDigestMismatch = errors.New("digest mismatch, file must be downloaded again")
1317

Michael Yang's avatar
Michael Yang committed
1318
1319
1320
1321
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
func verifyBlob(digest string) error {
	fp, err := GetBlobsPath(digest)
	if err != nil {
		return err
	}

	f, err := os.Open(fp)
	if err != nil {
		return err
	}
	defer f.Close()

	fileDigest, _ := GetSHA256Digest(f)
	if digest != fileDigest {
1332
		return fmt.Errorf("%w: want %s, got %s", errDigestMismatch, digest, fileDigest)
Michael Yang's avatar
Michael Yang committed
1333
1334
1335
1336
	}

	return nil
}