The Onlyoffice server hasn't been configured
")) res.Write([]byte("")) return } var ( path string // path of the file we want to open via onlyoffice filestashServerLocation string // location from which the oods server can reach filestash userId string // as seen by onlyoffice to distinguish different users username string // username as displayed by only office key string // unique identifier for a file as seen be only office contentType string // name of the application in onlyoffice filetype string // extension of the document filename string // filename of the document oodsMode string // edit mode oodsDevice string // mobile, desktop of embedded localip string ) query := req.URL.Query() path, err := ctrl.PathBuilder(ctx, query.Get("path")) if err != nil { SendErrorResult(res, err) return } userId = GenerateID(ctx.Session) f, err := ctx.Backend.Cat(path) if err != nil { SendErrorResult(res, err) return } key = HashStream(f, 20) key = Hash(key+userId+path, 20) filename = filepath.Base(path) oodsMode = func() string { if model.CanEdit(ctx) == false { return "view" } return "edit" }() oodsDevice = func() string { ua := req.Header.Get("User-Agent") if ua == "" { return "desktop" } else if strings.Contains(ua, "iPhone") { return "mobile" } else if strings.Contains(ua, "iPad") { return "mobile" } else if strings.Contains(ua, "Android") { return "mobile" } else if strings.Contains(ua, "Mobile") { return "mobile" } if oodsMode == "view" { return "embedded" } return "desktop" }() username = func() string { if ctx.Session["username"] != "" { return ctx.Session["username"] } return "Me" }() if ctx.Share.Id != "" { username = "Anonymous" userId = RandomString(10) } localip = func() string { // https://stackoverflow.com/questions/23558425/how-do-i-get-the-local-ip-address-in-go#23558495 addrs, err := net.InterfaceAddrs() if err != nil { return "" } maybeips := []string{} for _, address := range addrs { if ipnet, ok := address.(*net.IPNet); ok && !ipnet.IP.IsLoopback() { if ipnet.IP.To4() != nil { maybeips = append(maybeips, ipnet.IP.String()) } } } // if there is just one interface, we can just pick that one if len(maybeips) == 1 { return maybeips[0] } // if not, fallback to capturing our outgoing local ip conn, err := net.Dial("udp", "8.8.8.8:80") if err != nil { return "" } defer conn.Close() localAddr := conn.LocalAddr().(*net.UDPAddr) return localAddr.IP.String() }() filestashServerLocation = fmt.Sprintf( "%s://%s:%d", func() string { // proto if req.TLS == nil { return "http" } return "https" }(), localip, Config.Get("general.port").Int(), ) contentType = func(p string) string { var ( word string = "text" excel string = "spreadsheet" powerpoint string = "presentation" ) switch GetMimeType(p) { case "application/word": return word case "application/msword": return word case "application/vnd.oasis.opendocument.text": return word case "application/vnd.oasis.opendocument.spreadsheet": return excel case "application/excel": return excel case "application/vnd.ms-excel": return excel case "application/powerpoint": return powerpoint case "application/vnd.ms-powerpoint": return powerpoint case "application/vnd.oasis.opendocument.presentation": return powerpoint } return "" }(path) filetype = strings.TrimPrefix(filepath.Ext(filename), ".") onlyoffice_cache.Set(key, &onlyOfficeCacheData{path, ctx.Backend.Save, ctx.Backend.Cat}, cache.DefaultExpiration) res.Write([]byte(fmt.Sprintf(` `, contentType, oodsDevice, filename, filestashServerLocation, key, filetype, key, func() string { if can_download() { return "true" } return "false" }(), func() string { if can_edit() { return "true" } return "false" }(), filestashServerLocation, oodsMode, userId, username, ))) } func FetchContentHandler(res http.ResponseWriter, req *http.Request) { if plugin_enable() == false { return } var key string if key = req.URL.Query().Get("key"); key == "" { SendErrorResult(res, NewError("unspecified key", http.StatusBadRequest)) return } c, found := onlyoffice_cache.Get(key) if found == false { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte(`{"error": 1, "message": "missing data fetcher handler"}`)) return } cData, valid := c.(*onlyOfficeCacheData) if valid == false { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte(`{"error": 1, "message": "invalid cache"}`)) return } f, err := cData.Cat(cData.Path) if err != nil { res.WriteHeader(http.StatusNotFound) res.Write([]byte(`{"error": 1, "message": "error while fetching data"}`)) return } io.Copy(res, f) f.Close() } type onlyOfficeEventObject struct { Actions []struct { Type int `json: "type"` UserId string `json: "userid" ` } `json: "actions"` ChangesURL string `json: "changesurl"` Forcesavetype int `json: "forcesavetype"` History struct { ServerVersion string `json: "serverVersion"` Changes []struct { Created string `json: "created"` User struct { Id string `json: "id"` Name string `json: "name"` } } `json: "changes"` } `json: "history"` Key string `json: "key"` Status int `json: "status"` Url string `json: "url"` UserData string `json: "userdata"` Lastsave string `json: "lastsave"` Users []string `json: "users"` } func OnlyOfficeEventHandler(res http.ResponseWriter, req *http.Request) { if plugin_enable() == false { return } event := onlyOfficeEventObject{} if err := json.NewDecoder(req.Body).Decode(&event); err != nil { SendErrorResult(res, err) return } req.Body.Close() switch event.Status { case 0: Log.Warning("[onlyoffice] no document with the key identifier could be found. %+v", event) case 1: // document is being edited case 2: // document is ready for saving case 3: // document saving error has occurred Log.Warning("[onlyoffice] document saving error has occurred. %+v", event) case 4: // document is closed with no changes case 5: Log.Warning("[onlyoffice] undocumented status. %+v", event) case 6: // document is being edited, but the current document state is saved saveObject, found := onlyoffice_cache.Get(event.Key) if found == false { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte(`{"error": 1, "message": "doens't know where to store the given data"}`)) return } cData, valid := saveObject.(*onlyOfficeCacheData) if valid == false { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte(`{"error": 1, "message": "[internal error] invalid save handler"}`)) return } r, err := http.NewRequest("GET", event.Url, nil) if err != nil { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte(`{"error": 1, "message": "couldn't fetch the document on the oods server"}`)) return } f, err := HTTPClient.Do(r) if err = cData.Save(cData.Path, f.Body); err != nil { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte(`{"error": 1, "message": "error while saving the document"}`)) return } f.Body.Close() case 7: Log.Warning("[onlyoffice] error has occurred while force saving the document. %+v", event) default: Log.Warning("[onlyoffice] undocumented status. %+v", event) } res.Write([]byte(`{"error": 0}`)) }