jeans/ollama
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

clean

Browse Source
This commit is contained in:
Josh Yan 2024-07-03 17:04:20 -07:00
parent ea837412c2
commit 0d5a72aba9
1 changed files with 6 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
cmd/cmd.go
View File

@ -312,20 +312,17 @@ func createBlob(cmd *cobra.Command, client *api.Client, path string) (string, er
} }
} */ } */
if client.IsLocal() { if client.IsLocal() {
config, err := getLocalPath(cmd.Context(), digest) dest, err := getLocalPath(cmd.Context(), digest)
if errors.Is(err, ErrBlobExists) { if errors.Is(err, ErrBlobExists) {
return digest, nil return digest, nil
} }
if err != nil {
return "", err
}
dest := config
err = createBlobLocal(path, dest)
if err == nil { if err == nil {
return digest, nil err = createBlobLocal(path, dest)
if err == nil {
return digest, nil
}
} }
} }
@ -344,13 +341,12 @@ func getLocalPath(ctx context.Context, digest string) (string, error) {
Host: net.JoinHostPort(ollamaHost.Host, ollamaHost.Port), Host: net.JoinHostPort(ollamaHost.Host, ollamaHost.Port),
} }
var reqBody io.Reader
data, err := json.Marshal(digest) data, err := json.Marshal(digest)
if err != nil { if err != nil {
return "", err return "", err
} }
reqBody = bytes.NewReader(data) reqBody := bytes.NewReader(data)
path := fmt.Sprintf("/api/blobs/%s", digest) path := fmt.Sprintf("/api/blobs/%s", digest)
requestURL := base.JoinPath(path) requestURL := base.JoinPath(path)
request, err := http.NewRequestWithContext(ctx, http.MethodPost, requestURL.String(), reqBody) request, err := http.NewRequestWithContext(ctx, http.MethodPost, requestURL.String(), reqBody)