import osmAuth from "osm-auth" import { Store, Stores, UIEventSource } from "../UIEventSource" import { OsmPreferences } from "./OsmPreferences" import { ChangesetHandler } from "./ChangesetHandler" import { ElementStorage } from "../ElementStorage" import Svg from "../../Svg" import Img from "../../UI/Base/Img" import { Utils } from "../../Utils" import { OsmObject } from "./OsmObject" import { Changes } from "./Changes" export default class UserDetails { public loggedIn = false public name = "Not logged in" public uid: number public csCount = 0 public img: string public unreadMessages = 0 public totalMessages = 0 home: { lon: number; lat: number } public backend: string constructor(backend: string) { this.backend = backend } } export class OsmConnection { public static readonly oauth_configs = { osm: { oauth_consumer_key: "hivV7ec2o49Two8g9h8Is1VIiVOgxQ1iYexCbvem", oauth_secret: "wDBRTCem0vxD7txrg1y6p5r8nvmz8tAhET7zDASI", url: "https://www.openstreetmap.org", }, "osm-test": { oauth_consumer_key: "Zgr7EoKb93uwPv2EOFkIlf3n9NLwj5wbyfjZMhz2", oauth_secret: "3am1i1sykHDMZ66SGq4wI2Z7cJMKgzneCHp3nctn", url: "https://master.apis.dev.openstreetmap.org", }, } public auth public userDetails: UIEventSource public isLoggedIn: Store public loadingStatus = new UIEventSource<"not-attempted" | "loading" | "error" | "logged-in">( "not-attempted" ) public preferencesHandler: OsmPreferences public readonly _oauth_config: { oauth_consumer_key: string oauth_secret: string url: string } private readonly _dryRun: UIEventSource private fakeUser: boolean private _onLoggedIn: ((userDetails: UserDetails) => void)[] = [] private readonly _iframeMode: Boolean | boolean private readonly _singlePage: boolean private isChecking = false constructor(options: { dryRun?: UIEventSource fakeUser?: false | boolean oauth_token?: UIEventSource // Used to keep multiple changesets open and to write to the correct changeset singlePage?: boolean osmConfiguration?: "osm" | "osm-test" attemptLogin?: true | boolean }) { this.fakeUser = options.fakeUser ?? false this._singlePage = options.singlePage ?? true this._oauth_config = OsmConnection.oauth_configs[options.osmConfiguration ?? "osm"] ?? OsmConnection.oauth_configs.osm console.debug("Using backend", this._oauth_config.url) OsmObject.SetBackendUrl(this._oauth_config.url + "/") this._iframeMode = Utils.runningFromConsole ? false : window !== window.top this.userDetails = new UIEventSource( new UserDetails(this._oauth_config.url), "userDetails" ) if (options.fakeUser) { const ud = this.userDetails.data ud.csCount = 5678 ud.loggedIn = true ud.unreadMessages = 0 ud.name = "Fake user" ud.totalMessages = 42 } const self = this this.isLoggedIn = this.userDetails.map((user) => user.loggedIn) this.isLoggedIn.addCallback((isLoggedIn) => { if (self.userDetails.data.loggedIn == false && isLoggedIn == true) { // We have an inconsistency: the userdetails say we _didn't_ log in, but this actor says we do // This means someone attempted to toggle this; so we attempt to login! self.AttemptLogin() } }) this._dryRun = options.dryRun ?? new UIEventSource(false) this.updateAuthObject() this.preferencesHandler = new OsmPreferences(this.auth, this) if (options.oauth_token?.data !== undefined) { console.log(options.oauth_token.data) const self = this this.auth.bootstrapToken( options.oauth_token.data, (x) => { console.log("Called back: ", x) self.AttemptLogin() }, this.auth ) options.oauth_token.setData(undefined) } if (this.auth.authenticated() && options.attemptLogin !== false) { this.AttemptLogin() // Also updates the user badge } else { console.log("Not authenticated") } } public CreateChangesetHandler(allElements: ElementStorage, changes: Changes) { return new ChangesetHandler(this._dryRun, this, allElements, changes, this.auth) } public GetPreference( key: string, defaultValue: string = undefined, prefix: string = "mapcomplete-" ): UIEventSource { return this.preferencesHandler.GetPreference(key, defaultValue, prefix) } public GetLongPreference(key: string, prefix: string = "mapcomplete-"): UIEventSource { return this.preferencesHandler.GetLongPreference(key, prefix) } public OnLoggedIn(action: (userDetails: UserDetails) => void) { this._onLoggedIn.push(action) } public LogOut() { this.auth.logout() this.userDetails.data.loggedIn = false this.userDetails.data.csCount = 0 this.userDetails.data.name = "" this.userDetails.ping() console.log("Logged out") this.loadingStatus.setData("not-attempted") } public Backend(): string { return this._oauth_config.url } public AttemptLogin() { this.loadingStatus.setData("loading") if (this.fakeUser) { this.loadingStatus.setData("logged-in") console.log("AttemptLogin called, but ignored as fakeUser is set") return } const self = this console.log("Trying to log in...") this.updateAuthObject() this.auth.xhr( { method: "GET", path: "/api/0.6/user/details", }, function (err, details) { if (err != null) { console.log(err) self.loadingStatus.setData("error") if (err.status == 401) { console.log("Clearing tokens...") // Not authorized - our token probably got revoked // Reset all the tokens const tokens = [ "https://www.openstreetmap.orgoauth_request_token_secret", "https://www.openstreetmap.orgoauth_token", "https://www.openstreetmap.orgoauth_token_secret", ] tokens.forEach((token) => localStorage.removeItem(token)) } return } if (details == null) { self.loadingStatus.setData("error") return } self.CheckForMessagesContinuously() // details is an XML DOM of user details let userInfo = details.getElementsByTagName("user")[0] // let moreDetails = new DOMParser().parseFromString(userInfo.innerHTML, "text/xml"); let data = self.userDetails.data data.loggedIn = true console.log("Login completed, userinfo is ", userInfo) data.name = userInfo.getAttribute("display_name") data.uid = Number(userInfo.getAttribute("id")) data.csCount = userInfo.getElementsByTagName("changesets")[0].getAttribute("count") data.img = undefined const imgEl = userInfo.getElementsByTagName("img") if (imgEl !== undefined && imgEl[0] !== undefined) { data.img = imgEl[0].getAttribute("href") } data.img = data.img ?? Img.AsData(Svg.osm_logo) const homeEl = userInfo.getElementsByTagName("home") if (homeEl !== undefined && homeEl[0] !== undefined) { const lat = parseFloat(homeEl[0].getAttribute("lat")) const lon = parseFloat(homeEl[0].getAttribute("lon")) data.home = { lat: lat, lon: lon } } self.loadingStatus.setData("logged-in") const messages = userInfo .getElementsByTagName("messages")[0] .getElementsByTagName("received")[0] data.unreadMessages = parseInt(messages.getAttribute("unread")) data.totalMessages = parseInt(messages.getAttribute("count")) self.userDetails.ping() for (const action of self._onLoggedIn) { action(self.userDetails.data) } self._onLoggedIn = [] } ) } public closeNote(id: number | string, text?: string): Promise { let textSuffix = "" if ((text ?? "") !== "") { textSuffix = "?text=" + encodeURIComponent(text) } if (this._dryRun.data) { console.warn("Dryrun enabled - not actually closing note ", id, " with text ", text) return new Promise((ok) => { ok() }) } return new Promise((ok, error) => { this.auth.xhr( { method: "POST", path: `/api/0.6/notes/${id}/close${textSuffix}`, }, function (err, _) { if (err !== null) { error(err) } else { ok() } } ) }) } public reopenNote(id: number | string, text?: string): Promise { if (this._dryRun.data) { console.warn("Dryrun enabled - not actually reopening note ", id, " with text ", text) return new Promise((ok) => { ok() }) } let textSuffix = "" if ((text ?? "") !== "") { textSuffix = "?text=" + encodeURIComponent(text) } return new Promise((ok, error) => { this.auth.xhr( { method: "POST", path: `/api/0.6/notes/${id}/reopen${textSuffix}`, }, function (err, _) { if (err !== null) { error(err) } else { ok() } } ) }) } public openNote(lat: number, lon: number, text: string): Promise<{ id: number }> { if (this._dryRun.data) { console.warn("Dryrun enabled - not actually opening note with text ", text) return new Promise<{ id: number }>((ok) => { window.setTimeout( () => ok({ id: Math.floor(Math.random() * 1000) }), Math.random() * 5000 ) }) } const auth = this.auth const content = { lat, lon, text } return new Promise((ok, error) => { auth.xhr( { method: "POST", path: `/api/0.6/notes.json`, options: { header: { "Content-Type": "application/json" }, }, content: JSON.stringify(content), }, function (err, response: string) { console.log("RESPONSE IS", response) if (err !== null) { error(err) } else { const parsed = JSON.parse(response) const id = parsed.properties.id console.log("OPENED NOTE", id) ok({ id }) } } ) }) } public addCommentToNote(id: number | string, text: string): Promise { if (this._dryRun.data) { console.warn("Dryrun enabled - not actually adding comment ", text, "to note ", id) return new Promise((ok) => { ok() }) } if ((text ?? "") === "") { throw "Invalid text!" } return new Promise((ok, error) => { this.auth.xhr( { method: "POST", path: `/api/0.6/notes/${id}/comment?text=${encodeURIComponent(text)}`, }, function (err, _) { if (err !== null) { error(err) } else { ok() } } ) }) } private updateAuthObject() { let pwaStandAloneMode = false try { if (Utils.runningFromConsole) { pwaStandAloneMode = true } else if ( window.matchMedia("(display-mode: standalone)").matches || window.matchMedia("(display-mode: fullscreen)").matches ) { pwaStandAloneMode = true } } catch (e) { console.warn( "Detecting standalone mode failed", e, ". Assuming in browser and not worrying furhter" ) } const standalone = this._iframeMode || pwaStandAloneMode || !this._singlePage // In standalone mode, we DON'T use single page login, as 'redirecting' opens a new window anyway... // Same for an iframe... this.auth = new osmAuth({ oauth_consumer_key: this._oauth_config.oauth_consumer_key, oauth_secret: this._oauth_config.oauth_secret, url: this._oauth_config.url, landing: standalone ? undefined : window.location.href, singlepage: !standalone, auto: true, }) } private CheckForMessagesContinuously() { const self = this if (this.isChecking) { return } this.isChecking = true Stores.Chronic(5 * 60 * 1000).addCallback((_) => { if (self.isLoggedIn.data) { console.log("Checking for messages") self.AttemptLogin() } }) } }