Method writeContent

server/api_drive.go:414–442

(c *gin.Context)

}

func (dr *driveRoute) writeContent(c *gin.Context) {
	path := utils.CleanPath(c.Param("path"))
	d := c.MustGet("drive").(types.IDrive)

	principal := GetPrincipal(c)
	override := utils.ToBool(c.Query("override"))
	defer func() { _ = c.Request.Body.Close() }()
	tempFile, size, e := ReadRequestBodyToTempFile(c, dr.config.TempDir)
	if e != nil {
		_ = c.Error(e)
		return
	}
	t, e := dr.runner.ExecuteAndWait(func(ctx types.TaskCtx) (any, error) {
		defer func() {
			_ = tempFile.Close()
			_ = os.Remove(tempFile.Name())
		}()
		r, e := d.Save(ctx, path, size, override, tempFile)
		if e != nil {
			return nil, e
		}
		return dr.newEntryJson(r, principal), nil
	}, 2*time.Second, task.WithNameGroup(path, "drive/write"))
	if e != nil {
		_ = c.Error(e)
		return
	}
	SetResult(c, t)
}

func (dr *driveRoute) chunkUploadRequest(c *gin.Context) {
	size := utils.ToInt64(c.Query("size"), -1)