aboutsummaryrefslogtreecommitdiff
path: root/auth/server.go
diff options
context:
space:
mode:
authorVidhu Kant Sharma <vidhukant@vidhukant.com>2023-11-24 20:10:31 +0530
committerVidhu Kant Sharma <vidhukant@vidhukant.com>2023-11-24 20:10:31 +0530
commit9016476f2a5051fd72dbe35d0c7bce13b4b6d55b (patch)
treee2b2db69b12aabd8db1657530ee1b8289768e3a2 /auth/server.go
parent854e5250c672c002bd5362c1312325e4abe5ca89 (diff)
not prematurely killing the server before showing message in browser upon loginv1.21.0
Diffstat (limited to 'auth/server.go')
-rw-r--r--auth/server.go60
1 files changed, 41 insertions, 19 deletions
diff --git a/auth/server.go b/auth/server.go
index 0f2496e..5bce2aa 100644
--- a/auth/server.go
+++ b/auth/server.go
@@ -19,51 +19,73 @@ along with this program. If not, see <http://www.gnu.org/licenses/>.
package auth
import (
+ "context"
"net/http"
"net/url"
+ "html"
"encoding/json"
"os"
"fmt"
+ "errors"
)
func listen(clientId, verifier string) {
- http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
- code, codeExists := r.URL.Query()["code"]
+ mux := http.NewServeMux()
+ server := &http.Server{Addr: ":8000", Handler: mux}
+
+ mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+ code, codeExists := r.URL.Query()["code"]
if codeExists {
- accessToken, refreshToken, expiresIn := requestToken(clientId, verifier, code[0])
- setToken(accessToken)
- setRefreshToken(refreshToken)
- setExpiresIn(expiresIn)
- fmt.Println("\x1b[32mYou have successfully logged into macli.\x1b[0m")
- fmt.Println("\x1b[32mYou can close the web browser tab now.\x1b[0m")
- os.Exit(0)
+ err := getToken(clientId, verifier, code[0])
+ if err != nil {
+ fmt.Fprintf(w, "<p>An error occoured while logging in: %s</p>", html.EscapeString(err.Error()))
+
+ fmt.Println("Error while requesting an access token from MyAnimeList:", err)
+ } else {
+ fmt.Fprintf(w, "<p>Login successful! You may close this tab now.</p>")
+
+ fmt.Println("\x1b[32mYou have successfully logged into macli.\x1b[0m")
+ fmt.Println("\x1b[32mYou can close the web browser tab now.\x1b[0m")
+ }
+ } else {
+ fmt.Fprintf(w, "<p>An error occoured while logging in (invalid request)</p>")
+
+ fmt.Println("An error occoured while logging in (invalid request)")
}
+
+ go server.Shutdown(context.Background())
})
- err := http.ListenAndServe(":8000", nil)
- if err != nil {
+ err := server.ListenAndServe()
+ if err != nil && err != http.ErrServerClosed {
fmt.Println("There was an error initialising the server", err.Error())
os.Exit(1)
}
}
-func requestToken(clientId, verifier, code string) (string, string, string) {
+func getToken(clientId, verifier, code string) error {
data := url.Values{
- "client_id": {clientId},
- "code_verifier": {verifier},
- "grant_type": {"authorization_code"},
- "code": {code},
+ "client_id": {clientId},
+ "code_verifier": {verifier},
+ "grant_type": {"authorization_code"},
+ "code": {code},
}
resp, err := http.PostForm("https://myanimelist.net/v1/oauth2/token", data)
if err != nil {
- fmt.Println("Error while requesting an access token:", err)
- os.Exit(1)
+ return err
}
var res map[string]interface{}
json.NewDecoder(resp.Body).Decode(&res)
- return fmt.Sprintf("%v", res["access_token"]), fmt.Sprintf("%v", res["refresh_token"]), fmt.Sprintf("%v", res["expires_in"])
+ if res["error"] != nil {
+ return errors.New(fmt.Sprintf("%v (%v)", res["message"], res["error"]))
+ }
+
+ setToken(fmt.Sprintf("%v", res["access_token"]))
+ //setRefreshToken(refreshToken)
+ //setExpiresIn(expiresIn)
+ return nil
}