diff options
author | FChannel <> | 2021-07-28 15:43:48 -0700 |
---|---|---|
committer | FChannel <> | 2021-07-28 15:43:48 -0700 |
commit | 7c6ee8f4073a5b8fd9cc065f225c9f09f21ee4a1 (patch) | |
tree | f3fdedfcf6a045ac24be12ac62023ed9b3c24782 /main.go | |
parent | 98d72c9b94b5dda9a987dfe41552f00512d43574 (diff) |
added soft thread limits. they are not physically archived yet
Diffstat (limited to 'main.go')
-rw-r--r-- | main.go | 598 |
1 files changed, 299 insertions, 299 deletions
@@ -21,7 +21,7 @@ import ( "bufio" "io" "github.com/gofrs/uuid" - "crypto/sha256" + "crypto/sha256" "encoding/hex" ) @@ -68,7 +68,7 @@ func main() { *Key = CreateKey(32) FollowingBoards = GetActorFollowingDB(db, Domain) - + Boards = GetBoardCollection(db) // root actor is used to follow remote feeds that are not local @@ -76,16 +76,16 @@ func main() { if GetConfigValue("instancename") != "" { CreateNewBoardDB(db, *CreateNewActor("", GetConfigValue("instancename"), GetConfigValue("instancesummary"), authReq, false)) if PublicIndexing == "true" { - AddInstanceToIndex(Domain) + AddInstanceToIndex(Domain) } } - + // Allow access to public media folder fileServer := http.FileServer(http.Dir("./public")) http.Handle("/public/", http.StripPrefix("/public", neuter(fileServer))) javascriptFiles := http.FileServer(http.Dir("./static")) - http.Handle("/static/", http.StripPrefix("/static", neuter(javascriptFiles))) + http.Handle("/static/", http.StripPrefix("/static", neuter(javascriptFiles))) // main routing http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request){ @@ -101,7 +101,7 @@ func main() { var mainInbox bool var mainOutbox bool var mainFollowing bool - var mainFollowers bool + var mainFollowers bool var actorMain bool var actorInbox bool @@ -110,22 +110,22 @@ func main() { var actorPost bool var actorFollowing bool var actorFollowers bool - var actorReported bool + var actorReported bool var actorVerification bool var actorMainPage bool var accept = r.Header.Get("Accept") - + var method = r.Method var actor = GetActorFromPath(db, path, "/") if actor.Name == "main" { - mainActor = (path == "/") + mainActor = (path == "/") mainInbox = (path == "/inbox") mainOutbox = (path == "/outbox") mainFollowing = (path == "/following") - mainFollowers = (path == "/followers") + mainFollowers = (path == "/followers") } else { actorMain = (path == "/" + actor.Name) actorInbox = (path == "/" + actor.Name + "/inbox") @@ -133,7 +133,7 @@ func main() { actorOutbox = (path == "/" + actor.Name + "/outbox") actorFollowing = (path == "/" + actor.Name + "/following") actorFollowers = (path == "/" + actor.Name + "/followers") - actorReported = (path == "/" + actor.Name + "/reported") + actorReported = (path == "/" + actor.Name + "/reported") actorVerification = (path == "/" + actor.Name + "/verification") escapedActorName := strings.Replace(actor.Name, "*", "\\*", -1) @@ -141,15 +141,15 @@ func main() { escapedActorName = strings.Replace(escapedActorName, "$", "\\$", -1) escapedActorName = strings.Replace(escapedActorName, "?", "\\?", -1) escapedActorName = strings.Replace(escapedActorName, "+", "\\+", -1) - escapedActorName = strings.Replace(escapedActorName, ".", "\\.", -1) + escapedActorName = strings.Replace(escapedActorName, ".", "\\.", -1) re := regexp.MustCompile("/" + escapedActorName + "/[0-9]{1,2}$") actorMainPage = re.MatchString(path) - + re = regexp.MustCompile("/" + escapedActorName + "/\\w+") - - actorPost = re.MatchString(path) + + actorPost = re.MatchString(path) } if mainActor { @@ -159,27 +159,27 @@ func main() { } IndexGet(w, r, db) - + return } - + if mainInbox { if method == "POST" { - + } else { - w.WriteHeader(http.StatusForbidden) + w.WriteHeader(http.StatusForbidden) w.Write([]byte("404 no path")) } return } - + if mainOutbox { if method == "GET" { GetActorOutbox(w, r, db) } else if method == "POST" { ParseOutboxRequest(w, r, db) } else { - w.WriteHeader(http.StatusForbidden) + w.WriteHeader(http.StatusForbidden) w.Write([]byte("404 no path")) } return @@ -198,17 +198,17 @@ func main() { if actorMain || actorMainPage { if acceptActivity(accept) { GetActorInfo(w, db, actor.Id) - return + return } - postNum := strings.Replace(r.URL.EscapedPath(), "/" + actor.Name + "/", "", 1) + postNum := r.URL.Query().Get("page") - page, _ := strconv.Atoi(postNum) + page, _ := strconv.Atoi(postNum) collection, valid := WantToServePage(db, actor.Name, page) if valid { OutboxGet(w, r, db, collection) - } + } return } @@ -221,14 +221,14 @@ func main() { if actorFollowers { GetActorFollowers(w, db, actor.Id) return - } + } if actorInbox { if method == "POST" { ParseInboxRequest(w, r, db) } else { w.WriteHeader(http.StatusForbidden) - w.Write([]byte("404 no path")) + w.Write([]byte("404 no path")) } return } @@ -243,12 +243,12 @@ func main() { if actorOutbox { if method == "GET" { - GetActorOutbox(w, r, db) + GetActorOutbox(w, r, db) } else if method == "POST" { ParseOutboxRequest(w, r, db) } else { w.WriteHeader(http.StatusForbidden) - w.Write([]byte("404 no path")) + w.Write([]byte("404 no path")) } return } @@ -272,31 +272,31 @@ func main() { auth := CreateTripCode(verify.Code) auth = CreateTripCode(auth) - + if CreateTripCode(auth) == code { w.WriteHeader(http.StatusOK) } else { w.WriteHeader(http.StatusUnauthorized) } - - w.Write([]byte("")) + + w.Write([]byte("")) } //catch all if actorPost { - if acceptActivity(accept) { + if acceptActivity(accept) { GetActorPost(w, db, path) - return + return } PostGet(w, r, db) - return - } + return + } - w.WriteHeader(http.StatusForbidden) + w.WriteHeader(http.StatusForbidden) w.Write([]byte("404 no path")) }) - + http.HandleFunc("/news/", func(w http.ResponseWriter, r *http.Request){ timestamp := r.URL.Path[6:] @@ -308,10 +308,10 @@ func main() { if timestamp[len(timestamp)-1:] == "/" { timestamp = timestamp[:len(timestamp)-1] } - + ts, err := strconv.Atoi(timestamp) if err != nil { - w.WriteHeader(http.StatusForbidden) + w.WriteHeader(http.StatusForbidden) w.Write([]byte("404 no path")) } else { NewsGet(w, r, db, ts) @@ -328,7 +328,7 @@ func main() { fmt.Println("\n\nBlacklist post blocked\n\n") http.Redirect(w, r, Domain + "/", http.StatusMovedPermanently) return - } + } if(file != nil && header.Size > (7 << 20)){ w.Write([]byte("7MB max file size")) @@ -337,9 +337,9 @@ func main() { if(r.FormValue("inReplyTo") == "" && file == nil) { w.Write([]byte("Media is required for new posts")) - return + return } - + if(r.FormValue("inReplyTo") == "" || file == nil) { if(r.FormValue("comment") == "" && r.FormValue("subject") == ""){ @@ -356,25 +356,25 @@ func main() { if(len(r.FormValue("subject")) > 100 || len(r.FormValue("name")) > 100 || len(r.FormValue("options")) > 100) { w.Write([]byte("Name, Subject or Options limit 100 characters")) return - } + } if(r.FormValue("captcha") == "") { w.Write([]byte("Incorrect Captcha")) return - } - + } + b := bytes.Buffer{} we := multipart.NewWriter(&b) if(file != nil){ var fw io.Writer - + fw, err := we.CreateFormFile("file", header.Filename) CheckError(err, "error with form file create") _, err = io.Copy(fw, file) - + CheckError(err, "error with form file copy") } @@ -389,21 +389,21 @@ func main() { err := we.WriteField(key, name) CheckError(err, "error with writing name field") err = we.WriteField("tripcode", tripcode) - CheckError(err, "error with writing tripcode field") + CheckError(err, "error with writing tripcode field") }else{ err := we.WriteField(key, r0[0]) CheckError(err, "error with writing field") } } - + if(r.FormValue("inReplyTo") == "" && reply != ""){ err := we.WriteField("inReplyTo", reply) - CheckError(err, "error with writing inReplyTo field") + CheckError(err, "error with writing inReplyTo field") } - + we.Close() - sendTo := r.FormValue("sendTo") + sendTo := r.FormValue("sendTo") req, err := http.NewRequest("POST", sendTo, &b) CheckError(err, "error with post form req") @@ -417,16 +417,16 @@ func main() { defer resp.Body.Close() if(resp.StatusCode == 200){ - + body, _ := ioutil.ReadAll(resp.Body) - + var obj ObjectBase obj = ParseOptions(r, obj) for _, e := range obj.Option { if(e == "noko" || e == "nokosage"){ http.Redirect(w, r, Domain + "/" + r.FormValue("boardName") + "/" + shortURL(r.FormValue("sendTo"), string(body)) , http.StatusMovedPermanently) - return + return } } @@ -442,7 +442,7 @@ func main() { w.Write([]byte("Incorrect Captcha")) return } - + http.Redirect(w, r, Domain + "/" + r.FormValue("boardName"), http.StatusMovedPermanently) }) @@ -486,22 +486,22 @@ func main() { if following.MatchString(follow) { followingActor := FingerActor(follow) col := GetActorCollection(followingActor.Following) - + var nObj ObjectBase nObj.Id = followingActor.Id col.Items = append(col.Items, nObj) - + for _, e := range col.Items { if !IsAlreadyFollowing(db, actorId, e.Id) && e.Id != Domain && e.Id != actorId { followActivity := MakeFollowActivity(db, actorId, e.Id) if FingerActor(e.Id).Id != "" { MakeActivityRequestOutbox(db, followActivity) - } + } } } - + //follow all of boards followers } else if followers.MatchString(follow){ followersActor := FingerActor(follow) @@ -510,17 +510,17 @@ func main() { var nObj ObjectBase nObj.Id = followersActor.Id - col.Items = append(col.Items, nObj) - + col.Items = append(col.Items, nObj) + for _, e := range col.Items { if !IsAlreadyFollowing(db, actorId, e.Id) && e.Id != Domain && e.Id != actorId { followActivity := MakeFollowActivity(db, actorId, e.Id) if FingerActor(e.Id).Id != "" { MakeActivityRequestOutbox(db, followActivity) - } + } } } - + //do a normal follow to a single board } else { followActivity := MakeFollowActivity(db, actorId, follow) @@ -531,16 +531,16 @@ func main() { } if FingerActor(follow).Id != ""{ - MakeActivityRequestOutbox(db, followActivity) + MakeActivityRequestOutbox(db, followActivity) } } - + var redirect string if(actor.Name != "main") { redirect = "/" + actor.Name - } - - http.Redirect(w, r, "/" + *Key + "/" + redirect, http.StatusSeeOther) + } + + http.Redirect(w, r, "/" + *Key + "/" + redirect, http.StatusSeeOther) } else if manage && actor.Name != "" { t := template.Must(template.New("").Funcs(template.FuncMap{ "sub": func (i, j int) int { return i - j }}).ParseFiles("./static/main.html", "./static/manage.html")) @@ -577,7 +577,7 @@ func main() { r.ID = e.ID r.Reason = e.Reason reports = append(reports, r) - } + } var adminData AdminPage adminData.Following = following @@ -599,11 +599,11 @@ func main() { t.ExecuteTemplate(w, "layout", adminData) - + } else if admin || actor.Id == Domain { t := template.Must(template.New("").Funcs(template.FuncMap{ - "sub": func (i, j int) int { return i - j }}).ParseFiles("./static/main.html", "./static/nadmin.html")) - + "sub": func (i, j int) int { return i - j }}).ParseFiles("./static/main.html", "./static/nadmin.html")) + actor := GetActor(Domain) follow := GetActorCollection(actor.Following).Items follower := GetActorCollection(actor.Followers).Items @@ -628,12 +628,12 @@ func main() { adminData.Board.ModCred,_ = GetPasswordFromSession(r) adminData.Boards = Boards - + adminData.Board.Post.Actor = actor.Id - adminData.PostBlacklist = GetRegexBlacklistDB(db) + adminData.PostBlacklist = GetRegexBlacklistDB(db) - t.ExecuteTemplate(w, "layout", adminData) + t.ExecuteTemplate(w, "layout", adminData) } }) @@ -642,9 +642,9 @@ func main() { actor := GetActorFromDB(db, Domain) if !HasValidation(w, r, actor) { - return + return } - + var newActorActivity Activity var board Actor r.ParseForm() @@ -655,7 +655,7 @@ func main() { } else { restrict = false } - + board.Name = r.FormValue("name") board.PreferredUsername = r.FormValue("prefname") board.Summary = r.FormValue("summary") @@ -671,12 +671,12 @@ func main() { newActorActivity.Object.Alias = board.Name newActorActivity.Object.Name = board.PreferredUsername newActorActivity.Object.Summary = board.Summary - newActorActivity.Object.Sensitive = board.Restricted + newActorActivity.Object.Sensitive = board.Restricted MakeActivityRequestOutbox(db, newActorActivity) - http.Redirect(w, r, "/" + *Key, http.StatusSeeOther) + http.Redirect(w, r, "/" + *Key, http.StatusSeeOther) }) - + http.HandleFunc("/" + *Key + "/postnews", func(w http.ResponseWriter, r *http.Request) { actor := GetActorFromDB(db, Domain) @@ -684,17 +684,17 @@ func main() { if !HasValidation(w, r, actor) { return } - + var newsitem NewsItem - + newsitem.Title = r.FormValue("title") newsitem.Content = template.HTML(r.FormValue("summary")) - + WriteNewsToDB(db, newsitem) - - http.Redirect(w, r, "/", http.StatusSeeOther) + + http.Redirect(w, r, "/", http.StatusSeeOther) }) - + http.HandleFunc("/" + *Key + "/newsdelete/", func(w http.ResponseWriter, r *http.Request){ actor := GetActorFromDB(db, Domain) @@ -702,13 +702,13 @@ func main() { if !HasValidation(w, r, actor) { return } - + timestamp := r.URL.Path[13+len(*Key):] - + tsint, err := strconv.Atoi(timestamp) - + if(err != nil){ - w.WriteHeader(http.StatusForbidden) + w.WriteHeader(http.StatusForbidden) w.Write([]byte("404 no path")) return } else { @@ -728,12 +728,12 @@ func main() { verify.Code = code j, _ := json.Marshal(&verify) - + req, err := http.NewRequest("POST", Domain + "/auth", bytes.NewBuffer(j)) CheckError(err, "error making verify req") - req.Header.Set("Content-Type", activitystreams) + req.Header.Set("Content-Type", activitystreams) resp, err := http.DefaultClient.Do(req) @@ -747,15 +747,15 @@ func main() { if(resp.StatusCode != 200) { t := template.Must(template.ParseFiles("./static/verify.html")) - t.Execute(w, "wrong password " + verify.Code) + t.Execute(w, "wrong password " + verify.Code) } else { - + sessionToken, _ := uuid.NewV4() _, err := cache.Do("SETEX", sessionToken, "86400", body + "|" + verify.Code) if err != nil { t := template.Must(template.ParseFiles("./static/verify.html")) - t.Execute(w, "") + t.Execute(w, "") return } @@ -765,18 +765,18 @@ func main() { Expires: time.Now().UTC().Add(60 * 60 * 48 * time.Second), }) - http.Redirect(w, r, "/", http.StatusSeeOther) + http.Redirect(w, r, "/", http.StatusSeeOther) } } else { w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("404 no path")) + w.Write([]byte("404 no path")) } }) http.HandleFunc("/banmedia", func(w http.ResponseWriter, r *http.Request) { id := r.URL.Query().Get("id") board := r.URL.Query().Get("board") - + _, auth := GetPasswordFromSession(r) if id == "" || auth == "" { @@ -788,7 +788,7 @@ func main() { col := GetCollectionFromID(id) if len(col.OrderedItems) > 0 { - + actor := col.OrderedItems[0].Actor if !HasAuth(db, auth, actor) { @@ -796,7 +796,7 @@ func main() { w.Write([]byte("")) return } - + if len(col.OrderedItems[0].Attachment) > 0 { re := regexp.MustCompile(Domain) file := re.ReplaceAllString(col.OrderedItems[0].Attachment[0].Href, "") @@ -812,7 +812,7 @@ func main() { if err != nil { fmt.Println("error readin bytes for setting media ban") } - + if !IsMediaBanned(db, f) { query := `insert into bannedmedia (hash) values ($1)` @@ -825,8 +825,8 @@ func main() { var obj ObjectBase obj.Id = id obj.Actor = actor - - isOP := CheckIfObjectOP(db, obj.Id) + + isOP := CheckIfObjectOP(db, obj.Id) var OP string if len(col.OrderedItems[0].InReplyTo) > 0 { @@ -859,13 +859,13 @@ func main() { } } w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) - }) + w.Write([]byte("")) + }) http.HandleFunc("/delete", func(w http.ResponseWriter, r *http.Request){ id := r.URL.Query().Get("id") board := r.URL.Query().Get("board") - + _, auth := GetPasswordFromSession(r) if id == "" || auth == "" { @@ -883,7 +883,7 @@ func main() { w.Write([]byte("")) return } - + if !CheckIfObjectOP(db, id) { TombstoneObject(db, id) } else { @@ -898,7 +898,7 @@ func main() { return } } - + actor := col.OrderedItems[0].Actor if !HasAuth(db, auth, actor) { @@ -910,8 +910,8 @@ func main() { var obj ObjectBase obj.Id = id obj.Actor = actor - - isOP := CheckIfObjectOP(db, obj.Id) + + isOP := CheckIfObjectOP(db, obj.Id) var OP string if len(col.OrderedItems[0].InReplyTo) > 0 { @@ -943,15 +943,15 @@ func main() { http.Redirect(w, r, "/" + board, http.StatusSeeOther) return } - + w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) + w.Write([]byte("")) }) http.HandleFunc("/deleteattach", func(w http.ResponseWriter, r *http.Request){ - + id := r.URL.Query().Get("id") - board := r.URL.Query().Get("board") + board := r.URL.Query().Get("board") _, auth := GetPasswordFromSession(r) @@ -960,8 +960,8 @@ func main() { w.Write([]byte("")) return } - - manage := r.URL.Query().Get("manage") + + manage := r.URL.Query().Get("manage") col := GetCollectionFromID(id) if len(col.OrderedItems) < 1 { @@ -970,12 +970,12 @@ func main() { w.Write([]byte("")) return } - + DeleteAttachmentFromFile(db, id) TombstoneAttachmentFromDB(db, id) - + DeletePreviewFromFile(db, id) - TombstonePreviewFromDB(db, id) + TombstonePreviewFromDB(db, id) if(manage == "t"){ http.Redirect(w, r, "/" + *Key + "/" + board , http.StatusSeeOther) @@ -985,7 +985,7 @@ func main() { return } } - + actor := col.OrderedItems[0].Actor var OP string @@ -994,7 +994,7 @@ func main() { } else { OP = id } - + if !HasAuth(db, auth, actor) { w.WriteHeader(http.StatusBadRequest) w.Write([]byte("")) @@ -1003,10 +1003,10 @@ func main() { DeleteAttachmentFromFile(db, id) TombstoneAttachmentFromDB(db, id) - + DeletePreviewFromFile(db, id) TombstonePreviewFromDB(db, id) - + if (manage == "t") { http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) return @@ -1019,13 +1019,13 @@ func main() { } w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) + w.Write([]byte("")) }) http.HandleFunc("/marksensitive", func(w http.ResponseWriter, r *http.Request){ - + id := r.URL.Query().Get("id") - board := r.URL.Query().Get("board") + board := r.URL.Query().Get("board") _, auth := GetPasswordFromSession(r) @@ -1034,7 +1034,7 @@ func main() { w.Write([]byte("")) return } - + col := GetCollectionFromID(id) if len(col.OrderedItems) < 1 { @@ -1045,11 +1045,11 @@ func main() { } MarkObjectSensitive(db, id, true) - + http.Redirect(w, r, "/" + board, http.StatusSeeOther) return } - + actor := col.OrderedItems[0].Actor var OP string @@ -1058,7 +1058,7 @@ func main() { } else { OP = id } - + if !HasAuth(db, auth, actor) { w.WriteHeader(http.StatusBadRequest) w.Write([]byte("")) @@ -1076,14 +1076,14 @@ func main() { } w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) - }) + w.Write([]byte("")) + }) http.HandleFunc("/remove", func(w http.ResponseWriter, r *http.Request){ id := r.URL.Query().Get("id") manage := r.URL.Query().Get("manage") board := r.URL.Query().Get("board") - col := GetCollectionFromID(id) + col := GetCollectionFromID(id) actor := col.OrderedItems[0].Actor _, auth := GetPasswordFromSession(r) @@ -1102,8 +1102,8 @@ func main() { var obj ObjectBase obj.Id = id obj.Actor = actor - - isOP := CheckIfObjectOP(db, obj.Id) + + isOP := CheckIfObjectOP(db, obj.Id) var OP string if len(col.OrderedItems[0].InReplyTo) > 0 { @@ -1131,17 +1131,17 @@ func main() { http.Redirect(w, r, "/" + board, http.StatusSeeOther) return } - + w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) + w.Write([]byte("")) }) http.HandleFunc("/removeattach", func(w http.ResponseWriter, r *http.Request){ - + id := r.URL.Query().Get("id") - manage := r.URL.Query().Get("manage") - board := r.URL.Query().Get("board") - col := GetCollectionFromID(id) + manage := r.URL.Query().Get("manage") + board := r.URL.Query().Get("board") + col := GetCollectionFromID(id) actor := col.OrderedItems[0].Actor var OP string @@ -1150,7 +1150,7 @@ func main() { } else { OP = id } - + _, auth := GetPasswordFromSession(r) if id == "" || auth == "" { @@ -1167,7 +1167,7 @@ func main() { SetAttachmentFromDB(db, id, "Removed") SetPreviewFromDB(db, id, "Removed") - + if (manage == "t") { http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) return @@ -1180,8 +1180,8 @@ func main() { } w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) - }) + w.Write([]byte("")) + }) http.HandleFunc("/report", func(w http.ResponseWriter, r *http.Request){ @@ -1204,10 +1204,10 @@ func main() { if(close != "1" && !CheckCaptcha(db, captcha)) { w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("captcha required")) - return + w.Write([]byte("captcha required")) + return } - + if close == "1" { if !HasAuth(db, auth, actor.Id) { w.WriteHeader(http.StatusBadRequest) @@ -1216,14 +1216,14 @@ func main() { } if !IsIDLocal(db, id) { - CloseLocalReportDB(db, id, board) + CloseLocalReportDB(db, id, board) http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) - return + return } reported := DeleteReportActivity(db, id) if reported { - http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) + http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) return } @@ -1235,17 +1235,17 @@ func main() { if !IsIDLocal(db, id) { CreateLocalReportDB(db, id, board, reason) http.Redirect(w, r, "/" + board + "/" + remoteShort(id), http.StatusSeeOther) - return + return } - + reported := ReportActivity(db, id, reason) if reported { - http.Redirect(w, r, id, http.StatusSeeOther) + http.Redirect(w, r, id, http.StatusSeeOther) return } w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) + w.Write([]byte("")) }) http.HandleFunc("/auth", func(w http.ResponseWriter, r *http.Request){ @@ -1266,7 +1266,7 @@ func main() { } w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("")) + w.Write([]byte("")) }) http.HandleFunc("/.well-known/webfinger", func(w http.ResponseWriter, r *http.Request) { @@ -1274,7 +1274,7 @@ func main() { if(len(acct) < 1) { w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("resource needs a value")) + w.Write([]byte("resource needs a value")) return } @@ -1284,7 +1284,7 @@ func main() { if(len(actorDomain) < 2) { w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("accpets only subject form of acct:board@instance")) + w.Write([]byte("accpets only subject form of acct:board@instance")) return } @@ -1296,13 +1296,13 @@ func main() { if !IsActorLocal(db, TP + "" + actorDomain[1] + "" + actorDomain[0]) { w.WriteHeader(http.StatusBadRequest) - w.Write([]byte("actor not local")) + w.Write([]byte("actor not local")) return } var finger Webfinger var link WebfingerLink - + finger.Subject = "acct:" + actorDomain[0] + "@" + actorDomain[1] link.Rel = "self" link.Type = "application/activity+json" @@ -1314,7 +1314,7 @@ func main() { w.Header().Set("Content-Type", activitystreams) w.Write(enc) - + }) http.HandleFunc("/addtoindex", func(w http.ResponseWriter, r *http.Request) { @@ -1348,10 +1348,10 @@ func main() { testCase := r.FormValue("testCase") if regex == "" { - http.Redirect(w, r, "/", http.StatusSeeOther) + http.Redirect(w, r, "/", http.StatusSeeOther) return } - + r.ParseForm() re := regexp.MustCompile(regex) @@ -1362,9 +1362,9 @@ func main() { WriteRegexBlacklistDB(db, regex) } } - - http.Redirect(w, r, "/" + *Key + "#regex", http.StatusSeeOther) - }) + + http.Redirect(w, r, "/" + *Key + "#regex", http.StatusSeeOther) + }) http.HandleFunc("/api/media", func(w http.ResponseWriter, r *http.Request) { if r.URL.Query().Get("hash") != "" { @@ -1380,30 +1380,30 @@ func main() { board := r.URL.Query().Get("board") actor := GetActorByNameFromDB(db, board) - + SetActorAutoSubscribeDB(db, actor.Id) autoSub := GetActorAutoSubscribeDB(db, actor.Id) if autoSub { AutoFollow(db, actor.Id) } - - http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) - }) + + http.Redirect(w, r, "/" + *Key + "/" + board, http.StatusSeeOther) + }) fmt.Println("Server for " + Domain + " running on port " + Port) fmt.Println("Mod key: " + *Key) PrintAdminAuth(db) - - http.ListenAndServe(Port, nil) + + http.ListenAndServe(Port, nil) } func CheckError(e error, m string) error{ if e != nil { - fmt.Println() + fmt.Println() fmt.Println(m) - fmt.Println() + fmt.Println() panic(e) } @@ -1417,7 +1417,7 @@ func ConnectDB() *sql.DB { user := GetConfigValue("dbuser") password := GetConfigValue("dbpass") dbname := GetConfigValue("dbname") - + psqlInfo := fmt.Sprintf("host=%s port=%d user=%s password=%s " + "dbname=%s sslmode=disable", host, port, user, password, dbname) @@ -1436,20 +1436,20 @@ func CreateKey(len int) string { var key string str := (CreateTripCode(RandomID(len))) for i := 0; i < len; i++ { - key += fmt.Sprintf("%c", str[i]) + key += fmt.Sprintf("%c", str[i]) } return key } func neuter(next http.Handler) http.Handler { - return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { - if strings.HasSuffix(r.URL.Path, "/") { - http.NotFound(w, r) - return - } + return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { + if strings.HasSuffix(r.URL.Path, "/") { + http.NotFound(w, r) + return + } - next.ServeHTTP(w, r) - }) + next.ServeHTTP(w, r) + }) } func CreateTripCode(input string) string { @@ -1485,10 +1485,10 @@ func GetActorFromPath(db *sql.DB, location string, prefix string) Actor { var nActor Actor - nActor = GetActorByNameFromDB(db, actor) + nActor = GetActorByNameFromDB(db, actor) if nActor.Id == "" { - nActor = GetActorByName(db, actor) + nActor = GetActorByName(db, actor) } return nActor @@ -1497,7 +1497,7 @@ func GetActorFromPath(db *sql.DB, location string, prefix string) Actor { func GetContentType(location string) string { elements := strings.Split(location, ";") if len(elements) > 0 { - return elements[0] + return elements[0] } else { return location } @@ -1511,16 +1511,16 @@ func RandomID(size int) string { for i := 0; i < rng; i++ { newID += string(domain[rand.Intn(len(domain))]) } - + return newID } func CreateUniqueID(db *sql.DB, actor string) string { - var newID string + var newID string isUnique := false for !isUnique { newID = RandomID(8) - + query := fmt.Sprintf("select id from activitystream where id='%s/%s/%s'", Domain, actor, newID) rows, err := db.Query(query) @@ -1533,12 +1533,12 @@ func CreateUniqueID(db *sql.DB, actor string) string { for rows.Next(){ count += 1 } - + if count < 1 { isUnique = true } } - + return newID } @@ -1578,7 +1578,7 @@ func GetActorInfo(w http.ResponseWriter, db *sql.DB, id string) { func GetActorPost(w http.ResponseWriter, db *sql.DB, path string) { collection := GetCollectionFromPath(db, Domain + "" + path) if len(collection.OrderedItems) > 0 { - enc, _ := json.MarshalIndent(collection, "", "\t") + enc, _ := json.MarshalIndent(collection, "", "\t") w.Header().Set("Content-Type", "application/ld+json; profile=\"https://www.w3.org/ns/activitystreams\"") w.Write(enc) } @@ -1597,7 +1597,7 @@ func CreateObject(objType string) ObjectBase { func AddFollowersToActivity(db *sql.DB, activity Activity) Activity{ activity.To = append(activity.To, activity.Actor.Id) - + for _, e := range activity.To { aFollowers := GetActorCollection(e + "/followers") for _, k := range aFollowers.Items { @@ -1606,11 +1606,11 @@ func AddFollowersToActivity(db *sql.DB, activity Activity) Activity{ } var nActivity Activity - + for _, e := range activity.To { var alreadyTo = false for _, k := range nActivity.To { - if e == k || e == activity.Actor.Id { + if e == k || e == activity.Actor.Id { alreadyTo = true } } @@ -1618,17 +1618,17 @@ func AddFollowersToActivity(db *sql.DB, activity Activity) Activity{ if !alreadyTo { nActivity.To = append(nActivity.To, e) } - } + } + + activity.To = nActivity.To - activity.To = nActivity.To - return activity } func CreateActivity(activityType string, obj ObjectBase) Activity { var newActivity Activity actor := FingerActor(obj.Actor) - + newActivity.AtContext.Context = "https://www.w3.org/ns/activitystreams" newActivity.Type = activityType newActivity.Published = obj.Published @@ -1642,10 +1642,10 @@ func CreateActivity(activityType string, obj ObjectBase) Activity { } for _, e := range obj.Cc { - if obj.Actor != e { + if obj.Actor != e { newActivity.Cc = append(newActivity.Cc, e) } - } + } return newActivity } @@ -1722,7 +1722,7 @@ func CreateAttachmentObject(file multipart.File, header *multipart.FileHeader) ( var nAttachment []ObjectBase var image ObjectBase - + image.Type = "Attachment" image.Name = filename image.Href = Domain + "/" + tempFile.Name() @@ -1737,18 +1737,18 @@ func CreateAttachmentObject(file multipart.File, header *multipart.FileHeader) ( func ParseCommentForReplies(db *sql.DB, comment string, op string) []ObjectBase { - re := regexp.MustCompile(`(>>(https?://[A-Za-z0-9_.:\-~]+\/[A-Za-z0-9_.\-~]+\/)(f[A-Za-z0-9_.\-~]+-)?([A-Za-z0-9_.\-~]+)?#?([A-Za-z0-9_.\-~]+)?)`) + re := regexp.MustCompile(`(>>(https?://[A-Za-z0-9_.:\-~]+\/[A-Za-z0-9_.\-~]+\/)(f[A-Za-z0-9_.\-~]+-)?([A-Za-z0-9_.\-~]+)?#?([A-Za-z0-9_.\-~]+)?)`) match := re.FindAllStringSubmatch(comment, -1) var links []string for i:= 0; i < len(match); i++ { str := strings.Replace(match[i][0], ">>", "", 1) - str = strings.Replace(str, "www.", "", 1) + str = strings.Replace(str, "www.", "", 1) str = strings.Replace(str, "http://", "", 1) - str = strings.Replace(str, "https://", "", 1) + str = strings.Replace(str, "https://", "", 1) str = TP + "" + str - _ , isReply := IsReplyToOP(db, op, str) + _ , isReply := IsReplyToOP(db, op, str) if !IsInStringArray(links, str) && isReply { links = append(links, str) } @@ -1776,7 +1776,7 @@ func CheckValidActivity(id string) (Collection, bool) { } req, err := http.NewRequest("GET", id, nil) - + if err != nil { fmt.Println("error with request") panic(err) @@ -1788,7 +1788,7 @@ func CheckValidActivity(id string) (Collection, bool) { if err != nil { fmt.Println("error with response") - panic(err) + panic(err) } defer resp.Body.Close() @@ -1866,7 +1866,7 @@ func GetActorCollection(collection string) Collection { resp, err := RouteProxy(req) if err != nil { - fmt.Println("error with getting actor collection resp " + collection) + fmt.Println("error with getting actor collection resp " + collection) return nCollection } @@ -1875,13 +1875,13 @@ func GetActorCollection(collection string) Collection { if resp.StatusCode == 200 { body, _ := ioutil.ReadAll(resp.Body) - if len(body) > 0 { + if len(body) > 0 { err = json.Unmarshal(body, &nCollection) - + CheckError(err, "error getting actor collection from body " + collection) } } - + return nCollection } @@ -1893,7 +1893,7 @@ func IsValidActor(id string) (Actor, bool) { return actor, true; } - return actor, false; + return actor, false; } func IsActivityLocal(db *sql.DB, activity Activity) bool { @@ -1918,7 +1918,7 @@ func IsActivityLocal(db *sql.DB, activity Activity) bool { func IsIDLocal(db *sql.DB, id string) bool { activity := GetActivityFromDB(db, id) - return len(activity.OrderedItems) > 0 + return len(activity.OrderedItems) > 0 } func IsActorLocal(db *sql.DB, id string) bool { @@ -1957,22 +1957,22 @@ func IsObjectCached(db *sql.DB, id string) bool { var nID string defer rows.Close() rows.Next() - rows.Scan(&nID) + rows.Scan(&nID) if nID == "" { return false } - return true + return true } func GetObjectFromActivity(activity Activity) ObjectBase { - return *activity.Object + return *activity.Object } func MakeCaptchas(db *sql.DB, total int) { difference := total - GetCaptchaTotal(db) - + for i := 0; i < difference; i++ { CreateNewCaptcha(db) } @@ -2011,9 +2011,9 @@ func SupportedMIMEType(mime string) bool { return true } } - + return false -} +} func DeleteReportActivity(db *sql.DB, id string) bool { @@ -2025,7 +2025,7 @@ func DeleteReportActivity(db *sql.DB, id string) bool { CheckError(err, "error closing reported activity") return false } - + return true } @@ -2038,7 +2038,7 @@ func ReportActivity(db *sql.DB, id string, reason string) bool { actor := GetActivityFromDB(db, id) query := `select count from reported where id=$1` - + rows, err := db.Query(query, id) CheckError(err, "could not select count from reported") @@ -2058,13 +2058,13 @@ func ReportActivity(db *sql.DB, id string, reason string) bool { CheckError(err, "error inserting new reported activity") return false } - + } else { count = count + 1 query = `update reported set count=$1 where id=$2` _, err := db.Exec(query, count, id) - + if err != nil { CheckError(err, "error updating reported activity") return false @@ -2090,7 +2090,7 @@ func GetActorReported(w http.ResponseWriter, r *http.Request, db *sql.DB, id str w.Write([]byte("")) return } - + var following Collection following.AtContext.Context = "https://www.w3.org/ns/activitystreams" @@ -2098,7 +2098,7 @@ func GetActorReported(w http.ResponseWriter, r *http.Request, db *sql.DB, id str following.TotalItems = GetActorReportedTotal(db, id) following.Items = GetActorReportedDB(db, id) - enc, _ := json.MarshalIndent(following, "", "\t") + enc, _ := json.MarshalIndent(following, "", "\t") w.Header().Set("Content-Type", activitystreams) w.Write(enc) } @@ -2112,10 +2112,10 @@ func MakeActivityRequestOutbox(db *sql.DB, activity Activity) { req, err := http.NewRequest("POST", activity.Actor.Outbox, bytes.NewBuffer(j)) - CheckError(err, "error with sending activity req to outbox") + CheckError(err, "error with sending activity req to outbox") re := regexp.MustCompile("https?://(www.)?") - + var instance string if activity.Actor.Id == Domain { instance = re.ReplaceAllString(Domain, "") @@ -2132,16 +2132,16 @@ func MakeActivityRequestOutbox(db *sql.DB, activity Activity) { sig := fmt.Sprintf("(request-target): %s %s\nhost: %s\ndate: %s", "post", path, instance, date) encSig, err := ActivitySign(db, *activity.Actor, sig) CheckError(err, "unable to sign activity response") - signature := fmt.Sprintf("keyId=\"%s\",headers=\"(request-target) host date\",signature=\"%s\"", activity.Actor.PublicKey.Id, encSig) - - req.Header.Set("Content-Type", activitystreams) + signature := fmt.Sprintf("keyId=\"%s\",headers=\"(request-target) host date\",signature=\"%s\"", activity.Actor.PublicKey.Id, encSig) + + req.Header.Set("Content-Type", activitystreams) req.Header.Set("Date", date) req.Header.Set("Signature", signature) req.Host = instance _, err = RouteProxy(req) - CheckError(err, "error with sending activity resp to") + CheckError(err, "error with sending activity resp to") } func MakeActivityRequest(db *sql.DB, activity Activity) { @@ -2150,7 +2150,7 @@ func MakeActivityRequest(db *sql.DB, activity Activity) { for _, e := range activity.To { if e != activity.Actor.Id { - + actor := FingerActor(e) if actor.Id != "" { @@ -2164,7 +2164,7 @@ func MakeActivityRequest(db *sql.DB, activity Activity) { date := time.Now().UTC().Format(time.RFC1123) path := strings.Replace(actor.Inbox, instance, "", 1) - + re := regexp.MustCompile("https?://(www.)?") path = re.ReplaceAllString(path, "") @@ -2173,7 +2173,7 @@ func MakeActivityRequest(db *sql.DB, activity Activity) { CheckError(err, "unable to sign activity response") signature := fmt.Sprintf("keyId=\"%s\",headers=\"(request-target) host date\",signature=\"%s\"", activity.Actor.PublicKey.Id, encSig) - req.Header.Set("Content-Type", activitystreams) + req.Header.Set("Content-Type", activitystreams) req.Header.Set("Date", date) req.Header.Set("Signature", signature) req.Host = instance @@ -2183,21 +2183,21 @@ func MakeActivityRequest(db *sql.DB, activity Activity) { if err != nil { fmt.Println("error with sending activity resp to actor " + instance) } - } + } } } - } + } } func GetCollectionFromID(id string) Collection { var nColl Collection - + req, err := http.NewRequest("GET", id, nil) CheckError(err, "could not get collection from id req") - req.Header.Set("Accept", activitystreams) - + req.Header.Set("Accept", activitystreams) + resp, err := RouteProxy(req) if err != nil { @@ -2247,11 +2247,11 @@ func PrintAdminAuth(db *sql.DB){ var code string var identifier string - + rows.Next() rows.Scan(&identifier, &code) - fmt.Println("Admin Login: " + identifier + ", Code: " + code) + fmt.Println("Admin Login: " + identifier + ", Code: " + code) } func IsInStringArray(array []string, value string) bool { @@ -2266,10 +2266,10 @@ func IsInStringArray(array []string, value string) bool { func GetUniqueFilename(_type string) string { id := RandomID(8) file := "/public/" + id + "." + _type - + for true { if _, err := os.Stat("." + file); err == nil { - id = RandomID(8) + id = RandomID(8) file = "/public/" + id + "." + _type }else{ return "/public/" + id + "." + _type @@ -2307,18 +2307,18 @@ func DeleteObjectRequest(db *sql.DB, id string) { func DeleteObjectAndRepliesRequest(db *sql.DB, id string) { var nObj ObjectBase - var nActor Actor + var nActor Actor nObj.Id = id nObj.Actor = nActor.Id - + activity := CreateActivity("Delete", nObj) - + obj := GetObjectByIDFromDB(db, id) activity.Actor.Id = obj.OrderedItems[0].Actor activity.Object = &obj.OrderedItems[0] - + followers := GetActorFollowDB(db, obj.OrderedItems[0].Actor) for _, e := range followers { activity.To = append(activity.To, e.Id) @@ -2327,7 +2327,7 @@ func DeleteObjectAndRepliesRequest(db *sql.DB, id string) { following := GetActorFollowingDB(db, obj.OrderedItems[0].Actor) for _, e := range following { activity.To = append(activity.To, e.Id) - } + } MakeActivityRequest(db, activity) } @@ -2343,13 +2343,13 @@ func ResizeAttachmentToPreview(db *sql.DB) { defer rows.Close() for rows.Next() { - var id string + var id string var href string var mediatype string var name string var size int var published string - + rows.Scan(&id, &href, &mediatype, &name, &size, &published) re := regexp.MustCompile(`^\w+`) @@ -2368,20 +2368,20 @@ func ResizeAttachmentToPreview(db *sql.DB) { re = regexp.MustCompile(`/\w+$`) actor := re.ReplaceAllString(id, "") - + nPreview.Type = "Preview" - nPreview.Id = fmt.Sprintf("%s/%s", actor, CreateUniqueID(db, actor)) + nPreview.Id = fmt.Sprintf("%s/%s", actor, CreateUniqueID(db, actor)) nPreview.Name = name nPreview.Href = Domain + "" + nHref nPreview.MediaType = mediatype nPreview.Size = int64(size) nPreview.Published = published - nPreview.Updated = published + nPreview.Updated = published re = regexp.MustCompile(`/public/.+`) objFile := re.FindString(href) - + if(id != "") { cmd := exec.Command("convert", "." + objFile ,"-resize", "250x250>", "-strip", "." + nHref) @@ -2390,10 +2390,10 @@ func ResizeAttachmentToPreview(db *sql.DB) { CheckError(err, "error with resize attachment preview") if err == nil { - fmt.Println(objFile + " -> " + nHref) + fmt.Println(objFile + " -> " + nHref) WritePreviewToDB(db, nPreview) UpdateObjectWithPreview(db, id, nPreview.Id) - } + } } } } @@ -2409,7 +2409,7 @@ func UpdateObjectWithPreview(db *sql.DB, id string, preview string) { } func ParseCommentForReply(comment string) string { - + re := regexp.MustCompile(`(>>(https?://[A-Za-z0-9_.:\-~]+\/[A-Za-z0-9_.\-~]+\/)(f[A-Za-z0-9_.\-~]+-)?([A-Za-z0-9_.\-~]+)?#?([A-Za-z0-9_.\-~]+)?)`) match := re.FindAllStringSubmatch(comment, -1) @@ -2427,7 +2427,7 @@ func ParseCommentForReply(comment string) string { return links[0] } } - + return "" } @@ -2453,7 +2453,7 @@ func GetActorCollectionReq(r *http.Request, collection string) Collection { req.Header.Set("Accept", activitystreams) - req.Header.Set("Authorization", "Basic " + pass) + req.Header.Set("Authorization", "Basic " + pass) resp, err := RouteProxy(req) @@ -2469,7 +2469,7 @@ func GetActorCollectionReq(r *http.Request, collection string) Collection { CheckError(err, "error getting actor collection from body " + collection) } - + return nCollection } @@ -2496,8 +2496,8 @@ func shortURL(actorName string, url string) string { if(temp == actor){ id := localShort(op) - re := regexp.MustCompile(`.+\/`) - replyCheck := re.FindString(reply) + re := regexp.MustCompile(`.+\/`) + replyCheck := re.FindString(reply) if(reply != "" && replyCheck == actor){ id = id + "#" + localShort(reply) @@ -2505,20 +2505,20 @@ func shortURL(actorName string, url string) string { id = id + "#" + remoteShort(reply) } - return id; + return id; }else{ id := remoteShort(op) - re := regexp.MustCompile(`.+\/`) - replyCheck := re.FindString(reply) + re := regexp.MustCompile(`.+\/`) + replyCheck := re.FindString(reply) if(reply != "" && replyCheck == actor){ id = id + "#" + localShort(reply) } else if reply != "" { id = id + "#" + remoteShort(reply) - } + } - return id; + return id; } } @@ -2578,18 +2578,18 @@ func RunDatabaseSchema(db *sql.DB) { query, err := ioutil.ReadFile("databaseschema.psql") CheckError(err, "could not read databaseschema.psql file") if _, err := db.Exec(string(query)); err != nil { - CheckError(err, "could not exec databaseschema.psql") + CheckError(err, "could not exec databaseschema.psql") } } func CreatedNeededDirectories() { if _, err := os.Stat("./public"); os.IsNotExist(err) { - os.Mkdir("./public", 0755) + os.Mkdir("./public", 0755) } if _, err := os.Stat("./pem/board"); os.IsNotExist(err) { - os.MkdirAll("./pem/board", 0700) - } + os.MkdirAll("./pem/board", 0700) + } } //looks for actor with pattern of board@instance @@ -2606,10 +2606,10 @@ func FingerActor(path string) Actor{ if ActorCache[actor + "@" + instance].Id != "" { nActor = ActorCache[actor + "@" + instance] } else { - r := FingerRequest(actor, instance) + r := FingerRequest(actor, instance) if r != nil && r.StatusCode == 200 { defer r.Body.Close() - + body, _ := ioutil.ReadAll(r.Body) err := json.Unmarshal(body, &nActor) @@ -2617,7 +2617,7 @@ func FingerActor(path string) Actor{ CheckError(err, "error getting fingerrequet resp from json body") ActorCache[actor + "@" + instance] = nActor - } + } } return nActor @@ -2639,7 +2639,7 @@ func FingerRequest(actor string, instance string) (*http.Response){ if resp.StatusCode == 200 { defer resp.Body.Close() - + body, _ := ioutil.ReadAll(resp.Body) err := json.Unmarshal(body, &finger) @@ -2651,11 +2651,11 @@ func FingerRequest(actor string, instance string) (*http.Response){ for _, e := range finger.Links { if(e.Type == "application/activity+json"){ req, err := http.NewRequest("GET", e.Href, nil) - + CheckError(err, "could not get finger request from id req") - req.Header.Set("Accept", activitystreams) - + req.Header.Set("Accept", activitystreams) + resp, err := RouteProxy(req) return resp } @@ -2683,7 +2683,7 @@ func GetActorInstance(path string) (string, string) { if(len(match) > 2) { return "main", match[3] } - } + } re = regexp.MustCompile(`(https?://)?(www)?([\w\d-_.:]+)\/([\w\d-_.]+)(\/([\w\d-_.]+))?`) httpFormat := re.MatchString(path) @@ -2694,7 +2694,7 @@ func GetActorInstance(path string) (string, string) { if match[4] == "users" { return match[6], match[3] } - + return match[4], match[3] } } @@ -2708,7 +2708,7 @@ func AddInstanceToIndex(actor string) { if re.MatchString(actor) { return } - + followers := GetCollectionFromID("https://fchan.xyz/followers") var alreadyIndex = false @@ -2725,14 +2725,14 @@ func AddInstanceToIndex(actor string) { _, err = http.DefaultClient.Do(req) - CheckError(err, "error with add instance to actor index resp") + CheckError(err, "error with add instance to actor index resp") } } func AddInstanceToIndexDB(db *sql.DB, actor string) { time.Sleep(15 * time.Second) - + followers := GetCollectionFromID("https://fchan.xyz/followers") var alreadyIndex = false @@ -2745,7 +2745,7 @@ func AddInstanceToIndexDB(db *sql.DB, actor string) { checkActor := GetActor(actor) if checkActor.Id == actor { - if !alreadyIndex { + if !alreadyIndex { query := `insert into follower (id, follower) values ($1, $2)` _, err := db.Exec(query, "https://fchan.xyz", actor) @@ -2776,7 +2776,7 @@ func GetCollectionFromReq(path string) Collection { if err != nil { panic(err) - } + } return respCollection } @@ -2809,7 +2809,7 @@ func RouteImages(w http.ResponseWriter, media string) { fileBytes, err := ioutil.ReadFile("./static/notfound.png") CheckError(err, "could not get /static/notfound.png file bytes") - + w.Write(fileBytes) return } @@ -2818,12 +2818,12 @@ func RouteImages(w http.ResponseWriter, media string) { body, _ := ioutil.ReadAll(resp.Body) for name, values := range resp.Header { - for _, value := range values { - w.Header().Set(name, value) + for _, value := range values { + w.Header().Set(name, value) } } - - w.Write(body) + + w.Write(body) } func IsPostBlacklist(db *sql.DB, comment string) bool { @@ -2842,9 +2842,9 @@ func IsPostBlacklist(db *sql.DB, comment string) bool { func HasValidation(w http.ResponseWriter, r *http.Request, actor Actor) bool { id, _ := GetPasswordFromSession(r) - + if id == "" || (id != actor.Id && id != Domain) { - http.Redirect(w, r, "/", http.StatusSeeOther) + http.Redirect(w, r, "/", http.StatusSeeOther) return false } @@ -2865,20 +2865,20 @@ func IsReplyToOP(db *sql.DB, op string, link string) (string, bool) { link = re.ReplaceAllString(link, "") link = "%" + match[1] + "/" + link } - + query := `select id from replies where id like $1 and inreplyto=$2` rows, err := db.Query(query, link, op) CheckError(err, "error selecting in reply to op from db") - var id string + var id string defer rows.Close() rows.Next() rows.Scan(&id) if id != "" { - + return id, true } |