local path

cmd/cmd.go

@@ -319,26 +319,20 @@ func createBlob(cmd *cobra.Command, client *api.Client, path string) (string, er
 			return "", err
 		}
 
-		fmt.Println("HI")
+		dest := config
-		dest := config.ModelDir
-		fmt.Println("dest is ", dest)
 		err = createBlobLocal(path, dest)
 		if err == nil {
-			fmt.Println("createlocalblob succeed")
 			return digest, nil
 		}
-		fmt.Println("err is ", err)
-		fmt.Println("createlocalblob faileds")
 	}
 
-	fmt.Println("DEFAULT")
 	if err = client.CreateBlob(cmd.Context(), digest, bin); err != nil {
 		return "", err
 	}
 	return digest, nil
 }
 
-func getLocalPath(ctx context.Context, digest string) (*api.ServerConfig, error) {
+func getLocalPath(ctx context.Context, digest string) (string, error) {
 	ollamaHost := envconfig.Host
 
 	client := http.DefaultClient
@@ -348,10 +342,9 @@ func getLocalPath(ctx context.Context, digest string) (*api.ServerConfig, error)
 	}
 
 	var reqBody io.Reader
-	var respData api.ServerConfig
 	data, err := json.Marshal(digest)
 	if err != nil {
-		return nil, err
+		return "", err
 	}
 
 	reqBody = bytes.NewReader(data)
@@ -359,7 +352,7 @@ func getLocalPath(ctx context.Context, digest string) (*api.ServerConfig, error)
 	requestURL := base.JoinPath(path)
 	request, err := http.NewRequestWithContext(ctx, http.MethodPost, requestURL.String(), reqBody)
 	if err != nil {
-		return nil, err
+		return "", err
 	}
 
 	request.Header.Set("Content-Type", "application/json")
@@ -367,38 +360,26 @@ func getLocalPath(ctx context.Context, digest string) (*api.ServerConfig, error)
 	request.Header.Set("User-Agent", fmt.Sprintf("ollama/%s (%s %s) Go/%s", version.Version, runtime.GOARCH, runtime.GOOS, runtime.Version()))
 	request.Header.Set("X-Redirect-Create", "1")
 
-	fmt.Println("request", request)
 	resp, err := client.Do(request)
 	if err != nil {
-		return nil, err
+		return "", err
 	}
 	defer resp.Body.Close()
-	fmt.Println("made it here")
-	fmt.Println("resp", resp)
 
 	if resp.StatusCode == http.StatusTemporaryRedirect {
-		fmt.Println("redirect")
+		dest := resp.Header.Get("LocalLocation")
-		if err := json.Unmarshal([]byte(resp.Header.Get("loc")), &respData); err != nil {
-			fmt.Println("error unmarshalling response data")
-			return nil, err
-		}
 
-		return &respData, nil
+		return dest, nil
 	}
-
+	return "", ErrBlobExists
-	fmt.Println("!!!!!!!!!!")
-	fmt.Println(respData)
-	return nil, ErrBlobExists
 }
 
 func createBlobLocal(path string, dest string) error {
 	// This function should be called if the server is local
 	// It should find the model directory, copy the blob over, and return the digest
 	dirPath := filepath.Dir(dest)
-	fmt.Println("dirpath is ", dirPath)
 
 	if err := os.MkdirAll(dirPath, 0o755); err != nil {
-		fmt.Println("failed to create directory")
 		return err
 	}
 

server/routes.go

@@ -942,8 +942,7 @@ func (s *Server) CreateBlobHandler(c *gin.Context) {
 	}
 
 	if c.GetHeader("X-Redirect-Create") == "1" {
-		c.Header("Location", path)
+		c.Header("LocalLocation", path)
-		fmt.Println("!!!!!!!!!", string(path))
 		c.Status(http.StatusTemporaryRedirect)
 		return
 	}