images.go 32.9 KB
Newer Older
1
2
3
4
package server

import (
	"bytes"
5
	"context"
6
	"crypto/sha256"
Patrick Devine's avatar
Patrick Devine committed
7
	"encoding/hex"
8
9
10
11
12
13
	"encoding/json"
	"errors"
	"fmt"
	"io"
	"log"
	"net/http"
Michael Yang's avatar
Michael Yang committed
14
	"net/url"
15
16
	"os"
	"path/filepath"
Michael Yang's avatar
Michael Yang committed
17
	"reflect"
Michael Yang's avatar
Michael Yang committed
18
	"runtime"
19
20
	"strconv"
	"strings"
Quinn Slack's avatar
Quinn Slack committed
21
	"text/template"
22

Michael Yang's avatar
Michael Yang committed
23
24
	"golang.org/x/exp/slices"

25
	"github.com/jmorganca/ollama/api"
26
	"github.com/jmorganca/ollama/llm"
27
	"github.com/jmorganca/ollama/parser"
Michael Yang's avatar
Michael Yang committed
28
	"github.com/jmorganca/ollama/version"
29
30
)

31
32
33
34
type RegistryOptions struct {
	Insecure bool
	Username string
	Password string
Patrick Devine's avatar
Patrick Devine committed
35
	Token    string
36
37
}

38
type Model struct {
Patrick Devine's avatar
Patrick Devine committed
39
40
41
42
43
44
45
46
47
48
49
	Name          string `json:"name"`
	ShortName     string
	ModelPath     string
	OriginalModel string
	AdapterPaths  []string
	Template      string
	System        string
	License       []string
	Digest        string
	ConfigDigest  string
	Options       map[string]interface{}
50
51
}

52
func (m *Model) Prompt(request api.GenerateRequest) (string, error) {
53
54
55
56
57
58
	t := m.Template
	if request.Template != "" {
		t = request.Template
	}

	tmpl, err := template.New("").Parse(t)
59
60
61
62
63
	if err != nil {
		return "", err
	}

	var vars struct {
Michael Yang's avatar
Michael Yang committed
64
		First  bool
65
66
		System string
		Prompt string
67
68
69

		// deprecated: versions <= 0.0.7 used this to omit the system prompt
		Context []int
70
71
	}

Michael Yang's avatar
Michael Yang committed
72
	vars.First = len(request.Context) == 0
73
74
	vars.System = m.System
	vars.Prompt = request.Prompt
Michael Yang's avatar
Michael Yang committed
75
	vars.Context = request.Context
76

77
78
79
80
	if request.System != "" {
		vars.System = request.System
	}

81
82
83
84
85
86
87
88
	var sb strings.Builder
	if err := tmpl.Execute(&sb, vars); err != nil {
		return "", err
	}

	return sb.String(), nil
}

89
90
91
92
93
94
95
96
97
98
type ManifestV2 struct {
	SchemaVersion int      `json:"schemaVersion"`
	MediaType     string   `json:"mediaType"`
	Config        Layer    `json:"config"`
	Layers        []*Layer `json:"layers"`
}

type Layer struct {
	MediaType string `json:"mediaType"`
	Digest    string `json:"digest"`
Michael Yang's avatar
Michael Yang committed
99
	Size      int64  `json:"size"`
Michael Yang's avatar
Michael Yang committed
100
	From      string `json:"from,omitempty"`
101
102
}

Michael Yang's avatar
Michael Yang committed
103
type LayerReader struct {
104
	Layer
Michael Yang's avatar
Michael Yang committed
105
	io.Reader
106
107
108
}

type ConfigV2 struct {
Michael Yang's avatar
Michael Yang committed
109
110
111
112
113
	ModelFormat string `json:"model_format"`
	ModelFamily string `json:"model_family"`
	ModelType   string `json:"model_type"`
	FileType    string `json:"file_type"`
	RootFS      RootFS `json:"rootfs"`
114
115

	// required by spec
116
117
118
119
120
121
122
123
124
	Architecture string `json:"architecture"`
	OS           string `json:"os"`
}

type RootFS struct {
	Type    string   `json:"type"`
	DiffIDs []string `json:"diff_ids"`
}

Michael Yang's avatar
Michael Yang committed
125
func (m *ManifestV2) GetTotalSize() (total int64) {
Patrick Devine's avatar
Patrick Devine committed
126
127
128
	for _, layer := range m.Layers {
		total += layer.Size
	}
Michael Yang's avatar
Michael Yang committed
129

Patrick Devine's avatar
Patrick Devine committed
130
131
132
133
	total += m.Config.Size
	return total
}

Patrick Devine's avatar
Patrick Devine committed
134
func GetManifest(mp ModelPath) (*ManifestV2, string, error) {
Patrick Devine's avatar
Patrick Devine committed
135
	fp, err := mp.GetManifestPath(false)
136
	if err != nil {
Patrick Devine's avatar
Patrick Devine committed
137
		return nil, "", err
138
	}
139

140
	if _, err = os.Stat(fp); err != nil {
Patrick Devine's avatar
Patrick Devine committed
141
		return nil, "", err
142
143
144
145
	}

	var manifest *ManifestV2

146
	bts, err := os.ReadFile(fp)
147
	if err != nil {
Patrick Devine's avatar
Patrick Devine committed
148
		return nil, "", fmt.Errorf("couldn't open file '%s'", fp)
149
150
	}

Patrick Devine's avatar
Patrick Devine committed
151
152
153
	shaSum := sha256.Sum256(bts)
	shaStr := hex.EncodeToString(shaSum[:])

154
	if err := json.Unmarshal(bts, &manifest); err != nil {
Patrick Devine's avatar
Patrick Devine committed
155
		return nil, "", err
156
157
	}

Patrick Devine's avatar
Patrick Devine committed
158
	return manifest, shaStr, nil
159
160
161
}

func GetModel(name string) (*Model, error) {
162
	mp := ParseModelPath(name)
Patrick Devine's avatar
Patrick Devine committed
163
	manifest, digest, err := GetManifest(mp)
164
165
166
167
168
	if err != nil {
		return nil, err
	}

	model := &Model{
Patrick Devine's avatar
Patrick Devine committed
169
		Name:         mp.GetFullTagname(),
Patrick Devine's avatar
Patrick Devine committed
170
		ShortName:    mp.GetShortTagname(),
Patrick Devine's avatar
Patrick Devine committed
171
172
173
		Digest:       digest,
		ConfigDigest: manifest.Config.Digest,
		Template:     "{{ .Prompt }}",
Patrick Devine's avatar
Patrick Devine committed
174
		License:      []string{},
175
176
177
	}

	for _, layer := range manifest.Layers {
Patrick Devine's avatar
Patrick Devine committed
178
		filename, err := GetBlobsPath(layer.Digest)
179
180
181
182
		if err != nil {
			return nil, err
		}

183
184
185
		switch layer.MediaType {
		case "application/vnd.ollama.image.model":
			model.ModelPath = filename
Patrick Devine's avatar
Patrick Devine committed
186
			model.OriginalModel = layer.From
187
		case "application/vnd.ollama.image.embed":
188
189
190
			// Deprecated in versions  > 0.1.2
			// TODO: remove this warning in a future version
			log.Print("WARNING: model contains embeddings, but embeddings in modelfiles have been deprecated and will be ignored.")
191
192
		case "application/vnd.ollama.image.adapter":
			model.AdapterPaths = append(model.AdapterPaths, filename)
193
194
195
196
197
198
199
200
201
		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)
202
203
204
			if err != nil {
				return nil, err
			}
205
206

			model.System = string(bts)
207
208
209
210
211
212
213
		case "application/vnd.ollama.image.prompt":
			bts, err := os.ReadFile(filename)
			if err != nil {
				return nil, err
			}

			model.Template = string(bts)
214
		case "application/vnd.ollama.image.params":
Michael Yang's avatar
Michael Yang committed
215
216
217
218
219
			params, err := os.Open(filename)
			if err != nil {
				return nil, err
			}
			defer params.Close()
220

221
			// parse model options parameters into a map so that we can see which fields have been specified explicitly
222
			if err = json.NewDecoder(params).Decode(&model.Options); err != nil {
223
224
				return nil, err
			}
Patrick Devine's avatar
Patrick Devine committed
225
226
227
228
229
230
		case "application/vnd.ollama.image.license":
			bts, err := os.ReadFile(filename)
			if err != nil {
				return nil, err
			}
			model.License = append(model.License, string(bts))
231
232
233
234
235
236
		}
	}

	return model, nil
}

237
238
func filenameWithPath(path, f string) (string, error) {
	// if filePath starts with ~/, replace it with the user's home directory.
Michael Yang's avatar
Michael Yang committed
239
240
	if strings.HasPrefix(f, fmt.Sprintf("~%s", string(os.PathSeparator))) {
		parts := strings.Split(f, string(os.PathSeparator))
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
		home, err := os.UserHomeDir()
		if err != nil {
			return "", fmt.Errorf("failed to open file: %v", err)
		}

		f = filepath.Join(home, filepath.Join(parts[1:]...))
	}

	// if filePath is not an absolute path, make it relative to the modelfile path
	if !filepath.IsAbs(f) {
		f = filepath.Join(filepath.Dir(path), f)
	}

	return f, nil
}

257
func CreateModel(ctx context.Context, workDir, name string, path string, fn func(resp api.ProgressResponse)) error {
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
	mp := ParseModelPath(name)

	var manifest *ManifestV2
	var err error
	var noprune string

	// build deleteMap to prune unused layers
	deleteMap := make(map[string]bool)

	if noprune = os.Getenv("OLLAMA_NOPRUNE"); noprune == "" {
		manifest, _, err = GetManifest(mp)
		if err != nil && !errors.Is(err, os.ErrNotExist) {
			return err
		}

		if manifest != nil {
			for _, l := range manifest.Layers {
				deleteMap[l.Digest] = true
			}
			deleteMap[manifest.Config.Digest] = true
		}
	}

281
282
	mf, err := os.Open(path)
	if err != nil {
283
		fn(api.ProgressResponse{Status: fmt.Sprintf("couldn't open modelfile '%s'", path)})
284
		return fmt.Errorf("failed to open file: %w", err)
285
	}
286
	defer mf.Close()
287

288
	fn(api.ProgressResponse{Status: "parsing modelfile"})
289
290
291
292
293
	commands, err := parser.Parse(mf)
	if err != nil {
		return err
	}

294
295
296
297
298
	config := ConfigV2{
		Architecture: "amd64",
		OS:           "linux",
	}

Michael Yang's avatar
Michael Yang committed
299
	var layers []*LayerReader
300
	params := make(map[string][]string)
Michael Yang's avatar
Michael Yang committed
301
	var sourceParams map[string]any
302
	for _, c := range commands {
303
		log.Printf("[%s] - %s\n", c.Name, c.Args)
304
305
		switch c.Name {
		case "model":
306
			fn(api.ProgressResponse{Status: "looking for model"})
307

308
			mp := ParseModelPath(c.Args)
Patrick Devine's avatar
Patrick Devine committed
309
			mf, _, err := GetManifest(mp)
310
			if err != nil {
311
312
313
				modelFile, err := filenameWithPath(path, c.Args)
				if err != nil {
					return err
314
				}
315
				if _, err := os.Stat(modelFile); err != nil {
316
317
318
					// the model file does not exist, try pulling it
					if errors.Is(err, os.ErrNotExist) {
						fn(api.ProgressResponse{Status: "pulling model file"})
319
						if err := PullModel(ctx, c.Args, &RegistryOptions{}, fn); err != nil {
320
321
							return err
						}
Patrick Devine's avatar
Patrick Devine committed
322
						mf, _, err = GetManifest(mp)
323
324
325
326
327
328
329
330
331
						if err != nil {
							return fmt.Errorf("failed to open file after pull: %v", err)
						}
					} else {
						return err
					}
				} else {
					// create a model from this specified file
					fn(api.ProgressResponse{Status: "creating model layer"})
332
					file, err := os.Open(modelFile)
333
334
335
336
337
					if err != nil {
						return fmt.Errorf("failed to open file: %v", err)
					}
					defer file.Close()

Bruce MacDonald's avatar
Bruce MacDonald committed
338
					ggml, err := llm.DecodeGGML(file)
339
340
341
342
					if err != nil {
						return err
					}

343
					config.ModelFormat = ggml.Name()
Michael Yang's avatar
Michael Yang committed
344
345
346
					config.ModelFamily = ggml.ModelFamily()
					config.ModelType = ggml.ModelType()
					config.FileType = ggml.FileType()
347
348
349
350

					// reset the file
					file.Seek(0, io.SeekStart)

351
352
353
354
355
356
					l, err := CreateLayer(file)
					if err != nil {
						return fmt.Errorf("failed to create layer: %v", err)
					}
					l.MediaType = "application/vnd.ollama.image.model"
					layers = append(layers, l)
357
				}
358
			}
359

360
			if mf != nil {
361
				fn(api.ProgressResponse{Status: "reading model metadata"})
Michael Yang's avatar
Michael Yang committed
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
				sourceBlobPath, err := GetBlobsPath(mf.Config.Digest)
				if err != nil {
					return err
				}

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

				var source ConfigV2
				if err := json.NewDecoder(sourceBlob).Decode(&source); err != nil {
					return err
				}

378
				// copy the model metadata
Michael Yang's avatar
Michael Yang committed
379
380
				config.ModelFamily = source.ModelFamily
				config.ModelType = source.ModelType
381
				config.ModelFormat = source.ModelFormat
Michael Yang's avatar
Michael Yang committed
382
383
				config.FileType = source.FileType

384
				for _, l := range mf.Layers {
Michael Yang's avatar
Michael Yang committed
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
					if l.MediaType == "application/vnd.ollama.image.params" {
						sourceParamsBlobPath, err := GetBlobsPath(l.Digest)
						if err != nil {
							return err
						}

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

						if err := json.NewDecoder(sourceParamsBlob).Decode(&sourceParams); err != nil {
							return err
						}
					}

402
403
404
405
					newLayer, err := GetLayerWithBufferFromLayer(l)
					if err != nil {
						return err
					}
Michael Yang's avatar
Michael Yang committed
406
					newLayer.From = mp.GetNamespaceRepository()
407
408
409
					layers = append(layers, newLayer)
				}
			}
410
411
412
		case "adapter":
			fn(api.ProgressResponse{Status: fmt.Sprintf("creating model %s layer", c.Name)})

Michael Yang's avatar
Michael Yang committed
413
414
415
			fp, err := filenameWithPath(path, c.Args)
			if err != nil {
				return err
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
			}

			// create a model from this specified file
			fn(api.ProgressResponse{Status: "creating model layer"})

			file, err := os.Open(fp)
			if err != nil {
				return fmt.Errorf("failed to open file: %v", err)
			}
			defer file.Close()

			l, err := CreateLayer(file)
			if err != nil {
				return fmt.Errorf("failed to create layer: %v", err)
			}
			l.MediaType = "application/vnd.ollama.image.adapter"
			layers = append(layers, l)
Bruce MacDonald's avatar
Bruce MacDonald committed
433
434
435
436
437
438
439
440
441
		case "license":
			fn(api.ProgressResponse{Status: fmt.Sprintf("creating model %s layer", c.Name)})
			mediaType := fmt.Sprintf("application/vnd.ollama.image.%s", c.Name)

			layer, err := CreateLayer(strings.NewReader(c.Args))
			if err != nil {
				return err
			}

442
443
444
445
			if layer.Size > 0 {
				layer.MediaType = mediaType
				layers = append(layers, layer)
			}
Bruce MacDonald's avatar
Bruce MacDonald committed
446
		case "template", "system", "prompt":
447
			fn(api.ProgressResponse{Status: fmt.Sprintf("creating model %s layer", c.Name)})
448
			// remove the layer if one exists
449
450
			mediaType := fmt.Sprintf("application/vnd.ollama.image.%s", c.Name)
			layers = removeLayerFromLayers(layers, mediaType)
451

452
			layer, err := CreateLayer(strings.NewReader(c.Args))
453
			if err != nil {
454
				return err
455
			}
456

457
458
459
460
			if layer.Size > 0 {
				layer.MediaType = mediaType
				layers = append(layers, layer)
			}
461
		default:
462
			// runtime parameters, build a list of args for each parameter to allow multiple values to be specified (ex: multiple stop sequences)
463
			params[c.Name] = append(params[c.Name], c.Args)
464
465
466
467
		}
	}

	// Create a single layer for the parameters
Michael Yang's avatar
Michael Yang committed
468
	if len(params) > 0 {
469
		fn(api.ProgressResponse{Status: "creating parameter layer"})
Michael Yang's avatar
Michael Yang committed
470

471
		layers = removeLayerFromLayers(layers, "application/vnd.ollama.image.params")
472
		formattedParams, err := formatParams(params)
473
474
475
		if err != nil {
			return fmt.Errorf("couldn't create params json: %v", err)
		}
476

Michael Yang's avatar
Michael Yang committed
477
478
479
480
481
482
		for k, v := range sourceParams {
			if _, ok := formattedParams[k]; !ok {
				formattedParams[k] = v
			}
		}

Michael Yang's avatar
Michael Yang committed
483
484
485
486
487
488
		if config.ModelType == "65B" {
			if numGQA, ok := formattedParams["num_gqa"].(int); ok && numGQA == 8 {
				config.ModelType = "70B"
			}
		}

489
490
491
492
493
494
		bts, err := json.Marshal(formattedParams)
		if err != nil {
			return err
		}

		l, err := CreateLayer(bytes.NewReader(bts))
495
496
497
498
499
		if err != nil {
			return fmt.Errorf("failed to create layer: %v", err)
		}
		l.MediaType = "application/vnd.ollama.image.params"
		layers = append(layers, l)
500
501
	}

502
503
504
505
506
507
508
509
	digests, err := getLayerDigests(layers)
	if err != nil {
		return err
	}

	var manifestLayers []*Layer
	for _, l := range layers {
		manifestLayers = append(manifestLayers, &l.Layer)
510
		delete(deleteMap, l.Layer.Digest)
511
512
513
	}

	// Create a layer for the config object
514
	fn(api.ProgressResponse{Status: "creating config layer"})
515
	cfg, err := createConfigLayer(config, digests)
516
517
518
519
	if err != nil {
		return err
	}
	layers = append(layers, cfg)
520
	delete(deleteMap, cfg.Layer.Digest)
521

Michael Yang's avatar
Michael Yang committed
522
	if err := SaveLayers(layers, fn, false); err != nil {
523
524
525
526
		return err
	}

	// Create the manifest
527
	fn(api.ProgressResponse{Status: "writing manifest"})
528
529
530
531
532
	err = CreateManifest(name, cfg, manifestLayers)
	if err != nil {
		return err
	}

533
534
535
536
537
538
539
540
	if noprune == "" {
		fn(api.ProgressResponse{Status: "removing any unused layers"})
		err = deleteUnusedLayers(nil, deleteMap, false)
		if err != nil {
			return err
		}
	}

541
	fn(api.ProgressResponse{Status: "success"})
542
543
544
	return nil
}

Michael Yang's avatar
Michael Yang committed
545
func removeLayerFromLayers(layers []*LayerReader, mediaType string) []*LayerReader {
Michael Yang's avatar
Michael Yang committed
546
547
548
	return slices.DeleteFunc(layers, func(layer *LayerReader) bool {
		return layer.MediaType == mediaType
	})
549
550
}

551
func SaveLayers(layers []*LayerReader, fn func(resp api.ProgressResponse), force bool) error {
552
553
	// Write each of the layers to disk
	for _, layer := range layers {
Patrick Devine's avatar
Patrick Devine committed
554
		fp, err := GetBlobsPath(layer.Digest)
555
556
557
		if err != nil {
			return err
		}
558
559

		_, err = os.Stat(fp)
560
		if os.IsNotExist(err) || force {
561
562
			fn(api.ProgressResponse{Status: fmt.Sprintf("writing layer %s", layer.Digest)})

563
564
565
566
567
568
569
			out, err := os.Create(fp)
			if err != nil {
				log.Printf("couldn't create %s", fp)
				return err
			}
			defer out.Close()

Michael Yang's avatar
Michael Yang committed
570
			if _, err = io.Copy(out, layer.Reader); err != nil {
571
572
				return err
			}
Michael Yang's avatar
Michael Yang committed
573

574
		} else {
575
			fn(api.ProgressResponse{Status: fmt.Sprintf("using already created layer %s", layer.Digest)})
576
577
578
579
580
581
		}
	}

	return nil
}

Michael Yang's avatar
Michael Yang committed
582
func CreateManifest(name string, cfg *LayerReader, layers []*Layer) error {
583
	mp := ParseModelPath(name)
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
	manifest := ManifestV2{
		SchemaVersion: 2,
		MediaType:     "application/vnd.docker.distribution.manifest.v2+json",
		Config: Layer{
			MediaType: cfg.MediaType,
			Size:      cfg.Size,
			Digest:    cfg.Digest,
		},
		Layers: layers,
	}

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

Patrick Devine's avatar
Patrick Devine committed
600
	fp, err := mp.GetManifestPath(true)
601
602
603
	if err != nil {
		return err
	}
604
	return os.WriteFile(fp, manifestJSON, 0o644)
605
606
}

Michael Yang's avatar
Michael Yang committed
607
func GetLayerWithBufferFromLayer(layer *Layer) (*LayerReader, error) {
Patrick Devine's avatar
Patrick Devine committed
608
	fp, err := GetBlobsPath(layer.Digest)
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
	if err != nil {
		return nil, err
	}

	file, err := os.Open(fp)
	if err != nil {
		return nil, fmt.Errorf("could not open blob: %w", err)
	}
	defer file.Close()

	newLayer, err := CreateLayer(file)
	if err != nil {
		return nil, err
	}
	newLayer.MediaType = layer.MediaType
	return newLayer, nil
}

627
628
// formatParams converts specified parameter options to their correct types
func formatParams(params map[string][]string) (map[string]interface{}, error) {
629
630
631
	opts := api.Options{}
	valueOpts := reflect.ValueOf(&opts).Elem() // names of the fields in the options struct
	typeOpts := reflect.TypeOf(opts)           // types of the fields in the options struct
Michael Yang's avatar
Michael Yang committed
632

633
	// build map of json struct tags to their types
Michael Yang's avatar
Michael Yang committed
634
635
636
637
638
639
640
641
	jsonOpts := make(map[string]reflect.StructField)
	for _, field := range reflect.VisibleFields(typeOpts) {
		jsonTag := strings.Split(field.Tag.Get("json"), ",")[0]
		if jsonTag != "" {
			jsonOpts[jsonTag] = field
		}
	}

642
	out := make(map[string]interface{})
Michael Yang's avatar
Michael Yang committed
643
	// iterate params and set values based on json struct tags
644
	for key, vals := range params {
Michael Yang's avatar
Michael Yang committed
645
646
647
648
649
		if opt, ok := jsonOpts[key]; ok {
			field := valueOpts.FieldByName(opt.Name)
			if field.IsValid() && field.CanSet() {
				switch field.Kind() {
				case reflect.Float32:
650
					floatVal, err := strconv.ParseFloat(vals[0], 32)
Michael Yang's avatar
Michael Yang committed
651
					if err != nil {
652
						return nil, fmt.Errorf("invalid float value %s", vals)
Michael Yang's avatar
Michael Yang committed
653
654
					}

Michael Yang's avatar
Michael Yang committed
655
					out[key] = float32(floatVal)
Michael Yang's avatar
Michael Yang committed
656
				case reflect.Int:
Michael Yang's avatar
Michael Yang committed
657
					intVal, err := strconv.ParseInt(vals[0], 10, 64)
Michael Yang's avatar
Michael Yang committed
658
					if err != nil {
659
						return nil, fmt.Errorf("invalid int value %s", vals)
Michael Yang's avatar
Michael Yang committed
660
661
					}

662
					out[key] = intVal
Michael Yang's avatar
Michael Yang committed
663
				case reflect.Bool:
664
					boolVal, err := strconv.ParseBool(vals[0])
Michael Yang's avatar
Michael Yang committed
665
					if err != nil {
666
						return nil, fmt.Errorf("invalid bool value %s", vals)
Michael Yang's avatar
Michael Yang committed
667
668
					}

669
					out[key] = boolVal
Michael Yang's avatar
Michael Yang committed
670
				case reflect.String:
671
					out[key] = vals[0]
672
				case reflect.Slice:
673
674
					// TODO: only string slices are supported right now
					out[key] = vals
Michael Yang's avatar
Michael Yang committed
675
676
677
678
679
680
681
				default:
					return nil, fmt.Errorf("unknown type %s for %s", field.Kind(), key)
				}
			}
		}
	}

682
	return out, nil
683
684
}

Michael Yang's avatar
Michael Yang committed
685
func getLayerDigests(layers []*LayerReader) ([]string, error) {
686
687
688
689
690
691
692
693
694
695
696
	var digests []string
	for _, l := range layers {
		if l.Digest == "" {
			return nil, fmt.Errorf("layer is missing a digest")
		}
		digests = append(digests, l.Digest)
	}
	return digests, nil
}

// CreateLayer creates a Layer object from a given file
Michael Yang's avatar
Michael Yang committed
697
698
func CreateLayer(f io.ReadSeeker) (*LayerReader, error) {
	digest, size := GetSHA256Digest(f)
699
	f.Seek(0, io.SeekStart)
700

Michael Yang's avatar
Michael Yang committed
701
	layer := &LayerReader{
702
703
704
705
706
		Layer: Layer{
			MediaType: "application/vnd.docker.image.rootfs.diff.tar",
			Digest:    digest,
			Size:      size,
		},
Michael Yang's avatar
Michael Yang committed
707
		Reader: f,
708
709
710
711
712
	}

	return layer, nil
}

Patrick Devine's avatar
Patrick Devine committed
713
func CopyModel(src, dest string) error {
714
	srcModelPath := ParseModelPath(src)
715
716
717
718
719
	srcPath, err := srcModelPath.GetManifestPath(false)
	if err != nil {
		return err
	}

720
	destModelPath := ParseModelPath(dest)
721
	destPath, err := destModelPath.GetManifestPath(true)
Patrick Devine's avatar
Patrick Devine committed
722
723
724
725
726
	if err != nil {
		return err
	}

	// copy the file
Michael Yang's avatar
Michael Yang committed
727
	input, err := os.ReadFile(srcPath)
Patrick Devine's avatar
Patrick Devine committed
728
729
730
731
732
	if err != nil {
		fmt.Println("Error reading file:", err)
		return err
	}

Michael Yang's avatar
Michael Yang committed
733
	err = os.WriteFile(destPath, input, 0o644)
Patrick Devine's avatar
Patrick Devine committed
734
735
736
737
738
739
740
741
	if err != nil {
		fmt.Println("Error reading file:", err)
		return err
	}

	return nil
}

742
func deleteUnusedLayers(skipModelPath *ModelPath, deleteMap map[string]bool, dryRun bool) error {
743
744
745
746
	fp, err := GetManifestPath()
	if err != nil {
		return err
	}
Michael Yang's avatar
Michael Yang committed
747
748
749
750

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

Michael Yang's avatar
Michael Yang committed
753
754
755
756
		dir, file := filepath.Split(path)
		dir = strings.Trim(strings.TrimPrefix(dir, fp), string(os.PathSeparator))
		tag := strings.Join([]string{dir, file}, ":")
		fmp := ParseModelPath(tag)
757

Michael Yang's avatar
Michael Yang committed
758
		// skip the manifest we're trying to delete
759
		if skipModelPath != nil && skipModelPath.GetFullTagname() == fmp.GetFullTagname() {
Michael Yang's avatar
Michael Yang committed
760
			return nil
761
		}
Michael Yang's avatar
Michael Yang committed
762
763
764
765
766
767
768
769
770
771
772
773

		// save (i.e. delete from the deleteMap) any files used in other manifests
		manifest, _, err := GetManifest(fmp)
		if err != nil {
			return nil
		}

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

		delete(deleteMap, manifest.Config.Digest)
774
		return nil
Michael Yang's avatar
Michael Yang committed
775
776
777
	}

	if err := filepath.Walk(fp, walkFunc); err != nil {
Michael Yang's avatar
Michael Yang committed
778
779
		return err
	}
780
781
782
783

	// only delete the files which are still in the deleteMap
	for k, v := range deleteMap {
		if v {
784
			fp, err := GetBlobsPath(k)
785
			if err != nil {
786
787
788
				log.Printf("couldn't get file path for '%s': %v", k, err)
				continue
			}
789
790
791
792
793
794
795
			if !dryRun {
				if err := os.Remove(fp); err != nil {
					log.Printf("couldn't remove file '%s': %v", fp, err)
					continue
				}
			} else {
				log.Printf("wanted to remove: %s", fp)
796
797
798
799
			}
		}
	}

800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
	return nil
}

func PruneLayers() error {
	deleteMap := make(map[string]bool)
	p, err := GetBlobsPath("")
	if err != nil {
		return err
	}

	blobs, err := os.ReadDir(p)
	if err != nil {
		log.Printf("couldn't read dir '%s': %v", p, err)
		return err
	}

	for _, blob := range blobs {
		name := blob.Name()
		if runtime.GOOS == "windows" {
			name = strings.ReplaceAll(name, "-", ":")
		}
		deleteMap[name] = true
	}

	log.Printf("total blobs: %d", len(deleteMap))

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

	log.Printf("total unused blobs removed: %d", len(deleteMap))

	return nil
}

Michael Yang's avatar
Michael Yang committed
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
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
}

869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
func DeleteModel(name string) error {
	mp := ParseModelPath(name)
	manifest, _, err := GetManifest(mp)
	if err != nil {
		return err
	}

	deleteMap := make(map[string]bool)
	for _, layer := range manifest.Layers {
		deleteMap[layer.Digest] = true
	}
	deleteMap[manifest.Config.Digest] = true

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

	fp, err := mp.GetManifestPath(false)
888
889
890
891
892
893
894
895
896
897
898
899
	if err != nil {
		return err
	}
	err = os.Remove(fp)
	if err != nil {
		log.Printf("couldn't remove manifest file '%s': %v", fp, err)
		return err
	}

	return nil
}

Patrick Devine's avatar
Patrick Devine committed
900
901
902
903
904
905
906
907
908
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
942
943
944
945
946
947
948
949
950
951
952
953
func ShowModelfile(model *Model) (string, error) {
	type modelTemplate struct {
		*Model
		From   string
		Params string
	}

	var params []string
	for k, v := range model.Options {
		switch val := v.(type) {
		case string:
			params = append(params, fmt.Sprintf("PARAMETER %s %s", k, val))
		case int:
			params = append(params, fmt.Sprintf("PARAMETER %s %s", k, strconv.Itoa(val)))
		case float64:
			params = append(params, fmt.Sprintf("PARAMETER %s %s", k, strconv.FormatFloat(val, 'f', 0, 64)))
		case bool:
			params = append(params, fmt.Sprintf("PARAMETER %s %s", k, strconv.FormatBool(val)))
		case []interface{}:
			for _, nv := range val {
				switch nval := nv.(type) {
				case string:
					params = append(params, fmt.Sprintf("PARAMETER %s %s", k, nval))
				case int:
					params = append(params, fmt.Sprintf("PARAMETER %s %s", k, strconv.Itoa(nval)))
				case float64:
					params = append(params, fmt.Sprintf("PARAMETER %s %s", k, strconv.FormatFloat(nval, 'f', 0, 64)))
				case bool:
					params = append(params, fmt.Sprintf("PARAMETER %s %s", k, strconv.FormatBool(nval)))
				default:
					log.Printf("unknown type: %s", reflect.TypeOf(nv).String())
				}
			}
		default:
			log.Printf("unknown type: %s", reflect.TypeOf(v).String())
		}
	}

	mt := modelTemplate{
		Model:  model,
		From:   model.OriginalModel,
		Params: strings.Join(params, "\n"),
	}

	if mt.From == "" {
		mt.From = model.ModelPath
	}

	modelFile := `# Modelfile generated by "ollama show"
# To build a new Modelfile based on this one, replace the FROM line with:
# FROM {{ .ShortName }}

FROM {{ .From }}
TEMPLATE """{{ .Template }}"""
954
955

{{- if .System }}
Patrick Devine's avatar
Patrick Devine committed
956
SYSTEM """{{ .System }}"""
957
{{- end }}
Patrick Devine's avatar
Patrick Devine committed
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
{{ .Params }}
`
	for _, l := range mt.Model.AdapterPaths {
		modelFile += fmt.Sprintf("ADAPTER %s\n", l)
	}

	tmpl, err := template.New("").Parse(modelFile)
	if err != nil {
		log.Printf("error parsing template: %q", err)
		return "", err
	}

	var buf bytes.Buffer

	if err = tmpl.Execute(&buf, mt); err != nil {
		log.Printf("error executing template: %q", err)
		return "", err
	}

	return buf.String(), nil
}

980
func PushModel(ctx context.Context, name string, regOpts *RegistryOptions, fn func(api.ProgressResponse)) error {
981
	mp := ParseModelPath(name)
982
983
	fn(api.ProgressResponse{Status: "retrieving manifest"})

984
985
986
987
	if mp.ProtocolScheme == "http" && !regOpts.Insecure {
		return fmt.Errorf("insecure protocol http")
	}

Patrick Devine's avatar
Patrick Devine committed
988
	manifest, _, err := GetManifest(mp)
989
	if err != nil {
990
		fn(api.ProgressResponse{Status: "couldn't retrieve manifest"})
991
992
993
994
		return err
	}

	var layers []*Layer
Jeffrey Morgan's avatar
Jeffrey Morgan committed
995
	layers = append(layers, manifest.Layers...)
996
997
998
	layers = append(layers, &manifest.Config)

	for _, layer := range layers {
999
		exists, err := checkBlobExistence(ctx, mp, layer.Digest, regOpts)
1000
1001
1002
1003
1004
		if err != nil {
			return err
		}

		if exists {
1005
1006
1007
			fn(api.ProgressResponse{
				Status:    "using existing layer",
				Digest:    layer.Digest,
1008
1009
				Total:     layer.Size,
				Completed: layer.Size,
1010
			})
1011
			log.Printf("Layer %s already exists", layer.Digest)
1012
1013
1014
			continue
		}

1015
		fn(api.ProgressResponse{
1016
1017
1018
			Status: "starting upload",
			Digest: layer.Digest,
			Total:  layer.Size,
1019
		})
1020

1021
		location, chunkSize, err := startUpload(ctx, mp, layer, regOpts)
1022
1023
1024
1025
1026
		if err != nil {
			log.Printf("couldn't start upload: %v", err)
			return err
		}

Michael Yang's avatar
Michael Yang committed
1027
1028
		if strings.HasPrefix(filepath.Base(location.Path), "sha256:") {
			layer.Digest = filepath.Base(location.Path)
Michael Yang's avatar
Michael Yang committed
1029
1030
1031
1032
1033
1034
1035
1036
1037
			fn(api.ProgressResponse{
				Status:    "using existing layer",
				Digest:    layer.Digest,
				Total:     layer.Size,
				Completed: layer.Size,
			})
			continue
		}

1038
		if err := uploadBlob(ctx, location, layer, chunkSize, regOpts, fn); err != nil {
1039
1040
1041
			log.Printf("error uploading blob: %v", err)
			return err
		}
1042
1043
	}

1044
	fn(api.ProgressResponse{Status: "pushing manifest"})
Michael Yang's avatar
Michael Yang committed
1045
1046
	requestURL := mp.BaseURL()
	requestURL = requestURL.JoinPath("v2", mp.GetNamespaceRepository(), "manifests", mp.Tag)
1047
1048
1049
1050
1051
1052

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

Michael Yang's avatar
Michael Yang committed
1053
1054
	headers := make(http.Header)
	headers.Set("Content-Type", "application/vnd.docker.distribution.manifest.v2+json")
Michael Yang's avatar
Michael Yang committed
1055
	resp, err := makeRequestWithRetry(ctx, "PUT", requestURL, headers, bytes.NewReader(manifestJSON), regOpts)
1056
1057
1058
1059
1060
	if err != nil {
		return err
	}
	defer resp.Body.Close()

1061
	fn(api.ProgressResponse{Status: "success"})
1062
1063
1064
1065

	return nil
}

1066
func PullModel(ctx context.Context, name string, regOpts *RegistryOptions, fn func(api.ProgressResponse)) error {
1067
1068
	mp := ParseModelPath(name)

1069
1070
1071
1072
1073
1074
1075
1076
1077
1078
1079
1080
1081
1082
1083
1084
1085
1086
1087
1088
1089
	var manifest *ManifestV2
	var err error
	var noprune string

	// build deleteMap to prune unused layers
	deleteMap := make(map[string]bool)

	if noprune = os.Getenv("OLLAMA_NOPRUNE"); noprune == "" {
		manifest, _, err = GetManifest(mp)
		if err != nil && !errors.Is(err, os.ErrNotExist) {
			return err
		}

		if manifest != nil {
			for _, l := range manifest.Layers {
				deleteMap[l.Digest] = true
			}
			deleteMap[manifest.Config.Digest] = true
		}
	}

1090
1091
	if mp.ProtocolScheme == "http" && !regOpts.Insecure {
		return fmt.Errorf("insecure protocol http")
1092
	}
1093

1094
	fn(api.ProgressResponse{Status: "pulling manifest"})
1095

1096
	manifest, err = pullModelManifest(ctx, mp, regOpts)
1097
	if err != nil {
1098
		return fmt.Errorf("pull model manifest: %s", err)
1099
1100
1101
	}

	var layers []*Layer
Bruce MacDonald's avatar
Bruce MacDonald committed
1102
	layers = append(layers, manifest.Layers...)
1103
1104
1105
	layers = append(layers, &manifest.Config)

	for _, layer := range layers {
1106
1107
1108
1109
1110
1111
1112
1113
		if err := downloadBlob(
			ctx,
			downloadOpts{
				mp:      mp,
				digest:  layer.Digest,
				regOpts: regOpts,
				fn:      fn,
			}); err != nil {
1114
1115
			return err
		}
1116
		delete(deleteMap, layer.Digest)
1117
	}
1118
	delete(deleteMap, manifest.Config.Digest)
1119

Michael Yang's avatar
Michael Yang committed
1120
1121
1122
	fn(api.ProgressResponse{Status: "verifying sha256 digest"})
	for _, layer := range layers {
		if err := verifyBlob(layer.Digest); err != nil {
1123
1124
1125
1126
1127
1128
1129
1130
1131
1132
1133
			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
					log.Printf("couldn't remove file with digest mismatch '%s': %v", fp, err)
				}
			}
Michael Yang's avatar
Michael Yang committed
1134
1135
1136
1137
			return err
		}
	}

1138
	fn(api.ProgressResponse{Status: "writing manifest"})
1139

1140
	manifestJSON, err := json.Marshal(manifest)
1141
1142
1143
1144
	if err != nil {
		return err
	}

Patrick Devine's avatar
Patrick Devine committed
1145
	fp, err := mp.GetManifestPath(true)
1146
1147
1148
1149
	if err != nil {
		return err
	}

Bruce MacDonald's avatar
Bruce MacDonald committed
1150
	err = os.WriteFile(fp, manifestJSON, 0o644)
1151
1152
1153
1154
1155
	if err != nil {
		log.Printf("couldn't write to %s", fp)
		return err
	}

1156
1157
1158
1159
1160
1161
1162
1163
	if noprune == "" {
		fn(api.ProgressResponse{Status: "removing any unused layers"})
		err = deleteUnusedLayers(nil, deleteMap, false)
		if err != nil {
			return err
		}
	}

1164
	fn(api.ProgressResponse{Status: "success"})
1165
1166
1167
1168

	return nil
}

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

Michael Yang's avatar
Michael Yang committed
1172
1173
	headers := make(http.Header)
	headers.Set("Accept", "application/vnd.docker.distribution.manifest.v2+json")
Michael Yang's avatar
Michael Yang committed
1174
	resp, err := makeRequest(ctx, "GET", requestURL, headers, nil, regOpts)
1175
1176
1177
1178
1179
1180
	if err != nil {
		log.Printf("couldn't get manifest: %v", err)
		return nil, err
	}
	defer resp.Body.Close()

Michael Yang's avatar
Michael Yang committed
1181
	if resp.StatusCode >= http.StatusBadRequest {
1182
		if resp.StatusCode == http.StatusNotFound {
Bruce MacDonald's avatar
Bruce MacDonald committed
1183
			return nil, fmt.Errorf("model not found")
1184
		}
Michael Yang's avatar
Michael Yang committed
1185

1186
		body, _ := io.ReadAll(resp.Body)
1187
		return nil, fmt.Errorf("on pull registry responded with code %d: %s", resp.StatusCode, body)
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
	}

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

	return m, err
}

1198
1199
1200
1201
func createConfigLayer(config ConfigV2, layers []string) (*LayerReader, error) {
	config.RootFS = RootFS{
		Type:    "layers",
		DiffIDs: layers,
1202
1203
1204
1205
1206
1207
1208
	}

	configJSON, err := json.Marshal(config)
	if err != nil {
		return nil, err
	}

1209
	digest, size := GetSHA256Digest(bytes.NewBuffer(configJSON))
1210

Michael Yang's avatar
Michael Yang committed
1211
	layer := &LayerReader{
1212
1213
1214
1215
1216
		Layer: Layer{
			MediaType: "application/vnd.docker.container.image.v1+json",
			Digest:    digest,
			Size:      size,
		},
1217
		Reader: bytes.NewBuffer(configJSON),
1218
1219
1220
1221
1222
	}
	return layer, nil
}

// GetSHA256Digest returns the SHA256 hash of a given buffer and returns it, and the size of buffer
Michael Yang's avatar
Michael Yang committed
1223
func GetSHA256Digest(r io.Reader) (string, int64) {
Michael Yang's avatar
Michael Yang committed
1224
1225
1226
1227
1228
1229
	h := sha256.New()
	n, err := io.Copy(h, r)
	if err != nil {
		log.Fatal(err)
	}

Michael Yang's avatar
Michael Yang committed
1230
	return fmt.Sprintf("sha256:%x", h.Sum(nil)), n
1231
1232
1233
}

// Function to check if a blob already exists in the Docker registry
1234
func checkBlobExistence(ctx context.Context, mp ModelPath, digest string, regOpts *RegistryOptions) (bool, error) {
Michael Yang's avatar
Michael Yang committed
1235
1236
	requestURL := mp.BaseURL()
	requestURL = requestURL.JoinPath("v2", mp.GetNamespaceRepository(), "blobs", digest)
1237

Michael Yang's avatar
Michael Yang committed
1238
	resp, err := makeRequest(ctx, "HEAD", requestURL, nil, nil, regOpts)
1239
1240
1241
1242
1243
1244
1245
	if err != nil {
		log.Printf("couldn't check for blob: %v", err)
		return false, err
	}
	defer resp.Body.Close()

	// Check for success: If the blob exists, the Docker registry will respond with a 200 OK
Michael Yang's avatar
Michael Yang committed
1246
	return resp.StatusCode < http.StatusBadRequest, nil
1247
1248
}

Michael Yang's avatar
Michael Yang committed
1249
func makeRequestWithRetry(ctx context.Context, method string, requestURL *url.URL, headers http.Header, body io.ReadSeeker, regOpts *RegistryOptions) (*http.Response, error) {
Michael Yang's avatar
Michael Yang committed
1250
	var status string
Michael Yang's avatar
Michael Yang committed
1251
	for try := 0; try < maxRetries; try++ {
Michael Yang's avatar
Michael Yang committed
1252
		resp, err := makeRequest(ctx, method, requestURL, headers, body, regOpts)
Michael Yang's avatar
Michael Yang committed
1253
1254
1255
1256
1257
1258
1259
		if err != nil {
			log.Printf("couldn't start upload: %v", err)
			return nil, err
		}

		status = resp.Status

Michael Yang's avatar
Michael Yang committed
1260
1261
		switch {
		case resp.StatusCode == http.StatusUnauthorized:
Michael Yang's avatar
Michael Yang committed
1262
1263
			auth := resp.Header.Get("www-authenticate")
			authRedir := ParseAuthRedirectString(auth)
Michael Yang's avatar
Michael Yang committed
1264
			token, err := getAuthToken(ctx, authRedir)
Michael Yang's avatar
Michael Yang committed
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
			if err != nil {
				return nil, err
			}

			regOpts.Token = token
			if body != nil {
				if _, err := body.Seek(0, io.SeekStart); err != nil {
					return nil, err
				}
			}

			continue
Michael Yang's avatar
Michael Yang committed
1277
		case resp.StatusCode >= http.StatusBadRequest:
Michael Yang's avatar
Michael Yang committed
1278
1279
			body, _ := io.ReadAll(resp.Body)
			return nil, fmt.Errorf("on upload registry responded with code %d: %s", resp.StatusCode, body)
Michael Yang's avatar
Michael Yang committed
1280
1281
		default:
			return resp, nil
Michael Yang's avatar
Michael Yang committed
1282
1283
1284
1285
1286
1287
		}
	}

	return nil, fmt.Errorf("max retry exceeded: %v", status)
}

Michael Yang's avatar
Michael Yang committed
1288
func makeRequest(ctx context.Context, method string, requestURL *url.URL, headers http.Header, body io.Reader, regOpts *RegistryOptions) (*http.Response, error) {
Michael Yang's avatar
Michael Yang committed
1289
	if requestURL.Scheme != "http" && regOpts != nil && regOpts.Insecure {
Michael Yang's avatar
Michael Yang committed
1290
		requestURL.Scheme = "http"
1291
1292
	}

Michael Yang's avatar
Michael Yang committed
1293
	req, err := http.NewRequestWithContext(ctx, method, requestURL.String(), body)
1294
1295
1296
1297
	if err != nil {
		return nil, err
	}

Michael Yang's avatar
Michael Yang committed
1298
1299
1300
1301
	if headers != nil {
		req.Header = headers
	}

Michael Yang's avatar
Michael Yang committed
1302
1303
1304
1305
1306
1307
	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)
		}
1308
1309
	}

Michael Yang's avatar
Michael Yang committed
1310
	req.Header.Set("User-Agent", fmt.Sprintf("ollama/%s (%s %s) Go/%s", version.Version, runtime.GOARCH, runtime.GOOS, runtime.Version()))
1311

Michael Yang's avatar
Michael Yang committed
1312
1313
1314
1315
1316
1317
1318
1319
1320
	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
1321
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
	proxyURL, err := http.ProxyFromEnvironment(req)
	if err != nil {
		return nil, err
	}

	client := http.Client{
		Transport: &http.Transport{
			Proxy: http.ProxyURL(proxyURL),
		},
	}

	resp, err := client.Do(req)
1333
1334
1335
1336
1337
1338
	if err != nil {
		return nil, err
	}

	return resp, nil
}
Michael Yang's avatar
Michael Yang committed
1339

Patrick Devine's avatar
Patrick Devine committed
1340
1341
1342
1343
1344
1345
1346
1347
1348
1349
1350
1351
1352
1353
1354
1355
1356
1357
1358
1359
1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
1371
1372
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]
}

func ParseAuthRedirectString(authStr string) AuthRedirect {
	authStr = strings.TrimPrefix(authStr, "Bearer ")

	return AuthRedirect{
		Realm:   getValue(authStr, "realm"),
		Service: getValue(authStr, "service"),
		Scope:   getValue(authStr, "scope"),
	}
}

1373
1374
var errDigestMismatch = fmt.Errorf("digest mismatch, file must be downloaded again")

Michael Yang's avatar
Michael Yang committed
1375
1376
1377
1378
1379
1380
1381
1382
1383
1384
1385
1386
1387
1388
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 {
1389
		return fmt.Errorf("%w: want %s, got %s", errDigestMismatch, digest, fileDigest)
Michael Yang's avatar
Michael Yang committed
1390
1391
1392
1393
	}

	return nil
}